投稿
  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/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
    

发表回复 
登录后才能评论