Java WebSocket广播失效问题：多客户端无法接收跨客户端广播消息

你的推测是对的：WebLogic默认会为每个WebSocket连接创建独立的@ServerEndpoint实例，导致每个客户端的消息只能在自身对应的端点实例中处理，无法实现跨客户端的广播。以下是具体的解决步骤：

1. 将WebSocket端点设置为单例模式 #

通过自定义ServerEndpointConfig.Configurator，强制WebLogic为所有连接复用同一个端点实例：

public class SingletonEndpointConfigurator extends ServerEndpointConfig.Configurator {
    private static final MyBroadcastEndpoint INSTANCE = new MyBroadcastEndpoint();

    @Override
    public <T> T getEndpointInstance(Class<T> endpointClass) throws InstantiationException {
        return endpointClass.cast(INSTANCE);
    }
}

在端点类上绑定该配置器：

@ServerEndpoint(value = "/ws/broadcast", configurator = SingletonEndpointConfigurator.class)
public class MyBroadcastEndpoint {
    // 后续逻辑实现
}

2. 维护线程安全的全局会话集合 #

在单例端点中，用线程安全的集合存储所有活跃的WebSocket会话，确保并发场景下的操作安全：

// 使用CopyOnWriteArraySet保证读写并发安全
private static final Set<Session> activeSessions = new CopyOnWriteArraySet<>();

@OnOpen
public void onSessionOpen(Session session) {
    activeSessions.add(session);
}

@OnClose
public void onSessionClose(Session session) {
    activeSessions.remove(session);
}

@OnError
public void onSessionError(Session session, Throwable error) {
    activeSessions.remove(session);
}

3. 实现广播逻辑 #

收到客户端消息时，遍历全局会话集合，向所有活跃客户端（可选择排除发送者）转发消息：

@OnMessage
public void handleMessage(String message, Session senderSession) {
    Iterator<Session> sessionIterator = activeSessions.iterator();
    while (sessionIterator.hasNext()) {
        Session session = sessionIterator.next();
        // 跳过已关闭的会话
        if (!session.isOpen()) {
            sessionIterator.remove();
            continue;
        }
        try {
            // 可选：排除消息发送者，避免重复接收
            if (!session.equals(senderSession)) {
                session.getBasicRemote().sendText("[" + senderSession.getId() + "]：" + message);
            }
        } catch (IOException e) {
            // 发送失败时移除无效会话
            sessionIterator.remove();
        }
    }
}

4. 集群环境额外处理 #

如果WebLogic是集群部署，单例端点仅在当前节点有效，需要跨节点同步消息：

• 使用WebLogic JMS主题：每个节点的端点收到消息后，发送到JMS主题；所有节点订阅该主题，收到消息后在本地节点广播给客户端。
• 借助WebLogic Coherence分布式缓存：将全局会话集合存储在Coherence缓存中，实现跨节点的会话共享与消息转发。

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