java nio 事件_Java NIO原理及实例
Java NIO是在jdk1.4开始使用的,它既可以说成“新I/O”,也可以说成非阻塞式I/O。下面是java NIO的工作原理:
1. 由一个专门的线程来处理所有的 IO 事件,并负责分发。
2. 事件驱动机制:事件到的时候触发,而不是同步的去监视事件。
3. 线程通讯:线程之间通过 wait,notify 等方式通讯。保证每次上下文切换都是有意义的。减少无谓的线程切换。
(1)Java NIO的服务端只需启动一个专门的线程来处理所有的 IO 事件,这种通信模型是怎么实现的呢?
java NIO采用了双向通道(channel)进行数据传输,而不是单向的流(stream),在通道上可以注册我们感兴趣的事件。一共有以下四种事件:
事件名
对应值
服务端接收客户端连接事件
SelectionKey.OP_ACCEPT(16)
客户端连接服务端事件
SelectionKey.OP_CONNECT(8)
读事件
SelectionKey.OP_READ(1)
写事件
SelectionKey.OP_WRITE(4)
(2)NIO实现原理
服务端和客户端各自维护一个管理通道的对象,我们称之为selector,该对象能检测一个或多个通道 (channel) 上的事件。我们以服务端为例,如果服务端的selector上注册了读事件,某时刻客户端给服务端发送了一些数据,阻塞I/O这时会调用read()方法阻塞地读取数据,而NIO的服务端会在selector中添加一个读事件。服务端的处理线程会轮询地访问selector,如果访问selector时发现有感兴趣的事件到达,则处理这些事件,如果没有感兴趣的事件到达,则处理线程会一直阻塞直到感兴趣的事件到达为止。
(3)NIO实例
服务端:
packagecom.neu.nio;/*** Created by apple on 16/7/2.*/
importjava.io.IOException;importjava.net.InetSocketAddress;importjava.nio.ByteBuffer;importjava.nio.channels.SelectionKey;importjava.nio.channels.Selector;importjava.nio.channels.ServerSocketChannel;importjava.nio.channels.SocketChannel;importjava.util.Iterator;public classNIOServer {//通道管理器
privateSelector selector;/*** 获得一个ServerSocket通道,并对该通道做一些初始化的工作
*
*@paramport 绑定的端口号
*@throwsIOException*/
public void initServer(int port) throwsIOException {//获得一个ServerSocket通道
ServerSocketChannel serverChannel =ServerSocketChannel.open();//设置通道为非阻塞
serverChannel.configureBlocking(false);//将该通道对应的ServerSocket绑定到port端口
serverChannel.socket().bind(newInetSocketAddress(port));//获得一个通道管理器
this.selector =Selector.open();//将通道管理器和该通道绑定,并为该通道注册SelectionKey.OP_ACCEPT事件,注册该事件后,//当该事件到达时,selector.select()会返回,如果该事件没到达selector.select()会一直阻塞。
serverChannel.register(selector, SelectionKey.OP_ACCEPT);
}/*** 采用轮询的方式监听selector上是否有需要处理的事件,如果有,则进行处理
*
*@throwsIOException*/@SuppressWarnings("unchecked")public void listen() throwsIOException {
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);
}
}
}
}/*** 处理读取客户端发来的信息的事件
*
*@paramkey
*@throwsIOException*/
public void read(SelectionKey key) throwsIOException {//服务器可读取消息:得到事件发生的Socket通道
SocketChannel channel =(SocketChannel) key.channel();//创建读取的缓冲区
ByteBuffer buffer = ByteBuffer.allocate(10);
channel.read(buffer);byte[] data =buffer.array();
String msg= newString(data).trim();
System.out.println("服务端收到信息:" +msg);
ByteBuffer outBuffer=ByteBuffer.wrap(msg.getBytes());
channel.write(outBuffer);//将消息回送给客户端
}/*** 启动服务端测试
*
*@throwsIOException*/
public static void main(String[] args) throwsIOException {
NIOServer server= newNIOServer();
server.initServer(8000);
server.listen();
}
}
客户端:
packagecom.neu.nio;/*** Created by apple on 16/7/2.*/
importjava.io.IOException;importjava.net.InetSocketAddress;importjava.nio.ByteBuffer;importjava.nio.channels.SelectionKey;importjava.nio.channels.Selector;importjava.nio.channels.SocketChannel;importjava.util.Iterator;public classNIOClient {//通道管理器
privateSelector selector;/*** 启动客户端测试
*
*@throwsIOException*/
public static void main(String[] args) throwsIOException {
NIOClient client= newNIOClient();
client.initClient("localhost", 8000);
client.listen();
}/*** 获得一个Socket通道,并对该通道做一些初始化的工作
*
*@paramip 连接的服务器的ip
*@paramport 连接的服务器的端口号
*@throwsIOException*/
public void initClient(String ip, int port) throwsIOException {//获得一个Socket通道
SocketChannel channel =SocketChannel.open();//设置通道为非阻塞
channel.configureBlocking(false);//获得一个通道管理器
this.selector =Selector.open();//客户端连接服务器,其实方法执行并没有实现连接,需要在listen()方法中调//用channel.finishConnect();才能完成连接
channel.connect(newInetSocketAddress(ip, port));//将通道管理器和该通道绑定,并为该通道注册SelectionKey.OP_CONNECT事件。
channel.register(selector, SelectionKey.OP_CONNECT);
}/*** 采用轮询的方式监听selector上是否有需要处理的事件,如果有,则进行处理
*
*@throwsIOException*/@SuppressWarnings("unchecked")public void listen() throwsIOException {//轮询访问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.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);//获得了可读的事件
} else if(key.isReadable()) {
read(key);
}
}
}
}/*** 处理读取服务端发来的信息 的事件
*
*@paramkey
*@throwsIOException*/
public void read(SelectionKey key) throwsIOException {//和服务端的read方法一样//客户端可读取消息:得到事件发生的Socket通道
SocketChannel channel =(SocketChannel) key.channel();//创建读取的缓冲区
ByteBuffer buffer = ByteBuffer.allocate(10);
channel.read(buffer);byte[] data =buffer.array();
String msg= newString(data).trim();
System.out.println("客户端收到信息:" +msg);
ByteBuffer outBuffer=ByteBuffer.wrap(msg.getBytes());
channel.write(outBuffer);//将消息回送给服务端
}
}
参考:http://weixiaolu.iteye.com/blog/1479656
java nio 事件_Java NIO原理及实例相关推荐
- java nio 详_java nio详解
一. 分布式rpc框架有很多,比如dubbo,netty,还有很多其他的产品.但他们大部分都是基于nio的, nio是非阻塞的io,那么它的内部机制是怎么实现的呢. 1.由一个专门的线程处理所有IO事 ...
- java nio多路复用_Java NIO系列教程(六) 多路复用器Selector
多路复用器Selector是Java NIO编程的基础,熟练地掌握Selector对于掌握NIO编程至关重要.多路复用器提供选择已经就绪的任务的能力.简单来讲,Selector会不断地轮询注册在其上的 ...
- java linkedlist实例_Java Linkedlist原理及实例详解
这篇文章主要介绍了Java Linkedlist原理及实例详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 定义:linkedlist属于链表结构 ...
- java bytebuffer 读写_java nio bytebuffer文件读写问题
为什么下面的代码从文件中读不出3和2来?importjava.io.FileInputStream;importjava.io.FileOutputStream;importjava.io.IOExc ...
- mysql io nio区别_Java NIO和IO的区别
Java NIO Java NIO(New IO)是从Java 1.4版本开始引入的一个新的IO API,可以替代标准的Java IO API.NIO与原来的IO有同样的作用和目的,但是使用 的方式完 ...
- java 模拟停车_Java多线程编程小实例模拟停车场系统
下面分享的是一个Java多线程模拟停车场系统的小实例(Java的应用还是很广泛的,哈哈),具体代码如下: Park类 public class Park { boolean []park=new bo ...
- redis队列优先级java实现_Redis 实现队列原理的实例详解
Redis 实现队列原理的实例详解 场景说明: ·用于处理比较耗时的请求,例如批量发送邮件,如果直接在网页触发执行发送,程序会出现超时 ·高并发场景,当某个时刻请求瞬间增加时,可以把请求写入到队列,后 ...
- java nio 写事件_Java NIO
java Nio Selector 选择器 Buffer 缓冲器 Channel 通道 Selector是NIO的核心,是channel的管理者,通过执行select()阻塞方式,监听是否有chann ...
- java nio教程_Java NIO教程
java nio教程 1.简介 Java NIO是Java 1.4引入的一个库. 自从Java NIO推出以来,它提供了另一种方法来处理I / O和网络事务. 它被认为是Java网络和Java IO库 ...
最新文章
- Python3学习笔记----环境安装及文本编辑器的选择
- ANSYS滑块导轨配合方法
- 添加用户信息的方法java_添加用户的流程分析
- AIX和linux SSH互信
- Android安全教程(2)---Fiddler简易使用教程之使用
- SmartPDA图片
- 《千只鹤》:面对爱,我们永远还行走在成长的路上 ...
- App开发流程之创建项目和工程基本配置
- 三维立体动画制作_三维立体动画制作相比传统方式的特点
- [USACO14JAN]Recording the Moolympics
- UVa 11383 少林决胜(二分图最佳完美匹配)
- 设置UYVY格式YUV为黑色
- 大教堂与集市(The Cathedral and the Bazaar)读书笔记
- 图解机器学习算法(7) | 随机森林分类模型详解(机器学习通关指南·完结)
- ARM的启动过程详解(CHINAITLAB)
- 安卓原生系统_你没有用过的安卓系统:原生安卓桌面体验
- arm板linux内核移植,ARM开发板上uClinux内核移植
- 【leetcode】189.旋转数组 (四种方法开阔思路,java实现!)
- 课堂秩序难管理?这个方法造福师生
- 网页录屏将视频截图保存成gif图片并压缩的方法超详细