![路线提升篇netty in action中文版第四章transports传输_第1页](http://file4.renrendoc.com/view/81738648a43147eb6511b13ed3e3d3b0/81738648a43147eb6511b13ed3e3d3b01.gif)
![路线提升篇netty in action中文版第四章transports传输_第2页](http://file4.renrendoc.com/view/81738648a43147eb6511b13ed3e3d3b0/81738648a43147eb6511b13ed3e3d3b02.gif)
![路线提升篇netty in action中文版第四章transports传输_第3页](http://file4.renrendoc.com/view/81738648a43147eb6511b13ed3e3d3b0/81738648a43147eb6511b13ed3e3d3b03.gif)
版权说明:本文档由用户提供并上传,收益归属内容提供方,若内容存在侵权,请进行举报或认领
文档简介
1、NettyInAction章:Transports(传输本章内Transports(传输NIO(non-blocking IIO), OIO(Old IO,blocking IO), Local(本地), Embedded(APIs(接口网络应用程序一个很重要的工作是传输数据。传输数据的过程不一样取决是使用哪种交通工具,但是传输的方式是一样的:都是以字节码传输。Java开发网络程序传输数据的过程和方式是被抽象了的, 不需要关注底层接口,只需要使用JNettyInAction章:Transports(传输本章内Transports(传输NIO(non-blocking IIO), OIO(Old
2、 IO,blocking IO), Local(本地), Embedded(APIs(接口网络应用程序一个很重要的工作是传输数据。传输数据的过程不一样取决是使用哪种交通工具,但是传输的方式是一样的:都是以字节码传输。Java开发网络程序传输数据的过程和方式是被抽象了的, 不需要关注底层接口,只需要使用Java PI或其他网络框架如etty就能达到传输数据的目的。发送数据和接收数据都是字节码。otigore,otigess。本章将介绍 的PI以及如何使用它们,会拿etty的PI和Java的PI做比较来告诉你为什么etty可以更容易的使用。本章也提供了一些优质的用例代码,以便最佳使用etty。使用
3、etty不需要其他的网络框架或网络编程经验,若有则只是对理解etty有帮助,但不是必要的。下面让 来看看真是世界里的传输工作。案例研究:切换传输方为了让你想象如,我会从一个简单的应用程序开始,这个应用程序什么都不做,只是接受客户端连接并发送“Hi!”字符串消到客户端,发送完了就断开连接。我不会详细讲解这个过程的实现,它只是一个例子使用Java的I/O和不用Netty实现这个例子,下面代码是使用阻塞IO实现的例子package import import import import import * Blocking networking without * author *public cla
4、ss PlainOioServer public void port) throws Exception /bind server to final ServerSocket socket = new try /accept final Socket ntSocket = ln(Accepted connection from + /create new thread to handle new Thread(new Runnable() 目录案例研究切换传输方使用Java的IO和Netty中使用IO和Netty中实现异步支Transport Netty包含的传输实NIO - Nonblock
5、ing OIO -Old blocking Local- InVM Embedded每种传输方式在什么时候使public void run() OutputStream out = /write message to connected 上面的方式很简洁,但是这种阻塞模式在大连接数的情况就会有很严,如客户端连接超时,服务器响应严重延迟。为了解决种情况可以使用异步网络处理所有的并发连接,但问题在于NIO和OIO的API是完全不同的,所以一个用OIO开发的网络应用程想要使用NIO重构代码几public void run() OutputStream out = /write message to
6、connected 上面的方式很简洁,但是这种阻塞模式在大连接数的情况就会有很严,如客户端连接超时,服务器响应严重延迟。为了解决种情况可以使用异步网络处理所有的并发连接,但问题在于NIO和OIO的API是完全不同的,所以一个用OIO开发的网络应用程想要使用NIO重构代码几乎是重新开发下面代码是使用Java NIO实现的例package import import import import import import import import * Asynchronous networking without * author *public class PlainNioServer pub
7、lic void port) throws Exception ln(Listening for connections on port + /open ndles Selector selector = /open ServerSocketChannel serverChannel = /get ServerSocket serverSocket = /bind server to serverSocket.bind(new /set to non-/register ServerSocket to selector and t it erested in new accepted serv
8、erChannel.register(selector, final ByteBuffer msg = while (true) /Wait for new t are ready for s. This will block until something n = if (n 0) /Obtain all SelectionKey t received Iterator iter = while (iter.hasNext() SelectionKey key = try /Check if event was because new nt ready to get out.write(Hi
9、!rn.getBytes(Charset.forName(UTF-/close connection once message written and catch(IOException try catch (IOException e1) ).start();/start thread to begin catch(Exception if (key.isAcceptable() ServerSocketChannel server = (ServerSocketChannel) SocketChannel nt = ln(Accepted connection from + /Accept
10、 nt and register it to nt.register(selector, SelectionKey.OP_WRITE, /Check if event was because socket is ready to write if (key.isWritable() SocketChannel nt = (SocketChannel) if (key.isAcceptable() ServerSocketChannel server = (ServerSocketChannel) SocketChannel nt = ln(Accepted connection from +
11、/Accept nt and register it to nt.register(selector, SelectionKey.OP_WRITE, /Check if event was because socket is ready to write if (key.isWritable() SocketChannel nt = (SocketChannel) ByteBuffer buff = (ByteBuffer) /write o connected while (buff.hasRemaining() if nt.write(buff) = 0) nt.close();/clos
12、e catch (Exception e) 如你所见,即使它们实现的功能是一样,但是代码完全不同。下用Netty来实现相同的功能4.1.2 Netty中使用I/O和下面代码是使用Netty作为网络框架编写的一个阻塞IOpublic ettyOioServer public void port) throws Exception final ByteBuf buf = uffer(Unpooled.copiedBuffer(Hi!rn, /事件循环EventLoopGroup group = new try /用来引导服务器配ServerBootstrap b = new /使用OIO阻塞模ew
13、 /指定ChannelInitializer初始化.childHandler(new ChannelInitializer() protected void initChannel(Channel ch) throws Exception /添加一个“入站”handler到ch.pipeline().addLast(new ChannelInboundHandlerAdapter() public void channelActive(ChannelHandlerContext ctx) throws Exception /连接后,写消息到客户端,写完后便关闭连package netty.in
14、.action; import .InetSocketAddress; import import import import import import import import import import import import import ty.util.CharsetUtil; /绑定服务器接受连ChannelFuture f = catch (Exception e) 所有资上面代码实现功能一样,但结构清晰明了,这只是Netty的优势之一4.1.3 Netty中实现异步支持下面代码是使用Netty实现异步,可以看出/绑定服务器接受连ChannelFuture f = catc
15、h (Exception e) 所有资上面代码实现功能一样,但结构清晰明了,这只是Netty的优势之一4.1.3 Netty中实现异步支持下面代码是使用Netty实现异步,可以看出使用Netty由OIO切换到NIO是非常的方便public ettyNioServer public void port) throws Exception final ByteBuf buf = Hi!rn, / 事件循环EventLoopGroup group = new try / 用来引导服务器配ServerBootstrap b = new / 使用NIO异步模ew / 指定ChannelInitializ
16、er初始化.childHandler(new ChannelInitializer() protected void initChannel(SocketChannel ch) throws Exception / 添加一个“入站”handler到ChannelPipeline ch.pipeline().addLast(new ChannelInboundHandlerAdapter() public void channelActive(ChannelHandlerContext ctx) throws Exception / 连接后,写消息到客户端,写完后便关闭连/ 绑定服务器接受连Ch
17、annelFuture f = catch (Exception e) 所有资因为Netty使用相同的API来实现每个传输,它并不关心你使用什么来实现。Netty通过操作Channel接口和ChannelPipelineChannelHandler来实现传输4.2 Transport 传输API是Channel接口,它用于所有出站的操作。Channel接口的类层次结构如package netty.in.action; import import import import import import import import import import import import impor
18、t ty.util.CharsetUtil; import .InetSocketAddress; 如上图所示,每个Channel都会分配一个ChannelPipeline和ChannelConfig。ChannelConfig负责设置配置,并允许在运行期间更它们。传输一般有特定的配置设置,只作用于传输,没有其他的实现。ChannelPipeline容纳了使用的ChannelHandler实例,这如上图所示,每个Channel都会分配一个ChannelPipeline和ChannelConfig。ChannelConfig负责设置配置,并允许在运行期间更它们。传输一般有特定的配置设置,只作用于
19、传输,没有其他的实现。ChannelPipeline容纳了使用的ChannelHandler实例,这 现可以使用ChannelHandler做下面一些事情传输数据时,将数据从一种格式转换到另异常Channel变为有效或无效时获得通Channel或从EventLoop中注销时获得通通知用户特定事这些ChannelHandler实例添加到ChannelPipeline中,在ChannelPipeline中按顺序逐个执行。它类似于一个链条,有使用过Servlet读者可能会更容易理解ChannelPipeline实现过滤器模式,这意味连接不同的ChannelHandler并处理经过ChannelPip
20、eline的数据或件。可以把ChannelPipeline想象成UNIX管道,它允许不令链(ChannelHandler相当于命令)。你还可以在运行时根据需要添ChannelHandler实例到ChannelPipeline或从ChannelPipeline中删除,这能帮构建高度灵活的Netty程序。此外指定ChannelPipeline和ChannelConfig,你能在Channel自身上进行操作。Channel提供了很多方法,如下列eventLoop(),返回分配给Channel的pipeline(),返回分配给Channel的iive(),返回Channel是否激活,已激活说明连接对l
21、ocalAddress(),返回已绑定的本地remoteAddress(),返回write(),写数客户端,数据通过ChannelPipeline传输过后面会越来越熟悉这些方法,现在只需要记的操作都是在相同的接口上运行,Netty的高灵活性让你可以以不同的传输实现进行构写数据已连接客户端可以调用Channel.write()方法,如下代码Channel channel = /Create t holds o ByteBuf buf = Unpooled.copiedBuffer(your data, /Write ChannelFuture cf = /Add ChannelFutureLis
22、tener to get notified after write cf.addListener(new ChannelFutureListener() public plete(ChannelFuture future) /Write operation completes without if cs() ln(.Write else /Write operation completed but because of ln(.Write ae是线程安全(trea-safe)的,它可以被多个不同ae是线程安全(trea-safe)的,它可以被多个不同的线程安全的操作,在多线程环境下,所有的方法
23、都是安全的。正因为 ae是安全的,对Cae的,并在学习的时候使用它写入数据到已连接的客户端,使用多线程也是如此。下面代码是一个简单的多线程例子:final Channel channel = /Create t holds o final ByteBuf buf = Unpooled.copiedBuffer(your /Create Runnable which writes o Runnable writer = new Runnable() public void run() /Obtain reference to the Executor which uses threads to
24、execute Executor executor = / write in one /Hand over write task to executor for / write in another /Hand over another write task to executor for 此外,这种方法保证了写入的消息以相同的顺序通过写入它们的方法。想了解所有方法的使用可以参考Netty API4.3 Netty包含的传输实etty自带了一些传输协议的实现,虽然没有支持所有的传输协议,但是其自带的已足够来使用。etty应用程序的传输协议赖于底层协议,本节学习etty中的传输协议。Netty中
25、的传输方式有如下几种 Eee,io.ett.cae.eee,嵌入传输,它允许在没有真正网络的中使用aeaer,可以非常有用的来测试aeaer的实现。4.3.1NIO-NonblockingNIO传输是目前最常用的方式,它通过使用选择器提供了完全异步的方式操作所有的I/O,NIO从Java 1.4才被提供。NIO中一个通道或获得某个通道的改变的状态,通道状态有下面几种改变一个新的Channel被接受并已准备Channel连接完处理完改变的状态后需重新设置他们的状态,用一个线程来检查是否有已准备好的ae,如果有则执行相关事件。在这里可能只同时一个的事件而忽略其他的。选择器所支持的操作在SeectioKey中定义,具体如下:OP_WRITE,写入数据到通道时得到通Netty中的NIO传输就是基于这样的模型来接收和发送数据,通过封装将自己的接口提供给用户使用,这完全隐藏实
温馨提示
- 1. 本站所有资源如无特殊说明,都需要本地电脑安装OFFICE2007和PDF阅读器。图纸软件为CAD,CAXA,PROE,UG,SolidWorks等.压缩文件请下载最新的WinRAR软件解压。
- 2. 本站的文档不包含任何第三方提供的附件图纸等,如果需要附件,请联系上传者。文件的所有权益归上传用户所有。
- 3. 本站RAR压缩包中若带图纸,网页内容里面会有图纸预览,若没有图纸预览就没有图纸。
- 4. 未经权益所有人同意不得将文件中的内容挪作商业或盈利用途。
- 5. 人人文库网仅提供信息存储空间,仅对用户上传内容的表现方式做保护处理,对用户上传分享的文档内容本身不做任何修改或编辑,并不能对任何下载内容负责。
- 6. 下载文件中如有侵权或不适当内容,请与我们联系,我们立即纠正。
- 7. 本站不保证下载资源的准确性、安全性和完整性, 同时也不承担用户因使用这些下载资源对自己和他人造成任何形式的伤害或损失。
最新文档
- 汽车电喷产品商业计划书
- 低功率气动阀岛用控制阀产品相关项目建议书
- 电子商务论文-动漫行业网络营销
- 2024《成长的烦恼》课件
- 3“贝”的故事 公开课一等奖创新教学设计
- 黑龙江省鸡西市第十六中学2023-2024学年中考冲刺卷英语试题含答案
- 河南省鹿邑城郊乡阳光中学2023-2024学年中考英语仿真试卷含答案
- 2024年计划生育个人工作总结经典版(三篇)
- (完整)初二英语完形填空专项练习(10篇)
- 2024年经理述职报告模版(三篇)
- 新版北师大版数学六年级上册全册课件(新版)
- 急救知识安全课程课件
- 小学国韵书香第六册《诗经》原文节选及注释《鼹鼠的月亮河》导读课课件
- 2022中信银行总行授信审批部招聘人员模拟试题3套(含答案解析)
- SL 537-2011 水工建筑物与堰槽测流规范
- 标准直齿圆柱齿轮公法线长度数值表
- 电焊工培训(基础知识)课件
- 自我同情量表
- 拟投入本工程的主要施工机械及设备表
- DB13-T 3032-2022 水利工程建设质量检测管理规范
- 新修订高中生物课程标准及核心素养解读课件
评论
0/150
提交评论