Java客户端调用RabbitMQ出现消息投递双实例未轮询问题

你贴出的是生产者侧代码，这段生产逻辑本身没有问题，问题集中在消费者侧的队列声明、绑定规则、消费配置上，常见原因和对应解决方法如下：

• 原因1：每个应用实例都声明了独立的、名称不同/随机生成的队列，并且都绑定到了同一个topic交换机、使用了相同的binding key

  Topic交换机会把匹配路由键的消息投递到所有符合绑定条件的队列，如果每个实例单独绑定专属队列，同一条消息自然会被投递到所有实例。
  解决方法：所有实例统一声明并消费同一个固定名称的共享队列，交换机仅绑定这一个共享队列即可。

• 原因2：已经使用了共享队列，但没有配置basicQos预取值，默认RabbitMQ会把消息一次性批量推给所有在线消费者，不会按消费速度轮询分发

  默认RabbitMQ的分发逻辑是盲发：只要消费者处于空闲状态就会推送消息，不会等消费者处理完上一条消息再发下一条，会出现分发不均、不符合轮询预期的情况。
  解决方法：消费者侧在启动消费前添加配置：

  // 每次只预取1条消息，处理完成ack后才会收到下一条，实现严格轮询
  channel.basicQos(1);
  

• 原因3：消费侧开启了自动ack，或者处理逻辑异常时没有正确处理ack，也会打乱正常分发逻辑
  解决方法：关闭自动ack，消息处理完成后手动调用channel.basicAck()确认消息消费成功。

快速验证方法 #

你可以登录RabbitMQ管理后台查看绑定关系：

• 查看exchange_name下绑定的队列数量，如果超过1个就是多队列绑定导致的多实例同时收消息的问题
• 查看单队列的消费者数量，正常应该等于你部署的应用实例数，确认所有消费者都连接在同一个共享队列上

另外你贴出的生产者代码也可以做优化，无需每次发消息都创建销毁Channel，Channel是轻量级但频繁创建销毁会产生不必要的性能损耗：

// 建议全局复用Channel实例，不要每次发布消息都新建、关闭
Channel channel = connection.createChannel();
// 第三个参数设为true，开启交换机持久化，服务重启后交换机不会丢失
channel.exchangeDeclare("exchange_name", "topic", true);
channel.basicPublish("exchange_name", "binding.key",
        MessageProperties.PERSISTENT_TEXT_PLAIN,
        message.getBytes());

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