`
tianlijia202
  • 浏览: 78564 次
  • 性别: Icon_minigender_1
  • 来自: 大连
社区版块
存档分类
最新评论

Java NIO

    博客分类:
  • java
 
阅读更多

原文出自【比特网】,转载请保留原文链接:http://soft.chinabyte.com/database/470/12311470.shtml

 

 

package cn.nio;

  import java.io.IOException;

  import java.net.InetSocketAddress;

  import java.nio.ByteBuffer;

  import java.nio.channels.SelectionKey;

  import java.nio.channels.Selector;

  import java.nio.channels.ServerSocketChannel;

  import java.nio.channels.SocketChannel;

  import java.util.Iterator;

  /**

  * NIO服务端

  * @author 小路

  */

  public class NIOServer {

  //通道管理器

  private Selector selector;

  /**

  * 获得一个ServerSocket通道,并对该通道做一些初始化的工作

  * @param port 绑定的端口号

  * @throws IOException

  */

  public void initServer(int port) throws IOException {

  // 获得一个ServerSocket通道

  ServerSocketChannel serverChannel = ServerSocketChannel.open();

  // 设置通道为非阻塞

  serverChannel.configureBlocking(false);

  // 将该通道对应的ServerSocket绑定到port端口

  serverChannel.socket().bind(new InetSocketAddress(port));

  // 获得一个通道管理器

  this.selector = Selector.open();

  //将通道管理器和该通道绑定,并为该通道注册SelectionKey.OP_ACCEPT事件,注册该事件后,

  //当该事件到达时,selector.select()会返回,如果该事件没到达selector.select()会一直阻塞。

  serverChannel.register(selector, SelectionKey.OP_ACCEPT);

  }

  /**

  * 采用轮询的方式监听selector上是否有需要处理的事件,如果有,则进行处理

  * @throws IOException

  */

  @SuppressWarnings("unchecked")

  public void listen() throws IOException {

  System.out.println("服务端启动成功!");

  // 轮询访问selector

  while (true) {

  //当注册的事件到达时,方法返回;否则,该方法会一直阻塞

  selector.select();

  // 获得selector中选中的项的迭代器,选中的项为注册的事件

  Iterator ite = this.selector.selectedKeys().iterator();

  while (ite.hasNext()) {

  SelectionKey key = (SelectionKey) ite.next();

  // 删除已选的key,以防重复处理

  ite.remove();

  // 客户端请求连接事件

  if (key.isAcceptable()) {

  ServerSocketChannel server = (ServerSocketChannel) key

  .channel();

  // 获得和客户端连接的通道

  SocketChannel channel = server.accept();

  // 设置成非阻塞

  channel.configureBlocking(false);

  //在这里可以给客户端发送信息哦

  channel.write(ByteBuffer.wrap(new String("向客户端发送了一条信息").getBytes()));

  //在和客户端连接成功之后,为了可以接收到客户端的信息,需要给通道设置读的权限。

  channel.register(this.selector, SelectionKey.OP_READ);

  // 获得了可读的事件

  } else if (key.isReadable()) {

  read(key);

  }

  }

  }

  }

  /**

  * 处理读取客户端发来的信息 的事件

  * @param key

  * @throws IOException

  */

  public void read(SelectionKey key) throws IOException{

  // 服务器可读取消息:得到事件发生的Socket通道

  SocketChannel channel = (SocketChannel) key.channel();

  // 创建读取的缓冲区

  ByteBuffer buffer = ByteBuffer.allocate(10);

  channel.read(buffer);

  byte[] data = buffer.array();

  String msg = new String(data).trim();

  System.out.println("服务端收到信息:"+msg);

  ByteBuffer outBuffer = ByteBuffer.wrap(msg.getBytes());

  channel.write(outBuffer);// 将消息回送给客户端

  }

  /**

  * 启动服务端测试

  * @throws IOException

  */

  public static void main(String[] args) throws IOException {

  NIOServer server = new NIOServer();

  server.initServer(8000);

  server.listen();

  }

  }

 

客户端:

 

 

package

 

test;

 

import

 

java.io.IOException;

import

 

java.net.InetSocketAddress;

import

 

java.nio.ByteBuffer;

import

 

java.nio.channels.SelectionKey;

import

 

java.nio.channels.Selector;

import

 

java.nio.channels.SocketChannel;

import

 

java.util.Iterator;

 

/** * NIO客户端 *

@author

小路 */

public

 

class NIOClient {// 通道管理器private Selector selector;

 

/**

* * 获得一个Socket通道,并对该通道做一些初始化的工作 * //

@param ip 连接的服务器的ip * @param

port

* 连接的服务器的端口号 *

@throws

IOException

*/

publicvoid initClient(String ip, int port) throws IOException { //// 获得一个Socket通道

SocketChannel channel = SocketChannel.open();

// 设置通道为非阻塞

channel.configureBlocking(

false); // 获得一个通道管理器this.selector = Selector.open(); // 客户端连接服务器,其实方法执行并没有实现连接,需要在listen()方法中调// 用channel.finishConnect();才能完成连接

channel.connect(

new InetSocketAddress(ip, port));// 将通道管理器和该通道绑定,并为该通道注册SelectionKey.OP_CONNECT事件。

channel.register(

selector, SelectionKey.OP_CONNECT);

}

 

/**

* * 采用轮询的方式监听selector上是否有需要处理的事件,如果有,则进行处理 *

@throws

IOException

*/

// @SuppressWarnings("unchecked")publicvoid listen() throws IOException {// 轮询访问selectorwhile (true) { //// 选择一组可以进行I/O操作的事件,放在selector中,客户端的该方法不会阻塞,// 这里和服务端的方法不一样,查看api注释可以知道,当至少一个通道被选中时,// selector的wakeup方法被调用,方法返回,而对于客户端来说,通道一直是被选中的selector.select(); //// 获得selector中选中的项的迭代器

Iterator ite =

this.selector.selectedKeys().iterator();while (ite.hasNext()) {

SelectionKey key = (SelectionKey) ite.next();

// 删除已选的key,以防重复处理

ite.remove();

// 连接事件发生if (key.isConnectable()) {

SocketChannel channel = (SocketChannel) key.channel();

// 如果正在连接,则完成连接if (channel.isConnectionPending()) {

channel.finishConnect();

}

// 设置成非阻塞

channel.configureBlocking(

false);// 在这里可以给服务端发送信息哦

channel.write(ByteBuffer.wrap(

new String("向服务端发送了一条信息")

.getBytes()));

// 在和服务端连接成功之后,为了可以接收到服务端的信息,需要给通道设置读的权限。

channel.register(

this.selector, SelectionKey.OP_READ); // 获得了可读的事件

}

elseif (key.isReadable()) {

read(key);

}

}

}

}

 

/**

* * 处理读取服务端发来的信息 的事件 *

@param key * @throws

IOException

*/

publicvoid read(SelectionKey key) throws IOException {// 和服务端的read方法一样

}

 

/** * 启动客户端测试 * @throws IOException */publicstaticvoid main(String[] args) throws IOException {

NIOClient client =

new NIOClient();

client.initClient(

"localhost", 8000);

client.listen();

}

}


 

分享到:
评论

相关推荐

    java NIO和java并发编程的书籍

    java NIO和java并发编程的书籍java NIO和java并发编程的书籍java NIO和java并发编程的书籍java NIO和java并发编程的书籍java NIO和java并发编程的书籍java NIO和java并发编程的书籍java NIO和java并发编程的书籍java...

    JavaNIO chm帮助文档

    Java NIO系列教程(一) Java NIO 概述 Java NIO系列教程(二) Channel Java NIO系列教程(三) Buffer Java NIO系列教程(四) Scatter/Gather Java NIO系列教程(五) 通道之间的数据传输 Java NIO系列教程(六)...

    Java NIO英文高清原版

    Java NIO,全称为Non-Blocking Input/Output(非阻塞输入/输出),是Java平台中用于替代标准I/O(BIO)模型的一种新机制。NIO在Java 1.4版本引入,提供了更高效的数据处理和通道通信方式,特别适用于高并发、大数据...

    java NIO.zip

    Java NIO,全称为Non-Blocking Input/Output(非阻塞输入/输出),是Java标准库提供的一种替代传统的I/O模型的新技术。自Java 1.4版本引入NIO后,它为Java开发者提供了更高效的数据传输方式,尤其是在处理大量并发...

    java nio 包读取超大数据文件

    ### Java NIO 处理超大数据文件的知识点详解 #### 一、Java NIO简介 Java NIO(New IO)是Java平台上的新输入/输出流API,它提供了与传统IO(即Java IO)不同的数据处理方式。NIO在Java 1.4版本引入,并在后续版本...

    java NIO 视频教程

    Java NIO(New IO)是一个可以替代标准Java IO API的IO API(从Java 1.4开始),Java NIO提供了与标准IO不同的IO工作方式。 Java NIO: Channels and Buffers(通道和缓冲区) 标准的IO基于字节流和字符流进行操作的,...

    Java NIO 中文 Java NIO 中文 Java NIO 中文文档

    Java NIO 深入探讨了 1.4 版的 I/O 新特性,并告诉您如何使用这些特性来极大地提升您所写的 Java 代码的执行效率。这本小册子就程序员所面临的有代表性的 I/O 问题作了详尽阐述,并讲解了 如何才能充分利用新的 I/O ...

    java NIO技巧及原理

    Java NIO(New Input/Output)是Java标准库提供的一种I/O模型,它与传统的 Blocking I/O(IO)相比,提供了更加高效的数据传输方式。在Java NIO中,"新"主要体现在非阻塞和多路复用这两个特性上,这使得NIO更适合于...

    一个java NIO的例子

    Java NIO,全称为Non-Blocking Input/Output(非阻塞输入/输出),是Java标准库提供的一种替代传统I/O模型的新技术。在传统的Java IO模型中,读写操作是阻塞的,即当调用read或write方法时,线程会等待数据准备好或...

    java NIO实例

    Java NIO,全称为Non-Blocking Input/Output(非阻塞输入/输出),是Java从1.4版本开始引入的一种新的I/O模型,它为Java应用程序提供了更高效的数据传输方式。传统的Java I/O模型(BIO)在处理大量并发连接时效率较...

    java nio入门学习,两个pdf

    Java NIO,全称为Non-Blocking Input/Output(非阻塞输入/输出),是Java标准库提供的一种替代传统I/O模型的新技术。在Java 1.4版本中引入,NIO提供了一种全新的I/O编程方式,使得Java开发者能够更高效地处理I/O操作...

    java nio 实现socket

    ### Java NIO 实现Socket通信详解 #### 一、NIO与传统IO的区别及优势 在探讨如何使用Java NIO实现Socket通信之前,我们需要先理解NIO(Non-blocking I/O,非阻塞I/O)与传统阻塞I/O之间的区别。 **传统阻塞I/O...

    Java NIO测试示例

    Java NIO,全称为Non-Blocking Input/Output(非阻塞输入/输出),是Java从1.4版本开始引入的一种新的I/O模型,它为Java应用程序提供了更高效、灵活的I/O操作方式。NIO与传统的 Blocking I/O(阻塞I/O)模式相比,...

Global site tag (gtag.js) - Google Analytics