package com.ard.utils.tcp; import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelPipeline; import io.netty.channel.socket.SocketChannel; /** * @Description: 初始化客户端的通道(备用) * @ClassName: DynamicClientInitializer * @Author: 刘苏义 * @Date: 2023年11月30日9:27:03 **/ public class DynamicClientInitializer extends ChannelInitializer { @Override protected void initChannel(SocketChannel ch){ try { ChannelPipeline pipeline = ch.pipeline(); // 添加你需要的处理器 pipeline.addLast(new DynamicClientHandler()); }catch (Exception e) { e.printStackTrace(); } } }