Quarkus是否提供类似Socket.io的WebSocket房间会话聚合方案？

我目前正在开发Java Quarkus后端，希望实现类似Socket.io的「房间」功能，让不同房间内的用户能够进行通信，目标架构如下：

我查阅了Quarkus官方WebSocket指南，但该方案仅支持为每个用户创建独立Session，无法实现Socket.io那样的房间/大厅聚合功能。示例代码如下：

Map<String, Session> sessions = new ConcurrentHashMap<>();

@OnOpen
public void onOpen(Session session, @PathParam("username") String username) {
    broadcast("User " + username + " joined");
    sessions.put(username, session);
}

该方案的架构如下图所示：

• 是否可通过PathParams合并不同会话或创建自定义会话？
• 是否有提供类似Socket.io房间/大厅功能的实用Java库？
• 能否修改上述示例代码以实现目标功能？

1. PathParams实现会话聚合 #

可以通过PathParams传递房间ID来对会话分组，不需要合并或创建自定义会话。只需要维护一个「房间ID -> 会话集合」的线程安全映射，用户连接时通过PathParam传入房间ID，将对应的Session加入该房间的集合即可。

2. 实用Java库推荐 #

• Quarkus WebSocket原生扩展：无需额外依赖，通过自定义映射结构即可实现房间功能，完全适配Quarkus生态。
• Vert.x WebSocket：Quarkus基于Vert.x构建，Vert.x内置了会话分组（Group）功能，可直接用来实现房间通信，兼容性拉满。
• Tyrus：Java EE标准的WebSocket实现，支持通过注解或API管理会话分组，适合追求标准兼容性的场景。

3. 修改示例代码实现房间功能 #

以下是调整后的代码，通过维护房间与会话的映射实现房间内消息广播：

// 线程安全的房间-会话集合映射
private static final Map<String, Set<Session>> roomSessions = new ConcurrentHashMap<>();

@OnOpen
public void onOpen(Session session, @PathParam("username") String username, @PathParam("roomId") String roomId) {
    // 初始化房间集合并加入当前会话
    roomSessions.computeIfAbsent(roomId, k -> ConcurrentHashMap.newKeySet()).add(session);
    // 向房间内所有用户发送加入通知
    broadcastToRoom(roomId, "User " + username + " joined the room");
}

@OnMessage
public void onMessage(String message, Session session, @PathParam("roomId") String roomId) {
    // 广播消息到当前房间
    broadcastToRoom(roomId, message);
}

@OnClose
public void onClose(Session session, @PathParam("roomId") String roomId) {
    Set<Session> sessions = roomSessions.get(roomId);
    if (sessions != null) {
        sessions.remove(session);
        // 房间为空时清理映射，避免内存泄漏
        if (sessions.isEmpty()) {
            roomSessions.remove(roomId);
        }
    }
}

private void broadcastToRoom(String roomId, String message) {
    Set<Session> sessions = roomSessions.get(roomId);
    if (sessions != null) {
        sessions.forEach(session -> session.getAsyncRemote().sendText(message));
    }
}

这段代码通过roomId参数对会话分组，实现了指定房间内的消息广播，完全匹配你需要的Socket.io房间功能架构。

内容的提问来源于stack exchange，提问作者Vlajic Stevan