[發(fā)明專利]消息處理方法、裝置及系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 201610058201.6
• 申請(qǐng)日: 2016-01-28
• 公開(kāi)（公告）號(hào): CN105740083A
• 公開(kāi)（公告）日: 2016-07-06
• 發(fā)明（設(shè)計(jì)）人: 程崢嶸
• 申請(qǐng)（專利權(quán)）人: 努比亞技術(shù)有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54
• 代理公司: 廣東廣和律師事務(wù)所 44298
• 代理人: 章小燕

1.一種消息處理裝置，應(yīng)用于數(shù)據(jù)庫(kù)，其特征在于，所述裝置包括：

保存模塊，用于保存從消息接收服務(wù)器獲取的至少一個(gè)消息報(bào)文及其相關(guān)數(shù)據(jù)；

檢測(cè)模塊，用于檢測(cè)消息處理服務(wù)器中所述消息報(bào)文的處理狀態(tài)；

消息狀態(tài)處理模塊，用于當(dāng)檢測(cè)消息處理服務(wù)器成功處理所述消息報(bào)文對(duì)應(yīng)的數(shù)據(jù)時(shí)，將與所述消息報(bào)文對(duì)應(yīng)的狀態(tài)值由第一狀態(tài)改為第二狀態(tài)。

2.根據(jù)權(quán)利要求1所述的消息處理裝置，其特征在于，所述裝置還包括：

提取模塊，用于提取狀態(tài)值為第一狀態(tài)的消息報(bào)文；

消息推送模塊，用于將所述消息報(bào)文推送至消息接收服務(wù)器，經(jīng)由消息中間件轉(zhuǎn)發(fā)至所述消息處理服務(wù)器，以使所述消息處理服務(wù)器對(duì)所述消息報(bào)文進(jìn)行業(yè)務(wù)處理。

3.根據(jù)權(quán)利要求2所述的消息處理裝置，其特征在于，所述相關(guān)數(shù)據(jù)至少包括發(fā)送時(shí)間戳，所述裝置還包括：

偵測(cè)模塊，用于偵測(cè)所述消息接收服務(wù)器、所述消息中間件、以及所述消息處理服務(wù)器之一出現(xiàn)宕機(jī)；

相應(yīng)地，所述提取模塊具體用于當(dāng)宕機(jī)的所述消息接收服務(wù)器、所述消息中間件、以及所述消息處理服務(wù)器之一重新啟動(dòng)時(shí)，提取狀態(tài)值為第一狀態(tài)且所述發(fā)送時(shí)間戳在宕機(jī)之前的消息報(bào)文，并將提取的所述消息報(bào)文通過(guò)所述消息推送模塊推送至所述消息接收服務(wù)器。

4.根據(jù)權(quán)利要求1-3所述的消息處理裝置，其特征在于，所述裝置還包括：

刪除模塊，用于刪除狀態(tài)值為第二狀態(tài)的消息報(bào)文及其數(shù)據(jù)。

5.一種消息處理系統(tǒng)，其特征在于，所述系統(tǒng)包括：

消息接收服務(wù)器，用于接收至少一個(gè)消息報(bào)文，并將所述至少一個(gè)消息報(bào)文依次發(fā)送給消息中間件的消息隊(duì)列中，同時(shí)將所述至少一個(gè)消息報(bào)文及其對(duì)應(yīng)的狀態(tài)值寫入數(shù)據(jù)庫(kù)，默認(rèn)所述狀態(tài)值為第一狀態(tài)；

所述數(shù)據(jù)庫(kù)，用于保存從所述消息接收服務(wù)器獲取的所述至少一個(gè)消息報(bào)文及其相關(guān)數(shù)據(jù)；

消息處理服務(wù)器，用于從所述消息中間件提取所述消息報(bào)文進(jìn)行業(yè)務(wù)處理，當(dāng)業(yè)務(wù)處理成功時(shí)，所述狀態(tài)值改為第二狀態(tài)。

6.一種消息處理方法，應(yīng)用于數(shù)據(jù)庫(kù)，其特征在于，所述方法包括：

保存從消息接收服務(wù)器獲取的至少一個(gè)消息報(bào)文及其相關(guān)數(shù)據(jù)；

檢測(cè)消息處理服務(wù)器中所述消息報(bào)文的處理狀態(tài)；

當(dāng)檢測(cè)消息處理服務(wù)器成功處理所述消息報(bào)文對(duì)應(yīng)的數(shù)據(jù)時(shí)，將與所述消息報(bào)文對(duì)應(yīng)的狀態(tài)值由第一狀態(tài)改為第二狀態(tài)。

7.根據(jù)權(quán)利要求6所述的消息處理方法，其特征在于，所述方法還包括：

提取狀態(tài)值為第一狀態(tài)的消息報(bào)文；

將所述消息報(bào)文推送至消息接收服務(wù)器，經(jīng)由消息中間件轉(zhuǎn)發(fā)至所述消息處理服務(wù)器，以使所述消息處理服務(wù)器對(duì)所述消息報(bào)文進(jìn)行業(yè)務(wù)處理。

8.根據(jù)權(quán)利要求7所述的消息處理方法，其特征在于，所述相關(guān)數(shù)據(jù)至少包括發(fā)送時(shí)間戳，所述方法具體包括：

偵測(cè)所述消息接收服務(wù)器、所述消息中間件、以及所述消息處理服務(wù)器之一出現(xiàn)宕機(jī)；

當(dāng)宕機(jī)的所述消息接收服務(wù)器、所述消息中間件、以及所述消息處理服務(wù)器之一重新啟動(dòng)時(shí)，提取狀態(tài)值為第一狀態(tài)且所述發(fā)送時(shí)間戳為宕機(jī)之前的消息報(bào)文，并將提取的所述消息報(bào)文推送至所述消息接收服務(wù)器。

9.根據(jù)權(quán)利要求6-7任一所述的消息處理方法，其特征在于，所述方法還包括：

刪除狀態(tài)值為第二狀態(tài)的消息報(bào)文及其數(shù)據(jù)。

10.一種消息處理方法，其特征在于，所述方法包括步驟：

接收至少一個(gè)消息報(bào)文；

將所述至少一個(gè)消息報(bào)文依次發(fā)送給消息中間件的消息隊(duì)列中，同時(shí)將所述至少一個(gè)消息報(bào)文及其對(duì)應(yīng)的狀態(tài)值寫入數(shù)據(jù)庫(kù)，默認(rèn)所述狀態(tài)值為第一狀態(tài)；

保存從所述消息接收服務(wù)器獲取的所述至少一個(gè)消息報(bào)文及其相關(guān)數(shù)據(jù)；以及

從所述消息中間件提取所述消息報(bào)文進(jìn)行業(yè)務(wù)處理，當(dāng)業(yè)務(wù)處理成功時(shí)，所述狀態(tài)值改為第二狀態(tài)。