博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Netty学习笔记(二)
阅读量:5918 次
发布时间:2019-06-19

本文共 1912 字,大约阅读时间需要 6 分钟。

前两天写了一点netty相关的知识,并写了一个demo,但是对其原理还是没有深入,今天我们来做一次研究吧

首先让我们来认识一下netty的几个核心人物吧

BOOTSTRAP

Netty 应用程序通过设置 bootstrap(引导)类的开始,该类提供了一个 用于应用程序网络层配置的容器。

服务器端

Figure 9.3 ServerBootstrap.jpg

ServerChannel实现负责创建子 Channel,它代表接受连接

客户端

Figure 9.2 Bootstrap process.jpg

在调用 bind() 或 connect() 之后,Bootstrap 类负责创建管道给客户或应用程序,

CHANNEL

底层网络传输 API 必须提供给应用 I/O操作的接口,如读,写,连接,绑定等等。对于我们来说,这层结构几乎总是会成为一个“socket”。 Netty 中的接口 Channel 定义了与 socket 丰富交互的操作集:bind, close, config, connect, isActive, isOpen, isWritable, read, write 等等。 Netty 提供大量的 Channel 实现来专门使用。这些包括 AbstractChannel,AbstractNioByteChannel,AbstractNioChannel,EmbeddedChannel, LocalServerChannel,NioSocketChannel 等等。

CHANNELHANDLER

ChannelHandler支持很多协议,并且提供用于数据处理的容器。我们已经知道 ChannelHandler 由特定事件触发。 ChannelHandler 可专用于几乎所有的动作,包括将一个对象转为字节(或相反),执行过程中抛出的异常处理。

常用的一个接口是 ChannelInboundHandler,这个类型接收到入站事件(包括接收到的数据)可以处理应用程序逻辑。当你需要提供响应时,你也可以从 ChannelInboundHandler 冲刷数据。一句话,业务逻辑经常存活于一个或者多个 ChannelInboundHandler。

CHANNELPIPELINE

ChannelPipeline 提供了一个容器给 ChannelHandler 链并提供了一个API 用于管理沿着链入站和出站事件的流动。每个 Channel 都有自己的ChannelPipeline,当 Channel 创建时自动创建的。 ChannelHandler 是如何安装在 ChannelPipeline? 主要是实现了ChannelHandler 的抽象 ChannelInitializer。ChannelInitializer子类 通过 ServerBootstrap 进行注册。当它的方法 initChannel() 被调用时,这个对象将安装自定义的 ChannelHandler 集到 pipeline。当这个操作完成时,ChannelInitializer 子类则 从 ChannelPipeline 自动删除自身。

Figure 3.4 ChannelPipeline with inbound and outbound ChannelHandlers.jpg

Figure 6.3 Channel, ChannelPipeline, ChannelHandler and ChannelHandlerContext.jpg

1.Channel 绑定到 ChannelPipeline

2.ChannelPipeline 绑定到 包含 ChannelHandler 的 Channel
3.ChannelHandler
4.当添加 ChannelHandler 到 ChannelPipeline 时,ChannelHandlerContext 被创建

EVENTLOOP

EventLoop 用于处理 Channel 的 I/O 操作。一个单一的 EventLoop通常会处理多个 Channel 事件。一个 EventLoopGroup 可以含有多于一个的 EventLoop 和 提供了一种迭代用于检索清单中的下一个。

简单点来说,EventLoopGroup 是一个线程池,EventLoop是其中一个线程

但netty并不仅限于此
一旦 Channel 是分配给一个 EventLoop,它将使用这个 EventLoop 在它的生命周期里和同样的线程。你可以,也应该,依靠这个,因为它可以确保你不需要担心同步(包括线程安全、可见性和同步)在你 ChannelHandler实现。

CHANNELFUTURE

Netty 所有的 I/O 操作都是异步。因为一个操作可能无法立即返回,我们需要有一种方法在以后确定它的结果。出于这个目的,Netty 提供了接口 ChannelFuture,它的 addListener 方法注册了一个 ChannelFutureListener ,当操作完成时,可以被通知(不管成功与否)。

转载地址:http://kjbvx.baihongyu.com/

你可能感兴趣的文章
Android TV开发总结(二)构建一个TV Metro界面(仿泰捷视频TV版)
查看>>
背包问题--golang的入门解
查看>>
【MySQL】MySQL中查询出数据表中存在重复的值list
查看>>
struct的匿名用法详解
查看>>
siamese网络&&tripletnet
查看>>
使用prometheus抓取k8s的metrics作监控时,cAdvisor和kubelet配置有何差别?
查看>>
spring注解方式实现定时器
查看>>
选股:“均线是水,K线是舟,量是马达!”的选美理念!
查看>>
go语言 defer 高级
查看>>
微信小程序 - tabbar动态更换图标以及文字
查看>>
网络中两台主机通信
查看>>
今天,让Mac更好用!
查看>>
java.lang.ClassNotFoundException: org.apache.commons.fileupload.FileItemFactory报错springmvc
查看>>
自定义react-navigation的TabBar
查看>>
SQL生成包含年月日的流水号
查看>>
深入浅出视图
查看>>
C# 文件压缩与解压(ZIP格式)
查看>>
周五了,发给大家个好玩的东西
查看>>
DataTable 与 Excel文件(CSV)相互转化
查看>>
DataSet导出到Excel比较完整的解决方案(二)--服务器端生成文件(downmoon)
查看>>