mysql非阻塞通信协议_NIO 的非阻塞式网络通信
1.阻塞与非阻塞
① 传统的 IO 流都是阻塞式的。也就是说,当一个线程调用 read() 或 write()时,
该线程被阻塞,直到有一些数据被读取或写入,该线程在此期间不能执行其他任务。
因此,在完成网络通信进行 IO 操作时,由于线程会阻塞,
所以服务器端必须为每个客户端都提供一个独立的线程进行处理,
当服务器端需要处理大量客户端时,性能急剧下降。
② Java NIO 是非阻塞模式的。当线程从某通道进行读写数据时,若没有数据可用时,
该线程可以进行其他任务。线程通常将非阻塞 IO 的空闲时间用于在其他通道上执行 IO 操作,
所以单独的线程可以管理多个输入和输出通道。、
因此,NIO 可以让服务器端使用一个或有限几个线程来同
时处理连接到服务器端的所有客户端。
阻塞式:TestBlockingNIO
packagecom.aff.nio2;importjava.io.IOException;importjava.net.InetSocketAddress;importjava.nio.ByteBuffer;importjava.nio.channels.FileChannel;importjava.nio.channels.ServerSocketChannel;importjava.nio.channels.SocketChannel;importjava.nio.file.Paths;importjava.nio.file.StandardOpenOption;importorg.junit.Test;/*使用NIO完成网络通信的三个核心技术
1.通道(Channel):负责连接
java.nio.channels.Channel 接口:
|----SockableChannel
|----SocketChannel
|----ServerSocketChannel
|----DatagramChannel
|
|----Pipe.SinkChannel
|----Pipe.SourceChannel
2.缓冲区(Buffer):负责数据的存储
3.选择器(Selector):是SelectorableChannel的多路复用器。
用于监控SelectableChannel的IO状况*/
//阻塞式IO
public classTestBlockingNIO {//客户端
@Testpublic void client() throwsIOException {//1.获取通道
SocketChannel sChannel = SocketChannel.open(new InetSocketAddress("192.168.3.10", 8989));
FileChannel inChannel= FileChannel.open(Paths.get("1.jpg"), StandardOpenOption.READ);//2.分配指定大小的缓冲区
ByteBuffer buf = ByteBuffer.allocate(1024);//3.读取本地文件
while ((inChannel.read(buf)) != -1) {
buf.flip();
sChannel.write(buf);
buf.clear();
}//关闭通道
inChannel.close();
sChannel.close();
}//服务端
@Testpublic void server() throwsIOException {//1.获取通道
ServerSocketChannel ssChannel =ServerSocketChannel.open();
FileChannel outChannel= FileChannel.open(Paths.get("8.jpg"), StandardOpenOption.WRITE,
StandardOpenOption.CREATE);//2.绑定端口号
ssChannel.bind(new InetSocketAddress(8989));//3.获取客户端连接的通道
SocketChannel sChannel =ssChannel.accept();//4.分配指定大小的缓冲区
ByteBuffer buf = ByteBuffer.allocate(1024);//5.接受客户端的数据,并保存到本地
while ((sChannel.read(buf)) != -1) {
buf.flip();
outChannel.write(buf);
buf.clear();
}//6.关闭通道
ssChannel.close();
outChannel.close();
ssChannel.close();
}
}
2.选择器(Selector) )
① 选择器(Selector)是 SelectableChannle 对象的多路复用器,
Selector 可以同时监控多个 SelectableChannel 的 IO 状况,
也就是说,利用 Selector可使一个单独的线程管理多个 Channel。
Selector 是非阻塞 IO 的核心。
② SelectableChannle 的结构如下图:
3.选择 器(Selector )的应用
①当调用 register(Selector sel, int ops) 将通道注册选择器时,选择器
对通道的监听事件,需要通过第二个参数 ops 指定。
②可以监听的事件类型(用 可使用 SelectionKey 的四个常量 表示):
读 : SelectionKey.OP_READ (1)
写 : SelectionKey.OP_WRITE (4)
连接 : SelectionKey.OP_CONNECT (8)
接收 : SelectionKey.OP_ACCEPT (16)
③若注册时不止监听一个事件,则可以使用“位或”操作符连接
非阻塞式IO:TestBlockingNIO2
packagecom.aff.nio2;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.Date;importjava.util.Iterator;importjava.util.Scanner;importorg.junit.Test;//非阻塞式IO
public classTestBlockingNIO2 {//客户端
@Testpublic void client() throwsIOException {//1.获取通道
SocketChannel sChannel = SocketChannel.open(new InetSocketAddress("192.168.3.10", 8989));//2.切换非阻塞式模式
sChannel.configureBlocking(false);//3.分配指定大小的缓冲区
ByteBuffer buf = ByteBuffer.allocate(1024);//4.发送数据给服务端
Scanner scan = newScanner(System.in);while (scan.hasNext()) { //相当于聊天室功能了
String str =scan.next();
buf.put((new Date().toString() + "\n" +str).getBytes());
buf.flip();
sChannel.write(buf);
buf.clear();
}//关闭通道
sChannel.close();
}//服务端
@Testpublic void server() throwsIOException {//1.获取通道
ServerSocketChannel ssChannel =ServerSocketChannel.open();//2.切换非阻塞模式
ssChannel.configureBlocking(false);//3..绑定端口号
ssChannel.bind(new InetSocketAddress(8989));//4..获取选择器
Selector selector =Selector.open();//5.将通道注册到选择器上,并且指定监听接受事件
ssChannel.register(selector, SelectionKey.OP_ACCEPT);//6.轮巡式的获取选择器上已经 准备就绪 的事件
while (selector.select() > 0) {//7.获取当前选择器中所有注册的"选择键(已就绪的监听事件)"
Iterator it =selector.selectedKeys().iterator();//8.迭代获取
while(it.hasNext()) {
SelectionKey sk=it.next();//9.判断是什么事件准备就绪
if(sk.isAcceptable()) {//10.若"接收就绪",获取客户端连接
SocketChannel sChannel =ssChannel.accept();//11.切换非阻塞
sChannel.configureBlocking(false);//将该通道注册到选择器上
sChannel.register(selector, SelectionKey.OP_READ);
}else if(sk.isReadable()) {//获取当前选择器上"读就绪"的通道
SocketChannel Schannel =(SocketChannel) sk.channel();//读取数据
int len = 0;
ByteBuffer buf= ByteBuffer.allocate(1024);while ((len = Schannel.read(buf)) > 0) {
buf.flip();
System.out.println(new String(buf.array(), 0, len));
buf.clear();
}
}//取消选择键
it.remove();
}
}
}
}
执行效果
Sun Apr 05 17:34:26 CST 2020
nihaoa
nisha
Sun Apr 05 17:34:44 CST 2020
nihenhao
DatagramChannel:Java NIO中的DatagramChannel是一个能收发UDP包的通道
DatagramChannel:TestBlockingUDP
packagecom.aff.nio2;importjava.io.IOException;importjava.net.InetSocketAddress;importjava.nio.ByteBuffer;importjava.nio.channels.DatagramChannel;importjava.nio.channels.SelectionKey;importjava.nio.channels.Selector;importjava.util.Date;importjava.util.Iterator;importjava.util.Scanner;importorg.junit.Test;public classTestBlockingUDP {
@Testpublic void send() throwsIOException {
DatagramChannel dc=DatagramChannel.open();
dc.configureBlocking(false);
ByteBuffer buf= ByteBuffer.allocate(1024);
Scanner scan= newScanner(System.in);while(scan.hasNext()) {
String str=scan.next();
buf.put((new Date().toString() + ":\n" +str).getBytes());
buf.flip();
dc.send(buf,new InetSocketAddress("192.168.3.10", 9898));
buf.clear();
}
dc.close();
}
@Testpublic void receive() throwsIOException {
DatagramChannel dc=DatagramChannel.open();
dc.configureBlocking(false);
dc.bind(new InetSocketAddress(9898));
Selector selector=Selector.open();
dc.register(selector, SelectionKey.OP_READ);while (selector.select() > 0) {
Iterator it =selector.selectedKeys().iterator();while(it.hasNext()) {
SelectionKey sk=it.next();if(sk.isReadable()) {
ByteBuffer buf= ByteBuffer.allocate(1024);
dc.receive(buf);
buf.flip();
System.out.println(new String(buf.array(), 0, buf.limit()));
buf.clear();
}
}
it.remove();
}
}
}
管道 (Pipe):
Java NIO 管道是2个线程之间的单向数据连接。
Pipe有一个source通道和一个sink通道。数据会
被写到sink通道,从source通道读取。
TestPipe
packagecom.aff.nio2;importjava.io.IOException;importjava.nio.ByteBuffer;importjava.nio.channels.Pipe;importorg.junit.Test;public classTestPipe {
@Testpublic void test1() throwsIOException {//1. 获取管道
Pipe pipe =Pipe.open();//2. 将缓冲区中的数据写入管道
ByteBuffer buf = ByteBuffer.allocate(1024);
Pipe.SinkChannel sinkChannel=pipe.sink();
buf.put("通过单向管道发送数据".getBytes());
buf.flip();
sinkChannel.write(buf);//3. 读取缓冲区中的数据
Pipe.SourceChannel sourceChannel =pipe.source();
buf.flip();int len =sourceChannel.read(buf);
System.out.println(new String(buf.array(), 0, len));
sourceChannel.close();
sinkChannel.close();
}
}
mysql非阻塞通信协议_NIO 的非阻塞式网络通信相关推荐
- java 多线程阻塞队列 与 阻塞方法与和非阻塞方法
Queue是什么 队列,是一种数据结构.除了优先级队列和LIFO队列外,队列都是以FIFO(先进先出)的方式对各个元素进行排序的.无论使用哪种排序方式,队列的头都是调用remove()或poll()移 ...
- AIO,BIO,NIO:同步阻塞式IO,同步非阻塞IO,异步非阻塞IO
BIO,同步阻塞式IO,简单理解:一个连接一个线程 NIO,同步非阻塞IO,简单理解:一个请求一个线程 AIO,异步非阻塞IO,简单理解:一个有效请求一个线程 IO:阻塞IO BIO:同步阻塞IO.服 ...
- 深入理解非阻塞同步IO和非阻塞异步IO
这两篇文章分析了Linux下的5种IO模型 http://blog.csdn.net/historyasamirror/article/details/5778378 http://blog.csdn ...
- 两段文章清楚弄明白什么是异步IO、同步IO、同步阻塞IO、同步非阻塞IO、异步阻塞IO、异步非阻塞IO
百科解释:异步IO_百度百科 先看2,再看1,会理解的更好! 1. 2.阻塞和非阻塞 # 阻塞和非阻塞关注的是程序在等待调用结果时的状态 # 阻塞调用是指调用结果返回之前,当前线程会被挂起.调用线程只 ...
- 同步I/O、异步I/O、阻塞I/0、非阻塞I/O、五种I/O模型、高性能网络模型
10.I/O相关概念 https://www.cnblogs.com/xiaoxi/p/6525396.html 10.1.同步和异步 同步就是:如果有多个任务或者事件要发生,这些任务或者事件必须 ...
- java 非阻塞_Java之NIO(非阻塞IO)
[1]NIO的与IO的区别: 总的来说java 中的IO 和NIO的区别主要有3点: 1)IO是面向流的,NIO是面向缓冲的: 2)IO是阻塞的,NIO是非阻塞的: 3)IO是单线程的,NIO 是通过 ...
- Mysql解决死锁的问题,防止阻塞
Mysql解决死锁的问题,防止阻塞 参考文章: (1)Mysql解决死锁的问题,防止阻塞 (2)https://www.cnblogs.com/ywjfx/p/12197563.html 备忘一下.
- 【mysql】聚簇索引(聚集索引)和非聚簇索引(二级索引、辅助索引)的区别
文章目录 总结 1. 聚簇索引 一个坑 2. 非聚簇索引 3. 二级索引 总结 聚簇索引也叫聚集索引.,并不是一种单独的索引类型,而是一种数据存储方式.那么可以理解聚簇索引是一种抽象概念,在具体实现的 ...
- mysql对英文忽略字符集_非英文网站如何使用MySQL的字符集
使用 MySQL字符集 对于非英文网站,当他们使用非英语语言从数据库中写入或读取数据时,常常必须解决字符集的问题.字符集指导数据库哪种字符编码方案用于数据的写入读取,这样可以简单地理解为字符集的一个子 ...
- mysql 聚簇索引和非聚簇索引_MySql聚簇索引与非聚簇索引的区别
通常情况下,建立索引是加快查询速度的有效手段.但索引不是万能的,靠索 引并不能实现对所有数据的快速存取.事实上,如果索引策略和数据检索需求严重不符的话,建立索引反而会降低查询性能.因此在实际使用当中, ...
最新文章
- asp.net 添加成功弹出个div提示_Word双栏目录怎么做,这3个步骤早知道,让人眼前一亮...
- 3005-基于二叉链表的二叉树最大宽度的计算(附思路,注释,可能错误分析)
- C语言数组和指针的理解_在取地址运算上的操作_指针加减操作_a 和a 的区别
- 密码学研究-加密解密
- php---遍历一个数组获得一个新的数据结构
- win7注册服务器错误代码,win7系统启动不了iis服务器出现错误代码怎么解决
- MBR 与 GPT - 分区时要知道的事情
- php制作国旗头像图片,不要再@微信官方了,自己动手一秒制作国旗头像
- 如何评价一个人的科研能力
- linux播放器安装包下载地址,linux安装MPLAYER播放器
- Flutter 自定义TabBar指示器(indicator)实现秒杀UI样式
- 高校女生穿旗袍答辩!网友:导师说论文要是和旗袍一样漂亮就好了
- GET /static/js/jquery-3.5.1.min.js HTTP/1.1 200 89476
- 某阿里大神想和java程序员说的话
- Mac上挂载移动硬盘出现Read-only file system问题
- word锁定:解决Word文档由于文档保护而无法修改、查找、编辑的方法
- C++实现暴力筛、朴素素数筛、埃氏素数筛、欧拉素数筛的解法
- 【医学图像处理】CT成像技术之图像质量
- 反恐精英ol永恒python图_反恐精英python编程
- 【Java】什么是面向对象
热门文章
- 谈谈tmpdir与innodb_tmpdir的区别和用处
- COGS 2687 讨厌整除的小明
- smalot-bootstrap-datetimepicker 使用心得
- django基础入门(3)django中模板
- [转载]Oracle Minus关键字
- 【GIS开发者】(GISDeveloper) 11-14期 提供下载
- dojo0.9的第一个实例
- 分享一份非常强势的Android面试题
- 微信小程序开发 -- 获取当前页面路径
- )C# Enum,Int,String的互相转换 枚举转换