个人微信接入业务系统不是简单把微信消息转给系统处理。业务系统有自己的接口规范、数据格式、处理流程微信消息要适配才能对接。接入的核心是协议转换、数据映射、状态同步、异常处理四个环节。四个环节做好微信和业务系统像同一个系统一样工作。一、协议转换——微信消息和业务系统接口对齐微信消息是JSON格式业务系统可能是REST API、RPC、消息队列。协议转换是把微信消息格式转成业务系统能接收的格式。REST API——组装HTTP请求微信消息字段映射到API参数。RPC——按接口定义组装请求对象。消息队列——消息体按业务系统schema序列化。协议转换的工程实现是适配器模式。每种业务系统协议对应一个适配器——REST适配器、RPC适配器、MQ适配器。适配器统一接口微信消息进来按业务系统类型路由到对应适配器。适配的价值是解耦——业务系统协议变了只改适配器微信侧不动。二、数据映射——微信字段和业务字段对应微信消息字段和业务系统字段不一致。微信的wxid对应业务系统的user_id微信的content对应业务系统的message_body微信的timestamp对应业务系统的create_time。数据映射是字段对应关系配置转换时按映射规则转换。数据映射的工程实现是映射配置转换引擎。映射配置——JSON或YAML定义字段对应关系。转换引擎——按配置执行字段转换支持类型转换字符串转数字、时间戳转日期。映射的价值是灵活配置——业务字段变了改配置不改代码。三、状态同步与异常处理——业务处理结果回传微信业务系统处理完要回传结果——成功返回数据失败返回错误。状态同步是把业务处理结果同步回微信。同步的工程要点是异步回调和超时处理。异步回调——业务处理完主动推送结果到微信。超时处理——业务处理超时微信侧不能一直等要超时降级。异常处理是业务系统调用失败怎么办。失败分类——网络超时、业务错误、系统异常。处理策略——网络超时重试业务错误返回错误信息系统异常告警人工。业务系统接入对照环节核心动作工程要点价值协议转换适配器模式REST/RPC/MQ适配解耦数据映射字段对应转换映射配置引擎灵活配置状态同步异步回调回传超时处理结果闭环异常处理失败分类处理重试/告警稳定可用业务系统接入实现class BusinessSystemAdapter: def __init__(self): self.adapters { rest: RestAdapter(), rpc: RpcAdapter(), mq: MqAdapter(), } self.mapping FieldMapping() # 字段映射配置 def on_wechat_message(self, raw): # 数据映射微信字段→业务字段 biz_data self.mapping.to_business(raw) # 协议转换按业务系统类型路由 adapter self.adapters.get(raw.biz_type) try: result adapter.call(biz_data) # 状态同步结果回传微信 return self.to_wechat(raw.wxid, result) except TimeoutError: return self.timeout_fallback(raw) except BizError as e: return self.biz_error(raw, e) def to_business(self, raw): # 字段映射wxid→user_id等 return { user_id: raw.wxid, message_body: raw.content, create_time: self.to_datetime(raw.timestamp), } def timeout_fallback(self, raw): # 超时降级回复处理中 return self.send_wechat(raw.wxid, 处理中请稍后查询结果)落地建议协议转换从REST适配做起——REST最常见跑通了再加RPC和MQ。数据映射配置化——字段对应关系写配置业务字段变了改配置不改代码。状态同步用异步回调——业务处理完主动推结果微信侧不用轮询。异常处理分三类——网络超时重试业务错误返回错误系统异常告警。微信侧的消息收发和协议转换由Eyun这类个人微信API平台 提供业务系统对接和状态同步在自建服务实现接口字段以平台开发文档为准。
