草庐IT

Redis - 介绍与使用场景

程序员翔仔 2023-03-28 原文

简介

Redis 的全称是 Remote Dictionary Server，是一个使用 C 语言编写的、开源的（BSD 许可）高性能非关系型（NoSQL）的键值对数据库。

Redis 的数据是存储在内存中的，所以读写速度非常快，被广泛应用于缓存方向，当然也有持久化数据库的用法。

优缺点

优点

  • 读写性能优异， Redis 能读的速度是 110000 次/s，写的速度是 81000 次/s
  • 数据类型丰富，有 String、List、Hash、Set、SortedSet 等
  • 单线程原子性，Redis 所有的操作都是原子性的，也支持多个操作合并后的原子执行
  • 丰富的特性，Redis 支持发布订阅、通知、key 过期等功能
  • 支持持久化，Redis 支持 RDB、AOF 等持久化方式
  • 高可用性，Redis 支持主从复制、哨兵模式、Cluster 等高可用方式

缺点

  • 数据库容量受物理内存的限制，不能用作海量数据的读写
  • Redis 难以支持在线扩容，修改配置文件之后重启 Redis，恢复磁盘上的数据耗费时间较久

使用场景

数据缓存

Redis 是高性能的内存数据库，因此，缓存是 Redis 最常用的场景。Redis 作为缓存使用的时候，一般是采用先更新数据库，再删除缓存的 Cache Aside Pattern 策略。

整体的逻辑是：业务从 Redis 中读取数据，如果 Redis 中访问不到数据，然后读取数据库中的数据，将数据库中的数据缓存到 Redis 中；业务更新数据，直接修改数据库中的数据，然后将 Redis 中的缓存删除。

这种方案需要注意的就是：避免缓存击穿，数据的实时性相对较低。

限时业务

Redis 支持给 key 设置过期时间，客户端无法访问到过期的 key，利用这一特性可以运用在限时的优惠活动、手机验证码等业务场景。

计数器

Redis 的 INCRBY 命令可以实现原子性的递增，可以直接作为计数器存储和递增。尤其是，该命令在键不存在时会直接初始化值再执行 INCRBY 命令，执行成功后会直接返回计算增量之后的数值。

高并发的秒杀活动、分布式序列号的生成、限制手机发送短信次数、接口限制访问次数等需要计数的功能，都涉及到计数器的概念，尤其是分布式系统会涉及到分布式计数器。

分布式锁

先使用 SETNX 命令来争抢锁，结果返回 1 表示设置成功，抢到之后再用 EXPIRE 命令给锁加一个过期时间防止忘记释放锁。

从 Redis 的 2.6.12 版本开始，可以通过 SET 命令的复杂参数，将 SETNX 命令和 EXPIRE 命令合并成一条命令来使用：

  • EX second: 设置键的过期时间为 second 秒，使用 EX 选项效果等同于 SETEX 命令。
  • PX millisecond: 设置键的过期时间为 millisecond 毫秒，使用 PX 选项效果等同于 PSETEX 命令。
  • NX: 只在键不存在时，才对键进行设置操作，使用 NX 选项效果等同于 SETNX 命令。
  • XX: 只在键已经存在时，才对键进行设置操作。

同样的，使用 SET 命令操作成功之后会返回 OK，这样才表示抢到了锁。

为了避免分布式锁被误删，加锁时可以设置线程 ID 作为 value 值，删除时需要线程的线程 ID 和 Redis 存储的值一致才能够删除分布式锁，否则只能等待锁自动过期，整个删除过程使用事务的方式保证原子性。

排行榜功能

通过 Redis 的 SortedSet 可以实现排行榜功能。

比如说需要展示点赞排行榜，可以将用户 ID 作为 SortedSet 的 value 值，将用户的点赞数作为 SortedSet 的 score 值，SortedSet 提供的 ZRANGEBYSCORE 命令可以快速返回已排序的点赞排行榜。

延时队列

延时队列其实就是一个带有延迟功能的消息队列，Redis 可以通过 SortedSet 实现延时队列。

