java.nio异步线程安全的IO
BIO 方式使得整个处理过程和连接是绑定的,只要连接建立,无论客户端是否有消息发送,都要进行等待处理,一定程度上浪费了服务器端的硬件资源,因此就有了 NIO 方式。Java 对于 NIO 方式的支持是通过 Channel和 Selector 方式来实现,采用的方法为向 Channel注册感兴趣的事件,然后通过 Selector 来获取到发生了事件的 key,如发生了相应的事件,则进行相应的处理,否则则不做任何处理,是典型的Reactor 模式,按照这样的方式,就不用像 BIO 方式一样,即使在没有消息的情况下也需要占据一个线程来阻塞读取消息,从而提升服务器的使用效率, 为实现 TCP/IP+NIO 方式的系统间通讯, Java 提供了 SocketChannel和 ServerSocketChannel两个关键的类,网络 IO 的操作则改为通过ByteBuffer 来实现,具体的基于 java实现TCP/IP+NIO 方式的通讯的方法如下所示。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
package com.flyoung;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.util.Iterator;
import java.util.Set;
import java.nio.channels.SocketChannel;
public class NIOServer {
/*标志数字*/
private static int flag = 0;
/*定义缓冲区大小*/
private static int block = 4096;
/*接收缓冲区*/
private static ByteBuffer receiveBuffer = ByteBuffer.allocate(block);
/*发送缓冲区*/
private static ByteBuffer sendBuffer = ByteBuffer.allocate(block);
/*定义Selector*/
private Selector selector;
public NIOServer( int port) throws IOException{
//打开服务器套接字通道
ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
//服务器配置为非阻塞
serverSocketChannel.configureBlocking( false );
//检索与此服务器套接字通道关联的套接字
ServerSocket serverSocket = serverSocketChannel.socket();
//进行服务的绑定
serverSocket.bind( new InetSocketAddress(port));
//通过open()方法找到Selector
selector = Selector.open();
//注册到selector
serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
System.out.println( "Server Start -----8888:" );
}
//监听
public void listen() throws IOException{
while ( true ){
//监控所有注册的 channel ,当其中有注册的 IO 操作可以进行时,该函数返回,并将对应的 SelectionKey 加入 selected-key set
selector.select();
//Selected-key set 代表了所有通过 select() 方法监测到可以进行 IO 操作的 channel ,这个集合可以通过 selectedKeys() 拿到
Set<SelectionKey> selectionKeys = selector.selectedKeys();
Iterator<SelectionKey> iterator = selectionKeys.iterator();
while (iterator.hasNext()){
SelectionKey selectionKey = iterator.next();
handleKey(selectionKey);
iterator.remove();
}
}
}
//处理请求
public void handleKey(SelectionKey selectionKey) throws IOException{
//接受请求
ServerSocketChannel serverSocketChannel = null ;
SocketChannel socketChannel = null ;
String receiveText;
String sendText;
int count;
//测试此键的通道是否准备好接受新的套接字连接
if (selectionKey.isAcceptable()){
//返回创建此键的通道
serverSocketChannel = (ServerSocketChannel)selectionKey.channel();
//接受客户端建立连接的请求,并返回 SocketChannel 对象
socketChannel = serverSocketChannel.accept();
//配置为非阻塞
socketChannel.configureBlocking( false );
//注册到selector
socketChannel.register(selector, SelectionKey.OP_READ);
} else if (selectionKey.isReadable()){
//返回为之创建此键的通道
socketChannel = (SocketChannel)selectionKey.channel();
//将缓冲区清空,以备下次读取
receiveBuffer.clear();
//将发送来的数据读取到缓冲区
count = socketChannel.read(receiveBuffer);
if (count> 0 ){
receiveText = new String(receiveBuffer.array(), 0 ,count);
System.out.println( "服务器端接受到的数据---" +receiveText);
socketChannel.register(selector, SelectionKey.OP_WRITE);
}
} else if (selectionKey.isWritable()) {
//将缓冲区清空以备下次写入
sendBuffer.clear();
// 返回为之创建此键的通道。
socketChannel = (SocketChannel) selectionKey.channel();
sendText= "message from server--" + flag++;
//向缓冲区中输入数据
sendBuffer.put(sendText.getBytes());
//将缓冲区各标志复位,因为向里面put了数据标志被改变要想从中读取数据发向服务器,就要复位
sendBuffer.flip();
//输出到通道
socketChannel.write(sendBuffer);
System.out.println( "服务器端向客户端发送数据--:" +sendText);
socketChannel.register(selector, SelectionKey.OP_READ);
}
}
public static void main(String[] args) throws IOException {
int port = 8888 ;
NIOServer server = new NIOServer(port);
server.listen();
}
}
|
转载于:https://www.cnblogs.com/lotus-emperor/p/4761399.html
java.nio异步线程安全的IO相关推荐
- JAVA NIO 异步TCP服务端向客户端消息群发代码教程实战
前言 项目需要和第三方厂商的服务需要用TCP协议通讯,考虑到彼此双方可能都会有断网重连.宕机重启的情况,需要保证 发生上述情况后,服务之间能够自动实现重新通信.研究测试之后整理如下代码实现.因为发现客 ...
- Cocos2dx中lua实现与java交互(异步线程间的数据同步)
语言环境 Cocos2dx 3.6 lua 5.1 java 1.8.0_144 本节问题: lua 通过 luaj与java交互,在java中,如何回调lua?若要处理的事件代码必须在多线程中执行, ...
- java nio 阻塞_Java NIO和传统阻塞IO
传统的阻塞IO我就不多说,因为之前我发过几篇使用传统阻塞IO做QQ聊天写的几篇文章,服务器端每得到一个新的连接就开一个线程,在这个线程中接收数据方向是阻塞的, 这种方式对性能的开销是非常大的,总结 ...
- 【计算机IO系类】Java NIO
前面我们讲了操作系统的IO模型.而Java NIO并不是只包括IO模型,还包括了对模型的实现和优化.Java NIO是Java 1.4版加入的新特性,虽然Java技术日新月异,但历经10年,NIO依然 ...
- Java NIO 系列教程 转
Java NIO提供了与标准IO不同的IO工作方式: Channels and Buffers(通道和缓冲区):标准的IO基于字节流和字符流进行操作的,而NIO是基于通道(Channel)和缓冲区(B ...
- Java NIO 系列教程
Java NIO(New IO)是从Java 1.4版本开始引入的一个新的IO API,可以替代标准的Java IO API.本系列教程将有助于你学习和理解Java NIO. Java NIO提供了与 ...
- 我所理解的Java NIO
这两天了解了一下关于NIO方面的知识,网上关于这一块的介绍只是介绍了一下基本用法,没有系统的解释NIO与阻塞.非阻塞.同步.异步之间的联系,导致自己困扰了好久.本篇文章就个人关于NIO的理解进行阐述. ...
- JAVA NIO学习一:NIO简介、NIOIO的主要区别
在前面学习了IO之后,今天我们开始进入NIO学习环节,首先我们会NIO做一个简单的介绍,让大家认识NIO,然后会和IO进行一个对比认识进行区分.好了,下面我们就开始学习: 一.NIO简介 1.概述 从 ...
- 精讲Java NIO
Java NIO(New IO)是从Java 1.4版本开始引入的一个新的IO API,可以替代标准的Java IO API.本文将有助于你学习和理解Java NIO. Java NIO提供了与标准I ...
- java nio教程_Java NIO教程
java nio教程 1.简介 Java NIO是Java 1.4引入的一个库. 自从Java NIO推出以来,它提供了另一种方法来处理I / O和网络事务. 它被认为是Java网络和Java IO库 ...
最新文章
- SpringBoot第十四篇:在springboot中用redis实现消息队列
- 学习 Message(10): WM_CancelMode 消息测试
- C语言数组作为传入参数
- 单播,组播,广播的区别
- 领域驱动设计战术模式--值对象
- C语言使用fopen的两点注意事项
- c语言设计二级考试程序修改题,全国计算机c语言二级考试试题
- 最新消息2022年广西最新消防设施操作员模拟题库及答案
- 天池大数据竞赛 阿里流行音乐艺人热度预测
- iShare·AD小技巧--如何设置镂空的字体
- 上汽拿下国内首张道路测试用牌照
- Decal Buffer相关
- (node:22344) [DEP0123] DeprecationWarning: Setting the TLS ServerName to an IP address is not permit
- 一搜◎欢乐搜索 变相滋生垃圾邮件与病毒
- asp.net分页查询
- Unity3d 周分享(14期 2019.4.1 )
- 系统级编程语言性能大PK的笑话-Go语言
- 7条命令在docker中部署Mesos集群
- 【搜索方法】google搜索
- 数据挖掘中的指标--分类器中的ROC曲线及相关指标(ROC、AUC、ACC)