网络通信、BIO、NIO

news2024/9/26 3:28:52

1. 涉及的网络基础知识

Socket:

操作系统提供的api,介于应用层和tcp/ip层之间的软件层,封装服务器客户端之间网络通信相关内容,方便调用

IO多路复用:

(I/O Multiplexing)是一种IO操作模式,它允许单个进程或线程同时处理多个输入输出(IO)操作。

怎么算一个连接:

tcp层中,客户端ip、客户端端口、服务器ip、服务器端口,这4个算一个连接。

通信接收流程:

3步:接收连接、读取数据、写入数据

服务器端接收连接、服务器端读取客户端发来的数据、服务器端写入客户端发来的数据并进行业务处理。

应用程序java在处理通信的两个前提:

1、客户端a与服务器b通信,a的数据到达b的操作系统的socket的缓冲区中。这时候java要如何接收并处理这些数据呢?java会调用操作系统提供的socket api进行操作。

2、如果很多客户端与服务器b通信,并发量上来了,java又如何管理和处理这么多的连接呢?java有BIO(Blocking I/O,阻塞IO)和NIO(no-blocking I/O,非阻塞)两种

2. Java NIO和BIO的区别

  1. 阻塞与非阻塞
    • BIO是同步阻塞的。当线程发起I/O请求时,如果没有数据可读或可写,线程会一直阻塞,直到数据准备就绪。
    • NIO是同步非阻塞的。线程发起I/O请求后,如果没有数据可读或可写,线程不会阻塞,而是可以去做其他事情。当数据准备就绪时,线程会被通知去处理数据。
  2. I/O模型
    • BIO是基于流的。数据被顺序地从一个流读取到另一个流,期间没有缓存,且不能前后移动流中的数据。
    • NIO是基于缓冲区的。数据被读取到一个缓冲区中,需要时可以在缓冲区中前后移动,增加了处理过程中的灵活性。
  3. 线程管理
    • BIO中,每个连接都需要一个独立的线程来处理。这种方式在连接数较少时可行,但在连接数较多时会导致线程数量过多,系统资源消耗大。
    • NIO中,一个线程可以处理多个连接。这是通过Selector和Channel实现的,Selector可以监听多个Channel上的事件,从而允许单个线程管理多个连接。这就是IO多路复用。
  4. 适用场景
    • BIO适用于连接数较少且固定的场景。
    • NIO适用于连接数多且连接时间较短的场景,如聊天服务器、弹幕系统等。它能够有效减少线程数量,降低系统资源消耗,提高并发处理能力。

3、BIO和NIO详解

如果服务器b上同时有多个连接,下面我称为连接1号、连接2号等。

  • 基础版本:java原生bio

流程:读取连接1号socket中的数据,如果数据没有准备好,或者遇到一些其他问题,就会阻塞,一直等到问题解决好。连接1号处理好后,开始处理连接2号,获取连接2号数据与业务处理。

缺点:阻塞,并发量小

 

  • 改进版:伪异步IO

725a8c9128824cdea0e688d0fb8671e9.png

f2ef6fb50c8142f29590c1bf3dcfc497.png

f3a9dc6548d74ba992897556e963bcc7.png

流程:acceptor+处理器。acceptor用来处理连接,处理器用来接收和处理数据。连接1号来了,acceptor就开一个新线程交给一个处理器a去获取连接1号socket数据并业务处理数据。接着acceptor给连接2号开个新线程,交给处理器b去接收并业务处理连接2号。这样连接1号和2号就同时处理了。

优点:并发量大,因为开了线程

缺点:如果并发量多,线程多,消耗多,可能内存爆掉,这点可以通过线程池来控制线程量。

但是因为处理器本身还是阻塞的,如果连接1号的数据没准备好,读取不了数据,这个时候处理器a会等待,也就是cpu在等待,cpu时间其实就浪费了,所以如果并发量很大,性能还是不高

 

  • 改进版:非阻塞IO

流程:如果连接1号的处理器的数据还没准备好,读取不了,这个时候cpu不等待,cpu可以先去处理其他的连接,这个就是不阻塞啦,cpu处理好其他连接,回来处理连接1号时,此时连接1号的数据准备好了,cpu就能顺利的接收连接1号的数据并进行业务处理。

缺点:这个是让cpu在所有处理器(连接1号、连接2号...)中做个轮询,但可能这次轮询到1号,发现1号还是没有准备好,所以还有没有更好的办法呢?

 

  • 改进版:原生jdk网络编程——NIO

3a6fee5fbdf14f68a1851a4e377c2864.png

1b9ae9847e604d2a9611da38d470a5b8.png

3d712a1955924dd3a48aba307b4f7c2e.png

1、Reactor反应器模式

就是一种倒转思维,由处理器主动发布信号

接着上边的讲。如果cpu轮询,发现1号还是没有准备好,那不是也浪费了cpu资源?

所有最好是1号准备好了,来叫我,这时候我cpu去处理就比较顺利。每个连接准备好了,给个信号,我cpu只去处理有这个信号的连接,这样就更快一点。这就是反应器模式!

