System and method for distributed utility optimization in a messaging infrastructure

A distributed system for delivery of content between content producers and content consumers across multiple computer hardware nodes connected by links comprising:

• at least one source node for receiving producer content, said at least one source node comprising a flow rate calculation component for dynamically calculating a rate of at least one flow of producer content in said system and for making said rate of flow available for use by other nodes in the system;
• and
• at least one consumer admission node for receiving said rate of flow from said at least one source node, said at least one consumer admission node comprising at least one admission control component for dynamically controlling consumer access to said producer content, and at least one consumer admission price calculation component for dynamically generating consumer admission node price information for a rate of flow and for providing consumer admission node price information for use by other nodes in the system;
• and
• at least one intermediate node between said at least one source node and said at least one consumer control node, said method further comprising the steps of:
• said at least one source node dynamically adjusts data flow rates by the steps of:
• acquiring consumer service control information and price information;
• acquiring producer rate information generated by at least one content producer;
• adjusting data flow rates based on producer rate information, consumer service control information and price information;
• and
• making data flow rates available to nodes in said system;
• and
• said at least one consumer control node dynamically adjusts consumer service control information by the steps of:
• acquiring data flow rates;
• computing a number of consumers for each of a plurality of service classes;
• determining a price based on at least node capacity for the number of consumers for each service class for a rate of flow;
• and
• making the number of consumers for each of a plurality of service classes and the price available to nodes in said system;
• and wherein said steps are iteratively repeated by said at least one source node and said at least one consumer service control node to determine optimal flow rate and consumer service control for optimal resource usage;
• and wherein said data is made available to consumers based on the determined optimal flow rate and consumer service control.