使用redisSion分布式锁控制定时任务在多台服务器上执行具体实现代码

下面是一个使用 Redis 实现分布式锁的示例代码，可以用于控制定时任务在多台服务器上执行。

import redis

class RedisLock:
    def __init__(self, redis_conn, lock_name, expire_time=60):
        self.redis_conn = redis_conn
        self.lock_name = lock_name
        self.expire_time = expire_time

    def acquire(self):
        # 尝试获取锁，如果获取成功就返回 True，否则返回 False
        return self.redis_conn.set(self.lock_name, 1, ex=self.expire_time, nx=True)

    def release(self):
        # 释放锁
        self.redis_conn.delete(self.lock_name)

在使用该分布式锁的时候，可以这样写：

import redis
import time

redis_conn = redis.Redis(host='localhost', port=6379)

def do_task():
    # 获取分布式锁
    lock = RedisLock(redis_conn, 'task_lock')
    if lock.acquire():
        try:
            # 执行定时任务
            print('开始执行定时任务...')
            time.sleep(10)
            print('定时任务执行完成。')
        finally:
            # 释放分布式锁
            lock.release()
    else:
        print('其他服务器正在执行该定时任务，本服务器不进行执行。')

当多台服务器同时执行 `do_task` 函数时，只有一个服务器能够成功获取分布式锁，并执行定时任务。其他服务器会发现获取锁失败，不会执行定时任务。这样就能够保证定时任务只会在一个服务器上执行。