/**
  * 初始化EventPool 参数
*/
 private void initEventPool() {
        bossGroup = new NioEventLoopGroup(serverConfig.getBossThread(), new ThreadFactory() {
            private AtomicInteger index = new AtomicInteger(0);

            @Override
            public Thread newThread(Runnable r) {
                return new Thread(r, "Janus_Boss_" + index.incrementAndGet());
            }
        });
        workGroup = new NioEventLoopGroup(serverConfig.getWorkThread(), new ThreadFactory() {
            private AtomicInteger index = new AtomicInteger(0);

            @Override
            public Thread newThread(Runnable r) {
                return new Thread(r, "Janus_Work_" + index.incrementAndGet());
            }
        });

 }

 /**
     * 服务开启
     */
 public void start(int port) {
     //TODO 上生产时去掉
     ResourceLeakDetector.setLevel(ResourceLeakDetector.Level.ADVANCED);
     initEventPool();
     ServerBootstrap bootstrap = new ServerBootstrap();
     //绑定线程池
     bootstrap.group(bossGroup, workGroup)
                .channel(NioServerSocketChannel.class) //指定使用的channel
                .option(ChannelOption.SO_REUSEADDR, serverConfig.isReUseAddr())
                .option(ChannelOption.SO_BACKLOG, serverConfig.getBackLog())
                .childOption(ChannelOption.SO_RCVBUF, serverConfig.getRevBuf())
                .childOption(ChannelOption.SO_SNDBUF, serverConfig.getSndBuf())
                .childOption(ChannelOption.TCP_NODELAY, serverConfig.isTcpNoDelay())
                .childOption(ChannelOption.SO_KEEPALIVE, serverConfig.isKeepalive())
                .childHandler(initChildHandler());

      bootstrap.bind(port).addListener((ChannelFutureListener) channelFuture -> {
            if (channelFuture.isSuccess()) {
                changeOnLine(true);
                log.info("服务端启动成功【" + IpUtils.getHost() + ":" + port + "】");
            } else {
                log.error("服务端启动失败【" + IpUtils.getHost() + ":" + port + "】,cause:"
                        + channelFuture.cause().getMessage());
                shutdown(port);
            }
        });
  }

@SuppressWarnings("rawtypes")
private ChannelInitializer initChildHandler() {
return new ChannelInitializer<SocketChannel>() {
final ThreadPoolExecutor serverHandlerPool = ThreadPoolUtils.makeServerThreadPool(NettyServer.class.getSimpleName());
//网关Server的Http请求入口Handler
final NettyServerHandler nettyServerHandler = new NettyServerHandler(serverHandlerPool);

            @Override
            protected void initChannel(SocketChannel ch) throws Exception {
                //initHandler(ch.pipeline(), serverConfig);
                ch.pipeline().addLast(new IdleStateHandler(180, 0, 0));
                ch.pipeline().addLast("logging", new LoggingHandler(LogLevel.DEBUG));
                // We want to allow longer request lines, headers, and chunks
                // respectively.
                ch.pipeline().addLast("decoder", new HttpRequestDecoder(
                        serverConfig.getMaxInitialLineLength(),
                        serverConfig.getMaxHeaderSize(),
                        serverConfig.getMaxChunkSize()));
                //ch.pipeline().addLast("inflater", new HttpContentDecompressor());
                ch.pipeline().addLast("aggregator", new HttpObjectAggregator(serverConfig.getMaxHttpLength()));
                //响应解码器
                ch.pipeline().addLast("http-encoder", new HttpResponseEncoder());
                //目的是支持异步大文件传输（）
                ch.pipeline().addLast("http-chunked", new ChunkedWriteHandler());
                //网关Server的Netty HTTP连接处理类
                ch.pipeline().addLast("process", nettyServerHandler);
            }
        };
    }

@Slf4j
public class NettyConnectClient extends ConnectClient {

    public  NioEventLoopGroup clientGroup = new NioEventLoopGroup(0,
            new DefaultThreadFactory("Janus-client-Worker", true));

    private Channel channel;

    @Override
    public void init(String address) throws Exception {

        Object[] array = IpUtils.parseIpPort(address);
        String host = (String) array[0];
        int port = (int) array[1];

        Bootstrap bootstrap = new Bootstrap();
        bootstrap.group(clientGroup)
                .channel(NioSocketChannel.class)
                .handler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    public void initChannel(SocketChannel channel) throws Exception {
                        channel.pipeline()
                                .addLast(new IdleStateHandler(0, 0, 60, TimeUnit.SECONDS))
//                                .addLast(new HttpClientCodec())
//                                .addLast(new HttpObjectAggregator(65536))
                                //解压
                                //.addLast(new HttpContentDecompressor())
                                .addLast(new HttpClientCodec(NettyConstants.MAX_INITIAL_LINE_LENGTH,NettyConstants.MAX_HEADER_SIZE, NettyConstants.MAX_CHUNK_SIZE),
                                new HttpObjectAggregator(NettyConstants.MAX_RESPONSE_SIZE))
                                //Netty Client把请求转发给内网源服务的Handler
                                .addLast("handler", new NettyClientHandler());
                    }
                })
                .option(ChannelOption.TCP_NODELAY, true)
                .option(ChannelOption.SO_KEEPALIVE, true)
                .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 60*1000);
        this.channel = bootstrap.connect(host, port).sync().channel();
        // valid
        if (!isValidate()) {
            close();
            return;
        }

        log.debug("netty client proxy, connect to server success at host:{}, port:{}", host, port);
    }
}

static {
    DEFAULT_EVENT_LOOP_THREADS = Math.max(1, SystemPropertyUtil.getInt(
                "io.netty.eventLoopThreads", NettyRuntime.availableProcessors() * 2));

    if (logger.isDebugEnabled()) {
            logger.debug("-Dio.netty.eventLoopThreads: {}", DEFAULT_EVENT_LOOP_THREADS);
        }
}

/**
* @see MultithreadEventExecutorGroup#MultithreadEventExecutorGroup(int, ThreadFactory, Object...)
*/
protected MultithreadEventLoopGroup(int nThreads, ThreadFactory threadFactory, Object... args) {
super(nThreads == 0 ? DEFAULT_EVENT_LOOP_THREADS : nThreads, threadFactory, args);
}

- id: 7 #根据配置的多个Hosts不通过注册中心进行LB  #http://localhost:8081/admin7/menu/manage/allMenu2
    filters:
      - name: PathMapping
        args:
          /admin7/menu/manage/allMenu2: "/admin/menu/manage/allMenu"
    protocol: lb://hosts
    hosts:
      - 127.0.0.1:8084
      - admin.qingcloud.net:80
    predicates: # and ; if need or add a new route
      - name: PathPrecise
        args:
          paths: /admin7/menu/manage/allMenu2