[發(fā)明專利]在多進(jìn)程之間共享股票數(shù)據(jù)的方法及裝置

無效

• 申請?zhí)枺?/td>: 201110363404.3
• 申請日: 2011-11-16
• 公開（公告）號(hào): CN102385526A
• 公開（公告）日: 2012-03-21
• 發(fā)明（設(shè)計(jì)）人: 周垂富;王欽才
• 申請（專利權(quán)）人: 深圳市大贏家網(wǎng)絡(luò)有限公司
• 主分類號(hào): G06F9/46
• 分類號(hào): G06F9/46;G06Q40/04
• 代理公司: 深圳市科吉華烽知識(shí)產(chǎn)權(quán)事務(wù)所 44248
• 代理人: 胡吉科;劉顯揚(yáng)

技術(shù)領(lǐng)域

本發(fā)明涉及數(shù)據(jù)處理，更具體地說，涉及一種在多進(jìn)程之間共享股票數(shù)據(jù)的方法及裝置。

背景技術(shù)

???證券市場的股票數(shù)據(jù)是一種數(shù)據(jù)量龐大，且不斷實(shí)時(shí)更新的數(shù)據(jù)。在股票操作電子化的今天，需要將龐大的股票數(shù)據(jù)近于實(shí)時(shí)地、不斷地由證券公司的數(shù)據(jù)處理中心（通常是服務(wù)器）傳輸?shù)礁饔脩舳恕＿@些用戶端可能在證券公司內(nèi)部，也可能通過網(wǎng)絡(luò)與證券公司的服務(wù)器連接。因此，其傳輸速度非常關(guān)鍵。隨著服務(wù)器機(jī)器性能的不斷增長，現(xiàn)在單臺(tái)服務(wù)器的CPU內(nèi)核都超過一個(gè)，4核，8核，16核等等。一臺(tái)服務(wù)器勢必支持多個(gè)服務(wù)進(jìn)程（這些服務(wù)進(jìn)程可能是用戶端提出的數(shù)據(jù)請求），而如何在單臺(tái)服務(wù)器中搬遷大量實(shí)時(shí)數(shù)據(jù)，提高單臺(tái)服務(wù)器的容量，降低CPU負(fù)載，是目前股票服務(wù)器追求的目標(biāo)。目前市面上的股票服務(wù)器普遍采用Window平臺(tái)下開發(fā)的服務(wù)器，單臺(tái)服務(wù)器的多個(gè)服務(wù)進(jìn)程通過socket將數(shù)據(jù)打包傳輸達(dá)到數(shù)據(jù)共享目的。在上述現(xiàn)有技術(shù)中，增加一個(gè)服務(wù)進(jìn)程時(shí)需要增加一個(gè)數(shù)據(jù)拷貝，占用大量CPU時(shí)間進(jìn)行搬遷；原始數(shù)據(jù)的存儲(chǔ)不能達(dá)到快速數(shù)據(jù)分發(fā)的目的；耗費(fèi)的CPU資源和內(nèi)存資源勢必影響到單臺(tái)服務(wù)器的負(fù)載量，增加企業(yè)的運(yùn)營成本。

發(fā)明內(nèi)容

本發(fā)明要解決的技術(shù)問題在于，針對現(xiàn)有技術(shù)的上述共享數(shù)據(jù)占用時(shí)間長、耗費(fèi)大量的CPU資源的缺陷，提供一種占用時(shí)間較短，耗費(fèi)CPU資源較小的在多進(jìn)程之間共享股票數(shù)據(jù)的方法及裝置。

本發(fā)明解決其技術(shù)問題所采用的技術(shù)方案是：構(gòu)造一種在多進(jìn)程之間共享股票數(shù)據(jù)的方法，包括如下步驟：

????A）在共享存儲(chǔ)區(qū)域建立每個(gè)股票的檢索列表，并分別將所述檢索列表中每一項(xiàng)與所述共享存儲(chǔ)區(qū)域中的一段存儲(chǔ)區(qū)域?qū)?yīng)；

