WO2018127013A1

WO2018127013A1 - Method and device for concurrent transmission of stream data

Info

Publication number: WO2018127013A1
Application number: PCT/CN2017/120143
Authority: WO
Inventors: 韩天乐
Original assignee: 北京奇虎科技有限公司
Priority date: 2017-01-03
Filing date: 2017-12-29
Publication date: 2018-07-12
Also published as: CN106790632B; CN106790632A

Abstract

A method and device for the concurrent transmission of stream data, the method comprising: allocating first type threads to receive stream data; if a plurality of transmission requests for target stream data are received, determining transmission destination ends corresponding to the transmission requests and creating corresponding transmission tasks; creating transmission channels between the first type threads for receiving the target stream data and the transmission destination ends; and invoking the first type threads to concurrently execute the plurality of transmission tasks to transmit the target stream data to the transmission destination ends via the corresponding transmission channels. By making the transmission of stream data to transmission destination ends be directly completed on threads for receiving stream data, the technical solution avoids the problem of forwarding stream data to a plurality of threads for sending stream data by threads for receiving stream data, reduces performance overheads caused by data forwarding among threads, and reduces the response time.

Description

Concurrent transmission method and device for stream data

Technical field

The present invention relates to the field of streaming data transmission technologies, and in particular, to a concurrent transmission method of streaming data and a concurrent transmission apparatus for streaming data.

Background technique

Streaming data is data that can be transmitted over the network by means of streaming. Large website systems often rely on the Content Delivery Network (CDN) to transmit streaming data. The content distribution network is added to the existing network. A new layer of network structure allows users to transfer data to or near the nearest node. In the content distribution network, a transmission node is deployed to buffer the stream data and provide services to the user nearby.

On a transit node in a content distribution network, if there are multiple connections for the same stream data, a thread is randomly assigned to each connection to establish a connection for streaming data transmission, thereby implementing concurrent transmission of stream data.

However, in the case of multiple connections, the thread receiving the stream data needs to forward the stream data to the thread in which the multiple connections are located, the communication performance between threads is large, and the response time increases.

Summary of the invention

In view of the above problems, the present invention has been made in order to provide a concurrent transmission method and corresponding apparatus for streaming data that overcomes the above problems or at least partially solves or alleviates the above problems.

According to an aspect of the present invention, a method for concurrent transmission of stream data is provided, including:

Allocating a first type of thread to receive stream data, and each first type of thread correspondingly receiving one stream data;

Receiving a plurality of transmission requests for the target stream data, determining a transmission destination end corresponding to each transmission request and creating a corresponding transmission task;

Creating a transmission channel between the first type of thread that receives the target stream data and each transmission destination end, and each transmission channel carries a transmission task correspondingly;

The first type of thread is called to concurrently execute a plurality of transmission tasks, and the target stream data is transmitted to each transmission destination through a corresponding transmission channel.

According to another aspect of the present invention, a concurrent transmission apparatus for streaming data is provided, including:

a thread allocation module, configured to allocate a first type of thread to receive stream data, and each first type thread receives a stream data;

a transmission task determining module, configured to determine a transmission destination end corresponding to each transmission request and create a corresponding transmission task when receiving a plurality of transmission requests for the target stream data;

a transmission channel creation module, configured to create a transmission channel between the first type of thread receiving the target stream data and each transmission destination end, where each transmission channel carries a transmission task;

The transmission task invoking module is configured to invoke the first type of thread to concurrently execute a plurality of transmission tasks, and transmit the target stream data to each transmission destination end through a corresponding transmission channel.

According to still another aspect of the present invention, a computer program is provided, comprising computer readable code that, when executed on a computing device, causes the computing device to perform streaming data as described above Concurrent transmission method.

According to still another aspect of the present invention, a computer readable medium is provided, wherein the computer program described above is stored.

The beneficial effects of the invention are:

According to the present invention, a concurrent transmission method and apparatus for streaming data receives a plurality of transmission requests for target stream data by allocating a first type of thread to receive stream data, and determines a transmission destination end corresponding to each transmission request and creates a corresponding one. Transmitting a task, creating a transmission channel between the first type of thread receiving the target stream data and each of the transmission destinations, calling the first type of thread to concurrently execute a plurality of transmission tasks, and transmitting the target stream data through corresponding transmission Channels are transmitted to each transmission destination. The transmission of the streaming data to the transmission destination is directly performed on the thread that receives the streaming data, thereby avoiding the problem that the thread receiving the streaming data needs to forward the streaming data to the thread that sends the streaming data, thereby reducing the data forwarding between the threads. Performance consumption while also reducing response time.

The above description is only an overview of the technical solutions of the present invention, and the above-described and other objects, features and advantages of the present invention can be more clearly understood. Specific embodiments of the invention are set forth below.

