[發明專利]針對消息收發服務的高密度托管

有效

• 申請號: 201310080434.2
• 申請日: 2013-03-13
• 公開（公告）號: CN103227747A
• 公開（公告）日: 2013-07-31
• 發明（設計）人: K·帕拉瑪斯萬姆;S·H·金;M·斯里瓦斯塔瓦;M·克里希納普拉塞德;R·R·科克;V·R·G·拉維帕蒂;李斌
• 申請（專利權）人: 微軟公司
• 主分類號: H04L12/58
• 分類號: H04L12/58;H04L29/08;G06F9/48
• 代理公司: 上海專利商標事務所有限公司 31100
• 代理人: 胡利鳴

1.一種至少部分地由計算機實現的方法，所述方法包括：

接收（420）把與消息相關聯的數據遷移到至少一個消息收發容器的指令；

基于一個或多個因素確定（425）要遷移的隊列，所述因素包括：所述隊列上次被使用是在何時、所述隊列的大小、以及所述隊列的熱度；

在允許所述隊列被所述消息收發容器用于接收新消息和遞送所排隊的消息的同時遷移（430）所述隊列的第一數據；

凍結（435）所述隊列以不允許所述隊列被用于接收新消息和遞送所排隊的消息；

在所述隊列被凍結時遷移（440）所述隊列的剩余數據，如果有的話；以及

在遷移了所述剩余數據以后解凍（445）所述隊列，所述解凍允許所述隊列被用于接收新消息和遞送所排隊的消息。

2.如權利要求1所述的方法，其特征在于，還包括：

確定所述隊列是否比遷移所述隊列更快地增長；以及

如果所述隊列比遷移該隊列更快地增長，則通過降低消息被允許添加到所述隊列的速率來對所述隊列進行節流。

3.如權利要求1所述的方法，其特征在于，遷移所述隊列的第一數據包括：

執行一組動作，執行該組動作在允許所述隊列被用于接收新消息和遞送所排隊的消息的同時發生，該組動作包括：

將所述隊列的一部分復制到目的地消息收發容器；以及

檢測所述隊列的剩余部分是否小于閾值；以及

重新執行該組動作，直到所述隊列的剩余部分小于所述閾值，所述閾值被選擇為致使所述度列被凍結短于所選時間段。

4.如權利要求1所述的方法，其特征在于，還包括：

確定與消息收發容器相關聯的事務速率已經越過閾值；以及

指示所述消息收發容器把由所述消息收發服務使用的數據遷移到一個或多個其他消息收發容器。

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

確定針對消息收發容器所消費的存儲已經超過閾值；以及

指示所述消息收發容器把由所述消息收發服務使用的數據遷移到一個或多個其他消息收發容器。

6.如權利要求1所述的方法，其特征在于，基于一個或多個因素確定要遷移的隊列包括：

通過基于首先每個隊列上次被使用是在何時、第二每個隊列的大小、以及第三每個隊列的熱度對所述隊列進行排序來將所述隊列的標識符放置到經排序的列表中；以及

選擇與所述列表的第一元素相關聯的隊列。

7.如權利要求1所述的方法，其特征在于，基于一個或多個因素確定要遷移的隊列包括：

通過基于下列公式對所述隊列進行排序來將所述隊列的標識符放置到經排序的列表中：

f(x)=w₁*上次使用的+w₂*隊列大小+w₃*熱度，其中*表示相乘，并且w₁、w₂和w₃表示權重；以及

選擇與所述列表的第一元素相關聯的隊列。

8.一種在計算環境中的系統，包括：

源消息收發容器（310，311，312），其用于接收從發送者發送的消息以用于遞送給接收者，所述源消息收發容器還用于把要遞送給所述接收者的消息放置在存儲中；以及

遷移代理（320，321，322），其用于接收把與所述消息相關聯的數據遷移到目的地消息收發容器的指令，所述遷移代理還用于執行動作，包括：

基于一個或多個因素確定要遷移的隊列；

在允許所述隊列被所述源消息收發容器用于接收新消息和遞送所排隊的消息的同時遷移所述隊列的第一數據；

凍結所述隊列以不允許所述隊列被用于接收新消息和遞送所排隊的消息；

在所述隊列被凍結時遷移所述隊列的剩余數據，如果有的話；以及

在遷移了所述剩余數據以后解凍所述隊列，所述解凍允許所述隊列被用于接收新消息和遞送所排隊的消息。