Spring Boot中使用Redis和Lua脚本实现延时队列

本文涉及的产品
云数据库 Tair(兼容Redis),内存型 2GB
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
简介: Spring Boot中使用Redis和Lua脚本实现延时队列

一、延迟队列的四大使用场景

  1. 订单超时自动处理
    在电商领域,延迟队列对于处理订单超时问题至关重要。一旦用户下单,订单信息便进入延迟队列,并预设超时时长。若用户在此时间内未完成支付,订单信息将由消费者从队列中提取,并执行如取消订单、库存释放等后续操作,高效且自动化。
  2. 优惠券到期温馨提醒
    借助延迟队列,我们可以实现优惠券到期前的温馨提醒服务。将临近过期的优惠券信息入队,并设定精确延迟时间。时间一到,系统自动提醒用户优惠券的到期日,引导他们及时享用优惠,提升用户体验。
  3. 智能消息重试策略
    在处理网络请求失败、数据库异常等情况时,延迟队列提供了智能的消息重试机制。当消息初次处理失败,它会被置入队列并设定重试延时。延时结束后,系统会再次尝试处理,确保消息的可靠传递与处理。
  4. 异步通知与定时提醒
    延迟队列还能用于实现异步通知和定时提醒功能。用户完成操作后,系统将相关通知信息加入队列,并设定发送延时,确保在最佳时机向用户推送通知,既不打扰用户,又能保持信息的时效性。

二、如何利用ZSet实现延迟队列

Redis的ZSet(有序集合)是一个根据分数对唯一字符串成员进行排序的数据结构。在多个成员分数相同时,它们会按照字典顺序进行排列。ZSet不仅常用于排行榜和限速器等场景,还可巧妙用于实现延迟队列。

基于ZSet的延迟队列实现原理,主要利用了其有序性和按分数排序的特点。以下是具体实现步骤的简要介绍:


定义延迟消息:在ZSet中,我们将延迟消息作为成员,而其对应的延迟时间则作为该成员的分数。这里的延迟时间通常是一个未来的时间戳,它指明了消息应当被处理的确切时刻。


消息入队:使用ZADD命令,我们可以轻松地将消息添加到ZSet中,并为其指定相应的延迟时间作为分数。


定期检查:通过定期轮询ZSet,我们可以利用ZRANGEBYSCORE命令来检索那些分数(即延迟时间)小于或等于当前时间戳的消息,这些消息即为到期的、需要被处理的消息。


消息处理与出队:一旦找到到期的消息,我们可以使用ZPOPMIN命令将它们从ZSet中移除,并进行相应的处理。在处理过程中,需要考虑并发性和数据一致性问题,确保每条消息都能被正确处理且不会被重复处理。


后续操作与通知:为了提高系统的性能和可靠性,我们可以结合Redis的Pub/Sub机制。在处理完消息后,发布一个事件来通知其他服务或订阅者进行后续的操作或处理。

通过这种方式,ZSet能够有效地按照消息的延迟时间顺序,逐个取出并处理到期的消息,从而实现了一个高效且可靠的延迟队列系统。

三、实现步骤

在Spring Boot环境下,实现一个基于Redis和Lua脚本的延时队列,需要以下几个步骤:


环境准备


安装并启动Redis服务器。

在Spring Boot项目中添加spring-boot-starter-data-redis依赖。

Redis数据结构选择


使用Redis的zset(有序集合)数据结构来存储延时任务。zset中的元素是唯一的,但分数(score)可以相同,可以用作任务的延迟时间戳。

Lua脚本编写


编写一个Lua脚本来处理队列的出队和入队操作,以确保操作的原子性。

Spring Boot应用配置


配置Redis连接工厂和Redis模板。

实现延时队列服务


提供一个服务来管理延时队列,包括入队、出队、检查并处理到期的任务等。

定时任务调度


使用Spring的@Scheduled注解或者Redis的键空间通知来定期检查并处理到期的任务。

四、实现代码

下面是一个简化版本的实现:

1. 添加Maven依赖

pom.xml中添加spring-boot-starter-data-redis依赖:

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

2. 配置Redis

application.ymlapplication.properties中配置Redis连接信息:

spring:
  redis:
    host: localhost
    port: 6379

3. Lua脚本

定义一个Lua脚本原子性地执行出队操作。脚本使用Redis的有序集合命令来查找并移除到期的任务:

-- KEYS[1] 延时队列的key
-- ARGV[1] 当前时间戳
-- 返回值:任务ID(如果存在)或nil
local key = KEYS[1]
local currentTime = tonumber(ARGV[1])
local task = redis.call('zrangebyscore', key, 0, currentTime, 'LIMIT', 0, 1)
if #task > 0 then
    redis.call('zremrangebyscore', key, 0, currentTime)
    return task[1]
else
    return nil
end

可以稍微优化一下上面的Lua脚本,以减少不必要的操作和提高效率:

-- KEYS[1] 延时队列的key
-- ARGV[1] 当前时间戳
-- 返回值:任务ID(如果存在)或nil

local key = KEYS[1]
local currentTime = tonumber(ARGV[1])

-- 使用zrangebyscore和zrem的组合命令zpopmin,它原子性地返回并移除分数最低的元素
-- zpopmin命令(5.0及以上版本)
local task = redis.call('zpopmin', key, 1, 'BLOCK', 0, 'SCORES')

-- zpopmin返回的是一个包含两个元素的数组,第一个元素是分数,第二个是成员
if task and #task > 0 and task[2] and tonumber(task[1]) <= currentTime then
    return task[2] -- 返回任务ID
else
    return nil
end

注意:


zpopmin命令是一个原子性的操作,它返回并删除分数最低的元素。避免了先查询后删除可能带来的并发问题。zpopmin`命令在Redis 5.0及以上版本中可用。


zpopmin命令可以设置阻塞时间,这里设置为0,表示不阻塞。如果希望在没有可用元素时阻塞等待一段时间,可以调整这个值。


脚本检查了返回的分数是否小于等于当前时间戳,以确保只处理到期的任务。


如果Redis版本低于5.0zpopmin将不可用,可以使用zrangebyscore和zrem的组合,但需要注意并发问题。

4. 实现延时队列服务

@Service
public class DelayQueueService {
    @Autowired
    private StringRedisTemplate stringRedisTemplate;
    private static final String DELAY_QUEUE_KEY = "delay_queue";

    // 入队操作
    public void enqueue(String taskId, long delayInSeconds) {
        long score = System.currentTimeMillis() / 1000 + delayInSeconds;
        stringRedisTemplate.opsForZSet().add(DELAY_QUEUE_KEY, taskId, score);
    }

    // 出队操作,使用Lua脚本确保原子性
    public String dequeue() {
        String luaScript = "..."; // 上面定义的Lua脚本内容
        RedisScript<String> script = RedisScript.of(luaScript, String.class);
        long currentTime = System.currentTimeMillis() / 1000;
        return stringRedisTemplate.execute(script, Collections.singletonList(DELAY_QUEUE_KEY), String.valueOf(currentTime));
    }
}

5. 定时任务调度

@Component
public class DelayQueueScheduler {
    @Autowired
    private DelayQueueService delayQueueService;
    private static final long POLLING_INTERVAL = 1000; // 检查间隔1秒

    @Scheduled(fixedRate = POLLING_INTERVAL)
    public void pollAndProcess() {
        String taskId = delayQueueService.dequeue();
        if (taskId != null) {
            // 处理任务逻辑,例如调用某个服务或者方法等。
            System.out.println("Processing task: " + taskId);
        }
    }
}

五、使用ZSet实现延迟队列的缺陷

虽然Redis的ZSet能满足一些简单场景的延迟队列需求,但也存在一些明显的缺陷。

资源空转问题:

延迟任务的时间分布往往是不均匀的。在某些时段,可能会有大量的任务需要处理,而在其他时段则可能几乎没有任务。这种情况下,如果系统持续检查ZSet以寻找到期任务,那么在任务稀少或无任务的时段,系统会处于空转状态,这无疑是对计算资源的浪费。


性能瓶颈:

当延迟消息数量众多时,不断地轮询整个ZSet以查找到期消息会对性能产生显著影响。特别是当任务数量庞大且到期时间分散时,范围查询的开销会变得尤为突出。此外,如果多个任务同时到期且回调函数执行效率低下,还可能导致延迟处理中心的性能下降,进而引发连锁反应,影响到后续任务的及时处理。


时间精度问题:

ZSet使用浮点数作为分数来排序元素,这在某些需要高精度时间控制的场景中可能不够用。同时,Redis实例的故障、重启或时钟回拨等问题都可能影响到延迟事件处理的准确性。


六、替代实现方案

状态即时校验:

在某些业务流程中,可以通过即时校验当前状态与应有状态的方式来替代延迟队列。但这种方法更适用于工单等可以持续校验的业务场景,对于一次性的延迟通知任务则不太适用。


利用消息中间件的延迟消息功能:

像RocketMQ和RabbitMQ这样的消息中间件提供了延迟消息的功能。例如,RocketMQ在商业版本中支持自定义时长的延迟消息。


数据库轮询:

通过定期轮询数据库中的业务单据表或专门的延迟事件表来处理过期任务。但这种方法可能会对业务数据库和服务造成性能负担,且轮询的时间间隔难以精确把控。


时间轮算法:

时间轮算法是一种有效的处理定时任务的方法。但为了实现持久化和避免任务丢失,需要结合Redis或关系数据库来存储延迟任务。在服务启动时,需要将存储的延迟任务加载到时间轮中,并在任务过期后更新任务状态,以防止重复执行或加载。


结语

通过使用Redis和Lua脚本,可以在Spring Boot环境中实现一个高效且可靠的延时队列系统。这种方法利用了Redis的有序集合数据结构和Lua脚本的原子性操作来确保任务的正确性和一致性。通过定期调度任务来处理到期的任务,可以实现各种需要延迟执行的操作,如发送提醒、执行定时任务等。

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
2月前
|
NoSQL 安全 Java
深入理解 RedisConnectionFactory:Spring Data Redis 的核心组件
在 Spring Data Redis 中,`RedisConnectionFactory` 是核心组件,负责创建和管理与 Redis 的连接。它支持单机、集群及哨兵等多种模式,为上层组件(如 `RedisTemplate`)提供连接抽象。Spring 提供了 Lettuce 和 Jedis 两种主要实现,其中 Lettuce 因其线程安全和高性能特性被广泛推荐。通过手动配置或 Spring Boot 自动化配置,开发者可轻松集成 Redis,提升应用性能与扩展性。本文深入解析其作用、实现方式及常见问题解决方法,助你高效使用 Redis。
206 4
|
3月前
|
NoSQL Java 关系型数据库
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Redis 介绍
本文介绍在 Spring Boot 中集成 Redis 的方法。Redis 是一种支持多种数据结构的非关系型数据库(NoSQL),具备高并发、高性能和灵活扩展的特点,适用于缓存、实时数据分析等场景。其数据以键值对形式存储,支持字符串、哈希、列表、集合等类型。通过将 Redis 与 Mysql 集群结合使用,可实现数据同步,提升系统稳定性。例如,在网站架构中优先从 Redis 获取数据,故障时回退至 Mysql,确保服务不中断。
130 0
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Redis 介绍
|
1月前
|
消息中间件 缓存 NoSQL
基于Spring Data Redis与RabbitMQ实现字符串缓存和计数功能(数据同步)
总的来说,借助Spring Data Redis和RabbitMQ,我们可以轻松实现字符串缓存和计数的功能。而关键的部分不过是一些"厨房的套路",一旦你掌握了这些套路,那么你就像厨师一样可以准备出一道道饕餮美食了。通过这种方式促进数据处理效率无疑将大大提高我们的生产力。
92 32
|
11天前
|
机器学习/深度学习 数据采集 人机交互
springboot+redis互联网医院智能导诊系统源码,基于医疗大模型、知识图谱、人机交互方式实现
智能导诊系统基于医疗大模型、知识图谱与人机交互技术,解决患者“知症不知病”“挂错号”等问题。通过多模态交互(语音、文字、图片等)收集病情信息,结合医学知识图谱和深度推理,实现精准的科室推荐和分级诊疗引导。系统支持基于规则模板和数据模型两种开发原理:前者依赖人工设定症状-科室规则,后者通过机器学习或深度学习分析问诊数据。其特点包括快速病情收集、智能病症关联推理、最佳就医推荐、分级导流以及与院内平台联动,提升患者就诊效率和服务体验。技术架构采用 SpringBoot+Redis+MyBatis Plus+MySQL+RocketMQ,确保高效稳定运行。
45 0
|
3月前
|
存储 人工智能 NoSQL
SpringBoot整合Redis、ApacheSolr和SpringSession
本文介绍了如何使用SpringBoot整合Redis、ApacheSolr和SpringSession。SpringBoot以其便捷的配置方式受到开发者青睐,通过引入对应的starter依赖,可轻松实现功能整合。对于Redis,可通过配置RedisSentinel实现高可用;SpringSession则提供集群Session管理,支持多种存储方式如Redis;整合ApacheSolr时,借助Zookeeper搭建SolrCloud提高可用性。文中详细说明了各组件的配置步骤与代码示例,方便开发者快速上手。
71 11
|
3月前
|
NoSQL Java API
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Spring Boot 集成 Redis
本文介绍了在Spring Boot中集成Redis的方法,包括依赖导入、Redis配置及常用API的使用。通过导入`spring-boot-starter-data-redis`依赖和配置`application.yml`文件,可轻松实现Redis集成。文中详细讲解了StringRedisTemplate的使用,适用于字符串操作,并结合FastJSON将实体类转换为JSON存储。还展示了Redis的string、hash和list类型的操作示例。最后总结了Redis在缓存和高并发场景中的应用价值,并提供课程源代码下载链接。
198 0
|
3月前
|
NoSQL Java Redis
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Redis 安装
本教程介绍在 VMware 虚拟机(CentOS 7)或阿里云服务器中安装 Redis 的过程,包括安装 gcc 编译环境、下载 Redis(官网或 wget)、解压安装、修改配置文件(如 bind、daemonize、requirepass 等设置)、启动 Redis 服务及测试客户端连接。通过 set 和 get 命令验证安装是否成功。适用于初学者快速上手 Redis 部署。
59 0
|
3月前
|
前端开发 Java 数据库
微服务——SpringBoot使用归纳——Spring Boot集成Thymeleaf模板引擎——Thymeleaf 介绍
本课介绍Spring Boot集成Thymeleaf模板引擎。Thymeleaf是一款现代服务器端Java模板引擎,支持Web和独立环境,可实现自然模板开发,便于团队协作。与传统JSP不同,Thymeleaf模板可以直接在浏览器中打开,方便前端人员查看静态原型。通过在HTML标签中添加扩展属性(如`th:text`),Thymeleaf能够在服务运行时动态替换内容,展示数据库中的数据,同时兼容静态页面展示,为开发带来灵活性和便利性。
93 0
|
3月前
|
XML Java 数据库连接
微服务——SpringBoot使用归纳——Spring Boot集成MyBatis——基于 xml 的整合
本教程介绍了基于XML的MyBatis整合方式。首先在`application.yml`中配置XML路径,如`classpath:mapper/*.xml`,然后创建`UserMapper.xml`文件定义SQL映射,包括`resultMap`和查询语句。通过设置`namespace`关联Mapper接口,实现如`getUserByName`的方法。Controller层调用Service完成测试,访问`/getUserByName/{name}`即可返回用户信息。为简化Mapper扫描,推荐在Spring Boot启动类用`@MapperScan`注解指定包路径避免逐个添加`@Mapper`
106 0
|
3月前
|
Java 测试技术 微服务
微服务——SpringBoot使用归纳——Spring Boot中的项目属性配置——少量配置信息的情形
本课主要讲解Spring Boot项目中的属性配置方法。在实际开发中,测试与生产环境的配置往往不同,因此不应将配置信息硬编码在代码中,而应使用配置文件管理,如`application.yml`。例如,在微服务架构下,可通过配置文件设置调用其他服务的地址(如订单服务端口8002),并利用`@Value`注解在代码中读取这些配置值。这种方式使项目更灵活,便于后续修改和维护。
45 0