快捷導(dǎo)航

springboot 整合 seata的配置過程

更新時間：2022年05月20日 15:41:38 作者：秋葉清風(fēng)

本文給大家介紹springboot 整合 seata的配置過程，本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友參考下吧

前言：

小編引入的圖片和文字描述都是來自于尚硅谷的視頻講解，在此感謝尚硅谷的老師,同時也結(jié)合 seata文檔官方文檔進(jìn)行整合
項目地址（gitee）: https://gitee.com/qinenqi/online
springboot整合 seata

1.整合配置

online-project 這個服務(wù)調(diào)用 online-coupon這個服務(wù)

在這兩個被整合的服務(wù)對用的數(shù)據(jù)庫中分別創(chuàng)建 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>

小編這兒已經(jīng)引入了阿里的相關(guān)組件，請根據(jù)自己的實際情況進(jìn)行處理

 <!--        服務(wù)注冊/發(fā)現(xiàn)-->
        <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，要根據(jù)這個版本下載相應(yīng)的seata 服務(wù)器

在這里插入圖片描述

4.下載對應(yīng)的服務(wù)器軟件包

下載地址：seata下載地址，小編下載是seata-server-0.7.1，下載完成之后解壓文件

5.修改配置文件

進(jìn)入 conf文件夾，修改registry.conf

在這里插入圖片描述

在注冊中，小編配置的是nacos, 把type = “file” 改成 type = “nacos”，

在這里插入圖片描述

在配置信息中，小編用的是默認(rèn)的文件方式

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文件夾下復(fù)制到項目的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 服務(wù)（startup.cmd、seata-server.bat）

在這里插入圖片描述

服務(wù)啟動以后，訪問 http://127.0.0.1:8848/nacos/，可以看到 seata的服務(wù)

9.給分布式大事務(wù)的入口標(biāo)注@GlobalTransactional、每一個遠(yuǎn)程的小事務(wù)用 @Transactional

在這里插入圖片描述

10.具體業(yè)務(wù)：

在 online-project服務(wù)的ProjectController中

 /**
     *  根據(jù) id 更新數(shù)據(jù)
     * @param project
     * @return
     */
    @PostMapping("/updateProjectById")
    public R updateProjectById(@RequestBody Project project){
        projectService.updateProjectById(project);
        return R.ok();
    }

在 CouponServiceImpl中

/**
     *  從 商品哪兒調(diào)用  用來測試 seata
     */
    @Transactional
    public void  testSeata(){
        CouponEntity couponEntity = new CouponEntity();
        couponEntity.setId(4L);
        couponEntity.setCouponName("從 商品哪兒調(diào)用  用來測試 seata02");
        couponMapper.updateById(couponEntity);
//        int number = 2/0;
    }

在online-coupon服務(wù)CouponController中

 /**
     *  從 商品哪兒調(diào)用  用來測試 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中

/**
     *  從 商品哪兒調(diào)用  用來測試 seata
     */
    @Transactional
    public void  testSeata(){
        CouponEntity couponEntity = new CouponEntity();
        couponEntity.setId(4L);
        couponEntity.setCouponName("從 商品哪兒調(diào)用  用來測試 seata02");
        couponMapper.updateById(couponEntity);
//        int number = 2/0;
    }

兩個服務(wù)之間的調(diào)用使用的 openforeign，經(jīng)過小編的測試，兩個微服務(wù)實現(xiàn)了分布式事務(wù)的一致性

到此這篇關(guān)于springboot 整合 seata的文章就介紹到這了,更多相關(guān)springboot 整合 seata內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: