UNKNOWN
broker服务器
根据真实的TOPIC和QUEUEID保存消息
是否事物消息
获取所有半消息MessageQueue
CHECK流程一: broker服务器 主动发起check
设置msgHeader事物标记`TRAN_MSG`MessageConst.PROPERTY_TRANSACTION_PREPARED
将半消息存储成为最终的消息
MQClient
发送endTransaction消息
choose one
在讨论事物消息的check流程前需要知晓几个常量①transactionTimeOut 事物超时 默认 6s②transactionCheckMax 事物重试次数 默认 15lspan style=\"font-size: inherit;\
是否check消息
生产者
messageQueue_3
发送endTransaction消息， 执行方式回到第二阶段.
插入
一系列判断是否需要check
SUCCESS
替换的half半消息的TOPIC和queueId为固定的`RMQ_SYS_TRANS_HALF_TOPIC` 和 queue_0
ROLLBACK
messageQueue_1
第二阶段
循环针对messageQueue进行check
删除半消息
发送事物消息
messageQueue_0
第一阶段
将真实事物消息转成half半消息
发送消息(普通消息处理)
当前遍历的messageQueue是否全部执行完成了或者是全都删除了
输出日志
T
从producer的hashmap中获取对应的处理实例
本地事物是否执行成功
获取近32条op消息.
保存消息
将half半消息topic和queueId替换原始的topic和queueId
执行本地事物
消息
从返回消息中获取transactionId
本地事物check
从半消息TOPIC中获取一个消息，从最新的开始
将真实topic和queueId保存到msgHeader中将真实topic保存在 `REAL_TOPIC`属性中将真实queueId保存在 `REAL_QID`属性中
messageQueue_2
删除该半消息
AbstractTransactionalMessageCheckListener 处理check消息
