Redis消息队列(1)

news2025/1/31 11:03:49

一)消息队列:从字面意思上来看是存储消息的队列,最简单的消息队列包含三个元素:

1)消息队列:存储和管理消息,也被称之为是消息代理

2)生产者:发送消息到消息队列

3)消费者:从消息队列中获取消息并处理消息

4)当有用户想要进行秒杀下单的时候,先要进行判断是否具有购买的资格,如果这个用户具有购买的资格,不是着急下单,而是把优惠卷信息和用户ID发送到消息队列里面

5)这个时候我们在开启一个独立的线程,我们再来创建一个消费者,不断地从消息队列中来进行获取消息,来进行接收消息并下单;

 

1)首先消息队列是在JVM以外的独立服务,是不受JVM内存的限制

2)消息队列不光进行数据存储,还进行数据安全问题,存入到消息队列中的所有消息要去做持久化,无论是服务宕机还是重启数据都不会丢失

3)而且消息队列中的数据投递给消费者之后,要求消费者做消息的确认,如果这个消息没有被确认,那么这个消息仍然被投递给消费者,让他继续处理,知道确保消息至少被消费一次

一)基于List结构来进行模拟消息队列

1)Redis中的list结构就是一个双向链表,是很容易模拟出队列的效果的

2)队列是当入口和出口不在同一边,因此我们可以利用lpush结合rpop,或者rpush结合lpop来进行实现,不过需要进行注意的是当队列中没有rpop或者是lpop的时候会返回null,并不会像JVM的阻塞队列那样并等待消息,因此此时我们应该使用bropop或者是blpop来实现阻塞效果

优点:

1)使用redis进行存储,是不受JVM内存上限的

2)基于redis的持久化机制,数据安全性是具有保障的

3)可以满足消息的有序性

缺点:

1)无法避免消息丢失的问题,假设说我从消息队列里面取出了一条消息,此时如果还没来得及处理这些消息服务器就挂掉了或者出现异常了,那么这条消息就丢失了(因为Blpop是直接将消息从队列中删除了)

2)只能支持但消费者,是无法支持一个消息被多个消费者消费的情况

二)基于PubSub实现的消息队列: 

PubSub消息订阅是Redis2.0版本引入的全新的消息传递模型,顾名思义就是说消费者可以进行订阅一个或者多个PubSub,生产者向对应的channel发送信息之后,所有的订阅者是都可以收到相关的消息的

1)subscribe channel:订阅一个频道或者是多个频道,不同的消费者可以订阅相同的频道也是可以订阅不同的频道

2)publish channel msg:向一个频道发送一条信息

3)psubscribe pattern:订阅的是和pattern格式相匹配的所有频道,?代表一个字符,*是代表0个或者多个;

1)xadd  users * name jack age 18

创建一个名字是users的队列,并向这个消息队列中发送一个消息,消息是

{name=jack,age=18},这个消息队列ID是由redis自动生成的

2)xlen users获取消息队列中消息的数量

3)xread读取消息队列中的信息

1)xread count 1 streams users 0

表示从users这个消息队列中读取从0号下标开始数量是1的消息

2)xread count 1 streams users *

3)xread count 1 block 0  streams users $,其中block要是0的话表示一直进行阻塞

在业务开发当中,我们可以循环的进行调用xread阻塞方式来进行查询最新消息,从而来实现持续监听队列的效果,永远进行监听消息

当我们进行指定起始ID是$的时候,代表读取最新的消息,但是如果我们进行处理一条消息的过程中发现又有超过1条以上的消息到达队列,那么下一次进行获取的时候也会读取最新的一条,也会出现消息漏读的问题

xread命令的特点:

1)消息是可以回溯的,也就是消息读取完毕之后永远不会消失,永久地保存在我们的队列中,随时想看随时可以回去看

2)一个消息可以被多个消费者读取

3)消息可以阻塞读取,可以写while(true)循环,一直读取

4)消息漏读的问题

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

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

相关文章

