NIO的多线程优化

单线程会浪费多核的优势

单线程如果在某一业务上花费时间过长,会影响其他业务的处理

boss负责连接,worker负责读写

服务端代码:

package com.netty.demo;import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
import java.util.Set;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.atomic.AtomicInteger;import static com.netty.demo.ByteBufferUtil.debugAll;public class ThreadsServer {public static void main(String[] args) {try (ServerSocketChannel server = ServerSocketChannel.open()) {// 当前线程为Boss线程Thread.currentThread().setName("Boss");server.bind(new InetSocketAddress(8080));// 负责轮询Accept事件的SelectorSelector boss = Selector.open();server.configureBlocking(false);server.register(boss, SelectionKey.OP_ACCEPT);// 创建固定数量的WorkerWorker[] workers = new Worker[4];// 用于负载均衡的原子整数AtomicInteger robin = new AtomicInteger(0);for(int i = 0; i < workers.length; i++) {workers[i] = new Worker("worker-"+i);}while (true) {boss.select();Set<SelectionKey> selectionKeys = boss.selectedKeys();Iterator<SelectionKey> iterator = selectionKeys.iterator();while (iterator.hasNext()) {SelectionKey key = iterator.next();iterator.remove();// BossSelector负责Accept事件if (key.isAcceptable()) {// 建立连接SocketChannel socket = server.accept();System.out.println("connected...");socket.configureBlocking(false);// socket注册到Worker的Selector中System.out.println("before read...");// 负载均衡,轮询分配Workerworkers[robin.getAndIncrement()% workers.length].register(socket);System.out.println("after read...");}}}} catch (IOException e) {e.printStackTrace();}}static class Worker implements Runnable {private Thread thread;private volatile Selector selector;private String name;private volatile boolean started = false;/*** 同步队列,用于Boss线程与Worker线程之间的通信*/private ConcurrentLinkedQueue<Runnable> queue;public Worker(String name) {this.name = name;}public void register(final SocketChannel socket) throws IOException {// 只启动一次if (!started) {thread = new Thread(this, name);selector = Selector.open();queue = new ConcurrentLinkedQueue<>();thread.start();started = true;}// 向同步队列中添加SocketChannel的注册事件// 在Worker线程中执行注册事件queue.add(new Runnable() {@Overridepublic void run() {try {socket.register(selector, SelectionKey.OP_READ);} catch (IOException e) {e.printStackTrace();}}});// 唤醒被阻塞的Selector// select类似LockSupport中的park,wakeup的原理类似LockSupport中的unparkselector.wakeup();}@Overridepublic void run() {while (true) {try {selector.select();// 通过同步队列获得任务并运行Runnable task = queue.poll();if (task != null) {// 获得任务,执行注册操作task.run();}Set<SelectionKey> selectionKeys = selector.selectedKeys();Iterator<SelectionKey> iterator = selectionKeys.iterator();while(iterator.hasNext()) {SelectionKey key = iterator.next();iterator.remove();// Worker只负责Read事件if (key.isReadable()) {// 简化处理,省略细节SocketChannel socket = (SocketChannel) key.channel();ByteBuffer buffer = ByteBuffer.allocate(16);socket.read(buffer);buffer.flip();ByteBufferUtil.debugAll(buffer);}}} catch (IOException e) {e.printStackTrace();}}}}
}

客户端代码:

package com.netty.demo;import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.channels.SocketChannel;
import java.nio.charset.Charset;public class TestClient {public static void main(String[] args) throws IOException{SocketChannel sc = SocketChannel.open();sc.connect(new InetSocketAddress("localhost",8080));sc.write(Charset.defaultCharset().encode("1234567890abcdef"));System.in.read();}
}

一般worker的数量设置为cpu的核心数比较合适

阻塞I/O模型

非阻塞I/O模型:

多路复用I/O模型:

零拷贝:

 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/484815.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

国产CPU深度研究报告(干货,110页)

来源&#xff1a;特大牛 来自特大号&#xff08;ITXXXL&#xff09;来自特大号&#xff08;ITXXXL&#xff09;来自特大号&#xff08;ITXXXL&#xff09;来自特大号&#xff08;ITXXXL&#xff09;来自特大号&#xff08;ITXXXL&#xff09;未来智能实验室的主要工作包括&…

logging模块(* * * * *)

一 (简单应用)、 import logging logging.debug(debug message) logging.info(info message) logging.warning(warning message) logging.error(error message) logging.critical(critical message) 输出&#xff1a; WARNING:root:warning messageERROR:root:erro…

业界首个!华为联合中国信通院等发布《网络体系强基展望白皮书》

来源&#xff1a; 华为数据通信编辑&#xff1a; 杨盼近日&#xff0c;华为联合中国信息通信研究院等单位&#xff0c;共同发布《网络体系强基展望白皮书》(以下简称《白皮书》)。《网络体系强基展望白皮书》从工业网络现状、趋势和需求出发&#xff0c;首次提出了“工业设备网…

【原】Win SQL Server2012 IIS 安装(图文详解)

1、进入服务器管理&#xff0c;点击添加“添加角色和功能” 2、单击“安装类型”&#xff0c;然后选择“基于角色或者功能得安装”&#xff0c;单击下一步 3、选择“从服务器池中选择服务器”&#xff0c;单击下一步 4、在角色列表里面找到“Web服务器(IIS)”&#xff0c;并勾选…

终极孵化器:仿生婴儿的美丽新世界

Conceptual Photograph: The Voorhes来源&#xff1a; IEEE电气电子工程师子宫是人类生物学中最复杂的构造之一&#xff1a;可以帮助完成从胚胎到胎儿再到婴儿的壮举。但是如果没有胎盘&#xff0c;这种巨大的转化也是不可能实现的&#xff0c;胎盘是一种赋予生命的器官&#x…

学界丨北大清华合力打造通用人工智能实验班,朱松纯教授领衔

来源&#xff1a;北京大学微信公众号、AI科技评论、新智元据悉&#xff0c;首批北大通班同学已经开课&#xff0c;清华通班也已启动首批招生。师资方面&#xff0c;清华和北大各有优势学科&#xff0c;在通班的合作上可以优势互补&#xff1b;在平台方面&#xff0c;以朱松纯教…

struts2_模型驱动

一.注意点 建立实现ModelDriven接口的action类在该action类中,创建实体对象并new在getModel返回该对象在显示页面中提交的表单name正常写二.案例 创建实体类User: package com.ahd.entity;import com.opensymphony.xwork2.ModelDriven;public class User{private String userna…

美智库预言特斯拉十年内退出中国:已踩红线,谷歌就是前车之鉴

来源&#xff1a;厚势汽车编辑&#xff1a;琪琪2020 年年末&#xff0c;在经历了 8 年的发展期后&#xff0c;特斯拉终于在中国市场站稳了脚跟。2020 年销售暴涨&#xff0c;在中国电动车市场占比达到 21% &#xff0c;全球仅第四季度就交付 18 万辆电动车&#xff0c;相对于第…

222页斯坦福人工智能报告出炉:全球AI投资猛增680亿,北美博士学术机构就业率下降

来源&#xff1a;中国自动化学会编辑 ∑Gemini1、我们生活在一个「人工智能」的时代如图所示&#xff0c;人工智能的研究正在蓬勃发展&#xff1a;在2019年&#xff0c;全球发表了超过12万篇的AI论文。在2000年至2019年之间&#xff0c;人工智能的论文占所有同行评审论文的比例…

量子理论的哲学宣言

来源&#xff1a;《中国社会科学》2019年第2期作者&#xff1a;成素梅&#xff08;上海社会科学院&#xff09;本文为国家社会科学基金重大项目“当代量子论与新科学哲学的兴起”(16ZDA113)阶段性成果。关于量子理论的哲学研究有两个层次&#xff0c;一是根据量子理论及其技术的…

2050大会走向通用人工智能专场总结

来源&#xff1a;混沌巡洋舰这两天主持了阿里云A组召集的杭州云栖小镇的2050大会《走向更加通用的人工智能》专场。活动分为论坛和深度交流两部分。也邀请了来自神经符号&#xff0c;类脑计算&#xff0c;复杂系统的很多朋友共同交流。我觉得如果来总结这个主题&#xff0c; 我…

一种基于平衡二叉树(AVL树)插入、查找和删除的简易图书管理系统

目录1. 需求分析2. 项目核心设计2.1 结点插入2.2 结点删除3 测试结果4 总结分析4.1 调试过程中的问题是如何解决的&#xff0c;以及对设计与实现的回顾讨论和分析4.2 算法的时间和空间复杂度的分析&#xff0c;以及进一步改进的设想4.3 本次实验的经验和体会5 完整代码(C)1. 需…

物联网产业104页深度研究报告:物联网研究框架与投资机会分析

报告出品方&#xff1a;国信证券作者&#xff1a;马成龙、付晓钦、陈彤1物联网是未来五年甚至十年的大赛道1.1 物联网&#xff1a;下一代网络网络革命的本质是连接主体和连接方式的变化&#xff1a;第一代互联网&#xff08;PC互联网&#xff09;是计算机与计算机之间的联网&am…

随笔:朋友圈扫街图有感(爱情)

#声明&#xff1a;照片来自我的一位甘姓友人&#xff0c;并非本人所拍。但为之感动&#xff0c;尤其震撼。 皮夹里老照片上恰风华正茂的少年&#xff0c;但如今一双褶皱的手&#xff0c;缓缓掏出过了时的纸币&#xff0c;无疑岁月蹉跎&#xff0c;当年的Ta早已成了耄耋老人。说…

浅谈SDN架构下的运维工作

导读目前国内的网络运维还处于初级阶段&#xff0c;工作人员每天就像救火一样&#xff0c;天天疲于奔命。运维人员只能埋头查找系统运行的日志&#xff0c;耗时耗力&#xff0c;老眼昏花不说&#xff0c;有时候忙了半天还一无所获&#xff0c;作为运维工程师的你&#xff0c;有…

华为自动驾驶实车实路测试视频曝光!徐直军:比特斯拉好多了

资料来源&#xff1a;量子位、物联网智库等整理发布&#xff1a;物联网智库 昨日&#xff08;4月15日&#xff09;&#xff0c;消息称配备华为自动驾驶技术的北汽新能源极狐阿尔法S的HI版车型在上海进行了公开试乘&#xff0c;这也是华为自动驾驶技术公开试乘的全球首秀。以下视…

Pycharm社区版运行Django的三种方法(Pycharm添加配置参数快捷启动Django、Pycharm社区版Django项目创建)

目录Pycharm社区版运行Django的三种方法Django安装和环境变量的配置&#xff08;MacOS&#xff09;创建Project启动Django Webserver方法一&#xff1a;终端启动方法二&#xff1a;pycharm项目界面启动方法三&#xff1a;pycharm社区版实现直接启动Pycharm社区版运行Django的三…

日本机器人全球领先来自这三大顶尖技术

来源&#xff1a;工业机器人▍日本尖端技术之一&#xff1a;机器人精密减速机世界上工业机器人使用的精密减速机几乎都为日本所垄断。尽管国内也量产的RV减速机&#xff0c;但国产机器人企业却鲜有选用的&#xff0c;原因是日本精密减速机技术遥遥领先&#xff0c;短期很难替代…

仰望星空后,更将脚踏实地!

仰望星空后&#xff0c;更将脚踏实地&#xff01;

在目标检测中如何解决小目标的问题?

作者&#xff1a;Nabil MADALI来源&#xff1a;AI公园编译&#xff1a;ronghuaiyang在深度学习目标检测中&#xff0c;特别是人脸检测中&#xff0c;由于分辨率低、图像模糊、信息少、噪声多&#xff0c;小目标和小人脸的检测一直是一个实用和常见的难点问题。然而&#xff0c;…