Redis之Stream流

reidis为了抢占市场份额,推出了自己的消息队列,Stream流,

常用操作如下:

xadd name id值 key value key1 value1...:若不存在为name的stream流,则创建一个新的名为name的stream流。这里id相当于数据库中的主键,如果我们不想自己定义就可以设置为*,表示自动创建,(有点像数据库中的自增主键)。

这个主键是根据当前时间戳+个数来生成的,保证了唯一性。


查询

xrange name start end

通过命令查询,可通过- + 来表示查询所有

想倒序也可以使用


xlen name

获取流中信息个数


xdel name id

通过id来删除某个消息


xtrim 通过指定条件删除元素

xtrim name maxlen 个数

保留最新个数,多余的删除

在这个样例中我有三个元素,但我只保留一个最长的,因为id是按时间戳来排序,所以最新及最长的,旧的被删除。


xread count 个数 streams name 00 : 当前00表示最小的,表示从最小开始读

xread count 个数 streams name $: $表示最大的开始读,所以如果非阻塞的话肯定为空

当然我们可以用阻塞队列监控

xread count 个数 block 数字 streams name $

当我们使用阻塞进行监听时,可以显示新出的时间是多少,及再登一个虚拟机,对该流进行插入。


当有消息后就会有不同消费者来读,通过一个个组来维护

创建用户组

xgroup create mystream group1 0(或$): 创见消息mystream的用户组group1,0表示从小到大开始。

一个用户组肯定会有成员来读,一个读过则表示整个组都读过。

xreadgroup group 组名 成员名 streams stream名 > :表示一个读所有内容。

当然也可以限制成员读取个数

count限制读的个数

xpending stream名 组名 : 显示成员读的情况

想看某个成员读的有哪些也可以

xpending mystream名 客户组 - + 个数 个人名 

当然上面都是已读未确认,可以进行确认,

xack stream名 组名  stream里的某id 

这样就表示该组读取并确认了该消息,该消息并不在已读未确认中。

不过不如kafka等中间件!!!

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

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

相关文章

将要上市的自动驾驶新书《自动驾驶系统开发》中摘录各章片段 1

以下摘录一些章节片段: 1. 概论 自动驾驶系统的认知中有一些模糊的地方,比如自动驾驶系统如何定义的问题,自动驾驶的研发为什么会有那么多的子模块,怎么才算自动驾驶落地等等。本章想先给读者一个概括介绍,了解自动驾…

R语言中,查看经安装的包,查看已经加载的包,查看特定包是否已经安装,安装包,更新包,卸载包

创建于:2024.5.4 R语言中,查看经安装的包,查看已经加载的包,查看特定包是否已经安装,安装包,更新包,卸载包 文章目录 1. 查看经安装的包2. 查看已经加载的包3. 查看特定包是否已经安装4. 安装包…

【netty系列-03】深入理解NIO的基本原理和底层实现(详解)

Netty系列整体栏目 内容链接地址【一】深入理解网络通信基本原理和tcp/ip协议https://zhenghuisheng.blog.csdn.net/article/details/136359640【二】深入理解Socket本质和BIOhttps://zhenghuisheng.blog.csdn.net/article/details/136549478【三】深入理解NIO的基本原理和底层…

B树与B+树

B树定义 每个节点最多有m-1个关键字(可以存有的键值对,m表示树的高度)根节点最少可以只有1个关键字非根节点至少有m/2个关键字每个节点中的关键字都按照从小到大的顺序排列,每个关键字的左子树中的所有关键字都小于它&#xff0c…

arm 交叉编译 thumb 与 arm 指令的方法

arm 交叉编译 thumb 与 arm 指令的方法 本文实现了在 x86 的 ubuntu 的机器上,使用 arm-linux-gnueabihf-gcc 交叉编译链工具,编译出在 arm 开发板上可以运行的 thumb 指令集的可执行文件。后续会使用 vscode 使用网络进行远程调试。 1. 编译器 arm-li…

高等代数复习:可对角化

