[發(fā)明專(zhuān)利]一種通過(guò)消息隊(duì)列處理消息的方法、裝置和系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 200910092421.0
• 申請(qǐng)日: 2009-09-14
• 公開(kāi)（公告）號(hào): CN102023974A
• 公開(kāi)（公告）日: 2011-04-20
• 發(fā)明（設(shè)計(jì)）人: 王磊;范曉暉;劉越;于蓉蓉;鄭冬冬
• 申請(qǐng)（專(zhuān)利權(quán)）人: 中國(guó)移動(dòng)通信集團(tuán)公司
• 主分類(lèi)號(hào): G06F17/30
• 分類(lèi)號(hào): G06F17/30;G06F9/46
• 代理公司: 北京鑫媛睿博知識(shí)產(chǎn)權(quán)代理有限公司 11297
• 代理人: 龔家驊

1.一種通過(guò)消息隊(duì)列處理消息的方法，其特征在于，包括：

接收來(lái)自消息生產(chǎn)設(shè)備的消息，將所述消息發(fā)送到內(nèi)存中的第一消息隊(duì)列，并根據(jù)所述消息中的標(biāo)記位將所述消息添加到數(shù)據(jù)庫(kù)中；

將所述數(shù)據(jù)庫(kù)中的消息發(fā)送到內(nèi)存中的第二消息隊(duì)列，所述第二消息隊(duì)列用于存儲(chǔ)供消息使用設(shè)備獲取并處理的消息；

接收所述消息使用設(shè)備處理過(guò)的消息，將所述消息發(fā)送到所述第一消息隊(duì)列中，并根據(jù)所述處理過(guò)的消息的標(biāo)記位從所述數(shù)據(jù)庫(kù)中刪除或修改所述處理過(guò)的消息。

2.如權(quán)利要求1所述的方法，其特征在于，所述根據(jù)消息中的標(biāo)記位將消息添加到數(shù)據(jù)庫(kù)中，具體為：

根據(jù)所述第一消息隊(duì)列中的消息攜帶的插入標(biāo)記，將所述消息添加到所述數(shù)據(jù)庫(kù)中。

3.如權(quán)利要求1所述的方法，其特征在于，所述根據(jù)處理過(guò)的消息的標(biāo)記位從數(shù)據(jù)庫(kù)中刪除或修改處理過(guò)的消息，具體為：

根據(jù)所述處理過(guò)的消息攜帶的修改標(biāo)記，將所述處理過(guò)的消息從所述數(shù)據(jù)庫(kù)中刪除或者在所述數(shù)據(jù)庫(kù)中修改所述處理過(guò)的消息。

4.如權(quán)利要求1所述的方法，其特征在于，所述將數(shù)據(jù)庫(kù)中的消息發(fā)送到內(nèi)存中的第二消息隊(duì)列，具體為：

通過(guò)所述數(shù)據(jù)庫(kù)中的數(shù)據(jù)庫(kù)觸發(fā)器將所述數(shù)據(jù)庫(kù)中的消息發(fā)送到觸發(fā)器外部過(guò)程，并通過(guò)所述觸發(fā)器外部過(guò)程將所述消息發(fā)送到所述第二消息隊(duì)列。

5.如權(quán)利要求1所述的方法，其特征在于，所述接收消息使用設(shè)備處理過(guò)的消息之前，還包括：

所述消息使用設(shè)備從所述第二消息隊(duì)列中獲取并處理消息，將處理完畢的消息添加標(biāo)記位，并發(fā)送到所述第一消息隊(duì)列。

6.一種消息隊(duì)列服務(wù)器，其特征在于，包括：

收發(fā)模塊，用于接收來(lái)自消息生產(chǎn)設(shè)備的消息，將所述消息發(fā)送到內(nèi)存中的第一消息隊(duì)列，并接收消息使用設(shè)備處理過(guò)的消息，將所述處理過(guò)的消息發(fā)送到所述第一消息隊(duì)列中；

數(shù)據(jù)庫(kù)模塊，用于存儲(chǔ)消息，并將所述消息發(fā)送到內(nèi)存中的第二消息隊(duì)列；

添加模塊，與所述數(shù)據(jù)庫(kù)模塊和所述收發(fā)模塊連接，用于根據(jù)所述收發(fā)模塊發(fā)送到所述第一消息隊(duì)列中的來(lái)自所述消息生產(chǎn)設(shè)備的消息的標(biāo)記位，將所述消息添加到所述數(shù)據(jù)庫(kù)模塊中；

修改模塊，與所述收發(fā)模塊和所述數(shù)據(jù)庫(kù)模塊連接，用于根據(jù)所述收發(fā)模塊發(fā)送到所述第一消息隊(duì)列中的所述消息使用設(shè)備處理過(guò)的消息的標(biāo)記位，將所述處理過(guò)的消息從所述數(shù)據(jù)庫(kù)模塊中刪除或者在所述數(shù)據(jù)庫(kù)模塊中修改所述處理過(guò)的消息。

7.如權(quán)利要求6所述消息隊(duì)列服務(wù)器，其特征在于，

所述添加模塊，具體用于根據(jù)所述第一消息隊(duì)列中的消息攜帶的插入標(biāo)記，將所述第一消息隊(duì)列中消息添加到所述數(shù)據(jù)庫(kù)模塊中。

8.如權(quán)利要求6所述消息隊(duì)列服務(wù)器，其特征在于，還包括：

創(chuàng)建模塊，與所述收發(fā)模塊連接，用于創(chuàng)建所述第一消息隊(duì)列和所述第二消息隊(duì)列，分別供所述收發(fā)模塊和所述數(shù)據(jù)庫(kù)模塊使用。

9.如權(quán)利要求6所述消息隊(duì)列服務(wù)器，其特征在于，

所述數(shù)據(jù)庫(kù)模塊，具體用于通過(guò)數(shù)據(jù)庫(kù)觸發(fā)器將所述消息發(fā)送到觸發(fā)器外部過(guò)程，并通過(guò)所述觸發(fā)器外部過(guò)程將所述消息發(fā)送到所述第二消息隊(duì)列。

10.一種通過(guò)消息隊(duì)列處理消息的系統(tǒng)，包括消息生產(chǎn)設(shè)備、消息隊(duì)列服務(wù)器和消息使用設(shè)備，其特征在于，

所述消息生產(chǎn)設(shè)備，用于生成消息，并將所述消息發(fā)送到所述消息隊(duì)列服務(wù)器；

所述消息隊(duì)列服務(wù)器，用于接收來(lái)自所述消息生產(chǎn)設(shè)備的消息，將所述消息發(fā)送到內(nèi)存中的第一消息隊(duì)列，并根據(jù)所述消息中的標(biāo)記位將所述消息添加到數(shù)據(jù)庫(kù)中；將所述數(shù)據(jù)庫(kù)中的消息發(fā)送到內(nèi)存中的第二消息隊(duì)列，使消息使用設(shè)備獲取并處理所述消息；接收所述消息使用設(shè)備處理過(guò)的消息，將所述消息發(fā)送到所述第一消息隊(duì)列中，并根據(jù)所述處理過(guò)的消息的標(biāo)記位從所述數(shù)據(jù)庫(kù)中刪除或修改所述消息；

所述消息使用設(shè)備，用于從所述第二消息隊(duì)列中獲取并處理消息，將處理完畢的消息添加標(biāo)記位，并發(fā)送到所述第一消息隊(duì)列。