SEATA第三章:快速开始 AT模式(springboot)整合

前言:原文链接

上一章节我们讲述AT模式整合spring案例,此章节我们讲述AT模式整合spring boot案例,有如下几个知识点需要大家注意:dubbo,nacos,mybatis,mybatis-plus。(敲黑板:此章节的案例是依托于seata-samples项目中 springboot-dubbo-seata项目,没有下载的同学去github搜索此项目https://github.com/seata/seata-samples.git)

一.业务场景分析

和上一章节讲述的一致,下单业务场景,这里不再赘述。

二.pom文件分析

1.spring boot依赖引入

此项目没有通过标签继承父模块来构建,直接引入的 pom中的所有内容。

小提示:<spring-boot-dependencies>只能在dependencyManagement中使用

2.dubbo依赖引入

这里有不确定的一点标签是否包含的功能,我本人认为是包含的,与spring boot整合引入第一个标签就够了。

3.seata依赖引入

4.nacos依赖引入

5.数据源与mybatis依赖引入

三.项目结构分析

此案例项目以maven聚合模式构建,分为五个平行的模块。

samples-account----------账户扣减

samples-common---------公用依赖

samples-order--------------订单生成模块

samples-storage------------库存扣减

samples-business-----------客户订购

sql-------------------------------初始化的db文件

四.快速启动

samples-account

打开application.properties配置文件,修改dubbo.registry.address地址为你的nacos地址,修改mysql config中地址信息。

打开seata配置文件registry.conf,修改注册中心类型为nacos,配置注册中心信息,注意nacos.application依然是你seata-server注册到nacos的服务名称。配置中心我们依然选择默认的file,file文件中的内容我们使用默认配置。

初始化sql文件,注意分为三个库,依次为:account,order,storage。将对应的三张表初始化到对应的物理库,且在每一个物理库中初始化表结构undo_log。

配置文件以及数据库信息我们都已完成,现在我们调用启动类的main函数启动。理想很美好,现实很骨感,我们突然发现,启动后内嵌的tomcat自动stop了,咦,异常日志呢。。。。别急因为某种特殊原因异常日志没有输出,我们在启动模块加上try,catch,在启动一遍:

异常抛出缺失jackson依赖,OK我们在本项目pom文件中引入(实际上应该在common模块pom文件中引入下面依赖,然后在升级Jar包,毕竟是公共模块,我这里是为了简单)

<dependency>            <groupId>com.fasterxml.jackson.core</groupId>            <artifactId>jackson-databind</artifactId></dependency><dependency>            <groupId>com.fasterxml.jackson.core</groupId>            <artifactId>jackson-core</artifactId>            <version>2.10.0.pr1</version></dependency>

刷新一下项目 Reimport 在重新启动,发现项目正常启动,且不在自动关停,打开nacos注册中心放心提供者正常注册。

samples-order,samples-storage,samples-business模块不一一示例,和上述项目流程一样,当所有项目启动成功后,我们通过postman工具请求客户订单接口地址生成订单

好目前为止我们已经成功的生成了订单,现在测试一下全局事物的异常回滚,打开samples-business项目BusinessServiceImpl类,将抛出异常的代码放开注释

现在继续请求我们Postman写好的地址,请求后系统给我们的响应是500且提示事物异常回滚测试,说明全局事物回滚发生了

我们现在需要确定下全局事物是否成功回滚,打开我们的t_order表,数据一条也就是我们第一次生成的订单数据,说明第二次生成的订单数据逆向回滚了,如果想要跟踪的同学可以在生成订单后抛出异常前打上断点调试一下。

五.构建分析

拿samples-account和samples-common举例

1.dubbo整合分析

dubbo远程调用是基于接口(当然http请求除外),故需要把接口抛到一个jar,让调用方引入这个jar(基于SPI原理)。此项目将所有模块的对外暴露接口都整合到common模块,我本人建议大家不要这么做,容易混乱。为每一个模块都构建一个api项目,account模块应该是由两部分组成:account-api,account-service(samples-account)。

好回到正题,AccountDubboServiceImpl业务实现类通过dubbo的service注解设置提供者,具体参数含义大家可以到dubbo官网看一看。在启动类中我们必须要通过@EnableDubbo开启dubbo注解功能,且在注解中配置扫描包的位置。依赖可以往上翻到第二个模块查看。

2.数据源整合分析

打开SeataAutoConfig配置类,代码分为5块:

druid数据源设置

seata数据源代理

spring事物注入数据源对象

mybatis的SqlSession数据源对象注入以及xml加载配置

seata的scanner设置

3.mybatis-plugs和mybatis整合分析

在SeataAutoConfig中配置了SqlSession数据源以及xml加载配置,启动类中@MapperScan()注解配置mybatis扫描Mapper接口限定位置

mybatis-plugs是mybatis的一个增强工具,简化开发,提高效率,无侵入,有兴趣的同学可以到其官网研究一番(https://mp.baomidou.com/),这里只讲解项目中大概用法:

mapper

我们打开TAcountMapper类,发现其继承BaseMapper<T> T则是实体对象,接着我们点开父类BaseMapper查看到有很多常用的接口方法,这个就是plugs为我们提供的基础curd,service可以直接调用,无需自行写xml中sql语句。当然我们也可以自行实现一些特殊的sql语句,同时将sql语句写到对应的xml中,是不是很灵活。

service

mybatis-plugs不仅提供对mapper的封装,还提供service的支持,打开ITAccountService接口类,它继承了IService<T>,T是实体对象,IService中封装了常用的curd操作,内部其实也是调用自己封装的mapper,无非就是减少代码开发, 对于一些简单的操作无需构建Mapper接口文件和mapper的xml文件。打开ITAccountService接口实现了类,他继承于IService<T>接口的实现类,两个泛型参数:第一个是mapper接口类如果没有则默认BaseMapper,第二个参数则是对应数据库的实体对象。

entity

当下有很多DDD的理论领域驱动,根据对象划分模块业务,核心操作都封装在领域对象中而不在下沉到service层(有关于DDD的言论我只是大概叙述,有不对的同学们在文章下留言)。mybatis-plugs提供实体对象的curd操作实现,将对数据库操作逻辑封装到对象中,需要实体对象继承Model对象,打开model对象内部包含很多已封装的数据库操作,外部可以直接在初始化后对象的基础上直接调用数据库操作方法。


4.全局异常处理

在controller层做统一的全局异常处理,封装提示信息响应到前端,通过@ControllerAdvice注解实现,可以区分同步的异常进行拦截从而产生不同的响应。有一点需要注意,当全局事物A调用分支事物B和C通过http,且B和C都有全局异常拦截,那么A就需要判断接收到的响应码显示的抛出异常实现全局事物的正常回滚。

AT模式快速启动我们讲述两种方式,一种基于原始spring配置,一种基于spring boot快速构建,在了解其原理之前首先要做的是会用,下一章我们开始讲解TCC模式的快速启动。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 200,302评论 5 470
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 84,232评论 2 377
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 147,337评论 0 332
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 53,977评论 1 272
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 62,920评论 5 360
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,194评论 1 277
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,638评论 3 390
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,319评论 0 254
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,455评论 1 294
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,379评论 2 317
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,426评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,106评论 3 315
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,696评论 3 303
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,786评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,996评论 1 255
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,467评论 2 346
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,043评论 2 341