多线程笔记 - 伪异步IO
2020-03-01 16:06:15来源:博客园 阅读 ()
多线程笔记 - 伪异步IO
BIO的时候, 一个客户端对应服务器的一条线程, 比较耗线程资源.
在此基础上, 对起线程进行优化, 创建一个线程池, 对线程进行管理, 可以设置一个最大线程数 maxThreadCount. 这样, 达到线程可控的目的.
即使外面有远大于线程数的连接过来, 也不至于让服务器撑爆.
多出的客户端, 就进入线程池的队列中排队.
伪异步IO 是Netty权威指南里面提到的, 并不是一个公认的说法或者官方的说法.
这里只需要修改服务端的代码即可:
server:
public class Server implements Runnable { private Socket socket; public Server(Socket socket) { this.socket = socket; } @Override public void run() { BufferedReader in = null; PrintWriter out = null; try { in = new BufferedReader(new InputStreamReader(socket.getInputStream())); out = new PrintWriter(socket.getOutputStream(), true); System.out.println("server : 客户端接入" + socket.toString()); while (true) { String msg = in.readLine(); if (msg == null) { break; } System.out.println("from client : " + msg); if (msg.equals("几点了")) { out.println(new DateTime(2020,1,1,1,1,1).toString("yyyy-MM-dd HH:mm:ss")); } else{ out.println("没看懂..."); } } } catch (Exception e) { e.printStackTrace(); } finally { if (in != null) { try { in.close(); } catch (IOException e) { e.printStackTrace(); } } if (out != null) { out.close(); } if (this.socket != null) { try { this.socket.close(); } catch (IOException e) { e.printStackTrace(); } } } } public static void main(String[] args) throws Exception { final ServerSocket serverSocket = new ServerSocket(1234); try { int maxPoolSize = 100; ThreadPoolExecutor threadPool = new ThreadPoolExecutor( Runtime.getRuntime().availableProcessors(), maxPoolSize, 120L, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(1000) ); System.out.println("服务器启动, 开始监听 1234 端口"); Socket socket = serverSocket.accept(); System.out.println("监听到一个连接"); threadPool.execute(new Server(socket)); } finally { serverSocket.close(); } } }
我这里直接在main 方法里面, 创建了一个自定义线程池, 并放了一个长度为 1000 的有界队列进去.
客户端代码不变
clientA:
public class ClientA { public static void main(String[] args) throws IOException { //与服务器建立连接 Socket socket = new Socket("127.0.0.1", 1234); BufferedReader in = null; PrintWriter out = null; try { in = new BufferedReader(new InputStreamReader(socket.getInputStream())); out = new PrintWriter(socket.getOutputStream(), true); out.println("几点了"); while (true) { String serverMsg = in.readLine(); if(serverMsg == null){ break; } System.out.println("from server : " + serverMsg); } } finally { if (in != null) { try { in.close(); } catch (IOException e) { e.printStackTrace(); } } if (out != null) { out.close(); } if (socket != null) { try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } } } }
结果也是不变的:
clientA:
server:
这种方式任然是一种阻塞的方式.
参考:
Netty权威指南
原文链接:https://www.cnblogs.com/elvinle/p/12388427.html
如有疑问请与原作者联系
标签:
版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有
- Spring WebFlux 学习笔记 - (一) 前传:学习Java 8 Stream Ap 2020-06-11
- Java笔记:集合 2020-06-10
- Java基础语法菜鸟教程笔记 2020-06-10
- 黑菜菌的JAVA学习笔记 2020-06-09
- Java笔记:数组,异常,泛型 2020-06-08
IDC资讯: 主机资讯 注册资讯 托管资讯 vps资讯 网站建设
网站运营: 建站经验 策划盈利 搜索优化 网站推广 免费资源
网络编程: Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它
服务器技术: Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护
软件技巧: 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷
网页制作: FrontPages Dreamweaver Javascript css photoshop fireworks Flash