SocketInitializer.java 673 B

1234567891011121314151617181920212223
  1. package cn.com.zyjblogs.chat.netty;
  2. import io.netty.channel.ChannelInitializer;
  3. import io.netty.channel.socket.SocketChannel;
  4. import org.springframework.stereotype.Service;
  5. /**
  6. * Socket 初始化器,每一个Channel进来都会调用这里的 InitChannel 方法
  7. * @author Gjing
  8. **/
  9. @Service
  10. public class SocketInitializer extends ChannelInitializer<SocketChannel> {
  11. @Override
  12. protected void initChannel(SocketChannel ch) {
  13. ch.pipeline()
  14. //解码器
  15. .addLast(new MyMessageDecoder())
  16. //编码器
  17. .addLast(new MyMessageEncoder())
  18. .addLast(new MyServerHandler());
  19. }
  20. }