HttpClient 與 Close_Wait
服務(wù)器A需要通過(guò)HttpClient去連接另一個(gè)系統(tǒng)B提供的服務(wù)，運(yùn)行一段時(shí)間后拋出以下異常：java.net.SocketException: Connection reset by peer: socket write error close_wait
在服務(wù)器B上運(yùn)行netstat命令，發(fā)現(xiàn)大量連接處于CLOSE_WAIT 狀態(tài)。
問(wèn)題分析：
簡(jiǎn)單來(lái)說(shuō)CLOSE_WAIT數(shù)目過(guò)大是由于被動(dòng)關(guān)閉連接處理不當(dāng)導(dǎo)致的。
我說(shuō)一個(gè)場(chǎng)景，服務(wù)器A會(huì)去請(qǐng)求服務(wù)器B上面的apache獲取文件資源，正常情況下，如果請(qǐng)求成功，那么在抓取完資源后服務(wù)器A會(huì)主動(dòng)發(fā)出關(guān)閉連接的請(qǐng)求，這個(gè)時(shí)候就是主動(dòng)關(guān)閉連接，連接狀態(tài)我們可以看到是TIME_WAIT。如果一旦發(fā)生異常呢?假設(shè)請(qǐng)求的資源服務(wù)器B上并不存在，那么這個(gè)時(shí)候就會(huì)由服務(wù)器B發(fā)出關(guān)閉連接的請(qǐng)求，服務(wù)器A就是被動(dòng)的關(guān)閉了連接，如果服務(wù)器A被動(dòng)關(guān)閉連接之后自己并沒(méi)有釋放連接，那就會(huì)造成CLOSE_WAIT的狀態(tài)了。
所以很明顯，問(wèn)題還是處在程序里頭。
原始代碼塊：
- try
- {
- client = HttpConnectionManager.getHttpClient();
- HttpGet get = new HttpGet();
- get.setURI(new URI(urlPath));
- HttpResponse response = client.execute(get);
- if (response.getStatusLine ().getStatusCode () != 200) {
- return null;
- }
- HttpEntity entity =response.getEntity();
- if( entity != null ){
- in = entity.getContent();
- .....
- }
- return sb.toString ();
- }
- catch (Exception e)
- {
- e.printStackTrace ();
- return null;
- }
- finally
- {
- if (isr != null){
- try
- {
- isr.close ();
- }
- catch (IOException e)
- {
- e.printStackTrace ();
- }
- }
- if (in != null){
- try
- {
- <span style="color:#ff0000;">in.close ();</span>
- }
- catch (IOException e)
- {
- e.printStackTrace ();
- }
- }
- }
HttpClient使用我們常用的InputStream.close()來(lái)確認(rèn)連接關(guān)閉，分析上面的代碼，一旦出現(xiàn)非200的連接，這個(gè)連接將永遠(yuǎn)僵死在連接池里頭，因?yàn)閕nputStream得不到初始化，永遠(yuǎn)不會(huì)調(diào)用close()方法了。
通過(guò)代碼稍微修改，更嚴(yán)謹(jǐn)?shù)奶幚懋惓Ｇ闆r就可以解決問(wèn)題了：
- public static String readNet (String urlPath)
- {
- StringBuffer sb = new StringBuffer ();
- HttpClient client = null;
- InputStream in = null;
- InputStreamReader isr = null;
- HttpGet get = new HttpGet();
- try
- {
- client = HttpConnectionManager.getHttpClient();
- get.setURI(new URI(urlPath));
- HttpResponse response = client.execute(get);
- if (response.getStatusLine ().getStatusCode () != 200) {
- get.abort();
- return null;
- }
- HttpEntity entity =response.getEntity();
- if( entity != null ){
- in = entity.getContent();
- ......
- }
- return sb.toString ();
- }
- catch (Exception e)
- {
- get.abort();
- e.printStackTrace ();
- return null;
- }
- finally
- {
- if (isr != null){
- try
- {
- isr.close ();
- }
- catch (IOException e)
- {
- e.printStackTrace ();
- }
- }
- if (in != null){
- try
- {
- in.close ();
- }
- catch (IOException e)
- {
- e.printStackTrace ();
- }
- }
- }
- }
顯示調(diào)用HttpGet的abort，這樣就會(huì)直接中止這次連接，我們?cè)谟龅疆惓５臅r(shí)候應(yīng)該顯示調(diào)用，因?yàn)檎l(shuí)能保證異常是在InputStream in賦值之后才拋出的呢。
more:
首先我們知道，如果我們的服務(wù)器程序處于CLOSE_WAIT狀態(tài)的話，說(shuō)明套接字是被動(dòng)關(guān)閉的!
因?yàn)槿绻荂LIENT端主動(dòng)斷掉當(dāng)前連接的話，那么雙方關(guān)閉這個(gè)TCP連接共需要四個(gè)packet：
Client –-> FIN –-> Server Client <–- ACK <–- Server 這時(shí)候Client端處于FIN_WAIT_2狀態(tài)；而Server 程序處于CLOSE_WAIT狀態(tài)。 Client <–- FIN <–- Server 這時(shí)Server 發(fā)送FIN給Client，Server 就置為L(zhǎng)AST_ACK狀態(tài)。 Client –-> ACK –-> Server Client回應(yīng)了ACK，那么Server 的套接字才會(huì)真正置為CLOSED狀態(tài)。
Server 程序處于CLOSE_WAIT狀態(tài)，而不是LAST_ACK狀態(tài)，說(shuō)明還沒(méi)有發(fā)FIN給Client，那么可能是在關(guān)閉連接之前還有許多數(shù)據(jù)要發(fā)送或者其他事要做，導(dǎo)致沒(méi)有發(fā)這個(gè)FIN packet。
通常來(lái)說(shuō)，一個(gè)CLOSE_WAIT會(huì)維持至少2個(gè)小時(shí)的時(shí)間(這個(gè)時(shí)間外網(wǎng)服務(wù)器通常會(huì)做調(diào)整，要不然太危險(xiǎn)了)。如果有個(gè)流氓特地寫了個(gè)程序，給你造成一堆的CLOSE_WAIT，消耗
你的資源，那么通常是等不到釋放那一刻，系統(tǒng)就已經(jīng)解決崩潰了。
只能通過(guò)修改一下TCP/IP的參數(shù)，來(lái)縮短這個(gè)時(shí)間：修改tcp_keepalive_*系列參數(shù)有助于解決這個(gè)問(wèn)題。
但是實(shí)際上，還是主要是因?yàn)槲覀兊某绦虼a有問(wèn)題，
more:
最近做httpclient做轉(zhuǎn)發(fā)服務(wù)，發(fā)現(xiàn)服務(wù)器上總是有很多close_wait狀態(tài)的連接，而且這些連接都不會(huì)關(guān)閉，最后導(dǎo)致服務(wù)器沒(méi)法建立新的網(wǎng)絡(luò)連接，從而停止響應(yīng)。
后來(lái)在網(wǎng)上搜索了一下，發(fā)現(xiàn)解決的方法也很簡(jiǎn)單，如果想重用連接，那就使用連接管理器，從連接管理器里獲取連接，然后定時(shí)的用連接管理器來(lái)釋放空閑連接。httpclient自帶了SimpleHttpConnectionManager，提供了
Java代碼
- closeIdleConnections(long idleTimeout)
這樣的方法。
如果不需要重用鏈接，則直接在httpmethod創(chuàng)建時(shí)，設(shè)置一個(gè)http頭信息就可以了
Java代碼
- httpmethod.setRequestHeader("Connection", "close");
這樣就不會(huì)有惱人的close_wait了。
