Redis类型 Stream Bitfield

Stream 类型

Stream类型就是Redis里的mq,是redis为了占领市场份额的产物 

今天我们就来介绍一下Stream

Redis的消息队列一般是两个方案

第一个是Lpush Rpop 队列的异步队列方案(一对一)

第二个方案就是pubsub(发布订阅)模式 (一对多)

注:这里如果没有消费者了,队列中的数据就直接被丢弃了,没有持久化

Redis Stream是在Redis5引入的,支持消息持久化,全局自动生成唯一id,支持消息ack等等

底层数据结构

首先消息队列的底层是一个链表结构

解释一下这里的参数    

Message Content  消息内容

Consumer group 消费组  含有多个消费者

Last_delieved_id      游标  可以理解为读完一个就向后走一个,消费完成 表示哪些是新的消息,哪些是消费过的消息

   

消费者读完确认了就是ack   类似于TCP中的ack

这里记录的就是读过了但是没有签收的消息id 如果客户端没有ack 这里面的消息就会越来越多    如果客户段发送ack就开始减少    主要用来确保消息至少被消费了一次,而不是在网络传输中被丢失

有关Redis指令

xadd mystream * k1 v1 

这里*表示自动生成消息ID

这里的返回值就是毫秒时间戳和该毫秒产生的第一条消息

注:同一时间产生的消息不允许相同,但是可以产生不同的消息

type mystream

我们还可以查看一下类型如上文所见

xrange 查看消息列表

xrange mystream - +

注:这里使用count来分页  和mysql中的limit一样

xrevrange mystream + -

就是将原来的输出掉个个儿

xdel mtstream 主键

注意这里是按照主键删除,也就是按照时间戳+第一条信息的id删除

注:这里如果出现以下错误,我们只需要将配置文件修改即可(推荐使用yes保证数据快照的时效性)

xlen key

查看长度

xtrim截取操作

可以按照时间截取也可以按照最大长度获取

我们首先加点数据

我们执行操作就可以看到数据只剩两个了

同样的我们可以规定截取在某时间戳之后产生的消息

xread count n (block) streams key 符号

这里streams是一个关键字

这条指令用于获取消息,以阻塞或者非阻塞的方式或者比某个时间点大的n条消息

这里符号如果填写$就是表示目前队列中的最新消息的下一个消息

如果能获取到,返回,获取不到返回nil

0-0就是从最小的消息开始读取返回,没有限制就是类似于遍历整个队列

block 0 就是无限阻塞

我们这里举个例子就是获取最新的下一条信息 $  然后我们重新开一个客户端来进行修改看能不能返回

新的客户端

旧的客户端

消费组指令

队列里面也有消息了,那如何来消费呢?

下面我们就开始讲解消费组

创建消费组

例:xgroup create mystream groupX $   从尾部开始消费

xgroup create mystream groupA 0   从首部开始消费

 

注:此时2号消费者就读不到了,因为一旦被本组任意消费者消费了,指针就走到头了,本组其他消费者就不能再读取了

消费组的目的:

每个消费者读取一部分数据  这样就能达成负载均衡的效果

消息的ack机制

xpending key group

查看xpending队列中的消费组消费情况

这里就是groupA中的consumer1消费了三条数据

一旦消息被ack了之后,这里的消息队列中的数据就可以删除了

我们这里查看一下groupA的xpending数据

xpending stream groupA - + 10  consumer1

我们发现签收完了悬而未决的list中就删除了

注:这里队列中不会删除

xinfo 用于打印消费者分组的情况

xinfo stream mystream

使用建议

Stream不能100%代替kafka.....建议慎用

Bitfieid

这个数据类型,了解即可

基本命令

主要是做一个溢出控制  

可以设置溢出之后是使用比如8位有符号整数 

存储128之后就是-128   4位无符号存储15加一就会归零等等  

几乎没有使用机会

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

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

相关文章

代码随想录第25天 | 组合总和||| 、 电话号码的字母组合

