rocketmq核心源码分析第二十六篇一事务消息一broker端处理

文章目录
消息存储原理图源码分析[half消息]一SendMessageProcessor.sendMessage源码分析一parseHalfMessageInner
源码分析[commit|rollback]一EndTransactionProcessor.processRequestdeletePrepareMessage

消息回查源码分析一check
总结

消息存储
原理图
事务消息包括half消息,提交消息以及回滚消息分别由SendMessageProcessor和EndTransactionProcessor处理half消息发送至RMQ_SYS_TRANS_HALF_TOPIC提交消息则发送至业务侧定义topic,并删除half消息回滚消息仅删除half消息,删除的实质是发送消息至RMQ_SYS_TRANS_OP_HALF_TOPIC删除是为了协助消息回查RMQ_S

rocketmq核心源码分析第二十六篇一事务消息一broker端处理最先出现在Python成神之路。