如何在java中设置Socket写入时间？

我在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 。

这段代码通常工作正常，但有时候（可能在洪水泛滥？）它挂起而没有任何exception，直到我手动关闭客户端连接。 我关闭客户端连接后，我得到了大量的exception泛滥SocketException: Broken pipe来自out.write(buffer); SocketException: Broken pipe out.write(buffer);

 7053555 [LazyWorker-1] 09:57:35.268 [ERROR] [LazyWorker-1@ctsTcpServerForClient: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] 

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

我试过socket.setSoTimeOut(); 同样，但它似乎只是从客户端接收数据。

任何提示或建议将非常感激。 请让我知道如果需要更多的代码或信息来解决这个问题。 提前致谢。

Answer 1

如何在java中设置Socket写入时间？

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

我得到了大量的exception泛滥SocketException: Broken pipe来自out.write(buffer); SocketException: Broken pipe out.write(buffer);

你应该只得到一个。 当您收到此exception时，应该关闭套接字。