实时通信系统设计：WebSockets实现无URL存储的服务器-客户端连接

// 1. 初始化WebSocket服务器
WebSocketServer server = new WebSocketServer(port);

// 存储所有活跃的客户端连接，键为客户端ID，值为连接对象
Map<String, WebSocketConnection> activeConnections = new ConcurrentHashMap<>();

// 2. 监听新连接事件
server.onConnection((connection) -> {
    String clientId = generateUniqueClientId(); // 为每个新连接生成唯一ID
    activeConnections.put(clientId, connection);
    System.out.println("新客户端连接: " + clientId);

    // 3. 监听客户端消息事件
    connection.onMessage((message) -> {
        System.out.println("收到来自 " + clientId + " 的消息: " + message);
        // 根据消息内容进行路由（广播或私有消息）
        if (message.startsWith("BROADCAST:")) {
            String broadcastMsg = message.substring("BROADCAST:".length());
            // 广播消息给所有活跃连接
            activeConnections.values().forEach(conn -> conn.send("广播消息: " + broadcastMsg));
        } else if (message.startsWith("PRIVATE:")) {
            // 假设私有消息格式为 PRIVATE:targetClientId:content
            String[] parts = message.split(":", 3);
            if (parts.length == 3) {
                String targetId = parts[1];
                String privateContent = parts[2];
                WebSocketConnection targetConnection = activeConnections.get(targetId);
                if (targetConnection != null) {
                    targetConnection.send("私有消息 from " + clientId + ": " + privateContent);
                } else {
                    connection.send("错误: 目标客户端 " + targetId + " 不在线。");
                }
            }
        }
    });

    // 4. 监听连接关闭事件
    connection.onClose(() -> {
        activeConnections.remove(clientId); // 从活跃连接列表中移除
        System.out.println("客户端断开连接: " + clientId);
    });

    // 5. 监听错误事件
    connection.onError((error) -> {
        System.err.println("客户端 " + clientId + " 连接错误: " + error.getMessage());
    });
});

// 6. 启动服务器
server.start();
System.out.println("WebSocket服务器已启动，监听端口: " + port);

// 1. 建立WebSocket连接
WebSocket client = new WebSocket("ws://localhost:8080");

// 2. 监听连接打开事件
client.onOpen(() -> {
    System.out.println("已连接到WebSocket服务器。");
    // 连接成功后可以发送初始消息或身份验证信息
    client.send("Hello Server!");
});

// 3. 监听服务器消息事件
client.onMessage((message) -> {
    System.out.println("收到服务器消息: " + message);
});

// 4. 监听连接关闭事件
client.onClose(() -> {
    System.out.println("与服务器的连接已关闭。");
    // 实现重连逻辑
});

// 5. 监听错误事件
client.onError((error) -> {
    System.err.println("WebSocket连接错误: " + error.getMessage());
});

// 示例：客户端发送消息
// client.send("BROADCAST:大家好！"); // 广播消息
// client.send("PRIVATE:someOtherClientId:你好！"); // 私有消息