SpringBoot+Dubbo+Seata分布式事务实战

栏目: Java · 发布时间: 5年前

内容简介:事实上,官方在为什么笔者要重新写一遍呢,主要原因有两点:

Seata 是 阿里巴巴开源的分布式事务中间件,以高效并且对业务0侵入的方式,解决微服务场景下面临的分布式事务问题。

事实上,官方在 GitHub 已经给出了多种环境下的 Seata 应用示例项目,地址: https://github.com/seata/seata-samples

为什么笔者要重新写一遍呢,主要原因有两点:

  • 官网代码示例中,依赖太多,分不清哪些有什么作用
  • Seata相关资料较少,笔者在搭建的过程中,遇到了一些坑,记录一下

一、环境准备

本文涉及软件环境如下:

  • SpringBoot 2.1.6.RELEASE
  • Dubbo 2.7.1
  • Mybatis 3.5.1
  • Seata 0.6.1
  • Zookeeper 3.4.10

1、业务场景

为了简化流程,我们只需要订单和库存两个服务。创建订单的时候,调用库存服务,扣减库存。

涉及的表设计如下:

CREATE TABLE `t_order` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `order_no` varchar(255) DEFAULT NULL,
  `user_id` varchar(255) DEFAULT NULL,
  `commodity_code` varchar(255) DEFAULT NULL,
  `count` int(11) DEFAULT '0',
  `amount` double(14,2) DEFAULT '0.00',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=38 DEFAULT CHARSET=utf8;

