ActiveMQ Pub/Sub模式下第二个消费者漏收消息问题咨询

这个场景我之前帮朋友排查过类似的，核心矛盾点很明确：Topic模式本应是广播分发（每个在线订阅者都能收到所有消息），但你的两个消费者同时在线时B会漏收，断开A后B就正常，这说明Broker或者客户端的订阅配置没按Topic的广播逻辑走。下面是最可能的几个原因和对应的解决办法：

1. 两个消费者使用了相同的clientId（最常见诱因） #

Stomp.js连接ActiveMQ时，如果两个客户端配置了相同的clientId，Broker会把它们当成同一个持久订阅者的重复实例。这种情况下，ActiveMQ不会按Topic的广播逻辑分发消息，反而会把消息路由到其中一个活跃连接（甚至可能交替发送，导致某一方漏收）。当你断开A后，B成为唯一的活跃实例，自然就能收到所有消息了。

解决办法： #

• 确保每个Stomp客户端的clientId是唯一的，比如用随机字符串或客户端的唯一标识（如浏览器SessionId）生成：

// Stomp.js连接时设置唯一clientId
const client = Stomp.client('ws://your-activemq-host:61614/stomp');
const uniqueClientId = 'consumer-' + Math.random().toString(36).substring(2, 10);
client.connect('admin', 'admin', () => {
  client.subscribe('/topic/your-topic', (message) => {
    console.log('Received:', message.body);
  }, { id: 'sub-' + uniqueClientId, clientId: uniqueClientId });
});

• 如果不需要持久订阅（消费者离线后不用接收错过的消息），可以直接不设置clientId，Broker会自动把它们当成临时订阅者，按Topic的广播逻辑处理。

2. 消费者的ACK模式配置错误 #

如果你的消费者使用了CLIENT_ACK模式，但没有手动确认消息，Broker会认为消息还没被处理，暂时停止向该消费者分发新消息，导致漏收。虽然Topic模式下不会把A的消息转交给B，但这种情况也可能表现为B接收不完整。

解决办法： #

• 不需要手动ACK的话，直接用默认的auto-ack模式（Stomp.js默认就是这个），订阅时不要显式设置ack: 'client'：

// 正确的临时订阅（auto-ack）
client.subscribe('/topic/your-topic', (message) => {
  console.log('Received:', message.body);
});

• 如果必须用CLIENT_ACK，一定要在处理完消息后调用message.ack()：

client.subscribe('/topic/your-topic', (message) => {
  console.log('Received:', message.body);
  message.ack(); // 必须手动确认消息
}, { ack: 'client' });

3. ActiveMQ的Topic分发策略被修改 #

极少数情况下，有人修改了ActiveMQ的dispatchPolicy，把Topic的分发策略改成了队列模式的负载均衡（比如RoundRobinDispatchPolicy），导致消息被轮询分发给订阅者，而不是广播。

解决办法： #

• 检查ActiveMQ的activemq.xml配置，确保Topic的分发策略是默认的BroadcastDispatchPolicy：

<destinationPolicy>
  <policyMap>
    <policyEntries>
      <policyEntry topic=">" >
        <!-- 确保这里是BroadcastDispatchPolicy，默认无需额外配置，若被修改则改回 -->
        <dispatchPolicy>
          <broadcastDispatchPolicy/>
        </dispatchPolicy>
      </policyEntry>
    </policyEntries>
  </policyMap>
</destinationPolicy>

4. Stomp客户端的网络或心跳问题 #

如果消费者B的网络较慢，或者客户端心跳配置不合理，Broker可能会误以为B离线，暂时停止向它发送消息。当A断开后，Broker的分发压力减小，B就能正常接收了。

解决办法： #

• 检查消费者B的网络连接，确保没有丢包或延迟过高；
• 在Stomp.js连接时设置合理的心跳参数，避免Broker误判客户端状态：

client.heartbeat.outgoing = 20000; // 每20秒发送一次心跳
client.heartbeat.incoming = 20000; // 每20秒接收一次心跳
client.connect(...);

建议你先排查clientId的问题，这是Topic订阅者漏消息最常见的原因。如果还是不行，可以开启ActiveMQ的DEBUG日志（设置log4j.logger.org.apache.activemq=DEBUG），查看Broker的消息分发日志，就能清晰看到消息发给了哪个订阅者，定位问题更精准。

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