-1

我已经实现了一个小型 Java 聊天室程序,客户端可以在其中与服务器通信。尽管多个客户端不起作用-我相信这是因为客户端在连接时保留了一个套接字?有没有一种简单的方法来添加多个客户端功能?谢谢你的帮助。

public void startRunning(){
      try{
         server = new ServerSocket(6789, 100); // port no, max users
         while(true){
            try{
               waitForConnection();
               setupStreams();
               connectionRecieving();
            }catch(EOFException eofException){
               showMessage("Server ended connection \n");
            }finally{
               closeConnection();
            }
         }
      }catch(IOException ioException){
         ioException.printStackTrace();
      }
   }

   // Wait for connection
   private void waitForConnection() throws IOException{
      showMessage("Attempting connection... \n");
      connection = server.accept();
      showMessage("Connected to: " + connection.getInetAddress().getHostName() + "\n");
   }

   // Get stream to send and receive data
   private void setupStreams() throws IOException{
      output = new ObjectOutputStream(connection.getOutputStream());
      output.flush();
      input = new ObjectInputStream(connection.getInputStream());
   }

   // Close streams and sockets 
   private void closeConnection(){
      showMessage("----- \nClosing connections... \n");
      try{
         output.close();
         input.close();
         connection.close();
      }catch(IOException ioException){
         ioException.printStackTrace();
      }
   }
4

1 回答 1

0

要同时读取和写入多个客户端,您需要单独的线程(阻塞 IO),或者如果您想使用单个线程,则需要 NIO(非阻塞 IO)。

你可以查看这篇关于实现差异的帖子,但 NIO 通常是更有效的方法。

使用阻塞 I/O 通常遵循您上面使用的代码,除了您需要一个单独的线程来处理每个接受的套接字。使用 NIO,使用起来稍微复杂一些;看看这个教程

于 2013-02-14T19:41:15.847 回答