运用异步输入输出流编写Socket进程通信 - 编程入门网
作者 佚名技术
来源 NET编程
浏览
发布时间 2012-06-22
| ose (); this.selector.close(); } //将读入字 节缓冲的信息解码 public String decode( ByteBuffer byteBuffer ) throws CharacterCodingException { Charset charset = Charset.forName( "ISO-8859-1" ); CharsetDecoder decoder = charset.newDecoder(); CharBuffer charBuffer = decoder.decode( byteBuffer ); String result = charBuffer.toString(); return result; } //监听端口，当通道准备好时进行相应操作 public void portListening() throws IOException, InterruptedException { //服务器端通道注册OP_ACCEPT事件 SelectionKey acceptKey =this.serverChannel.register( this.selector, SelectionKey.OP_ACCEPT ); //当有已 注册的事件发生时,select()返回值将大于0 while (acceptKey.selector().select() > 0 ) { System.out.println("event happened"); //取 得所有已经准备好的所有选择键 Set readyKeys = this.selector.selectedKeys(); //使用迭代器对选择键进 行轮询 Iterator i = readyKeys.iterator(); while (i.hasNext()) { SelectionKey key = (SelectionKey)i.next(); i.remove();//删除当前将要 处理的选择键 if ( key.isAcceptable() ) {//如果是 有客户端连接请求 System.out.println ("more client connect in!"); ServerSocketChannel nextReady = (ServerSocketChannel)key.channel(); //获取客 户端套接字 Socket s = nextReady.accept(); //设置对应的通道为异步方式并注册感兴趣事件 s.getChannel().configureBlocking( false ); SelectionKey readWriteKey = s.getChannel().register( this.selector, SelectionKey.OP_READ|SelectionKey.OP_WRITE ); //将注册的事件与该套接字联系起来 readWriteKey.attach( s ); //将当前建立连接的客户端套接字及对应的通道存放在哈希 表//clientChannelMap中 this.clientChannelMap.put( s, new ClientChInstance( s.getChannel () ) ); } else if ( key.isReadable() ) {//如果是通道读准备好事件 System.out.println("Readable"); // 取得选择键对应的通道和套接字 SelectableChannel nextReady = (SelectableChannel) key.channel(); Socket socket = (Socket) key.attachment(); //处理该 事件，处理方法已封装在类ClientChInstance中 this.readFromChannel( socket.getChannel(), (ClientChInstance) this.clientChannelMap.get( socket ) ); } else if ( key.isWritable() ) {// 如果是通道写准备好事件 System.out.println ("writeable"); //取得套接字后处理， 方法同上 Socket socket = (Soc |
凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢! |
你可能对下面的文章感兴趣
关于运用异步输入输出流编写Socket进程通信 - 编程入门网的所有评论
