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 事务消息 事务状态回查

启发:从MNS事务消息谈分布式事务

事务消息本质上解决的问题是业务系统与消息系统之间的事务问题(跨系统分布式事务),其基本原理即两阶段提交以及最终一致性保障。最近看了下阿里云mns事务消息的实现原理,介绍的蛮简洁透彻的,对了解分布式事务实现原理挺有帮助,在阅读本文前推荐大家先仔细阅读下阿里云"mns事务消息"一文。

分布式 消息服务 MNS 消息队列 阿里云 日志 Commit 分布式事务 事务消息

1
GO