公开(公告)号：CN109417563A

公开(公告)日：2019-03-01

申请号：CN201780031030.0

申请日：2017-05-18

Applicant: 萨托里环球有限责任公司

Inventor： L·瓦尔金 ,  F·E·林德 ,  I·米尔雅可夫

IPC: H04L29/08

Abstract: 本发明提供了包括编码在计算机存储介质上的计算机程序的方法、系统和设备，用于：从多个源进程接收多个消息；标识与所述消息中的各消息相关联的相应目的地节点以及该目的地节点上的目的地进程；将所述消息中的各消息存储在针对与所述消息相关联的目的地进程和目的地节点的相应的缓冲器中；标识所述缓冲器中的一个或多个缓冲器，其中所标识的缓冲器中的各缓冲器中所存储的所有消息的总计大小超过阈值；以及对于所标识的各缓冲器，将该缓冲器中所存储的所有消息成批地发送至与该缓冲器中所存储的消息相关联的目的地节点上的目的地进程。

公开(公告)号：CN109964456A

公开(公告)日：2019-07-02

申请号：CN201780065516.6

申请日：2017-06-07

Applicant: 萨托里环球有限责任公司

Inventor： L·瓦尔金 ,  F·E·林德

IPC: H04L12/58

Abstract: 一种包括编码在计算机存储介质上的计算机程序的方法、系统和设备，用于平衡发布‑订阅系统中的负载。示例方法包括：至少部分基于负载数据来从多个托管节点中选择第一托管节点，所述负载数据是从表示所述多个托管节点上的负载的节点特定的数据和表示与通道相关联的负载的通道特定的数据的至少之一中选择的；将用以暂时托管所述通道的一部分的请求发送至所述第一托管节点；利用所述第一托管节点，通过暂时存储发布到所述通道的一个或多个消息、并且将向所述一个或多个消息的访问暂时提供至向所述通道的多个订户，来暂时托管通道部分；接收用以访问所述通道部分的请求；以及授予用以访问所述通道部分的许可。

公开(公告)号：CN109644155A

公开(公告)日：2019-04-16

申请号：CN201780053565.8

申请日：2017-08-25

Applicant: 萨托里环球有限责任公司

Inventor： Y·哈弗里 ,  L·瓦尔金 ,  F·E·林德

IPC: H04L12/58

CPC classification number: H04L67/1095 ,  H04L41/0677 ,  H04L51/14

Abstract: 本发明提供了包括编码在计算机存储介质上的计算机程序的方法、系统和设备，用于：维护多个通道，各通道包括一个或多个缓冲器中所存储的有序的多个消息，各缓冲器具有相应的存活时间并且多个副本驻留在相应节点上；检测所述多个节点中的第一节点的故障，其中所述第一节点存储第一缓冲器的相应的第一副本，并且至少一个订户订阅一个或多个第一通道的消息；对于具有驻留在所述第一节点上的第一副本的第一缓冲器，将所述多个节点中的任意其它节点标识为存储所述第一缓冲器的第二副本的第二节点；将所述至少一个订户从所述第一节点重定向至所述第二节点；以及针对所述至少一个订户，检索所述第二节点上的所述第二副本中所存储的消息。