r语言list添加元素_Redis数据结构 List 类型】List 类型生产中的应用 消息队列、排行榜、朋友圈、监控程序的实现...
LPUSH key value [value ...]
RPUSH key value [value ...]
LPUSHX key value
RPUSHX key value
从头部或尾部添加一个或多个新的元素,返回链表长度。LPUSHX/RPUSHX 是只能对已经存在元素的链表才会做增加操作。1.2. 链表删除元素
LPOP key
RPOP key
BLPOP key [key ...] timeout
BRPOP key [key ...] timeout
LPOP/RPOP 是以非阻塞的方式读取,从头部或尾部删除一个元素并返回元素的值,当 List 中没有元素时继续进行弹出元素操作,返回 None。BLPOP/BRPOP 是以阻塞的方式读取,从头部或尾部删除一个元素并返回链表的key值和元素的值 组成的元组,链表中没有元素的时候返回None,timeout是阻塞超时时间。非阻塞模式下是轮询读取队列中的数据,是可以容易的去观察程序的运行情况,但是阻塞模式下队列中没有数据的话程序会一直处于阻塞状态难以观察运行状态,设置一个合理的超时时间是比较有效的方法。1.3. 链表范围查询
LRANGE key start stop
从 List 中取出一定范围的元素,参数为 start、stop 两个索引,start 和 end 偏移量都是基于0的下标(也就是头部的第一个元素),可以使用超出链表长度的索引和负索引。1.4. 链表截取
LTRIM key start stop
对链表切片,截取从左边起的值的长度,参数为两个索引。1.5. 链表获取长度
LLEN key
返回存储在 key 里的list的长度。1.6. RPOPLPUSH /BRPOPLPUSH
RPOPLPUSH source destination
BRPOPLPUSH source destination timeout
原子性地返回并移除存储在 source 的链表的最后一个元素(链表尾部元素), 并把该元素放入存储在 destination 的链表的第一个元素位置(链表头部)。假设 source 存储着链表 a,b,c, destination 存储着链表 x,y,z。执行 RPOPLPUSH 得到的结果是 source 保存着链表 a,b ,而 destination 保存着链表 c,x,y,z。如果 source 不存在,那么会返回 nil 值,并且不会执行任何操作。如果 source 和 destination 是同一个链表的,那么这个操作等同于移除链表最后一个元素并且把该元素放在链表头部, 所以这个命令也可以当作是一个循环链表的命令。1.7. 链表插入元素- LINSERT key BEFORE|AFTER pivot value2. 应用针对一些开发中常见的场景使用上面介绍到的命令来进行实践。
消息队列
排行榜
待阅消息
朋友圈
监控程序
2.1. 消息队列在之前的内容中也提到了List类型的 LPUSH+RPOP/BRPOP、RLPUSH+LPOP/BLPOP 都能实现队列的功能,直接撸代码吧。需要注意的就是阻塞模式的返回值与非阻塞的不同,是key值和元素值的元组。设定队列 `task:mq`生产者A生产两条消息从头部加入队列,消费者AB采用阻塞和非阻塞的方式读取队列消息。生产者A
keyname = "task:mq"
r.lpush(keyname, u"你好啊 不太灵光的程序员!")
r.lpush(keyname, u"更新个红锁")
消费者A 非阻塞
keyname = "task:mq"while 1:
message = r.rpop(keyname)print(message, datetime.now())
time.sleep(1)
消费者B 阻塞
keyname = "task:mq"while 1:
message = r.brpop(keyname, timeout=5)print(message, datetime.now())
2.2. 排行榜List是顺序链表,当做增加和删除元素时间复杂度是非常低的,对于索引元素位置效率就比较低了,这种特点对于需要频繁更新名次的实时排行榜就不合适了。CSDN的周榜、总榜每周二更新一次,个人的单篇文章访问量排行榜每天更新一次,畅销书月榜等等访问量高但是更新周期不频繁的排行榜可以结合LRANGE命令实现。设定文章排行榜日榜`article:tops:{date}`对文章访问量进行每日排名并支持分页查询。文章列表 = ["Redis实现消息队列的6种方案", "让运维更简单的7种定时任务实现方式", "细品28岁程序员退休创业背后的可怕故事", "工作中都有哪些让你心累的时刻"]生成日榜数据
import pandas as pdimport randomfor d in pd.date_range(start='2020-02-20', end='2020-02-25', freq='D'):
date = d.date()
tops = f"article:tops:{date}"for title in [f"《Redis实现消息队列的6种方案》 访问量 " + str(random.randint(1000, 2000)),
f"《让运维更简单的7种定时任务实现方式》 访问量 " + str(random.randint(800, 1000)),
f"《细品28岁程序员退休创业背后的可怕故事》 访问量 " + str(random.randint(600, 800)),
f"《工作中都有哪些让你心累的时刻》 访问量 " + str(random.randint(100, 500)),]:
details = r.rpush(tops, title)
查看日榜数据
import pandas as pdfor d in pd.date_range(start='2020-02-20', end='2020-02-25', freq='D'): date = d.date() tops = f"article:tops:{date}"print(f"{date} 日榜 ")for index in range(0, 10, 2): details = r.lrange(tops, index, index+1)if details:print(details)else:print("没有下一页了")break
2.3. 待阅消息你有新的消息、朋友圈、新的点赞、新的评论。其实也是消息队列,每个用户都创建一个消息队列来保存待阅的消息,你不点击查看就显示队列的长度,点击查看再去一次消费所有消息。
moments1 = """
老干妈:
我冤枉啊
2020-07-01
"""
moments2 = """
XXX:
老干妈上架大客户专属1000瓶辣椒酱 售价9999
2020-07-02
"""
moments3 = """
XXX:
腾讯公司未展开调查直接冻结老干妈1600万
2020-07-02
"""
keyname = "user:1000:moments"
r.lpush(keyname, moments1, moments2, moments3)print("今天新的朋友圈消息待刷新", r.llen(keyname))while 1:print(r.rpop(keyname))
time.sleep(2)
2.3. 监控程序监控程序说的太宽泛了,其实只是循环队列的一种在监控场景中的应用,在公司里会有许多接口是需要监控是否存活的,一般情况会留一个返回 successful 的接口供监控程序调用。可以把这些接口存在数据库中,程序读取出来让再去轮询,当有新的接口加入时需要通知程序从新去查数据库,再轮询,就存在了判断是否有新的接口的判断。上面提到了 RPOPLPUSH/BRPOPLPUSH 命令,当操作的key是同一个时就是循环队列,程序运行中可以动态加入新的成员,缺点是能进不能出,尬尬尬 移除成员需要单独实现。
def get_api(url):print(url, "successful")
time.sleep(2)
r.lpush("task:mq", "api1", "api2", "api3", "api4")while 1:
url = r.brpoplpush("task:mq", "task:mq", timeout=30)
get_api(url)
end
推荐阅读:
让运维更简单的7种定时任务实现方式
细品28岁程序员退休创业背后的可怕故事
Python行业就业现状
基于Redis实现消息队列(上)
基于Redis实现消息队列(中)
基于Redis实现消息队列(下)
如有收获,点个在看,诚挚感谢
r语言list添加元素_Redis数据结构 List 类型】List 类型生产中的应用 消息队列、排行榜、朋友圈、监控程序的实现...相关推荐
- vector 赋值_从零开始学习R语言(一)——数据结构之“向量”(Vector)
本文首发于知乎专栏:https://zhuanlan.zhihu.com/p/59688569 也同步更新于我的个人博客:https://www.cnblogs.com/nickwu/p/125370 ...
- R语言ggplot2可视化在可视化图形的X轴标签中添加温度摄氏度符号(add temperature degree symbol on axis label)
R语言ggplot2可视化在可视化图形的X轴标签中添加温度摄氏度符号(add temperature degree symbol on axis label) 目录
- R语言ggplot2可视化改变线图(line plot)中线条的色彩实战
R语言ggplot2可视化改变线图(line plot)中线条的色彩实战 目录 R语言ggplot2可视化改变线图(line plot)中线条的色彩实战
- R语言ggplot2可视化使用vjust和hjust参数对齐图像中的文本注释信息(左对齐、右对齐、居中)实战
R语言ggplot2可视化使用vjust和hjust参数对齐图像中的文本注释信息(左对齐.右对齐.居中)实战 目录
- R语言将多张可视化结果图像保存到PDF中实战:多图保存到同一PDF页、将多个绘图保存到PDF格式的不同页面
R语言将多张可视化结果图像保存到PDF中实战:多图保存到同一PDF页.将多个绘图保存到PDF格式的不同页面 目录 R语言将多张可视化结果图像保存到PDF中实战:多图保存到同一PDF页.将多个绘图保存到 ...
- R语言使用psych包的cor.test函数检验dataframe中多个数值数据列之间的相关性系数是否具有统计显著性、对相关性系数进行显著性检验、使用print函数和short参数输出系数的置信区间
R语言使用psych包的cor.test函数检验dataframe中多个数值数据列之间的相关性系数是否具有统计显著性.对相关性系数进行显著性检验.使用print函数和short参数输出系数的置信区间 ...
- R语言使用epiDisplay包的summ函数计算dataframe数据中的指定数据列在分组变量下的统计量(样本数、均值、中位数、标准差、最大值、最小值)、可视化一个按照分类变量绘制的有序点图
R语言使用epiDisplay包的summ函数计算dataframe数据中的指定数据列在分组变量下的统计量(样本数.均值.中位数.标准差.最大值.最小值).可视化一个按照分类变量绘制的有序点图 目录
- R语言使用epiDisplay包的summ函数计算dataframe数据中的指定数据列在分组变量下的统计量、可视化一个按照分类变量绘制的有序点图(有序点图分析数值型变量的分布、密集趋势、异常值)
R语言使用epiDisplay包的summ函数计算dataframe数据中的指定数据列在分组变量下的统计量.可视化一个按照分类变量绘制的有序点图(有序点图分析数值型变量的分布.密集趋势.异常值) 目录
- R语言描述性统计:使用mean函数计算dataframe数据中指定数据列的均值
R语言描述性统计:使用mean函数计算dataframe数据中指定数据列的均值 目录 R语言描述性统计:使用mean函数计算dataframe数据中指定数据列的均值
最新文章
- python项目开发案例-Python项目开发案例集锦 PDF 全彩超清版
- 初学python还是swift-请问零基础学习python 和swift哪个更好入门呢?
- 基于卷积神经网络的人脸认证(判断两个人脸是否是一个人)
- 笔记:python3编写的仿hubot的聊天机器人Chattie
- LeetCode--91. 解码方法(动态规划)
- VS中添加新项 数据选项卡下没有ADO.NET实体数据模型解决方案
- 大庆油田真正解决了吃饭问题
- C语言复变函数PPT,C语言中如何应用复变函数
- 三相PWM整流器Simulink仿真
- Python列表是数组吗?
- 入门级Pytorch+MINIST数据集实现手写数字识别
- Traceback (most recent call last):
- Ant实现自动打包部署
- iOS 百度地图_自定义Annotation大头针_修改大头针图片
- 原生js-购物车案例(四)增减商品数量,小计价格计算
- Java自学.接口学习笔记!
- 微信小程序配置每个页面的标题名称
- CSP - J 2020 T2 直播获奖
- ​大数据和云计算技术周报(第37期) - 云+社区 - 腾讯云
- 大公司高级Android工程师技能要求
热门文章
- NUMA - Non Uniform Memory Architecture 非统一内存架构
- 2019.03.17 14:58
- web前端基础(13js语法基础)
- Java线程的一些api
- c++求n的几次方_2.七年级数学:怎么求mn+mn的值?完全平方公式,用配方法
- hikvision v2.3控件网页demo_网页禁止复制粘贴怎么解决?教你五招轻松搞定
- c语言单向链表经典,C语言基础 - 实现单向链表
- c语言学习进阶-C语言程序稳定性测试
- Unity3d导出Lightingmap的方法
- OpenShift 4.6 新特性 - 用 Windows MachineConfig Operator 管理 Windows Container