公开(公告)号：US08392961B2

公开(公告)日：2013-03-05

申请号：US12137147

申请日：2008-06-11

申请人： Sumeer K. Bhola ,  Daniel C. Sturman ,  Yuanyuan Zhao

发明人： Sumeer K. Bhola ,  Daniel C. Sturman ,  Yuanyuan Zhao

IPC分类号： G06F21/00

CPC分类号： H04L63/102 ,  G06F21/6218 ,  G06F2221/2105 ,  G06F2221/2141 ,  H04L51/00 ,  H04L67/00

摘要： Improved access control techniques for distributed messaging systems such as content-based publish/subscribe systems are disclosed. For example, a method for providing access control in a content-based publish/subscribe system, wherein messages are delivered from publishing clients to subscribing clients via a plurality of brokers, includes the following steps/operations. One or more changes to an access control policy are specified. An access control version identifier is associated to the one or more changes. The one or more changes are sent to one or more brokers of the plurality of brokers that have a publishing client or a subscribing client associated therewith that is affected by the one or more changes. The access control version identifier associated with the one or more changes is sent to each of the plurality of brokers.

摘要翻译： 公开了用于诸如基于内容的发布/订阅系统之类的分布式消息系统的改进的访问控制技术。 例如，一种用于在基于内容的发布/订阅系统中提供访问控制的方法，其中消息通过多个经纪人从发布客户端传递到订阅客户端包括以下步骤/操作。 指定访问控制策略的一个或多个更改。 访问控制版本标识符与一个或多个更改相关联。 将一个或多个更改发送给多个经纪人的一个或多个经纪人，其具有受一个或多个变化影响的发布客户端或与之相关联的订阅客户端。 将与一个或多个变化相关联的访问控制版本标识符发送给多个经纪人中的每一个。

公开(公告)号：US07822801B2

公开(公告)日：2010-10-26

申请号：US10965458

申请日：2004-10-14

申请人： Yuanyuan Zhao ,  Daniel Charles Sturman ,  Sumeer Bhola

发明人： Yuanyuan Zhao ,  Daniel Charles Sturman ,  Sumeer Bhola

IPC分类号： G06F15/16

CPC分类号： G06Q10/10

摘要： The present invention is directed to a publish/subscribe system containing a plurality of brokers, a plurality of subscribers and plurality of brokers including publisher connecting brokers, intermediate brokers and subscriber connecting brokers. Subscriptions are introduced into the system by the subscribers through associated subscription brokers. New subscriptions are aggregated, assigned a virtual start time and propagated through the system toward the publishers. Each broker maintains subscription information in the form of a directed acyclic graph and a broker vector. Messages are published through the system by the publishers through their associated publisher connecting brokers. Each message is assigned a message vector associating subscriptions to that message. The published messages are routed through the brokers toward the subscribers in accordance with comparisons of message brokers and vector brokers conducted at each broker.

摘要翻译： 本发明涉及包含多个经纪人，多个订阅者和多个经纪人的发布/订阅系统，包括发行商连接经纪人，中间经纪人和订户连接经纪人。 用户通过相关订阅经纪人将订阅引入系统。 新订阅被聚合，分配一个虚拟的开始时间，并通过系统向发布商传播。 每个经纪人以有向无环图和代理向量的形式维护订阅信息。 消息通过系统由发布商通过其关联的发布商连接经纪人发布。 为每个消息分配一个将订阅关联到该消息的消息向量。 根据在每个经纪人进行的消息经纪人和向量经纪人的比较，所发布的消息通过经纪人路由到订户。

公开(公告)号：US07487246B2

公开(公告)日：2009-02-03

申请号：US11479264

申请日：2006-06-30

申请人： Mark C. Astley ,  Joshua S. Auerbach ,  Sumeer K. Bhola ,  Marc A. Kaplan ,  Robert E. Strom ,  Yuanyuan Zhao

发明人： Mark C. Astley ,  Joshua S. Auerbach ,  Sumeer K. Bhola ,  Marc A. Kaplan ,  Robert E. Strom ,  Yuanyuan Zhao

IPC分类号： G06F15/173 ,  G06F15/16

CPC分类号： H04L67/26 ,  H04L67/306 ,  H04L69/329

