当前位置：首页 > news >正文

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

news 2025/9/8 23:39:33

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

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

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

@Configuration
@EnableAsync
public class ThreadPoolConfig {@Bean("taskExecutor")public Executor taskExecutor() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(10); // 核心线程数executor.setMaxPoolSize(20);  // 最大线程数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 {@Autowiredprivate 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=falseusername: rootpassword: passwordhikari: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();
}