ChannelInboundHandlerAdapter 和 SimpleChannelInboundHandler 都是 Netty 提供的處理器基類。

它們之間的主要區(qū)別：

ChannelInboundHandlerAdapter
ChannelInboundHandlerAdapter 是一個(gè)通用的處理器基類，繼承自 ChannelInboundHandler，用于處理 入站消息（即從客戶端到服務(wù)端的消息）。
它不做任何具體的消息類型限制，因此適用于處理各種類型的入站消息。
你可以重寫 channelRead 方法來處理不同類型的消息，或者重寫 exceptionCaught 等方法處理異常。
特點(diǎn):
通用：沒有指定消息類型，你可以在 channelRead 方法中處理任何類型的入站消息。
靈活：你需要手動(dòng)判斷消息的類型，進(jìn)行相應(yīng)的處理。
適用場(chǎng)景：適用于處理多種不同類型的消息，或者當(dāng)你希望處理多個(gè)類型的消息時(shí)。

public class WebSocketServerHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        if (msg instanceof TextWebSocketFrame) {
            // 處理 TextWebSocketFrame 消息
            String request = ((TextWebSocketFrame) msg).text();
            ctx.channel().writeAndFlush(new TextWebSocketFrame("Hello, " + request));
        } else {
            super.channelRead(ctx, msg);  // 轉(zhuǎn)發(fā)其他消息
        }
    }
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }
}

SimpleChannelInboundHandler
SimpleChannelInboundHandler 是 ChannelInboundHandlerAdapter 的一個(gè)子類，它專門用于處理某一特定類型的入站消息。你需要在創(chuàng)建 SimpleChannelInboundHandler 時(shí)指定消息類型 T（如 TextWebSocketFrame、ByteBuf 等）。
它在處理完每個(gè)消息后會(huì)自動(dòng)釋放該消息，因此避免了手動(dòng)管理消息的生命周期（比如調(diào)用 ReferenceCountUtil.release）。
如果消息類型不匹配，它會(huì)拋出異常，這使得它更適合處理單一類型的消息，簡(jiǎn)化了類型檢查。
特點(diǎn):
泛型：SimpleChannelInboundHandler 強(qiáng)制指定一個(gè)消息類型，這樣可以避免手動(dòng)類型檢查，減少代碼出錯(cuò)的可能性。
自動(dòng)釋放消息：在處理完消息后，SimpleChannelInboundHandler 會(huì)自動(dòng)釋放消息，因此你不需要關(guān)心資源的回收。
簡(jiǎn)潔：適合處理特定類型的消息，代碼更簡(jiǎn)潔、可讀性更好。

public class WebSocketServerHandler extends SimpleChannelInboundHandler<TextWebSocketFrame> {
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, TextWebSocketFrame msg) throws Exception {
        // 直接處理 TextWebSocketFrame 消息，不需要類型檢查
        String request = msg.text();
        ctx.channel().writeAndFlush(new TextWebSocketFrame("Hello, " + request));
    }
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }
}

WebSocket 幀類型

1.Text WebSocket Frame (文本幀)
用于傳輸文本數(shù)據(jù)，通常是 UTF-8 編碼的字符串。
這類幀對(duì)應(yīng)于 TextWebSocketFrame 類。
TextWebSocketFrame 是一個(gè) 單一類型的消息框架，在 Netty 中用于表示 WebSocket 連接中傳輸?shù)奈谋鞠ⅰ?br />2.Binary WebSocket Frame (二進(jìn)制幀)
用于傳輸二進(jìn)制數(shù)據(jù)（如文件、圖片、視頻等）。
對(duì)應(yīng)于 BinaryWebSocketFrame 類。
這種類型的 WebSocket 幀通常是用于傳輸二進(jìn)制數(shù)據(jù)。
3.Close WebSocket Frame (關(guān)閉幀)
用于關(guān)閉 WebSocket 連接的幀。
對(duì)應(yīng)于 CloseWebSocketFrame 類。
發(fā)送此類型的幀可以通知對(duì)方關(guān)閉連接。
4.Ping WebSocket Frame (Ping 幀)
用于測(cè)試 WebSocket 連接是否正?？捎茫ㄐ奶?br />對(duì)應(yīng)于 PingWebSocketFrame 類。
一般由客戶端或服務(wù)器發(fā)送，收到 Ping 后，另一方通常會(huì)發(fā)送一個(gè) Pong 幀作為響應(yīng)。
5.Pong WebSocket Frame (Pong 幀)
用于回應(yīng) Ping 幀。
對(duì)應(yīng)于 PongWebSocketFrame 類。

TextWebSocketFrame 的作用
TextWebSocketFrame 是專門用于處理 文本消息 的 WebSocket 幀，它繼承了 WebSocketFrame，并封裝了文本內(nèi)容。在實(shí)際的 WebSocket 應(yīng)用中，客戶端和服務(wù)器通常會(huì)通過發(fā)送和接收 TextWebSocketFrame 來交換信息，通常這些信息都是 UTF-8 編碼的文本。

到此這篇關(guān)于基于Netty實(shí)現(xiàn)的WebSocket的常用處理器的文章就介紹到這了,更多相關(guān)Netty WebSocket處理器內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論