如何通过本地消息表实现分布式事务？

通过本地消息表（也称为可靠消息表）实现分布式事务是一种常见的做法，用于保证在分布式环境中消息的可靠传递和事务的一致性。以下是使用本地消息表实现分布式事务的一般步骤：

消息生产方（也就是发起方），需要额外建一个消息表，并记录消息发送状态。消息表和业务数据要在一个事务里提交，也就是说他们要在一个数据库里面。然后消息会经过MQ发送到消息的消费方。如果消息发送失败，会进行重试发送。
消息消费方（也就是发起方的依赖方），需要处理这个消息，并完成自己的业务逻辑。此时如果本地事务处理成功，表明已经处理成功了，如果处理失败，那么就会重试执行。如果是业务上面的失败，可以给生产方发送一个业务补偿消息，通知生产方进行回滚等操作。
生产方和消费方定时扫描本地消息表，把还没处理完成的消息或者失败的消息再发送一遍。

分布式事务-本地消息表 (1).png

以下是具体步骤：

0. 创建本地消息表：

在数据库中创建一个本地消息表，用于存储待发送的消息以及消息的发送状态和相关信息。表结构可以包含字段如下：

1. 业务处理： 业务处理时通常进行db变更

2. 将业务变更信息插入记录表：在业务逻辑中，当需要发送消息时，首先将消息插入到本地消息表中，设置状态为待发送。

3. 发送消息，1、2、3步骤在同一个本地事务中。如果本地事务执行成功，提交本地事务和消息表的记录；如果本地事务失败，回滚本地事务和消息表的记录。

3.1,3.2. 消息确认机制：

单独创建一个后台线程或定时任务，定时扫描本地消息表中状态为待发送的消息，并将这些消息发送到消息队列。在成功发送到消息队列后，将消息表中对应的状态修改为已发送。此外，可以根据需要实现消息发送失败后的重试机制。

4. B系统消费消息：

消费者监听消息队列，解析消息内容。

5. B系统进行业务逻辑处理：

进行业务逻辑处理，更改DB。此步骤必须要保证幂等性。

4、5 如果失败依赖3.1、3.2的定时投放

6. 确认消费完成：

当消息消费完成后，调用A系统进行状态变更

6、7如果失败相当于两个分布式系统的数据已经一致了，但是本地消息表的状态还是错的。这种情况下借助3.1、3.2的重新投放策略，让下游幂等处理再更改消息表的状态也能解决。或者A系统也可以查询B系统的处理状态，如果成功直接更改状态

使用本地消息表实现分布式事务可以确保消息在分布式环境中的可靠传递和一致性。然而，需要注意以下几点：

索引优化：在消息表中对状态字段增加索引，以加速扫表操作。索引可以加速消息的检索和筛选，从而提高操作效率。
分页查询：将扫表操作划分为多次分页查询，避免一次性查询大量数据造成的性能问题。
表较大时进行分库分表：如果表较大可以进行分库分表操作。
多线程分段查询：
- 如果有业务标识，可以通过业务标识进行多线程分段扫表查询。
- 如果没有业务标识可以按区间查询比如线程1查询0-1000的数据，线程2查询1001-2000的数据。