# async-tx-message

**Repository Path**: hsogoo/async-transaction-message

## Basic Information

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

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

- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 0
- **Created**: 2018-05-30
- **Last Updated**: 2020-12-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# async-tx-message

#### 项目介绍

### 异步事务消息

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

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

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


#### 软件架构
![输入图片说明](https://images.gitee.com/uploads/images/2018/1116/001135_3d0f59de_1421983.png "分布式事务解决方案.png")

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


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

#### 使用说明

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