0

我写了一个简单的程序，服务器应该打印多个客户端发送的数据。但是服务器只接收到部分数据。以下是相关的代码片段。

服务器：

try {
        serverSocket = new ServerSocket(8888);
    } catch (IOException e) {
        System.err.println("Could not listen on port: 8888");
        System.exit(-1);
    }
 while (listening) {
    Socket clientSocket = serverSocket.accept();
    BufferedReader reader = new BufferedReader(new InputStreamReader(
                            clientSocket.getInputStream()));
        System.out.println(reader.readLine());

        reader.close();
        clientSocket.close();
  }
  serverSocket.close();

客户：

  try {
        socket = new Socket("nimbus", 8888);
        writer = new PrintWriter(socket.getOutputStream(), true);
        localHost = InetAddress.getLocalHost();
    } 
    catch (UnknownHostException e) {} 
    catch (IOException e) {}

    StringBuilder msg1 = new StringBuilder("A: ");
    for(int i=1; i<=3; i++)
        msg1.append(i).append(' ');
    writer.println(localHost.getHostName() + " - " + msg1);

    StringBuilder msg2 = new StringBuilder("B: ");
    for(int i=4; i<=6; i++)
        msg2.append(i).append(' ');
    writer.println(localHost.getHostName() + " - " + msg2);

    StringBuilder msg3 = new StringBuilder("C: ");
    for(int i=7; i<=9; i++)
        msg3.append(i).append(' ');
    writer.println(localHost.getHostName() + " - " + msg3);

    writer.close();
    socket.close();

我得到以下输出（在 3 个客户端上运行时）

nimbus2 - A: 1 2 3 
nimbus3 - A: 1 2 3 
nimbus4 - A: 1 2 3

我没有收到第二条和第三条消息。服务器一直在等待。我哪里错了？

编辑：在服务器代码中，我尝试删除reader.close()和clientSocket.close(). 那也没有用。另一个问题——如果 3 个客户端发送 3 条消息，是否需要 9 个连接？（这就是原因，我在服务器代码中关闭了连接）

4

3 回答 3

1

您可能希望将套接字的处理委托给另一个线程。我编写了一个示例，该示例通过将每个传入套接字传递给 Executor 来工作，以便它可以读取所有输入。我使用 Executors.newCachedThreadPool() 应该增长到需要的大小。如果您希望它一次只能处理 1 个客户端，也可以使用 Executors.newFixedThreadPool(1)。

我所做的唯一其他更改是删除了 BufferedReader 并将其替换为 Scanner。我遇到了 BufferedReader 不返回数据的问题。我不确定为什么。

Executor exe = Executors.newCachedThreadPool();
ServerSocket serverSocket = null;
try {
    serverSocket = new ServerSocket(8888);
} catch (IOException e) {
    System.err.println("Could not listen on port: 8888");
    System.exit(-1);
}
while (listening) {
    final Socket clientSocket = serverSocket.accept();

    exe.execute(new Runnable() {

        @Override
        public void run() {
            try {
                Scanner reader = new Scanner(clientSocket.getInputStream());
                while(reader.hasNextLine()){
                    String line = reader.nextLine();
                    System.out.println(line);
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                clientSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    });

}
serverSocket.close();
于 2012-01-08T17:22:21.303 回答
0

约翰是对的。您在阅读消息后通过调用 clientsocket.close() 关闭客户端连接，这就是您无法获取其他消息的原因。收到所有消息后，您应该调用 clientsocket.close()

于 2012-01-08T16:38:43.227 回答
0

看起来您在客户端完成写入之前/服务器读取他们发送的所有消息之前关闭了与客户端的连接。我认为您需要继续readline，并且在他们向您发送一条消息后可能不会终止客户端的连接。

于 2012-01-08T16:16:44.753 回答