Filtering application messages in a high speed, low latency data communications environment
    1.
    发明授权
    Filtering application messages in a high speed, low latency data communications environment 有权
    在高速,低延迟的数据通信环境中过滤应用程序消息

    公开(公告)号:US07917912B2

    公开(公告)日:2011-03-29

    申请号:US11728850

    申请日:2007-03-27

    IPC分类号: G06F13/00 G06F15/16

    CPC分类号: H04L63/0227 H04L67/327

    摘要: Methods, systems, and products are disclosed for filtering application messages in a high speed, low latency data communications environment that include: receiving an application message in a transport engine of a message receiving device from a message transmitting device, the application message having a message contents label and a collision indicator, the message contents label representing contents of the application message, the collision indicator specifying whether the message contents label represents different contents in at least one other application message; determining, by the transport engine, whether contents of the application message satisfy a transport layer constraint in dependence upon the message contents label; providing, by the transport engine, the application message and the collision indicator to messaging middleware of the message receiving device if the contents of the application message satisfy the transport layer constraint; and administering the application message, by the messaging middleware, in dependence upon the collision indicator.

    摘要翻译: 公开了用于在高速,低延迟的数据通信环境中过滤应用消息的方法,系统和产品,其包括:从消息发送设备在消息接收设备的传输引擎中接收应用消息,所述应用消息具有消息 内容标签和冲突指示符,所述消息内容标签表示所述应用消息的内容,所述冲突指示符指定所述消息内容标签是否表示至少一个其他应用消息中的不同内容; 由所述传输引擎确定所述应用消息的内容是否根据所述消息内容标签满足传输层约束; 如果应用消息的内容满足传输层约束,则通过传输引擎将应用消息和冲突指示符提供给消息接收设备的消息中间件; 以及由所述消息收发中间件根据所述冲突指示器来管理所述应用消息。

    Filtering application messages in a high speed, low latency data communications environment
    2.
    发明申请
    Filtering application messages in a high speed, low latency data communications environment 有权
    在高速,低延迟的数据通信环境中过滤应用程序消息

    公开(公告)号:US20080244017A1

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

    申请号:US11728850

    申请日:2007-03-27

    IPC分类号: G06F15/16

    CPC分类号: H04L63/0227 H04L67/327

    摘要: Methods, systems, and products are disclosed for filtering application messages in a high speed, low latency data communications environment that include: receiving an application message in a transport engine of a message receiving device from a message transmitting device, the application message having a message contents label and a collision indicator, the message contents label representing contents of the application message, the collision indicator specifying whether the message contents label represents different contents in at least one other application message; determining, by the transport engine, whether contents of the application message satisfy a transport layer constraint in dependence upon the message contents label; providing, by the transport engine, the application message and the collision indicator to messaging middleware of the message receiving device if the contents of the application message satisfy the transport layer constraint; and administering the application message, by the messaging middleware, in dependence upon the collision indicator.

    摘要翻译: 公开了用于在高速,低延迟的数据通信环境中过滤应用消息的方法,系统和产品,其包括:从消息发送设备在消息接收设备的传输引擎中接收应用消息,所述应用消息具有消息 内容标签和冲突指示符,所述消息内容标签表示所述应用消息的内容,所述冲突指示符指定所述消息内容标签是否表示至少一个其他应用消息中的不同内容; 由所述传输引擎确定所述应用消息的内容是否根据所述消息内容标签满足传输层约束; 如果应用消息的内容满足传输层约束,则通过传输引擎将应用消息和冲突指示符提供给消息接收设备的消息中间件; 以及由所述消息收发中间件根据所述冲突指示器来管理所述应用消息。

    RELIABLE MESSAGING USING A MESSAGE STREAM IN A HIGH SPEED, LOW LATENCY DATA COMMUNICATIONS ENVIRONMENT
    3.
    发明申请
    RELIABLE MESSAGING USING A MESSAGE STREAM IN A HIGH SPEED, LOW LATENCY DATA COMMUNICATIONS ENVIRONMENT 审中-公开
    在高速,低端数据通信环境中使用信息流可靠的消息传递

    公开(公告)号:US20070300235A1

    公开(公告)日:2007-12-27

    申请号:US11426857

    申请日:2006-06-27

    IPC分类号: G06F9/46 H04L9/32

    CPC分类号: H04L69/326

    摘要: Methods, apparatus, and products are disclosed for reliable messaging using a message stream in a high speed, low latency data communications environment that include brokering, by a stream administration server, establishment of an active message stream to a subscribing client device from an active feed adapter; receiving, in a transport engine of the subscribing client device from the active feed adapter on an active message stream, active application messages encapsulated in active transport packets; receiving, by the transport engine from the active feed adapter, an active transport packet containing an active mapping; identifying, by the transport engine in dependence upon active sequence numbers, a missing active transport packet; identifying, by the transport engine, missing active application messages of the missing active transport packet in dependence upon the active mapping; and requesting, by the transport engine, transmission of the missing active application messages from the active feed adapter.

    摘要翻译: 公开了方法,装置和产品,用于使用消息流在高速,低延迟的数据通信环境中的可靠消息传递,其包括由流管理服务器从活动馈送向订阅客户端设备建立活动消息流 适配器; 在活动消息流中从主动馈送适配器在订阅客户端设备的传输引擎中接收封装在活动传输分组中的活动应用消息; 通过传输引擎从主动馈送适配器接收包含活动映射的主动传输分组; 通过传输引擎根据活动序列号识别丢失的活动传输分组; 由传输引擎根据主动映射来识别丢失的活动传输分组的活动应用消息; 并且由传输引擎请求从活动馈送适配器传输丢失的活动应用消息。

    SELECTING APPLICATION MESSAGES FROM AN ACTIVE FEED ADAPTER AND A BACKUP FEED ADAPTER FOR APPLICATION-LEVEL DATA PROCESSING IN A HIGH SPEED, LOW LATENCY DATA COMMUNICATIONS ENVIRONMENT
    4.
    发明申请
    SELECTING APPLICATION MESSAGES FROM AN ACTIVE FEED ADAPTER AND A BACKUP FEED ADAPTER FOR APPLICATION-LEVEL DATA PROCESSING IN A HIGH SPEED, LOW LATENCY DATA COMMUNICATIONS ENVIRONMENT 审中-公开
    从高速,低位数据通信环境中选择用于应用级数据处理的主动进给适配器和备份进纸适配器的应用程序消息

    公开(公告)号:US20070300234A1

    公开(公告)日:2007-12-27

    申请号:US11426819

    申请日:2006-06-27

    IPC分类号: G06F9/46

    摘要: Selecting application messages from redundant feed adapters for application-level data processing in a high speed, low latency data communications environment, including brokering establishment of an active message stream to a subscribing client device from an active feed adapter; brokering establishment of a backup message stream to the subscribing client device from a backup feed adapter; receiving active transport packets in a transport engine of the subscribing client device from the active feed adapter; receiving and buffering backup transport packets; identifying a missing active transport packet; determining whether a corresponding backup transport packet for the missing active transport packet has been received from the backup transport adapter; and replacing the missing active transport packet with the corresponding backup transport packet for further data processing if the corresponding backup transport packet for the missing active transport packet has been received.

    摘要翻译: 从冗余馈送适配器中选择应用消息以在高速,低延迟数据通信环境中进行应用级数据处理,包括从活动馈送适配器向订阅客户端设备建立活动消息流; 从备用馈送适配器代理建立备用消息流到订阅客户端设备; 在所述订阅客户端设备的传输引擎中从所述活动馈送适配器接收活动传输分组; 接收和缓冲备份传输数据包; 识别丢失的活动传输分组; 确定是否已经从备用传输适配器接收到用于丢失的活动传输分组的对应的备份传输分组; 并且如果已经接收到用于丢失的活动传输分组的对应的备份传输分组,则用相应的备份传输分组替换丢失的活动传输分组用于进一步的数据处理。

    Reliable messaging using message streams in a high speed, low latency data communications environment
    5.
    发明申请
    Reliable messaging using message streams in a high speed, low latency data communications environment 审中-公开
    在高速,低延迟的数据通信环境中使用消息流的可靠消息

    公开(公告)号:US20080104266A1

    公开(公告)日:2008-05-01

    申请号:US11586076

    申请日:2006-10-25

    IPC分类号: G06F15/16

    CPC分类号: H04L51/30

    摘要: Methods, apparatus, and products are disclosed for reliable messaging using message streams in a high speed, low latency data communications environment that include: receiving, in a transport engine of a message receiving device from an active message sending device, active transport packets on an active message stream established from the active message sending device to the message receiving device, the active message sending device encapsulating active application messages in the active transport packets; identifying, by the transport engine, a missing active application message from the active message sending device; and requesting, by the transport engine from a backup message sending device, transmission of a backup application message that corresponds to the missing active application message, the backup message sending device encapsulating backup application messages in backup transport packets for transmission on a backup message stream, each backup application message representing a duplicate of a corresponding active application message.

    摘要翻译: 公开了用于在高速,低延迟数据通信环境中使用消息流的可靠消息的方法,装置和产品,包括:在来自活动消息发送设备的消息接收设备的传输引擎中,在主动传输分组 主动消息流从活动消息发送设备建立到消息接收设备,活动消息发送设备将活动应用消息封装在活动传输分组中; 由所述传输引擎识别来自所述活动消息发送设备的丢失的活动应用消息; 并且通过传输引擎从备份消息发送设备发送与所述丢失的活动应用消息相对应的备份应用消息的传输,所述备份消息发送设备将备份应用消息封装在备份传输分组中以便在备份消息流上传输, 每个备份应用程序消息表示对应的活动应用程序消息的副本。

    Group communication system achieving efficient total order and state synchronization in a multi-tier environment
    6.
    发明授权
    Group communication system achieving efficient total order and state synchronization in a multi-tier environment 失效
    组通信系统在多层环境中实现高效的总体顺序和状态同步

    公开(公告)号:US08428065B2

    公开(公告)日:2013-04-23

    申请号:US11764233

    申请日:2007-06-18

    IPC分类号: H04L12/28 H04L12/56

    CPC分类号: H04L12/1877 H04L12/1881

    摘要: A group communication service maintains synchronization limiting the group to the processing entities that receive a plurality of source message streams from sources outside the group and transmit delivery message streams to destinations that are outside the group. Synchronization of message ordering and other state synchronization directives are communicated from a leader exclusively to other group members. Once having declared themselves to be synchronized and active by a reply protocol message, which is an opaque object and is interpreted by an application layer, the processing entities independently process the source message streams in accordance with the order specified in the directives, without requiring additional sequencing information from another processing entity.

    摘要翻译: 组通信服务维护同步,将组限制到从组外的源接收多个源消息流的处理实体,并将传送消息流发送到组外的目的地。 消息排序和其他状态同步指令的同步从领导者专门传达给其他组成员。 一旦声明自己被一个不透明对象的应答协议消息(由协议消息)同步并且被应用层解释,则处理实体根据指令中指定的顺序独立地处理源消息流,而不需要额外的 来自另一个处理实体的排序信息。

    Migration of Message Topics over Multicast Streams and Groups
    10.
    发明申请
    Migration of Message Topics over Multicast Streams and Groups 审中-公开
    通过组播流和组迁移消息主题

    公开(公告)号:US20080031243A1

    公开(公告)日:2008-02-07

    申请号:US11461495

    申请日:2006-08-01

    IPC分类号: H04L12/56

    摘要: A method for migrating data transmitted from a transmitter to a receiver over a first stream to a second stream in a reliable multicast system is provided. The method comprises transmitting a first message from the transmitter to the receiver over the first stream to notify the receiver that a first data flow transmitted on the first stream will be transmitted on the second stream. The transmitter transmits a second message to the receiver over the second stream after a second threshold has expired. The receiver tunes to the second stream based on the second message. The transmitter transmits a third message to the receiver over the first stream after a third threshold has expired to notify the receiver that transmission of the first data flow over the first stream will be terminated. The transmitter then transmits a fourth message from the transmitter to the receiver over the second stream after a fourth threshold has expired.

    摘要翻译: 提供了一种用于将从发送器发送到接收器的数据通过第一流迁移到可靠多播系统中的第二流的方法。 该方法包括通过第一流从发射机向接收机发送第一消息,以通知接收机将在第二流上发送在第一流上发送的第一数据流。 在第二阈值到期之后,发射机通过第二流向接收机发送第二消息。 接收机根据第二个消息调谐到第二个流。 发射机在第三阈值到期之后通过第一流发送第三消息给接收机,以通知接收机,第一流上的第一数据流的传输将被终止。 发射机然后在第四阈值到期之后通过第二流从发射机向接收机发送第四消息。