Netty3 源码分析 - Channel

何为通道(Channel)?代表的是一个网络套接字的连接点(nexus)。

一个通道抽象的内容包括:

1)当前通道状态,是否打开,是否绑定等;

2)通道的配置参数信息,如套接字缓冲区大小;

3)通道支持的IO操作;

4)处理和这个Channel相关的IO事件和请求的ChannelPipeline。

在Netty中所有的IO操作都是异步的,即执行一个IO调用的时候不会阻塞到操作完成,而后立即返回一个ChannelFuture对象,这个ChannelFuture对象会在某个时候通知我们IO操作执行结果(成功,失败或取消)。

Channel是分层结构的(和传输层实现有关),比如说一个监听套接字ServerSocketChannel在接收一个连接请求后会创建一个连接套接字对应的通道SocketChannel,那么当对一个连接通道调用getParent() 的时候就会返回那个监听通道实体。

每个通道还有一个interestOps属性,和select机制类似,就是告知内核该通道感兴趣的事件,有两个比特标识构成:

OP_READ: 如果设置了这个标识,并且有对端的数据到达,那么就会进行read操作;否则即使有数据也不会读取(读悬挂),有点边沿触发的味道。

OP_WRITE: 如果设置了该位,写请求不会将数据发送给对端,而是追加到队列中,如果清楚了这个标识,写请求就会从队列中flush。

OP_READ_WRITE:只有写请求会被悬挂(suspend)。

OP_NONE : 只有读请求会被悬挂。

比如接口中setReadable这个方法可以通过设置/清除OP_READ来:Suspends
or resumes the read operation of the I/O thread asynchronously。等价代码是:

int interestOps = getInterestOps();

if (readable) {

setInterestOps(interestOps | OP_READ);

} else { // clear the flag

setInterestOps(interestOps & ~OP_READ);

}

要注意的是,不能像设置/清除OP_READ标识那样来悬挂或恢复写操作,OP_WRITE这个标识只是用来告知悬挂的写请求是否超过了一定的阈值。比如在NIO
socket中可以通过NioSocketConfig设置低水位/高水位标识。

这个接口的源码如下:

public interface Channel extends Comparable<Channel>
{

int OP_NONE =
0;

int OP_READ =
1;

int OP_WRITE =
4;

int OP_READ_WRITE = OP_READ | OP_WRITE ;

Integer getId();

ChannelFactory getFactory();

Channel getParent();

ChannelConfig getConfig();

ChannelPipeline getPipeline();

boolean isOpen();

boolean isBound();

boolean isConnected();

SocketAddress getLocalAddress();

SocketAddress getRemoteAddress();

ChannelFuture write(Object message);

ChannelFuture write(Object message, SocketAddress
remoteAddress);

ChannelFuture bind(SocketAddress localAddress);

ChannelFuture connect(SocketAddress remoteAddress);

ChannelFuture disconnect();

ChannelFuture unbind();

ChannelFuture close();

ChannelFuture getCloseFuture();

int getInterestOps();

boolean isReadable();

boolean isWritable();

ChannelFuture setInterestOps( int interestOps);

ChannelFuture setReadable( boolean readable);

Object getAttachment();

void setAttachment(Object
attachment);

}

时间: 2024-11-29 05:17:57

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

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对

Netty源码分析--Channel注册(上)(五)

其实在将这一节之前,我们来分析一个东西,方便下面的工作好开展. 打开启动类,最开始的时候创建了一个NioEventLoopGroup 事件循环组,我们来跟一下这个. 这里bossGroup, 我传入了一个线程, workerGroup 没有入参,默认0, 也就是说父级我用一个线程来处理客户端的接入, 多个线程来处理客户端的读写操作 通过一连串的构造方法进入到 executor 是 null , selectorProvider 用来创建一个多路复用器, 最后一个参数传入了 一个多路复用器的一个策