具体的实现如下：

  1. 将消息内容序列化成一个字符串作为 SortedSet 的 value 值，这个消息的到期处理时间作为 score，生产者调用 ZADD 命令生产消息，消费者可以使用 ZRANGEBYSCORE 命令获取一段时间之前的数据轮询处理；
  2. 通常使用多个线程轮询 SortedSet 获取到期的任务进行处理，多个线程是为了保障可用性，万一挂了一个线程还有其他线程可以继续处理；
  3. 因为有多个线程，所以需要考虑并发争抢任务，确保任务不能被多次执行，Redis 的 ZREM 命令是多线程争抢任务的关键，ZREM 命令会返回被成功移除的成员数量，可以通过 ZREM 命令来决定任务的唯一属主；
  4. 同时也要注意一定要进行异常捕获，避免因为个别任务处理问题导致循环异常退出，同一个任务可能会被多个进程取到之后再使用 ZREM 命令进行争抢，那些没抢到的进程都是白取了一次任务，这是浪费；
  5. 通常可以使用 Lua 脚本的方式，将 ZRANGEBYSCORE 命令和 ZREM 命令一同挪到服务器端进行原子化操作，这样多个进程之间争抢任务时就不会出现这种浪费了。

异步队列

第一种方案 是使用 List 结构作为异步队列，RPUSH 命令生产消息，LPOP 命令消费消息。当使用 LPOP 命令没有得到消息的时候，需要适当 sleep 一会再重试，在这里 sleep 会导致消息的处理延迟增加。

如果不做 sleep 重试，改进的 第二种方案 是，使用 LPOP 命令的阻塞版本 BLPOP 命令，在 List 队列中没有消息的时候，它会阻塞直到消息到来，一旦数据到来，则立刻醒过来，消息的延迟几乎为零。但是如果线程一直阻塞，Redis 的客户端连接就成了闲置连接，闲置过久，服务器一般会主动断开连接，减少闲置资源占用。这个时候 BLPOP 命令会抛出异常来，代码中需要处理这样的异常。

除了 List 队列之外，第三种方案 是使用 Pub/Sub 订阅者模式实现一对多的消息队列。但是 Redis 的发布订阅功能是无状态的，对于发布者来说，无法知道发布的消息是否被订阅者接收到，在消费者下线的情况下，生产的消息会丢失。

Redis介绍code的NoSQL

