公开(公告)号：US09218220B2

公开(公告)日：2015-12-22

申请号：US13613183

申请日：2012-09-13

申请人： Han Chen ,  Minkyong Kim ,  Hui Lei ,  Ming Li ,  Fan Ye

发明人： Han Chen ,  Minkyong Kim ,  Hui Lei ,  Ming Li ,  Fan Ye

IPC分类号： G06F15/16 ,  G06F9/50 ,  H04L29/08

CPC分类号： G06F9/5083 ,  H04L67/1008 ,  H04L67/18 ,  H04L67/26

摘要： A system and method are disclosed for an elastic and scalable publish/subscribe scheme. Subscription information is received at a dispatcher node. A plurality of matching nodes is selected in an overlay network to store the subscription information on a computer readable storage medium. Upon receiving an event at a dispatching node, at least one of the matching nodes with the stored subscription information is selected to process the event.

摘要翻译： 公开了用于弹性和可扩展的发布/订阅方案的系统和方法。 在分配器节点处接收订阅信息。 在覆盖网络中选择多个匹配节点以将订阅信息存储在计算机可读存储介质上。 在调度节点接收到事件时，选择具有存储的订阅信息的匹配节点中的至少一个来处理该事件。

公开(公告)号：US08627333B2

公开(公告)日：2014-01-07

申请号：US13197461

申请日：2011-08-03

申请人： Han Chen ,  Minkyong Kim ,  Hui Lei ,  Fan Ye

发明人： Han Chen ,  Minkyong Kim ,  Hui Lei ,  Fan Ye

IPC分类号： G06F3/00

CPC分类号： G06F9/546 ,  G06F2209/548

摘要： Embodiments of the invention relate to message queuing. In one embodiment, a request from an application for retrieving a message from a queue is received. The queue is stored across multiple nodes of a distributed storage system. A preference with respect to message order and message duplication associated with the queue is identified. A message sequence index associated with the queue is sampled based on the preference that has been identified. The message is selected in response to the sampling. The message that has been selected is made unavailable to other applications for a given interval of time, while maintaining the message in the queue. The message is sent to the application.

摘要翻译： 本发明的实施例涉及消息队列。 在一个实施例中，接收来自应用程序的来自队列检索消息的请求。 队列存储在分布式存储系统的多个节点上。 识别与队列相关联的消息顺序和消息复制的偏好。 基于已经识别的偏好，对与队列相关联的消息序列索引进行采样。 选择该消息以响应采样。 已经选择的消息在给定的时间间隔内对其他应用程序不可用，同时将消息保留在队列中。 该消息被发送到应用程序。

公开(公告)号：US09250975B2

公开(公告)日：2016-02-02

申请号：US13014501

申请日：2011-01-26

申请人： Han Chen ,  Minkyong Kim ,  Hui Lei ,  Ming Li ,  Fan Ye

发明人： Han Chen ,  Minkyong Kim ,  Hui Lei ,  Ming Li ,  Fan Ye

IPC分类号： G06F15/16 ,  G06F9/50 ,  H04L29/08

CPC分类号： G06F9/5083 ,  H04L67/1008 ,  H04L67/18 ,  H04L67/26

摘要： A system and method are disclosed for an elastic and scalable publish/subscribe scheme. Subscription information is received at a dispatcher node. A plurality of matching nodes are selected in an overlay network to store the subscription information on a computer readable storage medium. Upon receiving an event at a dispatching node, at least one of the matching nodes with the stored subscription information is selected to process the event.

摘要翻译： 公开了用于弹性和可扩展的发布/订阅方案的系统和方法。 在分配器节点处接收订阅信息。 在覆盖网络中选择多个匹配节点以将订阅信息存储在计算机可读存储介质上。 在调度节点接收到事件时，选择具有存储的订阅信息的匹配节点中的至少一个来处理该事件。

公开(公告)号：US20130007131A1

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

申请号：US13613183

申请日：2012-09-13

申请人： Han Chen ,  Minkyong Kim ,  Hui Lei ,  Ming Li ,  Fan Ye

发明人： Han Chen ,  Minkyong Kim ,  Hui Lei ,  Ming Li ,  Fan Ye

IPC分类号： G06F15/16

CPC分类号： G06F9/5083 ,  H04L67/1008 ,  H04L67/18 ,  H04L67/26

摘要： A system and method are disclosed for an elastic and scalable publish/subscribe scheme. Subscription information is received at a dispatcher node. A plurality of matching nodes is selected in an overlay network to store the subscription information on a computer readable storage medium. Upon receiving an event at a dispatching node, at least one of the matching nodes with the stored subscription information is selected to process the event.

