我的应用程序必须提供请求“转发”机制,从某种意义上说,它处理传入的请求并通过从基于请求确定的“目标”系统之一中检索数据来响应它。
这是根据HttpAsyncClient的集合来实现的,根据其从中检索数据的系统,每个HttpAsyncClient都有自己的配置(MaxConnections,MaxPerRouteConnections等)。
foreach (TargetSystem t: systems) {
RequestConfig rc = RequestConfig.custom()
.setConnectionRequestTimeout(s.timeout)
.setConnectTimeout(s.timeout)
.setSocketTimeout(s.timeout)
.build();
HttpAsyncClientBuilder b = HttpAsyncClients.custom()
.setDefaultRequestConfig(rc)
.setMaxConnTotal(t.maxConnections)
.setMaxConnPerRoute(t.maxPerRouteConnections);
t.client = b.build();
t.client.start();
}
然后,我选择正确的目标客户端并将其用于异步HTTP请求。
问题是,这是可接受的做法,还是仅一个HttpAsyncClient用于所有目标系统之间的通信?
当前,为每个客户端打开了多个线程(作为CPU的数量),因此对于10个目标,我最终获得了> 100个线程。
我想限制每个系统的套接字的最大数量,并限制为每个系统服务的线程数(或全部HTTP客户端出站流量)。
最佳答案
每个应用程序或单独的服务应只有一个HttpAsyncClient
实例。将HttpASyncClient
视为可以维护多个会话/选项卡的浏览器