BIO
程序员文章站
2024-01-22 14:21:46
...
前言:今天在学习netty,看了BIO一章,内容也非常的简单,书中的例子也非常的简单,我又把其中的代码敲了一遍,感觉虽然简单,却受益匪浅,使我对阻塞同步式IO有了更清晰的认知。
经典的BIO例子,就是有一个服务端,负责监听客户端连接,然后为每一个客户端建立线程,处理客户端的请求,处理完成后销毁。
通过代码,我们就可以看出来,同步阻塞IO的弊端就是当客户端连接数膨胀后,系统的性能将会急剧下降,因为为每一个客户端开启一个线程,然后处理完成一个请求关闭,将会造成大量的内存垃圾。
package com.honzh.mwq.bio.server; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; import com.honzh.mwq.bio.server.handler.TimeServerHandler; public class TimeServer { public static void main(String[] args) { ServerSocket server = null; try { server = new ServerSocket(9901); System.out.println("server running at port: " + 9901); Socket socket = null; while (true) { socket = server.accept(); new Thread(new TimeServerHandler(socket)).start(); } } catch (IOException e) { e.printStackTrace(); } finally { if (server != null) { System.out.println("server close"); try { server.close(); } catch (IOException e) { e.printStackTrace(); } server = null; } } } }
上类创建一个server对象,等待客户端连接,在接收到客户端连接后,启动一个线程进行socket处理。
package com.honzh.mwq.bio.server.handler; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; public class TimeServerHandler implements Runnable{ private Socket socket; private BufferedReader br = null; private PrintWriter pw = null; public TimeServerHandler(Socket socket) { this.socket = socket; } @Override public void run() { try { br = new BufferedReader(new InputStreamReader(socket.getInputStream())); pw = new PrintWriter(socket.getOutputStream(), true); while (true) { String order = br.readLine(); if (order != null) { System.out.println("the order is: " + order); if (order.equals("query")) { pw.println(System.currentTimeMillis()); } } else { break; } } } catch (Exception e) { if (br != null) { try { br.close(); } catch (IOException e1) { e1.printStackTrace(); } } if (pw != null) { pw.close(); pw = null; } if (socket != null) { try { socket.close(); socket = null; } catch (IOException e1) { e1.printStackTrace(); } } } } }
上类也非常的简单,线程启动后,获取客户端socket请求,如果请求到数据,则进行处理,等消息都处理完成后退出循环,然后等待资源回收。
package com.honzh.mwq.bio.client; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; import java.net.UnknownHostException; public class TimeClient { public static void main(String[] args) { Socket socket = null; BufferedReader br = null; PrintWriter pw = null; try { socket = new Socket("127.0.0.1", 9901); br = new BufferedReader(new InputStreamReader(socket.getInputStream())); pw = new PrintWriter(socket.getOutputStream(), true); pw.println("query"); String result = br.readLine(); System.out.println("now time is: " + result); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } finally { if (br != null) { try { br.close(); } catch (IOException e1) { e1.printStackTrace(); } } if (pw != null) { pw.close(); pw = null; } if (socket != null) { try { socket.close(); socket = null; } catch (IOException e1) { e1.printStackTrace(); } } } } }
上类启动客户端,进行socket连接,发送查询命令,然后获取处理信息,然后进行资源回收。
总结:以上内容非常的简单,也易于理解,但是重新手写一下,加上写这篇博客,让我对此的印象会更加深刻。
上一篇: 为什么在做后台的时候大家都喜欢用iframe的结构来做,为什么不直接跳转?
下一篇: 数据库范式