spring boot + mybatis 使用线程池异步修改数据库数据

在Spring Boot + Mybatis中使用线程池实现多线程异步修改数据库数据并避免Session关闭问题，需结合线程池管理、事务控制及SqlSession生命周期管理。在多线程环境下，每个线程需要独立的SqlSession，因为SqlSession不是线程安全的。以下是具体方案及最佳实践：

1. 线程池配置与异步执行

• 线程池配置：通过ThreadPoolTaskExecutor配置线程池，设置核心参数：

  @Configuration
  @EnableAsync
  public class ThreadPoolConfig {
      @Bean("taskExecutor")
      public Executor taskExecutor() {
          int corePoolSize = Runtime.getRuntime().availableProcessors() * 2;
  
          ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
          executor.setCorePoolSize(corePoolSize);
          executor.setMaxPoolSize(corePoolSize * 2);
          executor.setQueueCapacity(200); // 任务队列容量
          executor.setThreadNamePrefix("AsyncDB-");
          executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); // 拒绝策略
          executor.initialize();
          return executor;
      }
  }

  • 
    使用@EnableAsync启用异步支持，避免Executors直接创建线程池（防止OOM）。
• 异步方法声明：在Service层使用@Async注解标记异步方法：

  @Service
  public class UserService {
      @Async("taskExecutor")
      @Transactional // 事务管理
      public void asyncUpdateUser(User user) {
          // 数据库操作逻辑
      }
  }

2. 事务管理与SqlSession生命周期

• 事务上下文传播：由于@Async方法在独立线程运行，需显式声明事务。关键点：
  • 在异步方法上直接使用@Transactional，确保事务绑定到当前线程。
  • 避免跨线程共享SqlSession，通过SqlSessionFactory为每个线程创建独立Session：

    @Service
    public class UserService {
        @Autowired
        private SqlSessionFactory sqlSessionFactory;
    
        @Async("taskExecutor")
        public void asyncUpdateUser(User user) {
            try (SqlSession session = sqlSessionFactory.openSession()) {
                UserMapper mapper = session.getMapper(UserMapper.class);
                mapper.updateUser(user);
                session.commit(); // 提交事务
            } // 自动关闭session，释放连接
        }
    }

  • 使用try-with-resources确保SqlSession在操作后自动关闭，避免Session泄漏。

3. 连接池与数据源配置

• POOLED数据源：在application.yml中配置连接池（如HikariCP），确保连接复用：

  mybatis:
    configuration:
      default-executor-type: REUSE # 复用Executor
  spring:
    datasource:
      url: jdbc:mysql://localhost:3306/db?useSSL=false
      username: root
      password: password
      hikari:
        maximum-pool-size: 20 # 连接池大小与线程池匹配
        idle-timeout: 30000

  • 连接池大小需与线程池最大线程数协调，避免连接耗尽。

4. 异常处理与资源释放

• 强制关闭机制：在finally块中显式关闭SqlSession，防止异常导致连接未释放：

  SqlSession session = null;
  try {
      session = sqlSessionFactory.openSession();
      // 执行数据库操作
      session.commit();
  } catch (Exception e) {
      session.rollback(); // 回滚事务
  } finally {
      if (session != null) session.close();
  }

• 监控与调优：通过Spring Boot Actuator监控线程池和连接池状态：

  management:
    endpoints:
      web:
        exposure:
          include: metrics,threadpool

  • 动态调整线程池参数（如队列容量、最大线程数）以适应负载。

5. 最佳实践验证

• 避免跨线程共享：确保每个线程使用独立的SqlSession，禁止在多线程间共享SqlSession实例。
• 批量处理优化：对于高频异步任务，采用Mybatis批量操作（如<foreach>标签）减少数据库交互次数。
• 日志跟踪：启用Mybatis日志（logging.level.org.mybatis=DEBUG），监控Session创建/关闭过程。

通过上述方案，可实现线程池驱动下的异步数据库操作，同时确保SqlSession生命周期管理严格遵循“按需创建、操作后关闭”原则，避免Session关闭导致的操作异常。实际开发中，建议结合监控工具（如Actuator）持续优化线程池和连接池配置，确保系统稳定高效运行。