java - 用于多用户聊天程序的ArrayList

Question

嘿，堆栈溢出。

所以我一直在开发一个聊天程序来自学一些 Java，并且我让它可以运行到任何数量的客户端都可以自由连接到服务器，但每个客户端只能与服务器通信。

这显然是一个糟糕的聊天程序，因此我实现了一个处理程序数组列表，其目标是将一个客户端写入的内容发送给所有客户端。问题是我无法让它工作，现在我在客户端和服务器之间输入 3 行文本后我的程序崩溃了。

请看一下我的代码。我将突出显示在尝试实现数组列表时更改的代码部分。我想我只是把东西放错了地方。

服务器代码:

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

    public class Server{
    //----------------------------------------------------
    ArrayList<Handler> handlers = new ArrayList<Handler>();
    //----------------------------------------------------
public static void main(String[] args){

    try{
        ServerSocket ss = new ServerSocket(8822);
        while(true){

            Socket s = ss.accept();
            new Handler(s).start();



        }
    }catch(Exception e){
        System.out.println(e.getMessage());
    }
}
    }

    class Handler extends Thread{

Socket socket;
boolean notdone;
BufferedReader br;
PrintWriter pw;
String line;


public Handler(Socket socket){
    this.socket = socket;
    notdone = true;
}

public void run(){

    //------------------
    handlers.add(this);
    //------------------

    try{
        br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()),true);
                    //--------------------------------------------------------
        Iterator<Handler> handlerIterator = handlers.iterator();
                    //--------------------------------------------------------
        while(notdone){

            line = br.readLine();

            if(line.equals("bye")){
                System.out.println("Client said 'bye'");
                notdone = false;
                break;
            }else{
                System.out.println("Echo: " + line);
                            //----------------------------------------------
                while (handlerIterator.hasNext()){
                    Handler current = handlerIterator.next();

                    current.pw.println(line);

                }
                            //----------------------------------------------
            }

        }
        br.close();
        pw.close();
        socket.close();

    }catch(Exception e){
        System.out.println(e);
        System.out.println("Client severed connection.");
    }
}
    }

对于客户，我认为我应该更改突出显示部分中的一些内容，但我不确定是什么。

客户端代码:

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

public class Client{

public static void main(String[] args){


    try{
        Socket s = new Socket("localhost", 8822);

        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        PrintWriter pw = new PrintWriter(new OutputStreamWriter(s.getOutputStream()),true);

        Scanner scan = new Scanner(System.in);
        boolean notdone = true;

        while(notdone){
            String outString = scan.nextLine();
            if(outString.equals("bye")){
                pw.println(outString);
                notdone = false;
            }else{
                            //------------------
                pw.println(outString);
                String inString = br.readLine();
                            //------------------

                System.out.println("Received: " + inString);
            }
        }
        br.close();
        pw.close();
        s.close();

    }catch(Exception e){
        System.out.println("Server severed connection.");
    }

}
}

Answer 1

这里有一个错误供您引用:

    Iterator<Handler> handlerIterator = handlers.iterator();
    while(notdone){
        // ...
        while (handlerIterator.hasNext()){
            Handler current = handlerIterator.next();
            // ....
        }
    }

第一次执行外循环时，您将执行内循环。通过外循环的第二次，handlerIterator 已经耗尽，因此它会为 hasNext() 返回 false并且你将永远不会再进入内循环。

相反，使用 for-each 循环:

    while(notdone){
        // ...
        for (Handler current : handlers){
            // ....
        }
    }

这相当于(但更简洁)

    while(notdone){
        // ...
        Iterator<Handler> handlerIterator = handlers.iterator()
        while (handlerIterator.hasNext()){
            Handler current = handlerIterator.next();
            // ....
        }
    }

同时，在客户端，

            pw.println(outString);
            String inString = br.readLine();

表示您仅在写入服务器之后才从服务器读取。所以客户不能只是听。对于单个客户端来说这应该没问题，但是如果您有两个客户端，那么您将得到以下结果:

1. ClientA 向服务器发送“hello”
2. 服务器向两个客户端流打印“hello”
3. ClientA 从其缓冲区中读取“hello”(ClientB 尚未读取任何内容)
4. ClientB 向服务器发送“world”
5. ClientB 从其缓冲区中读取“hello”
6. 服务器将“world”打印到两个客户端流

现在两个客户端都看到了 ClientA 的消息，但没有看到 ClientB 的消息。您将不断收到这种奇怪的延迟效果，最终缓冲区将被填满并阻塞。

真正的解决方案是每个客户端都需要有一个单独的线程来读取和写入。但这是代码难度的一个相当大的跳跃。我认为你应该看看BufferedReader#ready() ，它告诉您是否有数据等待读取。在客户端，您可以在 while-not-done 循环的开始处使用它:

while(br.ready()) {
    String inString = br.readLine();
    // ...
}
// Now all the messages from the server have been printed

您仍然会遇到客户需要不断交谈的问题，但只要他们这样做，事情就会成功。