文章目录 可对角化定义可对角化的刻画 本篇文章适合个人复习翻阅,不建议新手入门使用 可对角化 定义 定义:可对角化的线性映射 若 n n n 维线性空间 V V V 上的线性变换 φ \varphi φ 在某组基 { e 1 , e 2 , … , e n } \{e_1,e_2,\dots,e_n\} {…

如何将 redis 快速部署为 docker 容器?

部署 Redis 作为 Docker 容器是一种快速、灵活且可重复使用的方式,特别适合开发、测试和部署环境。本文将详细介绍如何将 Redis 部署为 Docker 容器,包括 Docker 安装、Redis 容器配置、数据持久化、网络设置等方面。 步骤 1:安装 Docker 首…

【Python异常处理】

文章目录 一、什么是异常?二、Python的异常处理机制三、异常处理示例1. 简单异常处理2. 捕获多个异常3. 使用else和finally 四、抛出异常 一、什么是异常? 异常指的是程序在执行过程中遇到的非正常情况,可能会导致程序中断或产生错误结果。常…

uni-app(优医咨询)项目实战 - 第3天

学习目标: 掌握 luch-request 网络请求的用法 能够对 Pinia 进行初始化操作 掌握创建 Store 及数据操作的步骤 能够对 Pinia 数据进行持久化的处理 掌握用户登录的实现方法 一、项目启动 从零起步创建项目,完整的静态页面可以从 gitee 仓库获取。 1.1 创建项目 以 HBuilde…

JavaEE 多线程详细讲解(1)

1.线程是什么 (shift F6)改类名 1.1.并发编程是什么 (1)当前的CPU,都是多核心CPU (2)需要一些特定的编程技巧,把要完成的仍无,拆解成多个部分,并且分别让…

中国打造成熟工艺产能,台积电力推先进工艺,反杀成功了!

分析机构指出2023年Q4全球芯片市场28纳米及以上工艺芯片占比在快速下降,已跌穿五成,这主要是台积电力推芯片企业向先进工艺发展,与中国大陆打造的成熟工艺芯片抗衡。 分析机构指出2023年Q4全球芯片以工艺划分,28纳米及以上工艺的芯…

考研入门55问---基础知识篇

考研入门55问---基础知识篇 01 >什么是研究生入学考试? 研究生是指大专和本科之后的深造课程。以研究生为最高学历, 研究生毕业后,也可称研究生,含义为研究生学历的人。在中国大陆地区,普通民众一般也将硕士毕业生称…

[入门] Unity Shader前置知识(5) —— 向量的运算

在Unity中,向量无处不在,我想很多人都使用过向量类的内置方法 normalized() 吧,我们都知道该方法是将其向量归一化从而作为一个方向与速度相乘,以达到角色朝任一方向移动时速度都相等的效果,但内部具体是如何将该向量进…

Spring - 8 ( 10000 字 Spring 入门级教程 )

一: MyBatis 1.1 引入 MyBatis 我们学习 MySQL 数据库时,已经学习了 JDBC 来操作数据库, 但是 JDBC 操作太复杂了. 我们先来回顾⼀下 JDBC 的操作流程: 创建数据库连接池 DataSource通过 DataSource 获取数据库连接 Connection编写要执行带 ? 占位符…

21岁的人生赚51W!拒绝捞男捞女,翻身也要爱惜身体!——早读(逆天打工人爬取热门微信文章解读)

身体是革命的本钱 引言Python 代码第一篇 卢克文工作室 捞女在今天的中国是怎样的存在第二篇 人民日报 来啦 新闻早班车要闻社会政策 结尾 我将我的健康视为生活的基石 不会为了短暂的成功而牺牲 我珍惜身体 知道健康是实现梦想的前提 引言 这里毕竟是一个程序员的代码学习平台…

LVS/NAT工作模式介绍及配置

1.1 LVS/NAT模式工作原理 LVS(Linux Virtual Server)的网络地址转换(NAT)模式是一种在网络层(第四层)实现负载均衡的方法。在NAT模式中,Director Server(DS)充当所有服务…

54.HarmonyOS鸿蒙系统 App(ArkTS)tcp socket套接字网络连接收发测试

工程代码https://download.csdn.net/download/txwtech/89258409?spm1001.2014.3001.5501 54.HarmonyOS鸿蒙系统 App(ArkTS)tcp socket套接字网络连接收发测试 import socket from ohos.net.socket; import process from ohos.process; import wifiManager from ohos.wifiMana…

sql 中having和where区别

where 是用于筛选表中满足条件的行,不可以和聚类函数一起使用 having 是用于筛选满足条件的组 ,可与聚合函数一起使用 所以having语句中不能使用select中定义的名字

51单片机软件环境安装

keli5的安装 把CID放到破解程序中 破解程序会给一串数字然后填到那个框中 驱动程序的安装 安装完了以后 设备管理器会出现这个 同时c盘会出现这个文件夹

区块链 | IPFS:IPNS(实操版)

🦊原文:Publishing IPNS names Publishing IPNS names with Kubo Step1: 启动你的 IPFS 守护进程(如果尚未运行): $ ipfs daemon说明:以 $ 开头的是命令,以 > 开头的是执行结果…