【问题标题】:a loop in the server which reads all the client sockets服务器中的一个循环,它读取所有客户端套接字
【发布时间】:2013-02-15 08:23:20
【问题描述】:

假设我有一个类 ServerReader,它是一个一直运行的线程。 ServerReader 有一个循环,它以如下方式从所有客户端读取所有消息:

while(true) {
    for(Socket socket: sockets_arraylist) {
        ObjectInputStream object_stream = new ObjectInputStream(socket.getInputStream());
        String str = (String) object_stream.readObject();
        System.out.println("message from client: " + str);
        object_stream.close();
    }
}

据我了解,当循环遇到 readObject() 方法时,线程将进入休眠状态,直到客户端实际发送对象。 所以想象一下这个场景: ArrayList "sockets_arraylist" 包含 2 个套接字。列表中的第二个套接字,属于等待接收消息的 2 号客户端。客户端 2 发送此消息并等待服务器读取它。但是有一个问题:上面的循环卡在 readObject() 方法上,等待来自客户端 1 的消息。所以直到客户端 1 不会向服务器发送他的消息,客户端 2 的消息才会被读取。

我需要在服务器上为每个客户端创建一个单独的线程吗?还是有另一种解决方案?

【问题讨论】:

  • 不要在每次要读取套接字时都创建一个新的ObjectInputStream。在套接字的整个生命周期中使用相同的。

标签: java multithreading sockets connection


【解决方案1】:

有两种解决方案:

1) 为每个客户端使用单独的线程。

2) 使用 java.nio 使用异步 IO - 在这种情况下,您可能需要 SocketChannel

为每个客户端使用单独的线程可能在概念上更简单,尽管这确实意味着您需要更仔细地考虑竞争条件。使用 NIO可能更具可扩展性(不同的基准测试显示不同的结果,而且它也可能取决于您的操作系统,就线程和调度的成本而言。)

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2017-10-05
    • 2011-11-15
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多