一、前言 参考文献:代码随想录 今天的还是回溯算法,主要用到了昨天的回溯组合方法和巧妙思路方法,让我们继续为算法打基础吧! 二、组合总和||| 1、思路: 这一题和昨日的组合没啥太大区别只是遍历的范围变为了固定…

未来智慧停车:技术架构解析与创新应用

随着城市化进程的不断加速,停车难题已成为城市居民生活中的一大痛点。传统的停车方式已经无法满足日益增长的停车需求,而智慧停车系统则成为了解决这一难题的重要途径。本文将深入探讨智慧停车系统的技术架构,并探索其在城市管理和用户体验上…

echarts双柱状堆叠图

效果 代码 option {tooltip: {trigger: axis,axisPointer: { // 坐标轴指示器&#xff0c;坐标轴触发有效type: shadow // 默认为直线&#xff0c;可选为&#xff1a;line | shadow},formatter: function (params) { var res<div><p>时间&am…

数据库聚簇索引和非聚簇索引的区别

聚簇索引&#xff08;Clustered Index&#xff09;和非聚簇索引&#xff08;Non-clustered Index&#xff09;是数据库中两种不同的索引类型&#xff0c;它们的主要区别在于数据的存储方式和索引的结构&#xff1a; 数据存储方式&#xff1a; 聚簇索引&#xff1a;索引的叶子节…

ssm框架笔记-maven

html是骨头 css使皮肤 js是你能做的动作 MAVEN 依赖管理&#xff1a;1.声明dependenciys标签 2.maven search3。 版本号提取 3.$引用 3.2依赖传递和冲突 依赖传递指的是当一个模块或库 A 依赖于另一个模块或库 B&#xff0c;而 B 又依赖于模块或库 C&#xff0c;那么 A 会间…

vue3+vite模版框架 tabs右键刷新时丢失路由参数

问题&#xff1a; 标题栏的tabs的右键&#xff1a;刷新时&#xff0c;没有保存上一个页面传递过来的参数 分析&#xff1a; TagView.vue刷新事件 function refreshSelectedTag(view: TagView) {console.log(|--执行刷新, view)tagsViewStore.delCachedView(view);const {full…

吴恩达2022机器学习专项课程(一) 4.1 梯度下降

问题预览 梯度下降算法的作用是&#xff1f;梯度下降的过程&#xff1f;梯度下降和最小化成本函数的联系&#xff1f;所有的成本函数都是一个形状吗&#xff1f;在非凸形状中&#xff0c;梯度下降的更新过程是&#xff1f;在非凸形状中&#xff0c;不同的初值对最小化成本函数…

对于提高Web安全,WAF能有什么作用

数字化时代&#xff0c;网络安全已经成为了一个不可忽视的重要议题。网络攻击事件频发&#xff0c;各种安全隐患层出不穷&#xff0c;如何有效地保护我们的网络空间&#xff0c;确保信息安全&#xff0c;已成为一项迫切的任务。而Web应用防火墙&#xff0c;正是守护网络安全的一…

【LIMS】CMA与CNAS:中国认证体系中的两大支柱

目录 一、CMA&#xff1a;[中国计量认证](http://cma-cma.org.cn/)什么是CMA&#xff1f;CMA的作用 二、CNAS&#xff1a;[中国合格评定国家认可委员会](https://www.cnas.org.cn/)什么是CNAS&#xff1f;CNAS的作用 三、CMA与CNAS的关系相互促进共同目标 结语系列文章版本记录…

国内顶级大牛整理:分布式消息中间件实践笔记+分布式核心原理解析

XMPP JMS RabbitMQ 简介 工程实例 Java 访问RabbitMQ实例 Spring 整合RabbitMQ 基于RabbitMQ的异步处理 基于RabbitMQ的消息推送 RabbitMQ实践建议 虚拟主机 消息保存 消息确认模式 消费者应答 流控机制 通道 总结 ActiveMQ 简介 工程实例 Java 访问ActiveMQ实例…

【21-40】计算机网络基础知识(非常详细)从零基础入门到精通,看完这一篇就够了

【21-40】计算机网络基础知识&#xff08;非常详细&#xff09;从零基础入门到精通&#xff0c;看完这一篇就够了 以下是本文参考的资料 欢迎大家查收原版 本版本仅作个人笔记使用21、HTTPS是如何保证数据传输的安全&#xff0c;整体的流程是什么&#xff1f;&#xff08;SSL是…

运筹学基础(三):求解整数规划的切平面法(cutting plane method)

文章目录 算法思想一个例子参考文档 算法思想 先将整数规划问题松弛为线性规划问题&#xff0c;然后割掉线性规划问题可行域的一部分&#xff08;只包含非整数解&#xff09;&#xff0c;使得线性规划问题的最优解在原整数规划问题的可行域某顶点上取得。 因此&#xff0c;割平…

Flink SQL 基于Update流出现空值无法过滤问题

问题背景 问题描述 基于Flink-CDC &#xff0c;Flink SQL的实时计算作业在运行一段时间后&#xff0c;突然发现插入数据库的计算结果发生部分主键属性发生失败&#xff0c;导致后续计算结果无法插入&#xff0c; 超过失败次数失败的情况问题报错 Caused by: java.sql.BatchUp…

智慧公厕:让公共厕所变得更智能、更卫生、更舒适的解决方案

近年来&#xff0c;随着城市发展的不断壮大&#xff0c;公共设施的建设也越来越受到重视。而公共厕所作为城市基础设施的一部分&#xff0c;是城市文明程度的重要体现。然而&#xff0c;传统的公共厕所在使用、运行、管理、养护等方面存在诸多问题&#xff0c;严重影响了市民的…

特征选择集大成的包-arfs(python)

特征选择集大成的包-arfs&#xff08;python&#xff09; 一、介绍 arfs介绍文档https://arfs.readthedocs.io/en/latest/Introduction.html 英文好的朋友可以阅读作者写的介绍&#xff1a; All relevant feature selection means trying to find all features carrying info…

YOLOv5改进系列:升级版ResNet的新主干网络DenseNet

一、论文理论 论文地址&#xff1a;Densely Connected Convolutional Networks 1.理论思想 DenseNet最大化前后层信息交流&#xff0c;通过建立前面所有层与后面层的密集连接&#xff0c;实现了特征在通道维度上的复用&#xff0c;不但减缓了梯度消失的现象&#xff0c;也使其…

【二分图】【二分图最大匹配】LCP 04. 覆盖

作者推荐 视频算法专题 本文涉及知识点 二分图 二分图最大匹配 LeetCode LCP 04. 覆盖 你有一块棋盘&#xff0c;棋盘上有一些格子已经坏掉了。你还有无穷块大小为1 * 2的多米诺骨牌&#xff0c;你想把这些骨牌不重叠地覆盖在完好的格子上&#xff0c;请找出你最多能在棋盘…

2024年京东云主机租用价格_京东云服务器优惠价格表

2024年京东云服务器优惠价格表&#xff0c;轻量云主机优惠价格5.8元1个月、轻量云主机2C2G3M价格50元一年、196元三年&#xff0c;2C4G5M轻量云主机165元一年&#xff0c;4核8G5M云主机880元一年&#xff0c;游戏联机服务器4C16G配置26元1个月、4C32G价格65元1个月、8核32G费用…

新书速递——《可解释AI实战(PyTorch版)》

本书旨在帮助你实施最新的可解释AI技术&#xff0c;以构建公平且可解释的AI系统。可解释AI是当今AI研究中的热门话题&#xff0c;但只有少数资源和指南涵盖了所有重要技术&#xff0c;这些技术对实践者来说非常有价值。本书旨在填补这一空白。 本书读者对象 本书既适合那些有兴…

GIt的原理和使用(五):模拟多人协作的两种情况

目录 多人协作 多人协作一 准备工作 协作开发 多人协作二 准备工作 额外场景 申请单合并分支 更推荐写法 远程分支删除后&#xff0c;本地git branch -a依然能看到的解决办法 多人协作 多人协作一 目标&#xff1a;在远程master分支下的file.txt文件新增代码“aaa”…