springboot集成rocketmq

发送消息的几种模式：

• 同步发送：可靠性高，但延迟较高。
• 异步发送：提高性能，但需要额外处理回调。
• 单向发送：延迟最低，但没有消息确认。
• 顺序发送：保证消息顺序，但影响性能。
• 广播发送：每个消费者都消费消息，适用于广播场景。
• 事务消息：支持分布式事务，适合保证消息一致性。

springboot集成rocketmq的语法：

同步发送：

rocketMQTemplate.syncSend(topic, message)

异步发送：

rocketMQTemplate.asyncSend(topic, message, new SendCallback() {
      @Override
      public void onSuccess(SendResult sendResult) {
           System.out.println("Send success: " + sendResult);
     }

     @Override
     public void onException(Throwable e) {
          e.printStackTrace();
     }
});

单向发送：

rocketMQTemplate.sendOneWay(topic, message);

顺序发送：

// 使用 MessageQueueSelector 来控制消息发送到某个队列，从而保证顺序性
rocketMQTemplate.send(topic, message, new MessageQueueSelector() {
     @Override
     public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) {
           // 根据某个参数决定消息发送到哪个队列
          int index = Math.abs(msg.getKeys().hashCode()) % mqs.size();
          return mqs.get(index);
     }
});

广播发送:

rocketMQTemplate.setMessageModel(MessageModel.BROADCASTING);

事务消息:

 // 发送事务消息
SendResult sendResult = rocketMQTemplate.sendMessageInTransaction(topic, message, null);

tag的使用的坑：

使用相同的topic和group，使用不同的tag区分消息，会出现指定消费tagA的消息还会消费tagB的消息，

• 轮询消费
  是由于消息队列的负载均衡机制 和 消费者组的共享消费 导致的。虽然消费者配置了不同的 tag，消息队列的分配不受 tag 影响，导致多个消费者可能从相同的消息队列中获取不同 tag 的消息。
• 避免轮询消费
  可以通过调整消费者组配置、增加消息队列数量、确保每个消费者配置不同的 selectorExpression 来减少或避免轮询消费现象。
  参考：

https://www.jianshu.com/p/46eda2745258