Java ServerSocket

Question

所以我有一个多线程服务器，数据可以正确地来回发送，但是我的写操作在较慢的连接上停止了。我注意到它是按连接时间走的。第一个连接的客户端总是首先从服务器接收数据。下一个必须等到第一个完成接收，以此类推。我正在寻找的是一个服务器，发送数据给许多客户端，而不是等待一个客户端完成接收。我对NIO(非阻塞)有所了解，但我真的更喜欢保留我目前的方法，即对每个客户端使用一个单独的线程。

下面是代码。

服务器：

public class Server implements Runnable {

private Thread thread;
private ServerSocket serverSocket;
private ArrayList<ClientThread> clients;

public Server(int port) throws IOException {
    thread = new Thread(this);
    clients = new ArrayList<ClientThread>();
    serverSocket = new ServerSocket(port);
    thread.start();
}

@Override
public void run() {

    while (true) {

        try {
            //Listens to clients connecting.
            ClientThread client = new ClientThread(serverSocket.accept());
            clients.add(client);
            ServerWindow.addText("-- Someone connected!");
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

public void broadcast(String data) {
    broadcast(data, null);
}

public void broadcast(String data, ClientThread exclude) {

    int amount = clients.size();

    for (int i = 0; i < amount; i++) {

        if (!clients.get(i).equals(exclude)) { //Don't send it to that client.
            try {
                clients.get(i).broadcast(data);
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }
}

}

客户端线程对象：

public class ClientThread implements Runnable {

private Thread thread;
private Socket socket;
private Scanner input;
private PrintWriter output;

public ClientThread(Socket s) throws IOException {
    thread = new Thread(this);
    socket = s;
    socket.setTcpNoDelay(true);
    //socket.setSoTimeout(10); //Send little chunk for 10 milliseconds.
    input = new Scanner(socket.getInputStream());
    output = new PrintWriter(socket.getOutputStream());
    thread.start();
}

public void run() {

    while (true) {          
        if (input.hasNext()) {
            reciever(input.nextLine());
        }
    }
}

private void reciever(String data) {
    ServerWindow.addText(data);
    ServerWindow.server.broadcast(data, this);
}

public void broadcast(String data) throws IOException {
    output.println(data);
    output.flush();
}

}

Answer 1

似乎您正在从同一个线程调用广播方法。

对于Java多线程的新手来说，这是一个常见的陷阱。
广播方法位于Thread的子类中这一事实并不意味着它将在该Thread上执行

事实上，它将在调用它的线程上执行。将在您创建的< code>ClientThread上执行的唯一方法是< code>run()以及< code>run()在执行时调用的任何方法。如果您希望所述线程不仅从您的连接中读取数据，还向其写入数据，您必须修改run方法来侦听外部命令以开始写入。