DRAWINGS

Various other advantages and benefits will become apparent to those skilled in the art from a The drawings are only for the purpose of illustrating the preferred embodiments and are not to be construed as limiting. Throughout the drawings, the same reference numerals are used to refer to the same parts. In the drawing:

1 is a flow chart showing the steps of a method for concurrently transmitting stream data according to a first embodiment of the present invention;

FIG. 2 is a schematic flow chart showing the steps of a method for concurrently transmitting stream data according to Embodiment 2 of the present invention; FIG.

FIG. 3 is a block diagram showing the structure of a concurrent transmission device for streaming data according to Embodiment 3 of the present invention; FIG.

Figure 4 is a schematic block diagram showing a computing device for performing the method according to the present invention;

Fig. 5 schematically shows a storage unit for holding or carrying program code implementing the method according to the invention.

Specific embodiment

The invention is further described below in conjunction with the drawings and specific embodiments.

Referring to FIG. 1 , a flow chart of steps of a method for concurrently transmitting stream data according to a first embodiment of the present invention is shown.

In step 101, the first type of thread is allocated to receive the stream data.

Stream data is data that can be transmitted over the network by means of streaming. Stream data can be transmitted between network devices such as clients or servers. In a multi-threaded environment, it is necessary to allocate the same or different threads to handle the tasks of receiving, sending, and storing streaming data to implement concurrent execution of multiple threads.

In the embodiment of the present invention, threads are classified into several classes according to different tasks performed, wherein a thread is allocated in a thread pool to perform a task of receiving stream data, and the thread that performs the task of receiving the stream data is referred to as a first class. Threads, and each first class thread receives a stream of data.

For example, in the field of live video broadcasting, content distribution networks are utilized to provide high performance, scalable, and low cost web content delivery to users. On the server for transmitting stream data in the content distribution network, there may be multiple tasks for receiving stream data at the same time. When a stream data receiving request is responded, a first type thread is allocated for receiving stream data, specifically A connection is established with the streaming data sender on the assigned first type thread, and the transmitted stream data is received.

Step 102: When receiving multiple transmission requests for the target stream data, determine a transmission destination end corresponding to each transmission request and create a corresponding transmission task.

The transmission request is a transmission request initiated by the target stream data, and the transmission request specifically includes information of the target stream data, the transmission destination end, the transmission mode, and the like, wherein the target stream data is stream data requested to be transmitted, and one transmission request may request at least one target stream. Data, the destination of the transmission is the end of the received stream data specified in the transmission request. The transmission task is a task of establishing a connection with the transmission destination to transmit the target stream data.

In the embodiment of the present invention, when multiple transmission requests for the target stream data are received, the pointer has multiple transmission requests for one stream data, and specifically, the transmission request may be received on a random thread, when multiple transmissions are received. When requesting, according to the information in the transmission request, the transmission destinations corresponding to the respective transmission requests are determined, and each transmission task corresponding to each transmission request is created.

Step 103: Create a transmission channel between the first type of thread that receives the target stream data and each of the transmission destinations.

A transmission channel is a channel established between a local and a transmission destination for performing transmission of data, and may be used for a byte buffer and for transmitting data for a data entity on the other side of the channel. In the embodiment of the present invention, the transmission channel may refer to a Socket (the original meaning of the socket is "hole" or "socket". As a process communication mechanism of BSD UNIX, also called "socket"), it is used to describe IP. Address and port, is a handle to a communication chain that can be used to communicate between different virtual machines or different computers.

In the embodiment of the present invention, the first type thread that is receiving the target stream data of the transmission task is found, and the transmission channel between the first type thread and each transmission destination end is created according to the transmission task, and each transmission channel carries a transmission correspondingly. task.

In step 104, the first type of thread is invoked to perform multiple transmission tasks concurrently, and the target stream data is transmitted to each transmission destination through a corresponding transmission channel.

In the embodiment of the present invention, multiple transmission tasks may be performed concurrently on the first type of thread, where each transmission task corresponds to transmitting the target stream data to each transmission destination through the created transmission channel. Under certain hardware conditions, the maximum number of transmission tasks that can be executed concurrently on the first type of thread depends on the CPU resources consumed by the transmission task, and may be any applicable number, which is not limited by the present invention.

In summary, according to the embodiment of the present invention, when the first type of thread is received to receive the stream data, and the plurality of transmission requests for the target stream data are received, the transmission destination end corresponding to each transmission request is determined and a corresponding transmission task is created. Creating a transmission channel between the first type of thread receiving the target stream data and each of the transmission destinations, calling the first type of thread to concurrently perform a plurality of transmission tasks, and transmitting the target stream data to the corresponding transmission channel to Each transmission destination. The transmission of the streaming data to the transmission destination is directly performed on the thread that receives the streaming data, thereby avoiding the problem that the thread receiving the streaming data needs to forward the streaming data to the thread that sends the streaming data, thereby reducing the data forwarding between the threads. Performance consumption while also reducing response time.

