公开(公告)号：US20130304826A1

公开(公告)日：2013-11-14

申请号：US13470928

申请日：2012-05-14

申请人： Bin Li ,  Kartik Paramasivam ,  Manu Srivastava ,  SeongJoon Kwak ,  Venkata Raja Gopal Ravipati

发明人： Bin Li ,  Kartik Paramasivam ,  Manu Srivastava ,  SeongJoon Kwak ,  Venkata Raja Gopal Ravipati

IPC分类号： G06F15/16

CPC分类号： H04L51/14

摘要： Techniques are provided for scheduled and non-scheduled delivery of messages. A message directed to at least one consumer is received at a message entity. The message is determined to include a scheduled delivery time. The received message is stored in a scheduled sub-queue of the message entity. Activation metadata is retrieved and stored for any messages stored in the scheduled sub-queue that include a scheduled delivery time within a predetermined upcoming time period. If when the message is received, the scheduled delivery time of the message is within a current activation window, the activation metadata for the message may be extracted and stored immediately. The stored activation metadata is analyzed to determine a batch of messages in the scheduled sub-queue ready for delivery. The determined batch of messages is stored in an active sub-queue of the message entity, to be ready for delivery at the request of a consumer.

摘要翻译： 提供技术用于定期和非定期传递消息。 在消息实体处接收指向至少一个消费者的消息。 消息被确定为包括预定的交货时间。 接收到的消息被存储在消息实体的调度子队列中。 为预定的子队列中存储的任何消息检索和存储激活元数据，所述消息在预定的即将到来的时间段内包括预定的递送时间。 如果当接收到消息时，消息的预定传送时间在当前激活窗口内，则可以立即提取并存储消息的激活元数据。 分析存储的激活元数据以确定准备传送的计划子队列中的一批消息。 确定的消息批次存储在消息实体的活动子队列中，以便在消费者的请求下准备好传送。

公开(公告)号：US20130066977A1

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

申请号：US13230823

申请日：2011-09-12

申请人： Jayteerth Katti ,  Kartik Paramasivam ,  Stuart John Langley ,  Pramod Gurunath ,  Muralidhar Krishnaprasad ,  Elvin Morales ,  Manu Srivastava

发明人： Jayteerth Katti ,  Kartik Paramasivam ,  Stuart John Langley ,  Pramod Gurunath ,  Muralidhar Krishnaprasad ,  Elvin Morales ,  Manu Srivastava

IPC分类号： G06F15/16

CPC分类号： H04L51/26 ,  H04L51/30

摘要： Network and storage calls are reduced by batching messages. Messages are collected from a client and sent to the gateway or backend application in one round trip. Alternatively, the messages are collected for different entities, and the batched messages are durably stored. Related messages, which may have the same sessionID, are grouped into a logical unit or session. This session may be locked to a single message consumer. A session may be associated with an application processing state as an atomic unit of work while other operations are performed on the messages in the session. Acknowledgements are accumulated by a broker on a message server, but the messages are not immediately deleted. Instead, multiple messages in a selected range are periodically truncated from a message store in a single operation. Expired messages for active sessions are proactive cleaned up to prevent sessions from reaching a quota or limit.

摘要翻译： 通过批量消息来减少网络和存储呼叫。 消息从客户端收集，并一次性发送到网关或后端应用程序。 或者，为不同的实体收集消息，并且批量消息被持久地存储。 可能具有相同sessionID的相关消息被分组为逻辑单元或会话。 此会话可能被锁定到单个消息消费者。 会话可以与作为原子工作单元的应用处理状态相关联，而对会话中的消息执行其他操作。 致谢由消息服务器上的代理商累积，但消息不会立即被删除。 相反，在单个操作中，从消息存储区定期地截断所选范围内的多个消息。 活跃会话的过期消息被主动清理，以防止会话达到配额或限制。

公开(公告)号：US20130060834A1

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

申请号：US13420620

申请日：2012-03-15

申请人： Kartik Paramasivam ,  Sung Hwa Jin ,  Ruppert Koch

发明人： Kartik Paramasivam ,  Sung Hwa Jin ,  Ruppert Koch

IPC分类号： G06F15/16

