Message transmission for distributed computing systems

摘要

A message from a source computer that includes message information indicating a destination target computer system to receive the message, is received. The received message in a storage component, is stored. An entry to a virtual queue for the received message, wherein the entry in the virtual queue points to a memory address of the received message that is stored in the message component, is created. Responsive to determining that the destination target computer system is available, the received message to a physical queue component and assigning an expiration condition to the received message is enqueued. The enqueued message to the destination target computer system is transmitted. Responsive to determining that the expiration condition for the received message is met, the received message from the physical queue is removed.

主权项

1. A method for message queuing in a message-oriented middleware computer implemented in a distributed computing environment including a source computer and a plurality of target computers connected by a network, the method comprising:
receiving, by one or more computer processors in a message-oriented middleware computer, a message from a source computer including message information indicating that a target computer is designated to receive the message; storing, by the one or more computer processors, the message in a non-transitory high speed computer readable storage medium of the message-oriented middleware computer configured for high speed read and write operations, wherein the message-oriented middleware computer includes the non-transitory high speed computer readable storage medium and a non-transitory low speed computer readable storage medium; creating, by the one or more computer processors, an entry in a virtual queue associated with the target computer for the message, wherein a pointer address of the entry points to a memory address of the message stored in the non-transitory high speed computer readable storage medium, and wherein each of the plurality of target computers is associated with a respective unique virtual queue; responsive to determining that the target computer is available to receive the message over the network:
enqueuing, by the one or more computer processors, the message to a physical queue component;transmitting, by the one or more computer processors, the message from the physical queue component to the target computer;moving, by the one or more computer processors, the message from the non-transitory high speed computer readable storage medium to the non-transitory low speed computer readable storage medium, and updating the pointer address of the entry in the virtual queue to point to a memory address of the message stored in the non-transitory low speed computer readable storage medium; responsive to receiving a confirmation of message receipt from the target computer within a specified time, removing, by the one or more computer processors, the message from the physical queue component, removing the message from the non-transitory low speed computer readable storage medium, and removing the entry for the message in the virtual queue; and responsive to not receiving the confirmation of message receipt from the target computer within the specified time, removing, by the one or more computer processors, the message from the physical queue component, indicating in the entry of the virtual queue that the confirmation of message receipt was not received from the target computer within the specified time, and wherein the message remains in the non-transitory low speed computer readable storage medium.