码迷,mamicode.com
首页 > Web开发 > 详细

Netty原理

时间:2018-03-02 20:47:50      阅读:180      评论:0      收藏:0      [点我收藏+]

标签:channel   缓存   pos   center   cto   com   还需要   java   非阻塞   

Netty是一个高性能、异步事件驱动的NIO框架,基于JAVA NIO提供的API实现

  • ChannelEvent

先说这个ChannelEvent,因为Netty是基于事件驱动的,就是我们上文提到的,发生什么事,就通知"有关部门"。所以,不难理解,我们自己的业务代码中,一定有跟这些事件相关的处理。在样例代码,我们处理的事件,就是channelConnected。以后,我们还会处理更多的事件。

  • ChannelPipeline

Pipeline,翻译成中文的意思是:管道,传输途径。也就是说,在这里他是控制ChannelEvent事件分发和传递的。事件在管道中流转,第一站到哪,第二站到哪,到哪是终点,就是用这个ChannelPipeline 处理的。比如:开发事件。先给A设计,然后给B开发。一个流转图,希望能给你更直观的感觉。

  • ChannelHandler

刚说Pipeline负责把事件分发到相应的站点,那个这个站点在Netty里,就是指ChannelHandler。事件到了ChannelHandler这里,就要被具体的进行处理了,我们的样例代码里,实现的就是这样一个处理事件的“站点”,也就是说,你自己的业务逻辑一般都是从这里开始的。

  • Channel

有了个部门的协调处理,我们还需要一个从整体把握形势的,所谓“大局观”的部门,channel。

channel,能够告诉你当前通道的状态,是连同还是关闭。获取通道相关的配置信息。得到Pipeline等。是一些全局的信息。Channel自然是由ChannelFactory产生的。Channel的实现类型,决定了你这个通道是同步的还是异步的(nio)。例如,我们样例里用的是NioServerSocketChannel。

  • ChannelFuture

 异步结果,这个是异步事件处理的关键,当一个事件被处理时,可以直接以ChannelFuture的形式直接返回,不用在当前操作中被阻塞。可以通过 ChannelFuture得到最终的执行结果,具体的做法是在ChannelFuture添加监听器listener,当操作最终被执行完 后,listener会被触发,我们可以在listener的回调函数中预定义我们的业务代码。

技术分享图片

技术分享图片

阻塞IO的通信方式

                                                                           技术分享图片

非阻塞IO的通信方式

                                         技术分享图片

Channel一览

  • · Channel:数据传输流,与channel相关的概念有以下四个,上一张图让你了解netty里面的Channel。
  • Channel,表示一个连接,可以理解为每一个请求,就是一个Channel。
  • ChannelHandler,核心处理业务就在这里,用于处理业务请求。
  • ChannelHandlerContext,用于传输业务数据。
  • ChannelPipeline,用于保存处理过程需要用到的ChannelHandler和ChannelHandlerContext。
    • ByteBuf
      ByteBuf是一个存储字节的容器,最大特点就是使用方便,它既有自己的读索引和写索引,方便你对整段字节缓存进行读写,也支持get/set,方便你对其中每一个字节进行读写,他的数据结构如下图所示:

技术分享图片

 

 

 

Netty原理

标签:channel   缓存   pos   center   cto   com   还需要   java   非阻塞   

原文地址:https://www.cnblogs.com/stanljj/p/8494476.html

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