摘要:修改之前的服務(wù)端開發(fā)代碼修改為下面代碼綁定端口同步等待成功等待服務(wù)端監(jiān)聽端口關(guān)閉主要修改了和方法和原理分析的工作原理是它依次遍歷中的可讀字節(jié)判斷看是否有或如果有就以此位置為結(jié)束位置從可讀索引到結(jié)束位置區(qū)間的字節(jié)就組成了一行它是以換行符為結(jié)束
修改之前的 Netty 服務(wù)端開發(fā) 代碼, 修改為下面代碼
public class TimeServer { public void bind(int port) throws Exception { EventLoopGroup bossGroup = new NioEventLoopGroup(); EventLoopGroup workerGroup = new NioEventLoopGroup(); try { ServerBootstrap b = new ServerBootstrap(); b.group(bossGroup, workerGroup) .channel(NioServerSocketChannel.class) .option(ChannelOption.SO_BACKLOG, 1024) .childHandler(new ChildChannelHandler()); // 綁定端口, 同步等待成功 ChannelFuture f = b.bind(port).sync(); // 等待服務(wù)端監(jiān)聽端口關(guān)閉 f.channel().closeFuture().sync(); } finally { bossGroup.shutdownGracefully(); workerGroup.shutdownGracefully(); } } private class ChildChannelHandler extends ChannelInitializer{ @Override protected void initChannel(SocketChannel ch) throws Exception { ch.pipeline().addLast(new LineBasedFrameDecoder(1024)); ch.pipeline().addLast(new StringDecoder()); ch.pipeline().addLast(new TimeServerHandler()); } } private class TimeServerHandler extends ChannelHandlerAdapter { @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { ctx.close(); } @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { String body = (String) msg; System.out.println(body); ByteBuf resp = Unpooled.copiedBuffer("6666".getBytes()); ctx.write(resp); } @Override public void channelReadComplete(ChannelHandlerContext ctx) throws Exception { ctx.flush(); } } }
主要修改了 initChannel 和 channelRead 方法.
LineBasedFrameDecoder 和 StringDecoder 原理分析LineBasedFrameDecoder 的工作原理是它依次遍歷 ByteBuf 中的可讀字節(jié), 判斷看是否有 或 , 如果有, 就以此位置為結(jié)束位置, 從可讀索引到結(jié)束位置區(qū)間的字節(jié)就組成了一行.
它是以換行符為結(jié)束標(biāo)志的解碼器, 支持?jǐn)y帶結(jié)束符或者不攜帶結(jié)束符兩種解碼方式, 同時支持配置單行的最大長度. 如果連續(xù)讀取到最大長度后仍然沒有發(fā)現(xiàn)換行符, 就會拋出異常, 同時忽略之前讀到的異常碼流.
StringDecoder 的功能非常簡單, 就是將收到的對象轉(zhuǎn)換成字符串, 然后繼續(xù)調(diào)用后面的 Handler.
LineBasedFrameDecoder + StringDecoder 組合就是按行切換的文本解碼器, 它被設(shè)計用來支持 TCP 的粘包和拆包.
文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址:http://specialneedsforspecialkids.com/yun/72740.html
摘要:接收方只需要等待,直到讀到確定數(shù)量的字節(jié),然后處理即可。而這個字節(jié)流的前個字節(jié)用于表示對象的長度,接下來的字節(jié)就是傳輸?shù)膶ο蟮淖止?jié)流,最后不夠最大長度的用任意字節(jié)進(jìn)行填充即可。 什么是tcp半包粘包?簡單來講就是接收到的tcp包并不一定是一個完整的包。它可能是1個包的一部分,也可能是多個完整包加上1個包的一部分。為什么?因?yàn)閠cp的定義是面向字節(jié)流的傳輸協(xié)議,所以操作系統(tǒng)實(shí)現(xiàn)這個協(xié)議的...
摘要:是一個面向字節(jié)流的協(xié)議,它是性質(zhì)是流式的,所以它并沒有分段。可基于分隔符解決。編解碼的主要目的就是為了可以編碼成字節(jié)流用于在網(wǎng)絡(luò)中傳輸持久化存儲。 showImg(https://segmentfault.com/img/remote/1460000015895049); 前言 記得前段時間我們生產(chǎn)上的一個網(wǎng)關(guān)出現(xiàn)了故障。 這個網(wǎng)關(guān)邏輯非常簡單,就是接收客戶端的請求然后解析報文最后發(fā)送...
摘要:以流的方式進(jìn)行數(shù)據(jù)傳輸上層的應(yīng)用協(xié)議為了對消息進(jìn)行區(qū)分往往采用如下中方式消息長度固定累計讀取到長度總和為定長的報文后就認(rèn)為讀到了一個完整的消息將計數(shù)器置位重新開始讀取下一個數(shù)據(jù)報將回車換行符作為消息結(jié)束符例如協(xié)議這種方式在文本協(xié)議中應(yīng)用比較 TCP 以流的方式進(jìn)行數(shù)據(jù)傳輸, 上層的應(yīng)用協(xié)議為了對消息進(jìn)行區(qū)分, 往往采用如下 4 中方式. 消息長度固定, 累計讀取到長度總和為定長 LE...
摘要:設(shè)置每個數(shù)據(jù)包的大小如個字節(jié),如果某個數(shù)據(jù)包不足個字節(jié)可能會出現(xiàn)丟包的情況,即該數(shù)據(jù)包未從一個端到另一個端,此時需要用空格或者既定的符號補(bǔ)充在數(shù)據(jù)包之間使用一些字符進(jìn)行分割如號之類的,解析的時候先處理掉分隔符再拿到各個數(shù)據(jù)包就好了。 netty 概念: Netty是由JBOSS提供的一個java開源框架。Netty提供異步的、事件驅(qū)動的網(wǎng)絡(luò)應(yīng)用程序框架和工具,用以快速開發(fā)高性能、高可靠...
摘要:如果什么事都沒得做,它也不會死循環(huán),它會將線程休眠起來,直到下一個事件來了再繼續(xù)干活,這樣的一個線程稱之為線程。而請求處理邏輯既可以使用單獨(dú)的線程池進(jìn)行處理,也可以跟放在讀寫線程一塊處理。 Netty到底是什么 從HTTP說起 有了Netty,你可以實(shí)現(xiàn)自己的HTTP服務(wù)器,F(xiàn)TP服務(wù)器,UDP服務(wù)器,RPC服務(wù)器,WebSocket服務(wù)器,Redis的Proxy服務(wù)器,MySQL的P...
閱讀 1892·2021-11-23 09:51
閱讀 1535·2021-11-19 09:40
閱讀 3208·2021-11-11 11:01
閱讀 1105·2021-09-27 13:34
閱讀 1835·2021-09-22 15:56
閱讀 2122·2019-08-30 15:52
閱讀 1061·2019-08-30 14:13
閱讀 3473·2019-08-30 14:10