如何在Redis键过期时触发命令？实现worker自动回队需求

可以实现你的需求，但Redis本身无法直接在键过期时自动执行推回队列的命令，需要结合额外机制，下面提供两种可行方案：

方案1：键空间通知 + 外部监听服务 #

利用Redis的键空间通知功能监听键过期事件，再通过外部程序触发推回队列的操作：

1. 开启键空间通知
   执行以下命令临时开启（要永久生效需修改redis.conf中的notify-keyspace-events配置为Ex）：

   CONFIG SET notify-keyspace-events Ex
   

   说明：E表示监听键事件，x表示监听过期事件。

2. 同步保存worker值映射
   注意：键过期时会被Redis自动删除，无法直接获取对应值，因此设置临时worker键时，需同步将键与worker值存入哈希表：

   # 设置临时worker键，过期时间100秒
   SET 132303:worker worker_value EX 100
   # 同步存入哈希表保存映射关系
   HSET worker_temp_mapping 132303:worker worker_value
   

3. 编写监听程序
   用任意语言编写轻量程序订阅过期事件频道，示例（Python）：

   import redis
   
   r = redis.Redis(host='localhost', port=6379, db=0)
   pubsub = r.pubsub()
   # 订阅db0的过期事件频道（db编号根据实际修改）
   pubsub.subscribe('__keyevent@0__:expired')
   
   for message in pubsub.listen():
       if message['type'] == 'message':
           expired_key = message['data'].decode('utf-8')
           # 判断是否为worker临时键
           if expired_key.endswith(':worker'):
               worker_value = r.hget('worker_temp_mapping', expired_key)
               if worker_value:
                   # 推回可用队列（根据你的队列类型选择LPUSH/RPUSH）
                   r.lpush('available_workers:queue', worker_value)
                   # 删除哈希表中的冗余映射
                   r.hdel('worker_temp_mapping', expired_key)
   

方案2：Sorted Set 实现延迟队列（更可靠） #

放弃依赖键过期事件，改用Sorted Set存储需延迟恢复的worker，通过定时任务扫描到期条目：

1. 添加延迟恢复的worker
   当worker暂时耗尽时，将其存入Sorted Set，score设置为到期的时间戳（当前时间+100秒）：

   ZADD worker_delay_queue <当前时间戳+100> worker_value
   

2. 定时扫描并恢复
   编写Lua脚本保证原子性处理，避免重复操作：

   local now = tonumber(ARGV[1])
   -- 取出所有到期的worker
   local workers = redis.call('ZRANGEBYSCORE', 'worker_delay_queue', 0, now)
   if #workers > 0 then
       -- 推回可用队列
       redis.call('LPUSH', 'available_workers:queue', unpack(workers))
       -- 删除已处理的条目
       redis.call('ZREMRANGEBYSCORE', 'worker_delay_queue', 0, now)
   end
   return #workers
   

   定时调用该脚本（比如每隔1秒），可通过Python定时任务、crontab或Redis的定时任务工具实现。

方案对比 #

• 方案1：实时性高，但依赖外部监听服务，且Redis键空间通知为尽力送达机制，存在少量丢失风险，适合对实时性要求高的场景。
• 方案2：可靠性更强，即使Redis重启也不会丢失数据，但实时性取决于扫描间隔，适合对数据一致性要求高的场景。

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