如何使用多线程允许多个客户端连接到服务器？ [复制]

Question

我有两个 java 类，一个用于服务器，一个用于客户端。使用常规套接字在它们之间建立连接。如何允许客户端类的多个实例使用多线程同时连接到服务器？ 我尝试在 SO 上进行搜索，但我真的找不到任何简明/清晰的答案。

这是我的重要方法（它们都在Server类中）：

public void startRunning() {

    try {
        server = new ServerSocket(portNum, 10); // port num and backlog

        while (true) {
            try {

                waitForConnection();
                setupStreams();  //sets up streams
                whileChatting(); //exchanges messages
            } catch (EOFException e1) {
                showMessage("\n Server ended the connection");

            } finally {
                closeEverything();  //closes all streams
            }
        }
    } catch (IOException e) {
        e.printStackTrace();
    }

}

private void waitForConnection() throws IOException {

    showMessage(" Waiting for connections...\n");
    connection = server.accept();
    showMessage(" Connected to "
            + connection.getInetAddress().getHostName());

}

Answer 1

这是一个简单的例子。一个新的线程回复每个新的传入客户端。

import java.io.*;
import java.net.*;

class Server implements Runnable {
  public static final int port = 5678;


  public void run() {
    try{
       ServerSocket server = new ServerSocket(port);

       while (true) 
       {
           final Socket client = server.accept();
           new Thread() {
                public void run() {
                      try{
                          ObjectInputStream in = 
                          new ObjectInputStream( client.getInputStream() );
                         String msg = (String) in.readObject();
                         System.out.println(msg);
                        }
                      catch(Exception e){System.err.println(e);}

          }}.start();
       }
      }
    catch(IOException e){System.err.println(e);}
    }

}

class Client {

  public void writeMessage(String msg) throws IOException {
     new ObjectOutputStream((new Socket("localhost",Server.port).getOutputStream())).writeObject(msg);
  }
}

public class ClientServer{
  public static void main(String[] args) throws IOException{
    Server server = new Server("My Multithreaded Server");
    new Thread(server).start();
    Client client1 = new Client();
    Client client2 = new Client();
    client1.writeMessage("Hello !");
    client2.writeMessage("Give me five !");
  }
}