服务器如何处理 Close Wait 状态？ (服务器 close wait)

在服务器端，当连接处于 Close Wt 状态时，常常会出现一些错误和异常情况。Close Wt 是一个关于 TCP 连接状态的一种特殊状态，它通常发生在已经向对端发送了关闭连接请求，但是对端仍未响应的情况下。

在这种情况下，服务器需要采取一些措施来解决因 Close Wt 状态引起的问题，以确保连接能够正获得正常关闭。

服务器需要了解 Close Wt 状态是什么，以及它的出现原因。Close Wt 状态通常是由服务器主动关闭连接，但是对方没有立即响应关闭请求而导致出现的。这个状态表示服务器已经关闭了连接，但是还在等待对方响应关闭请求确认。

服务器需要采取一些方法来解决 Close Wt 状态带来的问题。这些方法包括：

1. 回收 Close Wt 连接资源：服务器需要主动回收已经处于 Close Wt 状态的连接资源，以避免它们一直占据服务器的资源而导致系统负载过大。服务器可以通过设置 TCP 连接超时时间来控制这个过程，一旦连接超时，服务器就会自动回收它们的资源。

2. 通过关闭当前连接来解决问题：服务器还可以通过强制关闭当前连接来解决因 Close Wt 状态引起的问题。虽然这个方法可能会导致数据丢失或者连接不充分断开，但是在某些情况下它是一个有效的解决方案。服务器可以通过发送一个 RST 数据包来强制关闭连接，从而避免连接一直处于 Close Wt 状态。

3. 通过改进测试程序来解决问题：服务器也可以通过改进当前测试程序来解决由 Close Wt 状态引起的问题。服务器可以增加发送关闭请求确认等机制，以确保连接能够及时关闭。

服务器处理 Close Wt 状态的方法有多种，但是选择何种方法需要根据具体情况而定。服务器需要考虑连接的性质、网络环境等因素来确定哪种方法最适合当前的场景。这样才能够更大程度地避免因 Close Wt 状态引起的问题，确保连接的正常关闭。

相关问题拓展阅读：

• java httpclient4.3连接池怎么解决大量close_wait的问题
• 为什么会发生close wait和time wait

java httpclient4.3连接池怎么解决大量close_wait的问题

可以巧档让试试使用完蠢宽后关闭连孝局接

httpClient.getConnectionManager().shutdown();

最近发现一个问题，在服务器上通过netstat命令发现有大量的Close_Wait长时间存在，甚至有时候数量接近1000：

查看服务器参数(etc/sysctl.conf):

net.ipv4.tcp_keepalive_time 网管已经修改成1200。

参数值还可以改小，但似乎是治标不治本饥团，出现这种问题，肯定是某个地方的程序本身存在问题。

根据ip及端口信息，不难发现是什么地方除问题了，项目中有涉及到图片上传，于是找到图片上传的代码，结果发现代码非常简单，一行上传权限初始化代码，一行CDN官方提供的一个静态方法，之后就是处理响应结果的代码烂或橘了。代码少且简单，上传调用代码没什么问题，那么问题可能出在CDN官方提供的jar包了，好在CDN有提供源码，于是查看源码，源码中使用apache 的团罩是httpClient包，调用代码大致如下：

String response = “”;

HttpPost httpPost = null;

CloseableHttpResponse ht = null;

String startTime = formatter.format(new Date());//请求时间

String endTime = “-“;

String statusCode = “-“;

String contentLength = “-“;