In the embodiment of the present invention, preferably, before the receiving the plurality of transmission requests for the target stream data, determining the transmission destination end corresponding to each transmission request and creating a corresponding transmission task, the method may further include the following steps: The second type of thread is used to receive transmission requests for all stream data.

A thread is called from a thread pool to receive a transfer request for all stream data, which may be referred to as a second type of thread. Specifically, the respective transmission requests of the respective flow data may be respectively executed by using different threads, which is not limited by the embodiment of the present invention.

In an embodiment of the present invention, preferably, before the creating a transmission channel between the first type of thread that receives the target stream data and each of the transmission destinations, the method may further include the step of: invoking the second type of thread A plurality of transmission tasks are sent to the first type of thread, and the transmission task carries an identifier of a corresponding transmission destination.

When receiving the multiple transmission requests for the target stream data, the second type of thread determines the transmission destination end corresponding to each transmission request and creates a corresponding transmission task, and then sends the plurality of transmission tasks to the target stream data corresponding to the transmission task. A type of thread, and the transmission task carries an identifier of the corresponding transmission destination. For example, the transmission destination is a server, and the identifier may include a network address of the server.

In the embodiment of the present invention, preferably, before the invoking the second type of thread to send the plurality of transmission tasks to the first type of thread, the method may further include: identifying that the flow data corresponding to each transmission request is The target stream data, and determines that the thread receiving the target stream data is the first type of thread.

The transmission request carries the identifier of the requested target stream data, and after receiving each transmission request, identifies the stream data corresponding to each transmission request request, identifies the stream data as the target stream data, and finds the thread that receives the target stream data, and determines that The first type of thread.

2 is a flow chart showing the steps of a method for concurrently transmitting stream data according to a second embodiment of the present invention. Specifically, the method may include the following steps:

Step 201: randomly select a thread from the preset thread pool as the first type thread for receiving the stream data to be received.

A thread pool is a form of multi-threaded processing that adds tasks to a queue during processing and then automatically starts them after the thread is created. Thread pool threads are background threads. Each thread uses the default stack size, runs at the default priority, and is in a multithreaded apartment. If a thread is idle in managed code (such as waiting for an event), another worker thread is inserted in the thread pool to keep all processors busy. If all thread pool threads are always busy, but the queue contains pending work, another worker thread will be created in the thread pool after a period of time but the number of threads will never exceed the maximum. Threads that exceed the maximum value can be queued, but they will not start until other threads have completed.

In the embodiment of the present invention, the preset thread pool is a thread pool preset for processing stream data related tasks. A thread is randomly selected from the preset thread pool to receive the stream data to be received as the first type of thread.

Step 202, invoking a second type of thread for receiving a transmission request for all stream data.

Step 203: When receiving a plurality of transmission requests for the target stream data, determine a transmission destination end corresponding to each transmission request and create a corresponding transmission task.

In the embodiment of the present invention, the specific manner is the same as that described in the other embodiments, and details are not described herein.

Step 204: Determine whether the thread for transmitting the target stream data includes only the first type of thread.

In the embodiment of the present invention, there may be multiple threads for sending the target stream data, one of which is the first type of thread, and the other thread that sends the target stream data may create a new thread when the first type thread reaches the upper limit of the concurrent thread. The transfer task of executing the target stream data, after the creation, forwards the stream data received in the first type of thread to the newly created thread. It is judged whether the thread currently used to send the target stream data includes only the first type of thread.

If the thread for transmitting the target stream data includes only the first type of thread, step 205 is performed.

Step 205: Determine that the first type of thread meets the first setting condition.

The first setting condition includes at least one of the following: the total number of transmission channels corresponding to the creation does not exceed the set number, and the set load amount is not exceeded. Get the total number of transmission channels created on the first type of thread. The first setting condition is that the total number does not exceed the set number or does not exceed the set load.

In the embodiment of the present invention, the total number of transmission channels created on the first type of thread of the target stream data is obtained, and whether the first type of thread is determined according to whether the total number exceeds the set number or exceeds the set load amount. The first setting condition is satisfied, and it is determined that the first type of thread satisfies the first setting condition. The number of the settings and the amount of the set load may be any applicable, which is not limited in the embodiment of the present invention.

In the embodiment of the present invention, preferably, if the first type of thread does not satisfy the first setting condition, the third type of thread is created to perform transmission of the target stream data.

