创建一个套接字服务器，它允许通过线程和Java进行多个连接

Question

我正在尝试调整我的简单套接字服务器，使其可以通过多线程具有多个TCP连接，但是我似乎无法使其正常工作。到目前为止，我的代码如下，我不太确定从这里可以去哪里：

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

public class DoSomethingWithInput implements Runnable {
   private final Socket clientSocket; //initialize in const'r
   public void run() {


     BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
        String nextline;
        while ((nextline = in.readLine())!=null) {
           System.out.println(nextline);
        } //... close socket, etc.
    }
}


public class Socket{

  public Socket() {
}
@Override
public void run() {
  try {
    ServerSocket serverSocket = null;
    serverSocket = new ServerSocket(5432);
    for (;;) {
      ServerSocket serverSocket = null;
      serverSocket = new ServerSocket(5432);
      for (;;) {
        Socket clientSocket = null;
        clientSocket = serverSocket.accept();
        //delegate to new thread
        new Thread(new DoSomethingWithInput(clientSocket)).start();
      }
    }
  }catch (IOException e) {
   System.err.println("Could not listen on port: 5432.");
   System.exit(1);
}
}
}

谁能为我提供一些有关如何执行此操作的指示，以及为什么我当前的实现无法正常工作？我在这里浏览了Java教程http://download.oracle.com/javase/tutorial/networking/sockets/examples/KKMultiServerThread.java中的技巧，但他们在此处提供的示例似乎使用了许多外部资源，并且诸如KnockKnockProtocol等类的类

有人可以帮助我吗？

非常感谢你！

Answer 1

问题是当前您正在接受连接，但是随后立即对其进行阻塞读取，直到连接关闭：

// After a few changes...
Socket clientSocket = serverSocket.accept();
BufferedReader in = new BufferedReader(new InputStreamReader(
     clientSocket.getInputStream()));
String nextLine;
while ((nextLine = in.readLine()) != null) {
    System.out.println(nextline);
}

这意味着接受连接的同一线程正在尝试 处理 该连接。这样一来，您将无法同时使用多个连接。

而是创建一个实现的类（例如ConnectionHandler）Runnable，并让构造函数接受Socket。它的run方法应该处理连接。然后将代码更改为：

Socket clientSocket = serverSocket.accept();
Runnable connectionHandler = new ConnectionHandler(clientSocket);
new Thread(connectionHandler).start();

这将使您的“主”线程有空等待下一个连接。

（顺便说一句，KnockKnockProtocol该类并不是真正的“外部”类，它是html" target="_blank">示例的一部分。他们只是不清楚源在这里
…）