我們有一個(gè)groovy單例,使用PoolingHttpClientConnectionManager(httpclient：4.3.6),池大小為200,以處理與搜索服務(wù)非常高的并發(fā)連接并處理xml響應(yīng).

盡管已經(jīng)指定了超時(shí),但它每個(gè)月凍結(jié)約一次,但在其余時(shí)間內(nèi)運(yùn)行良好.

下面的groovy單身.方法retrieveInputFromURL似乎阻止在client.execute(get);

@Singleton(strict=false)

class StreamManagerUtil {

// Instantiate once and cache for lifetime of Signleton class

private static PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager();

private static CloseableHttpClient client;

private static final IdleConnectionMonitorThread staleMonitor = new IdleConnectionMonitorThread(connManager);

private int warningLimit;

private int readTimeout;

private int connectionTimeout;

private int connectionFetchTimeout;

private int poolSize;

private int routeSize;

PropertyManager propertyManager = PropertyManagerFactory.getInstance().getPropertyManager("sebe.properties")

StreamManagerUtil() {

// Initialize all instance variables in singleton from properties file

readTimeout = 6

connectionTimeout = 6

connectionFetchTimeout =6

// Pooling

poolSize = 200

routeSize = 50

// Connection pool size and number of routes to cache

connManager.setMaxTotal(poolSize);

connManager.setDefaultMaxPerRoute(routeSize);

// ConnectTimeout : time to establish connection with GSA

// ConnectionRequestTimeout : time to get connection from pool

// SocketTimeout : waiting for packets form GSA

RequestConfig config = RequestConfig.custom()

.setConnectTimeout(connectionTimeout * 1000)

.setConnectionRequestTimeout(connectionFetchTimeout * 1000)

.setSocketTimeout(readTimeout * 1000).build();

// Keep alive for 5 seconds if server does not have keep alive header

ConnectionKeepAliveStrategy myStrategy = new ConnectionKeepAliveStrategy() {

@Override

public long getKeepAliveDuration(HttpResponse response, HttpContext context) {

HeaderElementIterator it = new BasicHeaderElementIterator

(response.headerIterator(HTTP.CONN_KEEP_ALIVE));

while (it.hasNext()) {

HeaderElement he = it.nextElement();

String param = he.getName();

String value = he.getValue();

if (value != null && param.equalsIgnoreCase

("timeout")) {

return Long.parseLong(value) * 1000;

}

}

return 5 * 1000;

}

};

// Close all connection older than 5 seconds. Run as separate thread.

staleMonitor.start();

staleMonitor.join(1000);

client = HttpClients.custom().setDefaultRequestConfig(config).setKeepAliveStrategy(myStrategy).setConnectionManager(connManager).build();

}

private retrieveInputFromURL (String categoryUrl, String xForwFor, boolean isXml) throws Exception {

URL url = new URL( categoryUrl );

GPathResult searchResponse = null

InputStream inputStream = null

HttpResponse response;

HttpGet get;

try {

long startTime = System.nanoTime();

get = new HttpGet(categoryUrl);

response = client.execute(get);

int resCode = response.getStatusLine().getStatusCode();

if (xForwFor != null) {

get.setHeader("X-Forwarded-For", xForwFor)

}

if (resCode == HttpStatus.SC_OK) {

if (isXml) {

extractXmlString(response)

} else {

StringBuffer buffer = buildStringFromResponse(response)

return buffer.toString();

}

}

}

catch (Exception e)

{

throw e;

}

finally {

// Release connection back to pool

if (response != null) {

EntityUtils.consume(response.getEntity());

}

}

}

private extractXmlString(HttpResponse response) {

InputStream inputStream = response.getEntity().getContent()

XmlSlurper slurper = new XmlSlurper()

slurper.setFeature("http://xml.org/sax/features/validation", false)

slurper.setFeature("http://apache.org/xml/features/disallow-doctype-decl", false)

slurper.setFeature("http://apache.org/xml/features/nonvalidating/load-dtd-grammar", false)

slurper.setFeature("http://apache.org/xml/features/nonvalidating/load-external-dtd", false)

return slurper.parse(inputStream)

}

private StringBuffer buildStringFromResponse(HttpResponse response) {

StringBuffer buffer= new StringBuffer();

BufferedReader rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));

String line = "";

while ((line = rd.readLine()) != null) {

buffer.append(line);

System.out.println(line);

}

return buffer

}

public class IdleConnectionMonitorThread extends Thread {

private final HttpClientConnectionManager connMgr;

private volatile boolean shutdown;

public IdleConnectionMonitorThread

(PoolingHttpClientConnectionManager connMgr) {

super();

this.connMgr = connMgr;

}

@Override

public void run() {

try {

while (!shutdown) {

synchronized (this) {

wait(5000);

connMgr.closeExpiredConnections();

connMgr.closeIdleConnections(10, TimeUnit.SECONDS);

}

}

} catch (InterruptedException ex) {

// Ignore

}

}

public void shutdown() {

shutdown = true;

synchronized (this) {

notifyAll();

}

}

}

我還發(fā)現(xiàn)在日志中發(fā)現(xiàn)這一點(diǎn),導(dǎo)致我相信它在等待響應(yīng)數(shù)據(jù)時(shí)發(fā)生

java.net.SocketTimeoutException：通過(guò)java.net.SocketInputStream.read(SocketInputStream.java:150)在java.net.SocketInputStream.read(SocketInputStream.java:121)上的java.net.SocketInputStream.socketRead0(Native Method)讀取超時(shí))在sun.security.ssl.InputRecord.readFully(InputRecord.java:465)

到目前為止的調(diào)查結(jié)果：

問(wèn)題

>這可能是同步問(wèn)題嗎？從我的理解,即使單線程被多個(gè)線程訪問(wèn),唯一的共享數(shù)據(jù)是緩存的CloseableHttpClient

>這個(gè)代碼有什么其他根本的錯(cuò)誤,可能導(dǎo)致這種行為的方法？

總結(jié)

以上是生活随笔為你收集整理的java httpclient单例_java-8 – CloseableHttpClient.execute每隔几周就会冻结一次,尽管超时...的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。