Dubbo協(xié)議解析
?????????Dubbo協(xié)議設(shè)計(jì)參考了TCP/IP協(xié)議，包括協(xié)議頭和協(xié)議體兩部分晨横。16字節(jié)報(bào)文頭主要攜帶了魔法數(shù)（0xdabb莽囤，用于分割兩個(gè)不同請(qǐng)求），以及當(dāng)前請(qǐng)求報(bào)文是否是Request颗品、Response肯尺、心跳和事件的信息，請(qǐng)求時(shí)也會(huì)攜帶當(dāng)前報(bào)文體內(nèi)序列化協(xié)議編號(hào)躯枢，另外還有請(qǐng)求狀態(tài)则吟、請(qǐng)求唯一表示和報(bào)文體長(zhǎng)度。
?????????0~7 ????????? 魔數(shù)高位 ??存儲(chǔ)0xda
?????????8~15 ????????魔數(shù)低位?? 存儲(chǔ)0xbb
?????????16???????????? 數(shù)據(jù)包類型?? 是否為雙向的RPC調(diào)用（比如方法調(diào)用有返回值）锄蹂，0位Response氓仲，1位Request
?????????17???????????? 調(diào)用方式 ?? 16位為1的情況下有效，0為單向調(diào)用得糜，1為雙向調(diào)用
?????????18???????????? 事件標(biāo)識(shí) ??? 0為請(qǐng)求/響應(yīng)包敬扛，1位心跳包
?????????19~23???????序列化器編號(hào)
?????????24~31???????狀態(tài)
?????????32~95?????? 請(qǐng)求編碼 ??? 8個(gè)字節(jié)存儲(chǔ)RPC請(qǐng)求的唯一id，用來將請(qǐng)求和響應(yīng)做關(guān)聯(lián)
?????????96~127?????消息體長(zhǎng)度 ??? 4個(gè)字節(jié)消息體朝抖，存有Dubbo版本號(hào)啥箭、服務(wù)接口名、服務(wù)接口版本治宣、方法名急侥、參數(shù)類型、方法參數(shù)值和請(qǐng)求額外參數(shù)
Netty編解碼器擴(kuò)展
?????????Netty提供了兩個(gè)基類炼七，一個(gè)是ByteToMessageDecoder解碼基類，一個(gè)是MessageToByteEncode編碼基類布持，用于自定義協(xié)議擴(kuò)展豌拙。
ByteToMessageDecoder
?????????ByteToMessageDecoder是一個(gè)抽象類，解碼方法名decode题暖，需要子類去實(shí)現(xiàn)按傅。繼承關(guān)系如下圖：
?????????ByteToMessageDecoder繼承了ChannelInboundHandlerAdapter，是一個(gè)Inbound入站處理器胧卤，關(guān)于ChannelPipeline事件傳播機(jī)制前面幾篇文章已經(jīng)做了詳細(xì)介紹唯绍，此處不再贅述，所以重點(diǎn)關(guān)注一下其channelRead方法枝誊，即讀事件的傳播况芒，代碼如下：
?????????其實(shí)現(xiàn)比較簡(jiǎn)單，主要是對(duì)ByteBuf解碼叶撒，然后繼續(xù)向下傳播ChannelRead事件绝骚，解碼具體實(shí)現(xiàn)在callDecode方法中，代碼實(shí)現(xiàn)如下：
?????????callDecode中會(huì)讀取數(shù)據(jù)祠够，然后會(huì)調(diào)用decodeRemovalReentryProtection繼續(xù)解碼压汪，在decodeRemovalReentryProtection中我們看到了所期待的的調(diào)用子類的decode方法解碼。
MessageToByteEncoder
?????????與解碼器相對(duì)的古瓤，MessageToByteEncoder編碼器止剖，也是個(gè)抽象基類腺阳，提供了抽象方法encode需要子類去實(shí)現(xiàn)，繼承關(guān)系如下圖：
?????????由繼承關(guān)系圖可以看出穿香，MessageToByteEncoder繼承了ChannelOutboundHandlerAdapter亭引，是一個(gè)outbound出站處理器，重點(diǎn)關(guān)注其write方法扔水，代碼實(shí)現(xiàn)如下：
?????????代碼邏輯還是比較清晰痛侍，就是調(diào)用encode編碼，然后向下傳播write事件魔市。
?????????到這里就看到了Netty對(duì)自定義編解碼的擴(kuò)展主届，下面介紹Dubbo對(duì)擴(kuò)展的自定義實(shí)現(xiàn)。
Dubbo協(xié)議實(shí)現(xiàn)源碼分析
?????????編解碼器本質(zhì)上都是handler待德，所以先從Netty啟動(dòng)是往ChannelPipeline中添加handler開始看君丁，以服務(wù)端為例，NettyServer#doOpen方法代碼如下：
?????????標(biāo)準(zhǔn)的一個(gè)Netty服務(wù)器寫法将宪，里邊可以看到編解碼都由NettyCodecAdapter維護(hù)绘闷，NettyCodecAdapter代碼如下：
?????????實(shí)現(xiàn)較為簡(jiǎn)單，維護(hù)了兩個(gè)內(nèi)部類较坛，一個(gè)是InternalEncoder繼承自MessageToByteEncoder印蔗，一個(gè)是InternalDecoder繼承自ByteToMessageDecoder，實(shí)現(xiàn)了對(duì)應(yīng)的編解碼接口丑勤。以及維護(hù)了一個(gè)Code2類型的對(duì)象华嘹，Codec2也是一個(gè)擴(kuò)展點(diǎn)，對(duì)應(yīng)不同協(xié)議的實(shí)現(xiàn)法竞，因?yàn)榻榻BDubbo協(xié)議耙厚，所以此處是DubboCountCodec，DubboCountCodec代碼如下：
?????????DubboCountCodec內(nèi)部維護(hù)了一個(gè)DubboCodec岔霸，DubboCodec才是編解碼具體實(shí)現(xiàn)薛躬，DubboCountCodec做的就是一次性讀取更多完整報(bào)文編解碼生成對(duì)象。DubboCodec繼承關(guān)系如下圖：
encode源碼分析
?????????先介紹encode呆细，DubboCountCodec調(diào)用encode之后型宝，其具體實(shí)現(xiàn)邏輯位于ExchangeCodec#encode方法，實(shí)現(xiàn)代碼如下：
?????????首先對(duì)需要編碼的消息類型進(jìn)行判斷絮爷，如果是Request則調(diào)用encodeRequest诡曙，如果是Response則調(diào)用encodeResponse，如果都不是略水，則調(diào)用父類TelnetCodec的encode方法价卤。先展開分析下encodeRequest方法，代碼如下：
?????????實(shí)際上就是對(duì)開頭所描述的Dubbo協(xié)議的構(gòu)建渊涝，其中會(huì)調(diào)用encodeRequestData對(duì)RpcInvocation調(diào)用進(jìn)行編碼慎璧，代碼如下：
?????????主要是將方法調(diào)用參數(shù)和值編碼成字節(jié)流床嫌。包括框架版本、調(diào)用接口胸私、方法名稱厌处、參數(shù)類型、參數(shù)值等信息岁疼。
?????????encodeResponse方法實(shí)現(xiàn)與encodeRequest方法實(shí)現(xiàn)十分相似阔涉，同樣是對(duì)Dubbo協(xié)議字節(jié)流的構(gòu)建，不再展開描述捷绒，主要介紹下其encodeResponseData方法瑰排，其data一半是Result類型，實(shí)現(xiàn)代碼如下：
?????????主要完成對(duì)調(diào)用結(jié)果的序列化暖侨。
decode源碼分析
?????????解碼過程要比編碼復(fù)雜一點(diǎn)椭住，主要是需要解決粘包和半包問題，其實(shí)現(xiàn)位于ExchangeCodec#decode方法字逗，實(shí)現(xiàn)代碼如下：
?????????解碼主要分為解碼16字節(jié)報(bào)文頭和解碼報(bào)文體京郑，具體的消息體解碼位于DubboCodec#decodeBody方法中，具體代碼如下：
?????????解碼分為對(duì)request的解碼和response的解碼葫掉，雖然看上去很長(zhǎng)些举，其實(shí)只是請(qǐng)求類型的分類，以及根據(jù)decode.in.io的配置值判斷是在I/O線程中直接解碼俭厚，還是交由業(yè)務(wù)線程池去解碼户魏。
?????????請(qǐng)求消息解碼具體實(shí)現(xiàn)位于DecodeableRpcInvocation#decode方法，代碼實(shí)現(xiàn)如下：
?????????主要邏輯是獲取各項(xiàng)參數(shù)封裝到當(dāng)前的RpcInvocation對(duì)象中套腹。
?????????響應(yīng)消息解碼的具體實(shí)現(xiàn)位于DecodeableRpcResult#decode中绪抛，具體代碼實(shí)現(xiàn)如下：
?????????根據(jù)響應(yīng)標(biāo)記位资铡，對(duì)各種情況下的響應(yīng)做處理电禀，正常情況下將返回?cái)?shù)據(jù)反序列化后存到result字段中。
