分布式事务:SpringBoot+Dubbo+Seata+Nacos 实现案例

Posted 朝雨忆轻尘

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了分布式事务:SpringBoot+Dubbo+Seata+Nacos 实现案例相关的知识,希望对你有一定的参考价值。

案例源码使用SpringBoot 2.3.2 + Dubbo 2.7.6 + Mybatis 1.3.2 + Nacos 1.3.2 + Seata 1.3.0整合来实现Dubbo分布式事务管理,使用Nacos 作为 Dubbo和Seata的注册中心和配置中心,使用 mysql 数据库和 MyBatis来操作数据库。

案例说明

项目包含四个模块,consumer模块依赖其他三个模块。

 

示例采用TCC模式与AT模式混合使用模式,所以兼容纯数据库事务和其他事务的支持。

建立数据库

要求:示例使用MySQL数据库,需要具有InnoDB引擎的MySQL。

注意: 实际上,在示例用例中,这3个服务应该有3个数据库。 但是,为了简单起见,我们只创建一个数据库并配置3个数据源,创建一个数据库seata。

创建回滚日志表

SEATA 的AT 模式需要 UNDO_LOG 表,用于支持回滚操作。

-- 注意此处0.3.0+ 增加唯一索引 ux_undo_log

CREATE TABLE `undo_log` (

  `id` bigint(20) NOT NULL AUTO_INCREMENT,

  `branch_id` bigint(20) NOT NULL,

  `xid` varchar(100) NOT NULL,

  `context` varchar(128) NOT NULL,

  `rollback_info` longblob NOT NULL,

  `log_status` int(11) NOT NULL,

  `log_created` datetime NOT NULL,

  `log_modified` datetime NOT NULL,

  `ext` varchar(100) DEFAULT NULL,

  PRIMARY KEY (`id`),

  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)

) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

创建业务相关表

在action-db-provider项目的sql目录下也可以找到SQL脚本。

