WebSocketConnection.java 文件源码

@Override
protected void preparePipeline(ChannelPipeline pipeline) {
    pipeline.addLast(
            new HttpClientCodec(),
            new HttpObjectAggregator(8192));
    pipeline.addLast("handler",
            new WebSocketClientHandler(this,
                    WebSocketClientHandshakerFactory.newHandshaker(
                            this.uri, WebSocketVersion.V13, null, false, new DefaultHttpHeaders())));
}