如何实现Java中服务器与多个客户端的聊天功能？

在Java中，实现服务器与多个客户端的聊天功能可以通过使用Socket编程和多线程技术来实现，下面是一个简单的示例，展示了如何创建一个服务器，该服务器可以与多个客户端进行通信。

我们需要创建一个服务器端程序，它可以接收来自多个客户端的连接请求，并为每个连接创建一个新的线程来处理客户端的消息。

import java.io.*;
import java.net.*;
import java.util.*;
public class ChatServer {
    private static final int PORT = 8888;
    private Set<String> clientNames = new HashSet<>();
    private Map<String, PrintWriter> clientOutputs = new HashMap<>();
    public void start() throws IOException {
        ServerSocket serverSocket = new ServerSocket(PORT);
        System.out.println("Chat Server is running...");
        while (true) {
            Socket socket = serverSocket.accept();
            System.out.println("New client connected");
            ClientHandler handler = new ClientHandler(socket, this);
            new Thread(handler).start();
        }
    }
    public static void main(String[] args) throws IOException {
        new ChatServer().start();
    }
}

我们需要创建一个客户端处理器类，它将负责读取客户端发送的消息并将其广播到所有已连接的客户端。

import java.io.*;
import java.net.*;
public class ClientHandler implements Runnable {
    private Socket socket;
    private ChatServer server;
    private String clientName;
    public ClientHandler(Socket socket, ChatServer server) {
        this.socket = socket;
        this.server = server;
    }
    @Override
    public void run() {
        try {
            InputStreamReader input = new InputStreamReader(socket.getInputStream());
            BufferedReader reader = new BufferedReader(input);
            PrintWriter writer = new PrintWriter(socket.getOutputStream(), true);
            clientName = reader.readLine();
            server.clientNames.add(clientName);
            server.clientOutputs.put(clientName, writer);
            String serverMessage = "New client connected: " + clientName;
            broadcast(serverMessage, server);
            String clientMessage;
            do {
                clientMessage = reader.readLine();
                serverMessage = "[" + clientName + "]: " + clientMessage;
                broadcast(serverMessage, server);
            } while (!clientMessage.equalsIgnoreCase("bye"));
            server.clientNames.remove(clientName);
            server.clientOutputs.remove(clientName);
            String disconnectMessage = clientName + " has disconnected.";
            broadcast(disconnectMessage, server);
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public void broadcast(String message, ChatServer server) {
        for (PrintWriter writer : server.clientOutputs.values()) {
            writer.println(message);
        }
    }
}

我们需要创建一个客户端程序，它可以连接到服务器并发送消息。

import java.io.*;
import java.net.*;
public class ChatClient {
    private static final String SERVER_IP = "127.0.0.1";
    private static final int SERVER_PORT = 8888;
    private BufferedReader in;
    private PrintWriter out;
    private Socket socket;
    private String nickname;
    public ChatClient(String nickname) throws IOException {
        this.nickname = nickname;
        socket = new Socket(SERVER_IP, SERVER_PORT);
        in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        out = new PrintWriter(socket.getOutputStream(), true);
    }
    public void sendMessage(String message) {
        out.println(message);
    }
    public void receiveMessage() throws IOException {
        String serverMessage;
        do {
            serverMessage = in.readLine();
            System.out.println(serverMessage);
        } while (!serverMessage.equalsIgnoreCase("bye"));
    }
    public void disconnect() throws IOException {
        out.println("bye");
        socket.close();
    }
    public static void main(String[] args) throws IOException {
        ChatClient client = new ChatClient("John");
        client.receiveMessage();
        client.sendMessage("Hello, everyone!");
        client.disconnect();
    }
}

在这个示例中，我们创建了一个简单的聊天服务器，它可以与多个客户端进行通信，当一个新的客户端连接到服务器时，服务器会为该客户端创建一个新的线程来处理它的消息，客户端可以发送消息，服务器会将消息广播到所有已连接的客户端，当客户端断开连接时，服务器会更新客户端列表并将断开连接的消息广播到其他客户端。