CREATE TABLE `t_user` (
  `id`bigint(32) NOT NULL AUTO_INCREMENT,
  `userName`varchar(32) NOT NULL,
  `passWord`varchar(50) NOT NULL,
  `realName`varchar(32) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;

Nacos服务器

示例使用Nacos注册中心,需要先安装Nacos服务器。

下载软件

下载地址:https://github.com/alibaba/nacos/releases

从下载地址下载服务器软件包,示例要求使用1.3.2版本,解压缩后启动。

运行模式

单机模式

因为下载下来的Nacos的启动脚本默认是使用集群模式启动的,需要依赖MySQL数据库,如果想使用单机模式,修改bin目录下的startup.cmd,设置其启动模式为单机模式。

集群模式

1. 将nacos/conf/nacos-mysql.sql导入自己的数据库

2. 配置修改nacos/conf/application.properties

spring.datasource.platform=mysql
db.num=1
db.url.0=jdbc:mysql://127.0.0.1:3306/nacos?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true
db.user=root
db.password=123456

启动服务

启动脚本在bin目录下,进入目录,执行脚本启动服务。

Windows:cmd> startup.cmd

Linux/Mac:bash> startup.sh -m standalone

关闭服务:

Windows:cmd> shutdown.cmd

Linux/Mac:bash> shutdown.sh

访问地址

nacos服务默认端口是8848 浏览器输入:http://127.0.0.1:8848/nacos

登陆账号和密码都是 nacos,登陆成功的画面如下:

 

参考资料

官方网站:https://nacos.io/zh-cn/

官方文档:https://nacos.io/zh-cn/docs/quick-start.html

Seata服务器

下载软件

下载地址: https://github.com/seata/seata/releases

从下载地址下载服务器软件包,这里下载1.3.0版本。

可以直接下载二进制软件包,也可以下载源码编译。

源码编译命令如下:

mvn -Prelease-all -DskipTests clean install –U

Seata配置

在seata的目录下需要关注两个配置文件。

首先是registry.conf,选择seata使用的注册中心,可选项包含file 、nacos 、eureka、redis、zk、consul、etcd3、sofa,默认配置是nacos。如果你的nacos地址账号等信息与默认配置不一致,将配置改成你自己的。

另外file.conf配置了seata的存储模式,seata的存储模式包括:file、db、redis,db、redis模式需要将连接信息配置成你自己的。

导入配置

如果下载的是二进制安装包,以下文件需要到git仓库源码或下载源码包获取。使用db模式导入配置,进入源码目录,mysql.sql为seata库必须的表,执行sql即可。

 

复制config.txt文件到seata根目录。

复制nacos中的nacos-config.sh、nacos-config.py到seata的conf目录。

 

然后命令行执行 sh nacos-config.sh hostip 导入配置到Nacos即可,导入完成之后,可以登录Nacos查看配置。

 

启动服务

启动脚本在bin目录下,进入目录,执行脚本启动服务。

Windows:cmd> seata-server.bat

Linux/Mac:bash> seata-server.sh

启动时可以指定包括主机、端口、日志存储模式等启动参数。

参数说明:

--host, -h

The host to bind,Default: 0.0.0.0

--port, -p

The port to listen,Default: 8091

--storeMode, -m

log store mode : file、db Default: file

--help

比如:

sh seata-server.sh -p 8091 -h 127.0.0.1 -m file

参考资料

官方网站:https://seata.io/zh-cn/index.html

官方文档:https://seata.io/zh-cn/docs/overview/what-is-seata.html

搭建源码项目

项目结构

项目结构如下,项目包含四个模块,consumer模块依赖其他三个模块。

 

springboot-dubbo-seata-tccat

项目父模块,包含四个子模块,并提供了nacos、seata、dubbo的依赖。

 

service-consumer

提供分布式事务的服务和测试接口,通过RPC调用其他几个子模块的服务。

在TccController里提供了测试提交和回滚的相关接口,代码如下:

/**
 * 发起事务控制器
 *
 * @author louis
 */
@RestController
public class TccController {

    @Resource
    private TccTransactionService tccTransactionService;

    /**
     * 分布式事务提交示例接口
     */
    @GetMapping("/testCommit")
    public String testCommit() {
        String result = tccTransactionService.testCommit();
        return "----------test transaction commit---------- \\n" + result;
    }

    /**
     * 分布式事务回滚示例接口
     */
    @GetMapping("/testRollback")
    public String testRollback() {
        String result = "";
        try {
            tccTransactionService.testRollback();
        } catch (Throwable t) {
            result = t.getMessage();
        }
        return  "----------test transaction rollback ---------- \\n" + result;
    }
}

具体的的分布式服务在TccTransactionService中实现,方法内容如下:

@Service
public class TccTransactionService {

    @Resource
    private TccActionOne tccActionOne;
    @Resource
    private TccActionTwo tccActionTwo;
    @Reference(version = "1.0.0", group = "tcc")
    private UserService userService;

    /**
     * 测试分布式事务提交示例
     */
    @GlobalTransactional
    public String testCommit() {
        // 第一个TCC 事务参与者
        String result = tccActionOne.prepare("action-one-commit").getMessage();
        // 第二个TCC 事务参与者
        result = result + "\\n" + tccActionTwo.prepare("action-two-commit").getMessage();
        // 数据库操作
        userService.save(getUser());
        return result;
    }

    /**
     * 测试分布式事务回滚示例
     */
    @GlobalTransactional
    public String testRollback() {
        //第一个TCC 事务参与者
        String result = tccActionOne.prepare("action-one-rollback").getMessage();
        // 第二个TCC 事务参与者
        result = result + "\\n" + tccActionTwo.prepare("action-two-rollback").getMessage();
        // 数据库操作
        userService.save(getUser());
        throw new RuntimeException(result);
    }
}

相关配置查看application.yml配置文件。

seata:
application-id: ${spring.application.name}
tx-service-group: my_test_tx_group # 事务分组,与seata-server配置保持一致
registry:
type: nacos
nacos:
server-addr: 127.0.0.1:8848
namespace:
cluster: default
config:
type: nacos
nacos:
namespace:
server-addr: 127.0.0.1:8848

action-one-provider

提供TCC参与者,编写prepare、commit、rollback三个方法。

@Component
@Service(version = "1.0.0", group = "tcc")
public class ActionOneServiceImpl implements ActionOneService {

    @Override
    public String prepare(String param) {
        String result = ":::: action-one-provider prepare, rpc called success, param:" + param + ".";
        System.out.println(result);
        return result;
    }

    @Override
    public String commit(String param) {
        String result = ":::: action-one-provider commit, rpc called success, param:" + param + ".";
        System.out.println(result);
        return result;
    }

    @Override
    public String rollback(String param) {
        String result = ":::: action-one-provider rollback, rpc called success, param:" + param + ".";
        System.out.println(result);
        return result;
    }
}

action-two-provider

同actiono-one-provider一样,提供TCC参与者,编写prepare、commit、rollback三个方法。

action-db-provider

提供数据库操作服务,用于测试AT模式。

POM文件添加了Mybatis和MySQL的支持。

<dependency>
    <groupId>org.mybatis.spring.boot</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
    <version>1.3.2</version>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
</dependency>

UserServiceImpl提供了用户表相关的CRUD服务。

@Component
@Service(version = "1.0.0", group = "tcc")
public class UserServiceImpl implements UserService {

    @Resource
    private UserMapper userMapper;

    @Override
    public User save(User user) {
        if(user.getId() == null || "".equals(user.getId())) {
            userMapper.insert(user);
        } else {
            userMapper.updateByPrimaryKeySelective(user);
        }
        return user;
    }

...

}

运行示例程序

启动服务

直接运行各个模块的Application启动应用即可。

 

测试服务

成功案例

测试一下接口,观察控制台输出和数据库记录。

测试接口:

http://localhost:8005/testCommit

回滚案例

测试一下接口,观察控制台输出和数据库记录。

测试接口:

http://localhost:8005/testRollback

 

源码下载

码云:https://gitee.com/liuge1988/seata-demo.git


作者:朝雨忆轻尘
出处:https://www.cnblogs.com/xifengxiaoma/ 
版权所有,欢迎转载,转载请注明原文作者及出处。

以上是关于分布式事务:SpringBoot+Dubbo+Seata+Nacos 实现案例的主要内容,如果未能解决你的问题,请参考以下文章

springboot2.x+dubbo2.x+seata1.x AT+nacos+zk实现分布式事务

dubbo教程-09-dubbo分布式事务 ? 看看dubbo作者怎么说 !

基于Dubbo的分布式事务框架(LCN)

dubbo项目开发实战

dubbo(x)分布式事务解决方案

调用dubbo服务时事务配置在哪