投稿
  1. 簡單一點首頁
  2. 編程

深入了解NettyHandler

小藍 • • 編程

一、NettyHandler傳遞

Netty框架提供可重用的事件驅動的網路應用程序編程框架，設計靈活且具有高效的性能。NettyHandler是這個框架中的一個重要組成部分，它負責處理所有入站和出站的數據流。NettyHandler是包含在Netty的ChannelPipeline中的一個攔截器，每個攔截器都可以執行自定義的邏輯處理，然後傳遞給下一個攔截器。

NettyHandler可以通過channelActive()，channelRead()和channelWrite()這些方法來處理Channel的網路事件。其中，channelActive()方法在連接建立時被調用，channelRead()方法在收到消息時被調用，channelWrite()方法在發送消息時被調用。對於入站數據，它將以ByteBuf形式傳遞到NettyHandler中，而出站數據則以ByteBuf的形式從NettyHandler中傳遞。

下面是一個簡單的NettyHandler示例：

public class MyNettyHandler extends ChannelInboundHandlerAdapter {

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        //連接到服務端成功時調用
        super.channelActive(ctx);
        System.out.println("Channel is active");
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        //接收到服務端消息時調用
        ByteBuf in = (ByteBuf)msg;
        try {
            String message = in.toString(CharsetUtil.UTF_8);
            System.out.println("Received the server message：" + message);
        } finally {
            in.release();
        }
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
        //服務端消息讀取完成時調用
        super.channelReadComplete(ctx);
        System.out.println("Channel read complete");
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        //異常處理方法
        super.exceptionCaught(ctx, cause);
        cause.printStackTrace();
        ctx.close();
    }
}

二、NettyHandler和ChildHandler

ChildHandler是一種特殊類型的攔截器，它用於處理NettyHandler創建的子通道。NettyHandler與ChildHandler之間有很多相似之處，但它們在用途上不同。ChildHandler被用於處理連接建立之後，NettyHandler創建的子通道，通常對於子通道的配置和狀態管理，我們使用ChildHandler實現。

下面是一個NettyHandler和ChildHandler如何使用的示常式序：

public class MyServerInitializer extends ChannelInitializer{

    @Override
    protected void initChannel(SocketChannel ch) throws Exception {
        //添加多個Handler到ChannelPipeline中
        ch.pipeline().addLast(new MyNettyHandler());
        ch.pipeline().addLast(new MyChildHandler());
    }
}

public class MyChildHandler extends ChannelInboundHandlerAdapter {

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        //子通道連接到服務端成功時調用
        super.channelActive(ctx);
        System.out.println("sub channel is active");
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        //接收到子通道消息時調用
        ByteBuf in = (ByteBuf)msg;
        try {
            String message = in.toString(CharsetUtil.UTF_8);
            System.out.println("Received the sub channel message：" + message);
        } finally {
            in.release();
        }
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
        //子通道消息讀取完成時調用
        super.channelReadComplete(ctx);
        System.out.println("Sub channel read complete");
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        //異常處理方法
        super.exceptionCaught(ctx, cause);
        cause.printStackTrace();
        ctx.close();
    }
}

三、常見NettyHandler

NettyHandler是Netty框架中的基本模塊，而在實際應用中，我們還會根據實際需要編寫自定義的NettyHandler。下面是一些常見的NettyHandler示例：

1. HeartbeatHandler

HeartbeatHandler用於實現心跳機制，可以在一段時間內檢查一些連接的狀態並發送心跳信息來保證連接的持續性。

public class HeartbeatHandler extends ChannelDuplexHandler {

    //心跳包內容，用於檢查連接狀態
    private static final ByteBuf HEARTBEAT_SEQUENCE = Unpooled.unreleasableBuffer(Unpooled.copiedBuffer("HEARTBEAT", CharsetUtil.UTF_8));

    @Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
        if (evt instanceof IdleStateEvent) {
            IdleStateEvent e = (IdleStateEvent) evt;
            switch (e.state()) {
                case READER_IDLE:
                    //長時間沒有讀取到數據，觸發心跳事件
                    ctx.writeAndFlush(HEARTBEAT_SEQUENCE.duplicate());
                    break;
                default:
                    break;
            }
        }
    }
}

2. AuthHandler

AuthHandler用於身份驗證，例如在連接服務端之前需要驗證客戶端的身份，可以通過AuthHandler實現。

public class AuthHandler extends ChannelInboundHandlerAdapter {

    private static final String USERNAME = "admin";
    private static final String PASSWORD = "secret";

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        //身份驗證代碼
        String[] data = ((String) msg).split(",");
        String username = data[0];
        String password = data[1];
        if (USERNAME.equals(username) && PASSWORD.equals(password)) {
            ctx.pipeline().remove(this);
            System.out.println("Authentication successful");
        } else {
            System.out.println("Authentication failed");
            ctx.close();
        }
    }
}

