springcloud实现分布式事务

「爱情、让人受尽委屈。」 2023-06-02 09:21 23阅读 0赞

springcloud 分布式事务

1.下载Consul

[https://www.consul.io/downloads.html][https_www.consul.io_downloads.html]

下载对应的版本

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70][]

cmd切换到consul解压目录，即consul.exe目录，执行输入consul出现如下表示安装成功

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 1][]

cmd到consul安装目录键入命令：  
consul.exe agent -dev -ui -node=cy ///可指定节点node  
consul.exe agent -dev 本地模式，将会使用127.0.0.1 的ip地址

consul.exe agent -dev -client 192.168.xx.xx 远程模式

我这里使用的是：启动脚本:consul agent -dev -ui (dev模式)

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 2][]

[http://localhost:8500/ui/dc1/services][http_localhost_8500_ui_dc1_services] 查看consul信息

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 3][]

2.下载tx-lcn框架代码，启动txlcn-tm项目（修改数据库连接信息）

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 4][]

2.1创建MySQL数据库, 名称为: tx-manager

2.2创建数据表

CREATE TABLE `t_tx_exception`  (
      `id` bigint(20) NOT NULL AUTO_INCREMENT,
      `group_id` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
      `unit_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
      `mod_id` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
      `transaction_state` tinyint(4) NULL DEFAULT NULL,
      `registrar` tinyint(4) NULL DEFAULT NULL,
      `remark` varchar(4096) NULL DEFAULT  NULL,
      `ex_state` tinyint(4) NULL DEFAULT NULL COMMENT '0 未解决 1已解决',
      `create_time` datetime(0) NULL DEFAULT NULL,
      PRIMARY KEY (`id`) USING BTREE
    ) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT =

3.[http://localhost:7970/admin/index.html\#/][http_localhost_7970_admin_index.html]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 5][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 6][]

红框里面的2是因为我已经启动了后续操作，第一次应该是0

4. [下载微服务代码][Link 1]

5. 启动微服务（修改对应的数据库连接，配置文件没有配置tx-tm的链接，默认会有，tm端口也是默认的端口）

1）如果不用默认的，则需要在tx-tm项目的配置文件新增配置：

#tx-lcn.logger.enabled=true
    # TxManager Host Ip
    tx-lcn.manager.host=127.0.0.1
    # TxClient连接请求端口
    tx-lcn.manager.port=8070

2）微服务中的两个配置文件新增配置：

tx-lcn.client.manager-address=127.0.0.1:8070

6.测试 [http://localhost:8090/start?money=100][http_localhost_8090_start_money_100]  手动抛出了异常，a b 数据库数据回滚都为1000  说明成功！

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 7][]

7.微服务两个数据库信息

创建数据库bank-a和bank-b  两个数据库都创建t\_bank表如下：

CREATE TABLE `t_bank` (
    `id` bigint(20) NOT NULL AUTO_INCREMENT,
    `money` int(10) DEFAULT NULL,
    `user` varchar(32) DEFAULT NULL,
    PRIMARY KEY (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC;
    insert into t_bank(money,user) values(1000,'xiaoming');

![20191004154021227.png][]

8.经过步骤6的测试，数据库的数据还是初始的1000 说明数据已经回滚了。 （这里测试了一下，大概花了30s的时间数据库的数据进行了回滚）。

[环境搭建可以参考这里][Link 2]

[https_www.consul.io_downloads.html]: https://www.consul.io/downloads.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70]: /images/20230601/3028578e19734737b7ce3d86ea1a514f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 1]: /images/20230601/0ed432ced24d4fd6a7cff71fb41d6e98.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 2]: /images/20230601/e8c5562b8abb4496bbfa268aa24272dc.png
[http_localhost_8500_ui_dc1_services]: http://localhost:8500/ui/dc1/services
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 3]: /images/20230601/6204771e47194b8483b67398ba34519b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 4]: /images/20230601/916cdcf4371f4b8d9828b94eeae6ada2.png
[http_localhost_7970_admin_index.html]: http://localhost:7970/admin/index.html#/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 5]: /images/20230601/312d353cbb20459288520e132a0e7bab.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 6]: /images/20230601/9fff722d1e4443d999d84855866e16f6.png
[Link 1]: https://github.com/ChenXbFrank/tx-bank-demo
[http_localhost_8090_start_money_100]: http://localhost:8090/start?money=100
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 7]: /images/20230601/3a109d677db749dd99393695cc179390.png
[20191004154021227.png]: /images/20230601/f401ccaa20a1432581ed080b9c6f276e.png
[Link 2]: https://www.txlcn.org/zh-cn/docs/start.html