面向高并發(fā)實(shí)時(shí)交易數(shù)據(jù)的分布式快速匯總統(tǒng)計(jì)

王穎卓 郭開衛(wèi) 王亞雄

摘 ?要：本案涉及計(jì)算機(jī)數(shù)據(jù)統(tǒng)計(jì)領(lǐng)域的一種數(shù)據(jù)統(tǒng)計(jì)方法和裝置，具體來說，首先根據(jù)預(yù)先設(shè)定的過濾規(guī)則，對(duì)原始交易數(shù)據(jù)進(jìn)行過濾處理，得到第一交易數(shù)據(jù);然后根據(jù)第一交易數(shù)據(jù)中的關(guān)鍵字信息，確定第一交易數(shù)據(jù)所對(duì)應(yīng)的計(jì)算服務(wù)器;最后將第一交易數(shù)據(jù)發(fā)送至計(jì)算服務(wù)器，以使計(jì)算服務(wù)器將根據(jù)預(yù)先設(shè)定的統(tǒng)計(jì)維度對(duì)第一交易數(shù)據(jù)進(jìn)行統(tǒng)計(jì)得到的第二交易數(shù)據(jù)發(fā)送給查詢服務(wù)器使用，關(guān)鍵字相同的第一交易數(shù)據(jù)將會(huì)發(fā)送至同一計(jì)算服務(wù)器，而計(jì)算服務(wù)器可將第二交易數(shù)據(jù)給查詢服務(wù)器使用。因此，可通過增加計(jì)算服務(wù)器的數(shù)量的方式水平擴(kuò)展計(jì)算統(tǒng)計(jì)的能力，從而提高將數(shù)據(jù)寫入數(shù)據(jù)庫的速度，進(jìn)而提升數(shù)據(jù)的查詢效率。

關(guān)鍵詞：交易數(shù)據(jù);實(shí)時(shí)查詢;計(jì)算服務(wù)器

中圖分類號(hào)：TP333 ? ? 文獻(xiàn)標(biāo)識(shí)碼：A 文章編號(hào)：2096-4706（2019）12-0023-03

Abstract：This case relates to a data statistics method and device in the field of computer data statistics，including：firstly filtering the original transaction data according to a preset filtering rule to obtain the first transaction data，and then according to the first transaction data Key information，determining a computing server corresponding to the first transaction data，and finally sending the first transaction data to the computing server，so that the computing server will perform the second transaction obtained by counting the first transaction data according to a preset statistical dimension. The data is sent to the query server for use. The first transaction data with the same keyword will be sent to the same computing server，and the computing server can use the second transaction data for the query server. Therefore，the ability to calculate statistics can be horizontally expanded by increasing the number of computing servers，thereby increasing the speed at which data is written into the database，thereby improving data query efficiency.

Keywords：transaction data;real-time query;computing server

0 ?引 ?言

目前行業(yè)內(nèi)普遍采用的實(shí)時(shí)統(tǒng)計(jì)方法是接收實(shí)時(shí)交易數(shù)據(jù)，以事務(wù)方式計(jì)算后寫入數(shù)據(jù)庫供用戶查詢，這種方法的時(shí)效性較低，而且支持大并發(fā)量的成本要求非常高。

1 ?技術(shù)背景

數(shù)據(jù)統(tǒng)計(jì)在各行各業(yè)中都有應(yīng)用，尤其是在銀行業(yè)務(wù)中使用較為頻繁。目前，普遍采用的數(shù)據(jù)統(tǒng)計(jì)方法是在接收交易數(shù)據(jù)并針對(duì)接收到的交易數(shù)據(jù)進(jìn)行計(jì)算后，再以事務(wù)的方式將計(jì)算后的交易數(shù)據(jù)寫入數(shù)據(jù)庫，以供用戶查詢。然而，通過事務(wù)的方式將交易數(shù)據(jù)寫入數(shù)據(jù)庫的時(shí)效性較低，并且由于通過事務(wù)的方式將交易數(shù)據(jù)寫入數(shù)據(jù)庫的速度取決于服務(wù)器的CPU（Central Processing Unit，中央處理器）、內(nèi)存以及數(shù)據(jù)庫的寫入性能，難以水平擴(kuò)展，從而無法提高將交易數(shù)據(jù)寫入數(shù)據(jù)庫的速度，降低了數(shù)據(jù)的查詢效率。

