分析系统流程
2019-04-01 11:06:53 0 举报
登录查看完整内容
分析系统流程
作者其他创作
大纲/内容
msg json解析成数组
定时启动分析器多个分析器分开出发
AES IP msg
msg aes 解密成json
判断是否是密文
都有效
启动业务分析器(有多个)
循环处理mgs数组
解密,注意ip的处理。
放弃处理此条数据
数据收集器
休息3秒,开始下一次轮询
签名是否正确mqtt_topic是否有效
参数完整性校验
失败
mqtt_topicmsgdevice_idsign 是否存在
订阅mq队列长轮询模式
参数有效性校验
结束本次运行,写日志
msg数组编码成json
3秒内无数据
发送mq队列
参数都有
400输出错误
结束
异常处理写日志,并发送通知
数组置入ip
解析成功
否
判断msg数组是否是有效数组
分析器
监听所有异常
200 成功
写入日志库(总表和按天分表)
urldecodedecrypt_data
发送运行通知异常重启需要人工查询原因
订阅确认回调(确认操作应该放到业务分析后面,避免重复消费)
400 失败
组装特定格式的字符串,加入ip属性
将msg json解析成数组
是
循环取出数据
解密成功
检测是否正在运行
是数组
msg 数组有效性验证
在运行
0 条评论
回复 删除
下一页