Redis 在 Agent 工作流中的 5 种经典模式

模式一：API 响应缓存

减少重复 API 调用，降低延迟和费用。

# 设置缓存，30 分钟过期
redis SET api:weather:beijing '{"temp":22}' EX 1800

# 读取缓存
redis GET api:weather:beijing

要点：

• 过期时间根据数据更新频率设定
• 缓存 key 包含查询参数，避免命中错误数据
• 缓存 miss 时回源查询并重新写入

模式二：速率限制

防止 Agent 过快调用外部 API。

# 滑动窗口限流：每分钟最多 60 次
redis INCR rate:api:openai:minute
redis EXPIRE rate:api:openai:minute 60

要点：

• 用 INCR + EXPIRE 实现简单计数器
• 超过阈值时 Agent 自动等待
• 不同 API 设置不同限额

模式三：分布式锁

多 Agent 实例同时运行时防止重复操作。

# 获取锁，10 秒自动释放
redis SET lock:deploy:prod unique-value NX EX 10

# 释放锁（用 Lua 脚本保证原子性）
if redis.call('get', KEYS[1]) == ARGV[1] then
  return redis.call('del', KEYS[1])
else
  return 0
end

要点：

• value 必须唯一，防止误解锁
• 锁必须有超时，避免死锁
• 释放锁用 Lua 脚本保证原子性

模式四：实时排行榜

适合任务优先级、用户活跃度等排序场景。

# 添加分数
redis ZADD leaderboard:weekly 1500 "user:alice"
redis ZADD leaderboard:weekly 1200 "user:bob"

# 查询 Top 10
redis ZREVRANGE leaderboard:weekly 0 9 WITHSCORES

要点：

• 用 ZADD 更新分数，自动排序
• ZREVRANGE 从高到低
• 支持按时间维度建多个排行榜

模式五：消息队列

Agent 间的异步通信。

# 生产者：推入任务
redis LPUSH queue:tasks '{"type":"scrape","url":"example.com"}'

# 消费者：取出任务
redis RPOP queue:tasks

要点：

• LPUSH + RPOP 实现先进先出
• 处理失败的消息需要重入队列
• 用 BRPOP 实现阻塞等待，减少轮询

总结

模式	数据结构	典型场景
缓存	String + TTL	API 响应缓存
限流	String + INCR	API 调用频率控制
分布式锁	String + NX	防止重复操作
排行榜	Sorted Set	优先级排序
消息队列	List	异步任务分发