Приложение обрабатывает примерно 60 запросов в секунду. Это прокси: принимает соединение, обращается к удаленному ресурсу и проксирует данные.
Со временем (через несколько дней) число исходящий соединений доходит до такого количества, что приложение начинает упираться в лимит на число открытых файлов.
1.
2.
netstat -anp | grep java | grep CLOSE_WAIT -c
265
На следующий день их будет уже 1000 и так далее.
Копятся в CLOSE_WAIT именно исходящие соединения, которые порождает jersey client.
CLOSE_WAIT - если я правильно понимаю означает, что удаленный сервер закрыл соединение, а наше приложение еще нет.
HttpClient один на все приложение.
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
final ClientConfig clientConfig = new ClientConfig();
clientConfig.property(ClientProperties.CONNECT_TIMEOUT, config.getInt("http_client.connect_timeout"));
clientConfig.property(ClientProperties.READ_TIMEOUT, config.getInt("http_client.read_timeout"));
PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager();
clientConfig.property(ApacheClientProperties.CONNECTION_MANAGER, connectionManager);
clientConfig.property(ApacheClientProperties.CONNECTION_MANAGER_SHARED, true);
ConnectorProvider connectorProvider = new ApacheConnectorProvider();
clientConfig.connectorProvider(connectorProvider);
connectionManager.setMaxTotal(config.getInt("http_client.max_total_connections"));
connectionManager.setDefaultMaxPerRoute(config.getInt("http_client.default_max_per_route_connections"));
client = ClientBuilder
.newBuilder()
.withConfig(clientConfig)
.sslContext(SSLContextBuilder.createdTrustedAll())
.hostnameVerifier((hostname, session) -> true)
.build();
В мануале сказано тред-сейф.
Запрос делается так:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
public Response createRequest(String url, Client client) throws Exception {
logger.debug("Download resource: " + url);
WebTarget webTarget = client.target(url);
Invocation.Builder invocationBuilder = webTarget.request();
Response response = invocationBuilder.get();
if (response.getStatusInfo().getStatusCode() != 200) {
throw new Exception("Invalid response = " + url + " code = " +
response.getStatusInfo().getStatusCode());
}
return response;
}
Используется в HttpHandler, закрывается так:
1.
2.
3.
4.
5.
6.
7.
try (Response response = resourceProvider.createRequest(url, httpClientProvider.get())) {
httpExchange.sendResponseHeaders(200, response.getLength());
InputStream is = response.readEntity(InputStream.class);
IOUtils.copy(is, os);
} catch (Exception e) {
throw new Exception("Error download url " + url, e);
}
Не догоняю почему со временем копятся соединения.
С учетом количества обрабатываемых запросов - проблемы далеко не со всеми, какие-то рандомные соединения иногда не закрываются.
