我编写了如下的一小段Java程序:
package com.ny.utils.pub;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
public class NetWriter {
private static String link = "http://xxx.yyyyyy.com:4444";
public String getLink() {
return link;
}
public static void setLink(String link) {
NetWriter.link = link;
}
private static HttpURLConnection conn = null;
private static BufferedReader bufReader = null;
private static InputStreamReader isReader = null;
private static OutputStreamWriter osw = null;
private static URL url = null;
static {
try {
url = new URL(link);
} catch(MalformedURLException e) {
}
}
public static void write(String msg) {
long threadId = Thread.currentThread().getId();
System.out.println("--Insert>{" + threadId + "}:" + msg);
try {
conn = (HttpURLConnection) url.openConnection();
conn.setRequestMethod("POST");
conn.setRequestProperty("Content-Type",
"application/x-www-form-urlencoded");
conn.setRequestProperty("Content-Language", "en-US");
conn.setUseCaches(false);
conn.setDoOutput(true);
conn.setReadTimeout(5000);
conn.setConnectTimeout(5000);
osw = new OutputStreamWriter(conn.getOutputStream());
osw.write(msg);
osw.flush();
osw.close();
if (conn.getResponseCode() != HttpURLConnection.HTTP_OK) {
System.err.println("Server not return HTTP_OK status");
} else {
System.out.println(" request: " + msg);
isReader = new InputStreamReader(conn.getInputStream());
bufReader = new BufferedReader(isReader);
String rep = bufReader.readLine();
if (conn.getResponseCode() == 200) {
System.out.println("Post data OK to " + link);
}
System.out.println(" response: " + rep);
}
} catch(IOException e) {
System.err.println("Post data error: " + link + " "
+ e.getMessage());
e.printStackTrace();
}
}
}
[我编写了另一个程序来调用此类中的方法时,这将导致”打开的文件过多”,然后操作系统将拒绝用户登录。调用的脚本如下:
try{
NetWriter.write(new String(content, "utf-8"));
}catch(Exception e){
logger.error(e.getMessage());
e.printStackTrace();
}
}
当问题再次出现时,我发现手柄占用量正在增加。以下是我执行命令“ lsof -p PROGRAM_PID”的消息]
java 27439 root 66u unix 0xffff8103473fb6c0 10151765 socket
java 27439 root 67u unix 0xffff8103473fb6c0 10151765 socket
java 27439 root 68u unix 0xffff8103473fb6c0 10151765 socket
java 27439 root 69r FIFO 0,6 10151917 pipe
java 27439 root 70w FIFO 0,6 10151917 pipe
java 27439 root 71r 0000 0,11 0 10151918 eventpoll
java 27439 root 72r FIFO 0,6 10151919 pipe
java 27439 root 73w FIFO 0,6 10151919 pipe
java 27439 root 74r 0000 0,11 0 10151920 eventpoll
java 27439 root 75u unix 0xffff8103473fb6c0 10151765 socket
java 27439 root 76u unix 0xffff8103473fb6c0 10151765 socket
java 27439 root 77r FIFO 0,6 10152042 pipe
java 27439 root 78w FIFO 0,6 10152042 pipe
java 27439 root 79r 0000 0,11 0 10152043 eventpoll
java 27439 root 80r FIFO 0,6 10152044 pipe
java 27439 root 81w FIFO 0,6 10152044 pipe
java 27439 root 82r 0000 0,11 0 10152045 eventpoll
java 27439 root 83u unix 0xffff8103473fb6c0 10151765 socket
java 27439 root 84r FIFO 0,6 10154168 pipe
java 27439 root 85w FIFO 0,6 10154168 pipe
java 27439 root 86r 0000 0,11 0 10154169 eventpoll
java 27439 root 87r FIFO 0,6 10154170 pipe
句柄(管道套接字事件池)的数量最多为数千。
我尝试了许多方法来避免这种情况,但是失败了。有人可以告诉我上面程序的缺陷吗?
您不关闭输入阅读器。它应该关闭。
作为一般规则,应关闭finally
块中的资源。
在这种情况下,您应该在finally
块中关闭输入和输出读取器。
如果您尚未找到解决方案,则值得将该线程签出:
Android - HttpUrlConnection is not closing. Eventually results to SocketException
这与Jellybean中的“保持活动”连接有关。希望有帮助
我为此花费了数小时,数天,数周的时间,为设置较小的读取/连接超时并使用finally
块关闭连接,输入流,输出流等而做的所有事情。解。 HttpsUrlConnection
似乎在某种程度上有缺陷。
因此我们尝试将OkHttp
替换为HttpsUrlConnection
和瞧!它开箱即用。
因此,如果您对此感到挣扎,并且很难解决它,建议您也尝试使用OkHttp。
这里是基础知识:
一旦添加了Maven依赖项,您可以执行以下操作来下载文件:
OkHttpClient okHttpClient = new OkHttpClient.Builder().build();
OutputStream output = null;
try {
Request request = new Request.Builder().url( download_url ).build();
Response response = okHttpClient.newCall( request ).execute();
if ( !response.isSuccessful() ) {
throw new FileNotFoundException();
}
output = new FileOutputStream( output_path );
output.write( response.body().bytes() );
}
finally {
// Ensure streams are closed, even if there's an exception.
if ( output != null ) output.flush();
if ( output != null ) output.close();
}
切换到OkHttp会立即解决我们泄漏的文件描述符问题,因此即使您被困,也值得尝试,即使以增加另一个库依赖项为代价。