JavaWebSocket实时通信服务端实现

package org.example.websocket.chat;

import java.net.InetSocketAddress;
import java.net.UnknownHostException;
import org.java_websocket.WebSocket;
import org.java_websocket.framing.Framedata;
import org.java_websocket.handshake.ClientHandshake;
import org.java_websocket.server.WebSocketServer;

/**
 * WebSocket 服务端实现
 * 作者：Example Developer
 * 网站：example.com
 */
public class ChatServer extends WebSocketServer {

    public ChatServer(int port) throws UnknownHostException {
        super(new InetSocketAddress(port));
    }

    public ChatServer(InetSocketAddress address) {
        super(address);
    }

    /**
     * 当客户端发送消息给服务器时调用此方法
     */
    @Override
    public void onMessage(WebSocket conn, String message) {
        if (message != null && message.startsWith("[video313596790]")) {
            this.userJoin(message.replaceFirst("\[video313596790\]", ""), conn);
        } else {
            ChatServerPool.sendMessage(message); // 向所有在线用户广播消息
        }
    }

    /**
     * 处理用户加入
     * @param user 用户标识
     * @param conn 连接对象
     */
    public void userJoin(String user, WebSocket conn) {
        ChatServerPool.addUser(user, conn); // 将新用户添加到连接池
    }

    /**
     * 处理用户离开
     * @param conn 连接对象
     */
    public void userLeave(WebSocket conn) {
        ChatServerPool.removeUser(conn); // 从连接池中移除用户
    }

    /**
     * 当新的客户端连接到服务器时调用
     */
    @Override
    public void onOpen(WebSocket conn, ClientHandshake handshake) {}

    /**
     * 当客户端断开连接时调用
     */
    @Override
    public void onClose(WebSocket conn, int code, String reason, boolean remote) {
        userLeave(conn);
    }

    /**
     * 当发生错误时调用
     */
    @Override
    public void onError(WebSocket conn, Exception ex) {
        if (conn != null) {} // 可以在这里处理错误
    }

    /**
     * 当服务器启动时调用
     */
    @Override
    public void onStart() {}
}