关于分布式事务seata的使用与踩坑（解决修改数据源导致mapper无法注入和java.lang.NoSuchMethodException）

最近在学习分布式事务seata时遇到了一些问题，做个总结记录一下

我们先搭建一个简单的微服务工程（因为是针对解决seata问题，搭建仅展示核心代码）
如果只需要解决问题请跳过
pom

 
        
            mysql
            mysql-connector-java
            8.0.11
        
        
        
            com.baomidou
            mybatis-plus-boot-starter
            3.4.2
        

        
            org.springframework.boot
            spring-boot-starter-freemarker
        

        
            org.springframework.boot
            spring-boot-starter-web
        

        
            com.alibaba.cloud
            spring-cloud-starter-alibaba-seata
        

        
            com.alibaba.cloud
            spring-cloud-starter-alibaba-nacos-discovery
        
        
        
            com.alibaba.cloud
            spring-cloud-starter-alibaba-nacos-config
        
        
        
            org.springframework.boot
            spring-boot-starter-actuator
        

        
        
            org.springframework.cloud
            spring-cloud-starter-bootstrap
        

        
            org.projectlombok
            lombok
            1.18.22
        

        
            org.springframework.boot
            spring-boot-starter-test
            test
        
    

bootstrap.yml

server:
  port: ${port:8011}


spring:
  profiles:
    active: prod
  application:
    # 这里一定要用-定义，不能用下划线，因为负载均衡器如果用下划线会找不到服务。
    name: xq-pug-user-service
  cloud:
    sentinel:
      enabled: true
      web-context-unify: false
#      filter:
#        # 默认情况下对项目中所有的springmvc请求进行流量监控
#        enabled: true
#        url-patterns: /**
      transport:
        # 指定sentinel的服务地址
        dashboard: 127.0.0.1:8080
        # 如果被占用就 +1
        port: 8791

    nacos:
      discovery:
        # 服务的注册与发现 默认是true
        enabled: true
        server-addr: 127.0.0.1:8848
      config:
        # 集群版本
        #server-addr: 127.0.0.1:8848,127.0.0.1:8868,127.0.0.1:8858
        # 单机版本
        server-addr: 127.0.0.1:8848
        # 命名空间 默认是public，不用指定
        namespace: 52adf7ed-1664-453a-9c1e-78f461d7fe11
        # 如果你要修改，可以自己去指定dataid的名字
        prefix: ${spring.application.name}-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
        # 指定配置中心文件的后缀
        file-extension: yaml
        # group 默认：DEFAULT_GROUP
        group: DEFAULT_GROUP
        shared-configs[0]:
          data_id: redis.yaml
          group: COMMON_GROUP
          refresh: true

# 暴露监控断点，给后续的Admin进行监控处理
# 获取单独访问http://localhost:8011/actuator
management:
  endpoints:
    web:
      exposure:
        include: '*'

seata:
  tx-service-group: mygroup # 事务组名称，要和服务端对应
  service:
    vgroup-mapping:
      mygroup: default

application

#监控配置
management:
  endpoints:
    web:
      exposure:
        include: '*'
spring:
  datasource:
    type: com.zaxxer.hikari.HikariDataSource
    # type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://127.0.0.1:3306/lele_alibaba?serverTimezone=GMT%2b8&useUnicode=true&characterEncoding=utf-8&useSSL=false
    username: root
    password: root
  boot:
    admin:
      client:
        url:  http://localhost:8800 #监控服务器的地址
        instance:
          service-url: http://127.0.0.1:8011 #当前系统api地址

数据库中添加回滚日志表undo_log

CREATE TABLE `sys_seata_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,
  PRIMARY KEY (`id`),
  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

at模式下必须要有回滚日志表

AT模式搭建非常的简单，写好示例，启动工程查看即可，也可以直接用官网的示例
官网示例地址：https://github.com/seata/seata-samples/tree/master
这里我用转账来模拟事务，是在同一个微服务下的事务，如果想严谨些也可以用多个微服务通过fegin进行调用（我觉得原理都一样的）
新建一个简单的账单表

编写各层级代码（这里我使用了mybatis-plus，也是后面的踩坑关键所在）

@Mapper
public interface UserMapper extends BaseMapper {
}

public interface UserService extends IService {

    public void get();

    public void set();
}

@Service
public class UserServiceImpl extends ServiceImpl implements UserService {
    @Autowired
    private UserService userService;

    public void get(){
        User user = userService.getById(1L);
        user.setMoney(user.getMoney()-50);
        userService.updateById(user);
    }

    public void set(){
        User user = userService.getById(2L);
        user.setMoney(user.getMoney()+50);
        userService.updateById(user);
    }
}

    @GetMapping("/getUser2")
    @GlobalTransactional
    public List getUser2(){
        userService.get();
        int i = 1/0; // 自己故意写一个异常代码验证事务回滚
        userService.set();

        return userService.list();
    }

seata事务关键代码：@GlobalTransactional

启动项目后，访问接口，在 int i = 1/0; 处打断点调试

这时查看数据库表中的数据变化


释放断点，出现异常，事务回滚，undo_log中的临时数据清空了

XA模式的使用和AT模式非常相似
官网描述：https://seata.io/zh-cn/docs/dev/mode/xa-mode.html

我在使用XA模式的时候，用配置类切换数据源，启动就会报错

这是照着官网说的，写的配置类

这个问题我从昨晚卡到今天下午，看了很多论坛和文章，各种方法都试了，还是没能解决，今天下午打完一把排位之后，瞬间来了灵感，自己解决了。下面是我的解决方案：

首先，使用XA模式修改数据源代理时，要先把seata的数据源自动代理关闭

seata:
  tx-service-group: mygroup # 事务组名称，要和服务端对应
  service:
    vgroup-mapping:
      mygroup: default
  enable-auto-data-source-proxy: false # 关闭seata的数据源自动代理

其次，上面说到我用了mp才导致的错误，用jdbctemplate的时候没有出现这个问题
查看mp的启动源码发现，mp启动类里的sqlSessionFactory方法也是注入一个数据源
所以去掉配置类中SqlSessionFactory的配置，并且加上@Primary注解，让mp优先使用我们自己配置的数据源，这样就解决了因为seata代理数据源导致mapper无法注入的bug

（@Primary：在多个相同的bean中，优先使用@Primary注解的bean，在多数据源的时候，使用@Primary注解用于指定其中一个作为主数据源）

下面是最终的配置类：

@Configuration
public class UserDataSourceConfiguration {

    @Bean
    @ConfigurationProperties(prefix = "spring.datasource")
    public DruidDataSource druidDataSource() {
        return new DruidDataSource();
    }

    @Bean("dataSourceProxy")
    @Primary
    public DataSource dataSource(DruidDataSource druidDataSource) {
        // DataSourceProxy for AT mode
        // return new DataSourceProxy(druidDataSource);

        // DataSourceProxyXA for XA mode
        return new DataSourceProxyXA(druidDataSource);
    }
}

问题一解决之后，再次启动有可能会报新的错误

高版本mysql驱动中的接口com.mysql.cj.conf.PropertySet不存在getBooleanReadableProperty方法，也就是兼容性的问题了

看到源码注释// maybe 8.0.11 or higher version.，于是把mysql依赖更改为8.0.11版本问题解决