Netty中ChannelInboundHandlerAdapter的生命周期

1.channelRegistered

channel注册事件

	@Override
	public void channelRegistered(ChannelHandlerContext ctx) throws Exception {
		System.out.println("channel注册了");
		super.channelRegistered(ctx);
	}

2.channelUnregistered

channel取消注册事件

@Override
	public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
		System.out.println("channel移除了");
		super.channelUnregistered(ctx);
	}

3.channelActive

channel是否是活跃

@Override
	public void channelActive(ChannelHandlerContext ctx) throws Exception {
		System.out.println("channel 活跃");
		super.channelActive(ctx);
	}

4.channelInactive

channel不活跃

@Override
	public void channelInactive(ChannelHandlerContext ctx) throws Exception {
		System.out.println("channel 不活跃,断开连接");
		super.channelInactive(ctx);
	}

5.channelReadComplete

channel读取完毕事件

@Override
	public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
		System.out.println("channel 读取完毕");
		super.channelReadComplete(ctx);
	}

6.userEventTriggered

channel 用户事件触发

@Override
	public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
		System.out.println("channel 用户事件触发");
		super.userEventTriggered(ctx, evt);
	}

7.channelWritabilityChanged

channel 可写更改

@Override
	public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
		System.out.println("channel 可写更改");
		super.channelWritabilityChanged(ctx);
	}

8.exceptionCaught

channel 捕获到异常

@Override
	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
		System.out.println("channel 捕获到异常了,关闭了");
		super.exceptionCaught(ctx, cause);
	}

9.handlerAdded

channel 助手类(拦截器)的添加

@Override
	public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
		System.out.println("channel 助手类添加");
		super.handlerAdded(ctx);
	}

10.handlerRemoved

channel 助手类(拦截器)移除

@Override
	public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
		System.out.println("channel 助手类移除");
		super.handlerRemoved(ctx);
	}

11.channelRead

channel读取数据

System.out.println("Server: " + obj);
		String msg = (String) obj;
		String result = "";
		if(!StringUtil.isEmpty(msg)){
			String commandType = msg.substring(10,12);
			AbstractExecutor executor = SpringBeanUtil.executor(commandType);
			if(executor == null){
				result = "0000";
			}else{
				boolean crc16Val = executor.valiCRC16(msg);
				if(crc16Val){
					executor.tcpExecutor(msg);
					String content = executor.downCommand(msg);
					System.out.println("发送:"+content);
					result = content;
				}else{
					result = "0000";
				}
			}
		}
		result = "0000";
		byte[] bytes =  StringUtil.hexStrToBinaryStr((String) result);
		ctx.writeAndFlush(Unpooled.copiedBuffer(bytes));

12.执行顺序

在这里插入图片描述

发布了60 篇原创文章 · 获赞 1 · 访问量 3344

猜你喜欢

转载自blog.csdn.net/qq_16438883/article/details/103456346