宁夏住房和城乡建设部网站icp网站 是什么意思
张小明 2026/1/1 15:47:04
宁夏住房和城乡建设部网站,icp网站 是什么意思,网站的方案,济南优化网站价格RocketMQ 通过 TransactionListener 接口实现事务消息机制#xff0c;其工作流程如下#xff1a;发送半消息首先向 Broker 发送一条半消息#xff08;状态标记为prepared#xff09;#xff0c;该消息会被存储在事务日志中但暂不可消费。执行本地事务半消息发…RocketMQ 通过 TransactionListener 接口实现事务消息机制其工作流程如下发送半消息首先向 Broker 发送一条半消息状态标记为prepared该消息会被存储在事务日志中但暂不可消费。执行本地事务半消息发送成功后应用程序执行本地事务逻辑并确定最终状态。提交/回滚本地事务成功通知 Broker 提交消息状态改为committed消息转为可消费状态本地事务失败通知 Broker 回滚消息状态改为rollback消息会被立即删除异常处理机制未收到确认指令时若 Broker 未及时收到 COMMIT/ROLLBACK主动发起事务状态检查应用程序通过回调返回处理结果若超时未响应则标记为UNKNOW状态最终过期后自动回滚半消息发送失败由于业务操作在半消息之后执行失败时业务尚未执行不存在一致性问题可通过重试机制解决自主重试或依赖上游重试设计优势相比先提交事务再发消息的传统方案事务消息解决了最终一致性即使 COMMIT 消息发送失败MQ 仍能通过半消息状态反查确保最终一致防丢失本地事务提交与消息投递形成原子操作避免事务成功但消息丢失的情况状态可追踪通过 prepared/committed/rollback 状态机明确消息生命周期