Transport-neutral in-order delivery in a distributed system
    14.
    发明授权
    Transport-neutral in-order delivery in a distributed system 有权
    在分布式系统中的传输中立的按顺序传送

    公开(公告)号:US07747894B2

    公开(公告)日:2010-06-29

    申请号:US11146644

    申请日:2005-06-06

    IPC分类号: G06F11/00

    CPC分类号: H04L67/32

    摘要: A transport-neutral in-order delivery in a distributed environment is provided. Typically, in-order delivery guarantees that sequential orders received by a transport engine are sent out in the same order they are received. Such delivery may be forwarded either to another transport engine or to some application. In case there is a failure of delivery of messages in a stream, the messages are either resubmitted, suspended, or moved to backup. A user or administrator can configure the desired action. Additionally, any stream can be manually aborted or a specified port can be unenlisted. Deliverable streams of messages are locked on to a back-end transport engines or applications and dequeued sequentially unless one of the above mentioned failure scenarios occurs.

    摘要翻译: 在分布式环境中提供运输中立的按顺序交货。 通常,按顺序传送保证传输引擎接收到的顺序是按照接收到的顺序发出的。 这种传送可以转发到另一个传输引擎或某些应用。 如果流中的消息传递失败,则消息将被重新提交,暂停或移动到备份。 用户或管理员可以配置所需的操作。 此外,任何流都可以手动中止或指定的端口可以取消登录。 可传递的消息流被锁定到后端传输引擎或应用程序,并且顺序排队,除非发生上述故障情形之一。

    Optimizing message transmission and delivery in a publisher-subscriber model
    15.
    发明申请
    Optimizing message transmission and delivery in a publisher-subscriber model 有权
    在发布商订阅者模型中优化消息传输和传递

    公开(公告)号:US20060277319A1

    公开(公告)日:2006-12-07

    申请号:US11144102

    申请日:2005-06-03

    IPC分类号: G06F15/173

    CPC分类号: H04L67/26 H04L51/00 H04L51/26

    摘要: Systems and methods for reducing the latency incurred during the publication of a message in a message publication system are provided. In a message publication system wherein the publishing component and the receiving component are located within the same processing space, several of the latency components that are usually unavoidably incurred may be eliminated. In such a system, the messaging queue is not used as a medium between the two components but is instead used as a secondary back-up storage. This results in the elimination of one latency component as the message is directly published from the publishing component to the receiving component. Further time reductions or optimizations occur when the durability, or reliability, of the message publication is not a concern and the messaging queue can be completely disregarded. Yet another optimization occurs when the identity of the subscriber is known in advance by the publisher.

    摘要翻译: 提供了用于减少在消息发布系统中发布消息期间发生的延迟的系统和方法。 在其中发布组件和接收组件位于相同处理空间内的消息发布系统中,可以消除通常不可避免地引起的几个等待时间组件。 在这样的系统中,消息队列不用作两个组件之间的介质,而是用作辅助备用存储。 这导致消息从发布组件直接发布到接收组件时消除一个延迟组件。 当消息出版物的耐久性或可靠性不是关心且消息队列可以被完全忽视时,会发生进一步的时间缩减或优化。 当发布者预先知道用户的身份时,会发生另一个优化。

    Transport-neutral in-order delivery in a distributed system
    16.
    发明申请
    Transport-neutral in-order delivery in a distributed system 有权
    在分布式系统中的传输中立的按顺序传送

    公开(公告)号:US20060274727A1

    公开(公告)日:2006-12-07

    申请号:US11146644

    申请日:2005-06-06

    IPC分类号: H04L12/66

    CPC分类号: H04L67/32

    摘要: A transport-neutral in-order delivery in a distributed environment is provided. Typically, in-order delivery guarantees that sequential orders received by a transport engine are sent out in the same order they are received. Such delivery may be forwarded either to another transport engine or to some application. In case there is a failure of delivery of messages in a stream, the messages are either resubmitted, suspended, or moved to backup. A user or administrator can configure the desired action. Additionally, any stream can be manually aborted or a specified port can be unenlisted. Deliverable streams of messages are locked on to a back-end transport engines or applications and dequeued sequentially unless one of the above mentioned failure scenarios occurs.

    摘要翻译: 在分布式环境中提供运输中立的按顺序交货。 通常,按顺序传送保证传输引擎接收到的顺序是按照接收到的顺序发出的。 这种传送可以被转发到另一个传输引擎或某些应用。 如果流中的消息传递失败,则消息将被重新提交,暂停或移动到备份。 用户或管理员可以配置所需的操作。 此外,任何流都可以手动中止或指定的端口可以取消登录。 可传递的消息流被锁定到后端传输引擎或应用程序,并且顺序排队,除非出现上述任何一种故障情况之一。

    Dynamic process recovery in a distributed environment
    17.
    发明申请
    Dynamic process recovery in a distributed environment 有权
    分布式环境中的动态过程恢复

    公开(公告)号:US20060277538A1

    公开(公告)日:2006-12-07

    申请号:US11143536

    申请日:2005-06-02

    IPC分类号: G06F9/44

    CPC分类号: G06F11/1438

    摘要: Methods for providing dynamic process recovery that supports recovery of event driven services. The present invention addresses situations where a service-hosting process fails as well as all of the services which were running in that process. To recover from this scenario, the present invention restarts the services a different process from a last know good state. The present invention also provides for situations where a process is shut down in a controlled manner, but the services running within it are still able to drive. Here again, the services are restarted in a secondary process. The recovery modal described here, therefore, advantageously addresses a problem in the design of a distributed event-driven environment.

    摘要翻译: 提供支持事件驱动服务恢复的动态过程恢复的方法。 本发明解决了服务承载过程失败的情况以及在该过程中运行的所有服务。 为了从这种情况中恢复,本发明重新启动与最近的知道状态不同的进程的服务。 本发明还提供了以受控的方式关闭进程的情况,但是其中运行的服务仍然能够驱动。 再次,这些服务在次要过程中重新启动。 因此,这里描述的恢复模式有利地解决了分布式事件驱动环境的设计中的问题。

    Providing flow control and moderation in a distributed message processing system
    18.
    发明申请
    Providing flow control and moderation in a distributed message processing system 有权
    在分布式消息处理系统中提供流量控制和审核

    公开(公告)号:US20060277317A1

    公开(公告)日:2006-12-07

    申请号:US11144412

    申请日:2005-06-03

    IPC分类号: G06F15/16

    摘要: Systems and methods for controlling the work load on a distributed system comprising a plurality of stages are provided. The capacity of a present stage is monitored, using either various resources of the present stage or rates of work completion and work receipt of the present stage. Information indicating the capacity of a succeeding stage are obtained and communicated to the present stage. The monitored capacity information of the present stage and the communicated information of the succeeding stage, either alone or in combination, are used to determine if a throttling action is necessary to control the load of work at the present stage. A provided throttling technique inserts an appropriate delay before the present stage to allow the present stage to process an amount of work without saturating the capacity of the present stage. This technique is applied at each stage of the distributed system to control the work load of the overall system by controlling the work load at each stage.

    摘要翻译: 提供了用于控制包括多个级的分布式系统上的工作负载的系统和方法。 使用现阶段的各种资源或工作完成率和现阶段工作收到情况监测现阶段的能力。 获得指示后续能力的信息并传达到现阶段。 目前阶段的监控能力信息和后续阶段的通信信息单独或组合用于确定是否需要节流动作来控制现阶段的工作负荷。 提供的节流技术在当前阶段之前插入适当的延迟,以允许当前阶段处理一定量的工作而不使本阶段的容量饱和。 该技术应用于分布式系统的各个阶段,通过控制各阶段的工作负荷来控制整个系统的工作负荷。

    Asynchronous communication in an unstable network
    19.
    发明授权
    Asynchronous communication in an unstable network 有权
    不稳定网络中的异步通信

    公开(公告)号:US08755397B2

    公开(公告)日:2014-06-17

    申请号:US13368705

    申请日:2012-02-08

    摘要: Embodiments are directed to promptly reestablishing communication between nodes in a dynamic computer network and dynamically maintaining an address list in an unstable network. A computer system sends a message to other message queuing nodes in a network, where each node in the message queuing network includes a corresponding persistent unique global identifier. The computer system maintains a list of unique global identifiers and the current network addresses of those network nodes from which the message queuing node has received a message or to which the message queuing node has sent a message. The computer system goes offline for a period of time and upon coming back online, sends an announcement message to each node maintained in the list indicating that the message queuing node is ready for communication in the message queuing network, where each message includes the destination node's globally unique identifier and the node's current network address.

    摘要翻译: 实施例旨在及时重新建立动态计算机网络中节点之间的通信,并动态地维护不稳定网络中的地址列表。 计算机系统向网络中的其他消息队列节点发送消息,其中消息队列网络中的每个节点包括对应的持久唯一全局标识符。 计算机系统维护唯一全局标识符的列表以及消息队列节点已经从其接收到消息或消息队列节点已向其发送消息的那些网络节点的当前网络地址。 计算机系统脱机一段时间,并且在返回在线时,向列表中维护的每个节点发送通知消息,指示消息队列节点准备好在消息队列网络中进行通信,其中每个消息包括目的地节点 全局唯一标识符和节点的当前网络地址。

    Optimizing message transmission and delivery in a publisher-subscriber model
    20.
    发明授权
    Optimizing message transmission and delivery in a publisher-subscriber model 有权
    在发布商订阅者模型中优化消息传输和传递

    公开(公告)号:US08028085B2

    公开(公告)日:2011-09-27

    申请号:US11144102

    申请日:2005-06-03

    IPC分类号: G06F15/173

    CPC分类号: H04L67/26 H04L51/00 H04L51/26

    摘要: Systems and methods for reducing the latency incurred during the publication of a message in a message publication system are provided. In a message publication system wherein the publishing component and the receiving component are located within the same processing space, several of the latency components that are usually unavoidably incurred may be eliminated. In such a system, the messaging queue is not used as a medium between the two components but is instead used as a secondary back-up storage. This results in the elimination of one latency component as the message is directly published from the publishing component to the receiving component. Further time reductions or optimizations occur when the durability, or reliability, of the message publication is not a concern and the messaging queue can be completely disregarded. Yet another optimization occurs when the identity of the subscriber is known in advance by the publisher.

    摘要翻译: 提供了用于减少在消息发布系统中发布消息期间发生的延迟的系统和方法。 在其中发布组件和接收组件位于相同处理空间内的消息发布系统中,可以消除通常不可避免地引起的几个等待时间组件。 在这样的系统中,消息队列不用作两个组件之间的介质,而是用作辅助备用存储。 这导致消息从发布组件直接发布到接收组件时消除一个延迟组件。 当消息出版物的耐久性或可靠性不是关心且消息队列可以被完全忽视时,会发生进一步的时间缩减或优化。 当订阅者的身份由发布者预先知道时,发生另一优化。