2018-04-07 00:56:19 +00:00
|
|
|
@startuml
|
|
|
|
|
participant runDataRecord as run
|
|
|
|
|
participant mongoDB as db
|
|
|
|
|
participant MainEngine as me
|
|
|
|
|
participant DrEngine as dr
|
|
|
|
|
participant Queue as drq
|
|
|
|
|
participant eventEngine as ee
|
|
|
|
|
participant Queue as eeq
|
|
|
|
|
participant ibGateway as gw
|
|
|
|
|
|
|
|
|
|
activate db
|
|
|
|
|
activate run
|
|
|
|
|
'create ee
|
|
|
|
|
run->ee: new evnetEngine()
|
|
|
|
|
activate ee
|
|
|
|
|
|
2018-04-07 09:45:17 +00:00
|
|
|
|
2018-04-07 00:56:19 +00:00
|
|
|
ee->ee: __init__()
|
|
|
|
|
activate ee
|
|
|
|
|
create eeq
|
|
|
|
|
ee->eeq: Create Queue
|
|
|
|
|
activate eeq
|
|
|
|
|
ee->ee: Create Child Thread
|
|
|
|
|
deactivate ee
|
|
|
|
|
|
2018-04-07 09:45:17 +00:00
|
|
|
|
2018-04-07 00:56:19 +00:00
|
|
|
create me
|
|
|
|
|
run->me: new mainEngine(ee)
|
|
|
|
|
activate me
|
|
|
|
|
me->ee: ee.start()
|
|
|
|
|
note right
|
|
|
|
|
启动ee的子线程
|
|
|
|
|
end note
|
|
|
|
|
me->me:创建DataEngine()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
run->me: addGateway(ibGateway)
|
|
|
|
|
run->me: addApp()
|
|
|
|
|
run->ee: regiser() 注册日志处理事件
|
|
|
|
|
run->me: 连接IB网关
|
|
|
|
|
create dr
|
|
|
|
|
me->dr: new DrEngine(me,ee)
|
|
|
|
|
|
|
|
|
|
activate dr
|
|
|
|
|
|
|
|
|
|
dr->dr:loadSetting()
|
|
|
|
|
note right
|
|
|
|
|
从配置文件中加载
|
|
|
|
|
订阅设置到字典对象
|
|
|
|
|
end note
|
|
|
|
|
create drq
|
|
|
|
|
dr->drq:Create Queue
|
|
|
|
|
activate drq
|
|
|
|
|
dr->ee:register(TICK, handler)
|
|
|
|
|
deactivate ee
|
|
|
|
|
gw-->eeq: queue.put(tick/bar)
|
|
|
|
|
activate ee #red
|
|
|
|
|
loop
|
|
|
|
|
ee->eeq:queue.get()
|
|
|
|
|
eeq-->ee: Message
|
|
|
|
|
ee->ee: process(mesage)
|
|
|
|
|
end
|
|
|
|
|
ee->dr:call procecssTickEvent()
|
|
|
|
|
deactivate ee
|
|
|
|
|
activate dr #blue
|
|
|
|
|
dr->dr:OnTick()
|
|
|
|
|
activate dr
|
|
|
|
|
dr->drq: queue.put(tick)
|
|
|
|
|
deactivate dr
|
|
|
|
|
dr->dr:OnBar()
|
|
|
|
|
activate dr
|
|
|
|
|
dr->drq: queue.put(bar)
|
|
|
|
|
deactivate dr
|
|
|
|
|
deactivate dr
|
|
|
|
|
deactivate dr
|
|
|
|
|
|
|
|
|
|
dr->dr:run()
|
|
|
|
|
activate dr #blue
|
|
|
|
|
loop
|
|
|
|
|
dr->drq:queue.get()
|
|
|
|
|
drq-->dr:data
|
|
|
|
|
dr->me:insertDB(data)
|
|
|
|
|
end
|
|
|
|
|
deactivate dr
|
|
|
|
|
|
|
|
|
|
me->db: 写入mongoDB
|
|
|
|
|
|
|
|
|
|
@enduml
|
