如何利用setnx函数实现分布式锁

利用setnx函数实现分布式锁的基本思路是：

使用setnx命令尝试在redis中设置一个指定的key，如果该key不存在则返回1，表示成功获取锁；如果该key已经存在则返回0，表示获取锁失败。

在获取锁成功后，设置一个过期时间，确保锁在一定时间内自动释放，避免锁被长时间占用造成死锁。

在释放锁时，使用del命令删除该key，确保锁释放成功。

以下是一个简单的示例代码来实现分布式锁：

import redisimport time# 连接redisredis_client = redis.Redis(host='localhost', port=6379, db=0)# 获取分布式锁def acquire_lock(lock_key, expire_time=10):    lock = redis_client.setnx(lock_key, time.time() + expire_time)    if lock:        return True    current_time = time.time()    # 判断锁是否过期    if current_time > float(redis_client.get(lock_key) or 0):        # 如果锁已经过期，则重新设置锁        new_expire_time = current_time + expire_time        old_expire_time = float(redis_client.getset(lock_key, new_expire_time) or 0)        if old_expire_time == current_time:            return True    return False# 释放分布式锁def release_lock(lock_key):    current_time = time.time()    if current_time < float(redis_client.get(lock_key) or 0):        redis_client.delete(lock_key)        return True    return False# 测试分布式锁lock_key = "distributed_lock"if acquire_lock(lock_key):    try:        # 业务逻辑处理        print("获取锁成功，执行业务逻辑")    finally:        release_lock(lock_key)else:    print("获取锁失败")

在上面的示例中，首先通过acquire_lock函数尝试获取分布式锁，成功获取锁后执行业务逻辑，最后通过release_lock函数释放锁。通过这种方式可以确保在分布式环境下对资源的互斥访问。