使用@Async@Transactional方法Spring靴

Question

我的springboot控制器中有@async方法，它调用service method（async）并执行一些DB事务。当这个控制器@async方法被多次调用而没有时间延迟时，它会导致org.hibernate.exception.JDBCConnectionException：无法获取JDBC连接

控制器

 @PostMapping(value = "/api/sms/sendmsgasync")
  public ResponseEntity<Boolean> sendSMSMessageAsync(@RequestBody MessageRequestDto messageRequestDto) {

    final Future<Boolean> booleanFuture = smsService.sendSingleMessageAsync(messageRequestDto, requestContext.getConversationId());
    log.debug("sendSMSMessageAsync {} <<<<", booleanFuture.isDone());
    return ResponseEntity.ok(true);
  }

服务

 @Async
  @Override
  public Future<Boolean> sendSingleMessageAsync(MessageRequestDto messageRequestDto, String convId) {


    try {
      sendSingleMessage(messageRequestDto, convId);
    }
    catch (BadRequestException | NotFoundException | TwilioException e) {
      LOG.error("Error in sendSingleMessageAsync. Error logged to SMS Gateway db. Exception '" + e.getMessage() + "'", e);
    }
    return new AsyncResult<>(true);
  }

然后调用同一服务类中的sendSingleMessage方法，其中调用NOT跨国方法来进行数据库查找和添加数据库条目等。

当多次调用controllers @async方法而没有时间延迟时，会导致

org . spring framework . transaction . cannotcreatetransactionexception:无法打开事务的JPA EntityManager嵌套异常为org . hibernate . exception . jdbcconnectionexception:无法在获取JDBC连接...............org . spring framework . ORM . JPA . jpatransactionmanager . dobegin(jpatransactionmanager . Java:400)...65常见帧省略原因:Java . SQL . sqltransientconnection异常:HikariPool-1 -连接不可用，请求在30000毫秒后超时。在

需要用service @async方法添加“ThreadExecutor”吗？

我是这方面的新手，所以任何指示都会有帮助

Answer 1

最有可能的原因是以下2个原因之一，即数据库是可连接的：

1)连接池的大小不足。< br >检查属性spring . data source . hikari . maximumpoolsize的值(默认值为20)以确保该数值足够。想想在你的应用程序中可以同时处理多少个请求，假设每个线程都使用自己的连接。

2） 应用程序中的连接泄漏
检查您的连接是否已正确关闭（在本例中返回池）。始终呼叫连接。finally块中的close（）或使用try-with资源来避免异常泄漏。

Answer 2

我也有类似的情况。经过研究，我们发现异步线程正在压倒系统。所有线程都是并行启动的，这耗尽了JDBC连接池。没有为其他线程（如控制器）留下连接。

第一个措施是使用自定义线程执行器，您可以根据自己的资源进行限制。

    @Bean(name = "taskExecutor")
    public ExecutorService taskExecutor() {
        // adjust this value to your CPU cores
        // and to the JDBC connection pool size
        int maxThreads = 4;
        return Executors.newFixedThreadPool(maxThreads);
    }

确保此任务执行程序用于异步方法：

    @Async("taskExecutor")  
    public void myBackgroundThread() {
        ...
    }

在application.properties文件中，设置光数据源的连接池大小。默认值为10。

spring.datasource.hikari.maximum-pool-size=10

请注意，后台进程的线程池小于数据库连接的线程池。否则前台线程将受到影响。