摘要： A content-based publish/subscribe system for providing gapless message delivery from a publishing client to a subscribing client is disclosed. The system includes a plurality of brokers operatively coupled to one another via a network. Each of the brokers include at least one processor and are configured as a publisher-hosting broker, a subscriber-hosting broker or an intermediate broker. The subscriber-hosting broker may be operatively coupled to the publisher-hosting broker via the network through the intermediate broker. At least a portion of the plurality of brokers are configured so as to eliminate a need for persistent storage of messages at the intermediate broker and to substantially guarantee a gapless delivery of one or more messages transmitted by the publishing client to the subscribing client, even in the presence of a failure in the publish/subscribe system.

摘要翻译： 公开了一种基于内容的发布/订阅系统，用于从发布客户端向订阅客户端提供无缝隙的消息传递。 该系统包括经由网络可操作地彼此耦合的多个经纪人。 每个经纪人包括至少一个处理器，并且被配置为发行人托管代理，订户托管代理或中间代理。 订户托管代理可以经由中间代理经由网络可操作地耦合到发行商托管代理。 多个代理的至少一部分被配置为消除对在中间代理处的消息的持久存储的需要，并且基本上保证发布客户端发送给订阅客户端的一个或多个消息的无间隙传递，即使在 发布/订阅系统中出现故障。

公开(公告)号：US20080244696A1

公开(公告)日：2008-10-02

申请号：US12137147

申请日：2008-06-11

申请人： Sumeer K. Bhola ,  Daniel C. Sturman ,  Yuanyuan Zhao

发明人： Sumeer K. Bhola ,  Daniel C. Sturman ,  Yuanyuan Zhao

IPC分类号： G06F21/00

CPC分类号： H04L63/102 ,  G06F21/6218 ,  G06F2221/2105 ,  G06F2221/2141 ,  H04L51/00 ,  H04L67/00

摘要： Improved access control techniques for distributed messaging systems such as content-based publish/subscribe systems are disclosed. For example, a method for providing access control in a content-based publish/subscribe system, wherein messages are delivered from publishing clients to subscribing clients via a plurality of brokers, includes the following steps/operations. One or more changes to an access control policy are specified. An access control version identifier is associated to the one or more changes. The one or more changes are sent to one or more brokers of the plurality of brokers that have a publishing client or a subscribing client associated therewith that is affected by the one or more changes. The access control version identifier associated with the one or more changes is sent to each of the plurality of brokers.

摘要翻译： 公开了用于诸如基于内容的发布/订阅系统之类的分布式消息系统的改进的访问控制技术。 例如，一种用于在基于内容的发布/订阅系统中提供访问控制的方法，其中消息通过多个经纪人从发布客户端传递到订阅客户端包括以下步骤/操作。 指定访问控制策略的一个或多个更改。 访问控制版本标识符与一个或多个更改相关联。 将一个或多个更改发送给多个经纪人的一个或多个经纪人，其具有受一个或多个变化影响的发布客户端或与之相关联的订阅客户端。 将与一个或多个变化相关联的访问控制版本标识符发送给多个经纪人中的每一个。

公开(公告)号：US20070245018A1

公开(公告)日：2007-10-18

申请号：US11402685

申请日：2006-04-12

申请人： Sumeer Bhola ,  Daniel Sturman ,  Yuanyuan Zhao

发明人： Sumeer Bhola ,  Daniel Sturman ,  Yuanyuan Zhao

IPC分类号： G06F15/173

CPC分类号： H04L63/102 ,  G06F21/6218 ,  G06F2221/2105 ,  G06F2221/2141 ,  H04L51/00 ,  H04L67/00

摘要： Improved access control techniques for distributed messaging systems such as content-based publish/subscribe systems are disclosed. For example, a method for providing access control in a content-based publish/subscribe system, wherein messages are delivered from publishing clients to subscribing clients via a plurality of brokers, includes the following steps/operations. One or more changes to an access control policy are specified. An access control version identifier is associated to the one or more changes. The one or more changes are sent to one or more brokers of the plurality of brokers that have a publishing client or a subscribing client associated therewith that is affected by the one or more changes. The access control version identifier associated with the one or more changes is sent to each of the plurality of brokers.

摘要翻译： 公开了用于诸如基于内容的发布/订阅系统之类的分布式消息系统的改进的访问控制技术。 例如，一种用于在基于内容的发布/订阅系统中提供访问控制的方法，其中消息通过多个经纪人从发布客户端传递到订阅客户端包括以下步骤/操作。 指定访问控制策略的一个或多个更改。 访问控制版本标识符与一个或多个更改相关联。 将一个或多个更改发送给多个经纪人的一个或多个经纪人，其具有受一个或多个变化影响的发布客户端或与之相关联的订阅客户端。 将与一个或多个变化相关联的访问控制版本标识符发送给多个经纪人中的每一个。