2 ?實(shí)現(xiàn)方式

2.1 ?數(shù)據(jù)統(tǒng)計(jì)流程

數(shù)據(jù)統(tǒng)計(jì)通過以下3步完成：（1）根據(jù)預(yù)先設(shè)定的過濾規(guī)則，對(duì)原始交易數(shù)據(jù)進(jìn)行過濾處理，得到第一交易數(shù)據(jù)，其中，所述過濾規(guī)則包括所述原始交易數(shù)據(jù)中的至少一個(gè)字段信息。（2）根據(jù)第一交易數(shù)據(jù)中的關(guān)鍵字信息，確定第一交易數(shù)據(jù)所對(duì)應(yīng)的計(jì)算服務(wù)器。（3）將第一交易數(shù)據(jù)發(fā)送至所述計(jì)算服務(wù)器，以使所述計(jì)算服務(wù)器能夠?qū)⒏鶕?jù)預(yù)先設(shè)定的統(tǒng)計(jì)維度對(duì)第一交易數(shù)據(jù)進(jìn)行統(tǒng)計(jì)得到的第二交易數(shù)據(jù)發(fā)送給查詢服務(wù)器使用。

過濾規(guī)則是由各計(jì)算服務(wù)器的統(tǒng)計(jì)維度確定的。

上述步驟（2）中，可預(yù)先將所有的計(jì)算服務(wù)器的標(biāo)識(shí)信息放置在一致性哈希算法的閉合環(huán)中，根據(jù)第一交易數(shù)據(jù)中的關(guān)鍵字信息，確定數(shù)據(jù)所對(duì)應(yīng)的計(jì)算服務(wù)器，可通過將第一交易數(shù)據(jù)中的關(guān)鍵字信息作為一致性哈希算法的輸入?yún)?shù)進(jìn)行運(yùn)算后，得到對(duì)應(yīng)的計(jì)算服務(wù)器的標(biāo)識(shí)信息，然后確定第一交易數(shù)據(jù)所對(duì)應(yīng)的計(jì)算服務(wù)器。

因此，具有相同關(guān)鍵字的交易數(shù)據(jù)將會(huì)被路由到標(biāo)識(shí)信息相同的計(jì)算服務(wù)器中，即具有相同關(guān)鍵字的交易數(shù)據(jù)將會(huì)被路由到同一計(jì)算服務(wù)器中。

上述步驟（3）中，可通過RPC（Remote Procedure Call Protocol，遠(yuǎn)程過程調(diào)用協(xié)議）的方式將第一交易數(shù)據(jù)發(fā)送至計(jì)算服務(wù)器。

需要說明的是，如果第一交易數(shù)據(jù)中包含多個(gè)關(guān)鍵字，則第一交易數(shù)據(jù)可根據(jù)關(guān)鍵字的不同被路由到多個(gè)計(jì)算服務(wù)器。為了減少網(wǎng)絡(luò)傳輸次數(shù)，可在計(jì)算服務(wù)器中設(shè)置計(jì)時(shí)器，用于統(tǒng)計(jì)一段時(shí)間內(nèi)接收的交易數(shù)據(jù)。例如，當(dāng)計(jì)算服務(wù)器中的計(jì)時(shí)器設(shè)置的計(jì)時(shí)時(shí)間為1分鐘時(shí)，表示計(jì)算服務(wù)器在接收的交易數(shù)據(jù)持續(xù)的時(shí)間為1分鐘，然后計(jì)算服務(wù)器根據(jù)自身的統(tǒng)計(jì)維度對(duì)1分鐘之內(nèi)接收的交易數(shù)據(jù)進(jìn)行統(tǒng)計(jì)處理。

在計(jì)算服務(wù)器中設(shè)置計(jì)時(shí)器后，為了提升系統(tǒng)處理能力，還可在計(jì)算服務(wù)器中設(shè)置緩沖隊(duì)列。

