Netty (2)-ChannelInboundHandlerAdapter入站事件

最新推荐文章于 2025-03-18 16:43:27 发布

free_java

最新推荐文章于 2025-03-18 16:43:27 发布

阅读量5k

点赞数 3

分类专栏： netty 文章标签： ChannelInboundHandlerAdapter netty 生命周期事件 ChannelHandler

本文链接：https://blog.csdn.net/wangb_java/article/details/103897526

版权

netty 专栏收录该内容

10 篇文章

订阅专栏

本文详细介绍了Netty中ChannelInboundHandlerAdapter的使用方法及事件处理流程，包括注册、激活、读取消息、异常处理等核心事件的触发与响应机制。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

在第1篇，我们继承ChannelInboundHandlerAdapter后，即可收到消息并处理。本篇介绍其更多的用法

基本概念

Channel：可以理解为一个连接，每一个客户端连到服务器，都会有一个与之对应的Channel。
ChannelHandler：用来处理Channel中的各种事件。
ChannelInboundHandlerAdapter：入站ChannelHandler，即从客户端进入服务器的各种事件。
ChannelHandlerContext：每个处理事件的方法都有这个参数，可用于执行与当前Channel相关的各种操作。

捕获ChannelInboundHandlerAdapter事件

public class EchoServerHandler extends ChannelInboundHandlerAdapter{
    public void channelRegistered(ChannelHandlerContext ctx) {
        System.out.println("注册");
    }
    public void channelActive(ChannelHandlerContext ctx) {
    	System.out.println("激活");
    }
    public void channelInactive(ChannelHandlerContext ctx) {
    	System.out.println("断开");
    }
    public void channelUnregistered(ChannelHandlerContext ctx) {
    	System.out.println("注销");
    }
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
    	System.out.println("读取消息");
    }
    public void channelReadComplete(ChannelHandlerContext ctx)  {
    	System.out.println("消息读取完成");
    }
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) {
    	System.out.println("用户事件");
    }
    public void channelWritabilityChanged(ChannelHandlerContext ctx){
    	System.out.println("可写状态变更为"+ctx.channel().isWritable());
    }
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
    	System.out.println("发生异常");
    }

入站事件介绍

注册和激活：当客户端连接时，首先会触发注册，进行一些初始化的工作，然后激活连接，就可以收发消息了。
断开和注销：当客户端断开时，反向操作，先断开，再注销。
读取消息：当收到客户端消息时，首先读取，然后触发读取完成。
发生异常：不多解释了。
用户事件：由用户触发的各种非常规事件，根据evt的类型来判断不同的事件类型，从而进行不同的处理。
可写状态变更：收到消息后，要回复消息，会先把回复内容写到缓冲区。而缓冲区大小是有一定限制的，当达到上限以后，可写状态就会变为否，不能再写。等缓冲区的内容被冲刷掉后，缓冲区又有了空间，可写状态又会变为是。