[go: up one dir, main page]

WO2018127013A1 - Procédé et dispositif permettant de transmettre simultanément des données de flux - Google Patents

Procédé et dispositif permettant de transmettre simultanément des données de flux Download PDF

Info

Publication number
WO2018127013A1
WO2018127013A1 PCT/CN2017/120143 CN2017120143W WO2018127013A1 WO 2018127013 A1 WO2018127013 A1 WO 2018127013A1 CN 2017120143 W CN2017120143 W CN 2017120143W WO 2018127013 A1 WO2018127013 A1 WO 2018127013A1
Authority
WO
WIPO (PCT)
Prior art keywords
thread
type
transmission
stream data
target stream
Prior art date
Application number
PCT/CN2017/120143
Other languages
English (en)
Chinese (zh)
Inventor
韩天乐
Original Assignee
北京奇虎科技有限公司
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by 北京奇虎科技有限公司 filed Critical 北京奇虎科技有限公司
Publication of WO2018127013A1 publication Critical patent/WO2018127013A1/fr

Links

Images

Classifications

    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/50—Network services
    • H04L67/60—Scheduling or organising the servicing of application requests, e.g. requests for application data transmissions using the analysis and optimisation of the required network resources
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/14—Session management

Definitions

  • 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.
  • 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.
  • CDN Content Delivery Network
  • 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.
  • a transmission node is deployed to buffer the stream data and provide services to the user nearby.
  • a thread is randomly assigned to each connection to establish a connection for streaming data transmission, thereby implementing concurrent transmission of stream data.
  • 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.
  • a method for concurrent transmission of stream data including:
  • 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.
  • a concurrent transmission apparatus for streaming data 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.
  • a computer program 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.
  • a computer readable medium wherein the computer program described above is stored.
  • 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.
  • FIG. 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. 3 is a block diagram showing the structure of a concurrent transmission device for streaming data according to Embodiment 3 of the present invention.
  • 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.
  • 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.
  • 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.
  • network devices such as clients or servers.
  • 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.
  • 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.
  • 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.
  • the pointer 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.
  • 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.
  • the transmission channel may refer to a Socket (the original meaning of the socket is "hole” or “socket”.
  • Socket the original meaning of the socket is "hole” or "socket”.
  • Address and port is a handle to a communication chain that can be used to communicate between different virtual machines or different computers.
  • 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.
  • 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.
  • 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.
  • 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.
  • 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.
  • 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.
  • 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.
  • 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.
  • 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.
  • the transmission destination is a server, and the identifier may include a network address of the server.
  • 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.
  • FIG. 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.
  • 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.
  • 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.
  • 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.
  • 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.
  • Step 204 Determine whether the thread for transmitting the target stream data includes only the first type of 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.
  • 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.
  • 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.
  • the third type of thread is created to perform transmission of the target stream data.
  • 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.
  • 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.
  • 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
  • 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.
  • 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.
  • the third type thread that satisfies the first setting condition is called to perform the transmission of the target stream data.
  • 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.
  • 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.
  • 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.
  • 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.
  • 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.
  • the third type thread that satisfies the second setting condition is called to perform the transmission of the target stream data.
  • 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.
  • a new third type thread is created.
  • 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.
  • 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.
  • 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.
  • 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.
  • 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.
  • 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.
  • the device further includes:
  • 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 further includes:
  • 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 device further includes:
  • 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 further includes:
  • 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 further includes:
  • 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 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.
  • the device further includes:
  • 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 further includes:
  • 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 further includes:
  • 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 further includes:
  • 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 further includes:
  • 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 further includes:
  • 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 further includes:
  • 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 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.
  • 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 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.
  • a microprocessor or digital signal processor 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.
  • 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.
  • 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.
  • 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.

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Two-Way Televisions, Distribution Of Moving Picture Or The Like (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)

Abstract

L'invention concerne un procédé et un dispositif permettant de transmettre simultanément des données de flux. Le procédé comprend les étapes suivantes : l'attribution de fils de premier type afin de recevoir des données de flux ; si plusieurs demandes de transmission destinées à des données de flux cibles sont reçues, la détermination d'extrémités de destination de transmission correspondant aux demandes de transmission et la création de tâches de transmission correspondantes ; la création de voies de transmission entre les fils de premier type destinés à recevoir les données de flux cibles et les extrémités de destination de transmission ; l'appel des fils de premier type pour exécuter simultanément la pluralité de tâches de transmission afin de transmettre les données de flux cibles aux extrémités de destination de transmission par l'intermédiaire des voies de transmission correspondantes. En effectuant la transmission des données de flux vers des extrémités de destination de transmission directement sur des fils destinés à recevoir des données de flux, la solution technique évite le problème de transfert de données de flux vers une pluralité de fils destinés à envoyer des données de flux au moyen de fils destinés à recevoir des données de flux, réduit les surdébits de performance provoqués par le transfert de données entre les fils et réduit le temps de réponse.
PCT/CN2017/120143 2017-01-03 2017-12-29 Procédé et dispositif permettant de transmettre simultanément des données de flux WO2018127013A1 (fr)

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
CN201710002598.1A CN106790632B (zh) 2017-01-03 2017-01-03 一种流数据的并发传输方法和装置
CN201710002598.1 2017-01-03

Publications (1)

Publication Number Publication Date
WO2018127013A1 true WO2018127013A1 (fr) 2018-07-12

Family

ID=58949391

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/CN2017/120143 WO2018127013A1 (fr) 2017-01-03 2017-12-29 Procédé et dispositif permettant de transmettre simultanément des données de flux

Country Status (2)

Country Link
CN (1) CN106790632B (fr)
WO (1) WO2018127013A1 (fr)

Families Citing this family (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN106790632B (zh) * 2017-01-03 2020-07-14 北京奇虎科技有限公司 一种流数据的并发传输方法和装置
CN111026543B (zh) * 2019-10-31 2023-06-16 北京浪潮数据技术有限公司 一种存储系统转发数据的方法、装置、设备及介质

Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20110225302A1 (en) * 2010-03-12 2011-09-15 Park Anthony N Parallel streaming
CN104283694A (zh) * 2013-07-02 2015-01-14 北京邮电大学 基于ip组播及p2p补偿的流媒体传输方法
CN104346135A (zh) * 2013-08-08 2015-02-11 腾讯科技（深圳）有限公司 数据流并行处理的方法、设备及系统
CN104539727A (zh) * 2015-01-15 2015-04-22 北京国创富盛通信股份有限公司 一种基于ap平台的缓存方法和系统
US20150281114A1 (en) * 2014-03-28 2015-10-01 Akamai Technologies, Inc. Systems and methods for allocating work for various types of services among nodes in a distributed computing system
CN106790632A (zh) * 2017-01-03 2017-05-31 北京奇虎科技有限公司 一种流数据的并发传输方法和装置

Family Cites Families (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN104572290A (zh) * 2013-10-11 2015-04-29 中兴通讯股份有限公司 消息处理线程的控制方法及装置
US9575825B2 (en) * 2014-12-23 2017-02-21 International Business Machines Corporation Push instruction for pushing a message payload from a sending thread to a receiving thread
CN105045681A (zh) * 2015-07-10 2015-11-11 上海爱数软件有限公司 一种Oracle多通道并行备份及恢复方法
CN105162634B (zh) * 2015-09-24 2018-05-15 成都广达新网科技股份有限公司 在同一线程中收发oam协议包的处理方法
CN106095597B (zh) * 2016-05-30 2017-09-26 深圳市鼎盛智能科技有限公司 客户端数据处理方法及装置

Patent Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20110225302A1 (en) * 2010-03-12 2011-09-15 Park Anthony N Parallel streaming
CN104283694A (zh) * 2013-07-02 2015-01-14 北京邮电大学 基于ip组播及p2p补偿的流媒体传输方法
CN104346135A (zh) * 2013-08-08 2015-02-11 腾讯科技（深圳）有限公司 数据流并行处理的方法、设备及系统
US20150281114A1 (en) * 2014-03-28 2015-10-01 Akamai Technologies, Inc. Systems and methods for allocating work for various types of services among nodes in a distributed computing system
CN104539727A (zh) * 2015-01-15 2015-04-22 北京国创富盛通信股份有限公司 一种基于ap平台的缓存方法和系统
CN106790632A (zh) * 2017-01-03 2017-05-31 北京奇虎科技有限公司 一种流数据的并发传输方法和装置

Also Published As

Publication number Publication date
CN106790632A (zh) 2017-05-31
CN106790632B (zh) 2020-07-14

Similar Documents

Publication Publication Date Title
CN109688235B (zh) 虚拟网络业务处理方法、装置和系统，控制器，存储介质
US8090790B2 (en) Method and system for splicing remote direct memory access (RDMA) transactions in an RDMA-aware system
JP3382953B2 (ja) 有限メモリコンピュータシステム上におけるクライアント管理フロー制御方法及び装置
US9264369B2 (en) Technique for managing traffic at a router
CN113132489A (zh) 下载文件的方法、装置、计算设备和介质
WO2017041398A1 (fr) Procédé et dispositif de transmission de données
JP2009251708A (ja) Ｉ／ｏノード制御方式及び方法
EP2755363A1 (fr) Procédé et dispositif de distribution rapide de données
CN105577801A (zh) 一种业务加速方法及装置
CN112491066B (zh) 负载均衡方法、装置、系统、目标负载均衡设备及介质
CN114153581B (zh) 数据处理方法、装置、计算机设备和存储介质
US10212259B2 (en) Management of transmission control blocks (TCBs) supporting TCP connection requests in multiprocessing environments
US6934761B1 (en) User level web server cache control of in-kernel http cache
CN103166845A (zh) 数据处理方法和装置
US10154116B1 (en) Efficient synchronization of locally-available content
CN118200253A (zh) 面向rdma ud传输的可靠通信方法、电子设备及可读介质
WO2018127013A1 (fr) Procédé et dispositif permettant de transmettre simultanément des données de flux
WO2020124726A1 (fr) Procédé de distribution de flux audio et vidéo dans un système de distribution de flux audio et vidéo, et nœud parent dynamique
CN110290009B (zh) 一种数据调度方法、装置及计算机可读存储介质
US6668279B1 (en) User level web server in-kernel network I/O accelerator
CN107294911A (zh) 一种数据包监听方法及装置、远程过程调用系统、设备
CN104394095A (zh) 数据传输方法、系统及源服务器
CN111756649A (zh) 一种数据传输方法、装置、设备及计算机可读存储介质
CN116074553B (zh) 视频流传输方法、装置、电子设备及存储介质
JP2002342193A (ja) データ転送先サーバ選定方法及び装置及びデータ転送先サーバ選定プログラム及びデータ転送先サーバ選定プログラムを格納した記憶媒体

Legal Events

Date Code Title Description
121 Ep: the epo has been informed by wipo that ep was designated in this application

Ref document number: 17890253

Country of ref document: EP

Kind code of ref document: A1

NENP Non-entry into the national phase

Ref country code: DE

122 Ep: pct application non-entry in european phase

Ref document number: 17890253

Country of ref document: EP

Kind code of ref document: A1