IO 与 NIO之网络通信

Java架构师必看

发布于 2021-05-14 11:21:52

3960

发布于 2021-05-14 11:21:52

文章被收录于专栏：Java架构师必看

IO 与 NIO之网络通信

强烈推介IDEA2020.2破解激活，IntelliJ IDEA 注册码，2020.2 IDEA 激活码

IO 与 NIO之网络通信

一、阻塞IO / 非阻塞NIO

**阻塞IO：**当一条线程执行 read() 或者 write() 方法时，这条线程会一直阻塞直到读取到了一些数据或者要写出去的数据已经全部写出，在这期间这条线程不能做任何其他的事情。

非阻塞NIO：NIO 与原有的 IO 有同样的作用和目的，但是使用的方式完全不同，NIO 支持面向缓冲区的、基于通道的操作。NIO 将以更加高效的方式进行文件读写操作。JAVA NIO的核心在于：通道（Channel）和缓冲区（Buffer）。通道表示打开 IO 设备（例如：文件、套接字）的连接。若需要使用 NIO 系统，需要获取用于连接 IO 设备的通道以及用于容纳数据的缓冲区。对数据进行处理。

二、传统IO测试代码如下

当出现 accept() 、read() 等方法是就会阻塞。

 1 /**
 2  * 传统socket服务端
 3  * @author -zhengzx-
 4  */
 5 public class OioServer {
 6 
 7     @SuppressWarnings("resource")
 8     public static void main(String[] args) throws Exception {
 9         
10         //创建socket服务,监听10101端口
11         ServerSocket server=new ServerSocket(10101);
12         System.out.println("服务器启动！");
13         while(true){
14             //获取一个套接字（阻塞）
15             final Socket socket = server.accept();//(测试时可以通过:telnet 127.0.0.1 10101。进行测试)
16             System.out.println("来个一个新客户端！");
17                 //业务处理
18                 handler(socket);
19             }
20     }
21     
22     /**
23      * 读取数据
24      * @param socket
25      * @throws Exception
26      */
27     public static void handler(Socket socket){
28             try {
29                 byte[] bytes = new byte[1024];
30                 InputStream inputStream = socket.getInputStream();
31                 
32                 while(true){
33                     //读取数据（阻塞）
34                     int read = inputStream.read(bytes);
35                     if(read != -1){
36                         System.out.println(new String(bytes, 0, read));
37                     }else{
38                         break;
39                     }
40                 }
41             } catch (Exception e) {
42                 e.printStackTrace();
43             }finally{
44                 try {
45                     System.out.println("socket关闭");
46                     socket.close();
47                 } catch (IOException e) {
48                     e.printStackTrace();
49                 }
50             }
51     }
52 }

三、阻塞 IO解决办法

可以通过线程池创建多线程，为每一次连接创建一个新的线程来执行。问题是对于长连接而言，线程过多时会严重消耗系统资源导致性能下降。比较适合短连接的应用。

 1 public static void main(String[] args) throws Exception {
 2         
 3         //创建线程池（可以通过线程解决阻塞问题、问题：每次连接都会创建一个线程，特别是长连接时特别消耗系统资源）
 4         ExecutorService newCachedThreadPool = Executors.newCachedThreadPool();
 5         //创建socket服务,监听10101端口
 6         ServerSocket server=new ServerSocket(10101);
 7         System.out.println("服务器启动！");
 8         while(true){
 9             //获取一个套接字（阻塞）
10             final Socket socket = server.accept();//(测试时可以通过:telnet 127.0.0.1 10101。进行测试)
11             System.out.println("来个一个新客户端！");
12             newCachedThreadPool.execute(new Runnable() {
13                 
14                 @Override
15                 public void run() {
16                     //业务处理
17                     handler(socket);
18                 }
19             });
20             
21         }
22     }

四、NIO 的非阻塞模式

Java NIO 有阻塞模式和非阻塞模式，阻塞模式的 NIO除了使用 Buffer存储数据外和 IO基本没有区别，允许一条线程从 Channel 中读取数据，通过返回值来判断 buffer中是否有数据，如果没有数据，NIO不会阻塞，因为不阻塞这条线程就可以去做其他的事情，过一段时间再回来判断一下有没有数据。

