[發明專利]消息傳遞方法和系統及MOM服務器、接收端

有效

• 申請號: 201310481661.6
• 申請日: 2013-10-15
• 公開（公告）號: CN104579905B
• 公開（公告）日: 2018-11-06
• 發明（設計）人: 趙紅維
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: H04L12/58
• 分類號: H04L12/58;H04L29/08;G06F9/54
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 黨曉林

本申請實施例公開了消息傳遞方法、系統、消息中間件服務器及接收端。所述消息傳遞方法例如包括：發布者發布消息到消息中間件服務器；消息中間件服務器接收所述發布者發布的消息，并將該接收的消息置于隊列中；消息接收器監聽所述消息中間件服務器上的隊列，并在監聽到所述隊列上有消息后，將所述隊列上的消息取回，并通知消息拆分器；消息拆分器收到所述通知后獲取消息關注者列表，并通知關注者列表中的關注者；被通知的關注者將消息發送至該關注者對應的消息處理器。利用本申請各實施例，可以減輕消息中間件服務器的壓力。

技術領域

本申請涉及數據通信技術領域，特別涉及一種消息傳遞方法和系統及MOM服務器、接收端。

背景技術

在數據通信技術領域中，對象之間往往利用消息進行交互作用和通信。消息通信的基本方式包括一種同步方式。同步方式中，兩個通信的對象之間必須要進行同步。這就意味著每個對象的服務必須都是正常運行的。這樣，發送對象中的發送程序（一種服務）和接收對象中的接收程序（同樣是一種服務）都一直處于運行狀態，并且隨時做好相互通信的準備。發送程序向接收程序發起一個消息后，發送程序就會堵塞發送對象當前的進程。因此，發送對象不能與其它應用（也稱為應用程序）進行任何的通信以及交互，只能等待接收程序的響應。發送對象得到接收程序返回的消息之后，發送對象才會繼續向下運行，進行下一步的業務處理。消息通信的基本方式還包括一種異步方式。在異步方式中，兩個通信的對象之間可以不用同時在線等待，任何一方只需處理自己的業務。例如發送對象發送消息之后不必僅等待接收方的響應，而是還可以接著處理其他的任務。消息的接收方也不用立即對接收到的消息進行處理。

隨著技術的發展，出現了中間件（Middleware）技術。作為異步通信技術的一種，中間件典型的情況是基于分布式處理環境，最突出的特點是其數據通信功能。也可認為中間件是位于平臺和應用之間的通用服務，這些服務具有標準的程序接口和協議。

消息中間件（Message Oriented Middleware，MOM，也稱為面向消息的中間件）技術，提供了以松散耦合的靈活方式進行消息傳遞的一種中間件機制。圖1示出了一種利用消息中間件技術進行消息傳遞的原理圖。如圖1所示，應用程序A與應用程序B通過使用MOM的應用程序編程接口（Application Programming Interface,API）發送消息進行通信。這樣，MOM能夠實現在不同平臺之間的通信，它常被用來屏蔽掉各種平臺及協議之間的特性，實現應用程序之間的協同。目前主流的消息中間件產品包括國際商業機器公司（InternationalBusiness Machines Corporation，IBM）的MQSeries，東亞銀行（Bank of East Asia，BEA）的MessageQ和太陽公司（Sun）的Java消息服務（Java Message Service，JMS）等。

MOM包括基于存儲和轉發的應用之間的異步消息傳遞或同步消息傳遞。在異步消息傳遞中，應用之間彼此不直接通信，而是與作為中介的MOM服務器通信。異步中間件技術又包括廣播方式和發布-訂閱方式兩類。

圖2示出了發布-訂閱方式的系統原理圖。如圖2中所示，采用發布-訂閱模型的MOM利用稱為主題（topic）的內容來完成消息的發送和接收。發送應用程序（以下稱為發布者）發布自己的消息，指出消息描述的是有關某topic（一般對應該發布者）的信息。希望接收這些消息的應用程序（以下稱為訂閱者）訂閱了這個topic。訂閱該topic的訂閱者可以接收關于該主題的消息。MOM服務器起著代理的作用，將一個主題已發布的消息路由給該主題的所有訂閱者。

對于上述采用異步發布的方式，需要將當前還沒有發送完的消息存儲在MOM服務器中，在消息發送成功后才將消息從MOM服務器上刪除。具體的，發送者可以將消息發送給MOM服務器，MOM服務器將消息存放在某個或某些隊列中，在合適的時候再將消息轉發給接收者。不同的訂閱者一般對應MOM服務器上不同的隊列。