摘要翻译： 公开了用于弹性和可扩展的发布/订阅方案的系统和方法。 在分配器节点处接收订阅信息。 在覆盖网络中选择多个匹配节点以将订阅信息存储在计算机可读存储介质上。 在调度节点接收到事件时，选择具有存储的订阅信息的匹配节点中的至少一个来处理该事件。

公开(公告)号：US20120191856A1

公开(公告)日：2012-07-26

申请号：US13014501

申请日：2011-01-26

申请人： HAN CHEN ,  Minkyong Kim ,  Hui Lei ,  Ming Li ,  Fan Ye

发明人： HAN CHEN ,  Minkyong Kim ,  Hui Lei ,  Ming Li ,  Fan Ye

IPC分类号： G06F15/173

CPC分类号： G06F9/5083 ,  H04L67/1008 ,  H04L67/18 ,  H04L67/26

摘要： A system and method are disclosed for an elastic and scalable publish/subscribe scheme. Subscription information is received at a dispatcher node. A plurality of matching nodes are selected in an overlay network to store the subscription information on a computer readable storage medium. Upon receiving an event at a dispatching node, at least one of the matching nodes with the stored subscription information is selected to process the event.

摘要翻译： 公开了用于弹性和可扩展的发布/订阅方案的系统和方法。 在分配器节点处接收订阅信息。 在覆盖网络中选择多个匹配节点以将订阅信息存储在计算机可读存储介质上。 在调度节点接收到事件时，选择具有存储的订阅信息的匹配节点中的至少一个来处理该事件。

公开(公告)号：US20110307789A1

公开(公告)日：2011-12-15

申请号：US12814426

申请日：2010-06-11

申请人： Kyriakos Karenos ,  Minkyong Kim ,  Hui Lei ,  Hao Yang ,  Fan Ye ,  Liangzhao Zeng

发明人： Kyriakos Karenos ,  Minkyong Kim ,  Hui Lei ,  Hao Yang ,  Fan Ye ,  Liangzhao Zeng

IPC分类号： G06F15/173 ,  G06F15/177 ,  G06F3/01

CPC分类号： H04L45/02 ,  H04L41/046 ,  H04L41/12 ,  H04L45/24 ,  H04L45/245 ,  H04L45/64 ,  H04L67/02

摘要： A system may include an overlay network linking a plurality of publishers, a plurality of subscribers, and a plurality of brokers. The overlay network may include a first computer network having a first network protocol carried by a second computer network having a second network protocol. The system may also include an agent carried by each of the publishers, the subscribers, and the brokers that adjust the network's topology based upon collected runtime data of condition of each link within the network and/or broker availability to any publisher and subscriber.

摘要翻译： 系统可以包括链接多个发布者，多个订户和多个经纪人的覆盖网络。 覆盖网络可以包括具有由具有第二网络协议的第二计算机网络承载的第一网络协议的第一计算机网络。 系统还可以包括由发布者，订户和经纪人承担的代理，所述代理基于收集的网络中每个链路的条件的收集的运行时间数据和/或经纪人对任何发布者和订户的可用性来调整网络的拓扑。

公开(公告)号：US09537747B2

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

申请号：US12814426

申请日：2010-06-11

申请人： Kyriakos Karenos ,  Minkyong Kim ,  Hui Lei ,  Hao Yang ,  Fan Ye ,  Liangzhao Zeng

发明人： Kyriakos Karenos ,  Minkyong Kim ,  Hui Lei ,  Hao Yang ,  Fan Ye ,  Liangzhao Zeng

IPC分类号： H04L12/709 ,  H04L12/751 ,  H04L12/707 ,  H04L12/715 ,  H04L29/08

CPC分类号： H04L45/02 ,  H04L41/046 ,  H04L41/12 ,  H04L45/24 ,  H04L45/245 ,  H04L45/64 ,  H04L67/02

摘要： A system may include an overlay network linking a plurality of publishers, a plurality of subscribers, and a plurality of brokers. The overlay network may include a first computer network having a first network protocol carried by a second computer network having a second network protocol. The system may also include an agent carried by each of the publishers, the subscribers, and the brokers that adjust the network's topology based upon collected runtime data of condition of each link within the network and/or broker availability to any publisher and subscriber.

摘要翻译： 系统可以包括链接多个发布者，多个订户和多个经纪人的覆盖网络。 覆盖网络可以包括具有由具有第二网络协议的第二计算机网络承载的第一网络协议的第一计算机网络。 系统还可以包括由发布者，订户和经纪人承担的代理，所述代理基于收集的网络中每个链路的条件的收集的运行时间数据和/或经纪人对任何发布者和订户的可用性来调整网络的拓扑。

