async-tx-message

项目介绍

异步事务消息

消息中间件在互联网应用中被广泛使用，用于解耦和异步执行业务，但需保证业务的最终一致性。前置业务执行完，异步业务也应该执行完。即消息不能丢失。 如何保证消息和业务一定都被执行，如果利用事务消息则会阻断核心业务，因为事务消息需prepare成功后才会执行核心业务（网络问题导致prepare失败），并根据核心业务的执行状态，来正式提交消息会回滚消息。

消息中间件一般都能保证消息能被消费者at once消费，所以只要能保证核心业务提交后，消息一定能发送到消息中间件，那么消息中间件就能保证这个消息至少能被消费一次。

通过消息补偿来实现消息一定发送到消息中间件。

软件架构

基于springboot开发，实例使用一个简单的电商下单场景，下单成功后，给用户赠送积分业务。

（schedule发送消息通知应用重发消息），由于应用可能为分布式应用而非单机部署，所以不使用本地线程扫描消息落地表的方式。

使用说明

1. 建立消息落地表，sql脚本
2. 引入pom依赖
3. 需保证一定发送成功的消息，调用messageSender.sendTxMessage，普通消息发送使用messageSender.sendMessage
4. 配置消息重发