String contentType = “-“;try {

httpPost = new HttpPost(url);

List paramsList = new ArrayList();if (file != null) {

MultipartEntityBuilder mEntityBuilder = MultipartEntityBuilder.create();

BandwithLimiterFileBody fileBody = new BandwithLimiterFileBody(file, null, “application/octet-stream”, null, BaseBlockUtil.maxRate, progressNotifier);

mEntityBuilder.addPart(“file”, fileBody);

mEntityBuilder.addTextBody(“desc”, file.getName());  if (params != null && params.size() > 0) {      for (String name : params.keySet()) {

mEntityBuilder.addTextBody(name, params.get(name), ContentType.create(“text/plain”, Charset.forName(“UTF-8”)));

}

}

httpPost.setEntity(mEntityBuilder.build());

} else if (params != null && params.size() > 0) {  for (String name : params.keySet()) {

paramsList.add(new BasicNameValuePair(name, params.get(name)));

}

HttpEntity he = new UrlEncodedFormEntity(paramsList, “utf-8”);

httpPost.setEntity(he);

}if (headMap != null && headMap.size() > 0) {  for (String name : headMap.keySet()) {

httpPost.addHeader(name, headMap.get(name));

}

}if(!httpPost.containsHeader(“User-Agent”))

httpPost.addHeader(“User-Agent”, Config.VERSION_NO);

CloseableHttpClient hc = HttpClients.createDefault();

RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(30000).setConnectTimeout(30000).build();//设置请求和传输超时时间httpPost.setConfig(requestConfig);

ht = hc.execute(httpPost);

endTime = formatter.format(new Date());

Header headerArr = ht.getAllHeaders();for (Header header : headerArr) {

BufferedHeader bh = (BufferedHeader) header;  if (bh.getBuffer().toString().contains(“Content-Length”)) {

contentLength = bh.getValue();

} else if (bh.getBuffer().toString().contains(“Content-Type”)) {

contentType = bh.getValue();

}

}

HttpEntity het = ht.getEntity();

InputStream is = het.getContent();

BufferedReader br = new BufferedReader(new InputStreamReader(is, “utf8”));

String readLine;while ((readLine = br.readLine()) != null) {

response = response + readLine;

}

is.close();

br.close();int status = ht.getStatusLine().getStatusCode();

statusCode = String.valueOf(status);if (status == 200) {  if (!new JsonValidator().validate(response)) {

response = EncodeUtils.urlsafeDecodeString(response);

}

}return new HttpClientResult(status, response);

} catch (Exception e) {

statusCode = “500”;

endTime = formatter.format(new Date());throw new HttpClientException(e);

} finally {if (httpPost != null) {

httpPost.releaseConnection();

}if (ht != null) {  try {

ht.close();

} catch (IOException ignored) {

}

}

writeHttpLog(startTime, url, “-“, (null != params ? params.get(“token”) : “-“), (null != file ? file.getName() : “-“), “-“, “-“, endTime, statusCode, contentType, contentLength, response);

}

查看TCP协议端口状态说明 , 如果一直保持在CLOSE_WAIT状态，那么只有一种情况，就是在对方关闭连接之后服务器程序自己没有进一步发出ack信号。因此要解决这个问题大致有以下几种方案：

a、实例化httpClient 时，使用alwaysClose 的SimpleHttpConnectionManager

通常默认情况实例化httpClient 的时候使用的是无参构造的SimpleHttpConnectionManager，因此可替换为带参构造：

new HttpClient(new SimpleHttpConnectionManager(true));

b、在method.releaseConnection() 之后 通过获取HttpConnectionManager，进行关闭(getConnectionManager方法在httpclient 4.3之后已经标记为过期，后期可能会移除该方法)：

hc.getConnectionManager().shutdown();

c、在method.releaseConnection() 之后 通过获取HttpConnectionManager 调用closeIdleConnections方法进行关闭，(getConnectionManager方法在httpclient 4.3之后已经标记为过期，后期可能会移除该方法)：

hc.getConnectionManager().releaseConnection(conn, validDuration, timeUnit);

d、通过设置header由服务端自动关闭.

method.setHeader(“Connection”, “close”);

HTTP协议中有关于这个属性的定义： 

HTTP/1.1 defines the “close” connection option for the sender to signal that the connection will be closed after completion of the response. For example：

Connection: close 

e、使用MultiThreadedHttpConnectionManager 进行复用，但同时也必须在合适的地方进行关闭处理；

f、请求之后未收到响应信息时，调用method.abort()进行处理

估计你的中册问题和这个问题是一样的卖者宏嫌旁。

为什么会发生close wait和time wait

（推荐方法，只能治标不治本）重用本仔昌知地端口设置SO_REUSEADDR和SO_REUSEPORT(stevens的unix网络编程卷1 第179~182页)有详情的讲解，这样就可以允许同一端口上启动同一服务器的多个实例。怎样理解呢？说白了就迅型是即使socket断了，重新调用前面的socket函数不会再去占用新的一个，而是始终就是一个端口，这样防止socket始终连接不上，会不断地换新端口。Java 中通过调用Socket的setReuseAddress,详细可以查看java.net.Socket源码。【这个地方念消会有风险，具体可以看(stevens的unix网络编程卷1 第181页)】

关于服务器 close wait的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。