单机下rocketmq只能被最新的实例消费

Question

微服务在本地开发的时候，不可避免会启动新的实例去注册到开发环境中，开发环境本身实例是在消费mq消息的，在启动新的实例后，就只会在新的实例中消费了，在新的实例关闭后，开发环境中的实例就没有在消费了

Answer 1

引自免费微信小程序：皆我百晓生

在单机环境下，RocketMQ消费者的行为受其消费模型影响。默认情况下，RocketMQ采用集群消费模式（Clustering Consumption），在这种模式下，一个Topic下的消息会均匀地分配给所有在线的消费者实例进行消费。当您在开发环境中启动新的消费者实例并注册到RocketMQ Nameserver时，新实例也会参与到消息消费中来，从而可能造成原来已存在的实例不再接收到消息。

针对您描述的问题，确保消息能被多个实例稳定消费的解决方案如下：

1. 确保消费模式设置正确：检查您的消费者配置，确保使用了集群消费模式（DefaultMQPushConsumer#setConsumeMode(Cluster consumeMode)）而非广播消费模式（Broadcasting Consumption）。

   DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroup");
   consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);
   // 设置消费模式为集群消费
   consumer.setMessageModel(MessageModel.CLUSTERING);
   

2. 避免消费者实例竞争问题：如果您希望所有实例都持续消费，而不是只由最新启动的实例消费，可以确保每个实例具有唯一的consumerID（即Consumer Group内不同的消费者标识）。在微服务架构中，通常可以通过应用实例ID或者环境变量等动态生成consumerID，确保它们在同一个Consumer Group下但有唯一标识。

3. 检查消费者状态：当新的实例关闭后，旧的实例应该重新开始消费。如果未实现，请检查旧实例是否还在正常运行且与Nameserver保持连接，并确认其消费状态没有异常。

4. 处理实例上线、下线逻辑：在微服务启动和停止时，应当适当地初始化和关闭RocketMQ消费者实例，确保即使实例重启或下线，也能平滑过渡，不影响整体的消息消费。

5. 持久化offset管理：RocketMQ默认提供了自动 offset 管理，但在某些情况下，如需保证消费进度在实例切换时不受影响，可考虑启用基于存储的OffsetStore实现，确保消息消费的连续性。

总结起来，要解决这个问题，主要是通过合理配置RocketMQ消费者的消费模式以及妥善处理消费者实例的生命周期管理，以确保在微服务实例动态变化时，消息能够均衡且持续地被所有实例消费。