[發明專利]用于向多個訂戶提供消息的系統和方法

在審

• 申請號: 201780072371.2
• 申請日: 2017-05-04
• 公開（公告）號: CN110121863A
• 公開（公告）日: 2019-08-13
• 發明（設計）人: I·米爾雅可夫
• 申請（專利權）人: 薩托里環球有限責任公司
• 主分類號: H04L12/58
• 分類號: H04L12/58
• 代理公司: 北京林達劉知識產權代理事務所(普通合伙) 11277
• 代理人: 劉新宇

1.一種計算機實現的方法，包括：

從多個發布者接收多個消息；

將所述消息中的各消息分配給多個通道其中之一，其中各通道包括有順序的多個消息；

根據所述順序將所述通道中的各通道的消息存儲在一個或多個相應存儲緩沖器中，其中各存儲緩沖器具有第一持續時間的相應存活時間；

對于特定通道，從相應存儲緩沖器檢索所述特定通道的消息；

根據所述順序將所述特定通道的檢索消息存儲在傳遞緩沖器中，所述傳遞緩沖器包括一個或多個數據塊，其中各數據塊具有第二持續時間的相應存活時間；以及

將所述傳遞緩沖器中所存儲的消息提供給所述特定通道的多個訂戶。

2.根據權利要求1所述的方法，其中，將所述傳遞緩沖器中所存儲的消息提供給所述特定通道的多個訂戶還包括：

判斷特定訂戶的連接狀況；以及

基于此，將所述傳遞緩沖器中所存儲的消息中的一個或多個消息提供給所述特定訂戶。

3.根據權利要求2所述的方法，其中，還包括：

判斷為所述特定訂戶具有到所述特定通道的既存連接；以及

基于此，將所述傳遞緩沖器中所存儲的一個或多個消息提供給所述特定訂戶，所述一個或多個消息包括具有已經期滿的相應存活時間的一個或多個數據塊中所存儲的消息。

4.根據權利要求2所述的方法，其中，還包括：

判斷為所述特定訂戶具有到所述特定通道的新連接，并且基于此：

(i)將具有尚未期滿的相應存活時間的一個或多個數據塊中所存儲的一個或多個消息提供給所述特定訂戶；以及

(ii)防止所述特定訂戶接收具有已經期滿的相應存活時間的一個或多個數據塊中所存儲的一個或多個消息。

5.根據權利要求1所述的方法，其中，將所述特定通道的檢索消息存儲在所述傳遞緩沖器中包括：

將所述特定通道中的順序較前的檢索消息存儲在如下數據塊中，其中所述數據塊相比用于存儲所述特定通道中的順序較后的檢索消息的數據塊而言具有將會較早期滿的存活時間。

6.根據權利要求1所述的方法，其中，所述傳遞緩沖器包括所述數據塊的鏈表，其中所述特定通道中的順序最后的檢索消息被存儲在所述鏈表的尾數據塊中。

7.根據權利要求6所述的方法，其中，將所述特定通道的檢索消息存儲在所述傳遞緩沖器中還包括：

從所述鏈表中移除所述鏈表頭處的一個或多個數據塊，其中所移除數據塊具有已經期滿的相應存活時間。

8.根據權利要求1所述的方法，其中，

所述傳遞緩沖器駐留在第一計算節點上；以及

所述傳遞緩沖器中所存儲的消息通過駐留在所述第一計算節點上的相應計算進程而被提供給所述多個訂戶中的各訂戶。

9.根據權利要求8所述的方法，其中，所述存儲緩沖器駐留在與所述第一計算節點不同的相應第二計算節點上。

10.根據權利要求1所述的方法，其中，所述傳遞緩沖器包括可見區域和不可見區域。

11.根據權利要求10所述的方法，其中，具有既存連接的訂戶被許可訪問來自所述可見區域和所述不可見區域這兩者的數據。

12.根據權利要求10所述的方法，其中，具有新連接的訂戶被許可訪問來自所述可見區域的數據，并且不被許可訪問來自所述不可見區域的數據。