netty权威指南-第三章—

3.2 Netty 服务端开发

TimeServer.java

public class TimeServer {public void bind(int port) throws Exception {// 配置服务端的NIO线程组EventLoopGroup bossGroup = new NioEventLoopGroup();EventLoopGroup workerGroup = new NioEventLoopGroup();try {ServerBootstrap b = new ServerBootstrap();b.group(bossGroup,workerGroup).channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG,1024).childHandler(new ChildChannelHandler());// 绑定端口，同步等待成功ChannelFuture f = b.bind(port).sync();// 等待服务端监听端口关闭f.channel().closeFuture().sync();} finally {// 优雅退出，释放线程池资源bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}private class ChildChannelHandlerextends ChannelInitializer<SocketChannel>{@Overrideprotected void initChannel(SocketChannel socketChannel) throws Exception {socketChannel.pipeline().addLast(new TimeServeHandler());}}public static void main(String[] args) throws Exception{int port = 8080;if (args != null && args.length > 0) {try {port = Integer.valueOf(args[0]);} catch (NumberFormatException e) {// 采用默认值}}new TimeServer().bind(port);}
}

我们从 bind 方法开始学习，在代码第 5~6 行创建了两个 NioEventLoopGroup 实例。NioEventLoopGroup 是个线程组，它包含了一组 NIO 线程，专门用于网络事件的处理，实际上它们就是 Reactor 线程组。这里创建两个的原因是一个用于服务端接受客户端的连接，另一个用于进行 SocketChanneI 的网络读写。第 8行创建 ServerBootstrap 对象，它是 Netty用于启动 NIO 服务端的辅助启动类，目的是降低服务端的开发复杂度。第 9行调用ServerBootstrap 的 group 方法，将两个 NIO 线程组当作入参传递到 ServerBootstrap 中。接着设置创建的 Channel 为 NioServerSocketChannel, 它的功能对应于 JDK NIO 类库中的ServerSocketChannel 类。然后配置 NioServerSocketCh annel 的 TC P 参数，此处将它的 backlog
设置为 1024 ，最后绑定 I/O 事件的处理类 ChildChannelHandler ，它的作用类似于 Reactor模式中的 Handler 类，主要用于处理网络 1 / 0 事件，例如记录日志、对消息进行编解码等。

服务端启动辅助类配置完成之后，调用它的 bind 方法绑定监听端口，随后，调用它的同步阻塞方法 sync 等待绑定操作完成。完成之后 Netty 会返回一个 ChannelFuture ，它的功能类似于 JDK 的 java.util.concurrent.Future ，主要用于异步操作的通知回调。

第 16行使用 f.channel().closeFuture().sync() 方法进行阻塞，等待服务端鲢路关闭之后main 函数才退出。

第 19~20 行调用 NIO 线程组的 shutdownGracefully 进行优雅退出，它会释放跟shutdownGracefuIIy 相关联的资源。

TimeServeHandler.java

public class TimeServeHandler extends ChannelHandlerAdapter {@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("The time server receive order : " + body);String currentTime ="QUERY TIME ORDER".equalsIgnoreCase(body)? new java.util.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();}
}

第 5 行做类型转换，将 msg 转换成 Netty 的 ByteBuf 对象。 ByteBuf 类似于 JDK 中的java.nio.ByteBuffer 对象，不过它提供了更加强大和灵活的功能。通过 ByteBuf 的readabl e Bytes 方法可以获取缓冲区可读的字节数，根据可读的字节数创建 byte 数组，通过ByteBuf 的 read Bytes 方法将缓冲区中的字节数组复制到新建的 byte 数组中，最后通过 new
string 构造函数获取请求消息。这时对请求消息进行判断，如果是 "QUERY TIME ORDER"则创建应答消息，通过 ChanneIHandIerContext 的 write 方法异步发送应答消息给客户端。

第 20 行我们发现还调用了 ChannelHandlerContext的 flush 方法，它的作用是将消息发送队列中的消息写入到 SocketChannel 中发送给对方。从性能角度考虑，为了防止频繁地唤醒 SeIector 进行消息发送， Netty 的 write 方法并不直接将消息写入 SocketChanneI 中，调用 write 方法只是把待发送的消息放到发送缓冲数组中，再通过调用 flush 方法，将发送缓冲区中的消息全部写到 SocketChannel 中。

第 25 行，当发生异常时，关闭 ChanneIHandIerContext ，释放和 ChanneIHandIerContext相关联的句柄等资源。通过对代码进行统计分析可以看出，不到 30 行的业务逻辑代码，即完成了 NIO 服务端的丌发，相比于传统基于 JDK NIO 原生类库的服务端，代码量大大减少，开发难度也降低了很多。

3.3 Netty 客户端开发

TimeClient.java

