[發(fā)明專利]基于Storm和Kafka技術(shù)的訂單實時監(jiān)控系統(tǒng)

在審

• 申請?zhí)枺?/td>: 201710174852.6
• 申請日: 2017-03-22
• 公開（公告）號: CN106920158A
• 公開（公告）日: 2017-07-04
• 發(fā)明（設(shè)計）人: 王清霞;劉寧;周國輝;姜林
• 申請（專利權(quán)）人: 北京再塑寶科技有限公司
• 主分類號: G06Q30/06
• 分類號: G06Q30/06;G06Q10/10;G06F17/30;G06F9/50;G06F9/48
• 代理公司: 暫無信息
• 代理人: 暫無信息

1.一種基于Storm和Kafka技術(shù)的訂單實時監(jiān)控系統(tǒng)，其特征在于，該系統(tǒng)主要以下幾個流程：

A、訂單數(shù)據(jù)獲取；

B、Kafka集群；

C、Strom集群；

D、Zookeeper集群；

E、數(shù)據(jù)處理結(jié)果展示。

2.根據(jù)權(quán)利要求1所述的基于Storm和Kafka技術(shù)的訂單實時監(jiān)控系統(tǒng)，其特征在于，所述步驟A，具體為：從數(shù)據(jù)庫中獲取訂單數(shù)據(jù)，通過訂單號獲取價格、并查詢一個訂單所對應(yīng)的skucode。

3.根據(jù)權(quán)利要求1所述的基于Storm和Kafka技術(shù)的訂單實時監(jiān)控系統(tǒng)，其特征在于，所述步驟B，具體為：往kafka里面放數(shù)據(jù)，創(chuàng)建隨機放入時的方法。

4.根據(jù)權(quán)利要求1所述的基于Storm和Kafka技術(shù)的訂單實時監(jiān)控系統(tǒng)，其特征在于，所述步驟C包含以下幾個流程，具體為：

C1、從數(shù)據(jù)庫中獲取訂單數(shù)據(jù)，通過訂單號獲取價格、并查詢一個訂單所對應(yīng)的skucode；

C2、往kafka里面放數(shù)據(jù)；

C3、采用storm提供的KafkaSpout，來創(chuàng)建消費kafka的spout；

C4、創(chuàng)建兩個Bolt，一個是處理從kafka讀取數(shù)據(jù)的OrderBolt，一個是處理訂單的OrderHandleBolt；

C5、創(chuàng)建拓撲OrderTopology；

C6、創(chuàng)建一個叫OnProductOrder的topic，然后配置好KafkaSpout的配置SpoutConfig；

C7、將id為spout的通過shuffleGrouping關(guān)聯(lián)到OrderBolt對象，然后將節(jié)點為OrderBolt通過shuffleGrouping關(guān)聯(lián)到OrderHandleBolt對象；

C8、最后根據(jù)參數(shù)創(chuàng)建3個Worker，提交StormTopology。

5.根據(jù)權(quán)利要求4所述的基于Storm和Kafka技術(shù)的訂單實時監(jiān)控系統(tǒng)，其特征在于，所述步驟C6，具體為：Kafka創(chuàng)建了一個3分區(qū)的Topic，本發(fā)明將并行度設(shè)置為3。

6.根據(jù)權(quán)利要求4所述的基于Storm和Kafka技術(shù)的訂單實時監(jiān)控系統(tǒng)，其特征在于，所述步驟C8，具體為：在整個storm下，spout、bolt的id必須唯一，否則會出現(xiàn)異常。

7.根據(jù)權(quán)利要求1所述的基于Storm和Kafka技術(shù)的訂單實時監(jiān)控系統(tǒng)，其特征在于，所述步驟E，具體為：主要實現(xiàn)歷史訂單進行比對，并將異常訂單相關(guān)編號和sku編號，當前價格（skuPrice）和歷史價格（historySkuPrice），通過調(diào)用MailSender實體類郵件發(fā)送功能方法發(fā)送相關(guān)責任人的郵箱。