【网络】高并发场景处理:线程池和IO多路复用

news2024/12/28 6:28:11

文章目录

  • 短时间内有大量的客户端的解决方案
    • 线程池
    • IO 多路复用

短时间内有大量的客户端的解决方案

创建线程是比较经典的一种服务器开发模型,给每个客户端分配一个线程来提供服务

  • 但一旦短时间内有大量的客户端,并且每个客户端请求都是很快的,这个时候对于服务器来说,就会有比较大的压力
  • 虽然创建线程比创建进行更轻量,但也架不住短时间内创建销毁大量的线程
    所以引入线程池,来解决这样的问题
public void start() throws IOException {  
    System.out.println("启动服务器");  
    //创建线程池  
    ExecutorService service = Executors.newCachedThreadPool();  
    while(true) {  
        //建立连接  
        Socket clientSocket = serverSocket.accept();  
        //创建线程,每个线程去服务一个客户端  
        /*Thread t = new Thread(() -> {  
            try {                processConnection(clientSocket);            } catch (IOException e) {                throw new RuntimeException(e);            }        });        t.start();*/                


        //使用线程池
        service.submit(() -> {  
            try {  
                processConnection(clientSocket);  
            } catch (IOException e) {  
                throw new RuntimeException(e);  
            }        
        });    
    }
}

晚上 21:00开始比赛,可能就有几百万人涌入直播间

  • 这瞬间几百万格客户端就连上服务器了
  • 现代的服务器针对上述高并发场景,肯定是分布式(集群)方式来应对
    • 一台服务器无论如何也是没法去应对几百万个客户端,所以就引入更多的服务器

线程池

  1. 客户端发一个请求之后就快速断开连接了
    • 线程池解决的是这个问题
    • 线程池本质上也是一个线程服务于一个客户端,使用线程池就是在复用线程
    • 这样只能避免线程频繁创建和销毁,但如果同时有很多客户端,也需要有很多线程
ExecutorService service = Executors.newCachedThreadPool();
  • 此处使用的是这个线程池,他的最大线程数是非常非常大的
  • newFixedThreadPool 是需要指定最大线程数的,但如果固定线程数,就意味着同时只能处理这么多个客户端 image.png|445

IO 多路复用

  1. 客户端持续地发送请求处理响应,连接会保持很久
  • 这样的场景下,使用多线程/线程池都不合适
    • 每个客户端分配一个线程,对于一个系统来说,这里搞几百个线程,压力就非常大了
    • 此时一个服务器可能要处理上万个,几十万个客户端

针对这个问题,还有一个方案能解决这个问题,虽然数目非常多,但仍然可以使用较少的线程,提供高效的服务——IO 多路复用

希望在进行网络服务器开发的时候,可以使用更少的线程,处理更多的客户端

  • 虽然刚才是一个线程服务于一个客户端,实际上,每个这样的线程都可能会阻塞(客户端也不是持续地发请求的)
  • 相比于处理请求的时间,大部分的时间可能都是在阻塞等待
  • 如果可以让一个线程给多个客户端提供服务,那就正好了
    • 比如给一个线程分配 1000 个客户端进行处理,同一时刻,可能只有几十个客户端需要处理请求
    • 针对这样的情况,就需要操作系统内部提供支持了

