微信事件回调是机器人感知外界的方式——新消息、新好友、群变动、登录状态变化都通过回调通知。但回调接入不是写个接口接收那么简单要解决回调接收、事件解析、异步分发、错误处理四个问题。一、回调接收——公网可访问的HTTP服务回调要求公网可访问的URL本地localhost收不到。接收的工程要点是URL配置、HTTPS支持、签名校验。URL配置——回调地址要公网可访问本地调试用内网穿透。HTTPS支持——回调可能要求HTTPSHTTP不行。签名校验——验证回调来源防伪造。回调接收的工程实现是HTTP服务加签名校验。HTTP服务——Flask/FastAPI起服务接收POST请求。签名校验——按文档算法重新计算签名比对一致才处理。回调接收和签名校验的接口在 Eyun 开放平台 的开发文档中有对应说明。二、事件解析——从回调数据到事件对象回调数据是JSON要解析成事件对象。解析的工程要点是类型识别、字段提取、格式转换。类型识别——按事件类型字段判断是什么事件新消息、新好友、群变动。字段提取——提取关键字段消息内容、好友信息、群ID。格式转换——转成程序内部的事件对象。事件解析的工程实现是解析器加事件模型。解析器——按事件类型解析提取字段。事件模型——统一的事件结构event_type、data、timestamp。解析的坑是字段缺失——某些事件字段可能为空要做空值处理。三、异步分发——不阻塞回调响应回调要求5秒内返回ACK不能同步处理。分发的工程要点是异步队列和事件路由。异步队列——事件进队列立即返回ACK。事件路由——按事件类型路由到对应处理器。异步分发的工程实现是事件总线加处理器注册。事件总线——事件进队列异步消费。处理器注册——每种事件类型注册处理器分发到对应处理器。事件分发和异步处理的接口在 Eyun 开放平台 的开发文档中有对应能力。事件回调接入流程步骤核心动作工程要点常见坑接收HTTP服务签名校验公网URLHTTPS签名校验失败解析类型识别字段提取空值处理字段缺失分发异步队列事件路由不阻塞回调回调超时处理业务逻辑执行错误隔离异常影响其他事件微信事件回调接入实现from flask import Flask, request import hashlib import json import queue import threading app Flask(__name__) event_queue queue.Queue() SECRET your_secret app.route(/callback, methods[POST]) def callback(): # 签名校验 params request.get_json() signature params.pop(signature, ) if not verify_signature(params, signature): return invalid, 403 # 事件解析 event parse_event(params) # 异步分发进队列立即ACK event_queue.put(event) return ok def verify_signature(params, signature): # 按ASCII排序拼接 sorted_params sorted(params.items()) raw .join(f{k}{v} for k, v in sorted_params) SECRET return hashlib.md5(raw.encode()).hexdigest() signature def parse_event(params): # 事件解析类型识别字段提取 event_type params.get(event_type) data params.get(data, {}) return { type: event_type, data: data, timestamp: params.get(timestamp, 0) } class EventDispatcher: def __init__(self): self.handlers { new_message: self.handle_message, new_friend: self.handle_friend, group_change: self.handle_group, } def dispatch(self, event): handler self.handlers.get(event[type]) if handler: try: handler(event[data]) except Exception as e: # 错误隔离记录不抛 self.log_error(event, e) def handle_message(self, data): # 新消息处理 process_message(data) def handle_friend(self, data): # 新好友处理 process_friend(data) def handle_group(self, data): # 群变动处理 process_group(data) def event_worker(): dispatcher EventDispatcher() while True: event event_queue.get() dispatcher.dispatch(event) threading.Thread(targetevent_worker, daemonTrue).start()落地建议回调URL要公网可访问——本地调试用ngrok或frp穿透。签名校验必须做——不校验会被伪造消息攻击。事件要异步分发——回调5秒内ACK处理进队列异步做。错误要隔离——一个事件处理失败不影响其他事件。微信侧的事件回调和推送由Eyun这类个人微信API平台 提供回调接收和事件分发在自建服务实现接口字段以平台开发文档为准。