数据不一致

在使用消息队列时，如何保证数据一致呢？

先举一个数据不一致的例子，比如生成了一个订单，然后要通知下游服务处理相应的业务，如果此时订单创建成功，但是发送给下游的通知丢失了，就会导致数据不一致。又或者说发送给下游的通知发送成功，但是订单没有成功创建。如何解决呢？可以采用事务消息。

Tips:如果你前面看不懂，可以看后面的例子

什么是事务消息

事务消息通过 两阶段提交（2PC）  和 事务状态回查 机制解决生产者侧的一致性问题。

1. 两阶段提交流程

• 阶段1：发送预备消息

  • 生产者发送一条  "预备消息"  到消息队列，此消息对消费者不可见。
  • 消息队列持久化该消息并返回确认响应。

• 阶段2：提交或回滚

  • 提交（Commit） ：生产者完成本地事务（如更新数据库），通知消息队列提交预备消息，此时消息对消费者可见。
  • 回滚（Rollback） ：若本地事务失败，生产者通知消息队列删除预备消息。

2. 事务状态回查

• 超时未确认处理：若生产者未在超时时间内提交或回滚，消息队列会主动回查生产者。
• 业务逻辑回查：生产者需实现回调接口，根据本地事务最终状态（提交或回滚）响应消息队列。

流程图

举个例子

1. 商家接到订单之后，给配送站发一个“预备消息”
2. 配送站收到后返回确认信息
3. 商家开始备餐，备餐完成之后告诉配送站准备好了
4. 配送站通知骑手

以上是顺利的情况，如果商家备餐期间发送问题，比如备到一半突然有急事（异常），通知配送站，那么配送站将其信息删除，骑手永远也不会知道这个订单；如果商家备餐期间厨房炸了（比如系统崩溃），也有可能太忙了，那么超时后配送站会打电话问商家怎么还没备好，便可知道是要通知还是删除。