Netty权威指南(三)Netty入门应用
Netty入门应用目录
- 回顾NIO开发步骤
- 一、依赖
- 二、Netty TimeServer
- 三、Netty TimeServerHandler
- 四、Netty TimeClient
- 五、Netty TimeClientHandler
- 六、总结
回顾NIO开发步骤
- 创建
ServerSocketChannel
,配置为非阻塞
模式。 - 绑定监听,配置TCP参数,例如backlog大小。
- 创建一个独立的I/O线程,用于轮询多路复用器
Selector
。 - 创建Selector,将之前创建的
ServerSocketChannel
注册到Selector
上,监听SelectionKey.ACCEPT
。 - 启动IO线程,在循环体中执行
Selector.select()
方法。轮询就绪的Channel
。 - 当轮询到了处于就绪状态的
Channel
时,需要对其进行判断,如果是OP_ACCEPT
状态,说明是新的客户端接入,则调用ServerSocketChannel.accept()
方法接收新的客户端。 - 设置新接入的客户端链路SocketChannel为非阻塞模式,配置其他的一些TCP参数。
- 将
SocketChannel
注册到Selector
上,监听OP_READ
操作位。 - 如果轮询的
Channel
为OP_READ
,则说明SocketChannel中有询的就绪的数据包。 - 如果轮询的
Channel
为OP_WRITE
,说明还有数据没有发送完成,需要继续发送。
一个简单的NIO服务端程序,如果我们直接使用JDK的NIO类库进行开发,竟然需要经过繁琐的十多步操作才能完成最基本的消息读取和发送,这也是我们选择Netty
框架的原因了。下面我们看看Netty是如何轻松搞定服务端开发的。
一、依赖
使用的是netty5版本的依赖,与4版本的ChannelHandlerAdapter
类稍微有些区别。
<!-- https://mvnrepository.com/artifact/io.netty/netty-all --><dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId><version>5.0.0.Alpha2</version></dependency>
二、Netty TimeServer
package com.lsh.netty;import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;/*** @author :LiuShihao* @date :Created in 2021/3/8 12:09 下午* @desc :Netty服务端开发*/
public class TimeServer {public void bind(int port) throws Exception{/*** 配置服务端的NIO线程组 创建两个NioEventLoopGroup实例 ,* NioEventLoopGroup是个线程组 它包含了一组NIO线程,专门用于网络事件的处理,实际上它们就是Reactor线程组* 这里创建两个的原因是一个用于服务端接收客户端的连接,另一个就是用于进行SocketChannel的网络读写,*/NioEventLoopGroup bossGroup = new NioEventLoopGroup();NioEventLoopGroup workerGroup = new NioEventLoopGroup();try{/***ServerBootstrap 是Netty用于启动NIO服务端的辅助启动类,目的是降低服务端的开发复杂度* 调用ServerBootstrap的group方法:* 将两个NIO线程组当做入参传递到ServerBootstrap中,* 1.channel设置的为NIOServerSocketChannel,功能对应于NIO的ServerSocketChannel* 2.配置NIOServerSocketChannel的TCP参数* 3.绑定IO事件的处理类ChildChannelHandler,作用主要是类似于Reactor模式中的Handler类,主要用于* 处理网络IO事件例如记录日志,对消息进行编解码等**/ServerBootstrap b = new ServerBootstrap();b.group(bossGroup,workerGroup).channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG,1024).childHandler(new ChildChannelHandler());/*** 绑定端口,同步等待成功*/ChannelFuture sync = b.bind(port).sync();//等待服务端监听端口关闭sync.channel().closeFuture().sync();}finally {//优雅退出,释放线程池资源bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}private class ChildChannelHandler extends ChannelInitializer<SocketChannel> {@Overrideprotected void initChannel(SocketChannel socketChannel) throws Exception {socketChannel.pipeline().addLast(new TimeServerHandler());}}public static void main(String[] args) throws Exception {int port = 8080;new TimeServer().bind(port);}}
总结:
创建两个
NioEventLoopGroup
实例:NIOEventLoopGroup
是一个线程组,它包含了一组NIO线程,专门用于网络事件的处理,实际上他们就是Reactor
线程组,这里创建两个的原因是一个用于服务端接收客户端的连接,另一个用于进行SocketChannel
的网络读写。创建的
ServerBootstarp
对象:它是Netty用于启动NIO服务端的辅助启动类,目的是降低服务端的开发复杂度。ServerBootstrap的
group
方法:将两个NIO线程组当作入参
传递到ServerBootstrap
中。接着设置创建的Channel为
NioServerSocketChannel
,就相当于Java 的NIO类库中的ServerSocketChannel
。然后配置NioServerSocketChannel
的TCP参数,此处将它的backlog设置为1024,最后绑定I/O事件的处理类为ChildChannelHandler
,它的作用类型于Reactor模式中的Handler类,主要用于处理网络I/O事件,例如记录日志、对消息进行编解码等。服务端启动辅助类配置完成后,调用它的
bind
方法绑定监听端口,随后,调用它的同步阻塞方法sync等待绑定操作完成。完成之后会返回一个ChannelFuture
,它的功能类似于JDK的java.util.concurrent.Future,主要用于异步操作的通知回调。使用
sync()
方法进行阻塞,等待服务端链路关闭之后main函数才退出。NIO线程组的
shutdownGracefully
进行优雅退出,它会释放跟shutdownGracefully
相关联的资源。
三、Netty TimeServerHandler
package com.lsh.netty;import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerAdapter;
import io.netty.channel.ChannelHandlerContext;import java.io.UnsupportedEncodingException;
import java.util.Date;/*** @author :LiuShihao* @date :Created in 2021/3/8 12:39 下午* @desc :*/
public class TimeServerHandler extends ChannelHandlerAdapter {@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws UnsupportedEncodingException {ByteBuf buf = (ByteBuf) msg;byte[] req = new byte[buf.readableBytes()];buf.readBytes(req);String body = new String( req,"UTF-8");System.out.println("The time server receive order :"+body);String currentTime = "QUERY TIME ORDER".equalsIgnoreCase(body) ? new Date(System.currentTimeMillis()).toString() : "BAD ORDER";ByteBuf resp = Unpooled.copiedBuffer(currentTime.getBytes());ctx.write(resp);}@Overridepublic void channelReadComplete(ChannelHandlerContext ctx) throws Exception{ctx.flush();}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {ctx.close();}}
总结:
TimeServerHandler
继承自 ChannelHandlerAdapter
,它用于对网络事件进行读写操作。通常我们只需要关注channelRead
和exceptionCaught
方法。
- 类行转换:将
msg
转换成Netty的ByteBuf
对象,ByteBuf类似于JDK的java.nio.ByteBuffer 对象,不过它提供了更加强大和灵活的功能。通过ByteBuf
的readableBytes
方法可以获取缓冲区可读的字节数,根据可读的字节数创建byte数组
,通过ByteBuf
的readBytes
方法将缓冲区中的字节数组复制到新建的byte数组
中,最后通过new String 构造函数
获取请求消息。这时对请求消息进行判断,如果是“QUERY TIME OREER”则创建应答消息,通过ChannelHandlerContext
的write
方法异步
发送应答消息给客户端。 - ChannelHanContext的
flush()
方法:它的作用是将消息发送队列中的消息写入到SocketChannel
中发送给对方。从性能角度考虑,为了防止频繁的唤醒Selector进行消息发送,Netty的write方法并不直接将消息写入SocketChannel中,调用writer
方法只是把待发送消息放到发送缓冲数组中,在通过flash()
方法,将发送缓冲区中的消息全部写到SocketChannel
中。 - 当发生异常时:关闭
ChannelHandlerContext
,释放和ChannelHandlerContext相关联的句柄等资源。
Netty权威指南(二)NIO模型
通过对代码统计分析可以看出,不到30行的业务逻辑代码,即完成了NIO服务端的开发,相比于传统基于JDK NIO
原生类库的服务端,代码量大大减少,开发难度也降低了很多。
四、Netty TimeClient
package com.lsh.netty;import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;/*** @author :LiuShihao* @date :Created in 2021/3/17 12:09 下午* @desc :基于Netty的TimeClient*/
public class TimeClient {public void connect (int port,String host) throws Exception{//配置客户端NIO线程组NioEventLoopGroup group = new NioEventLoopGroup();try{Bootstrap b = new Bootstrap();b.group(group).channel(NioSocketChannel.class).option(ChannelOption.TCP_NODELAY,true).handler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel socketChannel) throws Exception {socketChannel.pipeline().addLast(new TimeClientHandler());}});//发起异步连接操作ChannelFuture f = b.connect(host, port).sync();//等待客户端链路关闭f.channel().closeFuture().sync();}finally {//优雅退出 释放NIO线程组group.shutdownGracefully();}}public static void main(String[] args) throws Exception {int port = 8080;new TimeClient().connect(port,"127.0.0.1");}
}
总结:
- 首先创建客户端处理I/O读写的
NioEventLoopGroup
线程组。 - 然后继续创建客户端辅助启动类
Bootstrap
,随后需要对其进行配置。 - 与服务端不同的是:它的
Channel
需要设置为NioSocketChannel
。 - 然后为其添加
Handler
,此处为了简单直接使用了匿名内部类,实现initChannel()
方法,其作用是当创建NioSocketChannel
成功之后,在进行初始化时,将它的ChannelHandler
设置到ChannelPipeline
中,用于处理网络IO事件。 - 客户端启动辅助类完成之后,调用connect方法发起异步连接,然后调用同步方法等待连接成功。
- 最后,当客户端连关闭之后,客户端主函数退出退出之前释放NIO线程组的资源。
五、Netty TimeClientHandler
package com.lsh.netty;import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerAdapter;
import io.netty.channel.ChannelHandlerContext;/*** @author :LiuShihao* @date :Created in 2021/3/17 12:13 下午* @desc :*/
public class TimeClientHandler extends ChannelHandlerAdapter {private final ByteBuf firstMessage;public TimeClientHandler() {byte[] req = "QUERY TIME ORDER".getBytes();firstMessage = Unpooled.buffer(req.length);firstMessage.writeBytes(req);}@Overridepublic void channelActive(ChannelHandlerContext ctx){ctx.writeAndFlush(firstMessage);}@Overridepublic void channelRead(ChannelHandlerContext ctx,Object msg) throws Exception{ByteBuf buf = (ByteBuf) msg;byte[] req = new byte[buf.readableBytes()];buf.readBytes(req);String body = new String(req, "UTF-8");System.out.println("Now is :"+body);}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {ctx.close();}}
总结:
这里关注三个方法:channelActive、channelRead、exceptionCaught。
- 当客户端和服务端TCP链路建立成功之后,Netty的NIO线程会调用
channelActive
方法,发送查询时间的指令给服务器,调用ChannelHandlerContext的writeAndFlush
方法将请求消息发送给服务端。 - 当服务端返回应答消息时,
channelRead
方法被调用,从Netty的ByteBuf
中读取并打印应答消息。 - 当发生异常时,打印异常日志,释放客户端资源。
六、总结
经过调试,运行结果正确,可以发现,通过Netty开发的NIO服务端和客户端非常简单,短短几十行代码就能完成之前NIO程序需要几百行才能完成的功能,基于Netty的应用开发不但API使用简单、开发模式固定,而且扩展性和定制性非常好,后面,我们会通过更多应用来介绍Netty的强大功能。
需要指出的是,本程序依然没有考虑读半包的处理,对于功能演示或者测试,上述程序并没有问题,但是稍加改造进行性能和压力测试,他就不能正确的工作了。在下一章我们会给出能够正确处理半包消息的应用实例。
Netty权威指南(三)Netty入门应用相关推荐
- 《Netty权威指南 第2版》学习笔记(1)---服务端与客户端开发入门
前言 Netty权威指南中以时间服务器为入门案例,演示了如何通过Netty完成了服务端与客户端之间的交互过程. 在开始使用Netty开发之前,先回顾一下使用NIO进行服务端开发的步骤. 创建Serve ...
- [201504][Netty 权威指南][第2版][李林锋][著]
[201504][Netty 权威指南][第2版][李林锋][著] https://github.com/wuyinxian124/nettybook2 基础篇 走进 Java NIO 第 1 章 J ...
- IT人物之《Netty权威指南》中文作者 专访华为李林锋:我与Netty那些不得不说的事
摘要:Netty是业界最流行的NIO框架之一,它的健壮性.功能.性能.可定制性和可扩展性在同类框架中都是首屈一指的.近日,CSDN采访了Netty领域的权威人士李林锋,请他分享Netty开发的经验之道 ...
- Netty权威指南(四)TCP粘包/拆包问题
TCP粘包/拆包问题解决之道 上一章 一.介绍 1.1 TCP粘包/拆包问题说明 1.2 TCP粘包/拆包发生的原因 1.3 粘包问题的解决策略 二.未考虑TCP粘包导致的功能异常案例 2.1 Tim ...
- 《Netty权威指南》
<Netty权威指南> 基本信息 作者: 李林锋 出版社:电子工业出版社 ISBN:9787121233432 上架时间:2014-5-29 出版日期:2014 年6月 开本:16开 页码 ...
- 《Netty权威指南》笔记 —— 第二十、二十一、二十二, 二十三章
<Netty权威指南>笔记--Netty高级特性 第20章 Netty架构剖析 Reactor通信调度层 职责链 ChannelPipeline 业务逻辑编排层 关键架构质量属性 高性能 ...
- netty权威指南第一章
本章内容如下: 5种网络I/O模型的介绍 I/O多路复用的介绍 1.I/O基础入门 在Java1.4之前,Java对I/O的支持不完善,开发人员在开发高性能I/O的程序时,会面临以下问题: 没有数据缓 ...
- netty权威指南笔记-以回车换行结尾的消息如何处理半包问题
概述 TCP底层会发生粘包和拆包,这个是TCP的一个特性.为了减少网络数据传输的次数,TCP总是希望让网络数据到达一定量级的时候才将数据发送出去,而不是缓存区一有数据就马上发送数据. TCP底层会根据 ...
- netty权威指南 学习笔记http
序 李林峰的<netty权威指南>,从Java的NIO开始介绍,后面介绍TCP粘包拆包.中级篇介绍编解码技术. 第10章介绍了HTTP及netty HTTP+XML的技术. 因为xml实际 ...
- Netty权威指南带目录完整版.pdf
2019独角兽企业重金招聘Python工程师标准>>> Netty权威指南带目录完整版.pdf 转载于:https://my.oschina.net/xiaojianyu/blog/ ...
最新文章
- MobileIMSDK怎样修改服务端核心jar包的源码并替换掉Java服务端的jar包
- 2019蓝桥杯省赛b组
- 解析markdown_markdown-it 原理浅析
- @Aspect中@Pointcut 12种用法
- WEB接口测试之Jmeter接口测试自动化 (三)(数据驱动测试) 接口测试与数据驱动...
- 由锚点失效引发的hasLayout探究
- Airflow 中文文档:保护连接
- RVC使用指南(六)-排错
- java命令javac java,使用命令行JAVAC编译Java
- webserver总结
- 批量生成ip地址shell脚本
- linux逻辑卷管理器下载,LVM逻辑卷管理器(Logical Volume Manager)
- 用cubesuite烧写器报下列错误: [Direct Error Cause] Incorrect ID Code.(C0602202)
- 图片转化成矩阵,灰度处理,黑白对调--ByMatlab
- 权限提升+权限维持+痕迹清理
- one to one
- rv1126和PC之间的数据交流(windows)
- QT (C++)安装5.14
- [二十三]JavaIO之PushbackReader
- 【html实现记住账号、记住密码功能】
热门文章
- IT服务管理(一)服务的演变与整体观
- Linux如何安装iperf软件,【iperf】iperfforLinux-最笨下载
- Head first java(第一章进入Java的世界)
- 批处理之 FOR循环
- php令牌桶,令牌桶限频(TokenBucket)
- echarts:迁徙图
- 【VHDL】VHDL设计一个分频器
- iOS 实现时间线列表效果
- 永中文档转换服务Swagger调用说明
- oracle财务管理系统有什么用,CSS_Oracle财务管理系统:会计业务周期,下面是使用Oracle财务管理系统 - phpStudy...