Node.js中如何通过stompit.ConnectFailover检测ActiveMQ连接状态？

我之前在使用stompit连接ActiveMQ时也碰到过一模一样的问题——ConnectFailover本身没有提供直接的属性来判断代理是否已经成功连接，它的设计是自动处理重连逻辑，所以得靠事件监听来感知连接状态的变化。

核心问题分析 #

stompit.ConnectFailover是一个连接管理器，它会自动尝试连接你添加的服务器列表，并且在连接断开后自动重试。但它不会主动暴露一个“已连接”的状态标识，你需要通过它提供的事件来捕获连接成功、失败或断开的时机。

解决方案：通过事件监听连接状态 #

下面是修改后的代码示例，加入了关键的事件监听，并且调整了订阅逻辑的时机：

var stompit = require('stompit');

// 创建连接管理器
var connectionManager = new stompit.ConnectFailover();
connectionManager.addServer({
  'host': 'localhost',
  'port': 61623,
  'connectHeaders': {
    'host': '/',
    'login': 'admin', // 替换成你的ActiveMQ用户名
    'passcode': 'admin', // 替换成你的ActiveMQ密码
    'heart-beat': '5000,5000' // 开启心跳，帮助检测连接存活
  }
});

// 监听【连接成功】事件：当成功连接到代理时触发
connectionManager.on('connect', function(connection) {
  console.log('✅ 成功连接到ActiveMQ代理:', connection.serverProperties.brokerName);
  
  // 连接成功后再创建Channel并执行订阅操作
  var channel = new stompit.Channel(connectionManager);
  
  var subscribeHeaders = {
    'destination': '/queue/test',
    'ack': 'client'
  };
  
  channel.subscribe(subscribeHeaders, function(error, message) {
    if (error) {
      console.error('❌ 订阅失败:', error.message);
      return;
    }
    
    // 读取消息内容
    message.readString('utf-8', function(error, body) {
      if (error) {
        console.error('❌ 读取消息失败:', error.message);
        message.nack(); // 读取失败时拒绝消息
        return;
      }
      
      console.log('📥 收到消息:', body);
      message.ack(); // 手动确认消息（因为ack设置为client）
    });
  });
});

// 监听【连接失败】事件：当尝试连接代理失败时触发
connectionManager.on('error', function(error) {
  console.error('❌ 连接ActiveMQ失败:', error.message);
  // ConnectFailover会自动重试连接，这里可以记录错误日志或者触发告警
});

// 监听【连接断开】事件：当与代理的连接意外断开时触发
connectionManager.on('disconnect', function() {
  console.log('🔌 与ActiveMQ的连接已断开，正在自动重试...');
});

关键注意点 #

1. 不要提前执行订阅操作：如果在创建connectionManager后立即创建Channel并订阅，此时可能还未建立连接，stompit会将请求排队，但通过connect事件触发后再执行，可以更明确地控制逻辑流程。
2. 开启心跳检测：配置heart-beat可以帮助ConnectFailover及时检测到连接是否存活，避免出现“假连接”的情况。
3. 错误处理不能少：无论是连接阶段还是消息处理阶段，都要捕获错误并处理，比如订阅失败、消息读取失败时的日志记录和消息确认/拒绝操作。

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