2.2 ?計(jì)算服務(wù)處理

當(dāng)在計(jì)算服務(wù)器中設(shè)置了計(jì)時(shí)器和緩沖隊(duì)列后，計(jì)算服務(wù)器的處理流程如下：（1）接收有效的第一交易數(shù)據(jù)。（2）判斷計(jì)時(shí)器是否已歸零，若是，則轉(zhuǎn)至步驟（3）;否則，轉(zhuǎn)至步驟（6）。（3）讀取自身的統(tǒng)計(jì)規(guī)則。（4）根據(jù)讀取的自身的統(tǒng)計(jì)規(guī)則，對(duì)緩沖隊(duì)列中的第一交易數(shù)據(jù)進(jìn)行統(tǒng)計(jì)處理，得到第二交易數(shù)據(jù)。（5）將第二交易數(shù)據(jù)發(fā)送給查詢服務(wù)器使用。（6）將接收的有效的第一交易數(shù)據(jù)存儲(chǔ)至緩沖隊(duì)列中。

此外，為了減少網(wǎng)絡(luò)傳輸次數(shù)，還可通過在計(jì)算服務(wù)器中設(shè)置閾值的方式控制第一交易數(shù)據(jù)的數(shù)量。例如，當(dāng)計(jì)算服務(wù)器中的閾值設(shè)置為50時(shí)，表示計(jì)算服務(wù)器在接收到50條第一交易數(shù)據(jù)后，可根據(jù)自身的統(tǒng)計(jì)維度對(duì)上述接收到的50條交易數(shù)據(jù)進(jìn)行統(tǒng)計(jì)處理。

當(dāng)計(jì)算服務(wù)器中設(shè)置了閾值和緩沖隊(duì)列后，計(jì)算服務(wù)器的處理流程如下：（1）接收有效的第一交易數(shù)據(jù)。（2）判斷接收的有效的第一交易數(shù)據(jù)的條數(shù)是否達(dá)到閾值，若是，則轉(zhuǎn)至步驟（3）;否則，轉(zhuǎn)至步驟（6）。（3）讀取自身的統(tǒng)計(jì)規(guī)則。（4）根據(jù)讀取的自身的統(tǒng)計(jì)規(guī)則，對(duì)緩沖隊(duì)列中的第一交易數(shù)據(jù)進(jìn)行統(tǒng)計(jì)處理，得到第二交易數(shù)據(jù)。（5）將第二交易數(shù)據(jù)發(fā)送給查詢服務(wù)器使用。（6）將接收的有效的第一交易數(shù)據(jù)存儲(chǔ)至緩沖隊(duì)列中。

需要說明的是，無論是通過在計(jì)算服務(wù)器中設(shè)置計(jì)時(shí)器的方式，還是通過在計(jì)算服務(wù)器中設(shè)置閾值的方式，當(dāng)計(jì)算服務(wù)器空閑時(shí)，均可以清空自身的緩存，從而確保計(jì)算服務(wù)器的處理實(shí)時(shí)性。

2.3 ?計(jì)算服務(wù)檢測

為了確保計(jì)算服務(wù)器的處理實(shí)時(shí)性，還可通過心跳機(jī)制對(duì)計(jì)算服務(wù)器進(jìn)行檢測，在檢測到計(jì)算服務(wù)器發(fā)生故障時(shí)，將發(fā)生故障的計(jì)算服務(wù)器的標(biāo)識(shí)信息從一致性哈希算法的閉合環(huán)中刪除。通過心跳機(jī)制，對(duì)計(jì)算服務(wù)器進(jìn)行檢測的具體流程如下：（1）定期接收計(jì)算服務(wù)器的存活消息。（2）判斷在預(yù)設(shè)的時(shí)間段內(nèi)，是否接收到計(jì)算服務(wù)器發(fā)送的存活消息，若是，則轉(zhuǎn)至步驟（3）;否則，轉(zhuǎn)至步驟（4）。（3）判定所述計(jì)算服務(wù)器處于正常狀態(tài)。（4）判定所述計(jì)算服務(wù)器發(fā)生故障。（5）將發(fā)生故障的計(jì)算服務(wù)器的標(biāo)識(shí)信息從一致性哈希算法的閉合環(huán)中刪除。

