快捷導(dǎo)航

Springboot使用Redis實(shí)現(xiàn)定時(shí)任務(wù)的三種方式

更新時(shí)間：2025年06月25日 10:10:23 作者：weixin_43833540

本文介紹了三種Redis定時(shí)任務(wù)實(shí)現(xiàn)方式,鍵空間通知,有序集合輪詢,分布式鎖,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

一、基于 Redis 鍵空間通知（適合精確延時(shí)任務(wù)）

原理：利用 Redis 的鍵過期事件（EXPIRE）觸發(fā)任務(wù)執(zhí)行，通過監(jiān)聽 __keyevent@*__:expired 通道捕獲事件。
步驟：

啟用 Redis 鍵空間通知（redis.conf 或運(yùn)行時(shí)配置）：

CONFIG SET notify-keyspace-events Ex

Spring Boot 監(jiān)聽器實(shí)現(xiàn)：

@Component
public class KeyExpiredListener extends KeyExpirationEventMessageListener {
    public KeyExpiredListener(RedisMessageListenerContainer listenerContainer) {
        super(listenerContainer);
    }

    @Override
    public void onMessage(Message message, byte[] pattern) {
        String expiredKey = new String(message.getBody());
        if (expiredKey.startsWith("task:")) { // 過濾業(yè)務(wù)鍵
            System.out.println("執(zhí)行任務(wù): " + expiredKey);
            // 例如：task:123 過期時(shí)執(zhí)行訂單超時(shí)邏輯
        }
    }
}

注冊(cè)監(jiān)聽器：

@Configuration
public class RedisConfig {
    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory factory, 
                                           KeyExpiredListener listener) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(factory);
        container.addMessageListener(listener, new PatternTopic("__keyevent@*__:expired"));
        return container;
    }
}

調(diào)度任務(wù)（設(shè)置帶過期時(shí)間的鍵）：

@Service
public class TaskScheduler {
    @Autowired
    private StringRedisTemplate redisTemplate;

    public void scheduleTask(String taskId, long delaySeconds) {
        redisTemplate.opsForValue().set("task:" + taskId, "data", 
                delaySeconds, TimeUnit.SECONDS); // 鍵在 delaySeconds 秒后過期
    }
}

注意：需在 Redis 配置中開啟 notify-keyspace-events Ex。

二、基于 Redis 有序集合輪詢（適合批量定時(shí)任務(wù)）

原理：將任務(wù)執(zhí)行時(shí)間作為 ZSET 的 score，通過定時(shí)任務(wù)查詢到期的任務(wù)并執(zhí)行。
步驟：

添加任務(wù)到 ZSET：

public void addTask(String taskId, Instant executeTime) {
    stringRedisTemplate.opsForZSet().add("scheduled_tasks", taskId, 
          executeTime.getEpochSecond());
}

定時(shí)掃描并執(zhí)行任務(wù)（每分鐘輪詢）：

@Scheduled(cron = "0 * * * * *") // 每分鐘執(zhí)行
public void pollTasks() {
    long now = Instant.now().getEpochSecond();
    Set<String> tasks = stringRedisTemplate.opsForZSet()
          .rangeByScore("scheduled_tasks", 0, now); // 獲取所有到期任務(wù)

    for (String task : tasks) {
        System.out.println("執(zhí)行任務(wù): " + task);
        // 執(zhí)行后移除任務(wù)
        stringRedisTemplate.opsForZSet().remove("scheduled_tasks", task);
    }
}

優(yōu)點(diǎn)：避免鍵空間通知的丟失風(fēng)險(xiǎn)，適合任務(wù)量大的場(chǎng)景。

三、基于 Redis 分布式鎖（防集群任務(wù)重復(fù)執(zhí)行）

原理：在分布式環(huán)境中，通過 Redis 鎖確保同一時(shí)間只有一個(gè)實(shí)例執(zhí)行定時(shí)任務(wù)。
代碼示例：

@Component
public class DistributedTask {
    @Autowired
    private StringRedisTemplate redisTemplate;
    private static final String LOCK_KEY = "TASK_LOCK:ORDER_CLEAN";

    @Scheduled(cron = "0 0 3 * * ?") // 每天凌晨3點(diǎn)執(zhí)行
    public void dailyTask() {
        Boolean locked = redisTemplate.opsForValue()
                .setIfAbsent(LOCK_KEY, "locked", Duration.ofMinutes(10));
        if (Boolean.TRUE.equals(locked)) {
            try {
                cleanExpiredOrders(); // 執(zhí)行核心任務(wù)
            } finally {
                redisTemplate.delete(LOCK_KEY); // 釋放鎖（可選）
            }
        }
    }
}

關(guān)鍵點(diǎn)：

使用 setIfAbsent 原子操作獲取鎖，避免并發(fā)沖突。
鎖自動(dòng)過期防止死鎖（如任務(wù)執(zhí)行超時(shí)）。

??版本要求??：
??Spring Data Redis ≥ 2.3.0??：該版本引入了 setIfAbsent(key, value, duration) 方法，支持??原子性設(shè)置鍵值+過期時(shí)間??（對(duì)應(yīng) Redis 的 SET key value NX EX seconds 命令）

四、方案對(duì)比

方案	適用場(chǎng)景	注意事項(xiàng)
鍵空間通知	精確延時(shí)任務(wù)（如30分鐘后關(guān)單）	需配置 Redis，事件可能丟失
有序集合輪詢	批量任務(wù)、高可靠性場(chǎng)景	需自行處理任務(wù)分頁和重試
分布式鎖	集群環(huán)境防重復(fù)執(zhí)行（如日?qǐng)?bào)生成）	鎖超時(shí)時(shí)間需大于任務(wù)執(zhí)行時(shí)間

*補(bǔ)充：

關(guān)鍵業(yè)務(wù)（如支付超時(shí)）建議結(jié)合 數(shù)據(jù)庫日志+重試機(jī)制 補(bǔ)償；
高頻任務(wù)優(yōu)先選 ZSET 輪詢，避免鍵空間通知的性能瓶頸；
分布式鎖的鎖鍵需包含業(yè)務(wù)標(biāo)識(shí)（如 LOCK_KEY:業(yè)務(wù)名）。

到此這篇關(guān)于Springboot使用Redis實(shí)現(xiàn)定時(shí)任務(wù)的三種方式的文章就介紹到這了,更多相關(guān)Springboot Redis 定時(shí)任務(wù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: