用户手册快速有效的网络应用开发

1、Netty3.2 快速有效的网络应用开3.2.4.Final 译者LarryZhang 二次整理1. 问题提2. 解决方1. 开1.1Netty3.2 快速有效的网络应用开3.2.4.Final 译者LarryZhang 二次整理1. 问题提2. 解决方1. 开1.1. 写在开始之. 1.3. Received. . . 1.7处理基于流的传 1.7.1套接字缓存（SocketBuffer）的一个小警 1.7.2. 第一个解决办 1.7.3. 第二个解决办 1.8. POJO1.9. 关闭应用程 1.10. 2. 架构概2.1丰富的缓存数据结I/O2.3. 基 2.4. 2.4.1. 编码框2

2、.4.2SSLTLS 支2.4.3HTTP实ProtocolBuffer集2.5. 总前1问题提常常使用2.4. 2.4.1. 编码框2.4.2SSLTLS 支2.4.3HTTP实ProtocolBuffer集2.5. 总前1问题提常常使用HTTP客户从WEB服务器上获不适用通用的 的 多2解决方 高 Chapter1开1.1. 开始之. 1.3. Received. . . 1.7处理基于流的传 1.7.1套接字缓存（SocketBuffer）的一个小警 1.7.2. 1.7.3. 1.8. POJO1.9关闭你的应用程 1.10. 这一章围绕Neey Chapter 2,架构概览开始，然后

3、再回到这里1.1. 开始之此。 API页面上。此外，记Netty并告1.2. 编写一个 Discard服个 ， ， 个 当一个异常因为I/O 错误由Netty 抛出，或者由在处理事件过程中，handler 的实现抛出了异常 ，并且对应channel应已经实现了 DISCARD 服务的一半。接下来需要写 main 方法来运行这个配备到此为import .InetSocketAddress; importjava.util.concurrent.Executors;publicclassDiscardServerpublicicvoidmain(Stringargs)throwsException