公开(公告)号：US20110125921A1

公开(公告)日：2011-05-26

申请号：US12625437

申请日：2009-11-24

申请人： Kyriakos Karenos ,  Minkyong Kim ,  Hui Lei ,  Dimitrios Pendarakis ,  Hao Yang ,  Fan Ye

发明人： Kyriakos Karenos ,  Minkyong Kim ,  Hui Lei ,  Dimitrios Pendarakis ,  Hao Yang ,  Fan Ye

IPC分类号： G06F15/173

CPC分类号： H04L45/00 ,  H04L45/24 ,  H04L45/302

摘要： Techniques for transmitting data according to at least one quality of service requirement. A message path is calculated specifying a sequence of broker computers selected from a network of interconnected broker computers. The message path is statistically estimated to fulfill the at least one quality of service requirement. Quality of service metrics are received about the network of interconnected broker computers. If the message path is determined not to fulfill the quality of service requirement, a new message path is calculated specifying a new sequence of broker computers selected from the network of interconnected broker computers. The new message path is statistically estimated to fulfill the at least one quality of service requirement.

摘要翻译： 根据至少一种服务质量要求传输数据的技术。 计算消息路径，指定从互连代理计算机的网络中选择的代理计算机的序列。 统计估计消息路径以满足至少一个服务质量要求。 收到关于互联经纪电脑网络的服务质量指标。 如果消息路径被确定为不满足服务质量要求，则计算新的消息路径，指定从互连代理计算机的网络中选择的新的代理计算机序列。 统计估计新消息路径以满足至少一个服务质量要求。

公开(公告)号：US08489722B2

公开(公告)日：2013-07-16

申请号：US12625437

申请日：2009-11-24

申请人： Kyriakos Karenos ,  Minkyong Kim ,  Hui Lei ,  Dimitrios Pendarakis ,  Hao Yang ,  Fan Ye

发明人： Kyriakos Karenos ,  Minkyong Kim ,  Hui Lei ,  Dimitrios Pendarakis ,  Hao Yang ,  Fan Ye

IPC分类号： G06F15/173 ,  H04L12/56

CPC分类号： H04L45/00 ,  H04L45/24 ,  H04L45/302

摘要： Techniques for transmitting data according to at least one quality of service requirement. A message path is calculated specifying a sequence of broker computers selected from a network of interconnected broker computers. The message path is statistically estimated to fulfill the at least one quality of service requirement. Quality of service metrics are received about the network of interconnected broker computers. If the message path is determined not to fulfill the quality of service requirement, a new message path is calculated specifying a new sequence of broker computers selected from the network of interconnected broker computers. The new message path is statistically estimated to fulfill the at least one quality of service requirement.

摘要翻译： 根据至少一种服务质量要求传输数据的技术。 计算消息路径，指定从互连代理计算机的网络中选择的代理计算机的序列。 统计估计消息路径以满足至少一个服务质量要求。 收到关于互联经纪电脑网络的服务质量指标。 如果消息路径被确定为不满足服务质量要求，则计算新的消息路径，指定从互连代理计算机的网络中选择的新的代理计算机序列。 统计估计新消息路径以满足至少一个服务质量要求。

公开(公告)号：US20130275569A1

公开(公告)日：2013-10-17

申请号：US13447936

申请日：2012-04-16

申请人： Seraphin Bernard Calo ,  Raheleh B. Dilmaghani ,  Douglas M. Freimuth ,  Raghu K. Ganti ,  Keith William Grueneberg ,  Fan Ye

发明人： Seraphin Bernard Calo ,  Raheleh B. Dilmaghani ,  Douglas M. Freimuth ,  Raghu K. Ganti ,  Keith William Grueneberg ,  Fan Ye

IPC分类号： G06F15/173

CPC分类号： H04L29/06 ,  H04L29/08072 ,  H04L67/22 ,  H04W4/00

摘要： A common infrastructure collects diverse data and information from large numbers of mobile devices and traditional sensors at Internet scale to support multiple different applications simultaneously. The infrastructure includes a backend phenomenon layer that provides high level abstractions to applications such that they can express their data and information needs in a declarative fashion and coordinate the data collection and processing activities for all applications. An edge layer that manages devices, receives collection requirements from the backend layer, configures and instructs devices for data collection, and conducts aggregation and primitive processing of the data. This layer contains network edge nodes, such as base stations in a cellular network. Each node manages a set of local data generating networked devices. The device agent data layer using common agents on the data generating networked devices receives data collection instructions from the edge layer, performs data collection.