本發(fā)明實(shí)施例中的查詢服務(wù)器還可通過Redis集群的方式，從而提供高效的讀寫服務(wù)，即查詢服務(wù)器可通過Redis集群的方式對(duì)計(jì)算服務(wù)器提供高效的寫服務(wù)，同時(shí)，查詢服務(wù)器還可通過Redis集群的方式提供高效的查詢服務(wù)。查詢服務(wù)器在收集所有計(jì)算服務(wù)器發(fā)送的第二交易數(shù)據(jù)后，可將第二交易數(shù)據(jù)寫入Redis集群中，因此，在使用查詢服務(wù)器查詢交易數(shù)據(jù)時(shí)，可從查詢服務(wù)器管理的Redis集群中查詢出統(tǒng)計(jì)結(jié)果數(shù)據(jù)。為了避免在查詢服務(wù)器發(fā)生故障時(shí)，影響到數(shù)據(jù)的查詢，還可設(shè)置一個(gè)備用的查詢服務(wù)器。當(dāng)設(shè)置備用的查詢服務(wù)器以后，計(jì)算服務(wù)器除了將第二交易數(shù)據(jù)發(fā)送給主查詢服務(wù)器外，還需要將第二交易數(shù)據(jù)同時(shí)發(fā)送給備用服務(wù)器。

本案例中的過濾規(guī)則以及計(jì)算服務(wù)器中的統(tǒng)計(jì)維度，可基于用戶的需求進(jìn)行更改。當(dāng)存在多個(gè)過濾規(guī)則以及對(duì)應(yīng)的計(jì)算服務(wù)器中的統(tǒng)計(jì)維度時(shí)，還可采用訂閱的方式供用戶選擇合適的過濾規(guī)則和統(tǒng)計(jì)維度，從而統(tǒng)計(jì)出用戶需要的統(tǒng)計(jì)結(jié)果數(shù)據(jù)。

下面通過一個(gè)具體的例子，對(duì)上述方法流程進(jìn)行詳細(xì)的解釋說明。在該例子中，假設(shè)存在兩個(gè)計(jì)算服務(wù)器，分別為計(jì)算服務(wù)器1和計(jì)算服務(wù)器2，并假設(shè)計(jì)算服務(wù)器1的標(biāo)識(shí)信息為“1”，計(jì)算服務(wù)器2的標(biāo)識(shí)信息為“2”，并且預(yù)先將計(jì)算服務(wù)器1的標(biāo)識(shí)信息“1”和計(jì)算服務(wù)器2的標(biāo)識(shí)信息“2”設(shè)置在一致性哈希算法的閉合環(huán)中，進(jìn)一步假設(shè)計(jì)算服務(wù)器1和計(jì)算服務(wù)器2對(duì)接收的交易數(shù)據(jù)統(tǒng)計(jì)的時(shí)間窗為3分鐘。

繼續(xù)假設(shè)，計(jì)算服務(wù)器1的統(tǒng)計(jì)維度X包括字段“商戶”“金額”“日期”，計(jì)算服務(wù)器2的統(tǒng)計(jì)維度Y包括“卡號(hào)”“商戶”“金額”，則根據(jù)計(jì)算服務(wù)器1的統(tǒng)計(jì)維度X和計(jì)算服務(wù)器2的統(tǒng)計(jì)維度Y，可確定過濾規(guī)則Z包括的字段有“商戶”“金額”“日期”“卡號(hào)”，并假設(shè)存在兩個(gè)關(guān)鍵字，分別為“東方航空”和“123”。

繼續(xù)假設(shè)用戶A使用卡號(hào)123的信用卡于2019年6月1日10：50分在東方航空上購買了一張機(jī)票，則原始交易信息為“用戶：A，卡號(hào)：123，商戶：東方航空，金額：500元，購買渠道：東方航空APP，日期：2019年6月1日”。