4、 new( Executors.newCachedThre 使用 建 和 ServerBootstrapbootstrap=newServerBootstrap bootstrap.setPipelineFactory(new publicChannelPipelinegetPipeline() bootstrap.setOption(child.keepAlive, true); 的 的 刚 问题是 着 buf = (ChannelBuffer) e.getMessage(); uf.readable() ln(char)buf.readByte(); 多个 。多个 。 le.discard

5、 包1.4. 编写一个 Echo服这。这里返回的Channel 代表收到消息事MessageEvent 的那个连接 1.5. 编写一个 Time服 ch = e.getChannel(); messageReceived 方法，而是需要重channelConnected 方法。代码如下 eEvente) Channelch=(System.currentTimeMillis() / 1000);ChannelFuturef= public 释过， 释过， 用 尚未发生的后续I/O操作ChannelFuture 为 importChannelBuffer dynamicBuf= 也返回 的 完成

6、后关Channel 1.6. Time客户需要一TIME 的 import .InetSocketAddress; importjava.util.concurrent.Executors;publicclassTimeC ntChannelch= NioServerSocketChannelFactoryC ntBootstrap 在客户端，对应服务器端的ServerBootstrap publicicvoidmain(Stringargs)throwsString host=port new( Executors.newCachedThrentBootstrapbootstrap=newn

7、tBootstrap bootstrap.setPipelineFactory(new publicChannelPipelinegetPipeline()returnChannels.pipeline(newTimeC bootstrap.setOption(keepAlive, true);(new InetSocketAddress(host, 应该connect方法而不是bind 方法应该connect方法而不是bind 方法 收 看上去真的很简单，并且和服务器端代码没什么区别。不过，这个 IndexOutOfBoundsExceptionimport publicclassTimeC

8、 long currentTimeMillis = buf.read() * 1000L;ln(newDate(currentTimeMillis); e.getCause().pr1.7. 处理基于流的传1.7.1. 1.7. 处理基于流的传1.7.1. 1.7.2. 现在TIME例子个 |ABC|DEF|GHI|AB |CDEFG|H|I|ABC|DEF|GHITimeC importimport publicclassTimeC privatefinalChannelBufferbuf= ifytes()=4)long currentTimeMillis = buf.read() * 1

9、000L; ln(newDate(currentTimeMillis); 这个动态的缓存是能够根据需要增加容量ChannelBuffer 。这这个动态的缓存是能够根据需要增加容量ChannelBuffer 。这首先，所有收到的数据都必须汇聚到buf中 1.7.3. 你可能也注意到，你可以增加多个 ChannelHandler 给 ChannelPipeline，由此，你可以拆分单ChannelHandler 为多个模块化的 handler 来减少你的应用程序的复杂度。 例如， 你可以拆分TimeC TimeDecoder 处理字节重最初那个简单的TimeC publicclassTimeDec

10、oderextendsprotectedObject FrameDecoder ChannelHandler 的一个实现，使得处理重组问题简单FrameDecoder调用decode方法，收到新的数据时FrameDecoder ChannelHandler 的一个实现，使得处理重组问题简单FrameDecoder调用decode方法，收到新的数据时如果返回的是null 以为这收到的数据还FrameDecoder 会在数据量足够的时候再次调用 了一个消息。FrameDecoder 会丢弃位于 直至返null已经有了另一个 handler 可以现在到 ChannelPipeline应该修TimeC

11、 nt ChannelPipelineFactory 实现 API手册以获bootstrap.setPipelineFactory(new publicChannelPipelinegetPipeline() newTimeC ifytes()returnreturn此外，Netty 提供了一些“开箱即用”此外，Netty 提供了一些“开箱即用” net针对的是基于行的文本协1.8. POJO 、可复用。在这个ITME客户端、服务器端的例子中只 protectedObjecte)returnprotectedObject if (buffer.readabytes()4) return nul

12、l;import publicprivatepublic this.value=returnpublicStringtoString()returnnewDate(value* 的方法后，TimeC 是不是看上去更简单、 更优雅了？ 同样的技术可以用于服务器端这次先更新一 下现在唯一缺少的就是编了。 这个编应该是一个把 ChannelBuffer 转换为 UnixTime UnixTimetime=newUnixTime(System.currentTimeMillis()/ChannelFuturef=e.getChannel().write(time); UnixTimem=(UnixTi

13、me)e.getMessage(); System.out.pr ln(m); returnnew编一个写入的请求。请注意MessageEvent 参数编一个写入的请求。请注意MessageEvent 参数和messageReceived的是同一类型，但是却有不同的解读。一个ChannelEvent 可以是上行或下行件，这取决于事件的传递方向。比如，MessageEvent在messageReceived中是上行事件，但是区 新的 中的前一个 用 importimport publicvoidwriteRequested(ChannelHandlerContextctx,UnixTimetim

14、e=(UnixTime) 的 1.9. 关闭应用的 1.9. 关闭应用程 字 如果在 TimeC nt 应用这三步, 关闭唯一的客户端连接所有 ChannelFactory 持有的资 publicclassTimeC ntpublicicvoidmain(Stringargs)throwsException ChannelPipelin peline=write(ctx, e.getFuture(), buf); 。 ChannelFuture 的getCause() 待 的 需要一所有活动连接的数据结构，这可不是琐碎的小事儿一桩。还好，有一个办法，那就ChannelGroupChannelF

15、uturefuture=bootstrap.connect(.); ifs()future.getCause().pr ChannelGroup代表打开Channel的集合JavacollectionAPI的特殊扩展。如果一个ChannelGroup代表打开Channel的集合JavacollectionAPI的特殊扩展。如果一个Channel入了 ChannelGroup， 然后这个 Channel 被关闭了， 那么这个关闭的 Channel 会自动从它的ChannelGroup 中移除。你可以对一个组执行一个操作，却作用于所有属于同一个组的Channel。比如你可以在停止服务器的时候，关闭

16、一ChannelGroup内所有的ChannelTimeServerHandler ChannelGroup( TimeServer.allChannels)添加一个新的ChannelGroup 是线程安全的这下所有的启用Channel都自动publicclassTimeServer publicicvoidmain(Stringargs)throwsException Channelchannel=bootstrap.bind(.); ServerBootstrap的bind 方法返回了一个服 ServerBootstrap的bind 方法返回了一个服务器端的、绑定了指定本地地址的Chann

17、el。调返回的Channelclose()方法可以使得它和绑定的本地地址解除绑定 的 包括绑定的服务Channel 会解除绑定，所有的受理的连接会被异步地关闭得到所有连 1.10. 总 区 一直都在期待Chapter2架构概. I/O2.3. 基2.4. 为更快捷开发的高级组2.4.1. 编码框2.4.2SSLTLS 支2.4.3HTTP 实ProtocolBuffer集2.5. 总2.4.2SSLTLS 支2.4.3HTTP 实ProtocolBuffer集2.5. 总。2.1. 丰富的 Buffer数据结 如果必要，你可以定义你buffer 再也不需flip() 了 ByteBuffer速

18、度ty.buffer 包描述I/OJava 中传统的 I/O API为不同的传输类型提供了不同的类型和方法。例如， .Socket ty.buffer 包描述I/OJava 中传统的 I/O API为不同的传输类型提供了不同的类型和方法。例如， .Socket 候就确定你的而应用程序基于哪套API 的API提供了很多重要的传输方式 另一种 替换掉几行构造方法的代码。此外2.3基者链模式的事件模2.3基者链模式的事件模 针对 ChannelEventChannelPipeline中的ChannelHandler来处理。pipeline实现了一 ercepting Filter模式的高级形式，使得用户可以完全控制事件是如何被处理的、handler之间如 public class MyWriteHandler implements SimpleChannelHandler Objectmessage=/Dosomethingwit