当前位置: 首页 > 面试题库 >

如何在Java中设置Socket写timout?

松元明
2023-03-14
问题内容

我在处理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

该代码通常可以正常工作,但是有时(可能是在泛洪时?)它挂起而没有任何异常,直到我手动关闭客户端连接为止。我关闭客户端连接后,然后我得到吨异常洪水
SocketException: Broken pipeout.write(buffer);

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]

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

我也尝试过socket.setSoTimeOut();,但似乎仅用于从客户端接收数据。

任何提示或建议将不胜感激。请让我知道是否需要更多代码或信息来解决这个问题。提前致谢。


问题答案:

如何在Java中设置Socket写timout?

你不能 Java中没有套接字写入超时。除非您将超级跳转设置为NIO,非阻塞模式Selectors等。

我吨异常洪水SocketException: Broken pipeout.write(buffer);

您只能得到一个。收到此异常时,应关闭套接字。



 类似资料:
  • 问题内容: 我可以如下设置Firefox的代理设置。 但是我也需要设置Chrome。.有人可以帮助我怎么做吗? 谢谢拉吉 问题答案: 您可以尝试使用该类,如下所示:

  • 问题内容: 我有很多jar文件要添加到我的类路径中,因此,每次编译Java文件时,都会得到如下命令: 我尝试使用: 然后: 但是根本没有添加jar:由于缺少jar,我得到了错误信息…谢谢 问题答案: 也许您想尝试使用Maven来构建您的应用程序?它真的很容易设置,并且消除了依赖管理的所有问题。 同样从Java 6开始,您可以在类路径中使用通配符: set CLASSPATH = my_libs \

  • 问题内容: 如何设置一个计时器(例如2分钟)尝试连接数据库,然后在连接中出现任何问题时引发异常? 问题答案: 因此,答案的第一部分是如何做主题所要求的,因为这是我最初对它的解释方式,并且似乎有人发现有所帮助。此后,问题得到了澄清,我已经扩展了答案以解决该问题。 设定计时器 首先,你需要创建一个计时器(我在java.util这里使用版本): .. 要执行任务,请执行以下操作: 要在持续时间之后重复执

  • 但在Wire shark软件中,我们看到客户端只在TLSV1中与服务器进行对话。 参考链接:https://superuser.com/questions/747377/enable-tls-1-1-and-1-2-for-clients-on-java-7 在和中。但仍然在Wire shark软件中,我们看到客户端只在TLSV1中与服务器进行对话。 谁能告诉我们如何在客户端和服务器上执行TLS1

  • 嘿,伙计们,我实际上是java编程的新手。我可以把背景颜色的代码行放在哪里。因为当我在main方法中放一个颜色为黄色的jpanel时。jframe中背景颜色的设置有效,但jtag、jtext field和j按钮现在不见了...一切都只是黄色。 }

  • 问题内容: 我正在用Java做一些Swing GUI,我想我的问题很简单。如何设置鼠标的位置? 问题答案: 您需要使用机器人 此类用于生成本机系统输入事件,用于测试自动化,自运行演示以及需要控制鼠标和键盘的其他应用程序。Robot的主要目的是促进Java平台实现的自动化测试。 使用类生成输入事件与将事件发布到AWT事件队列或AWT组件不同,因为事件是在平台的本机输入队列中生成的。例如,实际上将移动