springboot 整合 seata的配置过程
作者:秋叶清风 发布时间:2023-01-13 01:28:33
前言:
小编引入的图片和文字描述都是来自于尚硅谷的视频讲解,在此感谢尚硅谷的老师,同时也结合 seata文档官方文档进行整合
项目地址(gitee): https://gitee.com/qinenqi/online
springboot整合 seata
1.整合配置
online-project 这个服务调用 online-coupon这个服务
在 这两个被整合的服务对用的数据库中分别 创建 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;
2. 引入依赖
<!-- seata -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>
小编这儿已经引入了 阿里的相关组件,请根据自己的实际情况进行处理
<!-- 服务注册/发现-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!-- 配置中心来做配置管理-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
引入依赖后,查看自己的 seata-all-0.7.1,要根据这个版本下载相应的seata 服务器
4.下载对应的服务器软件包
下载地址:seata下载地址,小编下载是seata-server-0.7.1,下载完成之后解压文件
5.修改配置文件
进入 conf文件夹,修改registry.conf
在注册中, 小编配置的是nacos, 把type = “file” 改成 type = “nacos”,
在配置信息中,小编用的是默认的文件方式
6.在online-coupon、online-project 新建 MySeataConfig
import com.zaxxer.hikari.HikariDataSource;
import io.seata.rm.datasource.DataSourceProxy;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.util.StringUtils;
import javax.sql.DataSource;
@Configuration
public class MySeataConfig {
@Autowired
DataSourceProperties dataSourceProperties;
@Bean
public DataSource dataSource(DataSourceProperties dataSourceProperties){
HikariDataSource dataSource = dataSourceProperties.initializeDataSourceBuilder().type(HikariDataSource.class).build();
if (StringUtils.hasText(dataSourceProperties.getName())) {
dataSource.setPoolName(dataSourceProperties.getName());
}
return new DataSourceProxy(dataSource);
}
}
7.分别引入配置文件
(file.conf、registry.conf)并修改 vgroup_mapping.my_test_tx_group = “default”
把这两个配置文件从conf文件夹下复制到项目的resources目录下,分别修改file.conf,把vgroup_mapping.my_test_tx_group = "default"分别修改成vgroup_mapping.online-coupon-fescar-service-group = "default"和 vgroup_mapping.online-project-fescar-service-group = “default”
8.启动nacos 和 seata 服务(startup.cmd、seata-server.bat)
服务启动以后,访问 http://127.0.0.1:8848/nacos/, 可以看到 seata的服务
9.给分布式大事务的入口标注@GlobalTransactional、每一个远程的小事务用 @Transactional
10.具体业务:
在 online-project服务的ProjectController中
/**
* 根据 id 更新数据
* @param project
* @return
*/
@PostMapping("/updateProjectById")
public R updateProjectById(@RequestBody Project project){
projectService.updateProjectById(project);
return R.ok();
}
在 CouponServiceImpl中
/**
* 从 商品哪儿调用 用来测试 seata
*/
@Transactional
public void testSeata(){
CouponEntity couponEntity = new CouponEntity();
couponEntity.setId(4L);
couponEntity.setCouponName("从 商品哪儿调用 用来测试 seata02");
couponMapper.updateById(couponEntity);
// int number = 2/0;
}
在online-coupon服务CouponController中
/**
* 从 商品哪儿调用 用来测试 seata
* @return
*/
@RequestMapping("/testSeata")
public R testSeata(){
couponService.testSeata();
return R.ok();
}
新建 CouponFeignService
import com.example.onlinecommon.utils.R;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
@FeignClient("online-coupon")
public interface CouponFeignService {
@RequestMapping("/coupon/couponController/testSeata")
R testSeata();
}
在 CouponServiceImpl中
/**
* 从 商品哪儿调用 用来测试 seata
*/
@Transactional
public void testSeata(){
CouponEntity couponEntity = new CouponEntity();
couponEntity.setId(4L);
couponEntity.setCouponName("从 商品哪儿调用 用来测试 seata02");
couponMapper.updateById(couponEntity);
// int number = 2/0;
}
两个服务之间的调用使用的 openforeign,经过小编的测试,两个微服务实现了分布式事务的一致性
来源:https://blog.csdn.net/weixin_41695138/article/details/119831809
猜你喜欢
- 需要实现看门狗功能,定时检测另外一个程序是否在运行,使用 crontab 仅可以实现检测程序是否正在运行,无法做到扩展,如:手动重启、程序升
- 使用JAVA工程管理越来越多的jar包,担心导错了,多导了,漏导了怎么办?换一个IDE项目后项目会不会出一堆BUG,看的头皮发麻?自己写的代
- 导语:有些时候我们所需要查询的数据量比较大,但是jvm内存又是有限制的,数据量过大会导致内存溢出。这个时候就可以使用流式查询,数据一条条的返
- 在构建RESTful数据服务过程中,我们定义了controller、repositories,并用一些注解修饰它们,但是到现在为止我们还没执
- 1、修改application.properties新建 Mapper、实体类 相应的文件夹,将不同数据源的文件保存到对应的文件夹下# te
- 在 Java 中,LinkedList 和 ArrayList 的性能是不同的,具体取决于你所需要的操作。对于频繁的插入和删除操作,Link
- Navigator 的 push 和 pop方法Navigator 导航器的 push 和 pop 方法可以携带参数在页面间传递,其他变形的
- 判断参数是否为空并作为查询条件@Override public Page<DemandEntity>
- 简介使用配置类和注解代替web.xml和SpringMVC配置文件的功能在Servlet3.0环境中,容器会在类路径中查找实现javax.s
- 实例如下:ServletRequestAttributes aRequestAttributes=(ServletRequestAttrib
- 具体安装步骤,不再赘述,仅附上个人工作、学习中的对 EasyCode 的详细配置。插件链接地址:https://gitee.com/make
- 对于因为编程错误而导致的异常,或者是不能期望程序捕获的
- 1: .net framework 由两个部分组成:CLR 和 FCL。2:在CLR中,所有错误都是通过异常来报告的。3:智能感知功能主要是
- 双向顺序队列ArrayDeque和双向链式队列LinkedList,JDK已经包含,在此略。ArrayDeque包括顺序栈和顺序队列,Lin
- Spring MVC Controller控制器,是MVC中的部分C,为什么是部分呢?因为此处的控制器主要负责功能处理部分:收集、验证请求参
- Java7中文件IO发生了很大的变化,专门引入了很多新的类:import java.nio.file.DirectoryStream;imp
- 前言项目使用了SpringBoot构建项目。下面对动态调整日志的级别进行记录。从版本 1.5.1 之后就提供了基于 spring-boot-
- 1、conditional注解介绍含义: 基于条件的注解作用: 根据是否满足某一个特定条件来决定是否创建某个特定的bean意义: Sprin
- JVM内部结构图Java虚拟机主要分为五个区域:方法区、堆、Java栈、PC寄存器、本地方法栈。下面来看一些关于JVM结构的重要问题。1.哪
- SpringBoot 集成 activiti 基础环境搭建添加依赖<dependency> <groupId&g