測試Channelhandler

EmbeddedChannel提供了下面一些方法：

• writeInbound(Object...)，寫一個消息到入站通道
• writeOutbound(Object...)，寫消息到出站通道
• readInbound()，從EmbeddedChannel讀取入站消息，可能返回null
• readOutbound()，從EmbeddedChannel讀取出站消息，可能返回null
• finish()，標示EmbeddedChannel已結束，任何寫數據都會失敗

@Testpublic void test1() {ByteBuf buf = Unpooled.buffer();for (int i = 0; i < 9; i++) {buf.writeByte(i);}ByteBuf input = buf.duplicate();EmbeddedChannel channel = new EmbeddedChannel(new FixedLengthFrameDecoder(3));// write bytes Assert.assertTrue(channel.writeInbound(input));Assert.assertTrue(channel.finish());// read messageAssert.assertEquals(buf.readBytes(3), channel.readInbound());Assert.assertEquals(buf.readBytes(3), channel.readInbound());Assert.assertEquals(buf.readBytes(3), channel.readInbound());Assert.assertNull(channel.readInbound());} 簡單測試入站分割長度Handler

實現

WebSocket使用HTTP升級機制從一個普通的HTTP連接WebSocket，因為這個應用程序使用WebSocket總是開始于HTTP(s)，然后再升級。什么時候升級取決于應用程序本身。直接執行升級作為第一個操作一般是使用特定的url請求。 在這里，如果url的結尾以/ws結束，我們將只會升級到WebSocket，否則服務器將發送一個網頁給客戶端。升級后的連接將通過WebSocket傳輸所有數據。邏輯圖如下：

?

轉載于:https://www.cnblogs.com/mxz1994/p/9465643.html

總結

以上是生活随笔為你收集整理的WebSocket 中的Netty的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。