搜索平台流程图
2022-03-23 11:09:04 5 举报111
作者其他创作
大纲/内容
之前只有一个 ->此处可优化 消息是有优先级的 目前现状把cdp的标签信息挪到了低优先级队列 这两个topic 消息格式与消费逻辑相同
重试达到最大重试次数的消息
db
。。。。。。。其他业务消息
转发消息
异常且小于重试次数
转发消息队列-低优先级
消费逻辑是单条消费的->是否可以根据场景分组 批量查询 批量回源 批量写入
储值变更消息
查询配置 查询整个doc 回源 组装doc 写入es
是否异常
格式化 转发
业务消息
消费转发消息
积分变更消息
记录重试次数
目前认为达到最大重试次数的消息是逻辑上有问题 并未有扫表任务去扫表重试 ->此处应该是需要对达到最大重试次数的消息进行处理
这里需要获取各种配置信息去格式化消息 粗略看有四次db交互 并且未使用缓存
转发消息队列-高优先级
0 条评论
下一页
