[發明專利]用于消息服務的處理方法、裝置及系統、消息服務系統

在審

• 申請號: 201410032412.3
• 申請日: 2014-01-23
• 公開（公告）號: CN104811459A
• 公開（公告）日: 2015-07-29
• 發明（設計）人: 吳崢濤;常磊
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京市清華源律師事務所 11441
• 代理人: 沈泳;李贊堅

1.一種用于消息發布的消息處理方法，其特征在于包括：

接收客戶端發布的消息；

建立與消息管理服務器的連接，將所述客戶端發布的消息轉發到消息管理服務器；

在消息管理服務器處理后向客戶端發送發布成功的響應。

2.根據權利要求1所述的用于消息發布的消息處理方法，其特征在于，所述接收客戶端發布的消息之前，建立與客戶端之間的連接。

3.根據權利要求1所述的用于消息發布的消息處理方法，其特征在于，所述建立與所述客戶端之間的連接包括：

接收客戶端以TCP協議發起的連接請求；

向客戶端回應所述連接請求，并要求客戶端確認；

接收客戶端返回的確認，建立與客戶端的連接。

4.根據權利要求1所述的用于消息發布的消息處理方法，其特征在于，所述連接為基于超文本協議的短連接。

5.根據權利要求1所述的用于消息發布的消息處理方法，其特征在于，所述建立與消息管理服務器的連接，將客戶端發布的消息轉發到消息管理服務器包括：

建立與消息管理服務器的連接，并基于該連接建立虛擬通信通道；

將消息通過所述虛擬通信通道發布到所述消息管理服務器。

6.根據權利要求5所述的用于消息發布的消息處理方法，其特征在于，所述建立與消息管理服務器的連接，并基于該連接建立虛擬通信通道包括：

由預先建立的與消息管理服務器之間連接的連接池中選擇任意一個連接；

在所選擇的連接中選擇一個基于該連接的虛擬通信通道。

7.根據權利要求6所述的用于消息發布的消息處理方法，其特征在于，所述與消息管理服務器之間連接為長連接。

8.根據權利要求2所述的用于消息發布的消息處理方法，其特征在于，所述接收客戶端發布的消息具體是指在多個接收端構成接收端集群中擇一接收客戶端發布的消息；

所述建立與客戶端之間的連接具體包括：

通過負載均衡算法獲得接收端集群中各個接收端的負載狀況和健康狀況；

根據所述負載狀況和健康狀況依據壓力均負原則建立相應接收端與客戶端的連接。

9.根據權利要求1所述的用于消息發布的消息處理方法，其特征在于，所述在消息管理服務器處理后向客戶端發送發布成功的響應包括：

接收消息管理服務器發送的消息已存儲的響應消息；

收到所述響應消息后向客戶端發送發布成功的響應。

10.一種用于消息訂閱的消息處理方法，其特征在于，包括：

接收客戶端發出的訂閱消息的請求，建立與客戶端之間的連接；

建立針對所述連接的到消息管理服務器的虛擬通信通道；

通過所述虛擬通信通道接收被訂閱的消息；

將所述接收的被訂閱的消息投遞至客戶端；

在客戶端消費消息后向消息管理服務器發送消息被消費的確認響應。

11.根據權利要求10所述的用于消息訂閱的消息處理方法，其特征在于，所述接收客戶端發出的訂閱消息的請求，建立于客戶端之間的連接包括：

接收客戶端發起的websocket握手請求；

向客戶端發送基于所述websocket握手請求的應答；

接收客戶端發送的開始消費消息的請求。

12.根據權利要求10所述的用于消息訂閱的消息處理方法，其特征在于，所述建立針對所述連接的到消息管理服務器的虛擬通信通道包括：

由預先建立的與消息管理服務器之間連接的連接池中選擇任意一個連接；

在所選擇的連接中選擇一個基于該連接的虛擬通信通道。

13.根據權利要求10所述的用于消息訂閱的消息處理方法，其特征在于，所述接收客戶端發出的訂閱消息的請求具體是指，在多個接收端構成的接收端集群中擇一接收客戶端發出的訂閱消息的請求；

所述建立與客戶端之間的連接具體包括：

通過負載均衡算法獲得接收端集群中各個接收端的負載狀況和健康狀況；

根據所述負載狀況和健康狀況依據壓力均負原則建立相應接收端與客戶端的連接。