TOUCHANCE
Search
K
Comment on page

ZMQService 登入、連線

建立 ZMQ 系統架構

建立 QuoteZMQ 與 TradeZMQ 登入接口
g_TradeZMQ = tcore_zmq("ZMQ","8076c9867a372d2a9a814ae710c256e2")
g_QuoteZMQ = tcore_zmq("ZMQ","8076c9867a372d2a9a814ae710c256e2")
帶入登入參數
QuoteThread= g_QuoteZMQ.quote_connect("XXXXX")
XXXXX→連接埠數據
登入報價連線,可從QuoteZMQService的log中抓取到
在log中搜尋RepPort可以找到
TradeThread= g_TradeZMQ.trade_connect("XXXXX")
XXXXX→連接埠數據
登入交易連線,可從TradeZMQService的log中抓取到
在log中搜尋RepPort可以找到
登入成功,在 'Success' 欄位回應 'OK'

啟動 ZMQ 主推連線

TradeLane、QuoteLane 登入成功後會回傳對應的值 後續指令都要用 SessionKey 認證
QuoteThread = threading.Thread(target=quote_sub_th, args=(ZMQsystem, QuoteLane,))
建立行情主推子線程
QuoteThread.start()
啟動行情主推子線程
TradeThread = threading.Thread(target=trade_sub_th, args=(ZMQsystem, TradeLane["SubPort"],))
建立交易主推子線程
TradeThread.start()
啟動交易主推子線程

維持主推連線的PING與PONG

連線成功後,系統每隔約20秒會發送PING訊號確認使用者連線狀態 需每60秒至少進行回復一次(啟動連線時,計算為第一次回應)
系統發出確認訊號
QuotePongCheck = ZMQsystem.QuotePong(QuoteKey)
回應報價伺服器的ping功能
TradePongCheck = ZMQsystem.TradePong(TradeKey)
回應交易伺服器的ping功能