Spring cloudjavaWeb学习Spring-Boot

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

2019-07-04  本文已影响3人  70b39f9dc443

前言

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、业务场景

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

涉及的表设计如下:

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

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的服务要注册到Zookeeper,引入curator客户端。

最后,引入Seata。

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

二、项目配置

1、application.properties

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

2、数据源

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

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

3、Seata配置

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

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

4、配置注册中心

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

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

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

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

registry.conf文件内容如下:

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

三、业务代码

1、库存服务

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

<update id="decreaseStorage">

update t_storage set count = count-${count} where commodity_code = #{commodityCode}</update>

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

2、订单服务

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

值得注意的是,在订单服务事务开始的方法上,需要标注@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。

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

上一篇 下一篇

猜你喜欢

热点阅读