公开(公告)号：US20060085507A1

公开(公告)日：2006-04-20

申请号：US10965458

申请日：2004-10-14

申请人： Yuanyuan Zhao ,  Daniel Sturman ,  Sumeer Bhola

发明人： Yuanyuan Zhao ,  Daniel Sturman ,  Sumeer Bhola

IPC分类号： G06F15/16

CPC分类号： G06Q10/10

摘要： The present invention is directed to a publish/subscribe system containing a plurality of brokers, a plurality of subscribers and plurality of brokers including publisher connecting brokers, intermediate brokers and subscriber connecting brokers. Subscriptions are introduced into the system by the subscribers through associated subscription brokers. New subscriptions are aggregated, assigned a virtual start time and propagated through the system toward the publishers. Each broker maintains subscription information in the form of a directed acyclic graph and a broker vector. Messages are published through the system by the publishers through their associated publisher connecting brokers. Each message is assigned a message vector associating subscriptions to that message. The published messages are routed through the brokers toward the subscribers in accordance with comparisons of message brokers and vector brokers conducted at each broker.

摘要翻译： 本发明涉及包含多个经纪人，多个订阅者和多个经纪人的发布/订阅系统，包括出版商连接经纪人，中间经纪人和订户连接经纪人。 用户通过相关订阅经纪人将订阅引入系统。 新订阅被聚合，分配一个虚拟的开始时间，并通过系统向发布商传播。 每个经纪人以有向无环图和代理向量的形式维护订阅信息。 消息通过系统由发布商通过其关联的发布商连接经纪人发布。 为每个消息分配一个将订阅关联到该消息的消息向量。 根据在每个经纪人进行的消息经纪人和向量经纪人的比较，所发布的消息通过经纪人路由到订户。

公开(公告)号：US08185649B2

公开(公告)日：2012-05-22

申请号：US12166250

申请日：2008-07-01

申请人： Yuanyuan Zhao ,  Daniel Charles Sturman ,  Sumeer Bhola

发明人： Yuanyuan Zhao ,  Daniel Charles Sturman ,  Sumeer Bhola

IPC分类号： G06F15/16

CPC分类号： G06Q10/10

摘要： The present invention is directed to a publish/subscribe system containing a plurality of brokers, a plurality of subscribers and plurality of brokers including publisher connecting brokers, intermediate brokers and subscriber connecting brokers. Subscriptions are introduced into the system by the subscribers through associated subscription brokers. New subscriptions are aggregated, assigned a virtual start time and propagated through the system toward the publishers. Each broker maintains subscription information in the form of a directed acyclic graph and a broker vector. Messages are published through the system by the publishers through their associated publisher connecting brokers. Each message is assigned a message vector associating subscriptions to that message. The published messages are routed through the brokers toward the subscribers in accordance with comparisons of message brokers and vector brokers conducted at each broker.

摘要翻译： 本发明涉及包含多个经纪人，多个订阅者和多个经纪人的发布/订阅系统，包括出版商连接经纪人，中间经纪人和订户连接经纪人。 用户通过相关订阅经纪人将订阅引入系统。 新订阅被聚合，分配一个虚拟的开始时间，并通过系统向发布商传播。 每个经纪人以有向无环图和代理向量的形式维护订阅信息。 消息通过系统由发布商通过其关联的发布商连接经纪人发布。 为每个消息分配一个将订阅关联到该消息的消息向量。 根据在每个经纪人进行的消息经纪人和向量经纪人的比较，所发布的消息通过经纪人路由到订户。

公开(公告)号：US20080288655A1

公开(公告)日：2008-11-20

申请号：US12166250

申请日：2008-07-01

申请人： Yuanyuan Zhao ,  Daniel Charles Sturman ,  Sumeer Bhola

发明人： Yuanyuan Zhao ,  Daniel Charles Sturman ,  Sumeer Bhola

IPC分类号： G06F15/173

CPC分类号： G06Q10/10

摘要： The present invention is directed to a publish/subscribe system containing a plurality of brokers, a plurality of subscribers and plurality of brokers including publisher connecting brokers, intermediate brokers and subscriber connecting brokers. Subscriptions are introduced into the system by the subscribers through associated subscription brokers. New subscriptions are aggregated, assigned a virtual start time and propagated through the system toward the publishers. Each broker maintains subscription information in the form of a directed acyclic graph and a broker vector. Messages are published through the system by the publishers through their associated publisher connecting brokers. Each message is assigned a message vector associating subscriptions to that message. The published messages are routed through the brokers toward the subscribers in accordance with comparisons of message brokers and vector brokers conducted at each broker.

摘要翻译： 本发明涉及包含多个经纪人，多个订阅者和多个经纪人的发布/订阅系统，包括出版商连接经纪人，中间经纪人和订户连接经纪人。 用户通过相关订阅经纪人将订阅引入系统。 新订阅被聚合，分配一个虚拟的开始时间，并通过系统向发布商传播。 每个经纪人以有向无环图和代理向量的形式维护订阅信息。 消息通过系统由发布商通过其关联的发布商连接经纪人发布。 为每个消息分配一个将订阅关联到该消息的消息向量。 根据在每个经纪人进行的消息经纪人和向量经纪人的比较，所发布的消息通过经纪人路由到订户。

公开(公告)号：US07162524B2

公开(公告)日：2007-01-09

申请号：US10177474

申请日：2002-06-21

申请人： Mark C. Astley ,  Joshua S. Auerbach ,  Sumeer K. Bhola ,  Marc A. Kaplan ,  Robert E. Strom ,  Yuanyuan Zhao

发明人： Mark C. Astley ,  Joshua S. Auerbach ,  Sumeer K. Bhola ,  Marc A. Kaplan ,  Robert E. Strom ,  Yuanyuan Zhao

IPC分类号： G06F15/173 ,  G06F15/16

CPC分类号： H04L67/26 ,  H04L67/306 ,  H04L69/329

摘要： A content-based publish/subscribe system for providing gapless message delivery from a publishing client to a subscribing client, the system includes a plurality of brokers operatively coupled to one another via a network. Each of the brokers include at least one processor and are configured as a publisher-hosting broker, a subscriber-hosting broker or an intermediate broker. The subscriber-hosting broker is operatively coupled to the publisher-hosting broker via the network through the intermediate broker. At least a portion of the plurality of brokers are configured so as to eliminate a need for persistent storage of messages at the intermediate broker and to substantially guarantee a gapless delivery of one or more messages transmitted by the publishing client to the subscribing client, even in the presence of a failure in the publish/subscribe system.

摘要翻译： 一种基于内容的发布/订阅系统，用于提供从发布客户端到订阅客户端的无间隙消息传递，该系统包括经由网络可操作地彼此耦合的多个代理。 每个经纪人包括至少一个处理器，并且被配置为发行人托管代理，订户托管代理或中间代理。 订户托管代理通过中间代理经由网络可操作地耦合到发行商托管代理。 多个代理的至少一部分被配置为消除对在中间代理处的消息的持久存储的需要，并且基本上保证发布客户端发送给订阅客户端的一个或多个消息的无间隙传递，即使在 发布/订阅系统中出现故障。

公开(公告)号：US20140136575A1

公开(公告)日：2014-05-15

申请号：US13674021

申请日：2012-11-10

申请人： Yuanyuan Zhao ,  Per Brashers

发明人： Yuanyuan Zhao ,  Per Brashers

IPC分类号： G06F17/30

CPC分类号： G06F16/215

摘要： System and method for log-structured garbage collection are provided. In particular, some embodiments use write pointer to read pointer offsets to enable reclamation of space within a log-structured storage medium (e.g., sequential forward only write mechanisms such as SSD, Tape, Shingled Drives, Flash Drives, etc.). These techniques allow the garbage collection system to reclaim space without copying data from one storage medium to another. Instead of copying the data, various embodiments reset the write and read pointers. In addition, different retention policies can be easily enforced while allowing for efficient garbage collection. For example, in a backup storage, each log-structured media can be designated with a retention time and only allow workloads with the specified retention time to be stored. As a result, the garbage collection incurs only read pointer movements.

摘要翻译： 提供了日志结构垃圾收集的系统和方法。 特别地，一些实施例使用写指针来读取指针偏移量，以使得能够回收日志结构化存储介质（例如，诸如SSD，磁带，混合驱动器，闪存驱动器等顺序前进的写入机制）中的空间。 这些技术允许垃圾回收系统回收空间，而不将数据从一个存储介质复制到另一个存储介质。 代替复制数据，各种实施例重置写入和读取指针。 此外，可以容易地实施不同的保留策略，同时允许有效的垃圾回收。 例如，在备份存储中，可以将每个日志结构化介质指定为保留时间，并且只允许存储具有指定保留时间的工作负载。 结果，垃圾收集只会引起读取指针的移动。