GitHub上标星68k，基于SpringBoot+Netty分布式开源的即时通讯系统项目

该项目是一个基于Spring Boot和Netty的分布式即时通讯系统。以下是该项目的核心部分代码示例：

// 使用Spring Boot创建WebSocket端点
@ServerEndpoint(value = "/websocket/{userId}")
@Component
public class WebSocketServer {
    private static final Logger log = LoggerFactory.log("WebSocketServer");
 
    private Session session;
    private String userId;
 
    @OnOpen
    public void onOpen(Session session, @PathParam("userId") String userId) {
        this.session = session;
        this.userId = userId;
        // 新用户上线，通知其他在线用户
        OnlineProcessor.addOnlineUser(userId, this);
        // ... 其他逻辑
    }
 
    @OnClose
    public void onClose() {
        // 用户下线，通知其他在线用户
        OnlineProcessor.removeOnlineUser(userId);
        // ... 其他逻辑
    }
 
    @OnMessage
    public void onMessage(String message) {
        // 处理接收到的消息
        // ... 逻辑处理
    }
 
    @OnError
    public void onError(Throwable error) {
        log.error("WebSocket发生错误", error);
    }
 
    // 发送消息给单个用户
    public void sendMessage(String message) {
        this.session.getAsyncRemote().sendText(message);
    }
}

这段代码定义了一个WebSocket服务端点，用于处理用户的连接、断开连接和接收消息。它还展示了如何维护在线用户列表和如何向特定用户发送消息。

为了保持回答简洁，我省略了一些细节，如处理在线用户的具体逻辑（例如添加、移除在线用户、群发消息等）。这些细节可以在GitHub项目中查看完整的实现。