核心代码实现：指数退避重试

避免硬编码延时，建议封装重试逻辑。以下 Python 示例实现了遇到 45009 错误码时的指数退避，最大重试 5 次，初始等待 1 秒。

import time
import requests
import random

def send_wecom_message(webhook_url, payload, max_retries=5):
    retry_count = 0
    base_delay = 1  # 初始等待秒数
    
    while retry_count <= max_retries:
        try:
            response = requests.post(webhook_url, json=payload, timeout=5)
            data = response.json()
            
            if data.get("errcode") == 0:
                return True
            
            if data.get("errcode") == 45009:
                retry_count += 1
                if retry_count > max_retries:
                    print("超过最大重试次数，停止发送")
                    return False
                
                # 指数退避 + 随机抖动，避免惊群效应
                delay = (base_delay * (2 ** (retry_count - 1))) + random.uniform(0, 1)
                print(f"触发频率限制，第 {retry_count} 次重试，等待 {delay:.2f} 秒")
                time.sleep(delay)
            else:
                # 其他错误不重试，直接记录
                print(f"发送失败，错误码：{data.get('errcode')}")
                return False
                
        except Exception as e:
            print(f"请求异常：{e}")
            retry_count += 1
            if retry_count > max_retries:
                return False
            time.sleep(base_delay)
    
    return False

多实例场景：Redis 队列与锁

当多个服务实例共用同一个 webhook 地址时，本地重试无法控制总频率。需将消息推入 Redis 队列，由单一消费者或带分布式锁的消费者发送。

方案一：集中队列消费

所有实例只负责生产消息到 Redis List，独立部署一个消费者服务负责拉取发送。

# 消费者示例逻辑
while True:
    # 阻塞式拉取，控制拉取频率
    message = redis.blpop('wecom_queue', timeout=1) 
    if message:
        send_wecom_message(webhook_url, message)
        # 可根据发送结果动态调整拉取速度
        time.sleep(0.5) 

方案二：分布式锁控制

若必须多实例直接发送，需在发送前获取 Redis 锁，确保同一时刻只有一个实例在调用接口。

lock_key = "wecom_rate_limit_lock"
if redis.set(lock_key, "1", nx=True, ex=2):
    try:
        send_wecom_message(webhook_url, payload)
    finally:
        # 锁到期自动释放，或手动删除
        pass
else:
    # 获取锁失败，将消息重新入队或丢弃
    redis.lpush('wecom_queue', payload)

验证与监控方法

1. 日志 grep 统计：定期统计日志中 45009 错误码的数量，优化后应趋近于 0。

grep "errcode.*45009" app.log | wc -l

2. 消息到达率比对：对比业务发送日志与企业微信群实际收到消息的数量，偏差应在重试容忍范围内。

3. 动态阈值调整：由于官方未公开具体 QPS 数值，建议在配置中保留速率上限参数。若监控发现 45009 频繁出现，动态调低发送速率配置。

常见风险与排查

• 封禁类型混淆：频率限制（45009）通常暂时性；若返回 45015 或机器人完全无响应，可能是内容违规导致永久禁用，此时调整速率无效。
• 重试风暴：遇到频率限制时无限重试会导致账号风险升高，必须设置最大重试次数（建议 3-5 次），超过后告警人工介入。
• 惊群效应：多实例同时重试会导致瞬间流量峰值，代码中需加入随机抖动（Jitter）。
• 内容风控：确保消息不包含营销敏感词、短链接或频繁重复的相同内容，这与频率限制不同但表现类似。

参考来源

• 企业微信官方文档，群机器人接收消息，https://work.weixin.qq.com/api/doc/90000/90136/91770