单独调发送接口、单独收回调都不难。难的是两边一起跑起来之后发送要限流、接收要去重、回执和回调还要能对上。这篇讲收发协同会遇到的三个工程问题。一、发送限流与接收去重得各管一头发送侧有频率限制短时间发太多会被限所以发送要排队、按固定间隔出队。接收侧则相反——消息可能被重复推送必须按消息 ID 去重。这两件事是独立的发送限流管的是出的速度接收去重管的是进的重复。别把它们混进一个逻辑里分开处理反而更清晰。发送接口的间隔要求见Eyun 开发文档。二、回执与回调把一条消息追到底发送成功拿到回执里面有消息 ID对方有动作后回调过来带的是关联 ID。把两个 ID 记在同一条记录里才能回答这条消息到底成没成、对方看没看。很多项目只记了发送成功回调来了没关联最后统计怎么都对不上字段对照见Eyun 开发文档。三、并发发送的顺序问题同一个用户连发多条时如果并发发送到达顺序可能乱。需要按会话串行——同一用户的任务进同一个队列保证先后顺序。不同用户之间可以并发彼此不影响。按用户分区是常见的折中做法。收发协同问题对照问题归属做法后果发送限流出方向队列固定间隔超频被限接收去重入方向按消息 ID 去重重复处理回执回调关联追踪同记录记两个 ID统计对不上并发顺序顺序按用户串行消息乱序收发协同实现import queue import threading import time class OutboxDispatcher: def __init__(self, sender, interval3.0, workers4): self.sender sender self.interval interval # 出方向发送间隔 self.queues {} # user_id - 独立队列 for _ in range(workers): threading.Thread(targetself._loop, daemonTrue).start() def enqueue(self, user_id, payload): # 按用户分区同一用户串行顺序不乱 q self.queues.setdefault(user_id, queue.Queue()) q.put(payload) def _loop(self): while True: for user_id, q in list(self.queues.items()): try: payload q.get_nowait() except queue.Empty: continue self.sender(payload) time.sleep(self.interval) # 固定间隔防超频 class Inbox: def __init__(self): self.seen set() def accept(self, event): # 入方向按消息 ID 去重与发送限流互不干扰 mid event.get(msg_id) if mid in self.seen: return None self.seen.add(mid) return event落地建议发送用队列加固定间隔别裸调接口否则高峰必被限。接收按消息 ID 去重重复推送直接跳过。回执的消息 ID 和回调的关联 ID 记在同一条记录里统计才说得清。同一用户的发送按队列串行不同用户可并发。微信侧的消息收发接口由Eyun这类个人微信API平台 提供限流、去重与顺序控制在自建服务实现具体字段以Eyun 平台为准。