If the first type of thread does not satisfy the first set condition, that is, the total number of transmission channels on the first type of thread exceeds the set number or the set amount of load, a thread is created for the transmission of the target stream data. The created thread is a third type of thread. Creating a third type of thread requires the first type of thread to forward the stream data to the third type of thread.

In an embodiment of the present invention, preferably, the implementation of the third type of thread to perform the transmission of the target stream data is: randomly selecting a thread from the preset thread pool as the third type thread; The three types of threads acquire target stream data from the first type of thread that receives the target stream data, and transmit the target stream data.

A thread is randomly selected from the preset thread pool as the third type thread, and the third type thread is called to acquire the required target stream data from the first type thread, and the target stream data is transmitted according to the transmission task.

In an embodiment of the present invention, preferably, if the thread for transmitting the target stream data includes the first type thread and the at least one third type thread, creating the first type thread that receives the target stream data in the creating Before the transmission channel between each transmission destination end, the method may further include: selecting, in the first type thread and the at least one third type thread, a thread that satisfies the first setting condition, and determining that the first setting is satisfied The thread of the condition is a thread of the first type, and the first setting condition includes at least one of the following: the total number of transmission channels corresponding to the creation does not exceed the set number, and the set load amount is not exceeded.

If the thread for sending the target stream data includes the first type thread and the at least one third type thread, finding the thread satisfying the first setting condition in the first type thread and the third type thread, the first setting condition includes At least one of the following: the total number of transmission channels created correspondingly does not exceed the set number, and the set load amount is not exceeded. Get the total number of transmission channels created on the first type of thread and the third type of thread respectively. The first setting condition is that the total number does not exceed the set number or does not exceed the set load. And determining that the thread satisfying the first setting condition is the first type thread, and the third type thread does not satisfy the first setting condition.

In the embodiment of the present invention, preferably, if it is determined that the thread that satisfies the first setting condition is not the first type of thread, the third type thread that satisfies the first setting condition is called to perform the transmission of the target stream data.

Specifically, if the thread that satisfies the first set condition is not the first type of thread, then the third type of thread is called to perform the transmission of the target stream data, specifically transmitting the transmission task to the third type thread, and the third type thread The connection with the transmission destination is established, and the streaming data is transmitted.

In an embodiment of the present invention, preferably, if the thread that satisfies the first setting condition includes the first type thread and the at least one third type thread, randomly selecting one thread from the first type thread and the at least one third type thread And determine that the randomly selected thread is the first type of thread.

If the thread satisfying the first setting condition includes the first type thread and the at least one third type thread, one thread is randomly selected from the first type thread and the at least one third type thread, and in one case, randomly selected The thread is the first type of thread, and the first type of thread is used to transmit the target stream data.

In an embodiment of the present invention, preferably, if the thread that satisfies the first setting condition includes the first type of thread and the at least one third type of thread, further determining that the thread that satisfies the second setting condition is the first type of thread, The second setting condition includes at least one of the following: the total number of transmission channels corresponding to the creation is the smallest, and the corresponding load amount is the least.

The second setting condition is that the total number of transmission channels corresponding to the creation is the smallest, or the corresponding load amount is the least.

If the thread satisfying the first setting condition includes the first type thread and the at least one third type thread, it is also possible to find a thread in which the second setting condition is satisfied, and in one case, the thread satisfying the second setting condition For the first type of thread, the first type of thread is used to transmit the target stream data.

In the embodiment of the present invention, preferably, if the first type of thread does not satisfy the second setting condition, the third type thread that satisfies the second setting condition is called to perform the transmission of the target stream data.

If the first type of thread does not satisfy the second setting condition, the third type thread that satisfies the second setting condition is searched for the target stream data transmission, and the third type thread and the transmission destination satisfying the second setting condition are satisfied. The terminal establishes a connection and transmits the target stream data.

In the embodiment of the present invention, preferably, if the existing first type thread and the third type thread do not satisfy the first setting condition, a new third type thread is created.

If the existing first type thread and the third type thread do not satisfy the first set condition, a new third type thread is created, and the target stream data and the first type thread are forwarded to the newly created third type thread. The transmission task is sent to the newly created third type thread to complete the transmission of the target stream data according to the transmission task.

Step 206: Create a transmission channel between the first type of thread that receives the target stream data and each of the transmission destinations.

In the embodiment of the present invention, each transmission channel carries a transmission task. The specific manner is consistent with the description in other embodiments, and details are not described herein.

Step 207: Update the total number of transmission channels recorded for the first type of thread according to the number of established transmission channels.