CPC分类号： H04L12/66

摘要： A distributed messaging system includes a gateway having an interface to receive client messages and having access to a gateway database and to a messaging host that supports multiple partitions that are executed on processors of a cluster of processors. Each of the partitions supports execution of at least one message broker. The gateway database includes a mapping between each of the message brokers and one of the multiple partitions. An admin agent may periodically scan the gateway database to check if the message brokers reach a capacity threshold. The admin agent may create new message brokers and add the new message brokers to a pool of message brokers to allow new queues to be associated with the new message brokers.

摘要翻译： 分布式消息系统包括具有接收客户端消息并具有访问网关数据库的接口的网关以及支持在处理器集群的处理器上执行的多个分区的消息收发主机。 每个分区支持执行至少一个消息代理。 网关数据库包括每个消息代理和多个分区之一的映射。 管理员可以定期扫描网关数据库，以检查消息代理是否达到容量阈值。 管理代理可以创建新的消息代理，并将新的消息代理添加到消息代理池中，以允许新队列与新的消息代理相关联。

公开(公告)号：US20120102355A1

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

申请号：US12978336

申请日：2010-12-23

申请人： Muralidhar Krishnaprasad ,  Kartik Paramasivam ,  Jayteerth Katti ,  Anil Nori

发明人： Muralidhar Krishnaprasad ,  Kartik Paramasivam ,  Jayteerth Katti ,  Anil Nori

IPC分类号： G06F11/20 ,  G06F15/16

CPC分类号： H04L65/403 ,  G06F11/1446 ,  G06F11/1474 ,  H04L51/30

摘要： A messaging entity configured in a memory of first node of a plurality communicatively coupled nodes is disclosed. The nodes are included in a distributed computing system. The messaging entity is configured to operate as a secondary messaging entity in a messaging server for the plurality communicatively coupled nodes. The messaging entity is communicatively couple to a primary messaging entity configured in a memory of a second node of the plurality of nodes. The primary messaging entity is configured to store a message; store a copy of the message. Also, the messaging entity is configured to be promoted to a new primary messaging entity in the event of failure of the primary messaging entity.

摘要翻译： 公开了一种配置在多个通信耦合节点的第一节点的存储器中的消息传送实体。 节点包括在分布式计算系统中。 消息传送实体被配置为在用于多个通信耦合节点的消息收发服务器中作为次要消息接发实体操作。 消息传递实体通信地耦合到配置在多个节点中的第二节点的存储器中的主要消息传送实体。 主消息实体被配置为存储消息; 存储消息的副本。 此外，消息传递实体被配置为在主要消息传递实体失败的情况下被提升为新的主要消息传递实体。

公开(公告)号：US20110161392A1

公开(公告)日：2011-06-30

申请号：US13043964

申请日：2011-03-09

申请人： Stuart J. Langley ,  Kartik Paramasivam ,  Ramasubramaniam Poornalingam

发明人： Stuart J. Langley ,  Kartik Paramasivam ,  Ramasubramaniam Poornalingam

IPC分类号： G06F15/16

CPC分类号： H04L67/2814

摘要： The present invention extends to methods, systems, and computer program products for redirecting client messages between hosts within a messaging infrastructure. When a host receives a client message, it can refer to lock information in a shared database to determine if it is the correct host to receive the client message. The lock information includes a redirect endpoint. The redirect endpoint identifies an endpoint where client messages can be sent for delivery to the appropriate workflow instance. The redirect endpoint can be included in a redirect fault message, that is returned to a host when a host attempts to process a client message that is already locked to another workflow instance. Using the redirect endpoint, a host receiving a redirect fault message can use the redirect endpoint to send a client message to the correct host.

摘要翻译： 本发明扩展到用于在消息传递基础设施内的主机之间重定向客户端消息的方法，系统和计算机程序产品。 当主机收到客户端消息时，它可以引用共享数据库中的锁定信息，以确定它是否是正确的主机来接收客户端消息。 锁定信息包括重定向端点。 重定向端点标识可以发送客户端消息以发送到相应工作流实例的端点。 重定向端点可以包含在重定向故障消息中，当主机尝试处理已经锁定到另一个工作流实例的客户端消息时，重定向端点返回给主机。 使用重定向端点，接收重定向故障消息的主机可以使用重定向端点将客户端消息发送到正确的主机。

