netty 客户端创建多个连接

那是不是我每一个连接都要实例化一个 EventLoopGroup，我觉的不是，EventLoopGroup 是线程池，假设你要连接 10000 个设备，每个连接一个线程都会直接崩掉（10000 个线程要耗费多少资源啊），别说每个连接一个 EventLoopGroup 了。

再说服务端我们有没有每一个连接都创建一个线程呢，没有。服务端一般都是两个线程池， 一个 boss 负责接收连接请求， 一个 work 负责 IO 读写。所以客户端多个连接也是要共用一个 EventLoopGroup 的。客户端不需要接收连接，所以只需要一个EventLoopGroup 就行了。多路复用器 selector 的使用，使得一个线程就可以轮询成千上万个连接。

参考我写的demo理解一下

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import java.util.concurrent.TimeUnit;
public class NettyClient {
    private Bootstrap b = new Bootstrap();
    private EventLoopGroup group;
    public NettyClient() {
        group = new NioEventLoopGroup();
        b.group(group)
                .channel(NioSocketChannel.class)
                .option(ChannelOption.TCP_NODELAY, true)
                .handler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    protected void initChannel(SocketChannel ch) throws Exception {
    public void connect(String host, int port) {
        System.out.println("11111111111 connect " + host + " " + Thread.currentThread());
        b.connect(host, port).addListener(new ChannelFutureListener() {
            @Override
            public void operationComplete(ChannelFuture future) throws Exception {
                 * 这里就不是主线程了，这里是 netty 线程中执行
                if (future.isSuccess()) {
                    System.out.println("2222222222222 connect success " + host + " " + Thread.currentThread());
                } else {
                    System.out.println("333333333333333 connect failed " + host + " " + Thread.currentThread());
                    // 连接不成功，5秒后重新连接
                    future.channel().eventLoop().schedule(new Runnable() {
                        @Override
                        public void run() {
                            System.out.println("4444444444444  reconnect " + host + " " + Thread.currentThread());
                            connect(host, port);
                    }, 5, TimeUnit.SECONDS);
    public void stop() {
        if (group != null) {
            group.shutdownGracefully();
            group = null;
    public static void main(String[] args) {
        String[] ips = new String[]{
                "192.168.1.100",
                "192.168.1.101",
                "192.168.1.102",
        NettyClient nettyClient = new NettyClient();
        for (int i = 0; i < ips.length; i++) {
            nettyClient.connect(ips[i], 4001);
        // 这里主线程提前退出了，但JVM进程没有退出
        System.out.println("main thread finish");
这里其实演示了首次连接连不上一直重连的场景，还有一种断线重连也很简单， 断线 channeInactivie 时再从新 connect 就行了。
注意 connect(host, port) 后面没有调用 sync 进行同步阻塞，而是注册异步监听器。如果调用 sync 会一直阻塞调用线程直到连接成功或失败。
测试中发现了一个问题， 我的主线程提前结束了，但进程并没有结束，只有把  netty 的线程池 shutdown 以后进程才会退出，这是为什么呢？？？？
因为 JVM 只有在所有非 Daemon 线程都结束时才会退出，由于 netty 的线程还在，所以主线程结束后 JVM 并未退出。