????B）將接收到的股票數(shù)據(jù)經(jīng)過處理后分別存入其檢索列表項(xiàng)對應(yīng)的存儲(chǔ)區(qū)域；

????C）通過消息管道通知需要所述已更新數(shù)據(jù)的進(jìn)程；

????D）各進(jìn)程在所述共享存儲(chǔ)區(qū)域中取得股票數(shù)據(jù)。

在本發(fā)明所述的在多進(jìn)程之間共享股票數(shù)據(jù)的方法中，所述步驟B）中進(jìn)一步包括如下步驟：

????B1）取得一個(gè)股票數(shù)據(jù)；

????B2）將當(dāng)前取得的股票數(shù)據(jù)與同一數(shù)據(jù)的先前取得的值比較，得到其增量值；

????B3）存儲(chǔ)所述得到的增量值到所述共享存儲(chǔ)區(qū)域中與該股票數(shù)據(jù)對應(yīng)的指定存儲(chǔ)區(qū)域中。

在本發(fā)明所述的在多進(jìn)程之間共享股票數(shù)據(jù)的方法中，所述步驟A）中進(jìn)一步包括如下步驟：

????A1）形成股票檢索列表；

????A2）對所述檢索列表中的每一項(xiàng)設(shè)定一指向所述共享存儲(chǔ)區(qū)域中不同存儲(chǔ)段的地址指針；

????A3）將所述地址指針指向的存儲(chǔ)段初始化。

在本發(fā)明所述的在多進(jìn)程之間共享股票數(shù)據(jù)的方法中，所述步驟A1）中進(jìn)一步包括如下步驟：

????A11）取得每個(gè)股票的名稱代碼；

????A12）將所述取得的名稱代碼使用長度固定而內(nèi)容不同的字符串替代，得到所述股票的檢索代碼；

????A13）排列所述檢索代碼得到檢索列表。

在本發(fā)明所述的在多進(jìn)程之間共享股票數(shù)據(jù)的方法中，所述步驟D）中進(jìn)一步包括如下步驟：各進(jìn)程分別按照所述股票的檢索代碼和取得的地址指針在所述地址指針指向的區(qū)域取得其所需數(shù)據(jù)。?

本發(fā)明還涉及一種實(shí)現(xiàn)上述在多進(jìn)程之間共享股票數(shù)據(jù)方法的裝置，包括：

???共享存儲(chǔ)區(qū)建立單元：用于在共享存儲(chǔ)區(qū)域建立每個(gè)股票的檢索列表，并分別將所述檢索列表中每一項(xiàng)與所述共享存儲(chǔ)區(qū)域中的一段存儲(chǔ)區(qū)域?qū)?yīng)；

????股票數(shù)據(jù)存儲(chǔ)單元：用于將接收到的股票數(shù)據(jù)經(jīng)過處理后分別存入其檢索列表項(xiàng)對應(yīng)的存儲(chǔ)區(qū)域；

????數(shù)據(jù)通知單元：用于通過消息管道通知需要所述已更新數(shù)據(jù)的進(jìn)程；

????數(shù)據(jù)排列單元：用于按照所述股票的檢索代碼和取得的增量值次序排列各進(jìn)程需要數(shù)據(jù)。

在本發(fā)明所述的裝置中，所述股票數(shù)據(jù)存儲(chǔ)單元進(jìn)一步包括：

????股票數(shù)據(jù)取得模塊：用于取得一個(gè)股票數(shù)據(jù)；

????增量值取得模塊：用于將當(dāng)前取得的股票數(shù)據(jù)與同一數(shù)據(jù)的先前取得的值比較，得到其增量值；

????增量值存儲(chǔ)模塊：用于存儲(chǔ)所述得到的增量值到所述共享存儲(chǔ)區(qū)域中與該股票數(shù)據(jù)對應(yīng)的指定存儲(chǔ)區(qū)域中。

在本發(fā)明所述的裝置中，所述共享存儲(chǔ)區(qū)取得單元進(jìn)一步包括：

???檢索列表形成模塊：用于形成股票檢索列表；