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

在Netty框架中创建WebSocket服务器并实现代理一个观察者模式以持续监听接收到的消息，通常涉及以下几个步骤：

1. **创建WebSocket服务端处理器**:
首先，你需要创建一个`ChannelInboundHandler`，这是处理WebSocket连接事件的地方。你可以继承`WebSocketServerProtocolHandler`，并在其中设置自定义的`WebSocketFrameDecoder`和`WebSocketObjectTextMessageHandler`。

public class WebSocketServerHandler extends ChannelInboundHandlerAdapter {
    private final WebSocketFrameDecoder decoder;
    private final WebSocketObjectTextMessageHandler messageHandler;

    public WebSocketServerHandler(WebSocketObjectTextMessageHandler messageHandler) {
        this.messageHandler = messageHandler;
        // 初始化decoder
        decoder = new ...();
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        if (msg instanceof WebSocketFrame frame) {
            // 使用decoder解码帧
            TextWebSocketFrame textFrame = (TextWebSocketFrame) decoder.decode(ctx.channel(), frame);
            if (textFrame != null) {
                // 将消息传递给messageHandler处理
                messageHandler.handle(textFrame.content().toString());
            }
        } else {
            super.channelRead(ctx, msg);
        }
    }
}

2. **实现观察者接口**:
创建一个接口或类，用于接收消息，例如`MessageObserver`:

public interface MessageObserver {
    void onMessage(String message);
}

3. **创建观察者实例**:
在需要监听消息的地方，创建一个`MessageObserver`的实现对象，并将其注册到`WebSocketObjectTextMessageHandler`中。

MessageObserver observer = new MessageObserver() {
    @Override
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
        // 这里可以根据实际需求执行相应的业务逻辑
    }
};

WebSocketObjectTextMessageHandler handler = new WebSocketObjectTextMessageHandler(new MyCustomLogic(observer));

4. **启动WebSocket服务器**:
最后，在主程序中创建一个`Bootstrap`实例，配置好WebSocket服务器的处理器和其他属性，然后启动它。

Bootstrap b = new Bootstrap();
b.group(...).channel(NioServerSocketChannel.class)
    .childHandler(new ChannelInitializer<SocketChannel>() {
        @Override
        protected void initChannel(SocketChannel ch) {
            ch.pipeline().addLast(new WebSocketServerHandler(handler));
        }
    });
b.bind(port).sync().thenRun(() -> {
    // 服务器已经运行，开始监听消息
});