0

我想编写一个服务器，它在给定端口上侦听连接并将套接字放入BlockingLinkedQueue其中，消费者线程将从中读取消息。我以这种方式接受传入连接：

   ServerSocket serverSocket = new ServerSocket(port);
   while (true)
   {
        Socket socket = null;
        socket = serverSocket.accept();
        queue.put(socket);
   }

当我尝试从两个单独的主机并行连接时，在建立第二个连接后，对第一个主机的响应会发送到第二个主机。当我将代码更改为下面列出的代码时，第二个连接仅被拒绝： 

   while (true)
   {
        ServerSocket serverSocket = new ServerSocket(port);
        Socket socket = serverSocket.accept();
        queue.put(socket);
   }

我的问题是：

  1. 这两种情况有什么区别？为什么在第一种情况下消息被发送到第二台主机？
  2. 我应该如何重构我的代码以便在我的服务器和两个主机之间创建单独的连接并并行处理它们？
4

1 回答 1

5

这两种情况有什么区别？

在第一种情况下，您将同一端口用于多个连接。在第二种情况下，您将丢弃服务器端口，因此拒绝任何等待的连接。

为什么在第一种情况下消息被发送到第二台主机？

由于代码中的错误，此处未显示。

我应该如何重构我的代码以便在我的服务器和两个主机之间创建单独的连接并并行处理它们？

为每个连接创建一个线程。

于 2012-06-26T18:03:26.953 回答