会员体验
专利管家(专利管理)
工作空间(专利管理)
风险监控(情报监控)
数据分析(专利分析)
侵权分析(诉讼无效)
联系我们
交流群
官方交流:
QQ群: 891211   
微信请扫码    >>>
现在联系顾问~
热词
    • 2. 发明授权
    • Message sequencing for ordered multicasting of a message across a routing network
    • 通过路由网络对消息进行有序组播的消息排序
    • US06760340B1
    • 2004-07-06
    • US09280530
    • 1999-03-30
    • Guruduth Somasekhara BanavarTushar Deepak ChandraKevan Lee MillerRobert Evan StromDaniel Charles SturmanMichael James Ward
    • Guruduth Somasekhara BanavarTushar Deepak ChandraKevan Lee MillerRobert Evan StromDaniel Charles SturmanMichael James Ward
    • H04L1228
    • H04L12/1881H04L12/1868
    • A technique for reliably multicasting a message within a router network in a sequenced order with other messages is provided. At least one special router in the network has associated persistent storage for sequencing a message being routed to one or more clients. When a message is received at this sequencer node, the sequencer places a sequence number for the message in persistent storage and sends a sequencing acknowledgment back to those routers to which the message was originally routed, as well as back towards the source of the message. The sequencer acknowledgment includes the message id, and the sequencing number. When the sequencer acknowledgment is received by a router, it looks up the routing information from the original message, and sends the acknowledgment to those neighboring routers to which the original message was sent, excluding the link from which the sequencer acknowledgment was received. If the original message corresponding to the sequencer acknowledgment was buffered at this router waiting to be delivered, the message is then delivered to its client nodes.
    • 提供了一种以其他消息的顺序可靠地组播路由器网络内的消息的技术。 网络中至少有一个特殊路由器具有关联的持久存储器,用于对正在路由到一个或多个客户端的消息进行排序。 当在该定序器节点处接收到消息时,定序器将消息的序列号放置在持久存储器中,并将排序确认发送回消息最初路由到的那些路由器,以及返回到消息的源。 定序器确认包括消息标识和序列号。 当定序器确认由路由器接收时,它从原始消息中查找路由信息,并将确认发送给发送了原始消息的相邻路由器,不包括接收定序器确认的链路。 如果在等待传递的路由器上缓冲对应于定序器确认的原始消息,则将该消息传递给其客户机节点。
    • 3. 发明授权
    • Message logging for reliable multicasting across a routing network
    • 通过路由网络进行可靠组播的消息记录
    • US07050432B1
    • 2006-05-23
    • US09281421
    • 1999-03-30
    • Guruduth Somasekhara BanavarTushar Deepak ChandraKevan Lee MillerRobert Evan StromDaniel Charles SturmanMichael James Ward
    • Guruduth Somasekhara BanavarTushar Deepak ChandraKevan Lee MillerRobert Evan StromDaniel Charles SturmanMichael James Ward
    • H04L12/28H04L12/56
    • H04L12/1868H04L12/1895H04L67/26H04L67/327
    • A technique for reliably multicasting a message within a router network is provided. At least one special router in the network has associated persistent storage for logging a message being routed to one or more clients. When a message is received at this logger node, the logger places the message in persistent storage and sends a logging acknowledgment back to those routers to which the message was originally routed, as well as back towards the source of the message. The logger acknowledgment includes the message id, the logger id, and a logging number. When the logger acknowledgment is received by a router, it looks up the routing information from the original message, and sends the acknowledgment to those neighboring routers to which the original message was sent, excluding the link from which the logger acknowledgment was received. If the original message corresponding to the logger acknowledgment was buffered at this router waiting to be delivered, the message is then delivered to its client nodes. Processes for recovering from node or link failure within the router network, and for at most once delivery of messages, at least once delivery of messages, and exactly once delivery of messages are also provided.
    • 提供了一种在路由器网络内可靠地组播消息的技术。 网络中至少有一个特殊路由器具有关联的持久存储器,用于记录被路由到一个或多个客户端的消息。 当在此记录器节点接收到消息时,记录器将消息放置在持久存储器中,并将记录确认发送回消息最初路由到的那些路由器,并返回消息的源。 记录器确认包括消息标识,记录器ID和日志记录号。 当路由器接收到记录器确认时,它将从原始消息中查找路由信息,并将确认发送给发送原始消息的相邻路由器,不包括接收到记录器确认的链路。 如果与该记录器确认相对应的原始消息在等待传送的路由器中被缓冲,则该消息被传送到其客户机节点。 还提供了用于从路由器网络内的节点或链路故障恢复的过程,以及至少一次传送消息,至少一次传送消息,以及一次传送消息。
    • 8. 发明授权
    • Method for applying stochastic control optimization for messaging systems
    • 应用消息系统的随机控制优化的方法
    • US07792038B2
    • 2010-09-07
    • US12115742
    • 2008-05-06
    • Robert Evan Strom
    • Robert Evan Strom
    • H04L12/56
    • H04L67/322H04L67/325
    • A computer implemented method, apparatus, and computer usable program code for controlling when to send messages in a stream processing system. A policy is determined by utilizing probability statistics and a cost function prior to stream processing. The policy specifies under which conditions a message is sent eagerly and under which other conditions the message is delayed. A filter is operated during stream processing that selects which of the messages to send from a sending transform based upon a threshold. A controller is operated during stream processing that observes a current state of a receiving transform and that applies the policy based on the current state to determine whether to change the threshold.
    • 一种用于控制在流处理系统中发送消息的时间的计算机实现的方法,装置和计算机可用程序代码。 策略通过在流处理之前利用概率统计和成本函数来确定。 该策略指定在哪个条件下热切地发送消息,在哪个条件下消息被延迟。 在流处理期间操作滤波器,其基于阈值选择要从发送变换发送的哪个消息。 在流处理期间操作控制器,其观察接收变换的当前状态,并且基于当前状态应用策略以确定是否改变阈值。
    • 9. 发明申请
    • DISTRIBUTED MESSAGING SYSTEM SUPPORTING STATEFUL SUBSCRIPTIONS
    • 分布式消息传递系统支持强大的订阅
    • US20080209440A1
    • 2008-08-28
    • US12114464
    • 2008-05-02
    • Roman GinisRobert Evan Strom
    • Roman GinisRobert Evan Strom
    • G06F9/54
    • G06F9/542H04L67/28H04L67/2823H04L67/288
    • A distributed messaging system supporting stateful subscriptions is provided. A stateful publish-subscribe system extends the functionality of the content-based approach to include more general state-valued expressions. Stateful subscriptions may refer to one or more message histories and may include more complex expressions. Therefore, subscribers may receive different information than that provided in the published messages. A plurality of broker machines is provided to deliver messages sent by publishing clients toward subscribing clients based upon the contents of the messages and stateful transformations requested by the subscribing clients. Subscription specifications are analyzed by a compiler and converted into a collection of transform objects and view objects. The messaging system builds a structure containing all transform objects and view objects needed for all intermediate and subscribed views of all subscriptions. This messaging system uses this structure to allocate transform objects and view objects to broker machines in the overlay network.
    • 提供了支持有状态订阅的分布式消息传递系统。 有状态的发布订阅系统扩展了基于内容的方法的功能,以包括更一般的状态表达式。 有状态订阅可以指一个或多个消息历史,并且可以包括更复杂的表达。 因此,订阅者可以接收与发布的消息中提供的信息不同的信息。 提供多个代理机器,用于根据订阅客户端请求的消息内容和有状态转换,将发布客户端发送的消息发送给订阅客户端。 订阅规范由编译器分析,并转换成变换对象和查看对象的集合。 消息传递系统构建包含所有转换对象的结构,并查看所有订阅的所有中间和订阅视图所需的对象。 此消息传递系统使用此结构来分配转换对象并将对象查看到覆盖网络中的代理机器。
    • 10. 发明授权
    • Dynamic component placement in an event-driven component-oriented network data processing system
    • 动态组件放置在事件驱动的面向组件的网络数据处理系统中
    • US07962650B2
    • 2011-06-14
    • US12100915
    • 2008-04-10
    • Geetika Tewari LakshmananChitra DoraiRobert Evan Strom
    • Geetika Tewari LakshmananChitra DoraiRobert Evan Strom
    • G06F15/173
    • H04L45/22H04L45/02H04L45/08H04L45/122
    • Method, system and computer usable program code for dynamic component placement in an event processing system having producers, consumers, a plurality of nodes between the producers and the consumers, and a flow graph representing computational components to be executed between the producers and the consumers. A description of a change to the system is received. At each node, next-hop neighbor nodes for each consumer are identified. A routing value is assigned to each next-hop neighbor node for each consumer. Using the routing values in a context of the change, a performance cost of the system is estimated based on hypothetical changed placements of the computational components at nodes along paths from a producer to a consumer through the next-hop neighbor nodes for each consumer, and a changed placement of the computational components that minimizes performance cost of the system relative to the hypothetical changed placements is selected.
    • 在具有生产者,消费者,生产者和消费者之间的多个节点的事件处理系统中的动态组件放置的方法,系统和计算机可用程序代码以及表示在生产者和消费者之间执行的计算组件的流程图。 接收到对系统更改的描述。 在每个节点处,识别每个消费者的下一跳邻居节点。 路由值被分配给每个消费者的每个下一跳邻居节点。 在变化的上下文中使用路由值,系统的性能成本基于通过每个消费者的下一跳邻居节点沿着从生产者到消费者的路径的节点处的计算组件的假想改变的布局来估计,以及 选择最小化系统的性能成本相对于假设的改变的位置的计算组件的改变的位置。