[發(fā)明專利]處理異步消息的系統(tǒng)及其發(fā)送消息、監(jiān)聽處理任務的方法

無效

• 申請?zhí)枺?/td>: 201210045065.9
• 申請日: 2012-02-27
• 公開（公告）號: CN102611642A
• 公開（公告）日: 2012-07-25
• 發(fā)明（設(shè)計）人: 俞曉鴻
• 申請（專利權(quán)）人: 杭州閃亮科技有限公司
• 主分類號: H04L12/58
• 分類號: H04L12/58;H04L12/26
• 代理公司: 上海思微知識產(chǎn)權(quán)代理事務所(普通合伙) 31237
• 代理人: 鄭瑋

1.一種處理異步消息的系統(tǒng)，利用分布式異步隊列處理異步消息，其至少包括：

多個集群端，每個集群端均包含應用服務器及多個客戶端，每個客戶端根據(jù)預設(shè)規(guī)則選擇隊列服務器，當發(fā)送消息時，每個集群端作為發(fā)送端擇相應的隊列服務器將消息采用分布式隊列方式進行異步傳送；當需處理任務時，每個集群端作為監(jiān)聽端則創(chuàng)建監(jiān)聽線程，設(shè)置監(jiān)聽隊列和監(jiān)聽隊列服務器，以異步方式處理任務；以及

隊列服務器端，包含多個隊列服務器，其用于接收每個集群端發(fā)送的異步消息及存儲需處理的任務。

2.如權(quán)利要求1所述的處理異步消息的系統(tǒng)，其特征在于：該多個集群端采用分布式部署。

3.如權(quán)利要求1所述的處理異步消息的系統(tǒng)，其特征在于：該預設(shè)規(guī)則為基于權(quán)重的輪詢調(diào)度算法。

4.如權(quán)利要求1所述的處理異步消息的系統(tǒng)，其特征在于：該隊列服務器端還利用日志文件記錄每個任務的相關(guān)信息。

5.一種處理異步消息的系統(tǒng)之發(fā)送消息的方法，包括如下步驟

創(chuàng)建套接字發(fā)送端；

接收客戶端發(fā)送的消息；

檢查套接字連接池是否存在；

若存在，則使用原有套接字連接池，否則，則創(chuàng)建新的套接字連接池；

根據(jù)基于權(quán)重的負載檢查連接的可用性，若不可用，則自動重新連接；

選擇一套接字連接池；

創(chuàng)建發(fā)送消息任務并將任務放入任務池中；以及

異步發(fā)送套接字消息。

6.如權(quán)利要求5所述的處理異步消息的系統(tǒng)之發(fā)送消息的方法，其特征在于：當連接斷掉、網(wǎng)絡異?；蜿犃蟹掌鞫水惓r，連接不可用。

7.如權(quán)利要求5所述的處理異步消息的系統(tǒng)之發(fā)送消息的方法，其特征在于：當于異步發(fā)送消息時發(fā)送端發(fā)生異常時，該發(fā)送端將該任務重新放入任務池中，重新發(fā)送。

8.如權(quán)利要求5所述的處理異步消息的系統(tǒng)之發(fā)送消息的方法，其特征在于：于發(fā)送過程中，若因網(wǎng)絡問題導致連接超時或服務器端處理任務超時或讀取響應信息超時，該發(fā)送端重新將該任務放入任務池中發(fā)送。

9.如權(quán)利要求5所述的處理異步消息的系統(tǒng)之發(fā)送消息的方法，其特征在于：該發(fā)送端連接池中的每個連接不與具體隊列綁定，在該發(fā)送端發(fā)送時會動態(tài)設(shè)置連接所使用的隊列名稱。

10.一種處理異步消息的系統(tǒng)之監(jiān)聽處理任務的方法，包括如下步驟：

創(chuàng)建監(jiān)聽線程，設(shè)置監(jiān)聽隊列和監(jiān)聽隊列服務器；

各監(jiān)聽線程循環(huán)監(jiān)聽隊列服務器；

于有任務處理時相應的客戶端接受任務；

刪除隊列服務器端的該任務；

客戶端處理該任務；

于處理成功后刪除任務文件。

11.如權(quán)利要求10所述的處理異步消息的系統(tǒng)之監(jiān)聽處理任務的方法，其特征在于，客戶端接受任務后還包括如下步驟：

判斷任務文件中是否有該任務存在；

若有，則刪除隊列服務器端的該任務，否則將該任務寫入任務文件。

12.如權(quán)利要求10所述的處理異步消息的系統(tǒng)之監(jiān)聽處理任務的方法，其特征在于：若該客戶端處理該任務失敗三次以上，則將該任務寫入失敗隊列，并啟動一定時器定時處理失敗隊列中的任務，同時刪除該任務文件。

13.如權(quán)利要求10所述的處理異步消息的系統(tǒng)之監(jiān)聽處理任務的方法，其特征在于：于處理成功后刪除任務文件后，還包括記錄日志到日志文件的步驟。

14.如權(quán)利要求10所述的處理異步消息的系統(tǒng)之監(jiān)聽處理任務的方法，其特征在于：對于每個隊列服務器端，采用單線程循環(huán)監(jiān)聽多隊列的任務。