有关Redis - 介绍与使用场景的更多相关文章

  1. ruby - 如何使用 Nokogiri 的 xpath 和 at_xpath 方法 - 2

    我正在学习如何使用Nokogiri，根据这段代码我遇到了一些问题:require'rubygems'require'mechanize'post_agent=WWW::Mechanize.newpost_page=post_agent.get('http://www.vbulletin.org/forum/showthread.php?t=230708')puts"\nabsolutepathwithtbodygivesnil"putspost_page.parser.xpath('/html/body/div/div/div/div/div/table/tbody/tr/td/div

  2. ruby - 使用 RubyZip 生成 ZIP 文件时设置压缩级别 - 2

    我有一个Ruby程序，它使用rubyzip压缩XML文件的目录树。gem。我的问题是文件开始变得很重，我想提高压缩级别，因为压缩时间不是问题。我在rubyzipdocumentation中找不到一种为创建的ZIP文件指定压缩级别的方法。有人知道如何更改此设置吗？是否有另一个允许指定压缩级别的Ruby库？ 最佳答案 这是我通过查看ruby​​zip内部创建的代码。level=Zlib::BEST_COMPRESSIONZip::ZipOutputStream.open(zip_file)do|zip|Dir.glob("**/*")d

  3. ruby - 为什么我可以在 Ruby 中使用 Object#send 访问私有(private)/ protected 方法？ - 2

    类classAprivatedeffooputs:fooendpublicdefbarputs:barendprivatedefzimputs:zimendprotecteddefdibputs:dibendendA的实例a=A.new测试a.foorescueputs:faila.barrescueputs:faila.zimrescueputs:faila.dibrescueputs:faila.gazrescueputs:fail测试输出failbarfailfailfail.发送测试[:foo,:bar,:zim,:dib,:gaz].each{|m|a.send(m)resc

  4. ruby-on-rails - 使用 Ruby on Rails 进行自动化测试 - 最佳实践 - 2

    很好奇，就使用ruby​​onrails自动化单元测试而言，你们正在做什么？您是否创建了一个脚本来在cron中运行rake作业并将结果邮寄给您？git中的预提交Hook？只是手动调用？我完全理解测试，但想知道在错误发生之前捕获错误的最佳实践是什么。让我们理所当然地认为测试本身是完美无缺的，并且可以正常工作。下一步是什么以确保他们在正确的时间将可能有害的结果传达给您？ 最佳答案 不确定您到底想听什么，但是有几个级别的自动代码库控制:在处理某项功能时，您可以使用类似autotest的内容获得关于哪些有效，哪些无效的即时反馈。要确保您的提

  5. ruby - 在 Ruby 中使用匿名模块 - 2

    假设我做了一个模块如下:m=Module.newdoclassCendend三个问题:除了对m的引用之外，还有什么方法可以访问C和m中的其他内容？我可以在创建匿名模块后为其命名吗(就像我输入“module...”一样)？如何在使用完匿名模块后将其删除，使其定义的常量不再存在？ 最佳答案 三个答案:是的，使用ObjectSpace.此代码使c引用你的类(class)C不引用m:c=nilObjectSpace.each_object{|obj|c=objif(Class===objandobj.name=~/::C$/)}当然这取决于

  6. ruby - 使用 ruby​​ 和 savon 的 SOAP 服务 - 2

    我正在尝试使用ruby​​和Savon来使用网络服务。测试服务为http://www.webservicex.net/WS/WSDetails.aspx?WSID=9&CATID=2require'rubygems'require'savon'client=Savon::Client.new"http://www.webservicex.net/stockquote.asmx?WSDL"client.get_quotedo|soap|soap.body={:symbol=>"AAPL"}end返回SOAP异常。检查soap信封，在我看来soap请求没有正确的命名空间。任何人都可以建议我

  7. python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声？ - 2

    关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题？更新问题，以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点？我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等)，但我确实想创建一个输出文件。

  8. ruby-on-rails - 'compass watch' 是如何工作的/它是如何与 rails 一起使用的 - 2

    我在我的项目目录中完成了compasscreate.和compassinitrails。几个问题:我已将我的.sass文件放在public/stylesheets中。这是放置它们的正确位置吗？当我运行compasswatch时，它不会自动编译这些.sass文件。我必须手动指定文件:compasswatchpublic/stylesheets/myfile.sass等。如何让它自动运行？文件ie.css、print.css和screen.css已放在stylesheets/compiled。如何在编译后不让它们重新出现的情况下删除它们？我自己编译的.sass文件编译成compiled/t

  9. ruby - 使用 ruby​​ 将 HTML 转换为纯文本并维护结构/格式 - 2

    我想将html转换为纯文本。不过，我不想只删除标签，我想智能地保留尽可能多的格式。为插入换行符标签，检测段落并格式化它们等。输入非常简单，通常是格式良好的html(不是整个文档，只是一堆内容，通常没有anchor或图像)。我可以将几个正则表达式放在一起，让我达到80%，但我认为可能有一些现有的解决方案更智能。 最佳答案 首先，不要尝试为此使用正则表达式。很有可能你会想出一个脆弱/脆弱的解决方案，它会随着HTML的变化而崩溃，或者很难管理和维护。您可以使用Nokogiri快速解析HTML并提取文本:require'nokogiri'h

  10. ruby - 在 64 位 Snow Leopard 上使用 rvm、postgres 9.0、ruby 1.9.2-p136 安装 pg gem 时出现问题 - 2

    我想为Heroku构建一个Rails3应用程序。他们使用Postgres作为他们的数据库，所以我通过MacPorts安装了postgres9.0。现在我需要一个postgresgem并且共识是出于性能原因你想要pggem。但是我对我得到的错误感到非常困惑当我尝试在rvm下通过geminstall安装pg时。我已经非常明确地指定了所有postgres目录的位置可以找到但仍然无法完成安装:$envARCHFLAGS='-archx86_64'geminstallpg--\--with-pg-config=/opt/local/var/db/postgresql90/defaultdb/po

随机推荐