netty实现websocket服务端主动向客户端推送消息

要在 Netty 中实现 WebSocket 服务端主动向客户端推送消息，可以使用 `ChannelGroup` 来管理连接到服务器的 WebSocket 客户端的 `Channel`，然后通过遍历 `ChannelGroup` 并将消息写入每个 `Channel` 来实现消息的推送。

下面是一个示例代码，演示了如何在 Netty 中实现 WebSocket 服务端主动向客户端推送消息：

public class WebSocketServerHandler extends SimpleChannelInboundHandler<WebSocketFrame> {

    private static ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, WebSocketFrame frame) throws Exception {
        // 处理 WebSocket 请求
        if (frame instanceof TextWebSocketFrame) {
            // 处理文本消息
            String text = ((TextWebSocketFrame) frame).text();
            System.out.println("Received message: " + text);

            // 推送消息给所有连接的客户端
            channelGroup.writeAndFlush(new TextWebSocketFrame("Server: " + text));
        } else {
            // 其他类型的消息，如二进制消息、Ping/Pong 消息等
            // ...
        }
    }

    @Override
    public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
        // 当有客户端连接时，将其添加到 ChannelGroup 中
        Channel channel = ctx.channel();
        channelGroup.add(channel);
    }

    @Override
    public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
        // 当有客户端断开连接时，将其从 ChannelGroup 中移除
        Channel channel = ctx.channel();
        channelGroup.remove(channel);
    }

    // 主动向客户端推送消息的方法
    public void pushMessageToClients(String message) {
        channelGroup.writeAndFlush(new TextWebSocketFrame("Server: " + message));
    }
}

在上述示例中，我们创建了一个静态的 `ChannelGroup` 对象 `channelGroup`，用于存储连接到服务器的 WebSocket 客户端的 `Channel`。当有客户端连接时，将其添加到 `channelGroup` 中；当客户端断开连接时，将其从 `channelGroup` 中移除。

在处理 WebSocket 请求时，如果收到文本消息，我们可以通过调用 `channelGroup.writeAndFlush()` 方法将消息写入每个客户端的 `Channel` 中，实现消息的推送。

此外，我们还添加了一个名为 `pushMessageToClients()` 的方法，用于在服务端主动向所有客户端推送消息。

你可以在适当的时候调用 `pushMessageToClients()` 方法来推送消息给所有连接的客户端。例如，可以在定时任务或其他事件触发的地方调用该方法来主动向客户端推送消息。

希望对你有所帮助！如果还有其他问题，请继续提问。