過濾規(guī)則Z包括“商戶”“金額”“日期”“卡號(hào)”，交易數(shù)據(jù)在使用過濾規(guī)則Z后，得到的交易數(shù)據(jù)為“卡號(hào)：123，商戶：東方航空，金額：500元，日期：2019年6月1日”。

由于字段“東方航空”為關(guān)鍵字，因此可將關(guān)鍵字商戶字段“東方航空”作為輸入?yún)?shù)采用一致性哈希算法進(jìn)行運(yùn)算，并假設(shè)將關(guān)鍵字商戶字段“東方航空”作為輸入?yún)?shù)采用一致性哈希算法進(jìn)行運(yùn)算后，得到的計(jì)算服務(wù)器標(biāo)識(shí)信息為“1”，即用戶A的交易數(shù)據(jù)對(duì)應(yīng)的計(jì)算服務(wù)器為計(jì)算服務(wù)器1，因此，可將用戶A的交易數(shù)據(jù)路由到計(jì)算服務(wù)器1中。

基于用戶A的交易數(shù)據(jù)，由于字段“123”為關(guān)鍵字，因此可將關(guān)鍵字卡號(hào)字段“123”作為輸入?yún)?shù)采用一致性哈希算法進(jìn)行運(yùn)算，并假設(shè)將關(guān)鍵字卡號(hào)字段“123”作為輸入?yún)?shù)采用一致性哈希算法進(jìn)行運(yùn)算后，得到的計(jì)算服務(wù)器標(biāo)識(shí)信息為“2”，即用戶A的交易數(shù)據(jù)對(duì)應(yīng)的計(jì)算服務(wù)器為計(jì)算服務(wù)器2，因此，也可將用戶A的交易數(shù)據(jù)路由到計(jì)算服務(wù)器2中。

繼續(xù)假設(shè)用戶A使用卡號(hào)123的信用卡于2019年6月1日10：51分在星巴克購買了一杯咖啡，則原始交易信息為“用戶：A，卡號(hào)：123，商戶：星巴克，金額：25元，購買渠道：POS機(jī)刷卡，日期：2019年6月1日”。

過濾規(guī)則Z包括“商戶”“金額”“日期”“卡號(hào)”，交易數(shù)據(jù)在使用過濾規(guī)則Z后，得到的交易數(shù)據(jù)為“卡號(hào)：123，商戶：星巴克，金額：25元，日期：2019年6月1日”。

基于用戶A的交易數(shù)據(jù)，由于字段“123”為關(guān)鍵字，因此將關(guān)鍵字卡號(hào)字段“123”作為輸入?yún)?shù)采用一致性哈希算法進(jìn)行運(yùn)算后，得到的計(jì)算服務(wù)器標(biāo)識(shí)信息為“2”，即用戶A的交易數(shù)據(jù)對(duì)應(yīng)的計(jì)算服務(wù)器為計(jì)算服務(wù)器2，因此，也可將用戶A的交易數(shù)據(jù)路由到計(jì)算服務(wù)器2中。

繼續(xù)假設(shè)用戶B使用卡號(hào)456的信用卡于2019年6月1日10：52分在東方航空上購買了一張機(jī)票，則原始交易信息為“用戶：B，卡號(hào)：456，商戶：東方航空，金額：1000元，購買渠道：東方航空APP，日期：2019年6月1日”。

過濾規(guī)則Z包括“商戶”“金額”“日期”“卡號(hào)”，交易數(shù)據(jù)在使用過濾規(guī)則Z后，得到的交易數(shù)據(jù)為“卡號(hào)：456，商戶：東方航空，金額：1000元，日期：2019年6月1日”。

基于用戶B的交易數(shù)據(jù)，由于字段“東方航空”為關(guān)鍵字，因此將關(guān)鍵字商戶字段“東方航空”作為輸入?yún)?shù)采用一致性哈希算法進(jìn)行運(yùn)算后，得到的計(jì)算服務(wù)器標(biāo)識(shí)信息為“1”，因此，也可將用戶B的交易數(shù)據(jù)路由到計(jì)算服務(wù)器1中。

