Netty核心API

ChannelHandler及其实现类

ChannelHandler接口定义了许多事件处理的方法,我们可以通过重写这些方法去实现具体的业务逻辑。

我们经常需要自定义一个Handler类去继承ChannelInboundHandlerAdapter,然后通过重写相应方法实现业务逻辑,需要重写的方法:

public void channelActive(ChannelHandlerContext ctx),通道就绪事件

public void channelRead(ChannelHandlerContext ctx,Object msg),通道读取数据事件

public void channelReadComplete(ChannelHandlerContext ctx),数据读取完毕事件

public void exceptionCaught(ChannelHandlerContext ctx,Throwable cause),通道发生异常事件

Pipeline 和 ChannelPiepline

ChannelPipeline是一个handler的集合,它负责处理和拦截inbound或者outbound的事件和操作,相当于一个贯穿Netty的链。

ChannelPipeline addFirst(ChannelHandler...handlers),把一个业务处理类(handler)添加到链中的第一个位置

ChannelPipeline addLast(ChannelHandler...handlers),把一个业务处理类(handler)添加到链中的最后一个位置

ChannelHandlerContext

这是事件处理器上下文对象,pipeline链中的实际处理节点。每个处理节点ChannelHandlerContext中包含一个具体的事件处理器ChannelHandler,同时ChannelHandlerContext中也绑定了对应的pipeline和Channel的信息,方便对ChannelHandler进行调用。

常用方法:

ChannelFuture close(),关闭通道

ChannelOutboundInvoker flush(),刷新

ChannelFuture writeAndFlush(Object msg),将数据写到ChannelPipeline中当前ChannelHandler的下一个ChannelHandler开始处理(出站)

ChannelOption

Netty在创建Channel实例后,一般都需要设置ChannelOption参数。ChannelOption是Socket的标准参数,而非Netty独创的。常用的参数配置有

1.ChannelOption.SO_BACKLOG

对应TCP/IP协议listen函数中backlog参数,用来初始化服务器可连接队列大小。服务器端处理客户端连接是顺序处理的,所以同一时间只能处理一个客户端连接。多个客户端来的时候,服务器端将不能处理的客户端连接请求放在队列中等待处理,backlog参数指定了队列的大小。

2.ChannelOption.SO_KEEPALIVE,一直保持连接活动状态。

ChannelFuture

表示Channel中异步I/O操作的结果,在Netty中所有的I/O操作都是异步的,I/O的调用会直接返回,调用者并不能立刻获得结果,但是可以通过ChannelFutrue来获取I/O操作的处理状态。

常用方法:

Channel channel(),返回当前正在进行IO操作的通道

ChannelFuture sync(),等待异步操作执行完毕

EventLoopGroup和其实现类NioEventLoopGroup

EventLoopGroup是一组EventLoop的抽象,Netty为了更好的利用多核CPU资源,一般会有多个EventLoop同时工作,每个EventLoop维护着一个Selector实例。

EventLoopGroup提供next接口,可以从组里面按照一定规则获取其中一个EventLoop来处理任务。在Netty服务器端编程中,我们一般都需要提供两个EventLoopGroup,例如BossEvenLoopGroup和WorkerEventLoopGroup。

通常一个服务器端口即一个ServerSocketChannel对应一个Selector和一个EventLoop线程。BossEventLoop负责接收客户端连接并将SocketChannel交给WorkerEventLoopGroup来进行IO处理。

BossEventLoopGroup通常是一个单线程的EventLoop,EventLoop维护着一个注册了ServerSoketChannel的Selector实例,BossEventLoop不断轮询Selector将连接事件分离出来,通常是OP——ACCEPT事件,然后将连接到的SocketChannel交给WorkerEventLoopGroup,WorkerEventLoopGroup会由next选择其中一个EventLoopGroup来将这个SocketChannel注册到其他维护的Selector并对其后续的IO事件进行处理。

常用方法:

public NioEventLoopGroup(),构造方法

public Future<?> shutdownGracefully(),断开连接,关闭线程。

ServerBootstrap和Bootstrap

ServerBootstrap是Netty中服务器端启动助手,通过它可以完成服务器端的各种配置:Bootstrap是Netty中的客户端启动助手,通过它可以完成客户端的各种配置,

常用方法:

public ServerBootstrap group(EventLoopGroup parentGroup,EventLoopGroup childGroup),该方法用于服务器端,用来设置两个EventLoop

public B channel(Class<? extends C>channelClass),该方法用来设置一个服务器端的通道实现

public <T>B option(ChannelOption<T>option,T value),用来给ServerChannel添加配置

public <T>ServerBootstrap childOption(ChannelOption<T> childOption,T value),用来给接收到的通道添加配置

public ServerBootstrap childHandler(ChannelHandler childHandler),该方法用来设置业务处理类(自定义的handler)

public ChannelFuture bind(int inetPort),该方法用于服务器端,用来设置占用的端口号

public ChannelFuture connect(String inetHost,int inetPort),该方法用于客户端,用来连接服务器端

Unpooled类

这是Netty提供的一个专门用于操作缓冲区的工具类,常用方法如下:

public static ByteBuf copiedBuffer(CharSequence string,Charset charset),通过给定的数据和字符编码返回一个ByteBuf对象(类似于NIO中的ByteBuffer对象)


最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 216,997评论 6 502
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,603评论 3 392
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 163,359评论 0 353
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,309评论 1 292
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,346评论 6 390
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,258评论 1 300
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,122评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,970评论 0 275
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,403评论 1 313
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,596评论 3 334
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,769评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,464评论 5 344
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,075评论 3 327
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,705评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,848评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,831评论 2 370
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,678评论 2 354

推荐阅读更多精彩内容