1. 云栖社区>
  2. 全部标签>
  3. #事务消息#
事务消息

#事务消息#

已有0人关注此标签

内容分类:
博客 | 问答 | 视频 | 资料 |

RocketMQ事务消息实战

本文主要是考虑在使用消息中间件时,如果保证不丢消息的一些实践思考。

Apache 消息中间件 string 伪代码 RocketMQ 事务消息 事务消息实战

RocketMQ源码分析之RocketMQ事务消息实现原下篇(事务提交或回滚)

事务消息提交或回滚的实现原理就是根据commitlogOffset找到消息,如果是提交动作,就恢复原消息的主题与队列,再次存入commitlog文件进而转到消息消费队列,供消费者消费,然后将原预处理消息存入一个新的主题RMQ_SYS_TRANS_OP_HALF_TOPIC,代表该消息已被处理;回滚消息与提交事务消息不同的是,提交事务消息会将消息恢复原主题与队列,再次存储在commitlog文件中。

源码 存储 RocketMQ 事务消息 RocketMQ事务提交或回滚

RocketMQ源码分析之RocketMQ事务消息实现原理中篇----事务消息状态回查

本文详细分析了RocketMQ事务消息实现原理中的事务状态回查实现,RocketMQ会默认一分钟的频率处理消息状态为Prepare的消息,通过调用消息生产者的事务状态查询接口得知消息的事务状态,从而决定提交或回滚消息。

java 消息队列 LOG 源码 string exception Group RocketMQ 事务消息 事务状态回查

1
GO