In the embodiment of the present invention, the total number of transmission channels recorded for the first type of thread is updated according to the number of established transmission channels, and specifically, the transmission channel recorded for the first type of thread is established every time one transmission channel is established. The total number is increased by one. If there is a transmission task completed or other reasons lead to a reduction in the transmission channel, the total number of transmission channels recorded by the first type of thread is reduced accordingly.

Step 208, invoking the first type of thread to concurrently perform multiple transmission tasks, and transmitting the target stream data to each transmission destination end through a corresponding transmission channel.

In summary, according to the embodiment of the present invention, one thread is randomly selected from the preset thread pool as the first type thread for receiving the stream data to be received, and the second type thread is used to receive the transmission for all stream data. Determining, when receiving a plurality of transmission requests for the target stream data, determining a transmission destination end corresponding to each transmission request and creating a corresponding transmission task, determining whether the thread for transmitting the target stream data includes only the first type of thread, Determining that the first type of thread meets the first setting condition, creating a transmission channel between the first type of thread receiving the target stream data and each transmission destination end, and updating the target according to the number of established transmission channels The total number of transmission channels recorded by the first type of thread is recorded, and the first type of thread is invoked to perform multiple transmission tasks concurrently, and the target stream data is transmitted to each transmission destination through a corresponding transmission channel. The above solution makes the transmission of the stream data to the transmission destination directly on the thread receiving the stream data, avoiding the problem that the thread receiving the stream data needs to forward the stream data to the thread that sends the stream data, and reduces the data band between the threads. The performance is consumed, and the response time is also reduced.

Referring to FIG. 3, a structural block diagram of a concurrent transmission device for streaming data according to Embodiment 3 of the present invention is shown, which may specifically include the following modules:

a thread allocation module 301, configured to allocate a first type of thread to receive stream data, and each of the first type of threads corresponding to receive one stream data;

The transmission task determining module 302 is configured to: when receiving a plurality of transmission requests for the target stream data, determine a transmission destination end corresponding to each transmission request and create a corresponding transmission task;

a transmission channel creation module 303, configured to create a transmission channel between the first type of thread that receives the target stream data and each of the transmission destination ends, where each transmission channel carries a transmission task;

The transmission task invoking module 304 is configured to invoke the first type of thread to concurrently execute a plurality of transmission tasks, and transmit the target stream data to each transmission destination end through a corresponding transmission channel.

In an embodiment of the present invention, preferably, the device further includes:

a transmission request receiving module, configured to: when the plurality of transmission requests for the target stream data are received, determine a transmission destination corresponding to each transmission request and create a corresponding transmission task, call the second type of thread to receive for all Stream data transfer request.

a transmission task sending module, configured to send the second type of thread to send the plurality of transmission tasks to the transmission channel before the creating a transmission channel between the first type thread that receives the target stream data and each transmission destination end The first type of thread, the transmission task carries an identifier of a corresponding transmission destination.

a stream data identification module, configured to: before the calling the second type of thread sends a plurality of transmission tasks to the first type of thread, identify stream data corresponding to each transmission request as target stream data, and determine a receiving station The thread of the target stream data is the first type of thread.

a thread judging module, configured to determine, before the creating a transmission channel between the first type of thread that receives the target stream data and each of the transmission destinations, whether the thread for transmitting the target stream data includes only the first class Thread.

a first condition determining module, configured to: if the thread used to send the target stream data includes only the first type of thread, and transmit the transmission between the first type of thread that receives the target stream data and each of the transmission destinations Before the channel, determining that the first type of thread meets the first setting condition, the first setting condition includes at least one of the following: the total number of corresponding created transmission channels does not exceed the set number, and the setting is not exceeded. The amount of load.

The third thread creation module is configured to: if the first type thread does not satisfy the first setting condition, create a third type thread to perform target stream data transmission.

In the embodiment of the present invention, preferably, the third thread creation module includes:

The third thread selects a sub-module for randomly selecting one thread from the preset thread pool as the third type thread;

The stream data obtaining submodule is configured to invoke the third type thread to acquire target stream data from the first type thread that receives the target stream data, and transmit the target stream data.

a first condition satisfaction module, configured to: if the thread for transmitting the target stream data includes a first type of thread and at least one third type of thread, create a first type of thread and each of the target stream data Before transmitting the transmission channel between the destination ends, selecting, in the first type of thread and the at least one third type of thread, a thread that satisfies the first setting condition, and determining that the thread that satisfies the first setting condition is the first type Thread, the first setting condition includes at least one of the following: the total number of corresponding created transmission channels does not exceed the set number, and the set load amount is not exceeded.

The third thread invokes a module, if it is determined that the thread satisfying the first setting condition is not the first type thread, the third type thread that satisfies the first setting condition is called to perform the target stream data transmission.

