如何在 java 中设置套接字写入超时？

Question

我在处理 java 中的套接字时遇到问题。我是运行具有多个客户端连接的 TCP 服务器。

出于性能原因，我使用了一个简单的线程池来处理数据包。

请看下面的代码

public enum LazyWorkCenter {
        instance;

        LazyWorkCenter() {
            lazyWorker = new NamedThreadPoolExecutor(3,3, 0L,TimeUnit.MILLISECONDS, "LazyWorker");
        }
        private ExecutorService lazyWorker ;


        public void executeLazy(Runnable lazyTask) { 
            lazyWorker.execute(lazyTask);
        }

    }

public class TcpServerForClient { 

    DataOutputStream out = null;
    DataInputStream in = null;

    public void onConnect(ServerSocket socket) throws IOException {
        Socket client = server.accept();
        client.setSoTimeout(1000 * 10);
        out = new DataOutputStream(client.getOutputStream());
        in = new DataInputStream(client.getInputStream());
    }

     public void sendToClient( byte[] buffer) {
            Runnable lazy = () -> {
                out.write(buffer);
                out.flush();
            };

            LazyWorkCenter.instance.executeLazy(lazy);
        }
}

多个线程可能会访问 sendToClient。

这段代码通常工作正常，但有时（可能是在泛滥时？）它挂起而没有任何异常，直到我手动关闭客户端连接。在我关闭客户端连接后，我从 out.write(buffer);

收到大量异常泛滥 SocketException: Broken pipe

7053555 [LazyWorker-1]  09:57:35.268 [ERROR] [LazyWorker-1@c.t.s.TcpServerForClient:44] - error found
java.net.SocketException: Broken pipe
        at java.net.SocketOutputStream.socketWrite0(Native Method) ~[na:1.8.0_91]
        at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:109) ~[na:1.8.0_91]
        at java.net.SocketOutputStream.write(SocketOutputStream.java:153) ~[na:1.8.0_91]
        at java.io.DataOutputStream.write(DataOutputStream.java:107) ~[na:1.8.0_91]
        at java.io.FilterOutputStream.write(FilterOutputStream.java:97) ~[na:1.8.0_91]

我的主要问题是服务器可能会挂起，直到客户端退出连接。我想如果我可以为写作设置超时，那么服务器可能会自行关闭连接，但我找不到合适的方法。

我也试过socket.setSoTimeOut();，但似乎只能从客户端接收数据。

任何提示或建议将不胜感激。如果需要更多代码或信息来解决这个问题，请告诉我。提前致谢。

Answer 1

How can I set Socket write timout in java?

你不能。 Java 中没有套接字写入超时。除非你跳转到 NIO，非阻塞模式，Selectors，等等

I got tons of exception flooding SocketException: Broken pipe from out.write(buffer);

你应该只得到一个。当你得到这个异常时你应该关闭套接字。

如何在 java 中设置套接字写入超时？

How can I set Socket write timout in java?

java

sockets

executorservice

broken-pipe