快速业务通道

运用异步输入输出流编写Socket进程通信 - 编程入门网

作者 佚名技术 来源 NET编程 浏览 发布时间 2012-06-22
工作方式。与以前版本的API相 比较,ServerSocketChannel就相当于ServerSocket(ServerSocketChannel封装 了ServerSocket),而SocketChannel就相当于Socket(SocketChannel封装了 Socket)。当通道工作在同步方式时,编程方法与以前的基本相似,这里主要介 绍异步工作方式。

所谓异步输入输出机制,是指在进行输入输出处理时 ,不必等到输入输出处理完毕才返回。所以异步的同义语是非阻塞(None Blocking)。在服务器端,ServerSocketChannel通过静态函数open()返回一个 实例serverChl。然后该通道调用serverChl.socket().bind()绑定到服务器某端 口,并调用register(Selector sel, SelectionKey.OP_ACCEPT)注册 OP_ACCEPT事件到一个选择器中(ServerSocketChannel只可以注册OP_ACCEPT事 件)。当有客户请求连接时,选择器就会通知该通道有客户连接请求,就可以进 行相应的输入输出控制了;在客户端,clientChl实例注册自己感兴趣的事件后 (可以是OP_CONNECT,OP_READ,OP_WRITE的组合),调用clientChl.connect (InetSocketAddress )连接服务器然后进行相应处理。注意,这里的连接是异步 的,即会立即返回而继续执行后面的代码。

运用异步输入输出流编写Socket进程通信(2)

时间:2010-12-14 杨健

选择器和选择键介绍:

选择器(Selector)的作用是:将通道感兴趣的事件放入队列中,而不 是马上提交给应用程序,等已注册的通道自己来请求处理这些事件。换句话说, 就是选择器将会随时报告已经准备好了的通道,而且是按照先进先出的顺序。那 么,选择器是通过什么来报告的呢?选择键(SelectionKey)。选择键的作用就是 表明哪个通道已经做好了准备,准备干什么。你也许马上会想到,那一定是已注 册的通道感兴趣的事件。不错,例如对于服务器端serverChl来说,可以调用 key.isAcceptable()来通知serverChl有客户端连接请求。相应的函数还有: SelectionKey.isReadable(),SelectionKey.isWritable()。一般的,在一个循 环中轮询感兴趣的事件(具体可参照下面的代码)。如果选择器中尚无通道已注 册事件发生,调用Selector.select()将阻塞,直到有事件发生为止。另外,可 以调用selectNow()或者select(long timeout)。前者立即返回,没有事件时返 回0值;后者等待timeout时间后返回。一个选择器最多可以同时被63个通道一起 注册使用。

应用实例:

下面是用异步输入输出机制实现的客户/ 服务器实例程序清单(限于篇幅,只给出了服务器端 实现,读者可以参照着实现客户端代码):

程序类图

运用异步输入输出流编写Socket进程通信 - 编程入门网

程序清单1

public class NBlockingServer {   int port = 8000;   int BUFFERSIZE = 1024;   Selector selector = null;   ServerSocketChannel serverChannel = null;    HashMap clientChannelMap = null;//用来存放每一个客户连接对应的套接字和 通道      public NBlockingServer( int port ) {      this.clientChannelMap = new HashMap();     this.port = port;   }      public void initialize() throws IOException {    //初始化,分别实例化一个选择器,一个服务器端 可选择通道    this.selector = Selector.open();     this.serverChannel = ServerSocketChannel.open();     this.serverChannel.configureBlocking(false);    InetAddress localhost = InetAddress.getLocalHost();    InetSocketAddress isa = new InetSocketAddress(localhost, this.port );     this.serverChannel.socket().bind(isa);//将该套接字绑定到服务器某一可用 端口   }   //结束时释放资源   public void finalize() throws IOException {     this.serverChannel.cl

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务,公司网站:http://www.lingzhong.cn 为了给广大客户了解更多的技术信息,本技术文章收集来源于网络,凌众科技尊重文章作者的版权,如果有涉及你的版权有必要删除你的文章,请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息,谢谢!

分享到: 更多

Copyright ©1999-2011 厦门凌众科技有限公司 厦门优通互联科技开发有限公司 All rights reserved

地址(ADD):厦门软件园二期望海路63号701E(东南融通旁) 邮编(ZIP):361008

电话:0592-5908028 传真:0592-5908039 咨询信箱:web@lingzhong.cn 咨询OICQ:173723134

《中华人民共和国增值电信业务经营许可证》闽B2-20100024  ICP备案:闽ICP备05037997号