队列是一种特殊的线性表，特殊之处在于它只允许在表的前端（front）进行删除操作，而在表的后端（rear）进行插入操作，和栈一样，队列是一种操作受限制的线性表。进行插入操作的端称为队尾，进行删除操作的端称为队头。消息队列是在消息的传输过程中保存消息的容器。(redis教程)redis中的消息队列redis中可以使用自带的publish和subscribe命令完成“消息推送”和“消息拉取”功能，实现消息队列。但这种方式有一个缺陷就是，消费者...
1，安装Redis，根据自己的PHP版本安装对应的redis扩展（此步骤简单的描述一下）1.1，安装 php_igbinary.dll，php_redis.dll扩展此处需要注意你的php版本如图： 1.2，php.ini文件新增 extension=php_igbinary.dll;extension=php_redis.dll两处扩展ok此处已经完成第一步redis环境搭建完成看看phpinfo项目中实际使用redis2.1，第一步配置redis参数如下，redis安装的默认端口为6379： 1234567891011121314<?php/* 数据库配置 */ret...
现如今的互联网应用大都是采用 分布式系统架构 设计的，所以 消息队列 已经逐渐成为企业的应用系统 内部通信 的核心手段，它具有 低耦合、可靠投递、广播、流量控制、最终一致性 等一系列功能。当前使用较多的 消息队列 有 RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMQ 等，而部分数据库 如 Redis、MySQL 以及 phxsql ，如果硬搞的话，其实也可实现消息队列的功能。可能有人觉得，各种开源的 MQ 已经足够使用了，为什么需...
本文提出了一种用Redis实现简单消息队列的方案，适合在资源不足的条件下临时使用。[记录点滴]Redis实现简单消息队列目录[记录点滴]Redis实现简单消息队列4.1 数据变量4.2 消费函数4.3 删除备份消息4.4 处理异常2.1 Redis是否适合做消息队列2.2 Redis做消息队列的方案2.4 本文采取的方案2.1.1 Redis的问题2.1.2 不容忍错误2.1.3 容忍错误2.4.1 RPOPLPUSH2.4.2 BLPOP和BRPOP0x00 摘要0x01 缘由0x02 背景概念0x03 生产者LUA0x04 消费者...
所谓消息队列，即在消息的传输过程中保存消息的容器。最常见的使用场景是，通过引入消息队列来对耗时的任务就行异步处理，以及应对高并发问题，即所谓的削峰作用。在以PHP为主要开发语言的项目中，我们可以选择的软件有很多，最常使用的有三种：基于 Redis 的 List数据类型 来用PHP实现入列出列，基于 Memcached 的扩展应用 MemcacheQ，还有更强大和流行的RabbitMQ。基于 Redis 来实现消息队列，主要是用到 Redis 中的 List 数据类...
前言 前面我们在redis学习笔记之基本5种数据结构中提到列表实现队列，我们今天就简单说下redis队列实现的几种方式。redis队列实现可以通过 基于List的 LPUSH+BRPOP 的实现， 基于Sorted-Set的实现，PUB/SUB（订阅/发布模式），stream，下面我们主要是说说list，发布订阅，stream这三个知识点，至于sorted-set (有序集合)我们后面再说。 队列(LPUSH/BRPOP)redis中通过列表可以来实现队列具体操作可以下面操作 rpush/lpop或lpush/rp...
从最简单的开始：List 队列 首先，我们先从最简单的场景开始讲起。 如果你的业务需求足够简单，想把 Redis 当作队列来使用，肯定最先想到的就是使用 List 这个数据类型。 因为 List 底层的实现就是一个「链表」，在头部和尾部操作元素，时间复杂度都是 O(1)，这意味着它非常符合消息队列的模型。 如果把 List 当作队列，你可以这么来用。 生产者使用 LPUSH 发布消息： 127.0.0.1:6379>?LPUSH?queue?msg1(integer)?1127.0.0.1:6379>...
1. Redis分布式锁实现原理分布式锁本质上要实现的目标就是在 Redis 里面占一个“茅坑”，当别的进程也要来占时，发现已经有人蹲在那里了，就只好放弃或者稍后再试。占坑一般是使用 setnx(set if not exists) 指令，只允许被一个客户端占坑。先来先占， 用完了，再调用 del 指令释放茅坑。死锁问题：如果逻辑执行到中间出现异常了，可能会导致 del 指令没有被调用，这样就会陷入死锁，锁永远得不到释放， 解决这个问题我们在拿到锁之...
redis在很早之前就支持消息队列了，使用的是PUB/SUB功能来实现的。PUB/SUB有一个缺点就是消息不能持久化，如果redis发生宕机，或者客户端发生网络断开，历史消息就丢失了。redis5.0开始引入了stream这个数据结构，stream可以很好地用于消息队列，它支持消息持久化，同时可以记录消费者的位置，即使客户端断开重连，也不会丢失消息。本篇文章我们就来聊一聊基于stream的消息队列使用。stream队列简介基于stream实现的消息队列有4个角...
我们知道redis支持很多种结构的数据，那么如何使用redis作为异步队列使用呢？使用list结构，rpush生产消息，lpop消费消息。 lpop没有消息的时候，可适当sleep后重试。 若不使用sleep方案，可使用blpop消费消息，它会阻塞直至消息到来。pub/sub的主题订阅者模式的优缺点优点：可实现生产一次消费多次，实现1:N的消息队列。缺点：在消费者下线的情况下，生产的消息会丢失，需要专业的消息队列如rabbitMQ。 如何使用redis实现演示队列...
Redis分布式锁实现原理 分布式锁本质上要实现的目标就是在 Redis 里面占一个“茅坑”，当别的进程也要来占时，发现已经有人蹲在那里了，就只好放弃或者稍后再试。占坑一般是使用 setnx(set if not exists) 指令，只允许被一个客户端占坑。先来先占， 用完了，再调用 del 指令释放茅坑。 死锁问题：如果逻辑执行到中间出现异常了，可能会导致 del 指令没有被调用，这样就会陷入死锁，锁永远得不到释放， 解决这个问题我们在拿到锁之...
背景公司项目有个需求, 前端上传excel文件, 后端读取数据、处理数据、返回错误数据, 最简单的方式同步处理, 客户端上传文件后一直阻塞等待响应, 但用户体验无疑很差, 处理数据可能十分耗时, 没人愿意傻等, 由于项目暂未使用ActiveMQ等消息队列中间件, 而redis的lpush和rpop很适合作为一种轻量级的消息队列实现, 所以用它完成此次功能开发一、本文涉及知识点excel文件读写--阿里easyexcel sdk文件上传、下载--腾讯云对象存储远程服务...
摘要：本文将对Stream的常用命令和应用场景进行介绍，并探讨原生Redis Stream消息队列的缺陷以及GaussDB(for Redis)提供的解决方案，供大家学习和选用。 华为云高斯Redis团队欢迎各路英才加入，联系邮箱：yuwenlong4@huawei.com 引言： Redis Stream是Redis 5.0引入的一种新的数据类型，其本质是一个消息队列，类似于 kafka等消息中间件。它提供了消息的落地存储功能，并实现了类似kafka消费组和消费者的功能。与kafka相比，Redis ...
最近项目中有这样一个需求，在用户的考试快开始的时候要给用户发条消息，提醒用户考试快开始了。这种需求其实很常见，本质可以基于延时队列去实现，结合目前项目技术栈使用情况，想到了三种方案： 时间轮Redis Key 过期监听Redis ZSet 过期时间作为 score，每次取出 score 小于当前时间的数据 时间轮个人感觉单机版实现简单，但是分布式环境下实现复杂；Redis Key 过期监听根据以往经验不一定靠谱，且不易于控制消费进度；于是最终...
Redis 深度历险：核心原理和应用实践 目 录 开篇：授人以鱼不若授人以渔—— Redis 可以用来做什么？ 7 由 Redis 面试想到的 7 小册的内容范围 8 Redis 可以做什么？ 8 基础：万丈高楼平地起 ——Redis 基础数据结构 11 Redis 安装 11 Redis 基础数据结构 12 string (字符串) 12 list (列表) 15 hash (字典) 17 set (集合) 19 容器型数据结构的通用规则 22 应用 1：千帆竞发 —— 分布式锁 23 分布式锁 24 超时问题 25 可重入性 2...