CREATE TABLE `t_storage` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `commodity_code` varchar(255) DEFAULT NULL,
  `name` varchar(255) DEFAULT NULL,
  `count` int(11) DEFAULT '0',
  PRIMARY KEY (`id`),
  UNIQUE KEY `commodity_code` (`commodity_code`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
复制代码

另外还需要一个回滚日志表:

CREATE TABLE `undo_log` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `branch_id` bigint(20) NOT NULL,
  `xid` varchar(100) 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,
  `context` varchar(100) DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=67 DEFAULT CHARSET=utf8;
复制代码

2、Seata下载安装

打开 https://github.com/seata/seata/releases ,目前最新版本是 v0.6.1

下载解压后,到 seata-server-0.6.1\distribution\bin 目录下可以看到 seata-server.bat和seata-server.sh ,选择一个双击执行。

不出意外的话,当你看到 -Server started ... 等字样,就正常启动了。

3、Maven依赖

由于是Dubbo项目,我们先引入Dubbo相关依赖。

<dependency>
	<groupId>org.apache.dubbo</groupId>
	<artifactId>dubbo</artifactId>
	<version>2.7.1</version>
</dependency>
<dependency>
	<groupId>org.apache.dubbo</groupId>
	<artifactId>dubbo-spring-boot-starter</artifactId>
	<version>2.7.1</version>
</dependency>
复制代码

Dubbo的服务要注册到Zookeeper,引入curator客户端。

<dependency>
	<groupId>org.apache.curator</groupId>
	<artifactId>curator-framework</artifactId>
	<version>2.13.0</version>
</dependency>
<dependency>
	<groupId>org.apache.curator</groupId>
	<artifactId>curator-recipes</artifactId>
	<version>2.13.0</version>
</dependency>
复制代码

最后,引入Seata。

<dependency>
	<groupId>io.seata</groupId>
	<artifactId>seata-all</artifactId>
	<version>0.6.1</version>
</dependency>
复制代码

当然了,还有其他的如 Mybatis、mysql-connector 等就不粘了,自行引入即可。

二、项目配置

1、application.properties

这里只需要配置数据库连接信息和Dubbo相关信息即可。

server.port=8011

spring.datasource.url=jdbc:mysql://127.0.0.1:3306/seata
spring.datasource.username=root
spring.datasource.password=root

dubbo.application.name=order-service
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20881
dubbo.consumer.timeout=9999999
dubbo.consumer.check=false
复制代码

2、数据源

Seata 是通过代理数据源实现事务分支,所以需要先配置一个数据源的代理,否则事务不会回滚。

@Bean
public DataSourceProxy dataSourceProxy(DataSource dataSource) {
	return new DataSourceProxy(dataSource);
}
复制代码

注意,这里的 DataSourceProxy 类位于 io.seata.rm.datasource 包内。

3、Seata配置

还需要配置全局事务扫描器。有两个参数,一个是应用名称,一个是事务分组。

@Bean
public GlobalTransactionScanner globalTransactionScanner() {
	return new GlobalTransactionScanner("springboot-order", "my_test_tx_group");
}
复制代码

事实上,关于Seata事务的一系列初始化工作都在这里完成。

4、配置注册中心

Seata 连接到服务器的时候需要一些配置项,这时候有一个 registry.conf 文件可以指定注册中心和配置文件是什么。

这里有很多可选性,比如 file、nacos 、apollo、zk、consul

后面4个都是业界成熟的配置注册中心产品,为啥还有个file呢?

官方的初衷是在不依赖第三方配置注册中心的基础上快速集成测试 seata 功能,但是 file 类型本身不具备注册中心的动态发现和动态配置功能。

registry.conf 文件内容如下:

registry {
  type = "file"
  file {
    name = "file.conf"
  }
}
config {
  # file、nacos 、apollo、zk、consul
  type = "file"
  file {
    name = "file.conf"
  }
}
复制代码

如果你选择了 file 类型,通过name属性指定了 file.conf ,这个文件中指定了客户端或服务器的配置信息。比如传输协议、服务器地址等。

service {
  #vgroup->rgroup
  vgroup_mapping.my_test_tx_group = "default"
  #only support single node
  default.grouplist = "127.0.0.1:8091"
  #degrade current not support
  enableDegrade = false
  #disable
  disable = false
}
复制代码

三、业务代码

1、库存服务

在库存服务中,拿到商品编码和购买总个数,扣减即可。

<update id="decreaseStorage">
	update t_storage set count = count-${count} where commodity_code = #{commodityCode}
</update>
复制代码

然后用Dubbo将库存服务扣减接口暴露出去。

2、订单服务

在订单服务中,先扣减库存,再创建订单。最后抛出异常,然后去数据库检查事务是否回滚。

@GlobalTransactional
public void createOrder(OrderDTO orderDTO) {

	System.out.println("开始全局事务。XID="+RootContext.getXID());
	StorageDTO storageDTO = new StorageDTO();
	storageDTO.setCount(orderDTO.getCount());
	storageDTO.setCommodityCode(orderDTO.getCommodityCode());
	
	//1、扣减库存
	storageDubboService.decreaseStorage(storageDTO);
	
	//2、创建订单
	orderDTO.setId(order_id.incrementAndGet());
	orderDTO.setOrderNo(UUID.randomUUID().toString());
	Order order = new Order();
	BeanUtils.copyProperties(orderDTO,order);
	orderMapper.createOrder(order);

	throw new RuntimeException("分布式事务异常..."+orderDTO.getOrderNo());
}
复制代码

值得注意的是,在订单服务事务开始的方法上,需要标注 @GlobalTransactional 。另外,在库存服务的方法里,不需要此注解,事务会通过Dubbo进行传播。

四、注意事项

1、数据源

请切记,Seata 是通过代理数据源实现事务分支,一定不要忘记配置数据源代理。

2、主键自增

在数据库中,表里的主键ID字段都是自增的。如果你的字段不是自增的,那么在Mybatis的 insert SQL 中,要将列名写完整。

比如我们可以这样写SQL:

INSERT INTO table_name VALUES (值1, 值2,....)
复制代码

那么这时候就要写成:

INSERT INTO table_name (列1, 列2,...) VALUES (值1, 值2,....)
复制代码

3、序列化问题

在订单表中, amount 字段类型为 double 。在 seata0.6.1 版本中,默认的序列化方式为 fastjson ,但它会将这个字段序列化成 bigdecimal 类型,会导致后面类型不匹配。

但是在后续的 seata0.7.0 版本中(还未发布),已经将默认的序列化方式改为了 jackson

不过无需担心,这个问题一般不会出现。笔者是因为引错了一个包,才导致发现这问题。


以上所述就是小编给大家介绍的《SpringBoot+Dubbo+Seata分布式事务实战》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

挑战编程技能

挑战编程技能

Brian P. Hogan / 臧秀涛 / 人民邮电出版社 / 2017-2 / 39.00元

新手程序员在具备了理论基础后,面对实际项目时,往往不知道如何解决问题;有经验的程序员在学习了一门新语言后,也会有很多不知道如何使用的特性。针对程序员的这一普遍困惑,资深软件工程师Brian P. Hogan在这本书中总结了57道练习题,教他们如何锤炼技能。这些练习题的难度会逐渐增加,使得编程训练充满挑战又乐趣多多。一起来看看 《挑战编程技能》 这本书的介绍吧!

JSON 在线解析
JSON 在线解析

在线 JSON 格式化工具

RGB转16进制工具
RGB转16进制工具

RGB HEX 互转工具

XML、JSON 在线转换
XML、JSON 在线转换

在线XML、JSON转换工具