当前位置: 首页 > news >正文

Redis深入理解-Socket连接建立流程以及文件事件处理机制

Redis Server 运行原理图

在这里插入图片描述

Redis 服务器中 Socket 网络建立以及文件事件模型

一个 redis 单机,可以抗几百上千的并发,这里的并发指的就是同时可以有几百个 client 对这个 redis server 发起请求,都需要去建立网络连接,同时间可能会有几百个 redis client 通过 socket 和我们的 redis server socket 建立网络连接

如果自己使用 java socket 编程,无论使用 nio、bio,一旦要是说一个 server 和一个 client 完成了一个网络连接之后,就会多出来一个 socket,socket 是抽象出来通信的模型,通过一个 socket 就可以跟对方的 socket 形成一个连接

那么对于 redis server 而言,内部为了支撑并发访问的大量的 redis client,redis server 内部就会有几百个 socket,网络连接同时在维持着

因此呢,在 bio 模式下,一个 socket 连接就对应了一个线程来监听请求

在 nio 模式下,可以实现 IO 多路复用,一个线程就可以监听多个 socket 的网络事件

在 redis server 中,就是通过 FileEventHandler 进行多路复用

socket 中会产生一些网络事件,accept(连接应答)、read(有数据可以读的事件)、write(有数据可以写的事件)、close(连接被关闭) 在 redis 中这些网络事件都被抽象为文件事件

基于队列串行化的文件事件处理机制

针对 server 端的大量的 socket,不太可能每一个 socket 都使用一个线程来监听,因为线程资源不够,所以不会采用 bio 模式,因此解决方案就是针对大量的 socket,使用一个线程监听 n 多个 socket,采用 IO 多路复用模式

当 server 端保持了大量的 redis client 的连接,可能在同一时间,大量的 redis client 并发的给 server 端发送大量的请求,redis server 内部大量的 socket 会突然同一时间产生大量的事件(例如 read 事件,write 事件)

对于这些网络事件的处理,有两种解决方案(Redis Server 中就采用了第一种,使用队列进行串行化处理):

  • 使用 queue 队列,将接收到事件的 socket 放入 queue 中进行排队,串行化进行处理
  • 将有事件发生的 socket 分发给不同的线程,来进行并发的处理,开启大量的多线程,多个线程并发的去处理不同的 socket 里面的事件

client 和 server 端建立连接的流程为:

我们会有一个专门的 socket 去监听端口,用于监听来自客户端的连接请求,这个连接请求经过 IO 多路复用,由 连接应答处理器 进行处理,处理的操作其实也就是服务端和客户端进行 TCP 三次握手建立连接,建立好连接之后服务端就会创建一个新的 socket,这个 socket 就是接收客户端对应的事件

那么连接建立之后,客户端对于服务端的一些读写请求就会通过 socket 进行请求,请求到达服务端之后,通过 IO 多路复用将任务分发给不同的事件处理器进行处理,如果是读写请求,就将读写的响应通过 socket 响应给客户端

Redis 串行化单线程模型为什么能高并发?

首先 Redis 是通过 串行化 + 单线程 来应对高并发的

Redis 首先是基于内存操作,速度很快,并且当大量请求进入后,都放入队列中,进行串行化处理,由单个线程直接基于内存进行操作,并且单线程的情况下也不需要加锁以及线程上下文切换(多线程是很占用 CPU 资源的),核心就在于 Redis 通过单线程基于内存进行操作!

http://www.lryc.cn/news/241529.html

相关文章:

  • Docker run 命令
  • Vue中的$nextTick的作用
  • 浅谈Linux bash脚本----getopts获取脚本POSIX标准传参
  • PyCharm玩转ESP32
  • uniapp自定义导航栏返回按键
  • 「可移动工具车」物料管理的得力助手
  • 授时小课堂——北斗卫星信号和GPS卫星信号谁更强?
  • 网站会遭受那些攻击,要怎么应对
  • 后端-锁专题:synchronized(java对象结构、锁的类型、锁升级流程...)
  • vscode在运行c语言时,无法scanf输入
  • ROLLUP 的几点说明(十七)
  • 项目经理面试题持续更新
  • 基于JavaWeb+SSM+Vue校园水电费管理小程序系统的设计和实现
  • 主从复制读写分离?
  • h5小游戏-盖楼游戏
  • 量子计算的发展
  • YOLOv3老矣尚能战否?基于YOLOv3开发构建建钢铁产业产品智能自动化检测识别系统,我们来与YOLOv5进行全方位对比评测
  • 【lodash】 关于Some的相关用法
  • JavaScript基础—引入方式、注释和结束符、输入和输出、变量、常量、数据类型、检测数据类型、类型转换、综合案例—用户订单信息
  • 替换jar文件中的jar文件中的class
  • 基于51单片机倾角MPU6050老人跌倒远程GSM短信报警器+源程序
  • 代码规范有用吗?听听100W年薪谷歌大佬怎么说!
  • 最详细的软件测试面试题整理与分析
  • 【Vue】浏览器安装vue插件
  • 人人都会Blazor —— 3.3 参数
  • 【数据结构初阶】栈和队列
  • MATLAB - text的两种使用方法
  • ubuntu下配置qtcreator交叉编译环境
  • 金风玉露一相逢|实在智能联手浪潮信息合力致新生成式AI产业生态
  • Design Guidelines for 100 Gbps