~~~ public class WebsocketChannelInitalizer extends ChannelInitializer<SocketChannel> { protected void initChannel(SocketChannel socketChannel) throws Exception { ChannelPipeline pipeline = socketChannel.pipeline(); // websocket基于http協議，所以要有http編解碼器 pipeline.addLast(new HttpServerCodec()); // 對寫大數據流的支持 pipeline.addLast(new ChunkedWriteHandler()); // POST請求時，對應的參數信息是保存在message body中的,如果只是單純的用HttpServerCodec是無法完全的解析HttpPOST請求的， // 因為HttpServerCodec只能獲取uri中參數，所以需要加上HttpObjectAggregator // 對httpMessage進行聚合，聚合成FullHttpRequest或FullHttpResponse // 幾乎在netty中的編程，都會用到此handler pipeline.addLast(new HttpObjectAggregator(8192));// 聚合 // ws : 指定給客戶端連接訪問的路由 // 幫你處理一些繁重的復雜的事情，例如handshaking(ping, pong, close) // 對于websocket來講，都是以frames進行傳輸的，不同的數據類型對應的frames也不同 pipeline.addLast(new WebSocketServerProtocolHandler("/ws")); // pipeline.addLast(new TextWebsocketFrameHandler()); } } ~~~