公开(公告)号：US20100325642A1

公开(公告)日：2010-12-23

申请号：US12489095

申请日：2009-06-22

申请人： Kartik Paramasivam ,  Jayteerth N. Katti ,  Vinod Shanbhag ,  Ramasubramaniam Poornalingam

发明人： Kartik Paramasivam ,  Jayteerth N. Katti ,  Vinod Shanbhag ,  Ramasubramaniam Poornalingam

IPC分类号： G06F9/44 ,  G06F3/00 ,  G06F13/00

CPC分类号： G06F11/0757 ,  G06F11/302 ,  G06F11/3055 ,  G06F11/3093

摘要： The present invention extends to methods, systems, and computer program products for automatically re-starting services. Embodiments of the invention can be used to re-start a service when it is determined that the service stopped during the processing pending work. A container manager durably tracks a service's status (busy/idle and alive/dead) and tracks transitions between statuses. Accordingly, when a busy service is deemed dead (due to any event), the container manager can automatically re-start the service. Upon re-start the service can check for pending work and start executing its pending work.

摘要翻译： 本发明扩展到用于自动重新启动服务的方法，系统和计算机程序产品。 当在处理待处理工作期间确定服务停止时，本发明的实施例可用于重新启动服务。 容器管理员可持续地跟踪服务的状态（忙/闲，活/死）并跟踪状态之间的转换。 因此，当忙碌的服务被认为是死机（由于任何事件）时，容器管理者可以自动重启服务。 重新启动后，服务可以检查待处理的工作并开始执行其待处理的工作。

公开(公告)号：US08903782B2

公开(公告)日：2014-12-02

申请号：US12843888

申请日：2010-07-27

申请人： Nicholas A. Allen ,  John A. Taylor ,  Kartik Paramasivam ,  Dharma Shukla

发明人： Nicholas A. Allen ,  John A. Taylor ,  Kartik Paramasivam ,  Dharma Shukla

IPC分类号： G06F17/30

CPC分类号： G06F17/30345

摘要： An instance persistence command for an update to a state of an instance of an application can be issued. In response to the persistence command, a transaction with an instance store can be initiated. As part of the transaction, a first representation of the update can be stored in the instance store and a second representation of the update can be stored in a queue. The transaction can be committed after storing the first and second representations. After the transaction is committed, the second representation can be processed to store a third representation of the update in a query store. Application instance state information in the query store can be updated and queried without locking the instance store so that such operations in the query store can be performed asynchronously with operations in the instance store.

摘要翻译： 可以发出用于更新应用程序实例的状态的实例持久性命令。 响应于持久性命令，可以启动具有实例存储的事务。 作为事务的一部分，更新的第一表示可以存储在实例存储中，更新的第二表示可以存储在队列中。 可以在存储第一和第二表示之后提交事务。 提交事务后，可以处理第二个表示形式，以便在查询存储中存储更新的第三个表示形式。 可以更新和查询查询存储中的应用程序实例状态信息，而不锁定实例存储，以便可以与实例存储中的操作异步执行查询存储中的这些操作。

公开(公告)号：US08301706B2

公开(公告)日：2012-10-30

申请号：US12484741

申请日：2009-06-15

申请人： Kartik Paramasivam ,  James E. Johnson ,  Nicholas Alexander Allen ,  John Anthony Taylor ,  Margaret J. Lye

发明人： Kartik Paramasivam ,  James E. Johnson ,  Nicholas Alexander Allen ,  John Anthony Taylor ,  Margaret J. Lye

IPC分类号： G06F15/16

CPC分类号： G06Q10/06

摘要： Message intermediation for multiple service instances, while allowing the service instance to control whether messages are processed under a transaction. The message intermediator chooses to dispatch messages among different backend service instances based on any routing rules. The message intermediator performs a peek-lock of message from a forward-end queue, and assigns the message to a service instance. The message is provided into a backward-end queue specific to the assigned service instance. The service instance may then process the message, perhaps under a transaction created at the service instance. Upon completion of processing, the message is deleted in the back-end queue, which causes the forward-end queue to delete the message under the same transaction created by the service instance. Whether or not this deletion at the forward-end is committed or rolled back depends on whether the transaction created at the service instance is committed or rolled back.

