Comment on page
ZMQService 登入、連線
建立 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'
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()
啟動交易主推子線程
連線成功後，系統每隔約20秒會發送PING訊號確認使用者連線狀態
需每60秒至少進行回復一次(啟動連線時，計算為第一次回應)
系統發出確認訊號
QuotePongCheck = ZMQsystem.QuotePong(QuoteKey)
回應報價伺服器的ping功能
TradePongCheck = ZMQsystem.TradePong(TradeKey)
回應交易伺服器的ping功能
Last modified 2yr ago