RocketMQ 事务消息

RocketMQ 事务消息可以保证消息和本地事务的一致性。本节将学习 RocketMQ 事务消息。

本节将学习：事务消息原理、事务消息实现、消息回查，以及使用场景。

事务消息原理

原理说明

事务消息原理：

• 两阶段提交
• 半消息机制
• 事务状态回查

流程图

事务消息实现

实现方式

@Autowired
private RocketMQTemplate rocketMQTemplate;

public void sendTransactionMessage(String topic, String message) {
    TransactionSendResult result = rocketMQTemplate.sendMessageInTransaction(
        topic,
        MessageBuilder.withPayload(message).build(),
        null
    );
}

消息回查

回查机制

消息回查： Broker 定期回查事务状态，确保消息最终一致性。

使用场景

适用场景

事务消息使用场景：

• 分布式事务
• 订单支付
• 库存扣减

官方资源

• RocketMQ 事务消息：https://rocketmq.apache.org/docs/transaction-example/

本节小结

在本节中，我们学习了：

第一个是事务消息原理。 两阶段提交和半消息机制。

第二个是事务消息实现。 如何实现事务消息。

第三个是消息回查。 消息回查机制。

第四个是使用场景。 事务消息的适用场景。

这就是 RocketMQ 事务消息。使用事务消息，可以保证消息和本地事务的一致性。

在下一节，我们将学习 RocketMQ 顺序消息。