go 有没有能持久化的分布式定时任务库？-灵析社区

package main import ( "fmt" "github.com/go-co-op/gocron" "github.com/go-redis/redis/v8" "golang.org/x/net/context" "sync" ) var ( redisClient *redis.Client scheduler *gocron.Scheduler ctx = context.Background() ) func init() { redisClient = redis.NewClient(&redis.Options{ Addr: "localhost:6379", }) scheduler = gocron.NewScheduler(time.UTC) } func main() { var wg sync.WaitGroup wg.Add(1) loadTasksFromRedis() scheduler.StartAsync() wg.Wait() } func loadTasksFromRedis() { // 从 Redis 获取所有任务 taskKeys, err := redisClient.Keys(ctx, "task:*").Result() if err != nil { fmt.Println("Error fetching tasks from Redis:", err) return } for _, taskKey := range taskKeys { taskData, err := redisClient.HGetAll(ctx, taskKey).Result() if err != nil { fmt.Println("Error fetching task data from Redis:", err) continue } createTaskFromData(taskData) } } func createTaskFromData(taskData map[string]string) { // 解析 taskData 并创建任务 // ... // 添加任务到调度器 // ... } func executeTask(taskData map[string]string) { // 尝试获取分布式锁 lock, err := redisClient.SetNX(ctx, "lock:"+taskData["id"], 1, time.Duration(taskData["lockDuration"])*time.Second).Result() if err != nil || !lock { fmt.Println("Failed to acquire lock for task:", taskData["id"]) return } // 执行任务 // ... // 释放分布式锁 redisClient.Del(ctx, "lock:"+taskData["id"]) }