企业微信应用的 Token 缓存策略与分布式锁高可用设计

在分布式微服务架构下，多个后端实例同时去请求企业微信的access_token不仅会造成网络资源浪费，极易触发“频繁获取”的限流策略（ErrCode 40164 等）。

分布式缓存与锁架构

1. Redis 集中缓存：Token 全局只存一份在 Redis 中，Key 为qiwe:token:{agent_id}。

2. 分布式锁防击穿：当缓存失效瞬间，利用 Redlock 或 RedisSETNX机制只允许一个线程回源请求企业微信 API，其余线程阻塞等待或返回旧值。

Python 伪代码实现

import redis import time import requests redis_client = redis.StrictRedis(host='localhost', port=6379, db=0) def get_access_token_with_lock(corpid, secret, agent_id): cache_key = f"qiwe:token:{agent_id}" lock_key = f"qiwe:lock:{agent_id}" # 1. 尝试从缓存读取 token = redis_client.get(cache_key) if token: return token.decode('utf-8') # 2. 获取分布式锁 lock_acquired = redis_client.set(lock_key, "locked", nx=True, ex=10) if not lock_acquired: # 未抢到锁的线程等待片刻后重试读取缓存 time.sleep(0.5) return get_access_token_with_lock(corpid, secret, agent_id) try: # 3. 再次检查缓存（双重检查锁） token = redis_client.get(cache_key) if token: return token.decode('utf-8') # 4. 请求远程接口 url = f"https://api.qiweapi.com/cgi-bin/gettoken?corpid={corpid}&corpsecret={secret}" res = requests.get(url).json() new_token = res.get("access_token") expires_in = res.get("expires_in", 7200) # 5. 写入缓存（提前 200 秒过期以确保安全） redis_client.setex(cache_key, expires_in - 200, new_token) return new_token finally: # 6. 释放锁 redis_client.delete(lock_key)

这套加锁与缓存策略是保障企业微信后端服务稳定运行的工业级标准方案。