所以我有一些代码用来从网址读取文本文件。然而它表现出一些奇怪的行为。第一次运行代码时,我收到由对等错误重置的连接,并且所有代码都未运行。
如果我在代码运行良好后立即重新运行代码,则会下载文件并按预期执行操作。 这是代码:
public static String GetMasterFileStream(String Operation) throws Exception {
System.setProperty("http.keepAlive", "false");
StringBuilder sb = new StringBuilder();
BufferedWriter bw = null;
String inputLine = null;
System.out.println("Server manifest checks starting");
URL url = new URL(CrewAdviceMasterControlURL);
HttpURLConnection con = (HttpURLConnection) url.openConnection();
con.setRequestProperty("connection", "close");
BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()));
File outfile = new File(LocalManifestFile);
String return_string = "";
String [] ManifestLines;
switch (Operation) {
case "PreCheck":
inputLine = in.readLine();
sb.append(inputLine.toString());
return_string = String.valueOf(sb);
break;
case "UpdateMaster":
case "CreateMaster":
if(!outfile .exists()){
outfile .createNewFile();
}
FileWriter fileWriter = new FileWriter(outfile);
bw = new BufferedWriter(fileWriter);
int endlinecount =0;
while ((inputLine = in.readLine()) != null) {
System.out.println(inputLine); //for producing test output
sb.append(inputLine.toString());
sb.append("\n");
if (endlinecount > 0)
{
bw.write("\r\n");
}
bw.write(String.valueOf(inputLine));
endlinecount++;
}
bw.close();
System.out.println("Manifest file successfully written...");
return_string = String.valueOf(sb);
ManifestLines = return_string.split("\n");
return_string = ManifestLines[0];
//text = text.replace("\n", "").replace("\r", "");
break;
}
in.close();
return return_string;
}
这是错误日志:
W/System.err: java.net.SocketException: recvfrom failed: ECONNRESET (Connection reset by peer)
D/dalvikvm: GC_FOR_ALLOC freed 6333K, 33% free 18277K/26880K, paused 50ms, total 50ms
W/System.err: at libcore.io.IoBridge.maybeThrowAfterRecvfrom(IoBridge.java:545)
W/System.err: at libcore.io.IoBridge.recvfrom(IoBridge.java:509)
W/System.err: at java.net.PlainSocketImpl.read(PlainSocketImpl.java:489)
W/System.err: at java.net.PlainSocketImpl.access$000(PlainSocketImpl.java:46)
W/System.err: at java.net.PlainSocketImpl$PlainSocketInputStream.read(PlainSocketImpl.java:241)
W/System.err: at java.io.InputStream.read(InputStream.java:162)
W/System.err: at java.io.BufferedInputStream.fillbuf(BufferedInputStream.java:142)
W/System.err: at java.io.BufferedInputStream.read(BufferedInputStream.java:227)
W/System.err: at com.android.okhttp.internal.Util.readAsciiLine(Util.java:316)
W/System.err: at com.android.okhttp.internal.http.RawHeaders.fromBytes(RawHeaders.java:320)
W/System.err: at com.android.okhttp.internal.http.HttpTransport.readResponseHeaders(HttpTransport.java:147)
W/System.err: at com.android.okhttp.internal.http.HttpEngine.readResponse(HttpEngine.java:795)
W/System.err: at com.android.okhttp.internal.http.HttpURLConnectionImpl.execute(HttpURLConnectionImpl.java:347)
W/System.err: at com.android.okhttp.internal.http.HttpURLConnectionImpl.getResponse(HttpURLConnectionImpl.java:296)
W/System.err: at com.android.okhttp.internal.http.HttpURLConnectionImpl.getInputStream(HttpURLConnectionImpl.java:179)
W/System.err: at com.cm3.danielhutchinson.lialpatools.CrewAdviceFunctions.GetMasterFileStream(CrewAdviceFunctions.java:60)
W/System.err: at com.cm3.danielhutchinson.lialpatools.CrewAdviceFunctions.PreCheck(CrewAdviceFunctions.java:179)
W/System.err: at com.cm3.danielhutchinson.lialpatools.CrewAdviceActivity$AdviceController.doInBackground(CrewAdviceActivity.java:210)
W/System.err: at com.cm3.danielhutchinson.lialpatools.CrewAdviceActivity$AdviceController.doInBackground(CrewAdviceActivity.java:176)
W/System.err: at android.os.AsyncTask$2.call(AsyncTask.java:288)
W/System.err: at java.util.concurrent.FutureTask.run(FutureTask.java:237)
W/System.err: at android.os.AsyncTask$SerialExecutor$1.run(AsyncTask.java:231)
W/System.err: at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1112)
W/System.err: at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:587)
W/System.err: at java.lang.Thread.run(Thread.java:841)
W/System.err: Caused by: libcore.io.ErrnoException: recvfrom failed: ECONNRESET (Connection reset by peer)
W/System.err: at libcore.io.Posix.recvfromBytes(Native Method)
W/System.err: at libcore.io.Posix.recvfrom(Posix.java:141)
W/System.err: at libcore.io.BlockGuardOs.recvfrom(BlockGuardOs.java:164)
W/System.err: at libcore.io.IoBridge.recvfrom(IoBridge.java:506)
W/System.err: ... 23 more
最佳答案
我发现在测试中,连接在第一次尝试时有 50% 的时间被服务器重置,并且在立即重试时始终有效。
当我之前测试过这段代码时,它从未发生过。进一步的研究使我相信这可能是服务器端并不总是存在的故障。
我通过将代码放入一个以“成功标志”为键的 while 循环中来解决这个问题。
如果代码抛出连接重置错误,则会重试连接。如果成功,则不重试,然后我放入一个重试计数器,在 3 次重试尝试后,该计数器将退出循环并提醒用户服务器错误。到目前为止,第二次尝试的成功率始终为 100%。
关于java - 首次运行时 HttpURLConnection 由对等方重置...可立即重新运行,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/35190683/