RocketMQ——事务消息支持

RocketMQ的事务消息支持是通过Half Message机制实现的。

详细步骤如下：

1. 发送方发送半消息（Half Message）

发送方首先发送一条半消息，消息状态为"待确认"。发送成功后，执行本地事务逻辑。

2. 本地事务执行

发送方根据半消息执行本地事务逻辑，可能是数据库操作、文件操作等。本地事务执行成功后，发送方向RocketMQ发送确认消息或回滚消息。

3. 确认消息或回滚消息

如果本地事务执行成功，发送方向RocketMQ发送确认消息，将半消息标记为"已确认"；如果本地事务执行失败，发送方发送回滚消息，将半消息标记为"已回滚"。

4. 消费方消费消息

消费方消费已经确认的消息，处理业务逻辑。如果消息标记为"已回滚"，则不会被消费。

详细代码如下：

// 创建事务生产者
TransactionMQProducer producer = new TransactionMQProducer("transaction_producer_group");
producer.setNamesrvAddr("127.0.0.1:9876");

// 设置事务监听器
producer.setTransactionListener(new TransactionListenerImpl());

// 启动生产者
producer.start();

// 创建消息
Message msg = new Message("TopicTest", "TagA", "Hello RocketMQ".getBytes());

// 发送事务消息
SendResult sendResult = producer.sendMessageInTransaction(msg, null);

System.out.println(sendResult);

// 关闭生产者
producer.shutdown();

以上代码片段展示了如何使用RocketMQ的事务消息功能，通过设置事务监听器来处理本地事务逻辑，并发送确认消息或回滚消息，实现事务消息的可靠性传递。

原文链接: https://blog.csdn.net/2401_82884096/article/details/138597673