至此，路由至計(jì)算服務(wù)器1根據(jù)統(tǒng)計(jì)維度X對(duì)交易數(shù)據(jù)做統(tǒng)計(jì)處理后的交易數(shù)據(jù)，可參見表1所示。

在具體實(shí)施時(shí)，計(jì)算服務(wù)器1可將基于統(tǒng)計(jì)維度X對(duì)表格二和表格六中的交易數(shù)據(jù)做統(tǒng)計(jì)處理后的交易數(shù)據(jù)發(fā)送給匯總服務(wù)器，由匯總服務(wù)器將接收到的交易數(shù)據(jù)分發(fā)給下面的Redis集群，查詢服務(wù)器通過訪問匯總服務(wù)器下面的Redis集群查詢到東方航空公司的銷售額信息以及銷售日期。

作為一種實(shí)施方式，在通過查詢服務(wù)器查詢到東方航空公司的銷售額信息以及銷售日期后，可基于查詢到統(tǒng)計(jì)數(shù)據(jù)，統(tǒng)計(jì)出機(jī)票的淡季和旺季。

路由至計(jì)算服務(wù)器2中的交易數(shù)據(jù)根據(jù)統(tǒng)計(jì)維度Y對(duì)交易數(shù)據(jù)做統(tǒng)計(jì)處理后的交易數(shù)據(jù)，可參見表2所示。

在具體實(shí)施時(shí)，計(jì)算服務(wù)器2可將基于統(tǒng)計(jì)維度Y對(duì)交易數(shù)據(jù)做統(tǒng)計(jì)處理后的交易數(shù)據(jù)發(fā)送給匯總服務(wù)器，由匯總服務(wù)器將接收到的交易數(shù)據(jù)分發(fā)給下面的Redis集群，查詢服務(wù)器通過訪問匯總服務(wù)器下面的Redis集群查詢到卡號(hào)123的消費(fèi)信息，該消費(fèi)信息中包括卡號(hào)123經(jīng)常光顧的商家信息以及卡號(hào)123的消費(fèi)能力。

根據(jù)以上內(nèi)容可以看出，由于在得到第一交易數(shù)據(jù)后，可借助關(guān)鍵字確定第一交易數(shù)據(jù)所對(duì)應(yīng)的計(jì)算服務(wù)器，因此關(guān)鍵字相同的第一交易數(shù)據(jù)將會(huì)發(fā)送至同一計(jì)算服務(wù)器，而計(jì)算服務(wù)器可根據(jù)預(yù)先設(shè)定的統(tǒng)計(jì)維度在對(duì)第一交易數(shù)據(jù)進(jìn)行統(tǒng)計(jì)處理后得到第二交易數(shù)據(jù)，并將第二交易數(shù)據(jù)發(fā)送給查詢服務(wù)器使用，因此，可通過增加計(jì)算服務(wù)器的數(shù)量的方式，水平擴(kuò)展計(jì)算統(tǒng)計(jì)的能力，從而提高將數(shù)據(jù)寫入數(shù)據(jù)庫的速度，進(jìn)而提升數(shù)據(jù)的查詢效率。

2.4 ?數(shù)據(jù)統(tǒng)計(jì)

基于相同的技術(shù)構(gòu)思，本案例提供一種數(shù)據(jù)統(tǒng)計(jì)裝置，如圖1所示。

該裝置可包括：過濾單元501，用于根據(jù)預(yù)先設(shè)定的過濾規(guī)則，對(duì)原始交易數(shù)據(jù)進(jìn)行過濾處理，得到第一交易數(shù)據(jù)，所述過濾規(guī)則包括所述原始交易數(shù)據(jù)的至少一個(gè)字段信息;確定單元502，用于根據(jù)所述第一交易數(shù)據(jù)中的關(guān)鍵字信息，確定所述第一交易數(shù)據(jù)所對(duì)應(yīng)的計(jì)算服務(wù)器;發(fā)送單元503，用于將所述第一交易數(shù)據(jù)發(fā)送至所述計(jì)算服務(wù)器，以使所述計(jì)算服務(wù)器將根據(jù)預(yù)先設(shè)定的統(tǒng)計(jì)維度對(duì)所述第一交易數(shù)據(jù)進(jìn)行統(tǒng)計(jì)得到的第二交易數(shù)據(jù)發(fā)送給查詢服務(wù)器使用。所述過濾規(guī)則是由各計(jì)算服務(wù)器的統(tǒng)計(jì)維度確定的。

