Redis实现优惠券秒杀功能

import redis
import time
 
# 假设Redis已经配置并且可以连接
r = redis.Redis(host='localhost', port=6379, db=0)
 
# 优惠券秒杀功能
def seckill(user_id, coupon_id):
    # 使用Redis的原子操作来保证秒杀的原子性
    with r.pipeline() as pipe:
        # 检查是否已经抢购
        if r.sismember('used_users:{}'.format(coupon_id), user_id):
            return False
        # 设置过期时间，避免无限期的抢购
        expire_at = 60 * 60  # 秒杀活动有效时间
        current_time = time.time()
        # 检查是否超过了活动时间
        if r.zscore('coupon_times:{}'.format(coupon_id), 'remain') <= 0:
            return False
        # 开始抢购
        pipe.sadd('used_users:{}'.format(coupon_id), user_id)
        pipe.zincrby('coupon_times:{}'.format(coupon_id), '-1', 'remain')
        # 执行操作
        pipe.execute()
        # 发送优惠券
        send_coupon_to_user(user_id, coupon_id)
        return True
 
# 发送优惠券到用户，具体实现根据业务需求编写
def send_coupon_to_user(user_id, coupon_id):
    print('优惠券{}发送给用户{}'.format(coupon_id, user_id))
 
# 用户ID和优惠券ID
user_id = 'user123'
coupon_id = 'coupon456'
 
# 开始秒杀
seckill(user_id, coupon_id)

这段代码提供了一个简单的Python示例，展示了如何使用Redis来实现秒杀功能。它使用Redis的SET数据结构来追踪哪些用户已经抢购了优惠券，以及使用ZSET来跟踪剩余的优惠券数量。这个例子假设Redis服务器已经配置并且可以连接。在实际应用中，你需要根据自己的业务逻辑来发送优惠券给用户。