服務(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è)流氓特地寫(xiě)了個(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了。