rocketmq
2019-09-01 15:46:49 0 举报rocketmq可靠性消息
作者其他创作
大纲/内容
producer
method registry(){insert(mysql) // 注册用户rocketmq.producer.send(msg)// 发送优惠券}
begin transaction
消息对于消费者可见
rocketmq可靠性消息
commit成功(return result?LocalTransactionState.COMMIT_MESSAGE:LocalTransactionState.UNKNOW;)
commit失败(LocalTransactionState.UNKNOW)
根据id回查记录是否提交成功，如果是成功的使消息对于消费者是可见的，如果失败把broker消息抛弃
消息处于中间状态，开始反向查询
发送消息
注册用户
消息对于消费者不可见
commit成功
checkLocalTransaction
consumer
brocker
0 条评论
下一页
