Kubernetes多实例部署下如何确保定时函数仅执行一次？

你的问题核心是多实例独立执行定时逻辑导致重复触发，以下是几种可行的解决思路：

方案一：分布式锁（通用推荐） #

在每个实例执行DoSomething前，先尝试获取一个全局唯一的分布式锁，只有成功拿到锁的实例才能执行任务，其他实例直接跳过本轮执行。

以Redis实现分布式锁为例（StackExchange.Redis客户端）：

async Task Run(CancellationToken cancel)
{
    // 假设已初始化Redis连接
    var redis = ConnectionMultiplexer.Connect("your-redis-host:6379");
    var db = redis.GetDatabase();
    var lockKey = "global:do-something:lock";
    // 锁过期时间设为15分钟（需大于DoSomething的最大执行时长，避免死锁）
    var lockExpiry = TimeSpan.FromMinutes(15);

    while (!cancel.IsCancellationRequested)
    {
        // 尝试获取锁，仅当锁不存在时设置成功
        var lockAcquired = await db.StringSetAsync(lockKey, Environment.MachineName, lockExpiry, When.NotExists);
        
        if (lockAcquired)
        {
            try
            {
                await DoSomething(cancel);
            }
            finally
            {
                // 仅释放当前实例持有的锁，避免误删其他实例的锁
                var currentLockValue = await db.StringGetAsync(lockKey);
                if (currentLockValue == Environment.MachineName)
                {
                    await db.KeyDeleteAsync(lockKey);
                }
            }
        }

        await Task.Delay(TimeSpan.FromMinutes(10), cancel);
    }
}

注意：锁的过期时间必须大于任务的最长执行时间，防止任务执行中锁过期导致其他实例重复执行。如果DoSomething执行时间可能超过15分钟，可考虑加锁续期逻辑。

方案二：拆分定时任务为独立部署 #

将定时任务逻辑从主应用中拆分出来，单独创建一个Deployment，设置replicaCount: 1，专门负责执行这个每10分钟一次的任务。主应用的副本数可以保持原有配置。

示例Kubernetes Deployment配置：

apiVersion: apps/v1
kind: Deployment
metadata:
  name: do-something-scheduler
spec:
  replicas: 1
  selector:
    matchLabels:
      app: do-something-scheduler
  template:
    metadata:
      labels:
        app: do-something-scheduler
    spec:
      containers:
      - name: scheduler
        image: your-app-image:latest
        command: ["dotnet", "YourApp.dll", "--run-scheduler"]
        # 其他配置：环境变量、资源限制等

主应用启动时不执行定时逻辑，仅处理业务请求；独立的调度实例只运行Run方法。这种方案无需引入分布式锁，逻辑简单，适合任务与主业务解耦的场景。

方案三：使用Kubernetes CronJob #

直接利用Kubernetes的CronJob资源来调度任务，替代应用内部的定时逻辑。CronJob默认会确保同一时间只有一个Pod执行任务（通过concurrencyPolicy: Forbid配置）。

示例CronJob配置：

apiVersion: batch/v1
kind: CronJob
metadata:
  name: do-something-cron
spec:
  schedule: "*/10 * * * *" # 每10分钟执行一次
  concurrencyPolicy: Forbid # 禁止并发执行，若上一次任务未完成则跳过本次
  jobTemplate:
    spec:
      template:
        spec:
          containers:
          - name: do-something
            image: your-app-image:latest
            command: ["dotnet", "YourApp.dll", "--execute-do-something"]
          restartPolicy: OnFailure

这种方案完全依赖K8s的调度能力，应用只需实现单次执行DoSomething的逻辑即可，无需处理循环和延迟，适合任务为短周期、无状态的场景。

内容的提问来源于stack exchange，提问作者ca9163d9