Netty3 源码分析 - OioClientSocketChannelFactory

是一个ClientSocketChannelFactory 的实现,基于SocketChannel的阻塞方式的客户端通道。使用的是传统的阻塞IO API,特点是能得到好的吞吐量和低延迟,当需要服务的连接数少的时候。(联系NIO和OIO的区别)

在OioClientSocketChannelFactory中只有一种线程类型,worker threads。每个连接的通道有一个专用的worker,就是传统的IO模型。(见下图)

当OioClientSocketChannelFactory在构造的时候传入的参数线程池对象如Executors.newCachedThreadPool(),就是worker threads的来源。所以要保证指定的Executor 能提供足够数量的线程。

worker thread是延迟获得的(acquired lazily)并且在没有事务要处理时就会释放,所有yu该thread相关的资源都会释放,所以要优雅的关闭服务(先关闭所有的Channel,调用 ChannelGroup.close();而后调用releaseExternalResources()释放外部资源)。

要注意不要在所有的通道关闭前去关闭executor ,否则会发生RejectedExecutionException ,而且有些相关资源不会正常释放。

限制:通过OioClientSocketChannelFactory创建的SocketChannel 不支持异步操作,任何IO操作如连接,写等都已阻塞方式执行。

时间: 2024-09-10 01:54:04

Netty3 源码分析 - OioClientSocketChannelFactory的相关文章

Netty3 源码分析 - ChannelUpstreamHandler

Netty3 源码分析 - ChannelUpstreamHandler ChannelUpstreamHandler处理上行的通道事件,并且在流水线中传送事件.这个接口最常用的场景是拦截IO工作现场产生的事件,传输消息或者执行相关的业务逻辑.在大部分情况下,我们是使用SimpleChannelUpstreamHandler 来实现一个具体的upstream handler,因为它为每个事件类型提供了单个的处理方法.大多数情况下ChannelUpstreamHandler 是向上游发送事件,虽然

Netty3 源码分析 - NIO server绑定过程分析

一个框架封装的越好,越利于我们快速的coding,但是却掩盖了很多的细节和原理,但是源码能够揭示一切.服务器端代码在指定好ChannelFactory,设定好选项,而后Bootstrap.bind操作就会开启server,接受对端的连接.所以有必要对这后面的过程分析清楚,下图是关键流程.先是构建一个默认的Pipeline,为我们接下来要创建的监听通道服务,这个Pipeline里面会加入一个Binder的上行事件处理器:接下来创建了至关中的NioServerSocketChannel,在构造的过程

Netty3 源码分析 - 套接字绑定实现原理

前面关注的地方都是Netty采用的流水线处理方式的组织方式,ChannelHandler如何管理,通道状态,通道事件等这些上层的架构设计,那么Netty中如何实现诸如套接字绑定,连接,关闭等这些底层的操作呢?不能只顾着套用API写程序,却对细节不求甚解.这里大致追踪下OIO模式下Channel中套接字绑定的实现,(NIO以后分析)其实逻辑都是一样的,只是在线程模型的地方时不同的. 大致过程如下(详细的源码注释,看我的github): 1.我们在通过Bootstrap启动客户端或者服务端的时候会提

Netty3 源码分析 - ChannelFuture

ChannelFuture抽象的是Channel中异步IO操作的结果.在Netty中,所有的IO操作是异步的,意味着任何IO调用会立刻返回,而不是等到操作真正的执行完成.相反,会返回一个ChannelFuture 对象,在IO完成之后通过其得到结果状态.ChannelFuture 要么完成要么未完成,当IO操作开始执行会创建一个新的future对象,初始状态时uncompleted (不是成功,失败,也不是取消)因为IO操作还木有完成,一旦IO操作完成(成功,失败,或者被取消).这个CHanne

Netty3 源码分析 - ClientBootstrap

Bootstrap是通道初始化辅助类 提供了初始化通道或子通道所需要的数据结构,那么ClientBootstrap就是客户端的,而且会执行连接操作. 配置通道,就是把相应的键值对选项传递给底层: ClientBootstrap b = ...; // Options for a new channel b.setOption("remoteAddress", new InetSocketAddress("example.com", 8080)); b.setOpti

Netty3 源码分析 - ChannelPipeline

ChannelPipeline的作用就是组织一系列的ChannelHandlers 为某一个Channel服务,处理各种事件.实现了拦截过滤器模式的高级形式(an advanced form of the Intercepting Filter pattern),进而有效控制如何处理一个事件以及ChannelHandlers之间如何交互.类型结构图为: 流水线的创建:对于每个新的通道,必须为其创建和添置一个Pipeline,一旦设置,他们之间的耦合就是永久的,这个通道不同添置另一个流水线,不能解

Netty3 源码分析 - ChannelStateEvent

ChannelStateEvent是ChannelEvent的子接口,可以代表改变的通知或者是请求,取决于它是上行还是下行事件. UpstreamChannelStateEvent是默认的上行通道状态事件实现类.结合ChannelState中的表很容易看懂源码. DownstreamChannelStateEvent是默认的下行通道状态事件实现类.不同的是需要指定一个Future对象,当相应的动作完成后得到通知.源码很容易理解: public class DownstreamChannelSta

Netty3 源码分析 - ChannelHandlerContext

ChannelHandlerContext存在的意义是可以让其管理的Handler与Pipeline或其他handlers进行交互,ChannelHandler的理解在前面说过. 发送事件:可以调用 sendUpstream(ChannelEvent) 或sendDownstream(ChannelEvent)将一个事件传递给这个Pipeline中与其最近的那个Handler. 修改pipeline:调用 getPipeline()可以得到这个Handler所属的ChannelPipeline对

Netty3 源码分析 - Channel

何为通道(Channel)?代表的是一个网络套接字的连接点(nexus). 一个通道抽象的内容包括: 1)当前通道状态,是否打开,是否绑定等: 2)通道的配置参数信息,如套接字缓冲区大小: 3)通道支持的IO操作: 4)处理和这个Channel相关的IO事件和请求的ChannelPipeline. 在Netty中所有的IO操作都是异步的,即执行一个IO调用的时候不会阻塞到操作完成,而后立即返回一个ChannelFuture对象,这个ChannelFuture对象会在某个时候通知我们IO操作执行结