public class TimeClient {public void connect(int port, String host)  throws Exception {// 配置客户端NIO 线程组EventLoopGroup 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();}}/*** @param args* @throws Exception*/public static void main(String[] args) throws Exception {int port = 8080;if (args != null && args.length > 0) {try {port = Integer.valueOf(args[0]);} catch (NumberFormatException e) {// 采用默认值}}new TimeClient().connect(port, "127.0.0.1");}
}

我们从 connect 方法讲起，在第 5行首先创建客户端处理 I/O 读写的 NioEventLoopGroup 线程组，然后继续创建客户端辅助启动类 Bootstrap ，随后需要对其进行配置。与服务端不同的是，它的 ChanneI 需要设置为 N ioSocketChanneI ，然后为其添加 HandIer. 此处为了简单直接创建匿名内部类，实现 initChannel 方法，其作用是当创建 NioSocketChanneI
成功之后，在进行初始化时，将它的 ChannelHandler 设置到 ChannelPipeline 中，用于处理网络 I/O 事件。

客户端启动辅助类设置完成之后，调用 connect 方法发起异步连接，然后调用同步方法等待连接成功。

最后，当客户端连接关闭之后，客户端主函数退出，退出之前释放 NIO 线程组的资源。

TimeClientHandler.java

public class TimeClientHandler extends ChannelHandlerAdapter {private static final Logger logger =Logger.getLogger(TimeClientHandler.class.getName());private final ByteBuf firstMessage;// Creates a client-side handler.public TimeClientHandler() {byte[] req = "QUERY TIME ORDER".getBytes();firstMessage = Unpooled.buffer(req.length);firstMessage.writeBytes(req);}@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {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");}
}

这里重点关注三个方法： channelActive 、 channelRead 和 exceptionCaught0 当客户端和服务端 TCP 链路建立成功之后， Netty 的 NIO 线程会调用 channelActive 方法，发送查询时间的指令给服务端，调用 ChannelHandlerContext 的 writeAndFlush 方法将请求消息发送给服务端。
当服务端返回应答消息时， channelRead 方法被调用，第 39 ～ 43 行从 Netty 的 ByteBuf中读取并打印应答消息。
第 21~26 行，当发生异常时，打印异常日志，释放客户端资源。

netty权威指南-第三章——netty入门应用相关推荐

netty权威指南第三版_Hadoop权威指南(第二版及第三版）
书籍简介全书5部分24章,第Ⅰ部分介绍Hadoop基础知识,主题涉及Hadoop.MapReduce.Hadoop分布式文件系统.YARN.Hadoop的I/O操作. 第Ⅱ部分介绍MapReduce ...
netty权威指南学习笔记一——NIO入门（4）AIO
NIO2.0引入了新的异步通道的概念,并提供了异步文件通道和异步套接字通道的实现.异步通道提供以下两种方式获取操作结果. 1.通过java.util.concurrent.Future 类来表示异步操 ...
Asterisk权威指南/第三章安装Asterisk
在这一章我们将详细介绍如何从源代码安装Asterisk.很多人回避这种方法,说它太难了,又耗时间.我们在这里想证明的是从源代码安装Asterisk其实没那么难.更重要的是,我们想为你提供一个最好的As ...
CUDA C编程权威指南第三章 CUDA执行模型
基础每个GPU有多个SM(streaming multiprocessor) 当启动一个grid时,它的block会被分配给多个SM上执行,一个block一旦被调度到一个SM上,则这个block只会 ...
Netty权威指南（四）TCP粘包/拆包问题
TCP粘包/拆包问题解决之道上一章一.介绍 1.1 TCP粘包/拆包问题说明 1.2 TCP粘包/拆包发生的原因 1.3 粘包问题的解决策略二.未考虑TCP粘包导致的功能异常案例 2.1 Tim ...
IT人物之《Netty权威指南》中文作者专访华为李林锋：我与Netty那些不得不说的事
摘要:Netty是业界最流行的NIO框架之一,它的健壮性.功能.性能.可定制性和可扩展性在同类框架中都是首屈一指的.近日,CSDN采访了Netty领域的权威人士李林锋,请他分享Netty开发的经验之道 ...
《Netty权威指南》笔记 —— 第二十、二十一、二十二, 二十三章
<Netty权威指南>笔记--Netty高级特性第20章 Netty架构剖析 Reactor通信调度层职责链 ChannelPipeline 业务逻辑编排层关键架构质量属性高性能 ...
netty权威指南第一章
本章内容如下: 5种网络I/O模型的介绍 I/O多路复用的介绍 1.I/O基础入门在Java1.4之前,Java对I/O的支持不完善,开发人员在开发高性能I/O的程序时,会面临以下问题: 没有数据缓 ...
《Netty权威指南第2版》学习笔记（1）---服务端与客户端开发入门
前言 Netty权威指南中以时间服务器为入门案例,演示了如何通过Netty完成了服务端与客户端之间的交互过程. 在开始使用Netty开发之前,先回顾一下使用NIO进行服务端开发的步骤. 创建Serve ...
[201504][Netty 权威指南][第2版][李林锋][著]
[201504][Netty 权威指南][第2版][李林锋][著] https://github.com/wuyinxian124/nettybook2 基础篇走进 Java NIO 第 1 章 J ...

netty权威指南-第三章——netty入门应用

3.2 Netty 服务端开发

3.3 Netty 客户端开发

netty权威指南-第三章——netty入门应用相关推荐

最新文章

热门文章