封装基于netty的websocket服务器时，如何新建一个观察者可以一直监听websocket接收到消息

Question

封装基于netty的websocket服务器时，如何新建一个观察者可以一直监听websocket接收到消息

Answer 1

在使用Netty构建WebSocket服务器时，要创建一个观察者持续监听WebSocket接收到的消息，可以通过添加一个自定义的ChannelHandler来实现。这个ChannelHandler将处理WebSocket的数据帧，并且可以注册一个监听器来通知感兴趣的观察者。下面是基本的步骤：

1. 创建一个继承自SimpleChannelInboundHandler的自定义处理器类，用于处理WebSocket的数据帧。这个处理器可以是一个TextWebSocketFrameHandler或者BinaryWebSocketFrameHandler，这取决于你需要处理的是文本消息还是二进制消息。

2. 在自定义处理器中，重写channelRead0方法，这个方法会在接收到消息时被调用。在这个方法中，你可以将接收到的消息转发给注册的观察者。

3. 创建一个观察者接口，定义接收消息时调用的方法。

4. 在你的WebSocket服务器初始化过程中，将这个自定义处理器添加到你的ChannelPipeline中。

5. 创建观察者实例，并注册到你的自定义处理器中。

以下是一个简单的代码示例：

// 自定义的WebSocket处理器
public class WebSocketFrameHandler extends SimpleChannelInboundHandler<WebSocketFrame> {
    // 观察者列表
    private List<WebSocketObserver> observers = new ArrayList<>();

    // 注册观察者
    public void registerObserver(WebSocketObserver observer) {
        observers.add(observer);
    }

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, WebSocketFrame frame) throws Exception {
        // 将接收到的消息通知给所有注册的观察者
        for (WebSocketObserver observer : observers) {
            observer.onMessage(frame.text());
        }
    }

    // 观察者接口定义
    public interface WebSocketObserver {
        void onMessage(String message);
    }
}

// 服务器初始化代码
public class WebSocketServerInitializer extends ChannelInitializer<SocketChannel> {
    @Override
    protected void initChannel(SocketChannel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline();
        pipeline.addLast(new HttpServerCodec());
        pipeline.addLast(new HttpObjectAggregator(65536));
        pipeline.addLast(new WebSocketServerProtocolHandler("/ws"));
        pipeline.addLast(new WebSocketFrameHandler()); // 添加自定义的WebSocket处理器
    }
}

// 使用WebSocketFrameHandler时注册观察者
WebSocketFrameHandler handler = new WebSocketFrameHandler();
handler.registerObserver(new WebSocketFrameHandler.WebSocketObserver() {
    @Override
    public void onMessage(String message) {
        // 处理接收到的消息
    }
});

在这个例子中，WebSocketFrameHandler类处理WebSocket消息，并提供了注册观察者的方法。当一个WebSocket帧被接收到时，channelRead0方法会被调用，并将消息传递给所有注册的观察者。