Asp.net 手机网站制作,网站源码下载网,保险网上预约,线上购物网站建设成本rocketmq事务消息原理#xff1f;
RocketMQ的事务消息主要由三部分组成#xff1a;半消息#xff08;Half Message#xff09;、执行本地事务和事务补偿机制。下面详细介绍这三部分#xff1a;
半消息#xff08;Half Message#xff09;用户向RocketMQ发送半消息
RocketMQ的事务消息主要由三部分组成半消息Half Message、执行本地事务和事务补偿机制。下面详细介绍这三部分
半消息Half Message用户向RocketMQ发送半消息这是一个预处理消息也就是说它不会被消费者所消费。半消息主要存储在Commit Log中。执行本地事务在用户的业务服务中执行本地事务。本地事务的执行结果可能成功或失败根据本地事务的执行结果用户会向RocketMQ提交事务或者回滚事务。提交或回滚消息如果本地事务执行成功用户会向RocketMQ提交事务这将会使得之前的半消息变为可消费的消息如果本地事务执行失败那么用户可以回滚事务这将会删除之前存储的半消息。事务补偿机制如果在上述过程中产生了某些故障例如网络问题或者应用崩溃导致RocketMQ没有收到事务提交或回滚指令RocketMQ提供了一种事务检查机制。RocketMQ会定期扫描哪些处于半消息状态的消息然后询问用户这些消息对应的本地事务执行结果。然后根据用户的反馈决定是提交还是回滚。 注回查请求内容: CHECK_TRANSACTION_STATE 请求码
CHECK_TRANSACTION_STATE这是一种命令类型表示需要检查事务状态。
producerGroup生产者所在的组。
tranStateTableOffset事务状态表中的偏移值。
commitLogOffset提交日志中的偏移值。
msgId消息ID。 RocketMQ在事务消息的处理过程中Broker和生产者端使用了特定的请求码进行通信。
请求码: Broker向生产者发送回查事务状态的请求时会通过CHECK_TRANSACTION_STATE请求码来标识该操作。
当生产者客户端收到这个请求码后它会进一步执行以下操作
RocketMQ客户端对每个生产者实例注册一个TransactionListener这个监听器包含两个方法executeLocalTransaction 和 checkLocalTransaction。前者用于执行本地事务后者用于检查本地事务的状态。当生产者客户端收到CHECK_TRANSACTION_STATE请求时然后找到生产组客户端会将生产组缓存起来找到 MQProducerInner producer this.mqClientFactory.selectProducer(group);然后调用对应的producer中的TransactionListener中的checkLocalTransaction方法。checkLocalTransaction方法会根据业务逻辑判断事务执行结果并返回一个枚举值COMMIT_MESSAGE、ROLLBACK_MESSAGE或者UNKNOW。COMMIT_MESSAGE表示事务提交ROLLBACK_MESSAGE表示事务回滚UNKNOW表示未知状态。客户端将这个结果响应给BrokerBroker根据响应结果更新消息的状态。
通过以上的步骤RocketMQ可以确保消息的发送和本地事务的执行具有原子性即要么都成功要么都失败。
此外RocketMQ内部通过一个CheckTransactionStateService服务线程来定期扫描消息判断其是否需要检查。RocketMQ不会对每一条消息进行事务状态检查只有当一条消息第一次被发出并且已经等待了一段时间默认超过6sRocketMQ才会触发事务状态的检查。
对于消息的发送方来说如果收到RocketMQ的事务状态回查请求需要重新检查本地事务的执行状态然后再次向RocketMQ确认消息提交或回滚。
