这是一个创建于 246 天前的主题，其中的信息可能已经有所发展或是发生改变。
之前一直用的 qmq ，自带本地消息表，事务消息会与本地消息一起提交，对业务基本零侵入。
看了下 rocketmq 的事务消息示例
发送消息
https://github.com/apache/rocketmq-spring/blob/1be808da74764128e404ae33cbf5e97c248aa207/rocketmq-spring-boot-samples/rocketmq-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java#L209
本地事务、checkState
https://github.com/apache/rocketmq-spring/blob/1be808da74764128e404ae33cbf5e97c248aa207/rocketmq-spring-boot-samples/rocketmq-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java#L246
这也太别扭了吧，分割业务逻辑不说，也要多写很多代码，甚至还要改造业务表。
不知道是不是我使用的姿势不对，rmq 有点盛名之下其实难副的感觉？
看了下 rocketmq 的事务消息示例
发送消息
https://github.com/apache/rocketmq-spring/blob/1be808da74764128e404ae33cbf5e97c248aa207/rocketmq-spring-boot-samples/rocketmq-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java#L209
本地事务、checkState
https://github.com/apache/rocketmq-spring/blob/1be808da74764128e404ae33cbf5e97c248aa207/rocketmq-spring-boot-samples/rocketmq-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java#L246
这也太别扭了吧，分割业务逻辑不说，也要多写很多代码，甚至还要改造业务表。
不知道是不是我使用的姿势不对，rmq 有点盛名之下其实难副的感觉？
第 1 条附言 246 天前
大家使用 rocketmq 难道不用考虑消息发送失败的情况吗...
第 2 条附言 246 天前
FIX: "事务消息会与本地消息一起提交" => "事务消息会与本地事务一起提交"
 | 1 EMMMMMMMMM 246 天前 via Android 你是去哪儿的？ |
 | 2 mark2025 246 天前 如果数据库是 pgsql 可以考虑 pgmq （ https://tembo-io.github.io/pgmq/） ，这是 pg 的一个插件，用 pg 来实现的轻量级消息队列。 业务操作和队列消息可以共用事务，确保业务操作与消息的一致性。 |
 | 3 jorneyr 246 天前 RocketMQ 的分布式事务需要写代码判断事务是否提交，事务里的每个业务操作是否完成都需要调用方向 RocketMQ 确认的。 |
 | 4 securityCoding 246 天前 没理解为啥别扭，异构系统你要的事务不就是业务本身？ |
 | 5 1ffree 246 天前 怎么理解 本地消息表 && 对业务基本零侵入？ 请教下咋实现的 |
 | 7 nanwangnongfu 245 天前 会记录个发送消息的记录状态表，发送失败定期重试。 |
 | 8 xiaofan2 245 天前 我理解这就是两种不同模式的事务消息的实现罢了 你使用的是本地事务消息表模式（其他 MQ 也可以复用这种模式） RocketMQ 自带的是半消息模式 半消息模式确实对开发来说繁琐一点 毕竟要开发回查逻辑 但是性能比本地事务消息表高很多 毕竟本地事务消息表至少要多一条 SQL |
 | 9 ljzxloaf OP |
Select Language