CENTO OS上的网络安全工具(二十一)Hadoop HA swarm容器化集群部署

如果使用swarm来构建Hadoop、Spark之类的集群,一个绕不过去的问题每个容器都需要支持SSH免密互联——因为Hadoop需要。这就需要事先准备可以一键进行集群化部署的SSH镜像。 一、SSH集群及镜像的构建 1. 准备更换镜像源的Centos7 由于Centos7已经停止维护&#xff0c…

stm32 iic驱动ds1307实际使用驱动

本文使用的工程代码如下: (1条消息) stm32iic驱动ds1307实际使用驱动,参考博客:资源-CSDN文库 上次我记得写了一个使用开发板测试DS1307的测试例程,DS1307也是使用测试板,后面项目上具体使用了,又优化了驱…

HelloSpring

1.beans.xml配置文件 在resource资源文件夹下创建beans.xml文件 <?xml version"1.0" encoding"UTF-8"?> <beans xmlns"http://www.springframework.org/schema/beans"xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance&qu…

我们的愿景是在个人计算机上实现量子霸权

奥维尔号量子计算机 简介 采用扩展的量子二进制算法。在经典计算机上实现量子计算机。我们的景愿是在个人计算机上实现量子霸权。 此计算机的字长是64位&#xff0c;等效数据位为32位字长的量子计算机。我们采用量子扩展二进制&#xff0c;共有&#xff14;个字符:0,1,Q,P可以…

Redis---主从复制 哨兵

目录 一、主从复制 1、什么是主从复制呢&#xff1f; 2、案例演示 2.1 配置文件 2.2 一主二仆 2.2.1 相关题目&#xff1a; 2.3 薪火相传 & 反客为主 3、复制原理和工作流程 3.1、slave启动&#xff0c;同步清初 3.2 首次连接&#xff0c;全量复制 3.…

【CNN】卷积神经网络(LeNet)是什么?如何实现LeNet?

系列文章目录 第一章 深度学习 CNN中的卷积神经网络&#xff08;LeNet&#xff09; 目录 系列文章目录 文章目录 前言 一、卷积神经网络&#xff08;LeNet&#xff09;是什么&#xff1f; 二、LeNet的网络结构 三、实现LeNet模型 ​​​​ 总结 前言 本文主要是介绍卷…

【改进粒子群优化算法】自适应惯性权重粒子群算法(Matlab代码实现)

&#x1f4a5;&#x1f4a5;&#x1f49e;&#x1f49e;欢迎来到本博客❤️❤️&#x1f4a5;&#x1f4a5; &#x1f3c6;博主优势&#xff1a;&#x1f31e;&#x1f31e;&#x1f31e;博客内容尽量做到思维缜密&#xff0c;逻辑清晰&#xff0c;为了方便读者。 ⛳️座右铭&a…

【软考|软件设计师】某计算机系统的CPU主频为2.8GHz

目录 题&#xff1a; CPI MIPS 题&#xff1a; 某计算机系统的CPU主频为2.8GHz。某应用程序包括3类指令&#xff0c;各类指令的CPI &#xff08;执行每条指令所需要的时钟周期&#xff09;及指令比例如下表所示。执行该应用程序时 的平均CPI为______&#xff1b; 运算速度…

面试了一个00后,绝对能称为是内卷届的天花板

前言 公司前段缺人&#xff0c;也面了不少测试&#xff0c;结果竟然没有一个合适的。一开始瞄准的就是中级的水准&#xff0c;也没指望来大牛&#xff0c;提供的薪资也不低&#xff0c;面试的人很多&#xff0c;但平均水平很让人失望。令我印象最深的是一个00后测试员&#xf…

DelphiMVCFrameWork 源码分析(三)

中间件(MiddleWare) 文档中是这样说的&#xff1a; Middleware is a powerful and flexible layer within DMVCFramework. Middleware allows you to write SOLID code and separate the processing or each request into smaller steps to be invoked during the request ha…

二本4年测试经验,5面阿里(定薪38K),分享我的心得

