多くのクライアントからリクエストを受け取り、いくつかの処理後にクライアントにレスポンスを送信するサービスがあります。ThreadPoolExecutor (threadExecuterClient) を使用してクライアント リクエストを処理し、BlockingQueue (requestQueue) に入れます。多くのクライアントが同時リクエストを送信できます。requestQueue でリクエストを処理する別の ThreadPoolExecutor (threadExecuterServer) があります。この処理は、基本的にはそのリクエストをサーバーに送り、レスポンスを得るというものです。処理後、そのリクエストを行ったクライアントにそのレスポンスを送信する必要があります。どのクライアントがどのリクエストを行ったかを追跡するのが困難です。基本的に、クライアントのリクエストを処理の結果にマップする方法を見つける必要があります。サービスはゲートウェイのようなものになります。
この問題を処理するためのアイデアは大歓迎です。
ありがとう