网络插座：如何判断网络索克频道何时打开？

Question

我正在编写一个netty/websocket服务器应用程序，其中对websockent客户端（例如浏览器）的写入来自另一个线程（即不是来自websockets）。

这是netty4.0.18.Final，我的应用程序在很大程度上基于提供的websocket服务器示例。

我需要知道websocket通道何时打开，以便我可以保存ChannelHandlerContext，以便其他线程可以执行写入。我有一些有效的方法，但我希望有一个更健壮的方法。

它看起来像WebSocketServerHandler。当浏览器连接到Web套接字时，将调用channelRead0（）两次。第二个调用的ChannelHandlerContext可用于将来写入通道。

所以我的方法是对channelRead0（）的第二次调用采取一些行动。如果我在handleWebSocketFrame（）中得到一个CloseWebSocketFrame，我将重置计数器。

有更好的方法吗？

更新:添加userEventTriggered()后，处理程序类如下所示:

public class WebSocketServerHandler extends SimpleChannelInboundHandler<Object> {
   ...

   @Override
   public void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {
      System.out.println("read0");

      if (msg instanceof FullHttpRequest) {
        handleHttpRequest(ctx, (FullHttpRequest) msg);
      } else if (msg instanceof WebSocketFrame) {
        handleWebSocketFrame(ctx, (WebSocketFrame) msg);
      }
   }

   @Override
   public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
    System.out.println("userEvent");
    if (evt == WebSocketServerProtocolHandler.ServerHandshakeStateEvent.HANDSHAKE_COMPLETE) {
        System.out.println("opening channel " + ctx.toString());
        ...    
    } else {
        super.userEventTriggered(ctx, evt);
    }
} 

和初始值设定项：

public class WebSocketServerInitializer extends ChannelInitializer<SocketChannel> {

...

   @Override
   public void initChannel(SocketChannel ch) throws Exception {
      ChannelPipeline pipeline = ch.pipeline();
      pipeline.addLast("codec-http", new HttpServerCodec());
      pipeline.addLast("aggregator", new HttpObjectAggregator(65536));
      pipeline.addLast("handler", new WebSocketServerHandler(statusListener));
   } 
}

Answer 1

您可以检查ServerHandshakeStateEvent。HANDSHAKE_COMPLETE事件类似于我的聊天服务器示例中的事件，它可以如下使用：

@Override
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
    if (evt == WebSocketServerProtocolHandler.ServerHandshakeStateEvent.HANDSHAKE_COMPLETE) {

        ctx.pipeline().remove(HttpRequestHandler.class);

        group.writeAndFlush(new TextWebSocketFrame("Client " + ctx.channel() + " joined"));

        group.add(ctx.channel());
    } else {
        super.userEventTriggered(ctx, evt);
    }
}