[發明專利]高速分布式股票實時行情推送系統及方法

在審

• 申請號: 201710253406.4
• 申請日: 2017-04-18
• 公開（公告）號: CN107424072A
• 公開（公告）日: 2017-12-01
• 發明（設計）人: 王安全;于家鵬
• 申請（專利權）人: 湖南福米信息科技有限責任公司
• 主分類號: G06Q40/04
• 分類號: G06Q40/04;H04L29/08
• 代理公司: 北京律智知識產權代理有限公司11438
• 代理人: 邢雪紅,王衛忠

技術領域

本公開涉及數字通信領域，具體而言，涉及一種高速分布式股票實時行情推送系統及方法。

背景技術

隨著智能操作系統廣泛應用到智能手機、平板電腦以及智能電視中，現有的股票行情數據獲取方式更多仍停留在PC(person computer個人計算機)時代，靠手動刷新頁面的方式進行拉取。也有少數軟件采用推送方式更新股票行情數據，但在面對高并發、海量終端壓力情況下，延時偏高，數據丟失問題普遍存在。

因此，設計一種新的股票實時行情推送系統及方法是目前亟待解決的技術問題。

發明內容

本公開的目的在于提供一種高速分布式股票實時行情推送系統及方法，進而至少在一定程度上克服由于相關技術的限制和缺陷而導致的一個或者多個問題。

本公開的其他特性和優點將通過下面的詳細描述變得清晰，或者部分地通過本公開的實踐而習得。

根據本公開的第一方面，提供一種高速分布式股票實時行情推送系統，其特征在于，包括：

至少一個用于接收和存儲股票實時行情數據的隊列模塊；

至少一個用于從所述隊列模塊中分揀出與終端訂閱的股票信息匹配的實時行情數據的推送模塊；

至少一個用于與終端建立連接并存儲終端訂閱的股票信息的接入模塊；以及

至少一個用于控制推送模塊與接入模塊數據流轉的分發模塊。

在本公開的一種示例性實施例中，使用隊列存儲實時行情數據。

在本公開的一種示例性實施例中，所述推送模塊不間斷循環的從隊列模塊中拉取實時行情數據。

在本公開的一種示例性實施例中，所述推送模塊與隊列模塊的數量比為N:1，其中N為大于等于1的整數。

在本公開的一種示例性實施例中，所述接入模塊與終端采用TCP長連接進行通信。

在本公開的一種示例性實施例中，所述分發模塊可以與接入模塊進行通信，獲取接入模塊所有的股票訂閱信息，并緩存在所述分發模塊內。

在本公開的一種示例性實施例中，所述推送模塊可以與所述分發模塊進行通信，獲取所有終端訂閱的股票信息集合。

在本公開的一種示例性實施例中，所述分發模塊可以與多個接入模塊建立連接。

在本公開的一種示例性實施例中，所述分發模塊與接入模塊之間、分發模塊與分發模塊之間都采用TCP長連接進行通信。

在本公開的一種示例性實施例中，所述分發模塊為多個，所述多個分發模塊兩兩之間相互連接并可以進行擴展。

根據本公開的第二方面，提供一種用于如上所述的高速分布式股票實時行情推送系統進行股票行情推送的方法，所述方法包括：

終端與所述接入模塊建立TCP長連接，并向所述接入模塊注冊訂閱股票信息；

所述分發模塊通過輪詢的方式收集所有終端訂閱的股票，并緩存在所述分發模塊內；

所述推送模塊定時從所述分發模塊獲取所有的訂閱股票集合，同時所述推送模塊不間斷的從所述隊列模塊中獲取實時行情數據；

所述推送模塊根據獲取的實時行情數據與股票訂閱集合進行匹配，將與終端訂閱的股票信息匹配的實時行情數據推送到所述分發模塊；

所述分發模塊將接收到的實時行情數據推送給其它分發模塊和所述接入模塊。

在本公開的一種示例性實施例中，根據終端的網絡狀況、所屬區域，跨機房部署所述分發模塊，在不同區域之間擴展。

在本公開的一種示例性實施例中，不同區域的所述分發模塊可以互相轉發數據。相轉發數據。

根據本公開的一些實施方式，支持千萬級終端接入，能夠極大地降低終端接入成本，在海量終端接入和高頻繁股票交易的情況下，也能夠及時推送股票行情；同時將關注相同股票的終端進行聚合，以此集合作為推送單元，大大提升股票行情的推送效率。

根據本公開的一些實施方式，分發模塊之間通過互相配置構成集群，進行數據轉發，實現無限橫向擴展。

應當理解的是，以上的一般描述和后文的細節描述僅是示例性和解釋性的，并不能限制本公開。

附圖說明

此處的附圖被并入說明書中并構成本說明書的一部分，示出了符合本公開的實施例，并與說明書一起用于解釋本公開的原理。顯而易見地，下面描述中的附圖僅僅是本公開的一些實施例，對于本領域普通技術人員來講，在不付出創造性勞動的前提下，還可以根據這些附圖獲得其他的附圖。

圖1示出本公開示例性實施例中一種高速分布式股票實時行情推送系統的結構框圖。