Spring RabbitMQ多实例部署场景下如何获取全量消费者并跨实例操作监听器

该需求完全可以实现，你之前调整连接工厂配置无效是合理的：RabbitListenerEndpointRegistry 是Spring应用上下文内的本地Bean，每个实例独立维护自身的监听器状态，和RabbitMQ连接层的配置没有关系，天然只能查询到当前实例自身的监听队列。

你需要在应用层增加跨实例的状态同步与指令分发能力，不需要修改RabbitMQ侧的基础配置，分为全量监听器信息采集和跨实例监听器操作两个模块实现即可。

1. 全量监听器信息采集 #

两种常用实现方案可以二选一：

• 分布式状态上报方案：每个实例在创建、停止、恢复消费者时，将自身实例ID、监听队列列表、监听器ID、运行状态等元数据上报到统一的分布式存储（如Redis、Nacos、Consul），上报数据绑定实例心跳过期时间，实例下线后数据自动失效。查询全量监听信息时直接读取分布式存储的聚合数据即可，性能开销极低。
• 实例接口拉取方案：每个实例暴露内部查询接口GET /internal/listener/info，返回当前实例的所有监听队列与监听器元数据。查询全量信息时，先从服务注册中心拉取所有在线的应用实例列表，逐个调用每个实例的查询接口后聚合结果即可。

2. 跨实例移除队列监听器 #

基于上面的采集方案，配套实现指令分发能力即可：

• 定向调用方案：如果使用分布式状态上报方案，要移除指定队列的监听器时，先从分布式存储中查询到该队列对应的所有实例ID，逐个调用对应实例的内部移除接口即可。
• 广播通知方案：使用Redis Pub/Sub、RabbitMQ内部控制队列或者Spring Cloud Bus等广播组件，给所有实例下发移除指定队列监听器的指令，每个实例收到指令后判断自身是否存在对应队列的监听器，存在则执行停止、注销操作，操作完成后同步更新自身的上报状态。

实例本地暴露的内部移除监听器接口逻辑示例：

@Resource
private RabbitListenerEndpointRegistry rabbitListenerEndpointRegistry;

@PostMapping("/internal/listener/remove")
public boolean removeQueueListener(@RequestParam String targetQueueName) {
    for (MessageListenerContainer container : rabbitListenerEndpointRegistry.getListenerContainers()) {
        if (Arrays.asList(container.getQueueNames()).contains(targetQueueName)) {
            // 停止监听器容器
            container.stop();
            // 从注册表注销该监听器
            rabbitListenerEndpointRegistry.unregisterListenerContainer(container.getListenerId());
            // 这里同步更新上报到分布式存储的状态信息
            return true;
        }
    }
    // 当前实例无对应队列的监听器，直接返回
    return false;
}

• 内部操作接口要做好访问权限控制，仅允许集群内部节点调用，避免对外暴露产生安全风险
• 监听器操作逻辑要做幂等处理，避免重复下发指令产生异常
• 分布式存储中存储的实例监听状态要绑定心跳过期机制，避免实例异常下线后残留无效数据

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