问:Redis为什么这么快?
Redis,全称Remote Dictionary Server,是一个开源的高性能键值对数据库。它以其卓越的性能、丰富的数据结构和灵活的使用方式,在现代互联网应用中扮演着重要角色。本文将探讨Redis之所以快的原因,包括其数据结构、内存管理、IO多路复用等关键特性,并与其他数据库进行比较,结合实际代码案例展示Redis在实际应用中的表现,最后介绍Redis的适用场景和限制。
一、Redis的关键特性
1. 数据结构
Redis支持多种类型的数据结构,包括字符串(String)、哈希(Hash)、列表(List)、集合(Set)、有序集合(Zset)等。每种数据结构都经过精心设计,以优化特定的操作场景。
- 字符串(String):Redis中的字符串类型不仅可以存储文本数据,还可以存储数字。字符串类型的操作包括设置值、获取值、自增、自减等,时间复杂度通常为O(1)。
- 哈希(Hash):哈希类型是一个键值对的集合,其中每个键值对都可以存储一个字符串值。哈希类型非常适合存储对象信息,如用户信息等。Redis根据哈希类型中元素的数量和大小,选择使用压缩列表(ziplist)或哈希表(hashtable)作为内部编码。[1]
- 列表(List):列表类型是一个有序的字符串列表,支持在列表的头部或尾部添加元素,也支持在列表任意位置插入或删除元素。列表类型常用于实现消息队列、排行榜等功能。Redis根据列表的大小和元素数量,选择使用压缩列表(ziplist)或双向链表(linkedlist)作为内部编码。[1]
- 集合(Set):集合类型是一个无序的字符串集合,其中每个元素都是唯一的。集合类型支持交集、并集、差集等操作,常用于实现标签系统、好友关系等功能。Redis根据集合中元素的数量和类型,选择使用整数集合(intset)或哈希表(hashtable)作为内部编码。[1]
- 有序集合(Zset):有序集合类型是一个有序的字符串集合,每个元素都关联一个双精度浮点数分数。有序集合类型常用于实现排行榜、范围查询等功能。Redis使用跳表(skiplist)和哈希表(hashtable)来实现有序集合。[1]
这些数据结构的设计使得Redis在处理特定操作时能够非常高效。
2. 内存管理
Redis将所有数据存储在内存中,因此能够非常快速地读取和写入数据。Redis的内存管理策略包括以下几个方面:
- 内存分配:Redis使用jemalloc作为内存分配器,jemalloc针对多线程场景进行了优化,能够减少内存碎片,提高内存分配和释放的效率。
- 内存回收:Redis提供了多种内存淘汰策略,如LRU(最近最少使用)、LFU(最不经常使用)等,当内存使用达到上限时,Redis会根据配置的淘汰策略自动删除部分数据以释放内存。
- 过期策略:Redis支持为键设置过期时间,当键过期时,Redis会自动删除该键。Redis采用惰性删除和定期删除相结合的方式来实现过期策略,以减少对CPU的占用。[11]
3. IO多路复用
Redis采用IO多路复用技术,允许单个线程处理多个网络连接。Redis使用epoll(在Linux系统上)作为IO多路复用的实现方式,能够高效地处理大量的并发连接。当某个连接上有数据可读或可写时,epoll会通知Redis进行相应的读写操作,从而避免了大量的无用操作。IO多路复用技术使得Redis能够充分利用CPU资源,提高并发处理能力。[3]
二、Redis与其他数据库的比较
性能比较
| 数据库类型 | Redis | MySQL | MongoDB |
|---|---|---|---|
| 数据存储方式 | 内存 | 硬盘 | 硬盘 |
| 读写速度 | 快 | 慢 | 中等 |
| 并发处理能力 | 高 | 中等 | 高 |
| 数据一致性 | 最终一致性 | 强一致性 | 最终一致性 |
Redis由于将数据存储在内存中,读写速度非常快,远超过将数据存储在硬盘上的MySQL和MongoDB。同时,Redis采用单线程模型和IO多路复用技术,能够高效地处理大量的并发连接。虽然Redis的数据一致性是最终一致性,但在很多应用场景下已经足够。[9]
扩展性比较
| 数据库类型 | Redis | MySQL | MongoDB |
|---|---|---|---|
| 水平扩展 | 支持 | 支持 | 支持 |
| 主从复制 | 支持 | 支持 | 支持 |
| 分片 | 支持 | 不支持 | 支持 |
Redis支持主从复制和分片,能够实现数据的水平扩展。通过增加从节点,可以提高系统的读性能和可用性;通过分片,可以将数据分布到多个节点上,提高系统的写性能和存储容量。MySQL也支持主从复制,但不支持分片;MongoDB天生具有良好的扩展性,支持自动分片功能。[9]
容错性比较
| 数据库类型 | Redis | MySQL | MongoDB |
|---|---|---|---|
| 数据持久化 | 支持 | 支持 | 支持 |
| 高可用部署 | 支持 | 支持 | 支持 |
| 数据备份 | 支持 | 支持 | 支持 |
Redis支持RDB快照和AOF日志两种持久化方式,能够将内存中的数据定期保存到硬盘上,防止数据丢失。同时,Redis支持主从复制和高可用部署,如使用Redis Sentinel实现自动故障转移。MySQL和MongoDB也支持数据持久化、高可用部署和数据备份功能。[8]
三、Redis在实际应用中的表现
1. 缓存
Redis最常用的场景之一就是作为缓存使用。通过将经常访问的数据缓存到Redis中,可以减少对后端数据库的访问压力,提高系统性能。
import redis.clients.jedis.Jedis;public class CacheExample {private static final String REDIS_HOST = "localhost";private static final int REDIS_PORT = 6379;private Jedis jedis;public CacheExample() {this.jedis = new Jedis(REDIS_HOST, REDIS_PORT);}public void addToCache(String key, String value) {jedis.set(key, value);}public String getFromCache(String key) {return jedis.get(key);}public static void main(String[] args) {CacheExample cacheExample = new CacheExample();// 添加数据到缓存cacheExample.addToCache("user:1:name", "Alice");cacheExample.addToCache("user:1:email", "alice@example.com");// 从缓存中获取数据String name = cacheExample.getFromCache("user:1:name");String email = cacheExample.getFromCache("user:1:email");System.out.println("Name: " + name); // 输出 Name: AliceSystem.out.println("Email: " + email); // 输出 Email: alice@example.com}
}
示例中,使用Jedis客户端连接到本地Redis服务器,并向缓存中添加用户的姓名和邮箱信息,然后从缓存中获取并打印这些信息。通过缓存,可以显著提高数据访问速度,减轻数据库负载。[10]
2. 消息队列
Redis的列表类型可以用来实现消息队列。生产者将消息压入列表尾部,消费者从列表头部取出消息进行处理。Redis的消息队列支持阻塞读取操作,当队列为空时,消费者可以阻塞等待直到有新消息到达。
import redis.clients.jedis.Jedis;public class MessageQueueExample {private static final String REDIS_HOST = "localhost";private static final int REDIS_PORT = 6379;private Jedis jedis;public MessageQueueExample() {this.jedis = new Jedis(REDIS_HOST, REDIS_PORT);}public void produceMessage(String queueName, String message) {jedis.lpush(queueName, message);}public String consumeMessage(String queueName) {return jedis.rpop(queueName);}public String blockConsumeMessage(String queueName, int timeout) {return jedis.brpop(timeout, queueName).get(1);}public static void main(String[] args) {MessageQueueExample messageQueueExample = new MessageQueueExample();// 生产者发送消息messageQueueExample.produceMessage("message_queue", "message1");messageQueueExample.produceMessage("message_queue", "message2");// 消费者消费消息String message1 = messageQueueExample.consumeMessage("message_queue");String message2 = messageQueueExample.consumeMessage("message_queue");System.out.println("Consumed message 1: " + message1); // 输出 Consumed message 1: message1System.out.println("Consumed message 2: " + message2); // 输出 Consumed message 2: message2// 阻塞消费消息String blockMessage = messageQueueExample.blockConsumeMessage("message_queue", 0);System.out.println("Blocked consumed message: " + blockMessage); // 如果有新消息,则输出新消息;否则阻塞等待}
}
在示例中,实现了一个简单的消息队列。生产者使用LPUSH命令将消息压入队列尾部,消费者使用RPOP命令从队列头部取出消息进行处理。展示了如何使用BRPOP命令实现阻塞读取操作。[10]
3. 分布式锁
在分布式系统中,为了保证数据的一致性,需要使用锁来避免并发访问。Redis提供了分布式锁的支持,通过设置一个唯一的键和值,并设置过期时间,来确保在分布式环境中只有一个客户端能够获取到锁。
import redis.clients.jedis.Jedis;public class DistributedLockExample {private static final String REDIS_HOST = "localhost";private static final int REDIS_PORT = 6379;private Jedis jedis;private static final String LOCK_KEY = "distributed_lock";private static final long LOCK_EXPIRE_TIME = 10000; // 锁过期时间,单位:毫秒public DistributedLockExample() {this.jedis = new Jedis(REDIS_HOST, REDIS_PORT);}public boolean acquireLock() {String clientId = String.valueOf(Thread.currentThread().getId());long expireTime = System.currentTimeMillis() + LOCK_EXPIRE_TIME;String lockValue = clientId + ":" + expireTime;return jedis.setnx(LOCK_KEY, lockValue) == 1;}public void releaseLock(String clientId) {String lockValue = clientId + ":" + System.currentTimeMillis();while (true) {String oldValue = jedis.get(LOCK_KEY);if (oldValue == null || oldValue.startsWith(clientId)) {if (jedis.getSet(LOCK_KEY, "") != null) {break;}} else {break;}}}public static void main(String[] args) {DistributedLockExample lockExample = new DistributedLockExample();boolean isLocked = lockExample.acquireLock();if (isLocked) {System.out.println("Lock acquired!");try {// 执行需要加锁的操作Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();} finally {lockExample.releaseLock(String.valueOf(Thread.currentThread().getId()));System.out.println("Lock released!");}} else {System.out.println("Failed to acquire lock!");}}
}
示例中,实现了一个简单的分布式锁。客户端尝试使用SETNX命令获取锁,如果成功则返回true,表示获取到锁;否则返回false,表示获取锁失败。获取到锁的客户端在执行完需要加锁的操作后,需要释放锁。释放锁时,客户端会检查当前锁的值是否为自己设置的值,如果是则删除锁;否则不做任何操作。[10]
四、Redis的适用场景和限制
适用场景
- 缓存:将经常访问的数据缓存到Redis中,减少数据库访问压力,提高系统性能。
- 会话存储:在Web应用中,使用Redis存储用户的会话信息,如登录状态、购物车内容等。
- 排行榜/计数器:利用Redis的有序集合和自增/自减操作,实现排行榜和计数器功能。
- 消息队列:使用Redis的列表类型实现消息队列,处理异步任务。
- 分布式锁:在分布式系统中使用Redis实现分布式锁,保证数据一致性。
- 实时分析:利用Redis的快速读写能力,实现实时数据分析功能。
- 地理位置信息存储:Redis支持地理位置信息的存储和查询,可以用于实现附近的人、附近的商家等功能。
限制
- 内存限制:Redis将所有数据存储在内存中,因此受到物理内存大小的限制。当数据量过大时,需要考虑数据淘汰策略或扩展Redis集群。
- 数据一致性:Redis的数据一致性是最终一致性,不适用于需要强一致性的场景。
- 复杂查询:Redis不支持复杂的SQL查询操作,对于需要复杂查询的场景可能不是最佳选择。
- 网络依赖:Redis是基于内存的数据库,一旦网络出现问题或Redis服务宕机,可能会导致数据丢失或服务中断。因此,在使用Redis时需要做好数据备份和容灾准备。
综上所述,Redis凭借其高性能、丰富的数据结构和灵活的使用方式,在现代互联网应用中发挥着重要作用。然而,Redis也存在一些限制和挑战,需要在使用过程中根据具体场景进行权衡和选择。
相关文章:
问:Redis为什么这么快?
Redis,全称Remote Dictionary Server,是一个开源的高性能键值对数据库。它以其卓越的性能、丰富的数据结构和灵活的使用方式,在现代互联网应用中扮演着重要角色。本文将探讨Redis之所以快的原因,包括其数据结构、内存管理、IO多路…...
环信鸿蒙IM SDK实现附件消息发送与下载
环信HarmonyOS IM SDK 正式版已经发布,该版本全面覆盖即时通讯(IM)的核心功能,为用户提供了完整的IM全功能体验,同时支持从Android APK到 NEXT 的数据迁移,更好地满足企业在不同业务场景下的适配需求。 点…...
探索NetCat:网络流量监测与数据传输的利器
从简单的数据传输到复杂的网络调试,NetCat的灵活性和多功能性让人赞叹不已,在这篇文章中我将深入探讨NetCat的魅力,揭示它的基本功能、实用技巧以及在日常工作中的应用场景,发现如何用这一小工具提升的网络技能与效率。 目录 Net…...
【运动的&足球】足球运动员球守门员裁判检测系统源码&数据集全套:改进yolo11-DBBNCSPELAN
改进yolo11-FocalModulation等200全套创新点大全:足球运动员球守门员裁判检测系统源码&数据集全套 1.图片效果展示 项目来源 人工智能促进会 2024.10.28 注意:由于项目一直在更新迭代,上面“1.图片效果展示”和“2.视频效果展示…...
求最大公约数,最小公倍数
输入两个正整数 m 和 n,求其最大公约数和最小公倍数。 求最小公倍数算法: 最小公倍数 两整数的乘积 最大公约数 根据求最小公倍数的算法,可以看出如果已知最大公约数,就能很容易求出最小公倍数。而通过辗转相除法和相减法&#…...
Android——横屏竖屏
系统配置变更的处理机制 为了避免横竖屏切换时重新加载界面的情况,Android设计了一中配置变更机制,在指定的环境配置发生变更之时,无需重启活动页面,只需执行特定的变更行为。该机制的视线过程分为两步: 修改 Androi…...
scala---10.30
val、var package com_1030class Person {var name:String"rose"def sum(n1:Int,n2:Int):Int{n1n2} } object Person{def main(args: Array[String]): Unit {//创建person对象var personnew Person()println(person.sum(10,20))//30println(person.name)person.nam…...
Pinctrl子需要中client端使用pinctrl过程的驱动分析
往期内容 本专栏往期内容: Pinctrl子系统和其主要结构体引入Pinctrl子系统pinctrl_desc结构体进一步介绍Pinctrl子系统中client端设备树相关数据结构介绍和解析inctrl子系统中Pincontroller构造过程驱动分析:imx_pinctrl_soc_info结构体 input子系统专栏…...
【网络】传输层协议TCP
目录 四位首部长度 序号 捎带应答 标记位 超时重传机制 连接管理机制(RST标记位) 三次握手及四次挥手的原因 TCP的全称是传输控制协议(Transmission Control Protocol),也就是说,对于放到TCP发送缓冲…...
00-开发环境 MPLAB IDE 配置
MPLAB IDE V8.83 File 菜单简介 New (CtrlN): 创建一个新文件,用于编写新的代码。 Add New File to Project...: 将新文件添加到当前项目中。 Open... (CtrlO): 打开现有文件。 Close (CtrlE): 关闭当前打开的文件。 …...
<meta property=“og:type“ content=“website“>
<meta property"og:type" content"website"> 这段代码是HTML中的一部分,具体来说,它是一个用于定义Open Graph协议的meta标签。 代码分析 <meta> 标签:这是一个HTML标签,用于在HTML文档的头…...
C++ 实现俄罗斯方块游戏
✅作者简介:2022年博客新星 第八。热爱国学的Java后端开发者,修心和技术同步精进。 🍎个人主页:Java Fans的博客 🍊个人信条:不迁怒,不贰过。小知识,大智慧。 💞当前专栏…...
QT打包Macosx应用发布App Store简易流程
1、QC里编译工程,生成Release版的的app文件; 2、运行macdeployqt把需要的文件打包进app文件中; % ~/Qt/5.15.0/clang_64/bin/macdeployqt {编译的app文件所在路径}/Release/xxxx.app 3、使用codesign对app进行签名,如果要发App…...
untiy mlagents 飞机大战 ai训练
前言 之前那个python源码的飞机大战bug过多,还卡顿,难以继续训练。可直接放弃的话又不甘心,所以找了个unity版本的飞机大战继续(终于不卡了),这次直接使用现成的mlagents库。 过程 前前后后花了两周时间,甚至因此拖…...
从0开始学统计-什么是中心极限定理
引言 中心极限定理(Central Limit Theorem, CLT)是统计学中的一块基石,它揭示了一个难以置信的数学现象:无论一个随机变量的原始分布如何,只要我们取足够大的样本量,这些样本的平均值(或总和&a…...
工具方法 - 个人活动的分类
人类活动的分类是一个复杂的话题,因为人类的活动范围非常广泛且相互交叉。然而,我们可以尝试将人类的活动大致分为以下几个主要类别: 工作活动 工作活动是人类生活中不可或缺的一部分,通常包括以下方面: 1. 职业工作&a…...
11.1组会汇报-基于区块链的安全多方计算研究现状与展望
基础知识 *1.背书,这个词源来自银行票据业务,是指票据转让时,原持有人在票据背面加盖自己的印鉴,证明该票据真实有效、如果有问题就可以找原持有人。 区块链中的背书就好理解了。可以简单的理解为验证交易并声明此交易合法&…...
ubuntu【桌面】 配置NAT模式固定IP
DHCP分配导致虚拟机IP老变,SSH老要重新配置,设成静态方便些 一、设NAT模式 1、设为NAT模式 2、看模式对应的虚拟网卡 - VMnet8 3、共享主机网卡网络到虚拟网卡 - VMnet8 二、为虚拟网卡设置静态IP 记住这个IP 三、设置ubuntu固定IP 1、关闭DHCP并…...
评估 机器学习 回归模型 的性能和准确度
回归 是一种常用的预测模型,用于预测一个连续因变量和一个或多个自变量之间的关系。 那么,最后评估 回归模型 的性能和准确度非常重要,可以帮助我们判断模型是否有效并进行改进。 接下来,和大家分享如何评估 回归模型 的性能和准…...
如何下载安装TestLink?
一、下载TestLink、XAMPP TestLink 下载 |SourceForge.net 备用:GitHub - TestLinkOpenSourceTRMS/testlink-code: TestLink开源测试和需求管理系统 下载XAMPP: Download XAMPP 注意:TestLink与PHP版本有关系,所以XA…...
基础测试工具使用经验
背景 vtune,perf, nsight system等基础测试工具,都是用过的,但是没有记录,都逐渐忘了。所以写这篇博客总结记录一下,只要以后发现新的用法,就记得来编辑补充一下 perf 比较基础的用法: 先改这…...
C++ 基础特性深度解析
目录 引言 一、命名空间(namespace) C 中的命名空间 与 C 语言的对比 二、缺省参数 C 中的缺省参数 与 C 语言的对比 三、引用(reference) C 中的引用 与 C 语言的对比 四、inline(内联函数…...
C++.OpenGL (10/64)基础光照(Basic Lighting)
基础光照(Basic Lighting) 冯氏光照模型(Phong Lighting Model) #mermaid-svg-GLdskXwWINxNGHso {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-GLdskXwWINxNGHso .error-icon{fill:#552222;}#mermaid-svg-GLd…...
三体问题详解
从物理学角度,三体问题之所以不稳定,是因为三个天体在万有引力作用下相互作用,形成一个非线性耦合系统。我们可以从牛顿经典力学出发,列出具体的运动方程,并说明为何这个系统本质上是混沌的,无法得到一般解…...
SpringCloudGateway 自定义局部过滤器
场景: 将所有请求转化为同一路径请求(方便穿网配置)在请求头内标识原来路径,然后在将请求分发给不同服务 AllToOneGatewayFilterFactory import lombok.Getter; import lombok.Setter; import lombok.extern.slf4j.Slf4j; impor…...
Java面试专项一-准备篇
一、企业简历筛选规则 一般企业的简历筛选流程:首先由HR先筛选一部分简历后,在将简历给到对应的项目负责人后再进行下一步的操作。 HR如何筛选简历 例如:Boss直聘(招聘方平台) 直接按照条件进行筛选 例如:…...
iOS性能调优实战:借助克魔(KeyMob)与常用工具深度洞察App瓶颈
在日常iOS开发过程中,性能问题往往是最令人头疼的一类Bug。尤其是在App上线前的压测阶段或是处理用户反馈的高发期,开发者往往需要面对卡顿、崩溃、能耗异常、日志混乱等一系列问题。这些问题表面上看似偶发,但背后往往隐藏着系统资源调度不当…...
【VLNs篇】07:NavRL—在动态环境中学习安全飞行
项目内容论文标题NavRL: 在动态环境中学习安全飞行 (NavRL: Learning Safe Flight in Dynamic Environments)核心问题解决无人机在包含静态和动态障碍物的复杂环境中进行安全、高效自主导航的挑战,克服传统方法和现有强化学习方法的局限性。核心算法基于近端策略优化…...
AI+无人机如何守护濒危物种?YOLOv8实现95%精准识别
【导读】 野生动物监测在理解和保护生态系统中发挥着至关重要的作用。然而,传统的野生动物观察方法往往耗时耗力、成本高昂且范围有限。无人机的出现为野生动物监测提供了有前景的替代方案,能够实现大范围覆盖并远程采集数据。尽管具备这些优势…...
DingDing机器人群消息推送
文章目录 1 新建机器人2 API文档说明3 代码编写 1 新建机器人 点击群设置 下滑到群管理的机器人,点击进入 添加机器人 选择自定义Webhook服务 点击添加 设置安全设置,详见说明文档 成功后,记录Webhook 2 API文档说明 点击设置说明 查看自…...
