东莞市住房和城乡建设厅网站首页,用fw做网站页面,网上注册公司步骤,wordpress post status优质博文#xff1a;IT-BLOG-CN 一、阻塞IO / 非阻塞NIO
阻塞IO#xff1a;当一条线程执行read()或者write()方法时#xff0c;这条线程会一直阻塞直到读取到了一些数据或者要写出去的数据已经全部写出#xff0c;在这期间这条线程不能做任何其他的事情。
非阻塞NIO… 优质博文IT-BLOG-CN 一、阻塞IO / 非阻塞NIO
阻塞IO当一条线程执行read()或者write()方法时这条线程会一直阻塞直到读取到了一些数据或者要写出去的数据已经全部写出在这期间这条线程不能做任何其他的事情。
非阻塞NIONIO与原有的IO有同样的作用和目的但是使用的方式完全不同NIO支持面向缓冲区的、基于通道的操作。NIO将以更加高效的方式进行文件读写操作。JAVA NIO的核心在于通道Channel和缓冲区Buffer。通道表示打开IO设备例如文件、套接字的连接。若需要使用NIO系统需要获取用于连接IO设备的通道以及用于容纳数据的缓冲区。对数据进行处理。
二、传统IO测试代码如下
当出现accept() 、read()等方法是就会阻塞。
/*** 传统socket服务端* author -zhengzx-*/
public class OioServer {SuppressWarnings(resource)public static void main(String[] args) throws Exception {//创建socket服务,监听10101端口ServerSocket servernew ServerSocket(10101);System.out.println(服务器启动);while(true){//获取一个套接字阻塞final Socket socket server.accept();//(测试时可以通过:telnet 127.0.0.1 10101。进行测试)System.out.println(来个一个新客户端);//业务处理handler(socket);}}/*** 读取数据* param socket* throws Exception*/public static void handler(Socket socket){try {byte[] bytes new byte[1024];InputStream inputStream socket.getInputStream();while(true){//读取数据阻塞int read inputStream.read(bytes);if(read ! -1){System.out.println(new String(bytes, 0, read));}else{break;}}} catch (Exception e) {e.printStackTrace();}finally{try {System.out.println(socket关闭);socket.close();} catch (IOException e) {e.printStackTrace();}}}
}三、阻塞 IO解决办法
可以通过线程池创建多线程为每一次连接创建一个新的线程来执行。问题是对于长连接而言线程过多时会严重消耗系统资源导致性能下降。比较适合短连接的应用。
public static void main(String[] args) throws Exception {//创建线程池可以通过线程解决阻塞问题、问题每次连接都会创建一个线程特别是长连接时特别消耗系统资源ExecutorService newCachedThreadPool Executors.newCachedThreadPool();//创建socket服务,监听10101端口ServerSocket servernew ServerSocket(10101);System.out.println(服务器启动);while(true){//获取一个套接字阻塞final Socket socket server.accept();//(测试时可以通过:telnet 127.0.0.1 10101。进行测试)System.out.println(来个一个新客户端);newCachedThreadPool.execute(new Runnable() {Overridepublic void run() {//业务处理handler(socket);}});}
}四、NIO 的非阻塞模式
Java NIO有阻塞模式和非阻塞模式阻塞模式的NIO除了使用Buffer存储数据外和IO基本没有区别允许一条线程从Channel中读取数据通过返回值来判断buffer中是否有数据如果没有数据NIO不会阻塞因为不阻塞这条线程就可以去做其他的事情过一段时间再回来判断一下有没有数据。
*SelectorsJava NIO的selectors允许一条线程去监控多个channels的输入你可以向一个selector上注册多个channel然后调用selector的select()方法判断是否有新的连接进来或者已经在selector上注册时channel是否有数据进入。selector的机制让一个线程管理多个channel变得简单。
五、NIO示例代码如下
客户端使用SocketChannel服务端使用ServerSocketChannel获取通道
public class NIOServerSocket {//定义一个socket入口private ServerSocketChannel serverSocket;//定义一个监听器Selector selector;public static void main(String[] args) throws IOException {NIOServerSocket nio new NIOServerSocket();nio.initServer(8000);nio.listen();}public void initServer(int port) throws IOException {//获取一个serverSocket通道serverSocket ServerSocketChannel.open();//设置为非阻塞状态分为阻塞和非阻塞两种情况serverSocket.configureBlocking(false);//将通道对应的serverSocketChannel绑定到端口上serverSocket.socket().bind(new InetSocketAddress(port));//获取一个通道管理器this.selector Selector.open();//将通道管理器与通道进行绑定并赋值SelectionKey.OP_ACCEPT事件//注册后当事件到达后select.select()会返回如果没有返回就一直阻塞。serverSocket.register(selector, SelectionKey.OP_ACCEPT);}public void listen() throws IOException {System.out.println(服务器启动);//轮询访问select.select()while(true) {//当事件到达时返回否则一直阻塞Channel channel selector.select();//获取selector中选中项的迭代器相中的项为注册事件。IteratorSelectionKey iterator this.selector.selectedKeys().iterator();while(iterator.hasNext()) {SelectionKey selectionKey iterator.next();//删除已选的key防止重复处理iterator.remove();handler(selectionKey);}}}public void handler(SelectionKey key) throws IOException {if(key.isAcceptable()) {handlerAccept(key);}else if(key.isReadable()) {handlerRead(key);}}public void handlerAccept(SelectionKey key) throws IOException {//获取以有的通道ServerSocketChannel channel (ServerSocketChannel) key.channel();//获取和客户端连接的通道SocketChannel accept channel.accept();//设置为非阻塞accept.configureBlocking(false);// 在这里可以给客户端发送信息哦System.out.println(新的客户端连接);//连接成功之后为了读取客户端传送的消息需要设置读权限accept.register(selector, SelectionKey.OP_READ);}public void handlerRead(SelectionKey key) throws IOException {//服务器可读取消息获取事件发生的Socket通道SocketChannel channel (SocketChannel) key.channel();//创建读取内容的缓存区bufferByteBuffer buffer ByteBuffer.allocate(1024);int read channel.read(buffer);if(read 0) {byte[] array buffer.array();String msg new String(array).trim();System.out.println(服务端收到信息 msg);//会写ByteBuffer byteBuffer ByteBuffer.wrap(success.getBytes());channel.write(byteBuffer);}else {System.out.println(客户端关闭);key.cancel();}}
}六 、selector.select()
selector.select()虽阻塞但可以通过selector.wakeup()唤醒selector执行也可以通过selector.select(int timeout)设置时间限制timeout时间后唤醒 selector。
七、NIO提高性能
添加多线程一个线程对应一个selector端口的监听可以单独创建一个selector。既Netty的工作原理 总结 NIO允许你用一个单独的线程或几个线程管理很多个channels网络的或者文件的代价是程序的处理和处理IO相比更加复杂。如果你需要同时管理成千上万的连接但是每个连接只发送少量数据例如一个聊天服务器用NIO实现会更好一些相似的如果你需要保持很多个到其他电脑的连接例如P2P网络用一个单独的线程来管理所有出口连接是比较合适的。 IO如果你只有少量的连接但是每个连接都占有很高的带宽同时发送很多数据传统的IO会更适合
