码迷,mamicode.com
首页 > 其他好文 > 详细

Grizzly NIO框架 理论篇 【3】

时间:2014-08-30 13:50:29      阅读:174      评论:0      收藏:0      [点我收藏+]

标签:style   http   color   os   使用   io   java   ar   for   

Transport Configuration (Transport 的 配置)

我们先从一个简单的创建开始:
  1. final TCPNIOTransportBuilder builder = TCPNIOTransportBuilder.newInstance();
  2. final TCPNIOTransport transport = builder.build();
这样就创建了一个Transport,如果我们想建立服务端,接下来就是绑定端口和开启服务:
  1. final TCPNIOTransportBuilder builder = TCPNIOTransportBuilder.newInstance();
  2. final TCPNIOTransport transport = builder.build();
  3. try {
  4. // Bind server socket and start transport
  5. transport.bind(12345);
  6. transport.start();
  7. System.out.println("Press <enter> to exit...");
  8. System.in.read();
  9. } catch(Exception e){
  10. e.printStackTrace();
  11. }
Systen.in.read()的作用还是不让Main线程结束,因为transport创建的Selector线程或者Worker都是虚拟线程(虚拟线程什么特点网上有资料)。
按如上所述就开启了端口为12345的一个服务端了。

如果我们需要创建客户端,那么可以通过transport建立到某个地址+端口的连接:
  1. final TCPNIOTransportBuilder builder = TCPNIOTransportBuilder.newInstance();
  2. final TCPNIOTransport transport = builder.build();
  3. Future<Connection> fc = transport.connect("127.0.0.1", 12345);
  4. Connection conn = fc.get();
  5. conn.write(message);
其中message的格式根据自定义的Filter而变化,如果是底层的,message就是一个Buffer。
接下来还是主要看下我常用的配置:
IOStrategy
这个之前有讲解基本有如下几个:
  1. builder.setIOStrategy(WorkerThreadIOStrategy.getInstance());
  2. builder.setIOStrategy(SameThreadIOStrategy.getInstance());
  3. builder.setIOStrategy(SimpleDynamicNIOStrategy.getInstance());
  4. builder.setIOStrategy(LeaderFollowerNIOStrategy.getInstance());
memoryManager
这个就是内存管理器:有Heap和ByteBuffer两种。
processor
  1. FilterChainBuilder filterChainBuilder = FilterChainBuilder.stateless();
  2. builder.setProcessor(filterChainBuilder.build());
这个一般设置FilterChain,我们可以在FilterChain里面添加自己的滤镜,用于处理消息
readBufferSize读数据流的分配内存大小
writeBuffersSize写数据流的内存分配大小,一般可以根据工程而配置。
 
其他属性都是用默认的,所以如果有了解可以查看官方英文的文档。

Thread Pool Configuration

好了,基本使用已经学会,那么我们看看几个参数的作用:
  1. final TCPNIOTransportBuilder builder = TCPNIOTransportBuilder.newInstance();
  2. final ThreadPoolConfig config = builder.getWorkerThreadPoolConfig();
  3. config.setCorePoolSize(5).setMaxPoolSize(5).setQueueLimit(-1);
  4. final TCPNIOTransport transport = builder.build();
queue任务队列
queueLimit队列最大容纳的数量
threadFactory线程工厂,用于创建Worker线程或其他线程。。。
poolName线程池的名称
priorityThe priority to be assigned to each thread. This will override any priority assigned by the specified ThreadFactory.
corePoolSize初始线程数
maxPoolSize最大线程数,-1表示无限大
keepAliveTimeThe maximum time a thread may stay idle and wait for a new task to execute before it will be released. Custom time units can be used.
transactionTimeoutThe maximum time a thread may be allowed to run a single task before interrupt signal will be sent. Custom time units can be used.





Grizzly NIO框架 理论篇 【3】

标签:style   http   color   os   使用   io   java   ar   for   

原文地址:http://www.cnblogs.com/chzcb/p/3946346.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!