实现redis延迟队列的优雅方式

小鱼儿 2024-03-26 14:19 96阅读 0赞

### 前言 ###

工作中常常会遇到这样的场景，如订单到期未支付取消，到期自动续费等，我们发现延迟队列非常适合在这样的场景中使用。常见的延迟队列的优秀实现有rabbitMQ的死信队列，RocketMQ的延迟队列等，但是了有时候项目没有特别的大，没有引入类似的消息中间件，但是了又遇到了特别适合使用延迟队列的场景，我们一般会利用已有的redis实现一个简陋的延迟队列。常见的实现方式有监听过期key，使用zset利用分值进行一个匹配，但是了这些实现或多或少有些问题，不够优雅。监听过期key是一种危险行为，一是如果过redis中key数量较大监听过期key可能导致服务负载异常，二是redis中key过期后key是惰性删除的，因此监听机制需要主动触发。利用zset分值实现呢，需要自己开发代码处理定时轮训以及key删除的逻辑，具有一定的工作量和复杂度。哪有没有一种优雅的redis延迟队列的实现呢？

Redisson是Redis服务器上的分布式可伸缩Java数据结构----驻内存数据网格(In-Memory Data Grid，IMDG)。底层使用netty框架，并提供了与java对象相对应的分布式对象、分布式集合、分布式锁和同步器、分布式服务等一系列的Redisson的分布式对象。为我们提供了许多开箱即用的功能。今天介绍Redisson实现的优雅的延迟队列。

### 使用 ###

#### 依赖配置 ####

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.3.12.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.homeey</groupId>
        <artifactId>redis-delay-queue</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>redis-delay-queue</name>
        <description>redis-delay-queue</description>
        <properties>
            <java.version>1.8</java.version>
        </properties>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-redis</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId&g