摘要翻译： 消息中介为多个服务实例，同时允许服务实例来控制是否在事务处理消息。 消息中介器根据任何路由规则选择在不同的后端服务实例之间分派消息。 消息中介器从前端队列执行消息锁定，并将消息分配给服务实例。 该消息被提供给特定于所分配的服务实例的后端队列。 服务实例然后可以在服务实例创建的事务处理该消息。 完成处理后，消息在后端队列中被删除，这导致前端队列在由服务实例创建的相同事务下删除消息。 是否提交或回滚前端的此删除取决于是否提交或回滚在服务实例创建的事务。

公开(公告)号：US08103759B2

公开(公告)日：2012-01-24

申请号：US13043964

申请日：2011-03-09

申请人： Stuart J. Langley ,  Kartik Paramasivam ,  Ramasubramaniam Poornalingam

发明人： Stuart J. Langley ,  Kartik Paramasivam ,  Ramasubramaniam Poornalingam

IPC分类号： G06F15/173

CPC分类号： H04L67/2814

摘要： The present invention extends to methods, systems, and computer program products for redirecting client messages between hosts within a messaging infrastructure. When a host receives a client message, it can refer to lock information in a shared database to determine if it is the correct host to receive the client message. The lock information includes a redirect endpoint. The redirect endpoint identifies an endpoint where client messages can be sent for delivery to the appropriate workflow instance. The redirect endpoint can be included in a redirect fault message, that is returned to a host when a host attempts to process a client message that is already locked to another workflow instance. Using the redirect endpoint, a host receiving a redirect fault message can use the redirect endpoint to send a client message to the correct host.

摘要翻译： 本发明扩展到用于在消息传递基础设施内的主机之间重定向客户端消息的方法，系统和计算机程序产品。 当主机收到客户端消息时，它可以引用共享数据库中的锁定信息，以确定它是否是正确的主机来接收客户端消息。 锁定信息包括重定向端点。 重定向端点标识可以发送客户端消息以发送到相应工作流实例的端点。 重定向端点可以包含在重定向故障消息中，当主机尝试处理已经锁定到另一个工作流实例的客户端消息时，重定向端点将返回给主机。 使用重定向端点，接收重定向故障消息的主机可以使用重定向端点将客户端消息发送到正确的主机。

公开(公告)号：US08095935B2

公开(公告)日：2012-01-10

申请号：US12147155

申请日：2008-06-26

申请人： Kartik Paramasivam ,  Pan Wang

发明人： Kartik Paramasivam ,  Pan Wang

IPC分类号： G06F9/46

CPC分类号： G06F9/505 ,  G06F9/5033

摘要： A system for efficiently distributing messages to a server farm uses a hashing function and a map-based function, or combinations thereof, to distribute messages associated with a processing request. In one implementation, for example, the hashing function has inputs of an identifier for each message in a processing request, and a list of available servers. Upon identifying that any of the servers is unavailable, or will soon be unavailable, the load balancing server uses an alternate map-based assignment function for new requests, and inputs each assignment into a server map. The load balancing server can then use the map or the hashing function, as appropriate, to direct messages to an operating server. Upon receiving an updated list of available servers, the load balancing server can switch back to the hashing function after the map is depleted, and use the updated server list as an argument.

摘要翻译： 用于将消息有效地分发到服务器场的系统使用散列函数和基于映射的函数或其组合来分发与处理请求相关联的消息。 在一个实现中，例如，散列函数在处理请求中具有每个消息的标识符的输入和可用服务器的列表。 在确定任何服务器不可用或即将不可用时，负载平衡服务器使用替代的基于映射的新请求分配功能，并将每个分配输入服务器映射。 然后，负载平衡服务器可以根据需要使用映射或散列函数将消息定向到操作服务器。 在收到更新的可用服务器列表之后，负载平衡服务器可以在映射耗尽后切换回散列函数，并使用更新的服务器列表作为参数。