代做作业网站,内蒙做网站,成都灯光设计公司,微信小程序公众号开发一、传统BIO的缺点
BIO属于同步阻塞行IO,在服务器的实现模型为#xff0c;每一个连接都要对应一个线程。当客户端有连接请求的时候#xff0c;服务器端需要启动一个新的线程与之对应处理#xff0c;这个模型有很多缺陷。当客户端不做出进一步IO请求的时候#xff0c;服务器…一、传统BIO的缺点
BIO属于同步阻塞行IO,在服务器的实现模型为每一个连接都要对应一个线程。当客户端有连接请求的时候服务器端需要启动一个新的线程与之对应处理这个模型有很多缺陷。当客户端不做出进一步IO请求的时候服务器端的线程就只能挂着不能去处理其他请求。这样会对造成不必要的线程开销。
二、阻塞与同步
同步和异步都是由基于应用程序和操作系统处理IO事件所采用的方式所决定的。 阻塞和非阻塞式指线程在得到调用结果之前是否被挂起主要针对线程。
三、NIO简介(同步非阻塞)
Java NIO全称java non-blocking IO 是指JDK提供的新API。从JDK1.4开始Java提供了一系列改进的输入/输出的新特性被统称为NIO(即New IO)是同步非阻塞的。NIO是一种面向缓冲区的、基于通道的IO操作NIO有三大核心部分: Channel(通道) Buffer(缓冲区),Selector(选择器)java NIO的运行模式是客户端发送的链接请求都会被注册到Selector(选择器)上多路复用器轮询到有I/O请求时才会启动一个线程去服务。
四、NIO三大核心原理
NIO有三大核心部分: Channel(通道), Buffer(缓冲区),Selector(选择器) Buffer(缓冲区) 缓冲区本质上就是一块内存数据的读写都是通过Buffer类实现的。缓冲区buffer主要是和通道数据交互即从通道中读入数据到缓冲区和从缓冲区中把数据写入到通道中通过这样完成对数据的传输。 Channel(通道) java NIO的类似于流但是又有些不同既可以从通道中读取数据又可以写数据到通道。但流的(input和output)读写通常是单向的。通道可以非阻塞读取和写入通道通道可以支持读取或写入缓冲区也支持异步读写。 Selector选择器 Selector是一个java NIO组件可以检测一个或多个NIO通道并确定已经准备好进行读取或者写入。这样一个单独的线程就可以管理多个Channel,从而管理多个网络连接提高效率。
每个channel都会对应一个Buffer一个线程对应Selector,一个Selector对应多个Channel程序切换到那个channel是由事件决定Selector会根据不同的事件在各个通道上切换Buffer就是一个内存块底层就是一个数组数据的读取和写入都是通过Buffer来实现的
五、NIO三板斧 六、NIO实现案例
客户端
public class NioClient {public static void main(String[] args) throws IOException {SocketChannel socketChannelSocketChannel.open();socketChannel.configureBlocking(false);InetSocketAddress address new InetSocketAddress(127.0.0.1, 9000);if (!socketChannel.connect(address)) {while (!socketChannel.finishConnect()){System.out.println(连接中客户端可以进行其他工作);}String strhello world!;ByteBuffer wrap ByteBuffer.wrap(str.getBytes());socketChannel.write(wrap);//避免客户端中断System.in.read();}}
}服务器端
public class NioServer {public static void main(String[] args) throws IOException {// 获取一个ServerSocket通道ServerSocketChannel serverChannel ServerSocketChannel.open();// serverChannel通道一直监听9000端口serverChannel.socket().bind(new InetSocketAddress(9000));// 设置serverChannel为非阻塞serverChannel.configureBlocking(false);//创建Selector选择器用来监听通道Selector selector Selector.open();// 把ServerSocketChannel注册到selector中并且selector对客户端的连接操作感兴趣SelectionKey selectionKey serverChannel.register(selector, SelectionKey.OP_ACCEPT);System.out.println(服务启动成功);while(true){/** 如果事件没有到达 selector.select() 会一直阻塞等待*/selector.select();SetSelectionKey selectionKeys selector.selectedKeys();IteratorSelectionKey iterator selectionKeys.iterator();while (iterator.hasNext()){SelectionKey key iterator.next();if (key.isAcceptable()) // 如果是OP_ACCEPT事件则进行连接获取和事件注册{ServerSocketChannel server (ServerSocketChannel) key.channel(); //连接获取SocketChannel socketChannel server.accept(); // 连接获取socketChannel.configureBlocking(false); // 设置为非阻塞SelectionKey selKey socketChannel.register(selector, SelectionKey.OP_READ); //这里只注册了读事件如果需要给客户端写数据则需要注册写事件System.out.println(客户端连接成功);}else if(key.isReadable()) //如果是OP_READ事件则进行读取和打印{SocketChannel socketChannel (SocketChannel) key.channel();ByteBuffer byteBuffer ByteBuffer.allocate(128);int len socketChannel.read(byteBuffer);if (len 0) //如果有数据则打印数据{System.out.println(接受到客户端数据new String(byteBuffer.array()));}else if(len-1) //如果客户端断开连接关闭socket{System.out.println(客户端断开连接);socketChannel.close();}}// 从事件集合中删除本次处理的key防止下次select重复处理iterator.remove();}}}
}
