服务器发送带有网页搜索和网络 ->的问候消息，导致异常

Question

我有一个使用Netty（4.0.17）的websocket服务器，它可以响应来自JavaScript客户端的请求。通信工作正常，但当我尝试在客户端连接时立即发送问候消息时，我有一个例外。

我的代码看起来像这样:

public class LiveOthelloWSHandler extends SimpleChannelInboundHandler<TextWebSocketFrame> {

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        super.channelActive(ctx);
        ChannelFuture f = ctx.channel().writeAndFlush(new TextWebSocketFrame("(gameID=0)[LiveOthelloServer="+ VERSION_NUMBER + "]\n"));
    }

// ...

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, TextWebSocketFrame frame) throws Exception {

        final String request = frame.text();
        Channel thisChannel = ctx.channel();

        // Do something with request
        // Write back

        thisChannel.writeAndFlush(new TextWebSocketFrame(response + "\n"));
    }
}

< code>channelRead0()正常，客户端发送消息，服务器回复没有任何问题。不起作用的是“问候”部分。我想向客户端发送一条欢迎消息(在< code>ChannelActive()方法中使用< code>VERSION_NUMBER的字符串)，但是我总是得到一个异常:

java.lang.UnsupportedOperationException: unsupported message type: TextWebSocketFrame

我想这可能是因为channelActive（）在连接建立后但在websocket握手完成之前就被调用了。我怎么能等待握手完成，然后发送问候消息（客户端还没有发送任何请求）？

供参考，我的初始化是：

@Override
public void initChannel(SocketChannel ch) throws Exception {
    ChannelPipeline pipeline = ch.pipeline();
    pipeline.addLast(
                     new HttpRequestDecoder(),
                     new HttpObjectAggregator(65536),
                     new HttpResponseEncoder(),
                     new WebSocketServerProtocolHandler("/websocket"),
                     myLiveOthelloWSHandler);

Answer 1

只是室光...

http://netty.io/4.0/api/io/netty/handler/codec/http/websocketx/WebSocketServerProtocolHandler.html

检测握手的最佳方法是覆盖ChannelInboundHandler.userEventTriggered…所以我只需添加：

@Override
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
    super.userEventTriggered(ctx, evt);
    if (evt == WebSocketServerProtocolHandler.ServerHandshakeStateEvent.HANDSHAKE_COMPLETE) {
        ChannelFuture f = ctx.channel().writeAndFlush(new TextWebSocketFrame("(gameID=0)[LiveOthelloServer="+ VERSION_NUMBER + "]\n"));
    }
}