基于netty实现一个简单的支持http和webSocket协议的的服务器（含xxl-job通信模块源码分析）

• • 背景
  • 依赖
  • 包结构
  • 实现 WebSocketServer
  • 业务handler WebSocketServerHandler
  • 测试
  • xxl-job 源码中基于netty实现的http
  • 总结
  • 参考
  • 源码

上次看了下xxl-job，发现他的通信机制就是自己基于Netty实现了一个http服务器，然后发现自己看的不是很懂，就打算自己来实现一个简单的支持http协议和webSocket协议的服务器来帮助自己理解

		
            com.alibaba
            fastjson
            1.2.62
        
        
            cn.hutool
            hutool-all
            5.7.13
        
        
            io.netty
            netty-all
            5.0.0.Alpha1
        

主要这里我的netty版本用的5.x,推荐使用4.x版本的netty，因为netty 5.x好像是被netty作者废弃掉了。5.x版本和4.x版本部分api可能不同

• WebSocketServer.java

@Slf4j
public class WebSocketServer {

    // /Users/weihu/Desktop/sofe/java/netty-student/netty-websocket/src/main/resources/WebSocketServer.html
    public static void main(String[] args) throws Exception{
        int port = args.length > 0 ? Integer.parseInt(args[0]) : 8080;
        new WebSocketServer().run(port);
    }

    public void run(int port) throws Exception{
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workGroup = new NioEventLoopGroup();

        try {
            ServerBootstrap bootstrap = new ServerBootstrap();
            bootstrap.group(bossGroup, workGroup)
                    .channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer() {
                        @Override
                        protected void initChannel(SocketChannel ch) throws Exception {
                            ChannelPipeline pipeline = ch.pipeline();
                            pipeline.addLast("http-codec", new HttpServerCodec()) // http 编解码处理器
                                    // http多个消息部分组合成一条完整http消息
                                    .addLast("aggregator", new HttpObjectAggregator(65536))
                                    // 支持向客户端发送html5消息，主要用于支持浏览器和服务端进行websocket 通信，如果仅是http服务不需要该处理器
                                    .addLast("http-chunked", new ChunkedWriteHandler())
                                    // 核心业务逻辑处理器
                                    .addLast("handler", new WebSocketServerHandler());
                        }
                    });
            Channel channel = bootstrap.bind(port).sync().channel();
            log.info("Web socket or http server started at port: {}", port);
            log.info("open your browser and navigate to http://localhost:{}/",port);
            channel.closeFuture().sync();
        } finally {
            bossGroup.shutdownGracefully();
            workGroup.shutdownGracefully();
        }
    }

}

这里的代码其实就是固定的一套模板，当然如果是要优化一些网络相关的参数另说，可以看到接收和处理，核心业务逻辑都在WebSocketServerHandler这个类中

• WebSocketServerHandler.java

@Slf4j
public class WebSocketServerHandler extends SimpleChannelInboundHandler