前言：
小編引入的圖片和文字描述都是來自于尚硅谷的視頻講解，在此感謝尚硅谷的老師,同時也結合 seata文檔官方文檔進行整合
項目地址（gitee）: https://gitee.com/qinenqi/online
springboot整合 seata
整合配置
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，經過小編的測試，兩個微服務實現了分布式事務的一致性
到此這篇關于springboot 整合 seata的文章就介紹到這了,更多相關springboot 整合 seata內容請搜索服務器之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持服務器之家！
原文鏈接：https://blog.csdn.net/weixin_41695138/article/details/119831809