a thread random module, configured to: if the thread satisfying the first setting condition includes the first type thread and the at least one third type thread, randomly select one thread from the first type thread and the at least one third type thread, and determine a random The selected thread is the first type of thread.

a second condition satisfaction module, configured to: if the thread satisfying the first setting condition includes the first type thread and the at least one third type thread, further determining that the thread satisfying the second setting condition is the first type thread, The second setting condition includes at least one of the following: the total number of transmission channels corresponding to the creation is the smallest, and the corresponding load amount is the least.

The third thread invokes a module, configured to: if the first type of thread does not satisfy the second set condition, invoke a third type of thread that satisfies the second set condition to perform target stream data transmission.

The third creating module is configured to create a new third type thread if the existing first type thread and the third type thread do not satisfy the first setting condition.

a number update module, configured to update, according to the number of established transmission channels, the record for the first type of thread after the creating a transmission channel between the first type of thread and each of the transmission destinations The total number of transmission channels.

In the embodiment of the present invention, the thread allocation module is specifically configured to randomly select one thread from the preset thread pool as the first type thread for receiving the stream data to be received.

In summary, according to the embodiment of the present invention, when the first type of thread is received to receive the stream data, and the plurality of transmission requests for the target stream data are received, the transmission destination end corresponding to each transmission request is determined and a corresponding transmission task is created. Creating a transmission channel between the first type of thread receiving the target stream data and each of the transmission destinations, calling the first type of thread to concurrently perform a plurality of transmission tasks, and transmitting the target stream data to the corresponding transmission channel to Each transmission destination. The above solution makes the transmission of the stream data to the transmission destination directly on the thread receiving the stream data, avoiding the problem that the thread receiving the stream data needs to forward the stream data to the thread that sends the stream data, and reduces the data band between the threads. The performance is consumed, and the response time is also reduced.

The various component embodiments of the present invention may be implemented in hardware, or in a software module running on one or more processors, or in a combination thereof. Those skilled in the art will appreciate that a microprocessor or digital signal processor (DSP) may be used in practice to implement some of some or all of the components of a concurrent method and apparatus for streaming data in accordance with embodiments of the present invention. Or all features. The invention can also be implemented as a device or device program (e.g., a computer program and a computer program product) for performing some or all of the methods described herein. Such a program implementing the invention may be stored on a computer readable medium or may be in the form of one or more signals. Such signals may be downloaded from an Internet website, provided on a carrier signal, or provided in any other form.

For example, Figure 4 illustrates a concurrent transmission computing device, such as an application server, that can implement streaming data in accordance with the present invention. The computing device conventionally includes a processor 410 and a computer program product or computer readable medium in the form of a memory 420. The memory 420 may be an electronic memory such as a flash memory, an EEPROM (Electrically Erasable Programmable Read Only Memory), an EPROM, a hard disk, or a ROM. Memory 420 has a memory space 430 for program code 431 for performing any of the method steps described above. For example, storage space 430 for program code may include various program code 431 for implementing various steps in the above methods, respectively. The program code can be read from or written to one or more computer program products. These computer program products include program code carriers such as hard disks, compact disks (CDs), memory cards or floppy disks. Such computer program products are typically portable or fixed storage units as described with reference to FIG. The storage unit may have storage segments, storage spaces, and the like that are similarly arranged to memory 420 in the computing device of FIG. The program code can be compressed, for example, in an appropriate form. Typically, the storage unit includes computer readable code 431', ie, code readable by a processor, such as 410, that when executed by a computing device causes the computing device to perform each of the methods described above step.

"an embodiment," or "an embodiment," or "an embodiment," In addition, it is noted that the phrase "in one embodiment" is not necessarily referring to the same embodiment.

In the description provided herein, numerous specific details are set forth. However, it is understood that the embodiments of the invention may be practiced without these specific details. In some instances, well-known methods, structures, and techniques are not shown in detail so as not to obscure the understanding of the description.

It is to be noted that the above-described embodiments are illustrative of the invention and are not intended to be limiting, and that the invention may be devised without departing from the scope of the appended claims. In the claims, any reference signs placed between parentheses shall not be construed as a limitation. The word "comprising" does not exclude the presence of the elements or steps that are not recited in the claims. The word "a" or "an" The invention can be implemented by means of hardware comprising several distinct elements and by means of a suitably programmed computer. In the unit claims enumerating several means, several of these means can be embodied by the same hardware item. The use of the words first, second, and third does not indicate any order. These words can be interpreted as names.

In addition, it should be noted that the language used in the specification has been selected for the purpose of readability and teaching, and is not intended to be construed or limited. Therefore, many modifications and changes will be apparent to those skilled in the art without departing from the scope of the invention. The disclosure of the present invention is intended to be illustrative, and not restrictive, and the scope of the invention is defined by the appended claims.

