[發(fā)明專利]基于消息隊列的分布式方法和系統(tǒng)有效
| 申請?zhí)枺?/td> | 201210410481.4 | 申請日： | 2012-10-24 |
| 公開（公告）號： | CN103019866B | 公開（公告）日： | 2017-02-08 |
| 發(fā)明（設(shè)計）人： | 李鵬濤 | 申請（專利權(quán)）人： | 北京京東世紀(jì)貿(mào)易有限公司 |
| 主分類號： | G06F9/54 | 分類號： | G06F9/54 |
| 代理公司： | 中原信達(dá)知識產(chǎn)權(quán)代理有限責(zé)任公司11219 | 代理人： | 李寶泉,周亞榮 |
| 地址： | 100176 北京市北京經(jīng)濟*** | 國省代碼： | 北京;11 |
| 權(quán)利要求書： | 查看更多 | 說明書： | 查看更多 |
| 摘要： | |||
| 搜索關(guān)鍵詞： | 基于 消息 隊列 分布式 方法 系統(tǒng) | ||
1.一種基于消息隊列的分布式方法，包括：
由第一應(yīng)用向隊列管理器發(fā)送消息；
確定所述消息是否成功發(fā)送；
如果確定沒有成功發(fā)送所述消息，則所述消息被放入第一異常處理模塊進行處理；
如果確定已經(jīng)成功發(fā)送所述消息，則由所述隊列管理器對所接收到的消息進行處理；
將所述消息發(fā)送到第二應(yīng)用；以及
由所述第二應(yīng)用對所接收到的消息進行處理。
2.根據(jù)權(quán)利要求1所述的方法，其中所述由所述隊列管理器對所接收到的消息進行處理的步驟進一步包括：
確定所述消息是否是死信；以及
如果確定所述消息是死信，則所述消息被放入死信處理模塊以進行處理。
3.根據(jù)權(quán)利要求1所述的方法，其中所述由第二應(yīng)用對所接收到的消息進行處理的步驟進一步包括：
確定所述第二應(yīng)用是否已經(jīng)成功處理了所述消息；以及
如果確定沒有成功處理所述消息，則所述消息被放入第二異常處理模塊進行處理。
4.根據(jù)權(quán)利要求1所述的方法，其中所述消息被放入第一異常處理模塊進行處理的步驟進一步包括：
確定所述第一異常處理模塊是否已經(jīng)成功處理了所述消息；
如果確定沒有成功處理所述消息，則向監(jiān)控模塊報告該情況；以及
如果確定已經(jīng)成功處理了所述消息，則將所述消息發(fā)送到所述隊列管理器。
5.根據(jù)權(quán)利要求2所述的方法，其中所述消息被放入死信處理模塊以進行處理的步驟進一步包括：
確定所述死信處理模塊是否已經(jīng)成功處理所述消息；以及
如果確定沒有成功處理所述消息，則向監(jiān)控模塊報告該情況。
6.根據(jù)權(quán)利要求3所述的方法，其中所述消息被放入第二異常處理模塊進行處理的步驟進一步包括：
確定所述第二異常處理模塊是否已經(jīng)成功處理了所述消息；以及
如果確定沒有成功處理所述消息，則向監(jiān)控模塊報告該情況。
7.根據(jù)權(quán)利要求1所述的方法，其中在所述第一應(yīng)用向所述隊列管理器發(fā)送所述消息之前，注冊模塊可以對所述消息進行匹配檢查，并且僅當(dāng)所述消息匹配時，才繼續(xù)后續(xù)操作。
8.根據(jù)權(quán)利要求1所述的方法，其中所述隊列管理器是隊列管理器集群。
9.根據(jù)權(quán)利要求8所述的方法，其中所述由隊列管理器對所接收到的消息進行處理進一步包括：
確定所述隊列管理器集群中的一個隊列管理器未能正常工作；
隔離所述一個隊列管理器，使得不會再有新的消息路由到所述一個隊列管理器；以及
由其余的隊列管理器接管所述一個隊列管理器的工作。
10.根據(jù)權(quán)利要求4所述的方法，其中所述確定所述第一異常處理模塊是否已經(jīng)成功處理了所述消息的步驟在預(yù)定時間間隔之后執(zhí)行。
11.根據(jù)權(quán)利要求5所述的方法，其中所述確定所述死信處理模塊是否已經(jīng)成功處理所述消息的步驟在預(yù)定時間間隔之后執(zhí)行。
12.根據(jù)權(quán)利要求6所述的方法，其中所述確定所述第二異常處理模塊是否已經(jīng)成功處理了所述消息的步驟在預(yù)定時間間隔之后執(zhí)行。
13.一種基于消息隊列的分布式系統(tǒng)，包括：
第一應(yīng)用，所述第一應(yīng)用被配置成向隊列管理器發(fā)送消息；
第一異常處理模塊，所述第一異常處理模塊連接到所述第一應(yīng)用，并且被配置成對所述第一應(yīng)用沒有成功發(fā)送的消息進行處理；
隊列管理器，所述隊列管理器與所述第一應(yīng)用和所述第一異常處理模塊相連，并且被配置成對所接收到的消息進行處理并且將所述消息發(fā)送到第二應(yīng)用；以及
第二應(yīng)用，所述第二應(yīng)用連接到所述隊列管理器，并且被配置成對所接收到的消息進行處理。
14.根據(jù)權(quán)利要求13所述的系統(tǒng)，進一步包括監(jiān)控模塊，所述監(jiān)控模塊被配置成對所述第一應(yīng)用、所述隊列管理器和所述第二應(yīng)用進行監(jiān)控。
15.根據(jù)權(quán)利要求13或14所述的系統(tǒng)，其中所述隊列管理器進一步包括死信處理模塊，所述死信處理模塊被配置成對死信進行處理。
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息，商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于北京京東世紀(jì)貿(mào)易有限公司，未經(jīng)北京京東世紀(jì)貿(mào)易有限公司許可，擅自商用是侵權(quán)行為。如果您想購買此專利、獲得商業(yè)授權(quán)和技術(shù)合作，請聯(lián)系【客服】
本文鏈接：http://www.szxzyx.cn/pat/books/201210410481.4/1.html，轉(zhuǎn)載請聲明來源鉆瓜專利網(wǎng)。
