RocketMQ原理解析-producer 4.发送分布式事物消息
2014-09-08 23:50
615 查看
先引入官方文档图:
分布式事物是基于二阶段提交的
1) 一阶段,向broker发送一条prepared的消息,返回消息的offset即消息地址commitLog中消息偏移量。Prepared状态消息不被消费
发送消息ok,执行本地事物分支, 本地事物方法需要实现rocketmq的回调接口2)2)2) LocalTransactionExecuter,处理本地事物逻辑返回处理的事物状态LocalTransactionState
3) 二阶段,处理完本地事物中业务得到事物状态, 根据offset查找到commitLog中的prepared消息,设置消息状态commitType或者rollbackType, 让后将信息添加到commitLog中, 其实二阶段生成了两条消息
事物消息发送
分布式事物是基于二阶段提交的
1) 一阶段,向broker发送一条prepared的消息,返回消息的offset即消息地址commitLog中消息偏移量。Prepared状态消息不被消费
发送消息ok,执行本地事物分支, 本地事物方法需要实现rocketmq的回调接口2)2)2) LocalTransactionExecuter,处理本地事物逻辑返回处理的事物状态LocalTransactionState
3) 二阶段,处理完本地事物中业务得到事物状态, 根据offset查找到commitLog中的prepared消息,设置消息状态commitType或者rollbackType, 让后将信息添加到commitLog中, 其实二阶段生成了两条消息
事物消息发送
相关文章推荐
- RocketMQ原理解析-producer 4.发送分布式事物消息
- RocketMQ原理解析-producer 4.发送分布式事物消息
- RocketMQ原理解析-producer 3.如何发送顺序消息
- RocketMQ原理解析-producer 6.消息在broker落地之事物消息
- RocketMQ原理解析-producer 2.如何发送消息
- RocketMQ原理解析-producer 6.消息在broker落地之事物消息
- RocketMQ原理解析-producer 4.发送分布式事物消息
- RocketMQ原理解析-producer 3.如何发送顺序消息
- RocketMQ原理解析-producer 5.消息在broker落地之普通消息
- RocketMQ原理解析-producer 5.消息在broker落地之普通消息
- RocketMQ原理解析-consumer 5.push消费-顺序消费消息
- RocketMQ原理解析-producer 6.消息在broker落地之事物消息
- 消息中间件 RocketMQ源码解析:Message顺序发送与消费
- 消息顺序和消息事务 - RocketMQ及分布式消息系统的原理以及重要问题解读
- RocketMQ原理解析-consumer 4.长轮询push消息—并发消费消息
- 分布式消息队列RocketMQ源码分析之1 -- Topic路由数据结构解析 -- topicRoute与topicPublishInfo与queueId
- RocketMQ源码分析之Broker概述与同步消息发送原理与高可用设计及思考
- RocketMQ原理解析-broker 2.消息存储
- 分布式开放消息系统RocketMQ的原理与实践(消息的顺序问题、重复问题、可靠消息/事务消息)
- 分布式消息队列RocketMQ源码分析之1 -- Topic路由数据结构解析 -- topicRoute与topicPublishInfo与queueId