package cn.flightfeather.supervision.infrastructure.service;
|
|
import io.netty.channel.ChannelInitializer;
|
import io.netty.channel.ChannelPipeline;
|
import io.netty.channel.socket.SocketChannel;
|
import org.springframework.stereotype.Component;
|
|
// ChannelInitializer是默认的initializer，因此需要继承ChannelInitializer类来实现自己的initializer
|
@Component
|
public class MyChannelInitializer extends ChannelInitializer<SocketChannel> {
|
private static final int MAX_IDLE_SECONDS = 60;
|
|
@Override
|
protected void initChannel(SocketChannel socketChannel) throws Exception {
|
// 添加到pipeline中的handler会被串行处理(PS: 类似工业生产中的流水线)
|
ChannelPipeline pipeline = socketChannel.pipeline();
|
// pipeline.addLast("idleStateCheck", new IdleStateHandler(
|
// MAX_IDLE_SECONDS, MAX_IDLE_SECONDS, MAX_IDLE_SECONDS));
|
// 使用addLast来添加自己定义的handler到pipeline中
|
pipeline.addLast("myHandler", new EchoServerHandler());
|
}
|
}
|
