netty 5.0で多数の接続を作成する方法

Question

テスト目的でサーバーに多数のクライアント接続を作成したいと考えています。私は接続ごとにスレッドを作成することでこれを達成するので、私は自分のマシンで3000接続しか作成できません。以下は私のコードです：

package com.stepnetwork.iot.apsclient.application; 

import io.netty.bootstrap.Bootstrap; 
import io.netty.buffer.ByteBuf; 
import io.netty.buffer.Unpooled; 
import io.netty.channel.*; 
import io.netty.channel.socket.SocketChannel; 
import io.netty.channel.socket.nio.NioSocketChannel; 

/** 
* Created by sam on 3/22/16. 
*/ 
public class DtuClient extends Thread { 

    private static final String HOST = "192.168.54.36"; 
    private static final int PORT = 30080; 
    private EventLoopGroup workerGroup; 

    private String dtuCode; 

    public DtuClient(String dtuCode, EventLoopGroup workerGroup) { 
     this.dtuCode = dtuCode; 
     this.workerGroup = workerGroup; 
    } 

    public void run() { 

     Bootstrap bootstrap = new Bootstrap(); // (1) 
     try { 
      bootstrap.group(workerGroup); // (2) 
      bootstrap.channel(NioSocketChannel.class); // (3) 
      bootstrap.option(ChannelOption.SO_KEEPALIVE, true); // (4) 
      bootstrap.handler(new ChannelInitializer<SocketChannel>() { 
       @Override 
       public void initChannel(SocketChannel ch) throws Exception { 
        ch.pipeline().addLast(new MyClientHandler()); 
       } 
      }); 


      ChannelFuture feature = bootstrap.connect(HOST, PORT).sync(); 
      feature.addListener((future) -> { 
       System.out.println(dtuCode + " connected to server"); 
       Channel channel = feature.channel(); 
       ByteBuf buffer = Unpooled.buffer(256); 
       buffer.writeBytes(dtuCode.getBytes()); 
       channel.writeAndFlush(buffer); 
      }); 

      feature.channel().closeFuture().sync(); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 

     System.out.println("completed"); 
    } 
} 

もっと接続できますか？

私はGoogleの調査を行った後に別の解決策を試しましたが、チャンネルは自動的に閉じます。

Answer 1

ここに私の別の解決策

package com.stepnetwork.iot.apsclient.application; 

import io.netty.bootstrap.Bootstrap; 
import io.netty.channel.Channel; 
import io.netty.channel.ChannelInitializer; 
import io.netty.channel.ChannelOption; 
import io.netty.channel.EventLoopGroup; 
import io.netty.channel.nio.NioEventLoopGroup; 
import io.netty.channel.socket.SocketChannel; 
import io.netty.channel.socket.nio.NioSocketChannel; 

import java.util.ArrayList; 
import java.util.List; 

/** 
* Created by sam on 3/22/16. 
*/ 
public class Test { 

    private static final String HOST = "192.168.54.36"; 
    private static final int PORT = 30080; 

    public static void main(String[] args) throws InterruptedException { 
     EventLoopGroup workerGroup = new NioEventLoopGroup(); 

     Bootstrap bootstrap = new Bootstrap(); // (1) 
     try { 
      bootstrap.group(workerGroup); // (2) 
      bootstrap.channel(NioSocketChannel.class); // (3) 
      bootstrap.option(ChannelOption.SO_KEEPALIVE, true); // (4) 
      bootstrap.handler(new ChannelInitializer<SocketChannel>() { 
       @Override 
       public void initChannel(SocketChannel ch) throws Exception { 
        ch.pipeline().addLast(new MyClientHandler()); 
       } 
      }); 


      List<Channel> channels = new ArrayList<>(); 

      // create many connection here, but the channel will be closed atomically 
      for (int i = 0; i < 10000; i++) { 
       channels.add(bootstrap.connect(HOST, PORT).sync().channel()); 
      } 


     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 

     while (true) { 
      Thread.sleep(Integer.MAX_VALUE); 
     } 
    } 

}