Grizzly NIO框架 理论篇 【3】

Transport Configuration （Transport 的 配置）

我们先从一个简单的创建开始：

final TCPNIOTransportBuilder builder = TCPNIOTransportBuilder.newInstance();
final TCPNIOTransport transport = builder.build();

这样就创建了一个Transport，如果我们想建立服务端，接下来就是绑定端口和开启服务：

final TCPNIOTransportBuilder builder = TCPNIOTransportBuilder.newInstance();
final TCPNIOTransport transport = builder.build();
try {
     // Bind server socket and start transport
     transport.bind(12345);
     transport.start();

     System.out.println("Press <enter> to exit...");
     System.in.read();
} catch(Exception e){
     e.printStackTrace();
}

Systen.in.read()的作用还是不让Main线程结束，因为transport创建的Selector线程或者Worker都是虚拟线程（虚拟线程什么特点网上有资料）。

按如上所述就开启了端口为12345的一个服务端了。

如果我们需要创建客户端，那么可以通过transport建立到某个地址+端口的连接：

final TCPNIOTransportBuilder builder = TCPNIOTransportBuilder.newInstance();
final TCPNIOTransport transport = builder.build();
Future<Connection> fc = transport.connect("127.0.0.1", 12345);
Connection conn = fc.get();
conn.write(message);

其中message的格式根据自定义的Filter而变化，如果是底层的，message就是一个Buffer。

接下来还是主要看下我常用的配置：

builder.setIOStrategy(WorkerThreadIOStrategy.getInstance());
builder.setIOStrategy(SameThreadIOStrategy.getInstance());
builder.setIOStrategy(SimpleDynamicNIOStrategy.getInstance());
builder.setIOStrategy(LeaderFollowerNIOStrategy.getInstance());

FilterChainBuilder filterChainBuilder = FilterChainBuilder.stateless();
builder.setProcessor(filterChainBuilder.build());

其他属性都是用默认的，所以如果有了解可以查看官方英文的文档。

Thread Pool Configuration

好了，基本使用已经学会，那么我们看看几个参数的作用：

final TCPNIOTransportBuilder builder = TCPNIOTransportBuilder.newInstance();
final ThreadPoolConfig config = builder.getWorkerThreadPoolConfig();
config.setCorePoolSize(5).setMaxPoolSize(5).setQueueLimit(-1);
final TCPNIOTransport transport = builder.build();

来自为知笔记(Wiz)