2. 撮合完成后,写数据到kafka
通过http请求获取撮合结果进行补单
Kafka
发送到MQ
t_order
t_exchange_match_result
1. 保存资金 持仓数据到apo redis
API
Rabbit MQ
Mysql
match_result kafka
更新redis MaxFid
推动到客户端
Order
6.从队列 获取落库数据
Notification
Redis
是
主动消费mr
5.1 清算发送消息到MQ
Sync-storm
快照记录
Inter
t_tmp_order_check
exchange-core
7.update DB
撮合提供的sdk
fallback kafka
4.清算根据mr完成清算,更新redis异步落库队列
Clear-storm
match-l2
消费清算数据
snapshot
5. 清算更新redis异步落库队列
3. insert DB
获取待复核的数据,进行复核
match-noti
发送最新价到mq
1.1 调用sdk
persister
保存快照记录
是否降级
Task