RocketMQ事务消息​

　　一. 业务场景

　　大家好，我是千锋，今天和大家分享一个关于RocketMQ的面试题——“RocketMQ事务消息”。

　　在给面试官讲解这个问题之前，你可以先设计一个业务场景，越真实越好，越贴近生产越好，如果没有生产案例，可以直接列举电商中大家都容易懂的业务场景。比如，在分布式场景中用户取消订单，增加用户账户余额。这个业务简单易懂，业务大致流程是两个服务协同完成业务，订单服务取消订单，账户服务新增用户账户余额。场景有了，那接下来咱们就可以跟面试官沟通怎么解决，把思路分析清楚。

　　二. 解决思路

　　2.1 思路一

　　在分布式场景中，我们可以通过远程调用协议(RPC/HTTP)来完成服务间的远程调用，如果我们使用的是Dubbo、HSF、GRPC 等技术方案，那么使用RPC协议就可以完成服务间远程调用;如果使用的是SpringCloud技术方案，那么可以通过Openfeign(底层http协议)来完成服务间远程调用。具体实现流程如下图：

　　在分布式场景中，数据一致性是我们必须要面对的问题。在分布式项目中，保证数据的一致性，我们不能用本地事务的思维去解决，必须采用分布式事务的解决方案。

　　在这里千锋给大家推荐阿里的生产实践方案seata，至于seata具体是怎么实现的，解决原理是什么，我这里就不给大家详细说明了，我们的线下课程中有详细的讲解。

　　2.2 思路二

　　其实思路一并不是在正面回答面试官的问题，只是说了业务的实现方案，我们讲解思路一的目的是在告诉面试官，我知道什么是分布式事务，以及分布式事务应该怎么去解决。而思路二则是正面去回答面试官的问题，比如上面说到的业务场景，我们还可以利用MQ的事务消息来解决。

　　那为什么要使用MQ呢? 这是因为MQ有解耦以及异步处理的特性。具体流程如下：

　　基于MQ实现分布式事务的大概思路是，当order服务取消订单时，我们可以不用直接去调用账户服务。而是可以通过发送消息，然后账户服务监听消息队列，账户服务收到消息时处理账户业务。这个实现思路其实很简单，但要想落地实现却没那么简单，我们必须要解决取消订单与发送消息的一致性问题。试想一下，如果取消订单失败，结果消息发送成功;或者取消订单成功，但发送消息失败，那么就会导致数据的不一致问题。接下来千锋就给大家简单复现一下。

　　三. 问题复现

　　我们先来看看如下代码：

　　如上代码，当运行异常时，本地事务一定会回滚，但消息却发送出去了，数据的一致性就得不到保证了。那该怎么解决呢?这时我们就可以采用事务消息了，事务消息就能解决这个问题!

　　接下来我们就可以跟面试官讲解事务消息的具体实现过程，注意千锋这里用的MQ是RocketMQ，大家也可以采用其他MQ产品，只要支持事务消息就可以。

　　四. 实现原理

　　原理分析

　　在展示具体实现代码之前，千锋先把MQ实现分布式事务的原理讲解一下。

　　根据上图，千锋给大家梳理了RocketMQ实现分布式事务的流程原理，如下：

　　将发送消息的功能从业务中剥离出来。业务的第一步不是取消订单操作，而是发送消息，当然这里发送消息只能是”半消息“，”半消息“的特点是消费者不能消费;

　　当broker收到”半消息“时会应答生产者，生产者收到成功应答后再执行本地事务;

　　执行本地事务也就是取消订单;

　　本地事务如果处理成功则提交消息。提交消息后，消息就可以入队，消费者就可以消费消息。当然如果本地事务失败，那么就回滚消息，消息就会被删除，消费者也收不到消息;

　　如果不确定本地事务是否成功，我们可以进行本地事务回查;

　　回查本地事务;

　　回查可以直接查询数据库，检查本地事务是否成功，如果成功提交消息，否则回滚消息。

　　实现代码

　　我们把上图中展现的功能，在如下代码中进行实现：

　　事务消息监听器

　　另外RocketMQ的事务消息是基于两阶段提交方案来实现的，也就是说消息会有两个状态，prepared和commited。当消息执行完send方法后，进入到prepared状态，然后就会执行executeLocalTransaction方法，该方法的返回值有3个，这些返回值决定着该消息的命运。

　　COMMIT_MESSAGE：提交消息。表示该消息由prepared状态进入到commited状态，消费者可以消费这个消息;

　　ROLLBACK_MESSAGE：回滚。表示该消息将被删除，消费者不能消费这个消息;

　　UNKNOW：未知。这个状态有点意思，如果返回这个状态，则表示该消息既不提交，也不回滚，还是保持prepared状态。而最终决定这个消息命运的，是checkLocalTransaction这个方法。

　　事务监听器的实现代码如下：

　　五. 注意事项

　　我们在使用RocketMQ的时候，要注意以下两个配置参数。

　　事务消息最大反查次数

　　transactionCheckMax=N

　　事务消息检查间隔时间

　　默认为 60s transactionCheckInterval=5000

　　好啦，关于RocketMQ的事务消息，今天就给大家分享到这里啦。