Seata

「爱情、让人受尽委屈。」 2022-12-08 12:55 118阅读 0赞

seata的版本不要乱选 [https://github.com/alibaba/spring-cloud-alibaba/wiki/%E7%89%88%E6%9C%AC%E8%AF%B4%E6%98%8E][https_github.com_alibaba_spring-cloud-alibaba_wiki_E7_89_88_E6_9C_AC_E8_AF_B4_E6_98_8E]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70][]

本文使用seata 0.7.1版本  1.3.0的使用参考[seata-1.3.0解决SpringCloud分布式事务 nacos注册中心][seata-1.3.0_SpringCloud_ nacos]

seata AT 模式（Automatic Transaction）的使用

*  每个微服务创建UNDO\_LOG 表   [http://seata.io/zh-cn/docs/user/quickstart.html][http_seata.io_zh-cn_docs_user_quickstart.html]

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;

*  安装事务协调器seata-server, 启动服务 
 *  整合 1.导入依赖spring-cloud-starter-alibaba-seata 注意seata-all 0.7.1![20200919113356266.png][]

2.解压并启动seata-server

registry.conf:注册中心配置. 修改registry type=nacos

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 1][]

3.需要使用分布式事务的微服务要用seata DataSourceProxy代理自己的数据源

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;
    
    /**
     * @author jl
     * Created on 2020/9/19
     */
    @Configuration
    public class SeataDataSouceConfig {
        @Autowired
        private DataSourceProperties dataSourceProperties;
    
        @Bean
        public DataSource dataSource(DataSourceProperties dataSourceProperties) {
            HikariDataSource hikariDataSource = dataSourceProperties.initializeDataSourceBuilder().type(HikariDataSource.class).build();
            if (StringUtils.hasText(dataSourceProperties.getName())) {
                hikariDataSource.setPoolName(dataSourceProperties.getName());
            }
            return new DataSourceProxy(hikariDataSource);
        }
    }

4.每个微服务都要导入file.conf和registry.conf, 修改file.conf

**                vgroup\_mapping.`${spring.application.name}`\-fescar-service-group = "default"**

*  file.conf 的 service.vgroup\_mapping 配置必须和`spring.application.name`一致

在 `org.springframework.cloud:spring-cloud-starter-alibaba-seata`的`org.springframework.cloud.alibaba.seata.GlobalTransactionAutoConfiguration`类中，默认会使用 `${spring.application.name}-fescar-service-group`作为服务名注册到 Seata Server上，如果和`file.conf`中的配置不一致，会提示 `no available server to connect`错误

也可以通过配置 `spring.cloud.alibaba.seata.tx-service-group`修改后缀，但是必须和`file.conf`中的配置保持一致

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 2][]

5.分布式事务的入口添加@GlobalTransactional注解, 远程服务事务用@Transactional

6.启动项目测试

[https_github.com_alibaba_spring-cloud-alibaba_wiki_E7_89_88_E6_9C_AC_E8_AF_B4_E6_98_8E]: https://github.com/alibaba/spring-cloud-alibaba/wiki/%E7%89%88%E6%9C%AC%E8%AF%B4%E6%98%8E
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70]: /images/20221123/0c82451732fe4aa1ad00c7e689479d6a.png
[seata-1.3.0_SpringCloud_ nacos]: https://blog.csdn.net/sinat_38670641/article/details/108237920?utm_medium=distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-1.channel_param&depth_1-utm_source=distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-1.channel_param
[http_seata.io_zh-cn_docs_user_quickstart.html]: http://seata.io/zh-cn/docs/user/quickstart.html
[20200919113356266.png]: /images/20221123/e5fa723b6d594634a6b18f3256bffe24.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 1]: /images/20221123/ab5adc330a4e43869f44a71f6db4a093.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5OTQwMjA1_size_16_color_FFFFFF_t_70 2]: /images/20221123/e1df866c5c1d40118a29db1e3aeb5762.png