[發明專利]高效消息交換系統

在審

• 申請號: 201780031030.0
• 申請日: 2017-05-18
• 公開（公告）號: CN109417563A
• 公開（公告）日: 2019-03-01
• 發明（設計）人: L·瓦爾金;F·E·林德;I·米爾雅可夫
• 申請（專利權）人: 薩托里環球有限責任公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京林達劉知識產權代理事務所(普通合伙) 11277
• 代理人: 劉新宇

本發明提供了包括編碼在計算機存儲介質上的計算機程序的方法、系統和設備，用于：從多個源進程接收多個消息；標識與所述消息中的各消息相關聯的相應目的地節點以及該目的地節點上的目的地進程；將所述消息中的各消息存儲在針對與所述消息相關聯的目的地進程和目的地節點的相應的緩沖器中；標識所述緩沖器中的一個或多個緩沖器，其中所標識的緩沖器中的各緩沖器中所存儲的所有消息的總計大小超過閾值；以及對于所標識的各緩沖器，將該緩沖器中所存儲的所有消息成批地發送至與該緩沖器中所存儲的消息相關聯的目的地節點上的目的地進程。

相關申請的交叉引用

本申請要求提交于2016年5月19日的美國專利申請15/159,447的優先權，其全部內容通過引用而并入于此。

背景技術

本說明書涉及數據通信系統，特別地涉及用于實現實時、可擴展的發布-訂閱消息傳送的系統。

發布-訂閱模式(或者“PubSub”)是利用軟件系統實現的數據通信消息傳送布置，其中，所謂的發布者發布將消息發布到主題，并且所謂的訂戶接收與他們所訂閱的特定主題有關的消息。每個主題可以存在一個或多個發布者，并且發布者一般不知道什么樣的訂戶(如果有的話)將接收到所發布的消息。一些PubSub系統不緩存消息或者具有小的緩存，這意味著訂戶可能不會接收到在訂閱特定主題之前所發布的消息。在消息發布激增期間、或者隨著特定主題的訂戶的數量增加，PubSub系統可能易受到性能不穩定性的影響。

發明內容

一般來說，本說明書中所描述的主題的一個方面可以體現在如下的方法中，該方法包括利用一個或多個計算機來進行以下動作：從多個源進程接收多個消息；標識與所述消息中的各消息相關聯的相應目的地節點以及該目的地節點上的目的地進程；將所述消息中的各消息存儲在針對與所述消息相關聯的目的地進程和目的地節點的相應的緩沖器中；標識所述緩沖器中的一個或多個緩沖器，其中所標識的緩沖器中的各緩沖器中所存儲的所有消息的總計大小超過閾值；以及對于所標識的各緩沖器，將該緩沖器中所存儲的所有消息成批地發送至與該緩沖器中所存儲的消息相關聯的目的地節點上的目的地進程。該方面的其它實施例包括相應的系統、設備和計算機程序。

這些和其它方面的實現可以可選地包括以下特征中的一個或多個。用于存儲與特定目的地進程和特定目的地節點相關聯的消息的第一緩沖器可以駐留在與所述特定目的地節點不同的第一節點上。用于存儲與特定目的地進程和特定目的地節點相關聯的消息的第一緩沖器可以駐留在所述特定目的地節點上。特定目的地節點可以是虛擬機。將所述緩沖器中所存儲的所有消息成批地發送至與該緩沖器中所存儲的消息相關聯的目的地進程和目的地節點可以包括：將所述緩沖器中所存儲的所有消息匯集在第一消息中；以及將所述第一消息發送至所述目的地節點上的目的地進程。該方面還可以包括：標識特定緩沖器，其中自從該特定緩沖器發送了任意消息之后已經經過了一定時間量；以及將該緩沖器中所存儲的所有消息成批地發送至與該緩沖器中所存儲的消息相關聯的目的地進程和目的地節點。各緩沖器可以存儲多個不同通道中的一個通道的消息，其中各通道包括有順序的多個消息。源進程可以與用于根據所述順序來存儲特定通道的消息、并且具有相應存活時間的相應的第二緩沖器相關聯。目的地進程可以與用于根據所述順序來存儲特定通道的消息、并且具有相應存活時間的相應的第二緩沖器相關聯。

可以實施本說明中所描述的主題的特定實施例，以實現以下優點中的一個或多個優點。在消息傳送系統中，源進程通過首先例如通過一次一個的方式將消息存儲在數據緩沖器中，來將消息發送至目的地節點上的目的地進程。所述數據緩沖器存儲來自源進程的消息，直到所存儲消息的總計大小超過閾值為止。然后，所述數據緩沖器將所存儲消息成批地發送至所述目的地節點上的目的地進程。以這種方式，可以使將各消息發送至所述目的地進程的開銷最小化，并且可以提高發送消息的總吞吐量。由于對于各消息來說、任何系統調用進入到TCP棧中可能存在顯著的開銷，因此對消息進行“批處理”節省了顯著的開銷并實現更快的消息傳遞。

在附圖和以下的描述中詳細闡述了本說明書中所描述的主題的一個或多個實施例。根據說明書、附圖和權利要求，本主題的其它特征、方面和優點將變得明顯。