Claims

A method for concurrent transmission of stream data, comprising the steps of:

Allocating a first type of thread to receive stream data, and each first type of thread correspondingly receiving one stream data;

Receiving a plurality of transmission requests for the target stream data, determining a transmission destination end corresponding to each transmission request and creating a corresponding transmission task;

Creating a transmission channel between the first type of thread that receives the target stream data and each transmission destination end, and each transmission channel carries a transmission task correspondingly;

The first type of thread is called to concurrently execute a plurality of transmission tasks, and the target stream data is transmitted to each transmission destination through a corresponding transmission channel.
The method according to claim 1, wherein, before the receiving the plurality of transmission requests for the target stream data, determining the transmission destinations corresponding to the respective transmission requests and creating the corresponding transmission tasks, the method further includes:

A second type of thread is called for receiving a transfer request for all stream data.
The method of claim 2, wherein before the creating a transmission channel between the first type of thread receiving the target stream data and each of the transmission destinations, the method further comprises:

The second type of thread is called to send a plurality of transmission tasks to the first type of thread, and the transmission task carries an identifier of the corresponding transmission destination.
The method of claim 3, wherein before the invoking the second type of thread to send a plurality of transmission tasks to the first type of thread, the method further comprises:

The stream data identifying the corresponding request of each transfer request is the target stream data, and determining that the thread receiving the target stream data is the first type of thread.
The method of claim 1, wherein before the creating a transmission channel between the first type of thread receiving the target stream data and each of the transmission destinations, the method further comprises:

Determining whether the thread for transmitting the target stream data includes only the first type of thread.
The method according to claim 5, wherein if the thread for transmitting the target stream data includes only the first type of thread, the first type of thread that receives the target stream data is created and each of the transmission destinations is Before the transmission channel, the method further includes:

It is determined that the first type of thread satisfies the first setting condition, and the first setting condition includes at least one of the following: the total number of corresponding created transmission channels does not exceed the set number, and the set load amount is not exceeded.
The method of claim 6 wherein the method further comprises:

If the first type of thread does not satisfy the first set condition, a third type of thread is created to perform target stream data transmission.
The method of claim 7, wherein the creating the third type of thread for transmitting the target stream data comprises:

Randomly selecting a thread from the preset thread pool as the third type of thread;

The third type thread is called to acquire target stream data from the first type thread that receives the target stream data, and transmits the target stream data.
The method according to claim 5, wherein if the thread for transmitting the target stream data comprises a first type of thread and at least one third type of thread, the first class of the target stream data is created in the creating Before the transmission channel between the thread and each transmission destination, the method further includes:

In the first type of thread and the at least one third type of thread, selecting a thread that satisfies the first setting condition, and determining that the thread that satisfies the first setting condition is the first type of thread, the first setting condition includes At least one of the following: the total number of transmission channels created correspondingly does not exceed the set number, and the set load amount is not exceeded.
The method of claim 9 wherein the method further comprises:

If it is determined that the thread satisfying the first setting condition is not the first type of thread, the third type thread that satisfies the first setting condition is called to perform the transmission of the target stream data.
The method of claim 9 wherein the method further comprises:

If the thread satisfying the first setting condition includes the first type thread and the at least one third type thread, randomly selecting one thread from the first type thread and the at least one third type thread, and determining that the randomly selected thread is the first thread Class thread.
The method of claim 9 wherein the method further comprises:

If the thread that satisfies the first setting condition includes the first type thread and the at least one third type thread, further determining that the thread satisfying the second setting condition is the first type thread, and the second setting condition includes at least one of the following Species: The total number of transmission channels created is the least, and the corresponding load is the least.
The method of claim 12, wherein the method further comprises:

If the first type of thread does not satisfy the second setting condition, the third type thread that satisfies the second setting condition is called to perform the transmission of the target stream data.
The method of claim 7 wherein the method further comprises:

If the existing first type thread and the third type thread do not satisfy the first setting condition, a new third type thread is created.
The method according to claim 1 or 6, wherein after the creating a transmission channel between the first type of thread and each of the transmission destinations, the method further comprises:

The total number of transmission channels recorded for the first type of thread is updated according to the number of established transmission channels.
The method of claim 1, wherein the allocating the first type of thread to receive the stream data comprises:

For the stream data to be received, one thread is randomly selected from the preset thread pool as the first type thread to receive.
A concurrent transmission device for streaming data, comprising:

a thread allocation module, configured to allocate a first type of thread to receive stream data, and each first type thread receives a stream data;

a transmission task determining module, configured to determine a transmission destination end corresponding to each transmission request and create a corresponding transmission task when receiving a plurality of transmission requests for the target stream data;