IO 多路复用,也就是操作系统内核提供的功能(IO 多路复用具体的实现方案有很多种,最知名的就是 Linux 下的 epoll

  • epoll 就是在内核中,搞了一个数据结构,你可以把多个 Socket(每个 Socket 对应一个客户端)放到这个数据结构里
  • 同一时刻,大部分的 Socket 都是处于阻塞等待(没有数据需要处理),少数收到数据的 Socketepoll 就会通过回调函数的方式,通知应用程序,这里有数据了
  • 应用程序,就可以使用少量的线程,针对这里“有数据”的 Socket 进行处理即可

比如你今晚,你想吃烧烤,你妈想吃饺子,你爸想吃炒菜

  1. 你自己去买,先买烧烤,等;再买饺子,等;再买炒菜,等;完成。——>单线程,花的时间是最多的
  2. 你们三个一起去买,各买各的,分别等;完成——>多线程,花的时间机会缩短很多,等待的时间是三者最大值,系统开销也会更大
  3. 你自己去买,你先去买烧烤,给老板说“好了叫我”;再去买饺子,给老板说“好了叫我”;再去买炒菜,给老板说“好了叫我”,此时一个线程同时等待三份饭——>IO 多路复用的方案,此时等待的时间相比于多线程方案,相差不大,但是只需要一个线程就可以了
  • 最关键的就是老爸能够喊我,哪个客户端来数据了,操作系统就能通知到应用程序
  • 服务器开发中最主流的方案,尤其是 IO 多路复用中的 epoll

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

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

相关文章

电路笔记(PCB):串扰的原理与减少串扰的几种方法

串扰 串扰(Crosstalk)是指在电路中,一条信号线上的电磁干扰不经意间耦合到另一条相邻的信号线上,从而影响其正常信号传输的现象。串扰会导致相邻信号线上的信号出现畸变或噪声,从而影响信号的完整性和电路的正常工作。…

【ARM+Codesys 客户案例 】 基于RK3568/A40i/STM32+CODESYS在智能制造中的应用案例:液压动力装置

Poppe Potthoff是一家专门从事高压领域技术研发和产品制造的集团公司,该公司为汽车行业、特种车辆行业、船舶行业等开发制造先进的技术产品。 信迈提供ARMCodesys国产化定制。 Poppe Potthoff在其诺德豪森工厂研发用于爆破测试,自应力加工、脉冲测试和…

深度学习-------------------使用块的网络VGG

目录 VGGVGG块VGG架构进度总结 使用块的网络(VGG)VGG块VGG网络观察每层输出的形状该部分总代码 训练模型 VGG AlexNet比LeNet更深更大,以得到更好的精度 能不能更深和更大?该如何更深更大? 选项: 更多的…

阿里Qwen2开源大模型本地部署及调试全攻略

阿里Qwen2开源大模型本地部署及调试全攻略 #Qwen2系列大模型性能卓越,超越业界知名模型。开源后受到AI开发者关注,支持多种语言,提升多语言理解。在预训练和微调上优化,实现智能水平提升。Qwen2系列模型在各项能力上均领先&#…

基于NXP i.MX8M Mini+FPGA医疗超声诊断设备

医疗超声诊断设备 超声诊断仪,又称超声医疗影像设备,是利用超声波的反射、折射和衍射,对人体内部结构进行探查的仪器。由于超声诊断的无损伤、非介入、经济实用、应用范围广等特点,超声诊断仪也成为目前医疗领域普遍使用的医疗器…

C++_进阶:二叉搜索树

文章目录 1. 二叉搜索树是什么2. 二叉搜索树的基本操作3. 二叉搜索树的实现4 二叉搜索树的性能分析 1. 二叉搜索树是什么 二叉搜索树(BST,Binary Search Tree)又称二叉排序树,它或者是一棵空树,或者是具有以下性质的二叉树: 若它的左子树不…

汉诺塔问题详解及扩展(c++)

汉诺塔(Hanoi Tower)问题是一个著名的数学问题,它涉及到递归算法。问题的背景来源于一个传说:在印度的一个寺庙里,有三根金刚石柱和64个直径大小不一的金盘。僧侣们被命令将这些金盘从一根柱子按照从小到大的顺序移动到…

北京移民服务机构亨瑞移民:汇集全球专业顾问 30年致力全球生活方式

01      北京移民服务机构亨瑞集团成立于1992年,作为一站式海外综合服务专业平台,30年来致力于为有意赴海外求学、拓展事业、居住、生活、工作的各行业人士提供全球教育规划、身份规划及资产全球配置解决方案。    北京移民服务机构亨瑞集团公司…

在 C#/.NET Core 的 Web API 中使用 Swagger 按模块和版本分组并实现排序

文章目录 前言步骤一:安装 Swashbuckle.AspNetCore步骤二:创建自定义特性步骤三:配置 Swagger 生成文档步骤四:标记控制器和方法总结 前言 在开发 RESTful API 时,良好的文档是必不可少的。Swagger 是一种广泛使用的 …

C/C++ 多线程[1]---线程创建+线程释放+实例

文章目录 前言1. 多线程创建2. 多线程释放3. 实例总结 前言 说来惭愧,写了很久的代码,一个单线程通全部。可能是接触的项目少吧,很多多线程的概念其实都知道,但是实战并没有用上。前段时间给公司软件做一个进度条,涉及…

【Docker系列】Docker 容器时区设置指南

💝💝💝欢迎来到我的博客,很高兴能够在这里和您见面!希望您在这里可以感受到一份轻松愉快的氛围,不仅可以获得有趣的内容和知识,也可以畅所欲言、分享您的想法和见解。 推荐:kwan 的首页,持续学…

中国式现代化产业水平数据集(2011-2021年)

中国式现代化是一种社会主义现代化模式,它具有自己独特的特征和发展路径。这一现代化模式以实现国家富强、民族振兴和人民幸福为目标,强调物质文明与精神文明的协调发展以及人与自然的和谐共生 本文将中国式现代化理念与现代化产业体系相结合&#xff0…

希亦、洁盟、苏泊尔眼镜清洗机哪款好用?热门眼镜清洗机测评总结

随着科学技术的发展,电子设备的升级,越来越多的人开始戴眼镜,而眼镜由于长时间的佩戴,镜框以及镜面都积累了一些灰尘以及人们肉眼所看不见的细菌,但是如果你使用普通的清洁方式去清洗的话肯定是清洗不干净的&#xff0…

记录|Label组件如何控制下边框为直线

目录 前言一、问题描述二、重绘三、效果展示更新时间 前言 参考文章: C# WinForm开发时,仅显示label的下边框怎么解决啊? 验证过,方法可靠。并增加控制绘制的直线粗细的功能。 一、问题描述 C# winform中想只给Label组件的下边框…

佳能FAX-L160G打印机驱动程序安装

佳能FAX-L160G打印机驱动程序安装笔记 1.访问佳能官方网站https://www.canon.com.cn或者相关驱动下载网站,搜索并下载适用于佳能FAX-L160G打印机的驱动程序。 在这里跳出来相关系列(没有精确的型号),点进去搜索。 选择第一个驱动…

强化进度慢,武忠祥17堂课怎么听最高效?

武忠祥老师的17堂课怎么看? 我的建议是,别乱看! 17讲内容包括15个主要专题和2个附加专题,整体课时量还是相当大的。 以2023版的课时长度为例,即使你全程以1.5倍速观看且不做任何停顿,平均每个专题至少也…

系统项目管理师----高级----前情调研

要成功通过信息系统项目管理师的考试,需要系统性的学习和多方面的准备。以下是详细的学习资源、推荐的书籍和具体的备考步骤。 一、学习资源与网站 1. 官方网站与指南 中国计算机技术职业资格网:这是软考的官方网站,提供考试大纲、政策法规…

Java编程 : 对象的本质

1.1 从机器视角到问题视角的演变 在计算机科学的发展历程中,我们见证了从机器视角到问题视角的深刻转变。这一转变不仅体现了编程语言和技术的进步,更反映了我们对问题解决方式理解的深化。 起初,计算机编程主要依赖于机器视角。汇编语言作…

FPGA串口调试中当电脑串口无法正常通信,设备管理器中“其它设备”位置显示“USB-Blaster”显示感叹号等问题应该怎么解决?

一、问题描述 当我们进行FPGA开发关于串口等试验的设计中,都需要用到串口,而要使用串口就需要先安装串口驱动,但是在安装驱动的过程中会出现各种各样的问题。 这里就出现了如图所示的停产问题: 在图片中我们可以看到FPGA要使…

【promise】Promise的几个关键问题 (三)

Ⅰ-如何改变 promise 的状态? (1) resolve(value): 如果当前是 pending 就会变为 resolved (2) reject(reason): 如果当前是 pending 就会变为 rejected (3) 抛出异常: 如果当前是 pending 就会变为 rejected Ⅱ-一个 promise 指定多个成功/失败回调函数, 都会调用吗? 当 pro…