系统总体框架
2018-12-20 11:14:19 0 举报RocketMq组件流程图
作者其他创作
大纲/内容
false= localState =true
④
回查，在默认时间内halfmsg未收到反馈结果，调用回查方法进行本地事务状态确认，决定消息发送或者回滚
调用Producer发送 halfmsg消息
根据消息内容通过反射调用本地服务
⑦
⑧
⑨
pcms DB
executeLocalTransactionBranch
RocketMq事务组件
②
⑤.①
⑧.①
TransactionCheckListenerImpl.checkLocalTransactionState
RocketMQ Producer
⑥
1.构造消息体，（切入点注解和参数信息）获取要调用的service方法和参数
本地事务失败
③
⑩
csbps DB
RocketMqProducerAdvice 切面
⑤
RocketMQ Consumer
pcms 标记@RocketMqTransaction 服务
localState=true则LocalTransactionState.COMMIT_MESSAGE;
localState=false返回LocalTransactionState.ROLLBACK_MESSAGE
调用MyTransactionExecuter回调方法
2.执行被切的本地事务方法块 joinPoint.proceed();
本地事务成功
@RocketMqTransaction(serviceName = \"txTestResolveService\
LocalTransactionState.COMMIT_MESSAGE
①
0 条评论
下一页
