netty 抽象BootStrap定义：[url]http://donald-draper.iteye.com/blog/2392492[/url]
<br>netty ServerBootStrap解析：[url]http://donald-draper.iteye.com/blog/2392572[/url]
<br>netty Bootstrap解析：[url]http://donald-draper.iteye.com/blog/2392593[/url]
<br>netty 通道接口定义:[url]http://donald-draper.iteye.com/blog/2392740[/url]
<br>netty 抽象通道初始化：[url]http://donald-draper.iteye.com/blog/2392801[/url]
<br>netty 抽象Unsafe定义：[url]http://donald-draper.iteye.com/blog/2393053[/url]
<br>netty 通道Outbound缓冲区：[url]http://donald-draper.iteye.com/blog/2393098[/url]
<br>netty 抽象通道后续：[url]http://donald-draper.iteye.com/blog/2393166[/url]
<br>netty 抽象nio通道：[url]http://donald-draper.iteye.com/blog/2393269[/url]
<br>netty 抽象nio字节通道：[url]http://donald-draper.iteye.com/blog/2393323[/url]
<br>netty 抽象nio消息通道：[url]http://donald-draper.iteye.com/blog/2393364[/url]
<br>netty NioServerSocketChannel解析：[url]http://donald-draper.iteye.com/blog/2393443[/url]
<br>netty 通道配置接口定义：[url]http://donald-draper.iteye.com/blog/2393484[/url]
<br>netty 默认通道配置初始化：[url]http://donald-draper.iteye.com/blog/2393504[/url]
<br>netty 默认通道配置后续：[url]http://donald-draper.iteye.com/blog/2393510[/url]
<br>netty 字节buf定义：[url]http://donald-draper.iteye.com/blog/2393813[/url]
<br>netty 资源泄漏探测器：[url]http://donald-draper.iteye.com/blog/2393940[/url]
<br>netty 抽象字节buf解析：[url]http://donald-draper.iteye.com/blog/2394078[/url]
<br>netty 抽象字节buf引用计数器：[url]http://donald-draper.iteye.com/blog/2394109[/url]
<br>netty 复合buf概念：[url]http://donald-draper.iteye.com/blog/2394408[/url]
<br>netty 抽象字节buf分配器：[url]http://donald-draper.iteye.com/blog/2394419[/url]
<br>netty Unpooled字节buf分配器：[url]http://donald-draper.iteye.com/blog/2394619[/url]
<br>netty Pooled字节buf分配器：[url]http://donald-draper.iteye.com/blog/2394814[/url]
<br>[size=medium][b]引言：[/b][/size]
<br>上一篇文章我们看了Pooled字节buf分配器，先来回顾一下：
<br> Pooled字节buf分配器，内部有一个堆buf和direct buf分配Region区（PoolArena），每个Region的内存块（PoolChunk）size为chunkSize，每个内存块内存页（PoolSubpage）大小，默认为8k。Pooled 堆buf是基于字节数组，而direct buf是基于nio 字节buf。Pooled字节分配器分配heap和direct buf时，首先获取线程本地buf缓存PoolThreadCache，从buf获取对应的heap或direct分配区，分配区创建buf（PooledByteBuf），然后将buf放到内存块中管理，根据buf的容量，将放到相应tiny，small，normal Memory Region Cache（MemoryRegionCache）中。每个Pooled buf通过内存的Recycler，重用buf。Pool字节buf内部有一个回收器Recycler，管理字节buf，而回收器内部是将对象放在一个线程本地栈中管理。
<br>从看了ServerSocket通道之后，我们把字节buf（heap，direct），及字节buf分配器（Unpooled，Pooled）,
<br>今天我们回到Socket通道，由于socket通道我们讲了好久，先来把Nio socket通道的父类抽象字节通道回顾一下：
<br> 写通道Outbound缓冲区，即遍历刷新链上的写请求，如果写请求消息为字节buf，则调用doWriteBytes完成实际数据发送操作，待子类扩展，如果写请求消息为文件Region，调用doWriteFileRegion完成实际数据发送操作，待子类扩展，数据发送，则更新通道的数据发送进度，并从刷新链上移除写请求；如果所有写请求发送完毕，则重新添加写操作事件到选择key兴趣事件集，否则继续刷新通道Outbound缓冲区中的写请求。
<br> nio字节Unsafe读操作，从通道接收缓冲区读取数据，通知通道处理读取数据,触发Channel管道线的fireChannelRead事件，待数据读取完毕，触发Channel管道线的fireChannelReadComplete事件，如果在读数据的过程中，通道关闭，则触发通道输入关闭事件（fireUserEventTriggered），如果在读数据的过程中，发生异常，则读取缓存区中没有读完的数据，并通道通道处理剩余数据。
<br>
<br>现在来看socket通道：
<br>
<pre class="blockcode"><code class="language-java">/**<br> * {@link io.netty.channel.socket.SocketChannel} which uses NIO selector based implementation.<br> */<br>public class NioSocketChannel extends AbstractNioByteChannel implements io.netty.channel.socket.SocketChannel {<!-- --><br> private static final InternalLogger logger = InternalLoggerFactory.getInstance(NioSocketChannel.class);<br> //选择器提供者<br> private static final SelectorProvider DEFAULT_SELECTOR_PROVIDER = SelectorProvider.provider();<br> private final SocketChannelConfig config;//socket通道配置<br> /**<br> * Create a new instance<br> */<br> public NioSocketChannel() {<!-- --><br> th |
|
转播
