# [057][调度模块]分布式环境下定时任务的防重复执行方案

本文章代码: [gitee](https://gitee.com/yunjiao-source/tutorials4j) , [gitcode](https://gitcode.com/yun-jiao/tutorials4j) , [github](https://github.com/yunjiao-source/tutorials4j)

## 摘要
在集群部署中，同一个定时任务可能在多台机器上同时触发，造成资源浪费或数据错误。本文基于提供的 `AutoRenewalLockTaskRunner` 和 `FixedLeaseLockTaskRunner` 系列接口，阐述如何利用 Redis/Redisson 分布式锁包装任务执行，确保同一时刻只有一个节点执行任务。

## 1. 任务接口设计
框架定义了多个锁装饰器接口，业务实现只需继承相应接口并实现 `doRun()`：
```java
// Redis 自动续期锁
public interface AutoRenewalLockTaskRunner extends TaskRunner, Lockable {
    @Override
    default void run(Map<String, String> params) {
        RedisLockService.instance.autoRenewal()
            .doInLock(key(), () -> doRun(params));
    }
    void doRun(Map<String, String> params);
    // key() 定义锁的标识，如 "task:order:sync"
}
```
类似地，还提供了：
- `FixedLeaseLockTaskRunner`（Redis 固定租期）
- `AutoRenewalBlockLockTaskRunner`（Redisson 阻塞+自动续期）
- `FixedLeaseReentrantLockTaskRunner`（Redisson 可重入+固定租期）

## 2. 两种锁模式对比

| 模式 | 适用场景 | Redis 实现 | Redisson 实现 |
|------|----------|------------|----------------|
| **固定租期** | 任务执行时间稳定且较短 | `SET NX PX` + 不续期 | `lock(leaseTime)` |
| **自动续期** | 任务执行时间不确定或较长 | 定时任务每 5s 续期 | `lock()`（看门狗机制） |

## 3. 锁的粒度控制
`Lockable` 接口要求实现类提供 `key()` 方法，通常按任务名称或业务 ID 区分：
```java
@Override
public String key() {
    return "schedule:lock:" + getTaskName(); // 例如通过构造函数注入
}
```

## 4. 异常处理
- 若获取锁失败（如已被其他节点占用），会抛出 `LockCreateException`，任务直接跳过，不会影响下次调度。
- 可覆盖 `handleException(LockException)` 方法自定义失败处理（如记录日志、发送告警）。

## 5. 集群效果
所有节点使用相同的锁 key，第一个获得锁的节点执行，其他节点快速失败，保证任务在集群内单点运行。



在集群部署中，同一个定时任务可能在多台机器上同时触发，造成资源浪费或数据错误。本文基于提供的 AutoRenewalLockTaskRunner 和 FixedLeaseLockTaskRunner 系列接口，阐述如何利用 Redis/Redisson 分布式锁包装任务执行，确保同一时刻只有一个节点执行任务。

[057][调度模块]分布式环境下定时任务的防重复执行方案

后端

架构设计

云计算

分布式环境下定时任务防重复执行方案：利用Redis/Redisson分布式锁确保集群任务单点执行，提供自动续期和固定租期两种锁模式，支持自定义锁粒度与异常处理，避免多节点重复执行导致资源浪费或数据错误。

代码解释

Redis

文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

EdgeOne AI 安全实战专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

社区新版编辑器体验调研

[057][调度模块]分布式环境下定时任务的防重复执行方案-腾讯云开发者社区-腾讯云

[057][调度模块]分布式环境下定时任务的防重复执行方案

[057][调度模块]分布式环境下定时任务的防重复执行方案

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