增量
2024-01-14 11:23:54 0 举报增量
作者其他创作
大纲/内容
是否锁成功
单据变更Kafka
时序系统
将变更信息放入Set去重
增量线程
遍历租户
十五分钟执行一次
以Size-->0为条件进行循环RPop
是
获取下一个租户
LPush对应租户Redis List
获取租户Redis List Size
否
租户增量锁释放
查询哪些时序依赖了这些变更单据
提交offset
消费者线程
线程异常
单据时序化
获取所有租户Id
数据源系统
观察者
抢占租户增量锁
重启线程
接收单据变更消息
0 条评论
下一页
