 |
|
|
 首页 |
名片设计 CorelDRAW Illustrator AuotoCAD Painter 其他软件 Photoshop Fireworks Flash |
|
四、注册与处理过程详解 接下来我们要分析Connection的register()方式。前面我们总是说用Selector注册的连接，其实这是一种简化的说法。实际上，用Selector注册的是一个java.nio.channels.SocketChannel对象，但只针对特定的I/O操作。注册之后，有一个 java.nio.channels.SelectionKey被返回。这个选择键可以通过attach()方式关联到任意对象。为了通过键获得连接，这里把Connection对象关联到键。这样，我们就可以从Selector间接地获得一个Connection。 public void register(Selector selector) throws IOException { key = socketChannel.register(selector, SelectionKey.OP_READ); key.attach(this); } 回过头来看ConnectionSelector。select()方式的返回值表示有多少连接已经做好了I/O操作的预备。假如返回值是0，则返回；否则，调用selectedKeys()获得键的集合（Set），从这些键获得以前关联的Connection对象，然后调用其 readRequest()或writeResponse()方式，详细调用哪一个方式由连接被注册为读取操作还是写入操作决定。 现在再来看Connection类。Connection类代表着连接，处理所有协议有关的细节。在构造函数中，通过参数传入的 SocketChannel被设置成非阻塞模式，这对于服务器来说是很重要的。另外，构造函数还设置了一些默认值，分配了缓冲区 requestLineBuffer。由于分配直接缓冲区代价稍高，且这里的每一个连接都用一个新的缓冲区，因此这里使用 java.nio.ByteBuffer.allocate()而不是ByteBuffer.allocateDirect()。假如重用缓冲区，直接缓冲区可能具有更高的效率。 public Connection(SocketChannel socketChannel) throws IOException { this.socketChannel = socketChannel; ... socketChannel.configureBlocking(false); requestLineBuffer = ByteBuffer.allocate(512); ... } 完成所有初始化工作且SocketChannel做好了读取预备之后，ConnectionSelector调用了readRequest()方式，利用socketChannel.read(requestLineBuffer)方式把所有可用的数据读入缓冲区。假如不能读取完整的行，则返回发出调用的ConnectionSelector，答应另一个连接进入处理过程；反之，假如成功地读取了整个行，接下来应该做的是象在Httpd中相同解析哀求。假如当前的哀求合法，程序为哀求目标文件创建一个java.nio.Channels.FileChannel，并调用 prepareForResponse()方式。 private void prepareForResponse() throws IOException { StringBuffer responseLine = new StringBuffer(128); ... responseLineBuffer = ByteBuffer.wrap( responseLine.toString().getBytes("ASCII") ); key.interestOps(SelectionKey.OP_WRITE); key.selector().wakeup(); } prepareForResponse()方式构造出缓冲区responseLine以及（假如必要的话）应答头或错误信息，并把这些数据写入 responseLineBuffer。这个ByteBuffer是一个byte数组的简朴的封装器。生成待输出的数据之后，我们还要通知 ConnectionSelector：从现在开始不再读取数据，而是要写入数据了。这个通知通过调用选择键的interestedOps (SelectionKey.OP_WRITE)方式完成。为了保证选择器能够快速熟悉到连接操作状态的变化，接着还要调用wakeup()方式。接下来 ConnectionSelector调用连接的writeResponse()方式。首先，responseLineBuffer被写入到Socket 管道。假如缓冲区的内容全部被写入，而且还有被哀求的文件需要发送，接着调用前面打开的FileChannel的transferTo()方式。 transferTo()方式通常能够高效地把数据从文件传输到管道，但实际的传输效率依靠于底层的操作系统。任何时候，被传输的数据量至多相称于在无阻塞的情况下可写入目标管道的数据量。为安全和确保各个连接之间的公平起见，这里把上限设置成64 KB。 假如所有数据都已经传输完毕，close()执行清理工作。取消Connection的注册是这里的主要任务，详细通过调用键的cancel()方式完成。 public void close() { ... if (key != null) key.cancel(); ... } 这个新的方案性能如何呢？答案是肯定的。从原理上看，一个Acceptor和一个ConnectionSelector足以支持任意数量的打开的连接。因此，新的实现方案在可伸缩性方面占有优势。但是，由于两个线程必须通过同步的queue()方式通信，它们可能互相阻塞对方。解决这个问题有两种途径： ・改进实现队列的方式 ・采用多个Acceptor/ConnectionSelector对 与Httpd相比，NIOHttpd的一个缺点是，对于每一个哀求，就有一个新的带缓冲的Connection对象被创建。这就导致了垃圾收集器产生的额外的CPU占用，这部分附加代价的详细程度又与VM的类型有关。然而，Sun不厌其烦地强调说，有了Hotspot，短期生存的对象不再成为问题。 五、可伸缩性的定量分析和比较 在可伸缩性方面，NIOHttpd到底比Httpd好多少？下面我们来看看详细的数字。首先要声明的是，这里的数字具有大量的推测成分，一些重要的环境因素，例如线程同步、上下文切换、换页、硬盘速度和缓冲等，都没有考虑到。首先评估处理r个并发的哀求需要多少时间，假设被哀求的文件大小是s字节，客户端的带宽是b字节/秒。对于Httpd，这个时间显然直接依靠于线程的数量t，因为同一时刻只能处理t个哀求。所以Httpd的处理时间可以从公式一得到，其中c是执行哀求分析之类操作的开销常量，这个值对于每一个哀求来说都是相同的。另外，这里假定从磁盘读取数据的速度总是快于写入Socket的速度，服务器带宽总是大于客户机带宽之和，且CPU未满载。因此，服务器端的带宽、缓冲和硬盘速度等因素都不必在该公式中考虑。 然而，NIOHttpd的处理时间不再依靠于t。对于NIOHttpd，传输时间l在很大程度上依靠于客户端的带宽b、文件大小s以及前面提到的常数c。由此可以得出公式二，从该公式可以得到NIOHttpd的最小传输时间。 注重公式三的比值d，它度量了NIOHttpd和Httpd的性能对比关系。 进一步的分析表明，假如s、b、t和c是常数，r 趋向无穷时d的增长趋向于一个极限，从公式四可以方便地计算出这个极限。 因此，除了线程的数量和常量性的开销，连接的时长s/b对d具有极端重要的影响。连接持续的时间越长，d值越小，NIOHttpd对比Httpd的优势也就越高。表一显示出，当c=10ms，t=100，s=1mb，b=8kb/s时，NIOHttpd要比Httpd快126倍。假如连接持续了很长一段时间，NIOHttpd表现出巨大的优势。当连接时间较短时，例如在100 Mb的局域网内，假如文件较大，NIOHttpd表现出10%的优势；假如文件较小，优势不明显。 返回类别: 教程 上一教程: 实现 Java 平台的三种方法 下一教程: 详解J2EE的13种核心技术 您可以阅读与"Java I/O API之性能分析 (下)"相关的教程: · Java I/O API之性能分析 · Java I/O API之性能分析 (上) · Java API的Date, Calendar日期处理相关类分析 · Java 编程技术中汉字问题的分析及解决 · Java访问数据库的速度瓶颈问题的分析及解决 |
  |
| 快精灵印艺坊 版权所有 |
首页 会员中心在线印刷在线编辑付款方式索取样品设计指南连锁门店
|
||
