调度框架
2021-12-09 09:47:09 4 举报调度框架
作者其他创作
大纲/内容
tb0
优惠券扣减 没走完
worker 挂
库存扣减 失败
库存扣减 cancel
服务端申请
activity txid，stateaction1 stateaction2 1action3
insert commandB 延迟执行，或者立即执行
if（deal()）{mq()}
调用端结算页
createnode
b端dbsku秒杀
execute任务分配splituserid
订单提交 confirm
execute
task work-tab
tb1
commandA
主 时间点querybyTime任务分配
分布式框架server
mqservermsg
订单提交 cancel
发起者
insert commandE 延迟执行，或者立即执行
worklist
sdk
拦截器
tb4
insert seq 唯一索引dealbizdb
insert commandF 延迟执行，或者立即执行
任务调度1min
mysqlrr 幂等
即将开始秒杀的还有10min开始
tccXTSDTSseata
workerjob
管控平台
db
worker缓存
tb2
幂等orderId_sku_num_statuslockquery statusif（）update
贷款申请
订单提交 try 走完
zk
参与者
注册服务端表给库存任务 8 表给优惠券扣减 12 贷款申请 表 4refjar
worker容灾db容灾均匀积压高吞吐率
优惠券扣减 confirm
多长时间执行5min
服务端审核
job
taskid，tasktype，status， time，exectuecountb，c，d
worker
query(){querybiz()}send
优惠券扣减 cancel
execute任务分配
库存扣减confirm
if（query（））{}}
halfmq()if(deal()){commit;}else{}
insert commandA
集群版的调度框架taobquartzs
结算页提交模块订单提交rpc库存扣减rpc优惠券rpccommit；
tb3
1：同步（失败，放db）2：半同步模式，直接同步调用，并且异步放入db3：异步模式
主splituserid
redis
0 条评论
下一页