年前准备跳槽&#xff0c;先后面试了各大小公司&#xff0c;拿了一些offer&#xff0c;有阿里&#xff0c;滴滴&#xff0c;快手&#xff0c;达达&#xff0c;得物等公司。面试的公司大部分都能过&#xff0c;所以这里给大家分享下自己的经验&#xff0c;也给自己做个归档&…

新书推荐:《AIGC未来已来——迈向通用人工智能时代》

新书推荐&#xff1a;《AIGC未来已来——迈向通用人工智能时代》 导言 AIGC为何引发关注&#xff1f; ChatGPT会成为人工智能的拐点吗&#xff1f; GPT-4未来已来&#xff0c;奇点时刻该如何面对&#xff1f; 人类的创新能力会被AIGC替代吗&#xff1f; 当下有哪些典型的AIGC变…

单片机GD32F303RCT6 (Macos环境)开发 (二十)—— 光感芯片veml7700的使用

光感芯片veml7700的使用 1、veml有7个寄存器&#xff0c;每个十六位&#xff0c;见图。 00是config寄存器&#xff0c; 01 02 是中断设置的阈值 03是节能模式的设置 04 是得到的光的亮度值 05是得到的data of whole WHITE 06是中断设置值。 2、我们只测试得到光的亮度值&…

86盒IP对讲一键报警器

86盒IP对讲一键报警器 86盒IP对讲一键报警器&#xff1a;革命性保障生命安全的利器&#xff01; 随着科技的飞速发展&#xff0c;我们的生活变得越来越方便和智能化。而86盒IP对讲一键报警器更是在这种背景下应运而生。这款产品不仅无缝对接各种手机APP&#xff0c;也可以在智…

Linux系统crash后定位方法-PCIE举例

crash解释 在Linux操作系统中&#xff0c;"crash"通常是指一种用于分析系统崩溃&#xff08;crash&#xff09;的工具或方法。当系统发生崩溃时&#xff0c;可能会产生一些关键信息&#xff0c;如错误日志、内存转储文件等。使用crash工具可以分析这些信息&#xff…

零基础自学【Web安全/网络渗透】,保姆级快速入门指南(非常详细)

前言 基础真的很简单&#xff0c;是个人稍微认点真都能懂&#xff0c;这就是好多人说的网络安全简单、易懂、好学&#xff0c;然后就是一顿浮夸的言论&#xff0c;误导那些小白&#xff0c;再然后那些小白也就跟着浮夸。这里我就给那些轻浮的人泼一桶冷水&#xff0c;懂跟学会…

香港人才引进只看本科排名,“以本科定终身”是否公平?

2022年10月20日&#xff0c;香港特首在《2022 施政报告》时公布&#xff0c;新推出高端人才通行证计划&#xff0c;简称“高才通”&#xff0c;豪言3年引入10万人才&#xff0c;接受全球百强名校本科毕业的高材生或年收入超过250万港币的高收入群体到香港工作。 香港高才通是目…

【数据结构】链表(C语言实现)

创作不易&#xff0c;本篇文章如果帮助到了你&#xff0c;还请点赞 关注支持一下♡>&#x16966;<)!! 主页专栏有更多知识&#xff0c;如有疑问欢迎大家指正讨论&#xff0c;共同进步&#xff01; &#x1f525;c语言系列专栏&#xff1a;c语言之路重点知识整合 &#x…

丁鹿学堂:vue的脚手架项目基础入门和单文件代码分析

在实际开发中&#xff0c;我们都是通过脚手架创建vue项目的。 默认安装了node&#xff0c;yarn&#xff0c; 1创建项目&#xff1a; yarn create vue为了学习&#xff0c;我们选择最简单的培训&#xff0c;一路下来都选no 2 创建项目以后&#xff0c;只是搭起了架子&#x…

Uniapp一言“一句话接口调用

界面 代码 <template><view ><view class"uni-padding-wrap uni-common-mt"><view class"text-box" scroll-y"true"><text>{{data}}</text></view><view class"uni-btn-v"><butto…