分词设计
2022-12-04 13:48:39 2 举报
分词设计
作者其他创作
大纲/内容
状态为ing的分词，调用es的分词接口，拿到当前分词器切出来的分词
异步
启用禁用模块
返回状态为启用和同步状态为ing的禁用分词给es
释放互斥锁
拿到id集合的尾部key
IK分词器回调
启用操作
更新同步状态为end，状态变为相反值
1.id缓存不存在这个id2.数据库中的状态为禁用
success
同步时间是否有改变
读取所有同步状态为ing的分词信息
N
是否拿到锁
1.id缓存不存在这个id2.数据库中的状态为启用
1.同步状态为ing2.写入缓存最新的同步时间3.写入缓存此次同步的id集合
同步
当前新增分词渠道(页面新增)是否存在
Y
删除id集合缓存
释放锁
放入kafka的延时队列
数据库分词库
新增关键词（分词）
禁用操作
新增分词，注明分词来源，设置为禁用
通过update_by_query接口重组es中的索引
代码发布延时任务
加入互斥锁，此时不允许修改id集合缓存
0 条评论
回复 删除
下一页
