The present invention discloses a data stream distribution method and apparatus. In the method, a load balancer may access data in a data stream according to an instruction in a distribution rule that is sent by an application server according to an interface protocol or configured on the load balancer according to an interface protocol; determine, according to a keyword generated according to the accessed data, an application server that processes the data stream; and send the data stream to the determined application server. Therefore, the load balancer may access the data in the data stream according to an instruction in a common distribution rule, to distribute the data stream, thereby reducing complexity of data stream distribution performed by the load balancer.

Techniques are disclosed relating to handling queues. A server-based platform, in some embodiments, accesses queue information that includes performance attributes for a plurality of queues storing one or more messages corresponding to one or more applications. In some embodiments, the platform assigns, based on the performance attributes, a corresponding set of the plurality of queues to each of a plurality of processing nodes of the platform. In some embodiments, the assigning of a corresponding set of queues to a given one of the plurality of processing nodes causes instantiation of: a first set of one or more dequeuing threads and a second set of one or more processing threads. The dequeuing threads may be executable to dequeue one or more messages stored in the corresponding set of queues. The processing threads may be executable to perform one or more tasks specified in the dequeued one or more messages.

Embodiments of this application provide an information transmission method, a network element selector, and a controller. The information transmission method provided in the embodiments of this application includes: receiving, by an NES from an external network element, a first message including identification information of UE; determining, based on the identification information of the UE, a user group to which the UE belongs; determining a controller corresponding to the user group; and then sending the first message to the controller.

Techniques are disclosed for allocation of resources under the control of resource managers and the choice and coordination of resource acquisition protocols to communicate with these resource managers. The resource managers may be distributed and heterogeneous. For example, a technique for use by a service provider for allocating one or more resources from multiple resources associated with multiple resource managers based on at least one service agreement offer from a service client comprises the following steps/operations. At least one service agreement offer is obtained. A resource allocation is automatically determined based on the obtained service agreement offer. The automated step/operation of determining the resource allocation comprises: (i) coordinating selection of a resource acquisition protocol from among multiple resource acquisition protocols for use in communicating with the multiple resource managers to acquire one or more resources associated therewith; and (ii) evaluating a performance associated with one or more of the multiple resource acquisition protocols.

Disclosed are techniques and apparatuses that are configured to receive an indication that a web browsing session executing on an enterprise server needs additional information based on a request for additional information being sent to a client device. The request may include an identifier of the web browsing session and an identifier of an enterprise server that initiated the web browsing session. A globally unique identifier related to the web browsing session and an identifier of the enterprise server is stored in a common data store. The web browsing session may be paused when the web browsing session requests additional information from a client device. The client device may respond with the additional information. The system may provide the identifier of the enterprise server to a load balancing component so the identified web browsing session executing on the enterprise server may continue to be used.

A base station or content delivery server in a wireless network is configured to receive wireless network topology information from each of a plurality of wireless user devices. The wireless network topology information indicates which wireless user devices are within radio communication range of each other. The base station or content delivery server is configured to respond to a request for content from a first wireless user device by using the wireless network topology information for selecting a second wireless user device that has the content and is within radio communication range of the first wireless user device. The base station or content delivery server can be configured to forward the request to the second wireless user device, send a resource identifier to the first wireless user device that identifies the second wireless user device, and/or transmit a radio resource allocation to the first wireless user device to create a peer-to-peer link with the second wireless user device.

A base station or content delivery server in a wireless network is configured to receive wireless network topology information from each of a plurality of wireless user devices. The wireless network topology information indicates which wireless user devices are within radio communication range of each other. The base station or content delivery server is configured to respond to a request for content from a first wireless user device by using the wireless network topology information for selecting a second wireless user device that has the content and is within radio communication range of the first wireless user device. The base station or content delivery server can be configured to forward the request to the second wireless user device, send a resource identifier to the first wireless user device that identifies the second wireless user device, and/or transmit a radio resource allocation to the first wireless user device to create a peer-to-peer link with the second wireless user device.

Methods and apparatus for a computing infrastructure for configurable-quality random data are disclosed. A storage medium stores program instructions that when executed on a processor designate some servers of a provider network as members of a pool of producers of random data usable by random data consumers. The instructions, when executed, determine a subset of the pool to be used to supply a collection of random data intended for a random data consumer, and one or more sources of random phenomena to be used to generate the collection of random data. The instructions, when executed, initiate a transmission of the collection of random data directed to the random data consumer.

Streaming query resource control is described, for example, to allocate streaming queries to servers in a data center providing a streaming query platform. In various embodiments streaming queries are allocated to servers in a manner seeking to balance load between the servers and also to reduce network traffic costs between data stream sources and the servers. In various examples, query types are taken into account, where a query type is the identity of one or more data stream sources used by the query, and optionally also traffic rates of the data stream sources. In some examples, processes for allocating incoming queries in an online fashion are described and in some examples, processes for allocating queries in an offline fashion are described. In examples, a network traffic cost metric is used which takes into account an incremental network traffic cost of adding a given query at a server.

The embodiments described herein relate to dynamically optimizing a mapping from applications to shared service providers via one or more monitoring modules. A software layer positioned between a set of requestor applications and a set of shared service providers is configured. The layer is populated with a collection of one or more monitoring modules, with each monitoring module configured to monitor application resource usage. In response to receiving a monitoring request from the set of requestor applications, a mapping of the received request to the collection of xlets is dynamically optimized.