1234567891011121314151617181920212223 |
- package cn.com.zyjblogs.chat.netty;
- import io.netty.channel.ChannelInitializer;
- import io.netty.channel.socket.SocketChannel;
- import org.springframework.stereotype.Service;
- /**
- * Socket 初始化器,每一个Channel进来都会调用这里的 InitChannel 方法
- * @author Gjing
- **/
- @Service
- public class SocketInitializer extends ChannelInitializer<SocketChannel> {
- @Override
- protected void initChannel(SocketChannel ch) {
- ch.pipeline()
- //解码器
- .addLast(new MyMessageDecoder())
- //编码器
- .addLast(new MyMessageEncoder())
- .addLast(new MyServerHandler());
- }
- }
|