MQ改造定时任务
2017-11-10 17:54:22 0 举报mq改造
作者其他创作
大纲/内容
mongo是否成功
false
步骤验证
结束
获取报告
审核不通过
redis缓存处理
找对应appname的对象类型
缓存大key:APPLICATION_MQ_ORG小key:appid_ds_appname
循环处理数据
app dubbo 传入申请单/客户信息
分配模板
mq取报告校验
放入缓存
接受数据，保存入库
mq接收消息：key/prev/next
true
定时任务，界定时间(10s)
推送App
mysql是否成功
报告处理
false抛异常
获取大key1的数量
缓存转移到mq
数量是否大于界定值（100）
状态验证
数据源mongoappName
转移到新的缓存大key2
数据源mysqlappname
保存mongo
发送下一队列
通过key获取(mongo/mysql)申请单
所有信息转移到新的缓存大key2
公共的发往下个队列及更新
是否命中黑名单
dubbo服务接口
mysql保存
数据是否已分配模板
发给下个队列
设置执行顺序
true/是否报警
mq模板分发
批量分配模板
获取缓存大key2中的所有数据
新数据进入
将大key2发送给mq
foreach
0 条评论
下一页
