package com.ard.utils.netty.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<SocketChannel> {
|
@Override
|
protected void initChannel(SocketChannel ch){
|
try {
|
ChannelPipeline pipeline = ch.pipeline();
|
// 添加你需要的处理器
|
pipeline.addLast(new DynamicClientHandler());
|
}catch (Exception e)
|
{
|
e.printStackTrace();
|
}
|
}
|
}
|
