java - 简单的java聊天室

Question

非常简单，我想创建一个接受多个客户端的聊天室，所有客户端都可以分配自己的 ID。每当他们输入任何内容时，都会将其发送给所有用户。目前我有一个回显客户端服务器，客户端输入一些内容并回显。我的第一个问题是如何允许用户给自己一个用户名？显然我需要一个接受名称的变量，您建议我将其放入哪个类中？我怎样才能得到这个名字本身if (theInput.equalsIgnoreCase("用户名": ""))

然后我需要做的就是向所有客户回应客户所说的内容。我不知道如何做到这一点，所以任何建议将不胜感激。虽然我在网上找到了一些教程和示例代码，但我不理解它，如果我不理解，即使它确实有效，我也不会觉得使用它很舒服。谢谢

这是我的代码:Echo客户端

'// echo client
import java.util.Scanner;
import java.io.*;
import java.net.*;
public class EchoClient {
public static void main(String[] args) throws IOException { 
    Socket echoSocket = null;
    //PrintWriter socketOut = null;
    try {
        echoSocket = new Socket("127.0.0.1", 4444); // connect to self at port 4444
        System.out.println("Connected OK");
        Scanner socketIn = new Scanner(echoSocket.getInputStream());  // set up input from socket
        PrintWriter socketOut = new PrintWriter(echoSocket.getOutputStream(), true);    // set up output to socket
        Scanner kbdIn = new Scanner(System.in);     // Scanner to pick up keyboard input
        String serverResp = "";
        String userInput = kbdIn.nextLine();        // get input from the user

        while (true) {
            socketOut.println(userInput);                   // send user input to the socket
            serverResp =  socketIn.nextLine();     // get the response from the socket
            System.out.println("echoed back: " + serverResp);   // print it out
            if (serverResp.equals("Closing connection")) { break; } //break if we're done
            userInput = kbdIn.nextLine();   // get next user input
        }
        socketOut.close();
        kbdIn.close();
        socketIn.close();
    }
    catch (ConnectException e) {
        System.err.println("Could not connect to host");
        System.exit(1);
    }
    catch (IOException e) {
        System.err.println("Couldn't get I/O for connection");
        System.exit(1);
    }
    echoSocket.close();
} 

}'

回显服务器

// multiple (threaded) server
import java.net.ServerSocket;
import java.net.Socket;
public class EchoServerMult {
public static void main(String[] args) throws Exception {
    ServerSocket serverSocket = new ServerSocket(4444);   // create server socket on this machine
    System.err.println("Started server listening on port 4444");
    while (true) {        // as each connection is made, pass it to a thread
        //new EchoThread(serverSocket.accept()).start();  // this is same as next 3 lines
        Socket x = serverSocket.accept();   // block until next connection
        EchoThread et = new EchoThread(x);
        et.start();  
        System.err.println("Accepted connection from client");
    }
}

}

回声线程

// thread to handle one echo connection
import java.net.*;
import java.io.*;
import java.util.Scanner;
public class EchoThread extends Thread {
private Socket mySocket = null;

public EchoThread(Socket socket) {       // constructor method
    mySocket = socket;
}
public void run() {
    try {
        PrintWriter out = new PrintWriter(mySocket.getOutputStream(), true);
        Scanner in = new Scanner(mySocket.getInputStream());
        String inputLine;
        while (true) {
            inputLine = in.nextLine();      
            if (inputLine.equalsIgnoreCase("Bye")) {
                out.println("Closing connection");
                break;      
            } else {
                out.println(inputLine);
            }
        }
        out.close();
        in.close();
        mySocket.close(); 
    } catch (Exception e) {
        System.err.println("Connection reset");   // bad error (client died?)
    }
}

}

Answer 1

最简单的可能是使用 observer pattern 连接到所有客户端(在创建它们时)的公共(public)类。 。该链接甚至还提供了一些 java 代码。

要让客户端拥有用户名，最简单的方法就是让服务器发送的第一条消息是“输入您想要的用户名:”，然后按原样获取返回值。否则，您可以使用 inputLine.substring(int) 从 username:{username} 获取用户名。您可以将用户名存储在 EchoThread 中。避免重复的用户名需要您在 EchoServer 中存储一组用户名。然后，您可以将用户名与消息一起传递给 Observable 类。

目前，您的程序使用顺序消息传递，就像客户端和服务器交替发送消息一样(更具体地说，客户端发送一条消息，然后服务器发回相同的消息)。您需要更改此设置，以便客户端可以随时接收消息。您可以通过在客户端创建一个仅发送或仅接收的线程(并在客户端本身执行其他操作)来完成此操作。在客户端:

...
System.out.println("Connected OK");
PrintWriter socketOut = new PrintWriter(echoSocket.getOutputStream(), true);    // set up output to socket
new ReceiverThread(echoSocket).start();
while (true)
{
   String userInput = kbdIn.nextLine();        // get input from the user
   socketOut.println(userInput);                   // send user input to the socket
}
...

try ... catch 中的 ReceiverThread run 方法:(其余部分看起来与 EchoThread 相同)

Scanner in = new Scanner(mySocket.getInputStream());
while (true)
{
   String inputLine = in.nextLine();      
   if (inputLine.equalsIgnoreCase("Bye"))
   {
      out.println("Closing connection");
      System.exit(0);      
   }
   else
   {
      out.println(inputLine);
   }
}

System.exit() 可能不是最好的主意，但这只是为了让您了解该怎么做。