[發(fā)明專利]消息傳遞方法和系統(tǒng)及MOM服務(wù)器、接收端

有效

• 申請(qǐng)?zhí)枺?/td>: 201310481661.6
• 申請(qǐng)日: 2013-10-15
• 公開(kāi)（公告）號(hào): CN104579905B
• 公開(kāi)（公告）日: 2018-11-06
• 發(fā)明（設(shè)計(jì)）人: 趙紅維
• 申請(qǐng)（專利權(quán)）人: 阿里巴巴集團(tuán)控股有限公司
• 主分類號(hào): H04L12/58
• 分類號(hào): H04L12/58;H04L29/08;G06F9/54
• 代理公司: 北京三友知識(shí)產(chǎn)權(quán)代理有限公司 11127
• 代理人: 黨曉林

1.一種消息傳遞方法，其特征在于，包括：

發(fā)布者發(fā)布消息到消息中間件服務(wù)器；

消息中間件服務(wù)器接收所述發(fā)布者發(fā)布的消息，并將該接收的消息置于隊(duì)列中；

消息接收器監(jiān)聽(tīng)所述消息中間件服務(wù)器上的隊(duì)列，并在監(jiān)聽(tīng)到所述隊(duì)列上有消息后，將所述隊(duì)列上的消息取回，并通知消息拆分器；

消息拆分器收到所述通知后獲取消息關(guān)注者列表，并通知關(guān)注者列表中的關(guān)注者；

被通知的關(guān)注者將消息發(fā)送至該關(guān)注者對(duì)應(yīng)的消息處理器；

如果所述消息處理器執(zhí)行消息處理成功，則將數(shù)據(jù)庫(kù)中的該消息的處理狀態(tài)更新為成功；或，

如果所述消息處理器執(zhí)行消息處理失敗，則將數(shù)據(jù)庫(kù)中的該消息的處理狀態(tài)更新為失敗，設(shè)置下次重試處理的時(shí)間，并累計(jì)該消息的重試次數(shù)。

2.如權(quán)利要求1所述的方法，其特征在于，所述消息拆分器接收消息接收器發(fā)來(lái)的通知，具體包括：

消息拆分器接收消息接收器發(fā)來(lái)的包括消息的通知；或，

消息拆分器接收消息接收器發(fā)來(lái)的包括消息和事件類型的通知；或，

消息拆分器接收消息接收器發(fā)來(lái)的包括事件類型的通知；或

消息拆分器接收消息接收器發(fā)來(lái)的不包括消息和事件類型的通知。

3.如權(quán)利要求1或2所述的方法，其特征在于，所述消息拆分器通知關(guān)注者列表中的關(guān)注者，具體包括：

消息拆分器通知關(guān)注者列表中的與消息的事件類型對(duì)應(yīng)的關(guān)注者；或，

消息拆分器通知關(guān)注者列表中的全部關(guān)注者。

4.如權(quán)利要求1所述的方法，其特征在于，所述被通知的關(guān)注者將消息發(fā)送至該關(guān)注者對(duì)應(yīng)的消息處理器，具體包括：

被通知的關(guān)注者將需要關(guān)注的消息添加上關(guān)注者標(biāo)識(shí)后發(fā)送至數(shù)據(jù)庫(kù)中；

任務(wù)調(diào)度器定時(shí)到數(shù)據(jù)庫(kù)中輪詢，如果有存儲(chǔ)的消息，則讀取該消息上標(biāo)記的關(guān)注者標(biāo)識(shí)，并按照該消息上標(biāo)注的關(guān)注者標(biāo)識(shí)查找并通知對(duì)應(yīng)的消息處理器。

5.如權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

數(shù)據(jù)庫(kù)定時(shí)查詢每個(gè)消息的處理狀態(tài)，對(duì)于處理狀態(tài)為成功的消息執(zhí)行刪除處理；或，

對(duì)于重試次數(shù)達(dá)到或超過(guò)預(yù)定值的消息發(fā)出系統(tǒng)報(bào)警。

6.如權(quán)利要求1所述的方法，其特征在于：

所述隊(duì)列的個(gè)數(shù)為1個(gè)；或，

所述隊(duì)列的個(gè)數(shù)大于1，小于訂閱者個(gè)數(shù)。

7.一種消息傳遞系統(tǒng)，其特征在于，包括發(fā)布者，消息中間件服務(wù)器，消息接收器，消息拆分器，至少兩個(gè)關(guān)注者，其中，

發(fā)布者，用于發(fā)布消息到消息中間件服務(wù)器；

消息中間件服務(wù)器，用于接收所述發(fā)布者發(fā)布的消息，并將該接收的消息置于隊(duì)列中，所述隊(duì)列的個(gè)數(shù)為1個(gè)；或，所述隊(duì)列的個(gè)數(shù)大于1，小于訂閱者個(gè)數(shù)；

消息接收器，用于監(jiān)聽(tīng)所述消息中間件服務(wù)器上的隊(duì)列，并在監(jiān)聽(tīng)到所述隊(duì)列上有消息后，將所述隊(duì)列上的消息取回，并通知消息拆分器；

消息拆分器，用于收到消息接收器發(fā)來(lái)的通知后獲取消息關(guān)注者列表，并通知關(guān)注者列表中的關(guān)注者；

關(guān)注者，用于在接到消息拆分器發(fā)來(lái)的通知后將消息發(fā)送至該關(guān)注者對(duì)應(yīng)的消息處理器。

8.如權(quán)利要求7所述的系統(tǒng)，其特征在于，所述消息拆分器接收的消息接收器發(fā)來(lái)的通知，具體包括：

包括消息的通知；或，

包括消息和事件類型的通知；或，

包括事件類型的通知；或

不包括消息和事件類型的通知。

9.如權(quán)利要求7-8中任一項(xiàng)所述的系統(tǒng)，其特征在于，所述消息拆分器通知關(guān)注者列表中的關(guān)注者，具體包括：

與消息的事件類型對(duì)應(yīng)的關(guān)注者；或，

關(guān)注者列表中的全部關(guān)注者。