[發明專利]一種多隊列的自動售檢票數據處理方法

有效

• 申請號: 201310128727.3
• 申請日: 2013-04-15
• 公開（公告）號: CN103218254A
• 公開（公告）日: 2013-07-24
• 發明（設計）人: 王子龍;陳朝暉;張少文
• 申請（專利權）人: 廣州新科佳都科技有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 暫無信息
• 代理人: 暫無信息

技術領域

本發明涉及一種分布式系統中服務器的數據處理方法，特別是涉及一種自動售檢票系統中的多隊列自動售檢票數據處理方法。

背景技術

在地鐵車站的自動售檢票系統中，設備和車站計算機組成一個封閉的分布式系統，所有設備把產生的自動售檢票數據通過網絡隨時傳送到車站計算機進行實時處理，并及時反饋給車站操作人員，完成信息共享和監控。自動售檢票系統數據處理的效率對車站正常、高效運轉至關重要。

隨著地鐵業務發展，傳統的自動售檢票數據處理方法已無法滿足靈活、大量的數據處理要求。其原因在于：首先，地鐵線路中，各個站點的規模不一致，導致每個站點的車站計算機處理的數據量并不相同；其次，隨著地鐵業務的不斷改進，業務數據類型不斷變化，設備產生的數據量也在不斷增長。如通過增加計算機數量應對數據量變化，那么硬件投入成本和針對多臺計算機的軟件開發設計成本都比較高，而且，計算機硬件性能更新和提升較快，使得后期硬件升級成本較高。故，在原設計思路下，傳統的自動售票數據處理方法已無法充分調動和使用現有計算機硬件資源，給硬件資源和售票系統的高效使用帶來不利影響，并造成較大的資源浪費。

如何使現有自動售檢票系統形成高效、低成本、易伸縮的運行狀態，提高數據處理過程，就成為本發明想要解決的問題。

發明內容

鑒于上述現有技術的不足，本發明旨在提供一種多隊列的自動售檢票數據處理方法，為計算機設備提供軟件層面的低成本擴展方案，在確保數據處理效率的基礎上，通過配置計算實現應對自動售檢票系統數據量不斷變化的現象，以滿足自動售檢票車站的運營、管理需求。

本發明是通過以下技術方案實現的：

一種多隊列的自動售檢票數據處理方法，其特征在于，具體步驟包括：

步驟一、在計算機設備數據處理過程中首先建立：一級隊列和分發線程池，以及二級隊列和與二級隊列對應的業務處理線程池。

步驟二、利用所述一級隊列接收前端車站設備的實時數據包，同時，一級隊列還提供阻塞機制使用計算機設備的CPU，具體過程為：如所述一級隊列中沒有數據，所述分發線程池中的線程在獲取數據時會阻塞，直到獲取數據后才繼續執行；如所述一級隊列中數據包數量達到上限后，將不再接收數據包。

步驟三、通過所述分發線程池從所述一級隊列獲取數據，解析數據包并判斷類型后放入所述二級隊列。

步驟四、所述二級隊列從所述分發線程池接收符合預設類型的數據包，同時，二級隊列還提供阻塞機制使用計算機設備的CPU，具體過程為：如所述二級隊列中沒有數據，對應的業務處理線程池中的線程在獲取數據時會阻塞，直到獲取數據后才繼續執行；如所述二級隊列中數據包數量達到上限后，分發線程池在存入數據時會發送阻塞，直到等待存入成功后才繼續執行。

步驟五、所述業務處理線程池從對應的所述二級隊列獲取的數據包進行業務處理，完成數據處理過程。

若數據包要求返回，則對業務處理完成的數據組裝返回的數據包，并通過網絡通信送回。

所述一級隊列和分發線程池的數量各為一個，分發線程池的線程以并發或并行方式執行。

所述二級隊列的數量為一個或多個；所述業務處理線程池的數量與所述二級隊列數量相同并一一對應，相應的業務處理線程池只負責處理一個對應的二級隊列中的數據；所述業務處理線程池的線程以并發或并行方式執行。

所述一級隊列的容量和二級隊列的容量分別從相應的計算機設備內存容量和預期數據包處理量計算得出，公式如下：

其中，N為二級隊列的個數，DT₁...DT_n為每個隊列每秒預期處理的數據條數，PM為預期每條數據的大小，TM為計算機設備內存大小，FQ為一級隊列分配大小，SQ_i為第i個二級隊列的分配大小。

所述分發線程池中線程數量和所述業務處理線程池中線程數量分別從計算機設備的CPU數量和預期數據包處理效率計算得出，公式如下：

其中N為二級隊列的個數，DT₁...DT_n為每個隊列每秒預期處理的數據條數，UT為計算機設備中CPU總數，FT為分發線程池分配的線程數量，ST_i為第i個二級隊列業務處理線程池中線程分配數量。

所述分發線程池中的線程和所述業務處理線程池中的線程，如在單個CPU的計算機設備中，線程以并發方式執行；如在多個CPU的計算機設備中，線程以并行或并發方式執行。

所述計算機設備包括個人計算機、服務器或其它網絡設備。