RocketMQ事务消息的详细流程
2021-03-22 13:50:46 23 举报RocketMQ事务消息的流程图
作者其他创作
大纲/内容
checkTransactionState
oneWay
把 half 消息刷盘到 RMQ_SYS_TRANS_HALF_TOPIC
prepare
updateConsumeOffset
process normal msg
executeLocalTransaction
prepareMessage
Producer
TransactionalMessageBridge
发起 END_TRANSACTION
send(sync)
checkLocalTransactionState
SendMessageProcessor
每隔 60 秒执行一次
AbstractTransactionalMessageCheckListener
sendMessageInTransaction
ClientRemotingProcessor
EndTransactionProcessor
TransactionMQProducer
Container
TransactionalMessageServiceImpl
sendMessage
getHalfMessage
TransactionalMessageCheckService
putHalfMessage
sendCheckMessage
DefaultMQProducerImpl
fetchConsumeOffset
rollbackMessage
Broker
commitMessage
endTransaction
TRANSACTION_ROLLBACK_TYPE
TRANSACTION_NOT_TYPE
确认/回滚
回查
selectProducer
run
消息发送
check
TRANSACTION_COMMIT_TYPE
0 条评论
下一页
