ShardingSphere x Seata，一致性更强的分布式数据库中间件

日前，分布式数据库中间件ShardingSphere将 Seata 分布式事务能力进行整合，旨在打造一致性更强的分布式数据库中间件。
数据库领域，分布式事务的实现主要包含：两阶段的 XA 和 BASE 柔性事务。
XA 事务底层，依赖于具体的数据库厂商对 XA 两阶段提交协议的支持。通常，XA 协议通过在 Prepare 和 Commit 阶段进行 2PL（2 阶段锁），保证了分布式事务的 ACID，适用于短事务及非云化环境（云化环境下一次 IO 操作大概需要20ms，两阶段锁会锁住资源长达 40ms，因此热点行上的事务的 TPS 会降到25/s 左右，非云化环境通常一次 IO 只需几毫秒，因此锁热点数据的时间相对较低）。
但在 BASE 柔性事务方面，ShardingSphere 提供的接入分布式事务的 SPI，只适用于对性能要求较高，对一致性要求比较低的业务。
Seata 核心的 AT 模式适用于构建于支持本地 ACID 事务的关系型数据库。通过整合Seata，其AT模式在一阶段提交+补偿的基础上，通过 TC 的全局锁实现了 RC 隔离级别的支持，可提高ShardingSphere 的分布式事务的一致性。
整合 Seata AT 事务时，需要把 TM，RM，TC 的模型融入到 ShardingSphere 分布式事务的 SPI 的生态中。在数据库资源上，Seata 通过对接 DataSource 接口，让 JDBC 操作可以同 TC 进行 RPC 通信。同样，ShardingSphere 也是面向 DataSource 接口对用户配置的物理 DataSource 进行了聚合，因此把物理DataSource 二次包装为 Seata 的 DataSource 后，就可以把 Seata AT 事务融入到 ShardingSphere 的分片中。
在 Seata 模型中，全局事务的上下文存放在线程变量中，通过扩展服务间的transport，可以完成线程变量的传递，分支事务通过开发云主机域名线程变量判断是否加入到整个 Seata 全局事务中。而 ShardingSphere 的分片执行引擎通常是按多线程执行，因此整合 Seata AT 事务时，需要扩展主线程和子线程的事务上下文传递，这同服务间的上下文传递思路完全相同。

ShardingSphere 已经实现了 base-seata-raw-jdbc-example，大家可以自行进行尝试：
https://github.com/apache/incubator-shardingsphere-example/tree/dev/sharding-jdbc-example/transaction-example/transaction-base-seata-example/transaction-base-seata-raw-jdbc-example
操作手册：
1、按照 seata-work-shop 中的步骤，下载并启动 seata server。
https://github.com/seata/seata-workshop
参考 Step6 和 Step7 即可。
2、在每一个分片数据库实例中执行 resources/sql/undo_log.sql 脚本，创建 undo_log 表
3、Run YamlConfigurationTransactionExample.java
ShardingSphere 是一套开源的分布式数据库中间件解决方案组成的生态圈，它由 Sharding-JDBC、Sharding-Proxy 和 Sharding-Sidecar（计划中）这 3 款相互独立的产品组成，提供标准化的数据分片、分布式事务和数据库治理功能，可适用于如 Java 同构、异构语言、容器、云原生等各种多样化的应用场景。目前，已经拥有超过 8000的 Star，57 位 Contributors。
Seata 是阿里巴巴和蚂蚁金服共同开源的分布式事务中间件，融合了双方在分布式事务技术上的积累，并沉淀了新零售、云计算和新金融等场景下丰富的实践经验，以高效并且对业务0 侵入的方式，解决微服务场景下面临的分布式事务问题。目前，已经拥有超过 9900的 Star，83 位 Contributors。

相关推荐: Java B2B2C多用户商城springboot架构——springcloud整合bus

bus的使用主要是配合springcloud config部分来一开发云主机域名起使用，并没有单独使用首先建立服务端： 由于本次使用的是rabbitmq进行监听 了解springcloud架构可以加求求：三五三六二四七二五九 所以需要在依赖中引入amqp。这是…