如何向连接到 Undertow websocket 服务器的所有客户端广播消息？

Question

这是我目前对 Undertow websocket 服务器的设置：

    Undertow server = Undertow.builder()
            .addHttpListener(8080, "localhost")
            .setHandler(path()
                    .addPrefixPath("/", websocket((exchange, channel) -> {
                        channel.getReceiveSetter().set(new AbstractReceiveListener() {
                            @Override
                            protected void onFullTextMessage(WebSocketChannel channel, BufferedTextMessage message) {
                                final String messageData = message.getData();
                                for (WebSocketChannel session : channel.getPeerConnections()) {
                                    WebSockets.sendText(messageData, session, null);
                                }
                            }
                        });
                        channel.resumeReceives();
                    }))).build();

这是从他们的演示文件之一复制而来的。我相信onFullTextMessage 这里会将它收到的任何消息广播给所有客户端。

我希望能够按需触发此行为。因此，不必接收消息并使用事件处理程序发送更多消息，我希望能够任意执行server.send() 并向所有连接的客户端发送消息。

我环顾四周，没有发现任何似乎能够实现这一目标的东西。我不喜欢跟踪所有WebSocketChannels 并手动发送给每个客户的想法。当然，我忽略了某处的方法？

如果这不是不可能的事情，我将不胜感激！

Answer 1

您可以通过获取到此运河的所有连接并发送消息来向通道上的所有客户端广播消息：

channel.getPeerConnections().forEach(connection -> {
    WebSockets.sendText(messageData, connection, null);
});