測試Channelhandler

EmbeddedChannel提供了下面一些方法：

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

@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

實(shí)現(xiàn)

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

?

轉(zhuǎn)載于:https://www.cnblogs.com/mxz1994/p/9465643.html

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。