[發明專利]一種基于行情數據的延時統計裝置及方法

在審

• 申請號: 202011168653.2
• 申請日: 2020-10-28
• 公開（公告）號: CN112333043A
• 公開（公告）日: 2021-02-05
• 發明（設計）人: 楊杰;陳勇銓
• 申請（專利權）人: 上海英方軟件股份有限公司
• 主分類號: H04L12/26
• 分類號: H04L12/26;H04L12/24
• 代理公司: 上海國智知識產權代理事務所(普通合伙) 31274
• 代理人: 潘建玲

本發明公開了一種基于行情數據的延時統計裝置及方法，所述裝置包括：接收模塊，創建多個連接通道分別連接多路行情數據源，分別接收多路行情數據源的行情數據，并對接收的行情數據包進行拆分，同時獲取本地當前系統時間，將本地當前系統時間存入拆分后的行情數據包包尾，組成新的行情數據包，存入數據解析隊列；解析模塊，用于遍歷并解析數據解析隊列中各數據源對應的行情數據包，計算行情數據包中的行情市場時間與本地時間的差值作為相對延時，并統計當前數據包的相關信息加入統計隊列；統計模塊，用于對各數據源對應的統計隊列中的數據進行匹配，計算相對延時的差值作為通道間延時，并將計算的延時根據行情市場時間的順序制作圖表展示。

技術領域

本發明涉及計算機數據傳輸及分析技術領域，特別是涉及一種基于行情數據的延時統計裝置及方法。

背景技術

隨著信息技術快速發展，各行各業的信息化建設要求逐步提高，因而數據分析及傳輸領域的實時性及性能要求也越來越高。

以行情數據為例，隨著各交易所行情提速，原文件行情逐步切換到流式行情方式，行情數據不落地轉發使用，減少行情讀寫磁盤的耗時，極大地提高了傳輸及使用效率，使得證券基金等公司及終端使用者對行情的使用變得更加實時高效。

基于流行情數據的普及推廣，各證券和基金公司對于行情的提速也越來越重視，同時，流行情的傳輸效率也與各種網絡環境、硬件條件、轉發分流器效率、應用系統部署情況等有很大的關聯影響。然而，在現有技術中，流行情數據的延時很難做到精確統計，因而不同行情源和不同行情轉發分流器的選擇都比較困難。

基于行情提速和線路擇優的迫切需求，一種不同線路或不同分流器的行情高精度延時對比的方法也越來越重要。因此，實有必要提出一種技術手段，以使得券商或者應用系統供應商可以通過該技術手段，對比不同行情源或線路的延時情況，選擇行情傳輸的最優方案，從而達到線路上行情極速傳輸的目的，對信息化建設提供更高效的保證。

發明內容

為克服上述現有技術存在的不足，本發明之目的在于提供一種基于行情數據的延時統計裝置及方法，以自動化收集生產環境中不同行情源的實時行情數據，對比計算高精度延時予以輸出并以圖表直觀展示，為行情技術運維部提供可靠的數據支撐，從而能及時選擇或切換最優行情傳輸線路，保證行情應用系統的高實時性，為行情的提速提供可靠的保障。

為達上述目的，本發明提出一種基于行情數據的延時統計裝置，包括：

接收模塊，創建多個連接通道分別連接多路行情數據源或分流器，分別接收多路行情數據源或分流器的行情數據，并對接收的行情數據進行拆分獲取行情數據包，同時獲取本地當前系統時間，將本地當前系統時間存入拆分后的行情數據包包尾，組成新的行情數據包，存入數據解析隊列；

解析模塊，用于遍歷并解析所述數據解析隊列中各個數據源對應的行情數據包，計算行情數據包中的行情市場時間與本地時間的差值作為相對延時，并統計當前數據包的相關信息加入統計隊列；

統計模塊，用于對各數據源對應的統計隊列中的數據進行匹配，計算相對延時的差值作為通道間延時，并將計算的延時根據行情市場時間的順序制作圖表展示。

優選地，所述接收模塊進一步包括：

連接通道創建單元，用于通過TCP協議向不同的上級數據源或分流器發起連接請求，并在與各上級數據源或分流器建立連接后，通過對應的連接通道接收各上級數據源或分流器的行情數據；

系統時間添加單元，用于將通過各連接通道接收的行情數據進行拆包，將本地系統時間計入拆分后的行情數據包的包尾，組成新的行情數據包存入數據解析隊列中。

優選地，所述系統時間添加單元對不同數據源對應的不同連接通道的行情數據包進行拆分，并獲取精確到微秒的本地當前系統時間，將該本地當前系統時間存入拆分后的行情數據包包尾，組成新的行情數據包，存入數據解析隊列。