ColdFusion 2021复用RabbitMQ连接时APPLICATION scope读取异常求助

我们在ColdFusion 2021环境中复用RabbitMQ连接以避免每次新建，实现了以下代码：

客户端调用代码 #

<cfset rabbitClient = new RabbitClientFactory().getRabbitClient("customers")>

RabbitClientFactory.cfc实现代码 #

component {
    VARIABLES.instance = {
        vhosts = {
            "customers" = "amqp://insert_real_uri_here"
        }
    };

    public function getRabbitClient(required string vhost) {
        if (!structKeyExists(APPLICATION, "rabbitClients")) {
            APPLICATION.rabbitClients = {};
        }

        if (!structKeyExists(APPLICATION.rabbitClients, vhost)) {
            APPLICATION.rabbitClients[vhost] = new RabbitClient(uri = VARIABLES.instance.vhosts[vhost]);
        }

        return APPLICATION.rabbitClients[vhost];
    }
}

代码大部分时间运行正常，但每天会出现数次以下错误：

Element CUSTOMERS is undefined in a CFML structure referenced as part of an expression.

堆栈跟踪指向getRabbitClient方法的return语句。我们已经排除以下情况：

• 应用超时：错误发生频率过高，不符合超时特征
• RabbitClient初始化返回null：init方法声明返回RabbitClient类型，若返回null会更早触发错误，已模拟验证排除
• 手动无法复现该错误

排查思路 #

• 并发竞态条件：ColdFusion的APPLICATION作用域是多线程共享的，多个请求同时进入getRabbitClient方法时可能出现竞争。比如第一个请求检查到元素不存在开始创建实例，第二个请求此时也完成检查并尝试创建；若第一个请求创建过程中出现异常，可能导致元素未被正确存入结构，甚至破坏结构。建议给关键逻辑加排他锁：

public function getRabbitClient(required string vhost) {
    // 初始化全局结构时加锁
    if (!structKeyExists(APPLICATION, "rabbitClients")) {
        <cflock name="initRabbitClientsLock" type="exclusive" timeout="5">
            if (!structKeyExists(APPLICATION, "rabbitClients")) {
                APPLICATION.rabbitClients = {};
            }
        </cflock>
    }

    // 创建实例时加锁
    <cflock name="rabbitClientLock_#vhost#" type="exclusive" timeout="5">
        if (!structKeyExists(APPLICATION.rabbitClients, vhost)) {
            APPLICATION.rabbitClients[vhost] = new RabbitClient(uri = VARIABLES.instance.vhosts[vhost]);
        }
    </cflock>

    return APPLICATION.rabbitClients[vhost];
}

• 元素被意外移除：检查是否有其他代码（如清理脚本、错误处理逻辑）在修改APPLICATION.rabbitClients结构，删除其中的元素。可以在return前增加检查并记录日志：

public function getRabbitClient(required string vhost) {
    // 原有初始化和创建逻辑...

    <cflock name="checkRabbitClientLock_#vhost#" type="read" timeout="5">
        if (!structKeyExists(APPLICATION.rabbitClients, vhost)) {
            writeLog(file="rabbitMQDebug", text="#now()# - 意外情况：APPLICATION.rabbitClients中不存在#vhost#，将重新创建");
            // 重新创建实例
            APPLICATION.rabbitClients[vhost] = new RabbitClient(uri = VARIABLES.instance.vhosts[vhost]);
        }
    </cflock>

    return APPLICATION.rabbitClients[vhost];
}

• ColdFusion作用域异常：极端情况下（如内存不足、类加载异常），APPLICATION作用域的结构可能出现元素丢失。监控服务器内存使用情况，查看是否有内存溢出或GC频繁的现象。
• 初始化隐藏异常：尽管init方法声明返回RabbitClient，但初始化过程中可能存在未捕获的异常，导致实例未被正确存入结构。添加try-catch块记录异常：

<cflock name="rabbitClientLock_#vhost#" type="exclusive" timeout="5">
    if (!structKeyExists(APPLICATION.rabbitClients, vhost)) {
        try {
            APPLICATION.rabbitClients[vhost] = new RabbitClient(uri = VARIABLES.instance.vhosts[vhost]);
        } catch (any e) {
            writeLog(file="rabbitMQErrors", text="#now()# - 创建#vhost#的RabbitClient失败：#e.message#，堆栈：#e.stacktrace#");
            throw e;
        }
    }
</cflock>

内容的提问来源于stack exchange，提问作者Steve