如何修复 java.net.SocketException：损坏的管道？

Question

我正在使用 apache commons http 客户端使用 post 方法调用 url 来发布参数，它很少抛出以下错误。

java.net.SocketException: Broken pipe
        at java.net.SocketOutputStream.socketWrite0(Native Method)
        at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
        at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
        at java.io.BufferedOutputStream.write(BufferedOutputStream.java:105)
        at java.io.FilterOutputStream.write(FilterOutputStream.java:80)
        at org.apache.commons.httpclient.methods.ByteArrayRequestEntity.writeRequest(ByteArrayRequestEntity.java:90)
        at org.apache.commons.httpclient.methods.EntityEnclosingMethod.writeRequestBody(EntityEnclosingMethod.java:499)
        at org.apache.commons.httpclient.HttpMethodBase.writeRequest(HttpMethodBase.java:2114)
        at org.apache.commons.httpclient.HttpMethodBase.execute(HttpMethodBase.java:1096)
        at org.apache.commons.httpclient.HttpMethodDirector.executeWithRetry(HttpMethodDirector.java:398)

有人可以建议导致此异常的原因以及如何调试它吗？

Answer 1

这是由于：

• 最常见的情况是，在另一端已经关闭连接时写入连接；
• 通常情况下，对等方关闭连接而不读取其端已经挂起的所有数据。

因此，在这两种情况下，您的应用程序协议定义或实现都很差。

还有第三个原因，我不会在这里记录，但它涉及对等方故意采取行动来重置而不是正确关闭连接。

Answer 2

在我们的案例中，我们在应用服务器上执行负载测试时遇到了这种情况。事实证明，我们需要向 JVM 添加额外的内存，因为它已经用完了。这解决了问题。

尝试增加 JVM 可用的内存，或者在出现这些错误时监控内存使用情况。

Answer 3

SocketException: Broken pipe，是由“另一端”（客户端或服务器）在您的代码读取或写入连接时关闭连接引起的。

这是客户端/服务器应用程序中的一个非常常见的异常，这些应用程序从应用程序控制之外的客户端或服务器接收流量。例如，客户端是浏览器。如果浏览器进行了 Ajax 调用，和/或用户只是关闭了页面或浏览器，那么这可能会意外地终止所有通信。基本上，只要另一端终止他们的应用程序，您就会看到这个错误，而您没有预料到。

如果您在应用程序中遇到此异常，则意味着您应该检查发生 IO（输入/输出）的代码，并使用 try/catch 块对其进行包装以捕获此 IOException。然后，由您决定如何处理这种半有效的情况。

在您的情况下，您仍然可以控制的最早位置是对 HttpMethodDirector.executeWithRetry 的调用 - 因此，请确保使用 try/catch 块包装该调用，并按照您认为合适的方式处理它。

我强烈建议不要在调试/跟踪级别以外的任何地方记录 SocketException-Broken Pipe 特定错误。否则，这可以通过填充日志被用作 DOS（拒绝服务）攻击的一种形式。针对这种常见情况，尝试强化您的应用程序并对其进行负面测试。

Answer 4

所有打开的流和连接都需要正确关闭，所以下次我们尝试使用 urlConnection 对象时，它不会抛出错误。例如，以下代码更改为我修复了错误。

之前：

OutputStream out = new BufferedOutputStream(urlConnection.getOutputStream());
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(out));
bw.write("Some text");
bw.close();
out.close();

之后：

OutputStream os = urlConnection.getOutputStream();
OutputStream out = new BufferedOutputStream(os);
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(out));
bw.write("Some text");
bw.close();
out.close();
os.close(); // This is a must.

Answer 5

我已经通过 FTP 服务器实现了数据下载功能，并且在恢复下载时也发现了同样的异常。 要解决此异常，您将始终必须断开与先前会话的连接并创建客户端的新实例以及与服务器的新连接。同样的方法也可能对 HTTPClient 有所帮助。

Answer 6

我在开发一个侦听特定 TCP 的简单 Java 应用程序时遇到了同样的问题。通常，我没有问题，但是当我运行一些压力测试时，我注意到一些连接因错误socket write exception 而中断。

经过调查，我找到了解决我的问题的解决方案。我知道这个问题很老了，但我更愿意分享我的解决方案，有人会发现它很有用。

问题出在 ServerSocket 创建上。我从 Javadoc 中读到，默认限制为 50 个挂起的套接字。如果您尝试打开另一个连接，这些将被拒绝。解决方案只是在服务器端更改此默认配置。在以下情况下，我创建了一个 Socket 服务器，它侦听 TCP 端口 10_000 并接受 max 200 挂起的套接字。

