我只是想测试一下netty4支持的TCP持久连接的数量。当数量达到1337时，客户端出现如下新信息
java.lang.NullPointerException 在 sun.nio.ch.EPollArrayWrapper.setUpdateEvents(EPollArrayWrapper.java:178) 在 sun.nio.ch.EPollArrayWrapper.add(EPollArrayWrapper.java:227) 在 sun.nio.ch.EPollSelectorImpl.implRegister( EPollSelectorImpl.java:164) 在 sun.nio.ch.SelectorImpl.register(SelectorImpl.java:133) 在 java.nio.channels.spi.AbstractSelectableChannel.register(AbstractSelectableChannel.java:209) 在 io.netty.channel.nio .AbstractNioChannel.doRegister(AbstractNioChannel.java:285) at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:438) at io.netty.channel.AbstractChannel$AbstractUnsafe.access$100(AbstractChannel.java:373)在 io.netty.util.concurrent.SingleThreadEventExecutor 的 io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:417)。runAllTasks(SingleThreadEventExecutor.java:354) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:348) at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101) at java。 lang.Thread.run(Thread.java:724)
客户端代码是：
public class HSFTCPClient {
private final String host;
private final int port;
public HSFTCPClient(String host,int port){
this.host = host;
this.port = port;
}
public void run() throws Exception {
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
Bootstrap b = new Bootstrap();
b.group(workerGroup);
b.channel(NioSocketChannel.class);
//Note that we do not use childOption() here unlike we did with
// ServerBootstrap because the client-side SocketChannel does not have a parent.
b.option(ChannelOption.SO_KEEPALIVE, true);
b.handler(new HSFClientInitializer());
// Make a new connection.
ChannelFuture f = b.connect(host, port).sync();
Channel ch = f.channel();
} finally {
//workerGroup.shutdownGracefully();
}
}
/**
* @param args
*/
public static void main(String[] args) throws Exception {
String host = args[0];
int port = Integer.parseInt(args[1]);
int num = Integer.parseInt(args[2]);
for(int i=0;i<num;i++){
try {
new HSFTCPClient(host, port).run();
Thread.sleep(100);
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
HSFClientInitializer 是：
public class HSFClientInitializer extends ChannelInitializer<SocketChannel> {
@Override
protected void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline p = ch.pipeline();
p.addLast("frameDecoder", new ProtobufVarint32FrameDecoder());
p.addLast("protobufDecoder", new ProtobufDecoder(NetMessage.getDefaultInstance()));
p.addLast("frameEncoder", new ProtobufVarint32LengthFieldPrepender());
p.addLast("protobufEncoder", new ProtobufEncoder());
p.addLast("handler", new HSFTCPClientHandler());
}
}
HSFTCPClientHandler 是：
public class HSFTCPClientHandler extends SimpleChannelInboundHandler<NetMessage> {
@Override
protected void channelRead0(ChannelHandlerContext ctx, NetMessage msg)
throws Exception {
if(msg==null){
return;
}
int msgType = msg.getMessageType();
switch (msgType) {
case 200:
break;
}
}
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
Channel ch = ctx.channel();
ChannelFuture future= ctx.newSucceededFuture().addListener(new ClientConnectListener());
}
@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
ctx.fireChannelInactive();
ctx.disconnect().addListener(new ClientDisConnectListener());
}
}
ClientConnectListener 是：
public class ClientConnectListener implements ChannelFutureListener {
@Override
public void operationComplete(ChannelFuture future) throws Exception {
Channel ch= future.channel();
NetMessage.Builder msgBuilder = NetMessage.newBuilder();
msgBuilder.setMessageType(100);
System.out.println("-------client send netMsg ----------");
ch.writeAndFlush(msgBuilder.build());
}
}
ClientDisConnectListener 是：
public class ClientDisConnectListener implements ChannelFutureListener {
@Override
public void operationComplete(ChannelFuture future) throws Exception {
System.out.println("------- disconnect-----------");
}
}
客户端 jvm 参数：
/usr/java/jdk1.7.0_40/bin/java -Xms4G -Xmx4G -XX:NewSize=3584m -XX:PermSize=64m -XX:SurvivorRatio=1 -XX:+UseParallelGC -XX:-UseAdaptiveSizePolicy -classpath "./ bin:./lib/ " com.test.protobuf.client.HSFTCPClient 。. *.**(ip) 10007 10000
Linux 信息：任务：总计 374 个，正在运行 1 个，正在运行 373 个，已停止 0 个，0 个僵尸 Cpu0：0.3%us，0.7%sy，0.0%ni，99.0%id，0.0%wa，0.0%hi，0.0%si，0.0 %st Cpu1：0.3%us，0.0%sy，0.0%ni，99.7%id，0.0%wa，0.0%hi，0.0%si，0.0%st Cpu2：0.0%us，0.3%sy，0.0%ni，99.7 %id, 0.0%wa, 0.0%hi, 0.0%si, 0.0%st Cpu3: 0.0%us, 0.3%sy, 0.0%ni, 99.7%id, 0.0%wa, 0.0%hi, 0.0%si, 0.0% st Cpu4 : 0.0%us, 0.0%sy, 0.0%ni,100.0%id, 0.0%wa, 0.0%hi, 0.0%si, 0.0%st Cpu5 : 0.0%us, 0.0%sy, 0.0%ni,100.0% id, 0.0%wa, 0.0%hi, 0.0%si, 0.0%st Cpu6 : 0.0%us, 0.0%sy, 0.0%ni,100.0%id, 0.0%wa, 0.0%hi, 0.0%si, 0.0%st Cpu7 : 0.0%us, 0.0%sy, 0.0%ni,100.0%id, 0.0%wa, 0.0%hi, 0.0%si, 0.0%st Mem: 总共 32865072k, 2735996k, 30129076k free, 345764k buffers Swap: 总共 35110904k , 0k 已使用, 35110904k 免费,1362400k 缓存 jdk 版本：java 版本“1.7.0_40”Java(TM) SE 运行时环境（构建 1.7.0_40-b43）Java HotSpot(TM) 64 位服务器 VM（构建 24.0-b56，混合模式）
我该如何修复这个错误？并调整客户端代码？
我真的希望 Netty 可以在一台服务器上保持至少 50,000 个 TCP Connect。