Method and system for message processing

摘要

Processing a message includes receiving at a message processing system the message that is distributed by a message distributor, the message having a message type, based at least in part on the message type, locating among a plurality of subscriber groups a subscriber group that subscribes to the message type, each of the plurality of subscriber groups having a unique identifier and comprising one or more message subscriber nodes, at least some of the one or more message subscriber nodes in each of the plurality of subscriber groups being connected to the message processing system, and transmitting the message to a message subscriber node that belongs to the subscriber group that is located.

主权项

1. A message processing system comprising:
a processor configured to: divide a plurality of message subscriber nodes into a plurality of subscriber groups based at least in part on respective processing functions of the plurality of message subscriber nodes, wherein each subscriber group of the plurality of subscriber groups comprises one or more message subscriber nodes, wherein at least some of the one or more message subscriber nodes in each of the plurality of subscriber groups are associated with being connected to the message processing system; assign each of the plurality of subscriber groups a unique identifier; receive a message that is distributed by a message distributor, the message having a message type; based at least in part on the message type, locate among the plurality of subscriber groups a first located subscriber group and a second located subscriber group that subscribe to the message type, wherein each message subscriber node of the first located subscriber group is configured to perform a first processing function associated with the first located subscriber group and wherein each message subscriber node of the second located subscriber group is configured to perform a second processing function associated with the second located subscriber group, wherein the second processing function is different from the first processing function; select a message subscriber node among a plurality of message subscriber nodes in the first located subscriber group and select a message subscriber node among a plurality of message subscriber nodes in the second located subscriber group; and transmit the message to the selected message subscriber node that belongs to the first located subscriber group and transmit the message to the selected message subscriber node that belongs to the second located subscriber group, wherein the selected message subscriber node and no other message subscriber nodes of the first located subscriber group is configured to process the message based at least in part on the first processing function associated with the first located subscriber group and wherein the selected message subscriber node that belongs to the second located subscriber group and no other message subscriber nodes of the second located subscriber group is configured to process the message based at least in part on the second processing function associated with the second located subscriber group; and a memory coupled to the processor, configured to provide the processor with instructions.