a transmission channel creation module, configured to create a transmission channel between the first type of thread receiving the target stream data and each transmission destination end, where each transmission channel carries a transmission task;

The transmission task invoking module is configured to invoke the first type of thread to concurrently execute a plurality of transmission tasks, and transmit the target stream data to each transmission destination end through a corresponding transmission channel.
The apparatus of claim 17 wherein said apparatus further comprises:

a transmission request receiving module, configured to: when the plurality of transmission requests for the target stream data are received, determine a transmission destination corresponding to each transmission request and create a corresponding transmission task, call the second type of thread to receive for all Stream data transfer request.
The device of claim 18, wherein the device further comprises:

a transmission task sending module, configured to send the second type of thread to send the plurality of transmission tasks to the transmission channel before the creating a transmission channel between the first type thread that receives the target stream data and each transmission destination end The first type of thread, the transmission task carries an identifier of a corresponding transmission destination.
The device of claim 19, wherein the device further comprises:

a stream data identification module, configured to: before the calling the second type of thread sends a plurality of transmission tasks to the first type of thread, identify stream data corresponding to each transmission request as target stream data, and determine a receiving station The thread of the target stream data is the first type of thread.
The apparatus of claim 17 wherein said apparatus further comprises:

a thread judging module, configured to determine, before the creating a transmission channel between the first type of thread that receives the target stream data and each of the transmission destinations, whether the thread for transmitting the target stream data includes only the first class Thread.
The device of claim 21, wherein the device further comprises:

a first condition determining module, configured to: if the thread used to send the target stream data includes only the first type of thread, and transmit the transmission between the first type of thread that receives the target stream data and each of the transmission destinations Before the channel, determining that the first type of thread meets the first setting condition, the first setting condition includes at least one of the following: the total number of corresponding created transmission channels does not exceed the set number, and the setting is not exceeded. The amount of load.
The device of claim 22, wherein the device further comprises:

The third thread creation module is configured to: if the first type thread does not satisfy the first setting condition, create a third type thread to perform target stream data transmission.
The apparatus of claim 23, wherein the third thread creation module comprises:

The third thread selects a sub-module for randomly selecting one thread from the preset thread pool as the third type thread;

The stream data obtaining submodule is configured to invoke the third type thread to acquire target stream data from the first type thread that receives the target stream data, and transmit the target stream data.
The device of claim 21, wherein the device further comprises:

a first condition satisfaction module, configured to: if the thread for transmitting the target stream data includes a first type of thread and at least one third type of thread, create a first type of thread and each of the target stream data Before transmitting the transmission channel between the destination ends, selecting, in the first type of thread and the at least one third type of thread, a thread that satisfies the first setting condition, and determining that the thread that satisfies the first setting condition is the first type Thread, the first setting condition includes at least one of the following: the total number of corresponding created transmission channels does not exceed the set number, and the set load amount is not exceeded.
The device of claim 25, wherein the device further comprises:

The third thread invokes a module, if it is determined that the thread satisfying the first setting condition is not the first type thread, the third type thread that satisfies the first setting condition is called to perform the target stream data transmission.
The device of claim 25, wherein the device further comprises:

a thread random module, configured to: if the thread satisfying the first setting condition includes the first type thread and the at least one third type thread, randomly select one thread from the first type thread and the at least one third type thread, and determine a random The selected thread is the first type of thread.
The device of claim 25, wherein the device further comprises:

a second condition satisfaction module, configured to: if the thread satisfying the first setting condition includes the first type thread and the at least one third type thread, further determining that the thread satisfying the second setting condition is the first type thread, The second setting condition includes at least one of the following: the total number of transmission channels corresponding to the creation is the smallest, and the corresponding load amount is the least.
The device of claim 28, wherein the device further comprises:

The third thread invokes a module, configured to: if the first type of thread does not satisfy the second set condition, invoke a third type of thread that satisfies the second set condition to perform target stream data transmission.
The device of claim 23, wherein the device further comprises:

The third creating module is configured to create a new third type thread if the existing first type thread and the third type thread do not satisfy the first setting condition.
The device of claim 17 or 22, wherein the device further comprises:

a number update module, configured to update, according to the number of established transmission channels, the record for the first type of thread after the creating a transmission channel between the first type of thread and each of the transmission destinations The total number of transmission channels.
The apparatus according to claim 17, wherein the thread allocation module is configured to randomly select a thread from the preset thread pool as the first type of thread for receiving the stream data to be received.
A computer program comprising computer readable code, when said computer readable code is run on a computing device, causing said computing device to perform a concurrent transmission method of streaming data according to any of claims 1-16 .
A computer readable medium storing the computer program of claim 33.