什么是MQ?
1.1 为什么要用MQ？
1.2 场景一
1.3 场景二
事务消息
2.1 本地消息事务表
2.2 RocketMQ事务消息
1. 什么是MQ?
MQ(Message Quene) : 翻译为 消息队列,通过典型的 生产者和消费者模型，生产者不断向消息队列中生产消息，消费者不断的从队列中获取消息。因为消息的生产和消费都是异步的，而且只关心消息的发送和接收，没有业务逻辑的侵入,轻松的实现系统间解耦。
别名为 消息中间件 通过利用高效可靠的消息传递机制进行平台无关的数据交流，并基于数据通信来进行分布式系统的集成。
目前市面上有很多消息中间件：RabbitMQ，RocketMQ，Kafka等等…
1.1 为什么要用MQ？思考一个支付场景，订单—>支付—>优惠券—>积分—>短信—>…—>结束
随着业务的增长，调用链路增长，速度势必会变慢，这个时候就需要采用MQ解耦
这个时候就会有如下几个场景：
1.2 场景一1): A 开启事务
2): A 更新db数据
3): A 发送mq消息
4): A 提交事务(fail)
5): B 消费mq消息
这种会发生一种情况：消息已经发送成功，A数据库操作报错回滚了，但是B已经消费消息，数据已经更新了
1.3 场景二1): A 更新db数据
2): A 发送mq消息(fail)
3): B 消费mq消息(fail)
这种会发生一种情况：A数据库操作成功，消息发送失败了，造成上下游数据不一致
2. 事务消息 2.1 本地消息事务表设计如下一张表: msg_status
| id | status | msg |
|---|---|---|
| 1 | 0 | msg |
1): A 开启事务
2): A 更新db数据
3): A 插入msg_status 表一条数据
4): A 提交事务
5): B 扫描msg_status 表中状态为未发送的记录，发送mq消息，并更新状态为已发送
6): C 消费mq消息（需保证幂等，第5步不加锁的情况下或者数据库出错可能发送多条）
2.2 RocketMQ事务消息- 应用模块遇到要发送事务消息的场景时，先发送prepare消息给MQ。prepare消息发送成功后，应用模块执行数据库事务（本地事务）。根据数据库事务执行的结果，再返回Commit或Rollback给MQ。如果是Commit，MQ把消息下发给Consumer端，如果是Rollback，直接删掉prepare消息。第3步的执行结果如果没响应，或是超时的，启动定时任务回查事务状态（最多重试15次，超过了默认丢弃此消息），处理结果同第4步。MQ消费的成功机制由MQ自己保证。
（未完待续）