3. CompressionHandler

CompressionHandler用於數據壓縮和解壓縮。例如，當網路帶寬有限時，可以使用CompressionHandler自動壓縮傳輸數據，以節省帶寬。當然，數據交換的過程中，CompressionHandler也會自動解壓縮數據。

public class CompressionHandler extends ChannelDuplexHandler {

    private static final int DEFAULT_THRESHOLD = 1024;
    private int compressionThreshold = DEFAULT_THRESHOLD;

    public CompressionHandler() {
    }

    public CompressionHandler(int compressionThreshold) {
        this.compressionThreshold = compressionThreshold;
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        if (msg instanceof ByteBuf) {
            ByteBuf buf = (ByteBuf) msg;
            if (buf.readableBytes() >= compressionThreshold) {
                ByteBuf compressionBuf = compress(buf);
                buf.release();
                super.channelRead(ctx, compressionBuf);
            } else {
                super.channelRead(ctx, buf);
            }
        } else {
            super.channelRead(ctx, msg);
        }
    }

    @Override
    public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
        if (msg instanceof ByteBuf) {
            ByteBuf buf = (ByteBuf)msg;
            ByteBuf compressionBuf = compress(buf);
            buf.release();
            super.write(ctx, compressionBuf, promise);
        } else {
            super.write(ctx, msg, promise);
        }
    }

    private ByteBuf compress(ByteBuf buf) {
        //壓縮方法
    }
}

4. LengthFieldBasedFrameDecoder

LengthFieldBasedFrameDecoder是一個可以處理TCP粘包問題的解碼器，用於分割接收到的二進位數據。它可以從二進位數據流中讀取指定的長度欄位，並根據該長度欄位的值分割收到的數據。

public class LengthFieldBasedFrameDecoder extends ByteToMessageDecoder {
    private static final int DEFAULT_MAX_FRAME_SIZE = 1024 * 1024;

    private final ByteOrder byteOrder;
    private final int maxFrameLength;
    private final int lengthFieldOffset;
    private final int lengthFieldLength;
    private final int lengthAdjustment;
    private final int initialBytesToStrip;
    private final boolean failFast;

    public LengthFieldBasedFrameDecoder(int maxFrameLength, int lengthFieldOffset, int lengthFieldLength) {
        this(maxFrameLength, lengthFieldOffset, lengthFieldLength, 0, 0);
    }

    public LengthFieldBasedFrameDecoder(int maxFrameLength, int lengthFieldOffset, int lengthFieldLength, int lengthAdjustment, int initialBytesToStrip) {
        this(ByteOrder.BIG_ENDIAN, maxFrameLength, lengthFieldOffset, lengthFieldLength, lengthAdjustment, initialBytesToStrip, true);
    }

    public LengthFieldBasedFrameDecoder(ByteOrder byteOrder, int maxFrameLength, int lengthFieldOffset, int lengthFieldLength, int lengthAdjustment, int initialBytesToStrip, boolean failFast) {
        this.byteOrder = byteOrder;
        this.maxFrameLength = maxFrameLength;
        this.lengthFieldOffset = lengthFieldOffset;
        this.lengthFieldLength = lengthFieldLength;
        this.lengthAdjustment = lengthAdjustment;
        this.initialBytesToStrip = initialBytesToStrip;
        this.failFast = failFast;
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        if (msg instanceof ByteBuf) {
            ByteBuf buf = (ByteBuf) msg;
            try {
                List out = new ArrayList();
                while (buf.readableBytes() >= lengthFieldOffset + lengthFieldLength) {
                    //讀取length欄位值
                    int frameLength = getFrameLength(buf, buf.readerIndex() + lengthFieldOffset, lengthFieldLength, byteOrder);
                    if (frameLength  buf.readableBytes()) {
                        break;
                    }
                    //丟棄length欄位
                    if (initialBytesToStrip > frameLength) {
                        buf.skipBytes(lengthFieldOffset + lengthFieldLength + frameLength);
                        continue;
                    }
                    //根據讀取到的length值解碼數據
                    buf.skipBytes(lengthFieldOffset + lengthFieldLength + initialBytesToStrip);
                    int readerIndex = buf.readerIndex();
                    ByteBuf frame = buf.slice(readerIndex, frameLength - initialBytesToStrip);
                    try {
                        out.add(frame);
                    } finally {
                        buf.readerIndex(readerIndex + frameLength - initialBytesToStrip);
                    }
                }
                if (!out.isEmpty()) {
                    ctx.fireChannelRead(out);
                }
            } catch (DecoderException e) {
                throw e;
            } catch (Throwable t) {
                throw new DecoderException(t);
            } finally {
                buf.release();
            }
        } else {
            super.channelRead(ctx, msg);
        }
    }

