步骤5:初始化ChannelPipeline完成之后,添加并设置ChannelHandler
代码:
public void initChannel(SocketChannel ch) throws Exception { ChannelPipeline p = ch.pipeline(); if (sslCtx != null) { p.addLast(sslCtx.newHandler(ch.alloc())); } }
ChannelHandler是Netty提供给用户定制和扩展的关键接口。利用ChannelHandler用户可以完成大多数的功能定制,例如消息编解码、心跳、安全认证、TSL/SSL认证、流量控制和流量整形等。
典型的网络事件如下:
链路注册;
链路激活;
链路断开;
接收到请求消息;
请求消息接收并处理完毕;
发送应答消息;
链路发生异常;
发生用户自定义事件。
Netty同时也提供了大量的系统ChannelHandler供用户使用,比较实用的系统ChannelHandler总结如下:
•系统编解码框架-ByteToMessageCodec;
•通用基于长度的半包解码器-LengthFieldBasedFrameDecoder;
•码流日志打印Handler-LoggingHandler;
•SSL安全认证Handler-SslHandler;
•链路空闲检测Handler-IdleStateHandler;
•流量整形Handler-ChannelTrafficShapingHandler;
•Base64编解码-Base64Decoder和Base64Encoder。
步骤6:绑定并启动监听端口
ChannelFuture f = b.bind(PORT).sync();
在绑定监听端口之前系统会做一系列的初始化和检测工作,完成之后,会启动监听端口,并将ServerSocketChannel注册到Selector上监听客户端连接.
步骤7:关闭服务器,断开监听端口
f.channel().closeFuture().sync();
好了。到此,Netty全部服务器运行流程到此为止。
ServerBootstrap的Hanlder模型
附件中有netty服务端的代码,内容不多,只是开发时最基础的配置,接下来的文章中,我会用例子来展示netty的开发全过程,届时会把整个项目上传分享。