2、三大组件:selector、channel、buffer

selector:

相当于cpu、acceptor,主要起到记录和调度作用。记录事件与channel的关系,从而帮助分配channel

channel:

相当于处理器。主要有两个

ServerSocketChannel:相当于acceptor,是一个可以监听TCP连接请求的通道。当服务器程序创建一个ServerSocketChannel并绑定到一个特定的端口后,它就开始监听该端口上的连接请求。需ServerSocketChannel本身并不直接“接收”连接,而是触发了一个“连接到达”的事件,即给个“有连接啦”的信号,告知一下

SocketChannel:相当于处理器。一个socketChannel处理一个连接,一个连接可能有多个socketChannel。主要是接收这个连接的数据,并调用业务代码处理数据。

buffer:

用于存储数据,channel从buffer中读写数据

3、服务器端流程:

接收连接

ServerSocketChannel去selector注册,关注OP_ACCEPT接收事件。ServerSocketChannel绑定8808端口,会监听tcp层8808端口,如果发现有连接到达,ServerSocketChannel会给信号,就是触发一个OP_ACCEPT接收事件。 

selector一直在轮询,查看注册下的channel中是否有事件触发,有的话就回去执行channel。这时候发现ServerSocketChannel触发注册时关注的OP_ACCEPT事件了,selector就调用ServerSocketChannel的accept()方法开始接收连接,ServerSocketChannel就会创建并返回一个SocketChannel,然后把这个SocketChannel注册到selector上,并写上关注OP_READ事件,然后ServerSocketChannel就接着去监听还有没有新的连接到来了。接收并处理这个连接的内容是由这个SocketChannel去做的。

处理连接数据

连接socket的数据准备好了,操作系统会更新数据状态,channel就会知道(因为channel的底层是socket),然后就会给出信号,触发一个OP_READ可读事件。

selector一直在轮询,查看注册下的channel中是否有事件触发,发现这个SocketChannel注册时关注的OP_READ事件触发了,就会调用SocketChannel的read()方法,执行相关操作。这个channel可以设置为非阻塞,非阻塞的话就是,如果出现问题,直接返回一个值。也可以设置为阻塞,阻塞的话,就是出现问题,一直等待。

4、理解

所以这里的cpu是selector,selector一直在轮询那些事件触发了(也就是准备好了的,大概率不会阻塞的)的channel,然后去执行channel,这样cpu就不会闲置,通过selector就能管理多个channel,即管理多个连接。而channel呢,就不是被动接受,而是主动告知selector,channel自己监控自己,当准备好了,就触发下事件,主动给告知selector。

优点:最大限度压榨cpu性能,让cpu不闲着

 

 

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

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

相关文章

《算法笔记》总结No.5——递归

一.分而治之 将原问题划分为若干个规模较小而结构与原问题相同或相似的子问题,然后分别解决这些子问题,最后合并子问题的解,即可得到原问题的解,步骤抽象如下: 分解:将原问题分解为若干子问题解决&#x…

网络基础:二层交换与多层交换

二层交换 二层交换是以太网交换机的基本功能;二层交换指的是交换机根据数据帧的第二层头部中的目的MAC地址进行帧转发的行为。 每台交换机都维护一个MAC地址表,用于指导数据帧转发;MAC地址表(MAC Address Table)&…

基于vue的引入登录界面

以下是一些常见的登录页面布局: 1. 中心布局 - 登录表单位于页面的中心位置,通常包括用户名输入框、密码输入框、登录按钮等元素。页面背景简洁,以突出登录表单。 - 这种布局常见于大多数网站和应用,简洁明了,用户注意…

Spring Boot Vue 毕设系统讲解 3

目录 项目配置类 项目中配置的相关代码 spring Boot 拦截器相关知识 一、基于URL实现的拦截器: 二、基于注解的拦截器 三、把拦截器添加到配置中,相当于SpringMVC时的配置文件干的事儿: 项目配置类 项目中配置的相关代码 首先定义项目认…

WebRTC API接口教程:实现高效会议的步骤?

WebRTC api接口教程如何使用?WebRTC api接口的功能? WebRTC无需中间服务器即可传输音视频流,为视频会议、在线教育等应用提供了强大的支持。AokSend将详细介绍如何利用WebRTC API接口实现高效会议的步骤。 WebRTC API接口教程:获…

澳大利亚TikTok直播为什么需要海外直播专线?

近年来,许多卖家为了解决澳大利亚TikTok直播中的卡顿和高延迟问题,纷纷选择使用海外直播专线。这种专线服务是一种高效、低延迟的数据传输解决方案,专为需要高质量网络连接的场合设计。 与公共互联网相比,海外直播专线提供更稳定、…

海外展会 | 7月8-11日,INNOPROM 2024 ,云仪邀您俄罗斯观展→

