如何让ActiveMQ Artemis终端消费者保持活跃且不按消息计数关闭

完全可以实现和Kafka一样的持久活跃消费者，你当前遇到的消费指定数量后自动关闭连接的情况，是自定义的消息计数逻辑导致的，并非ActiveMQ Artemis本身的限制。

实现方式： #

• 移除计数终止逻辑
  你现有代码里应该存在判断消费数量达到阈值（比如1000条）就主动关闭消费者的逻辑，把这部分删除即可。例如：
  原计数终止代码：

  int consumedCount = 0;
  while (consumedCount < 1000) {
      Message msg = consumer.receive();
      // 消息处理逻辑
      consumedCount++;
  }
  consumer.close(); // 触发关闭的代码
  

  修改为持续消费：

  while (true) {
      Message msg = consumer.receive();
      if (msg != null) {
          // 消息处理逻辑
      }
  }
  // 不主动调用close()，除非手动触发
  

• 推荐使用异步消费模式
  通过注册MessageHandler实现异步监听，这种模式下消费者会持续运行，直到你手动调用关闭方法：

  consumer.setMessageHandler(message -> {
      // 处理消息的业务逻辑
  });
  
  // 阻塞主线程，防止程序退出
  CountDownLatch keepAliveLatch = new CountDownLatch(1);
  keepAliveLatch.await();
  

• 添加手动关闭触发机制
  要实现手动控制停止，可添加控制台输入监听、JMX控制或信号量触发等逻辑。比如通过控制台输入指令关闭：

  Scanner consoleScanner = new Scanner(System.in);
  new Thread(() -> {
      while (consoleScanner.hasNextLine()) {
          String input = consoleScanner.nextLine();
          if ("stop".equalsIgnoreCase(input)) {
              consumer.close();
              keepAliveLatch.countDown();
              break;
          }
      }
  }).start();
  

总结 #

ActiveMQ Artemis本身没有强制消费者达到特定消息量就关闭的默认行为，只要移除自定义的计数终止逻辑，改用持续消费的代码结构，就能实现和Kafka一致的持久活跃效果——消费者保持运行，仅在手动触发关闭时才停止连接。

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