基于Netty实现简易高并发IM

spring_cloud

netty服务public class NettyServer {

    private static final Logger log = LoggerFactory.getLogger(NettyServer.class);

    private static class SingletionWSServer {
        static final NettyServer instance = new NettyServer();
    }

    public static NettyServer getInstance() {
        return SingletionWSServer.instance;
    }

    private EventLoopGroup mainGroup;
    private EventLoopGroup subGroup;
    private ServerBootstrap server;
    private ChannelFuture future;

    public NettyServer() {
        mainGroup = new NioEventLoopGroup();
        subGroup = new NioEventLoopGroup();
        server = new ServerBootstrap();
        server.group(mainGroup, subGroup)
                .channel(NioServerSocketChannel.class)
                .childHandler(new NettyChannelInitializer());
    }

    public void start(int port) {
        this.future = server.bind(port);
        log.info("netty server start success");
    }

}管道初始化public class NettyChannelInitializer extends ChannelInitializer<SocketChannel>{

   private static final Logger log = LoggerFactory.getLogger(NettyChannelInitializer.class);
   
   @Override
   protected void initChannel(SocketChannel ch) throws Exception {
      log.info(" init  channel ....");
      ChannelPipeline pipeline = ch.pipeline();
      // websocket 基于http协议，所以要有http编解码器
      pipeline.addLast("HttpServerCodec",new HttpServerCodec());
         
      // 对写大数据流的支持   
      pipeline.addLast(new ChunkedWriteHandler());
      
      // 对httpMessage进行聚合，聚合成FullHttpRequest或FullHttpResponse
      // 几乎在netty中的编程，都会使用到此hanler
      pipeline.addLast(new HttpObjectAggregator(1024*64));
      
      
      // 增加心跳支持 start
      // 针对客户端，如果在1分钟时没有向服务端发送读写心跳(ALL)，则主动断开
      // 如果是读空闲或者写空闲，不处理
      pipeline.addLast(new IdleStateHandler(8, 10, 12));
      // 自定义的空闲状态检测
      pipeline.addLast(new NettyWsChannelInboundHandler());
      
      // 以下是支持httpWebsocket
      /**
       * websocket 服务器处理的协议，用于指定给客户端连接访问的路由 : /ws
       * 本handler会帮你处理一些繁重的复杂的事
       * 会帮你处理握手动作： handshaking（close, ping, pong） ping + pong = 心跳
       * 对于websocket来讲，都是以frames进行传输的，不同的数据类型对应的frames也不同
       */
      pipeline.addLast(new WebSocketServerProtocolHandler("/ws"));
         
      // 自定义的wshandler
      pipeline.addLast(new NettyWsChannelInboundHandler());
         
      // 自定义 http
      pipeline.addLast(new NettyHttpChannelInboundHandler());
   }

}未完待续....

alan3258

这是实例还是真正支持高并发？没看到高并发的地方啊。

52changew

了解下; 或许会用; 谢谢分享!!