7月8日,2024俄罗斯工业博览会(INNOPROM 2024)在俄罗斯工业中心第三大城市“叶卡捷琳堡国际展览中心”隆重举办。作为俄罗斯最大的工业展览会之一,INNOPROM 2024不仅展示了俄罗斯本土的工业实力,更是一个集合了全球最新…

快团团开团大团长和帮卖团长如何合并“收件人信息相同的订单”核销打印?

快团团开团大团长和帮卖团长如何合并“收件人信息相同的订单”核销打印? 一、背景 经营方式为线下自提等无需快递的团长,在核销打印订单时,需要将“收件人信息相同的订单”合并核销打印 二、操作说明 第一步,团长电脑端登陆快…

mybatis 延迟加载

MyBatis的延迟加载(Lazy Loading)是一种优化技术,用于在需要时才加载关联对象或集合,从而提高性能和效率。以下是对MyBatis延迟加载的详细介绍: 延迟加载的基本概念 延迟加载是指在第一次访问对象的属性时才加载该对象…

G24代刷卡鉴权方案

PICK_G24 产品型号 PICK_G24 尺寸 124x90x12mm(不含安装支架) 屏幕尺寸 4.2 inch 显示技术 电子墨水屏显示 显示区域面积 (mm) 84.8(H) x 63.6(V) 分辨率 400*300 像素密度 120dpi 显示颜色 黑/白 外观颜色 白色&灰外圏 按键 …

关于 Mac 系统 .DS_store 文件的起源

原文:Arno - 2006.10.01 (前排提醒:可以在 .gitignore 中添加 .DS_Store,否则 git 仓库会存储这个和项目无关的文件。) 如果你是 Mac 用户,曾经将文件从 Mac 传输到 Windows,那么可能对 .DS_S…

跟极光同频共振?!VELO Angel Ride坐垫,在挪威一起踏上的绿色征途!

如果可以选择,你喜欢徒步旅行还是骑脚踏车呢?      在挪威那片被午夜阳光亲吻的土地上,每一次骑行都是一场与自然对话的盛宴。维乐Angel Ride坐垫,作为环保与骑行舒适度的完美结合,携手每一位探索者,在这片北欧仙…

如何把excel翻译成中文?简单又实用的excel翻译器分享

自打步入职场之后,我才逐渐发现原来处理多语言的Excel文档现已经成为了职场人经常需要面对的挑战~传统的手动翻译不仅耗时费力,还容易出错,尤其是在面对大量数据和复杂的公式时,更是令人头疼。 幸运的是,后来被我发现…

生成图质量评价

1. RichHF-18K 论文地址 解决问题: 如何对生成图质量进行算法评价,以优化图片质量,提升模型生成能力 解决思路: 参考多模态模型,构建评价模型,从7个维度分三个分支对生成图进行测评: Tips&…

【鸿蒙学习笔记】交互事件

官方文档:交互事件 目录标题 分类交互事件-触屏交互事件-手势事件单一手势 分类 交互事件-触屏 在组件上按下(Down) , 滑动(Move) , 抬起(up)时触发的回调事件。包括点击事件、触摸事件和拖拽事件 交互事件-手势事件 在手机上点击打开应用 , 长按后拖动应用 , 这…

idea中的块映射中的子元素无效

在yml文件中,出现块映射中的子元素无效,如图: 在YAML文件中,通常需要在键和值之间添加空格,以确保文件的可读性和正确解析。一些YAML解析器可能要求在冒号后面必须有空格才能正确解析文件。如果不加空格,解…

eventFilter事件过滤器

通过使用eventFilter 事件过滤器&#xff0c;实现QLabel的 Enter、Leave 、MouseButtonPress、MouseButtonDblClick、MouseButtonRelease EventFilterExample.h #ifndef EVENTFILTEREXAMPLE_H #define EVENTFILTEREXAMPLE_H#include <QWidget>namespace Ui { class Event…

C++内存的一些知识点

一、内存分区 在C中&#xff0c;内存主要分为以下几个区域&#xff1a; 代码区&#xff1a;存放函数体的二进制代码。 全局/静态存储区&#xff1a;存放全局变量和静态变量&#xff0c;这些变量在程序的整个运行期间都存在。常量存储区&#xff1a;存放常量&#xff0c;这些值…

聚观早报 | 2025款比亚迪海豚上市;小米15系列防水细节

聚观早报每日整理最值得关注的行业重点事件&#xff0c;帮助大家及时了解最新行业动态&#xff0c;每日读报&#xff0c;就读聚观365资讯简报。 整理丨Cutie 7月9日消息 2025款比亚迪海豚上市 小米15系列防水细节 荣耀Magic V3将更轻薄 真我GT6通信细节 Apple Watch SE将…

修改服务器挂载目录

由于我们的项目通常需要挂载一个大容量的数据盘来存储文件数据&#xff0c;所以我们每台服务器都需要一个默认的挂载目录来存放这些数据&#xff0c;但是由于我们的误操作&#xff0c;导致挂载目录名字建错了&#xff0c;这时候后端就读不到挂载目录了&#xff0c;那我们我们的…