測(cè)試Channelhandler

EmbeddedChannel提供了下面一些方法：

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

@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());} 簡(jiǎn)單測(cè)試入站分割長(zhǎng)度Handler

實(shí)現(xiàn)

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

?

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

總結(jié)

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

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