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

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

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

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);  // 轉發(fā)其他消息
        }
    }
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }
}

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

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 編碼的字符串。
這類幀對應于 TextWebSocketFrame 類。
TextWebSocketFrame 是一個 單一類型的消息框架，在 Netty 中用于表示 WebSocket 連接中傳輸?shù)奈谋鞠ⅰ?br />2.Binary WebSocket Frame (二進制幀)
用于傳輸二進制數(shù)據(jù)（如文件、圖片、視頻等）。
對應于 BinaryWebSocketFrame 類。
這種類型的 WebSocket 幀通常是用于傳輸二進制數(shù)據(jù)。
3.Close WebSocket Frame (關閉幀)
用于關閉 WebSocket 連接的幀。
對應于 CloseWebSocketFrame 類。
發(fā)送此類型的幀可以通知對方關閉連接。
4.Ping WebSocket Frame (Ping 幀)
用于測試 WebSocket 連接是否正常可用（心跳）。
對應于 PingWebSocketFrame 類。
一般由客戶端或服務器發(fā)送，收到 Ping 后，另一方通常會發(fā)送一個 Pong 幀作為響應。
5.Pong WebSocket Frame (Pong 幀)
用于回應 Ping 幀。
對應于 PongWebSocketFrame 類。

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

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

最新評論