带线程池的Java聊天服务器

Question

我正在尝试使用线程池开发一个java聊天服务器，但我不知道如何处理来自客户端的传入消息。我想将每个套接字连接保存在哈希图中，并将任务添加到线程池的队列中。但是，服务器如何知道何时从客户端接收消息而不实例化缓冲区读取器？

Answer 1

您的服务器将需要使用包含从其套接字读取的BufferedReader的代理对象。也许您需要创建这些代理对象的集合。

例如

class ServerAgent implements Runnable {
   private OutputStream out;
   private BufferedReader br;

   public ServerAgent(Socket clientSocket) throws IOException {
      out = clientSocket.getOutputStream();
      br = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));

      // ....
   }


   @Override
   public void run() {
      // TODO finish code that reads from br, BufferedReader

   }
}

您的服务器可能有如下代码：

while (true) {
   Socket clientSocket = server.accept();
   futureList.add(threadPoolExector.submit(new ServerAgent(clientSocket)));
}

Answer 2

你不需要为你的每个套接字初始化一个缓冲的阅读器。您可以浏览并检查是否有数据等待读取。

for(Socket socket : socketsList)
    if(socket.getInputStream().available() > 0) {
        // you have data to be read from this socket
    }