new Thread(() -> {
      try (ServerSocket serverSocket = new ServerSocket(10_000, 200)) {
        logger.info("Server starts listening on TCP port {}", port);

        while (true) {
          try {
            ClientHandler clientHandler = clientHandlerProvider.getObject(serverSocket.accept(), this);
            executor.execute(clientHandler::start);
          } catch (Exception e) {
            logger.error(e.getMessage());
          }
        }

      } catch (IOException | SecurityException | IllegalArgumentException e) {
        logger.error("Could not open server on TCP port {}. Reason: {}", port, e.getMessage());
      }
    }).start();

来自ServerSocket的Javadoc：

传入连接指示（连接请求）的最大队列长度设置为 backlog 参数。如果队列满时有连接指示到达，则拒绝连接。

Answer 7

问题可能是您部署的文件未使用正确的 RMI 方法进行更新。检查您的 RMI 接口是否已更新参数，或更新您的客户端没有的数据结构。或者您的 RMI 客户端没有与您的服务器版本不同的参数。

这只是一个有根据的猜测。重新部署我的服务器应用程序的类文件并重新测试后，“Broken pipe”的问题就消失了。

Answer 8

上面的答案说明了这个java.net.SocketException: Broken pipe的原因：另一端关闭了连接。我想分享一下我遇到它时发生的事情：

1. 在客户端的请求中，Content-Type 标头被错误地设置为大于实际请求正文（实际上根本没有正文）
2. tomcat 套接字中的底层服务正在等待该大小的主体数据（http 位于 TCP 上，通过封装和...确保交付）
3. 当60秒过期时，tomcat抛出超时异常： Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception java.net.SocketTimeoutException: null
4. 由于超时异常，客户端收到状态码为 500 的响应。
5. 客户端关闭连接（因为它收到响应）。
6. tomcat 抛出 java.net.SocketException: Broken pipe 因为客户端关闭了它。

有时，tomcat 不会抛出损坏的 pip 异常，因为超时异常关闭了连接，为什么这样的差异也让我感到困惑。

Answer 9

我注意到我在制作它时使用了不正确的 HTTP 请求 URL，后来我更改它解决了我的问题。我的上传网址是：http://192.168.0.31:5000/uploader，而我使用的是http://192.168.0.31:5000。那是一个接听电话。并得到一个 java.net.SocketException: Broken pipe？例外。

这就是我的理由。出现此问题时可能会导致您再检查一点

  public void postRequest()  {


        Security.insertProviderAt(Conscrypt.newProvider(), 1);

        System.out.println("mediafilename-->>" + mediaFileName);
        String[] dirarray = mediaFileName.split("/");
        String file_name = dirarray[6];
        //Thread.sleep(10000);

        RequestBody requestBody = new MultipartBody.Builder()
                    .setType(MultipartBody.FORM)
                    .addFormDataPart("file",file_name, RequestBody.create(MediaType.parse("video/mp4"), new File(mediaFileName))).build();
        OkHttpClient okHttpClient = new OkHttpClient();
//        ExecutorService executor = newFixedThreadPool(20);
//        Request request = new Request.Builder().post(requestBody).url("https://192.168.0.31:5000/uploader").build();
        Request request = new Request.Builder().url("http://192.168.0.31:5000/uploader").post(requestBody).build();
//        Request request = new Request.Builder().url("http://192.168.0.31:5000").build();
        okHttpClient.newCall(request).enqueue(new Callback() {
            @Override
            public void onFailure(@NotNull Call call, @NotNull IOException e) {

//

                call.cancel();

                runOnUiThread(new Runnable() {
                    @Override
                    public void run() {
                        Toast.makeText(getApplicationContext(),"Something went wrong:" + " ", Toast.LENGTH_SHORT).show();

                    }
                });
                e.printStackTrace();

            }

            @Override
            public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {


                runOnUiThread(new Runnable() {
                    @Override
                    public void run() {

                        try {
                            System.out.println(response.body().string());
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
                    }
                });


                System.out.println("Response ; " + response.body().toString());
//                Toast.makeText(getApplicationContext(), response.body().toString(),Toast.LENGTH_LONG).show();
                System.out.println(response);

            }
        });

Answer 10

JavaDoc：

传入连接指示的最大队列长度（a 连接请求）设置为 50。如果连接指示到达 当队列已满时，连接被拒绝。

你应该增加你的ServerSocket的“backlog”参数，例如

int backlogSize = 50 ;
new ServerSocket(port, backlogSize);