运用异步输入输出流编写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 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!

分享到：更多

你可能对下面的文章感兴趣

还�

上一篇: Java数据库连接池原理机制详解 - 编程入门网下一篇: Java编程技巧：列表排序 - 编程入门网

关于运用异步输入输出流编写Socket进程通信 - 编程入门网的所有评论

随机推荐