Selectors*：Java NIO的 selectors 允许一条线程去监控多个 channels的输入，你可以向一个 selector上注册多个 channel，然后调用 selector 的select()** 方法判断是否有新的连接进来或者已经在 *selector* 上注册时 channel 是否有数据进入。selector 的机制让一个线程管理多个 channel 变得简单。

五、NIO示例代码如下

客户端使用 SocketChannel，服务端使用 ServerSocketChannel 获取通道

 1 public class NIOServerSocket {
 2     //定义一个socket入口
 3     private ServerSocketChannel serverSocket;
 4     //定义一个监听器
 5     Selector selector;
 6     public static void main(String[] args) throws IOException {
 7         NIOServerSocket nio =new NIOServerSocket();
 8         nio.initServer(8000);
 9         nio.listen();
10     }
11     public void initServer(int port) throws IOException {
12         //获取一个serverSocket通道
13         serverSocket = ServerSocketChannel.open();
14         //设置为非阻塞状态（分为阻塞和非阻塞两种情况）
15         serverSocket.configureBlocking(false);
16         //将通道对应的serverSocketChannel绑定到端口上
17         serverSocket.socket().bind(new InetSocketAddress(port));
18         //获取一个通道管理器
19         this.selector = Selector.open();
20         //将通道管理器与通道进行绑定，并赋值SelectionKey.OP_ACCEPT事件，当事件
21         //注册后，当事件到达后，select.select()会返回，如果没有返回，就一直阻塞。
22         serverSocket.register(selector, SelectionKey.OP_ACCEPT);
23     }
24     public void listen() throws IOException {
25         System.out.println("服务器启动");
26         //轮询访问select.select()
27         while(true) {
28             //当事件到达时返回，否则一直阻塞
29             Channel channel = selector.select();
30             //获取selector中选中项的迭代器，相中的项为注册事件。
31             Iterator<SelectionKey> iterator = this.selector.selectedKeys().iterator();
32             while(iterator.hasNext()) {
33                 SelectionKey selectionKey = iterator.next();
34                 //删除已选的key，防止重复处理
35                 iterator.remove();
36                 handler(selectionKey);
37             }
38         }
39     }
40     public void handler(SelectionKey key) throws IOException {
41         if(key.isAcceptable()) {
42             handlerAccept(key);
43         }else if(key.isReadable()) {
44             handlerRead(key);
45         }
46     }
47     public void handlerAccept(SelectionKey key) throws IOException {
48         //获取以有的通道
49         ServerSocketChannel channel = (ServerSocketChannel) key.channel();
50         //获取和客户端连接的通道
51         SocketChannel accept = channel.accept();
52         //设置为非阻塞
53         accept.configureBlocking(false);
54         // 在这里可以给客户端发送信息哦
55         System.out.println("新的客户端连接");
56         //连接成功之后，为了读取客户端传送的消息，需要设置读权限
57         accept.register(selector, SelectionKey.OP_READ);
58     }
59     public void handlerRead(SelectionKey key) throws IOException {
60         //服务器可读取消息，获取事件发生的Socket通道
61         SocketChannel channel = (SocketChannel) key.channel();
62         //创建读取内容的缓存区buffer
63         ByteBuffer buffer = ByteBuffer.allocate(1024);
64         int read = channel.read(buffer);
65         if(read > 0) {
66             byte[] array = buffer.array();
67             String msg = new String(array).trim();
68             System.out.println("服务端收到信息：" + msg);
69             
70             //会写
71             ByteBuffer byteBuffer = ByteBuffer.wrap("success".getBytes());
72             channel.write(byteBuffer);
73         }else {
74             System.out.println("客户端关闭");
75             key.cancel();
76         }
77     }
78 }

六、selector.select()

selector.select() 虽阻塞，但可以通过 **selector.wakeup()**唤醒 selector 执行，也可以通过 selector.select(int timeout) 设置时间限制，timeout 时间后唤醒 selector。

七、NIO提高性能

添加多线程，一个线程对应一个 selector，端口的监听可以单独创建一个 selector。（既Netty的工作原理）

总结：NIO允许你用一个单独的线程或几个线程管理很多个 channels（网络的或者文件的），代价是程序的处理和处理 IO相比更加复杂。如果你需要同时管理成千上万的连接，但是每个连接只发送少量数据，例如一个聊天服务器，用 NIO实现会更好一些，相似的，如果你需要保持很多个到其他电脑的连接，例如P2P网络，用一个单独的线程来管理所有出口连接是比较合适的。