私はサービスからメソッドを呼び出すRestControllerを持っています。メソッドは、最大20の接続を持つPostresSQLデータベースにユーザーを追加します。Spring CompletableFutureを返すトランザクションメソッド
@RestController
public class Controller {
@RequestMapping(value = "/user", method = RequestMethod.POST)
public String addUser(@RequestBody UserInfo userInfo) {
Future<String> completableFuture = userService.addUser(userInfo);
String answer = voidCompletableFuture.get();
return answer;
}
}
メソッドは、永続化データメソッドがCompletableFutureを返した後、Spring Transactionalによって注釈付けされます。複数のスレッドからメソッド "/ user"を同時に呼び出します(約100)。現在のスレッドをブロックコードの行「voidCompletableFuture.getは()」は、わずか20の同時要求が作動し、最大接続数によって、データベースにデータを追加して呼び出された場合
@Transactional
public Future<String> addUser(UserInfo userInfo) {
userDao.persist(userInfo);
return CompletableFuture.supplyAsync(() -> {
try {
Thread.sleep(10000);
return "Result";
} catch (InterruptedException e) {
e.printStackTrace();
}
return "Error";
});
}
。例外は、別のスレッドである:
Caused by: java.sql.SQLTransientConnectionException: Connection is not available, request timed out after 30000ms.
私はこのコード行を削除し、その後、すべての要求が働いていると予想されるとして、データベースにデータを追加した場合。後でfuture.get()を呼び出すと、メソッド "public Future addUser(UserInfo userInfo)"の終了後にトランザクションが完了しなかったと思います。 誰かがSpringとCompletableFutureがこのように動作する理由を知っているのでしょうか、それとも別の答えがあるのでしょうか?なぜCompletableFutureのブロックが別のメソッドでトランザクションの終了に影響するのですか?なぜメソッドが現在のトランザクションを完了しておらず、ブロック内にリクエストメソッドがある場合は接続を解放しないのか?
、あなたのトランザクションがすでに 'アドユーザー()'を呼び出すところに開始され、 '取得()'メソッドを呼び出す前にコミットされていない可能性があることでしょうか? –
@DidierLトランザクションのログを調べました。トランザクションは 'addUser()'で始まり、 'get()'メソッドを呼び出す前に完了したトランザクションがいくつかあります。そして、 'get()'が要求をブロックしている間、トランザクションは完了するのを止めます( 'TransactionInterceptor:485:トランザクションの完了 'をログします)。そして、接続数はdataSourceの接続プールで最大になり、この例外が発生します。原因:java.sql.SQLTransientConnectionException:Connection is not available。接続が完了するのを止める理由を知らない。 –