確定單元502，具體用于：將所述第一交易數(shù)據(jù)中的關(guān)鍵字信息作為一致性哈希算法的輸入?yún)?shù)進(jìn)行運(yùn)算后，得到所述第一交易數(shù)據(jù)所對(duì)應(yīng)的計(jì)算服務(wù)器的標(biāo)識(shí)信息;根據(jù)得到的所述標(biāo)識(shí)信息確定所述第一交易數(shù)據(jù)所對(duì)應(yīng)的計(jì)算服務(wù)器;其中，所述一致性哈希算法的閉合環(huán)中包括至少一個(gè)計(jì)算服服務(wù)器的標(biāo)識(shí)信息。

用于通過心跳機(jī)制對(duì)所述計(jì)算服務(wù)器進(jìn)行檢測，在檢測到計(jì)算服務(wù)器發(fā)生故障時(shí)，將發(fā)生故障的計(jì)算服務(wù)器的標(biāo)識(shí)信息從所述一致性哈希算法的閉合環(huán)中刪除。此外，還定期接收所述計(jì)算服務(wù)器的存活消息;若在預(yù)設(shè)的時(shí)間段內(nèi)，未接收到所述計(jì)算服務(wù)器的存活消息，則判定所述計(jì)算服務(wù)器發(fā)生故障。

從以上內(nèi)容可以看出，由于在得到第一交易數(shù)據(jù)后，可借助關(guān)鍵字確定第一交易數(shù)據(jù)所對(duì)應(yīng)的計(jì)算服務(wù)器，因此關(guān)鍵字相同的第一交易數(shù)據(jù)將會(huì)發(fā)送至同一計(jì)算服務(wù)器，而計(jì)算服務(wù)器可根據(jù)預(yù)先設(shè)定的統(tǒng)計(jì)維度將對(duì)第一交易數(shù)據(jù)進(jìn)行統(tǒng)計(jì)處理后得到第二交易數(shù)據(jù)，并將第二交易數(shù)據(jù)發(fā)送給查詢服務(wù)器使用，因此，可通過增加計(jì)算服務(wù)器的數(shù)量的方式水平擴(kuò)展計(jì)算統(tǒng)計(jì)的能力，從而提高將數(shù)據(jù)寫入數(shù)據(jù)庫的速度，進(jìn)而提升數(shù)據(jù)的查詢效率。

3 ?結(jié) ?論

本案例提供了一些思路和方法，或者為研究計(jì)算機(jī)程序產(chǎn)品提供靈感。因此，本案例可采用完全硬件實(shí)施例、完全軟件實(shí)施例，或者結(jié)合軟件和硬件方面的實(shí)施例的形式。而且，可采用在一個(gè)或多個(gè)其中包含有計(jì)算機(jī)可用程序代碼的計(jì)算機(jī)可用存儲(chǔ)介質(zhì)（包括但不限于磁盤存儲(chǔ)器、CD-ROM、光學(xué)存儲(chǔ)器等）上實(shí)施的計(jì)算機(jī)程序產(chǎn)品的形式。

參考文獻(xiàn)：

[1] 陸承濤.存儲(chǔ)系統(tǒng)性能管理問題的研究 [D].武漢：華中科技大學(xué)，2010.

[2] 羅東健.大規(guī)模存儲(chǔ)系統(tǒng)高可靠性關(guān)鍵技術(shù)研究 [D].武漢：華中科技大學(xué)，2011.

作者簡介：王穎卓（1978.05-），男，漢族，江西贛州人，架構(gòu)師，碩士，研究方向：大數(shù)據(jù)開發(fā)。