    private static int getFrameLength(ByteBuf buf, int offset, int length, ByteOrder order) {
        //讀取length欄位值方法
    }
}

四、結語
NettyHandler是Netty框架中的一種非常重要的組件，其在網路編程中的作用不可忽視。本文分別介紹了NettyHandler的傳遞機制和與ChildHandler之間的聯繫，並給出了一些常見的NettyHandler的示例。在實際開發中，我們需要根據實際需要編寫自定義的NettyHandler，使得我們的網路應用程序更加靈活和高效。
原創文章，作者：小藍，如若轉載，請註明出處：https://www.506064.com/zh-tw/n/295263.html
 贊 (0)

 打賞 

微信掃一掃
微信掃一掃 

支付寶掃一掃
支付寶掃一掃 



小藍的頭像小藍  

 0   0





 上一篇
2024-12-26 17:15



下一篇 
2024-12-26 17:15
相關推薦
  • 

深入解析Vue3 defineExpose 
    Vue 3在開發過程中引入了新的API `defineExpose`。在以前的版本中，我們經常使用 `$attrs` 和` $listeners` 實現父組件與子組件之間的通信，但…
    

GUVNF的頭像  GUVNF

    
編程
2025-04-25
    

    • 

  • 

深入理解byte轉int 
    一、位元組與比特 在討論byte轉int之前，我們需要了解位元組和比特的概念。位元組是計算機存儲單位的一種，通常表示8個比特（bit），即1位元組=8比特。比特是計算機中最小的數據單位，是…
    

WLTFM的頭像  WLTFM

    
編程
2025-04-25
    

    • 

  • 

深入理解Flutter StreamBuilder 
    一、什麼是Flutter StreamBuilder? Flutter StreamBuilder是Flutter框架中的一個內置小部件，它可以監測數據流（Stream）中數據的變…
    

NQQNV的頭像  NQQNV

    
編程
2025-04-25
    

    • 

  • 

深入探討OpenCV版本 
    OpenCV是一個用於計算機視覺應用程序的開源庫。它是由英特爾公司創建的，現已由Willow Garage管理。OpenCV旨在提供一個易於使用的計算機視覺和機器學習基礎架構，以實…
    

GBIZB的頭像  GBIZB

    
編程
2025-04-25
    

    • 

  • 

深入了解scala-maven-plugin 
    一、簡介 Scala-maven-plugin 是一個創造和管理 Scala 項目的maven插件，它可以自動生成基本項目結構、依賴配置、Scala文件等。使用它可以使我們專註於代…
    

URASX的頭像  URASX

    
編程
2025-04-25
    

    • 

  • 

深入了解LaTeX的腳註（latexfootnote） 
    一、基本介紹 LaTeX作為一種排版軟體，具有各種各樣的功能，其中腳註（footnote）是一個十分重要的功能之一。在LaTeX中，腳註是用命令latexfootnote來實現的。…
    

TKHQU的頭像  TKHQU

    
編程
2025-04-25
    

    • 

  • 

深入理解Python字元串r 
    一、r字元串的基本概念 r字元串（raw字元串）是指在Python中，以字母r為前綴的字元串。r字元串中的反斜杠（\）不會被轉義，而是被當作普通字元處理，這使得r字元串可以非常方便…
    

IBWTF的頭像  IBWTF

    
編程
2025-04-25
    

    • 

  • 

深入探討馮諾依曼原理 
    一、原理概述 馮諾依曼原理，又稱「存儲程序控制原理」，是指計算機的程序和數據都存儲在同一個存儲器中，並且通過一個統一的匯流排來傳輸數據。這個原理的提出，是計算機科學發展中的重大進展，…
    

GPAIH的頭像  GPAIH

    
編程
2025-04-25
    

    • 

  • 

深入剖析MapStruct未生成實現類問題 
    一、MapStruct簡介 MapStruct是一個Java bean映射器，它通過註解和代碼生成來在Java bean之間轉換成本類代碼，實現類型安全，簡單而不失靈活。 作為一個…
    

NWCYY的頭像  NWCYY

    
編程
2025-04-25
    

    • 

  • 

深入了解Python包 
    一、包的概念 Python中一個程序就是一個模塊，而一個模塊可以引入另一個模塊，這樣就形成了包。包就是有多個模塊組成的一個大模塊，也可以看做是一個文件夾。包可以有效地組織代碼和數據…
    

JZJGQ的頭像  JZJGQ

    
編程
2025-04-25
    

發表回復 
登錄後才能評論