溫馨提示×

溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊×
其他方式登錄
點(diǎn)擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

Netty粘包問題的解決方法

發(fā)布時(shí)間：2021-08-07 16:05:29 來源：億速云 閱讀：104 作者：chen 欄目：云計(jì)算

本篇內(nèi)容主要講解“Netty粘包問題的解決方法”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“Netty粘包問題的解決方法”吧!

我們知道，netty當(dāng)中有boss線程和worker線程，通常是1對多的關(guān)系，可以理解為boss接到客戶的請求之后，分配給其中一個(gè)worker去處理，如果客戶過多，可能會出現(xiàn)一個(gè)worker服務(wù)多個(gè)客戶的情況。這是背景。

按照我的理解，粘包問題解決的關(guān)鍵在于2點(diǎn)，1、接收到數(shù)據(jù)在無法得到及時(shí)解析的情況下，得有地方給它存下來；2、緩沖區(qū)指針的任意移動(dòng)；恰好，這兩點(diǎn)netty都能夠很輕易的。下面是代碼，因?yàn)楣镜谋Ｃ苄枨?，將會隱去具體業(yè)務(wù)部分。

public class ProtocolAnaDecoder extends ByteToMessageDecoder {

    @Override

    protected void decode(ChannelHandlerContext ctx, ByteBuf in, Listout) throws Exception {         Object decoded = null;

        while(true){

            decoded = decode(ctx, in);

             if (decoded != null) {

                out.add(decoded);

            } else{

                return;

            }

        }

    }

    private Object decode(ChannelHandlerContext ctx, ByteBuf in) {

        //標(biāo)記當(dāng)前讀指針位置

        in.markReaderIndex();

        while(in.isReadable()){

            byte b = in.readByte();

            //業(yè)務(wù)處理部分，如果獲得一個(gè)正確的消息對象，直接返回

        }

        //如果沒有得到任何消息對象，重置讀指針位置（之前mark的位置）。         in.resetReaderIndex();

        return null;

    }

}

到此，相信大家對“Netty粘包問題的解決方法”有了更深的了解，不妨來實(shí)際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！

向AI問一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場，如果涉及侵權(quán)請聯(lián)系站長郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手