记一次springcloud+seata事务不进行回滚

蔚落 2022-11-27 03:27 352阅读 0赞

不想看分析的。直接翻到最低。看解决方案

springcloud增加seata maven依赖

<dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-alibaba-seata</artifactId>
        <version>2.1.0.RELEASE</version>
        <exclusions>
            <exclusion>
                <artifactId>seata-all</artifactId>
                <groupId>io.seata</groupId>
            </exclusion>
        </exclusions>
    </dependency>
    
    
    <dependency>
        <groupId>io.seata</groupId>
        <artifactId>seata-all</artifactId>
        <version>0.9.0</version>
    </dependency>

**在application.yml中增加seata实例名以及增加file.conf和registry.conf。这两个文件可以直接从seata服务中拷贝**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NheWdvb2Q5OTk_size_16_color_FFFFFF_t_70][]

**然后我准备了三个服务和一个注册中心eureka.**

![20200813153553754.png][]

**orders-service中调用user-service ,user-service 中调用product-service。启动注册中心和orders-service，user-service。product-service不启动。**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NheWdvb2Q5OTk_size_16_color_FFFFFF_t_70 1][]

**然后请求。异常有抛出。就一直未回滚事务。数据还入了库。最后通过源码分析。我断定应该undo\_log数据未进行插入。打个断点果然undo\_log这个表。一直就没有数据。undo\_log这个表的意义就在。暂存上一个节点提交的事务。如果有异常。就会把这个数据回滚掉。也就是说下图这段代码肯定是没走**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NheWdvb2Q5OTk_size_16_color_FFFFFF_t_70 2][]

最后翻翻源码发现。这个代理连接的类。是被DataSourceProxy调用的

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NheWdvb2Q5OTk_size_16_color_FFFFFF_t_70 3][] 哦哦。那问题大致就出来了。也就是数据源。我要把这个DataSourceProxy进行配置下咯

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NheWdvb2Q5OTk_size_16_color_FFFFFF_t_70 4][]

重新启动。然后就这样解决了。

解决方案：加入以下配置（注意：DataSourceProxy是seata包下的）

@Bean
    public SqlSessionFactoryBean sqlSessionFactoryBean(){
       SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSourceProx());
       return sqlSessionFactoryBean;
    }
    @Bean
    @ConditionalOnBean(DataSource.class)
    public DataSourceProxy dataSourceProx() {
        return new DataSourceProxy(dataSource);
    }

项目我已放到gitee上[https://gitee.com/eduction/springcloudSeata][https_gitee.com_eduction_springcloudSeata] 。需要的自取参考

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NheWdvb2Q5OTk_size_16_color_FFFFFF_t_70]: /images/20221124/cc6e22123a854695b2ed9effa7d2c943.png
[20200813153553754.png]: /images/20221124/571a3a21cf724bf6b922338e133d28b5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NheWdvb2Q5OTk_size_16_color_FFFFFF_t_70 1]: /images/20221124/76d732d32c1b42fea9293cbf2129d8fd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NheWdvb2Q5OTk_size_16_color_FFFFFF_t_70 2]: /images/20221124/ff1da4bf75a14ccabb590c08e5e44b17.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NheWdvb2Q5OTk_size_16_color_FFFFFF_t_70 3]: /images/20221124/9005411467b041d6879491c10a4a806f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NheWdvb2Q5OTk_size_16_color_FFFFFF_t_70 4]: /images/20221124/007e5b1b2f4a409dba8f06a89728657b.png
[https_gitee.com_eduction_springcloudSeata]: https://gitee.com/eduction/springcloudSeata