Netty client 多路复用 连接池 |
您所在的位置：网站首页 › nio客户端建立连接 › Netty client 多路复用 连接池 |
|
有两种方式： 1）使用netty自带的 Netty自带连接池的使用/Users/joyce/work/jds/trade/trade-shenjinrong/jincePfyhServer com.jincetrade.pfyhserver.client.PfyhClientPool 2）自己for循环 教你正确地利用Netty建立连接池
演变： a） for ( bootstrap.group(eventLoopGroup).connect ) 问题很明显，如果每一个channel都对应一个NIOEventLoopGroup，那么我们实际上构建了一个connection:thread = 1:1的模型，随着连接数不断地扩大，线程膨胀的问题就会突显出来。 而nio本身是一个线程处理所有连接 b） bootstrap.group(eventLoopGroup) for( bootstrap.connect )
本文在2.b方式上结合apache common pool 2 实现 package com.jds.test.proto; /** * Created by sunyuming on 19/8/13. */ import java.net.InetSocketAddress; import java.util.ArrayList; import java.util.Date; import java.util.List; 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 io.netty.handler.codec.LengthFieldBasedFrameDecoder; import io.netty.handler.codec.LengthFieldPrepender; import io.netty.handler.codec.protobuf.ProtobufDecoder; import io.netty.handler.codec.protobuf.ProtobufEncoder; import io.netty.handler.timeout.IdleStateHandler; import io.netty.util.concurrent.Future; import io.netty.util.concurrent.GenericFutureListener; import org.apache.commons.pool2.BasePooledObjectFactory; import org.apache.commons.pool2.PooledObject; import org.apache.commons.pool2.impl.DefaultPooledObject; import org.apache.commons.pool2.impl.GenericObjectPool; import org.apache.commons.pool2.impl.GenericObjectPoolConfig; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; /** * * EWrapper连接池工厂 * @author shane * */ public class ClientPool extends BasePooledObjectFactory{ private String ip; private int port; public ClientPool() { ip = "127.0.0.1"; port = 8866; } public static void main(String[] args) throws Exception { GenericObjectPoolConfig config = new GenericObjectPoolConfig(); config.setMaxWaitMillis(2000); config.setMinIdle(3); config.setMaxIdle(5); config.setMaxTotal(5); /** * 销毁到minidle */ config.setSoftMinEvictableIdleTimeMillis(10000); config.setTestOnBorrow(true); /** * 销毁所有 */ // config.setMinEvictableIdleTimeMillis(3000); // 词句是必须的，否则（Soft）MinEvictableIdleTimeMillis不生效 config.setTimeBetweenEvictionRunsMillis(100); GenericObjectPool objectPool = new GenericObjectPool(new ClientPool(), config); // 先睡5s让系统补足3个对象 Thread.sleep(5000); List list = new ArrayList(); for(int i=0; i |
今日新闻 |
推荐新闻 |
| CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |