<b>事务消息的背景</b>:
有时候我们需要实现本地操作和消息发送的事务一致性功能。即:消息发送成功,则本地操作成功;反之,如果消息发送失败,本地操作失败(成功也需要rollback)。保证不出现操作成功但消息发送失败;或者操作失败但消息发送成功的情况;
另外,消费端,我们也希望消息一定被成功处理一次,不会因为消息端程序崩溃而导致消息没有成功处理,进而需要人工重置消费进度。
<b>解决方案</b>:
利用消息服务mns的延迟消息来实现。
<b>准备工作</b>:
创建两个队列:
1.事务消息队列
消息的有效期小于消息延迟时间。即如果生产者不主动修改(提交)消息可见时间,消息对消费者不可见;
2.操作日志队列
记录事务消息的操作记录信息。消息延迟时间为事务操作超时时间。日志队列中的消息确认(删除)后将对消费者不可见。
<b>具体步骤</b>:
1.发送一条事务准备消息到事务消息队列;
2.写操作日志信息到操作日志队列,日志中包含步骤1消息的消息句柄;
3.执行本地事务操作;
4.如果步骤3成功,提交消息(消息对消费者可见);反之,回滚消息;
5.确认步骤2中的操作日志(删除该日志消息);
6.步骤4后,消费者可以接收到事务消息;
7.消费者处理消息;
8.消费者确认删除消息;
如下图:
![](https://img.laitimes.com/img/_0nNw4CM6IyYiwiM6ICdiwiIn5GcuYTOwQGZjBjNhZmNkFmN0UjNzgjYxAjY4QTN4UTZ5ITO4YmMhBjZkdzLcNXZslmZxl3Lc12bj5ycj5Wd5lGbh5Sdvhmen5WYo1ibj1ycz92Lc9CX6MHc0RHaiojIsJye.png)
<b>异常分析:</b>
生产者异常(例如:进程重启):
a.读取操作日志队列超时未确认日志
b.检查事务结果
c.如果检查得到事务已经成功,则提交消息(重复提交无副作用,同一句柄的消息只能成功提交一次)
d.确认操作日志
<b> </b>
消费者异常(例如:进程重启):
消息服务提供至少保证消费一次的特性,只要步骤8不成功,消息在一段时间后可以继续可见,被当前消费者或者其他消费者处理。
消息服务不可达(例如:断网)
消息发送和接收处理状态以及操作日志都在消息服务端,消息服务本身具备高可靠和高可用的特点,所以只要网络恢复,事务可以继续,能保证只要生产者:操作成功,则消费者一定能够拿到消息并处理成功;或操作失败, 则消费者收不到消息的最终一致性。
<b>代码实现:</b>
mns最新的java sdk
<b>demo 代码</b>