事件类型白名单过滤
msg封装Event对象。通过Set集合实现白名单过滤
Redis.tryLock()实现消息幂等判断
dealWechatComponent.get(authorizerAppId)
根据原始ID获取公众号/小程序
参数:message 消息内容signatrue 签名串timeStamp 时间戳nonce 随机字符串说明: 基于SHA1算法对消息进行解密
create()
分类处理 发送Kafka消息
数据库持久化事件
deal-weixin-decrypt-server
判断公众号/小程序是否有效
send()
Kafka
消息幂等判断
deal-core2-server
参数:id: authorizerAppid 授权方appidsignature 签名串timeStamp 时间戳nonce 随机字符串content 消息内容
核心服务
参数：authorizerAppId调用数据库或缓存获取微信对象
微信解密服务
EventProcessor.process()
Redis
DB
Event&Set集合
解密
微信网关
dealCore2Component.getAppLicense(appId)
参数：appId调用核心服务获取License对象，判断公众号或小程序是否过期
保存事件
isDuplicated()
decrypt()
