WO2023045191A1

WO2023045191A1 - Video stream obtaining method and apparatus, server, storage medium, and program product

Info

Publication number: WO2023045191A1
Application number: PCT/CN2022/071431
Authority: WO
Inventors: 曹强; 刘琛; 顾恩超
Original assignee: 上海商汤智能科技有限公司
Priority date: 2021-09-22
Filing date: 2022-01-11
Publication date: 2023-03-30
Also published as: CN113873301A

Abstract

Disclosed in embodiments of the present application are a video stream obtaining method and apparatus, a server, a storage medium, and a program product. The method comprises: a first task analysis service in a server determines, after receiving a request message for obtaining a video stream, whether the first task analysis service has access to the video stream, wherein the request message is sent to the first task analysis service by a client on the basis of a first mapping relationship, and the first mapping relationship is used for indicating a client corresponding to each task analysis service in the server; and in the case that the first task analysis service does not have access to the video stream, a task management service in the server redirects the client to a second task analysis service on the basis of a second mapping relationship, such that the client can obtain the video stream by means of the redirected second task analysis service, wherein the second mapping relationship is used for indicating a video stream to which each task analysis service has corresponding access, and the task management service is determined from a plurality of task analysis services in the server.

Description

Method and device for acquiring video stream, server, storage medium and program product

Cross References to Related Applications

This application is based on a Chinese patent application with application number 202111109163.X and a filing date of September 22, 2021, and claims the priority of this Chinese patent application. The entire content of this Chinese patent application is hereby incorporated by reference in its entirety this application.

technical field

The embodiments of the present application relate to communication technologies, and relate to but are not limited to a method and device for acquiring a video stream, a server, a storage medium, and a program product.

Background technique

At present, the types of front-end equipment used by different manufacturers and the types of their respective platform protocols are different, which also has higher and higher requirements for the compatibility, stability and performance of the video access distribution system.

Therefore, how to provide a highly compatible, high-performance, stable and reliable video access distribution system has become a research hotspot for those skilled in the art.

Contents of the invention

In view of this, embodiments of the present application provide a method and device for acquiring video streams, a server, a storage medium, and a program product.

The technical scheme of the embodiment of the application is realized in this way:

In the first aspect, the embodiment of the present application provides a method for acquiring a video stream, which is applied to a server, and the method includes:

The first task analysis service in the server determines whether it has accessed the video stream after receiving the request message for obtaining the video stream; wherein, the request message is sent by the client based on the first mapping relationship to the For the first task analysis service, the first mapping relationship is used to indicate the client corresponding to each task analysis service in the server; when the first task analysis service does not access the video stream, the The task management service in the server redirects the client to the second task analysis service based on the second mapping relationship, so that the client can obtain the video stream through the redirected second task analysis service; wherein, The second mapping relationship is used to indicate that each task analysis service has a corresponding access video stream; the task management service is determined from multiple task analysis services in the server.

In the second aspect, the embodiment of the present application provides a device for obtaining a video stream, the device includes: a determining unit configured to determine the first task analysis service in the server after receiving a request message for obtaining a video stream Whether the video stream has been accessed; wherein, the request message is sent by the client to the first task analysis service based on a first mapping relationship, and the first mapping relationship is used to indicate that each task in the server A client corresponding to the analysis service; a redirection unit configured to, when the first task analysis service does not access the video stream, the task management service in the server sends the client to the client based on the second mapping relationship Redirecting to the second task analysis service, so that the client can obtain the video stream through the redirected second task analysis service; wherein, the second mapping relationship is used to indicate that each task analysis service has Corresponding to the accessed video stream; the task management service is determined from multiple task analysis services in the server.

In a third aspect, an embodiment of the present application provides a server, including a memory and a processor, the memory stores a computer program that can run on the processor, and the processor implements the steps in the above method when executing the program.

In a fourth aspect, the embodiments of the present application provide a computer-readable storage medium, on which a computer program is stored, and when the computer program is executed by a processor, the steps in the above method are implemented.

In the fifth aspect, an embodiment of the present application provides a computer program product, the computer program product includes a non-transitory computer-readable storage medium storing a computer program, and when the computer program is read and executed by a computer, the implementation of the present application can be realized. Some or all steps of the method described in the example. The computer program product may be a software installation package.

Embodiments of the present application provide a video stream acquisition method and device, server, storage medium, and program product. After receiving a request message for video stream acquisition, the first task analysis service in the server determines whether it has received the video stream. input the video stream; wherein, the request message is sent by the client to the first task analysis service based on the first mapping relationship, and the first mapping relationship is used to indicate that each task analysis service in the server corresponds to client; in the case that the first task analysis service does not access the video stream, the task management service in the server redirects the client to the second task analysis service based on the second mapping relationship, Enable the client to obtain the video stream through the redirected second task analysis service; wherein, the second mapping relationship is used to indicate that each task analysis service has a corresponding access to the video stream; the The task management service is determined from a plurality of task analysis services in the server. In this way, the redirection mechanism can be used to realize the traceability function of the video, so as to ensure that the video access distribution system (i.e. the server) is not connected to the front-end equipment (i.e. The device in which it is located) has a performance impact, and ensures that the internal forwarding function of the system is normal and effective.

Description of drawings

FIG. 1A is a schematic diagram of a system architecture corresponding to a method for acquiring a video stream according to an embodiment of the present application;

FIG. 1B is a first schematic diagram of the implementation process of the method for acquiring video streams in the embodiment of the present application;

FIG. 2 is a second implementation flow diagram of a method for acquiring a video stream according to an embodiment of the present application;

FIG. 3 is a schematic diagram of the third implementation process of the method for acquiring video streams in the embodiment of the present application;

FIG. 4 is a schematic diagram 4 of an implementation process of a method for acquiring a video stream according to an embodiment of the present application;

FIG. 5 is a schematic diagram of the implementation process of the video stream acquisition method according to the embodiment of the present application (5);

FIG. 6 is a schematic diagram of the composition and structure of an apparatus for obtaining a video stream according to an embodiment of the present application;

FIG. 7 is a schematic diagram of a hardware entity of a server according to an embodiment of the present application.

Detailed ways

The technical solution of the present application will be further described in detail below in conjunction with the accompanying drawings and embodiments. Apparently, the described embodiments are only some of the embodiments of the present application, rather than all the embodiments. Based on the embodiments of the present application, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts belong to the scope of protection of the present application.

In the following description, references to "some embodiments" describe a subset of all possible embodiments, but it is understood that "some embodiments" may be the same subset or a different subset of all possible embodiments, and Can be combined with each other without conflict.

In the following description, the use of suffixes such as 'module', 'part' or 'unit' for denoting elements is only for facilitating the description of the present application and has no specific meaning by itself. Therefore, 'module', 'part' or 'unit' may be used in combination.

It should be pointed out that the term "first\second\third" involved in the embodiment of the present application is only to distinguish similar objects, and does not represent a specific ordering of objects. Understandably, "first\second\third Where permitted, the specific order or sequence may be interchanged such that the embodiments of the application described herein can be practiced in sequences other than those illustrated or described herein.

FIG. 1A is a schematic diagram of a system architecture corresponding to a video stream acquisition method according to an embodiment of the present application. As shown in FIG. 1A, the system architecture may include at least one client 11, a network 12, a server 13, and at least one front-end device 14, in:

The user can use the client 11 to interact with the server 13 through the network 12 to obtain data such as video streams located on the front-end device 14. The front-end device 14 accesses the server 13, and the server 13 can access and manage the front-end device 14, and send the access result to the client 11 at the same time. That is to say, the server 13 can request the video stream on the front-end device 14 and forward the video stream to the client 11 . Therefore, the server 13 can be regarded as a video access distribution system.

In a broad sense, the client 11 can be various types of devices with information processing capabilities, including but not limited to navigators, smart phones, tablet computers, wearable devices, laptop computers, all-in-one computers, and desktop computers, etc. . In a narrow sense, the client 11 may be a streaming media server.

The server 13 may be a computing device with information processing capabilities such as a personal computer and a server cluster during implementation. Described server 13 can be the server that provides various services, for example, described server can be distributed server, comprises a plurality of node servers in the described distributed server, all has at least one task analysis service on each node server, when When the client 11 needs to acquire the video stream on the front-end device 14, the client 11 can send an acquisition request to a certain service node in the distributed server according to a certain mapping relationship, and the task analysis service on the service node The acquisition request may be processed. The front-end device 14 may be an electronic device (for example, a camera) or a platform (for example, a data platform of a view analysis manufacturer).

Based on this, an embodiment of the present application provides a method for acquiring a video stream, the method is applied to a server, and the functions implemented by the method can be implemented by calling the program code from the processor of the server. Of course, the program code can be stored in the storage medium of the server mentioned above. FIG. 1B is a schematic diagram of the first implementation process of the method for obtaining video streams in the embodiment of the present application. As shown in FIG. 1B, the method includes:

Step S101, the first task analysis service in the server determines whether it has accessed the video stream after receiving the request message for obtaining the video stream; wherein, the request message is sent by the client based on the first mapping relationship For the first task analysis service, the first mapping relationship is used to indicate the client corresponding to each task analysis service in the server;

Here, the server may be a computing device with information processing capabilities such as a personal computer and a server cluster. The server has the functions of video access and video distribution, and the task analysis service in the server can access the video stream in the front-end device, and distribute the accessed video stream to the client.

In the embodiment of the present application, the task analysis service in the server can access the video stream in the front-end device, that is, the task analysis service can continuously access the video stream in the front-end device, and the task analysis service and The transmission state of the video stream is always maintained between the front-end devices.

Here, the client may be a streaming media server, and different streaming media servers correspond to different task analysis services. There is a first mapping relationship between the first task analysis service and the client sending the request message. For example, streaming media server A corresponds to task analysis service A, streaming media server B corresponds to task analysis service B, and streaming media server C corresponds to task analysis service C.

Certainly, in some embodiments, it is also possible that the client directly sends a request for obtaining video streams to the server through a domain name, and the server internally resolves the domain name and designates a certain node (possibly randomly designated) to process all the video streams. In this way, if a distributed server is used, the multi-nodes in the distributed server can realize high reliability of load sharing at random.

Step S102, in the case that the first task analysis service does not access the video stream, the task management service in the server redirects the client to the second task analysis service based on the second mapping relationship, so that The client can obtain the video stream through the redirected second task analysis service; wherein, the second mapping relationship is used to indicate that each task analysis service has correspondingly accessed video stream; the task The management service is determined from a plurality of task analysis services in the server.

Here, the first task analysis service may determine whether it accesses the video stream according to the identification information of the video stream, that is, determines whether it is in a state of transmitting the video stream. Wherein, the service node where the first task analysis service is located may have a local cache, and the local cache stores the mapping relationship between the first task analysis service and the video stream it accesses, and further, the second A task analysis service can know whether it has accessed the video stream requested by the client by checking the data in the local cache.

Here, different task analysis services may correspond to different video streams. There is no second mapping relationship between the first task analysis service and the video stream that the client needs to request, and there is a second mapping relationship between the second task analysis service and the video stream that the client needs to request. For example, streaming media server A corresponds to task analysis service A, and the task analysis service A corresponds to accessing the first type of video stream. The streaming media server B corresponds to the task analysis service B, and the task analysis service B corresponds to accessing the second type of video stream. The streaming media server C corresponds to the task analysis service C, and the task analysis service C corresponds to accessing the third type of video stream.

For example, the streaming media server A (that is, the client A) sends a request message to the task analysis service A to obtain the third type of video stream, and the task analysis service A finds that it does not have access to the third type of video stream. type of video stream. The task analysis service A sends a query request message to the task management service, and the task management service inquires that the task analysis service C has accessed the third type of video stream, then the task management service redirects the streaming media service A to the task Analysis service C, after receiving the video stream request message sent by streaming media service A, the task analysis service C inquires that it has access to a third type of video stream, and directly sends the third type of video stream Return to streaming service A. In this way, the redirection mechanism is used to realize the traceability function of the video, to ensure that the video access distribution system (that is, the server) does not affect the performance of the front-end device (that is, the device where the video stream is located), and to ensure that the internal forwarding function of the system is normal and effective.

In this embodiment of the application, the task management service may be determined from a certain task analysis service after the system is created, that is to say, the service node where the task management service is located not only has video access The traceability function also has specific video access and distribution functions, so that resource reuse can be realized.

Based on the foregoing embodiments, this embodiment of the present application further provides a video stream acquisition method, the method is applied to a server, and the server includes a plurality of service nodes, and there is at least one task analysis service on each of the service nodes, The methods include:

Step S111, determining the first service node among the plurality of service nodes as a task management node;

In the embodiment of this application, the server usually includes several machines, or several sets of virtual machine environments. In this case, a machine or a set of virtual machine environments is a service node, and a server with multiple service nodes is a distributed server. . The task analysis service can be regarded as a process running on this node, and this process will use the IP (Internet Protocol, Internet Protocol) address of this node to monitor externally or establish a network connection.

Here, the distributed server is characterized by multi-node and multi-copy operation. In one case, each of the multiple service nodes (ie, physical machines) has a service (task analysis service or task management service). In another case, there are multiple services on one server, and each service is regarded as a virtual machine, and different virtual machines have resource isolation, both of which belong to distributed servers. In the embodiment of the present application, the distributed system framework is used to obtain the video stream, so that it has the characteristics of high reliability and high expansion, so as to ensure the stable and efficient operation of the access and forwarding functions in the scene of video stream acquisition. At the same time, among the multiple service nodes of the video access distribution system, a certain node is elected as the role of task management, so as to realize the redirection scheduling of pulling video streams between different nodes.

In the embodiment of the present application, the main function of the task management node is to query whether there is a service node to access the video stream required by the client, and if there is a service node to access the video stream, then determine to access the video stream specific service node, and send the query result to the service node where the first task analysis service is located. The node where the first task analysis service is located then sends the node address of the specific service node to the client, so that the client can obtain the video stream through the task analysis service on the specific service node. Through the above method, the redirection mechanism can be used to ensure the distribution of multiple services, and the traced services can be directly fed back to the client for docking, reducing the network consumption between the nodes where the internal services are located.

Here, any service node among the plurality of service nodes may be determined as the task management node, and a service node with the smallest load among the plurality of service nodes may be determined as the task management node. Of course, other methods can also be used to determine a certain service node as the task management node, that is, the method for determining the task management node in the embodiment of the present application is not limited, and those skilled in the art can use needs to be set.

Step S112, determining the task analysis service in the task management node as the task management service;

Here, if there is a task analysis service in the task management node, this task analysis service is determined as the task management service.

Step S113, the first task analysis service in the server determines whether it has accessed the video stream after receiving the request message for obtaining the video stream; wherein, the request message is sent by the client based on the first mapping relationship For the first task analysis service, the first mapping relationship is used to indicate the client corresponding to each task analysis service in the server;

Here, if the server is a distributed server, and the distributed server includes multiple service nodes, and there is at least one task analysis service on each service node, the first mapping relationship is used to indicate that each A client corresponding to the service node.

Here, the first task analysis service is a task analysis service on the service node corresponding to the client in the first mapping relationship.

Step S114, in the case that the first task analysis service does not access the video stream, the task management service in the server redirects the client to the second task analysis service based on the second mapping relationship, so that The client can obtain the video stream through the redirected second task analysis service;

Wherein, the second mapping relationship is used to indicate that each of the service nodes has correspondingly accessed video streams.

Here, the second mapping relationship exists between the service node where the second task analysis service is located and the video stream.

Through the above method, the distributed system framework can be used to obtain video streams, so that it has the characteristics of high reliability and high expansion, so as to ensure the stable and efficient operation of the access and forwarding functions in the video stream acquisition scene. At the same time, among the multiple task analysis services of the video access distribution system, a certain task analysis service is elected as the role of task management, so as to realize the redirection scheduling of pulling video streams between different services while reusing resources.

Based on the aforementioned embodiments, the embodiment of the present application further provides a method for obtaining a video stream, and the method is applied to a server. FIG. 2 is a schematic diagram of the second implementation process of the method for obtaining a video stream in the embodiment of the present application, as shown in FIG. 2 , the method includes:

Step S201, the first task analysis service in the server determines whether it has accessed the video stream after receiving the request message for obtaining the video stream; wherein, the request message is sent by the client based on the first mapping relationship For the first task analysis service, the first mapping relationship is used to indicate the client corresponding to each task analysis service in the server;

Step S202. In the case that the first task analysis service does not access the video stream, the first task analysis service sends a query request message to the task management service; wherein, the query request message carries Identification information of the video stream;

Step S203, the task management service queries the task analysis service that has accessed the video stream according to the identification information and the second mapping relationship, and obtains a query result;

In the embodiment of the present application, after the task management service receives the query request message sent by the first task analysis service, the task management service may query the task analysis service that has accessed the video stream in the shared storage, In order to realize the traceability function of the video. In this way, the client can directly use the task analysis service that has accessed the video stream to obtain the video stream, thereby ensuring that the video access distribution system (that is, the server) does not affect the performance of the front-end equipment, and that the system's The internal forwarding function works normally.

Step S204, when the query result indicates that the second task analysis service in the server has accessed the video stream, the task management service sends the query result to the first task analysis service, enabling the client to obtain the video stream through the second task analysis service; wherein, the second mapping relationship is used to indicate that each task analysis service has correspondingly accessed video stream; the task management The service is determined from a plurality of task analysis services in the server.

In some embodiments, the server includes multiple service nodes, and at least one task analysis service exists on each of the service nodes; correspondingly, the second mapping relationship is used to indicate that each of the service nodes The video stream that the node has been connected to;

Correspondingly, the method also includes:

Step S21, determining the first service node among the plurality of service nodes as a task management node;

Step S22, determining the task analysis service in the task management node as the task management service.

Based on the foregoing embodiments, this embodiment of the present application further provides a method for obtaining a video stream, the method is applied to a server, and the method includes:

Step S211, the first task analysis service in the server determines whether it has accessed the video stream after receiving the request message for obtaining the video stream; wherein, the request message is sent by the client based on the first mapping relationship For the first task analysis service, the first mapping relationship is used to indicate the client corresponding to each task analysis service in the server;

Step S212, in the case that the first task analysis service does not access the video stream, the first task analysis service sends a query request message to the task management service; wherein, the query request message carries Identification information of the video stream;

Step S213, the task management service queries the task analysis service that has accessed the video stream according to the identification information and the second mapping relationship, and obtains a query result;

Here, the purpose of carrying the identification information of the video stream in the query request message is that the task management service can query which node the task analysis service on which accesses the video stream according to the identification information.

Step S214, when the query result indicates that the second task analysis service in the server has accessed the video stream, the task management service sends the query result to the first task analysis service;

Step S215, the first task analysis service sends the node address of the second task analysis service to the client, so that the client can establish media with the second task analysis service according to the node address Connect to obtain the video stream; wherein, the second mapping relationship is used to indicate that each task analysis service has correspondingly accessed video stream; the task management service analyzes the tasks from multiple tasks in the server identified in the service.

In this embodiment of the application, when docking, the client first sends a basic signaling to the corresponding service node. After the service node determines that the video stream requested by the client is not accessed, it will search for the The service node of the video stream, and returns a 302 error, the error code carries a new address (that is, the found address of the service node that has accessed the video stream), and then, the client gets this After the new address, a request to obtain the video stream will be sent again, because the address has changed, so it is redirected. In this way, for a video source that has been accessed, when the client requests the video source from the task analysis service, if the node to which the video source has accessed is not the current service node corresponding to the client, redirected way to achieve the correct connection between the client and the service node.

In some embodiments, in step S213, the task management service queries the task analysis service that has accessed the video stream according to the identification information and the second mapping relationship, and obtains a query result, including:

Step S2131, the task management service determines the address information of the video stream that has been accessed according to the identification information and the second mapping relationship;

Here, the task analysis service that has accessed the video stream may be determined according to the address information that has accessed the video stream. That is to say, there is a corresponding relationship between the address information and the task analysis service, so that the traceability function of the video source to be accessed can be realized according to the corresponding relationship between the address information of the accessed video stream and the task analysis service.

Step S2132, the task management service determines the task analysis service that has accessed the video stream according to the address information, and obtains a query result.

Based on the foregoing embodiments, this embodiment of the present application further provides a method for obtaining a video stream, and the method is applied to a server. FIG. 3 is a schematic diagram of the third implementation process of the method for obtaining a video stream according to the embodiment of the present application, as shown in FIG. 3 , the method includes:

Step S301, the first task analysis service in the server determines whether it has accessed the video stream after receiving the request message for obtaining the video stream; wherein, the request message is sent by the client based on the first mapping relationship For the first task analysis service, the first mapping relationship is used to indicate the client corresponding to each task analysis service in the server;

Here, if the first task analysis service does not access the video stream, perform the following step S302; if the first task analysis service has access to the video stream, perform the following steps S303 to S304 .

Step S302, the task management service in the server redirects the client to the second task analysis service based on the second mapping relationship, so that the client can obtain the video through the redirected second task analysis service stream; wherein, the second mapping relationship is used to indicate that each task analysis service has correspondingly accessed video stream; the task management service is determined from multiple task analysis services in the server;

Step S303, the first task analysis service establishes a media connection with the client;

Here, if the first task analysis service has access to the video stream, the first task analysis service may be used directly to provide the client with the required video stream.

Step S304, the first task analysis service sends the accessed video stream to the client through the media connection.

Step S311, the first task analysis service in the server determines whether it has accessed the video stream after receiving the request message for obtaining the video stream; wherein, the request message is sent by the client based on the first mapping relationship For the first task analysis service, the first mapping relationship is used to indicate the client corresponding to each task analysis service in the server;

Here, if the first task analysis service does not access the video stream, perform the following steps S312 to S314; otherwise, if the first task analysis service has access to the video stream, perform the following Step S315 to step S316.

Step S312, the first task analysis service sends a query request message to the task management service; wherein, the query request message carries identification information of the video stream;

Step S313, the task management service queries the task analysis service that has accessed the video stream according to the identification information and the second mapping relationship, and obtains a query result;

Step S314, when the query result indicates that the second task analysis service in the server has accessed the video stream, the task management service sends the query result to the first task analysis service, enabling the client to obtain the video stream through the second task analysis service; wherein, the second mapping relationship is used to indicate that each task analysis service has correspondingly accessed video stream; the task management The service is determined from a plurality of task analysis services in the server;

Step S315, the first task analysis service establishes a media connection with the client;

Step S316, the first task analysis service sends the accessed video stream to the client through the media connection.

In some embodiments, the method further includes: when the query result shows that no task analysis service that has accessed the video stream is found, the task management service determines the target task analysis service according to preset rules. service, so that the client can obtain the video stream through the target task analysis service.

Based on the foregoing embodiments, this embodiment of the present application further provides a method for obtaining a video stream, and the method is applied to a server. FIG. 4 is a schematic diagram 4 of the implementation process of the method for obtaining a video stream according to the embodiment of the present application, as shown in FIG. 4 , the method includes:

Step S401, the first task analysis service in the server determines whether it has accessed the video stream after receiving the request message for obtaining the video stream; wherein, the request message is sent by the client based on the first mapping relationship For the first task analysis service, the first mapping relationship is used to indicate the client corresponding to each task analysis service in the server;

Step S402. In the case that the first task analysis service does not access the video stream, the first task analysis service sends a query request message to the task management service; wherein, the query request message carries Identification information of the video stream;

Step S403, the task management service queries the task analysis service that has accessed the video stream according to the identification information and the second mapping relationship, and obtains a query result;

Step S404, when the query result shows that the second task analysis service in the server has accessed the video stream, the task management service sends the query result to the first task analysis service, enabling the client to obtain the video stream through the second task analysis service; wherein, the second mapping relationship is used to indicate that each task analysis service has correspondingly accessed video stream; the task management The service is determined from a plurality of task analysis services in the server;

Step S405, when the query result shows that no task analysis service that has accessed the video stream is found, the task management service determines the target task analysis service according to preset rules, so that the client can pass The target task analysis service obtains the video stream.

Here, the query result shows that no task analysis service that has accessed the video stream is found, which means that none of the task analysis services in the server has access to the video stream, and the task management service can Determine a target task analysis service to obtain the video stream according to the preset rules. In this way, when the video stream has not been accessed by the task analysis service, flexible and diverse scheduling strategies can be adopted to ensure that various scene requirements can be covered. .

Step S411, the first task analysis service in the server determines whether it has accessed the video stream after receiving the request message for obtaining the video stream; wherein, the request message is sent by the client based on the first mapping relationship For the first task analysis service, the first mapping relationship is used to indicate the client corresponding to each task analysis service in the server;

Step S412, in the case that the first task analysis service does not access the video stream, the first task analysis service sends a query request message to the task management service; wherein, the query request message carries Identification information of the video stream;

Step S413, the task management service queries the task analysis service that has accessed the video stream according to the identification information and the second mapping relationship, and obtains a query result;

Step S414, when the query result shows that the second task analysis service in the server has accessed the video stream, the task management service sends the query result to the first task analysis service, enabling the client to obtain the video stream through the second task analysis service; wherein, the second mapping relationship is used to indicate that each task analysis service has correspondingly accessed video stream; the task management The service is determined from a plurality of task analysis services in the server;

Step S415, when the query result indicates that no task analysis service that has accessed the video stream is found, the task management service determines the first task analysis service as the first task analysis service according to the first mapping relationship. The target task analysis service, so that the client can obtain the video stream through the first task analysis service.

Here, the first task analysis service is the task analysis service assigned by the server to process the request when the server receives the client's request for acquiring video streams. In this way, when no video stream has been accessed by the task analysis service , adopt the nearest scheduling strategy, which can reduce the redirection phenomenon, be more friendly to the client, the logic is simpler, and the efficiency is higher.

Step S421, the first task analysis service in the server determines whether it has accessed the video stream after receiving the request message for obtaining the video stream; wherein, the request message is sent by the client based on the first mapping relationship For the first task analysis service, the first mapping relationship is used to indicate the client corresponding to each task analysis service in the server;

Step S422. In the case that the first task analysis service does not access the video stream, the first task analysis service sends a query request message to the task management service; wherein, the query request message carries Identification information of the video stream;

Step S423, the task management service queries the task analysis service that has accessed the video stream according to the identification information and the second mapping relationship, and obtains a query result;

Step S424, when the query result indicates that the second task analysis service in the server has accessed the video stream, the task management service sends the query result to the first task analysis service, enabling the client to obtain the video stream through the second task analysis service; wherein, the second mapping relationship is used to indicate that each task analysis service has correspondingly accessed video stream; the task management The service is determined from a plurality of task analysis services in the server;

Step S425, when the query result shows that no task analysis service that has accessed the video stream is found, the task management service determines the load of at least two task analysis services in the server;

Here, if the server is a distributed server, the distributed server includes multiple service nodes, and each service node has at least one task analysis service. In the case where the query result indicates that no task analysis service that has accessed the video stream is found, the load of all task analysis services or a part of all task analysis services may be determined. The load of the task analysis service refers to the amount of the task analysis service accessing video streams and forwarding video streams.

Step S426, the task management service sorts the loads of the at least two task analysis services in ascending order of values, and obtains a sorting result;

Step S427, the task management service determines the task analysis service with the smallest load as the target task analysis service according to the sorting result, so that the client can obtain the video stream through the task analysis service with the smallest load.

Through the above method, when the video stream has not been accessed by the task analysis service, a load balancing scheduling strategy can be adopted, and the node where the service with the smallest load among all task analysis services is selected as the docking node of the client, which can reduce the system Resource pressure, improved stability.

Step S431, the first task analysis service in the server determines whether it has accessed the video stream after receiving the request message for obtaining the video stream; wherein, the request message is sent by the client based on the first mapping relationship For the first task analysis service, the first mapping relationship is used to indicate the client corresponding to each task analysis service in the server;

Step S432. In the case that the first task analysis service does not access the video stream, the first task analysis service sends a query request message to the task management service; wherein, the query request message carries Identification information of the video stream;

Step S433, the task management service queries the task analysis service that has accessed the video stream according to the identification information and the second mapping relationship, and obtains a query result;

Step S434, when the query result indicates that the second task analysis service in the server has accessed the video stream, the task management service sends the query result to the first task analysis service, enabling the client to obtain the video stream through the second task analysis service; wherein, the second mapping relationship is used to indicate that each task analysis service has correspondingly accessed video stream; the task management The service is determined from a plurality of task analysis services in the server;

Step S435, when the query result shows that no task analysis service that has accessed the video stream is found, the task management service determines a third task analysis service according to the access type of the video stream, so that The client can obtain the video stream through the third task analysis service.

Here, some service nodes (that is, some task analysis services) can only receive a certain type of video stream, then the corresponding service node can be determined according to the access type of the video stream to be obtained, and then the service node can be used The task analysis service on the Internet can obtain the required video stream, so that the video stream access and forwarding functions can be realized more flexibly to meet the needs of user scenarios.

Of course, it is also possible that some client platforms can only correspond to certain service nodes. If the video stream required by the client has not been accessed by any service node, use the service node corresponding to the platform where the client is located. Get the video stream.

At present, using a distributed system for video access distribution has obvious advantages. It can increase the system concurrency, support dynamic expansion and contraction, and the distributed system also has the characteristics of high reliability. However, when the multi-node service of the distributed system handles access to video sources, it is easy for the same front-end device video source to be requested and forwarded multiple times, resulting in waste of front-end device bandwidth resources and limited system performance. For example, client A and client B are requesting the same video stream on the front-end device at the same time, then in the distributed system at this time, the node corresponding to client A serves the node corresponding to client A and client B Service B will request the video source from the front-end device at the same time, which may result in waste of bandwidth resources of the front-end device and poor performance of the distributed system.

Therefore, functions such as video distribution and traceability, and dynamic scheduling of system resources need to be considered. It is ensured that the distribution module in the distributed system is not limited by the performance of the access module, that the access module does not affect the performance of the front-end equipment, and that system resources are efficiently and fully utilized. Wherein, both the distribution module and the access module are located in the distributed system, the access module is mainly used to obtain video streams from the front-end equipment, and the distribution module is mainly used to transfer the obtained video streams sent to the client.

Based on this, the embodiment of the present application provides a solution for obtaining video streams. The solution (1) uses a distributed system to access video source data from different manufacturers and different protocols, that is, through docking with various manufacturers' protocols and standard platform protocols to obtain Access various types of video sources (including video and audio). At the same time, the deployment of distributed architecture is adopted, and multiple nodes are connected at the same time, which improves the concurrency and access efficiency, and can use the distributed high reliability feature to improve the stability of the access module. (2) Since some video protocols check the address, port and other information of the docking system when accessing, to prevent multiple accesses by a single user from affecting the performance of its equipment. Therefore, in the distributed system, the embodiment of the present application adopts a certain mechanism to ensure that the internal forwarding can be traced to the specific accessed media service node, so as to prevent multiple accesses due to multi-path forwarding. (3) Use the Manager-Worker mechanism to distinguish the functions of different nodes, let the Manager perform the traceability function of video access, and the Worker perform specific video access and distribution functions, so as to ensure that each video source is accessed at most once. In this way, the Manager-Worker mechanism ensures that there is a reasonable and efficient resource scheduling mechanism when multiple nodes do access and forwarding in a distributed system, and the system operation efficiency is improved to the greatest extent. (4) When forwarding video streams, the specific media service node to be forwarded is negotiated with the client through the redirection function, which can reduce bandwidth consumption between nodes.

During the implementation process, when the client pulls the video stream from the node, when the node corresponding to the pulled video stream is not a node that has accessed the video stream, the embodiment of this application adopts the method of redirection to realize the client The connection to its corresponding task analysis service (that is, Worker). And, among the plurality of Workers in the distributed system, a certain Worker is elected as the role of management (that is, Manager), that is, as a task management service, so as to realize the scheduling of redirection of video streams pulled by different streaming media services. At the same time, when there is no video stream to be pulled in all access services during the redirection process, a variety of scheduling logics are designed to achieve load balancing for system scheduling.

Wherein, the scheme can be realized through the following process:

The cameras connected to the distributed system include camera A, camera B and camera C, and the cameras connected here belong to the front-end equipment. The services enabled by the distributed system itself include task analysis service A, task analysis service B and task analysis service C, which respectively access the video streams of camera A, camera B and camera C. At the same time, the clients that pull video streams include client A, client B, and client C, that is, all three clients can use the distributed system to obtain the video stream in the camera, if client A has access When there is a demand for video streams, the system will assign task analysis service A to handle the needs of client A. If client B has a need to obtain video streams, the system will assign task analysis service B to handle the needs of client B. demand, if the client C has a demand for obtaining video streams, the system will assign task analysis service C to process the demand of the client C. Wherein, each task analysis service has the function of requesting video stream from the camera and forwarding the video stream to the client. Moreover, the task analysis service B is assigned as a task management service at the same time.

Furthermore, when client C needs to pull the video stream of camera A, the distributed system will assign task analysis service C to handle client C's demand for video stream acquisition, that is, client C first sends its corresponding pull request to Task Analysis Service C. Then, task analysis service C initiates a query request to the task management service (that is, task analysis service B) according to the query result of the video stream that is not connected to camera A, so as to obtain the information of which task analysis service accesses camera A's video stream. search result. The task management service returns the query result of the video stream connected to the camera A to the task analysis service C, and the task analysis service C returns the query result to the client C (here, the query result is the task analysis service A connection into the video stream of camera A). Finally, the client C establishes a connection with the task analysis service A that accesses the video stream of the camera A, so as to obtain the video stream accessed by the task analysis service A.

Here, the distributed system forwards the original video stream in the camera to an RTSP stream for client access as an example. Figure 5 is a schematic diagram of the implementation process of the video stream acquisition method according to the embodiment of the present application, as shown in Figure 5 , the method includes:

Step S501, the client sends an RTSP (Real Time Streaming Protocol, real-time streaming protocol) request to the task analysis service C;

Here, the RTSP request is mainly used to request a certain video source of RTSP type. That is to say, the distributed system connects the streams of various manufacturers and outputs them to the client through a unified and standard protocol. If it is an RTSP player, convert the streams of various front-end manufacturers into this RTSP stream for client access.

Step S502, the task analysis service C queries the local list, and confirms whether it accesses the video stream requested by the client;

Step S503, task analysis service C sends a query request to task management service if it does not access the video stream;

Step S504, the task management service queries the address of accessing the video stream in the storage medium, and determines the task analysis service accessing the video stream as task analysis service A according to the address;

Here, the storage medium may be a shared storage storage medium, such as ZooKeeper.

Step S505, the task management service returns the address of the task analysis service A to the task analysis service C;

Step S506, the task analysis service C returns the address of the task analysis service A to the client;

Here, the task analysis service C returns the address of the client, that is, the redirection address.

Step S507, the client sends an RTSP request to the task analysis service A according to the address of the task analysis service A;

Step S508, the task analysis service A queries the local list to confirm whether it accesses the video stream requested by the client;

Step S509, the task analysis service A converts the accessed video stream into an RTSP video stream and returns it to the client.

Here, the step S501 to the step S508 are signaling streams, that is, the signaling transmission path of this solution, and the step S509 is a video stream, that is, the video stream transmission path of this solution. Moreover, the steps S501 to S509 are solutions in a case where there is a video stream that the client needs to pull in a certain node of the distributed system.

If the task management service queries all the task analysis services and does not access the video stream to be pulled, the following scheduling strategy is adopted.

(1) The first scheduling strategy: the nearest scheduling strategy.

When the client needs to pull the video stream and all the task analysis services in the distributed system do not access the video stream, select the nearest node of the client as the node for pulling the video stream (that is, the system provides The original node assigned by the client). For example, when client A requests the video source of camera A from task analysis service A, and task analysis service A finds that it does not access the video source of camera A locally, then the task analysis service A will send a request to the task management service. Query, if the query result shows that none of the video sources of camera A is accessed by other task analysis services, the nearest scheduling strategy will be adopted, and the node corresponding to task analysis service A will be directly selected as the docking node of client A. In this way, it can reduce The redirection phenomenon is more friendly to client A, the logic is simpler, and the efficiency is higher.

Here, the method described in the above step S415 is an implementation of the nearest scheduling policy.

(2) The second scheduling strategy: a load balancing scheduling strategy.

When the client needs to pull the video stream and all task analysis services in the distributed system do not access the video stream, select the node with the smallest load in the distributed system as the node for pulling the video stream. For example, when client A requests the video source of camera A from task analysis service A, and task analysis service A finds that it does not access the video source of camera A locally, then the task analysis service A will send a request to the task management service. Query, if the query result shows that none of the video sources of camera A is accessed by other task analysis services, a load balancing scheduling strategy will be adopted to calculate the load values of all task analysis services at this time, and the corresponding task analysis service with the smallest load value will be selected. The node of is used as the docking node of the client A. In this way, the resource pressure of the distributed system can be reduced and the stability can be improved.

Here, the method described in the above step S425 to step S427 is an implementation of the load balancing scheduling strategy.

(3) The third scheduling strategy: custom scheduling strategy.

When the client needs to pull the video stream and all task analysis services in the distributed system do not access the video stream, a certain node will be decided as the The node that pulls the video stream. For example, when client A requests the video source of camera A from task analysis service A, and task analysis service A finds that it does not access the video source of camera A locally, then the task analysis service A will send a request to the task management service. Query, if the query result shows that the video source of camera A is not accessed by other task analysis services, and the video source is a video source corresponding to the GB28181 protocol, the user configuration information and the access of the video source will be The protocol type determines the set of nodes that can be scheduled, and then selects a node that meets the conditions as the docking node of the client A. In this way, the access and forwarding functions can be realized more flexibly under the condition of meeting the needs of the user scenario.

Here, the method described in the above step S435 is an implementation manner of the self-defined scheduling policy.

The collection and analysis of massive video materials have higher requirements on the video access and forwarding functions of the system. Adopting the solution in the embodiment of this application can not only be compatible with more different manufacturers’ protocol video sources, but also use various distributed characteristics to achieve more stable, efficient and flexible deployment. In addition, the acquisition of video streams in the embodiment of this application The traceability, dynamic resource scheduling and redirection mechanisms in the solution reduce the dependence on external resources and the consumption of internal resources.

That is to say, the video stream acquisition scheme in the embodiment of the present application can achieve the following technical effects: (1) Based on the distributed system framework, it has the characteristics of high reliability and high expansion, thus ensuring the continuous success of video stream acquisition scenarios. stable and efficient operation of incoming and forwarding functions. (2) The Manager-Worker mechanism is adopted to realize the traceability function of the video, to ensure that the access module of the distributed system will have an impact on the performance of the front-end equipment, and to ensure that the internal forwarding function of the distributed system is normal and effective. (3) When the redirection mechanism is used to ensure multi-node distribution, the traced nodes can be directly fed back to the client for docking, which reduces the network consumption between the internal nodes of the system. (4) Flexible and diverse scheduling strategies enable the acquisition of video streams to cover various scene requirements.

Based on the aforementioned embodiments, this embodiment of the present application provides a video stream acquisition device, which includes each unit included, each sub-unit and each module included in each unit, and each sub-module included in each module and each component can be realized by the processor in the server; of course, it can also be realized by a specific logic circuit; in the process of implementation, the processor can be CPU (Central Processing Unit, central processing unit), MPU (Microprocessor Unit, Microprocessor), DSP (Digital Signal Processing, digital signal processor) or FPGA (Field Programmable Gate Array, field programmable gate array), etc.

FIG. 6 is a schematic diagram of the composition and structure of a video stream acquisition device according to an embodiment of the present application. As shown in FIG. 6, the device 600 includes:

The determining unit 601 is configured such that the first task analysis service in the server determines whether it has accessed the video stream after receiving a request message for obtaining the video stream; wherein, the request message is obtained by the client based on the first The mapping relationship is sent to the first task analysis service, and the first mapping relationship is used to indicate the client corresponding to each task analysis service in the server;

The redirection unit 602 is configured to redirect the client to the second task based on the second mapping relationship when the first task analysis service does not access the video stream. Analysis service, so that the client can obtain the video stream through the redirected second task analysis service; wherein, the second mapping relationship is used to indicate that each task analysis service has corresponding access to the video stream ; The task management service is determined from multiple task analysis services in the server.

In some embodiments, the redirecting unit 602 includes: a first sending module configured to send the first task analysis service to the The task management service sends a query request message; wherein, the query request message carries identification information of the video stream; the query module is configured so that the task management service, according to the identification information and the second mapping relationship, Querying the task analysis service that has accessed the video stream to obtain a query result; the second sending module is configured to be configured to, when the query result indicates that the second task analysis service in the server has accessed the video stream , the task management service sends the query result to the first task analysis service, so that the client can obtain the video stream through the second task analysis service.

In some embodiments, the second sending module includes: a first sending component configured to send the query result to the first task analysis service by the task management service; a second sending component configured to The first task analysis service sends the node address of the second task analysis service to the client, so that the client can establish a media connection with the second task analysis service according to the node address to obtain the described video stream.

In some embodiments, the query module includes: a first determining component configured to determine, according to the identification information and the second mapping relationship, the address information of the video stream that has been accessed by the task management service; The second determining component is configured such that the task management service determines the task analysis service that has accessed the video stream according to the address information, and obtains a query result.

In some embodiments, the server includes multiple service nodes, and at least one task analysis service exists on each of the service nodes; correspondingly, the second mapping relationship is used to indicate that each of the service nodes The node has correspondingly accessed the video stream; correspondingly, the device further includes: a management node determination unit configured to determine the first service node among the plurality of service nodes as a task management node; a management service determination unit, It is configured to determine the task analysis service in the task management node as the task management service.

In some embodiments, the device further includes: a connection establishment unit configured to establish a connection between the first task analysis service and the client when the first task analysis service has accessed the video stream A media connection; a sending unit configured to send the accessed video stream to the client through the media connection for the first task analysis service.

In some embodiments, the device further includes: a target service determining unit, configured to, if the query result shows that no task analysis service that has accessed the video stream is found, the task management service A rule is set to determine a target task analysis service, so that the client can obtain the video stream through the target task analysis service.

In some embodiments, the target service determining unit includes: a first target service determining module, configured for the task management service to determine the first task analysis service as the target task according to the first mapping relationship An analysis service, so that the client can obtain the video stream through the first task analysis service.

In some embodiments, the target service determination unit includes: a load determination module configured for the task management service to determine the loads of at least two task analysis services in the server; a sorting module configured for the task management service Sorting the loads of the at least two task analysis services in ascending order to obtain a sorting result; the second target service determination module is configured so that the task management service sorts the task analysis service with the smallest load according to the sorting result Determine the target task analysis service, so that the client can obtain the video stream through the task analysis service with the least load.

In some embodiments, the target service determining unit includes: a third target service determining module, configured for the task management service to determine a third task analysis service according to the access type of the video stream, so that the client The terminal can obtain the video stream through the third task analysis service.

The description of the above device embodiment is similar to the description of the above method embodiment, and has similar beneficial effects as the method embodiment. For technical details not disclosed in the device embodiments of the present application, please refer to the description of the method embodiments of the present application for understanding.

It should be noted that, in the embodiment of the present application, if the above video stream acquisition method is implemented in the form of a software function module and sold or used as an independent product, it can also be stored in a computer-readable storage medium. Based on this understanding, the technical solution of the embodiment of the present application is essentially or the part that contributes to the prior art can be embodied in the form of a software product. The computer software product is stored in a storage medium and includes several instructions for Make an electronic device (which may be a personal computer, a server, etc.) execute all or part of the methods described in the various embodiments of the present application. The aforementioned storage media include: U disk, mobile hard disk, ROM (Read Only Memory, read-only memory), magnetic disk or optical disk and other media that can store program codes. Thus, embodiments of the present application are not limited to any specific combination of hardware and software.

Correspondingly, an embodiment of the present application provides a server, including a memory and a processor, the memory stores a computer program that can run on the processor, and when the processor executes the program, the video server provided in the above-mentioned embodiments is realized. A step in the stream's get method.

Correspondingly, an embodiment of the present application provides a readable storage medium on which a computer program is stored, and when the computer program is executed by a processor, the steps in the method for acquiring a video stream described above are implemented.

The embodiment of the present application also provides a computer program product, the computer program product carries a program code, and the instructions included in the program code can be used to execute the steps of the video stream acquisition method described in the above method embodiment, please refer to the above Method Example. That is, the computer program product provided by the embodiments of the present application includes a computer-readable storage medium storing program codes, and the instructions included in the program codes can be used to execute the steps of the methods for obtaining video streams described in the above method embodiments , for implementation, refer to the above-mentioned method embodiments.

It should be pointed out here that: the descriptions of the above storage medium and server embodiments are similar to the descriptions of the above method embodiments, and have similar beneficial effects to those of the method embodiments. For technical details not disclosed in the storage medium and server embodiments of the present application, please refer to the description of the method embodiments of the present application for understanding.

It should be noted that FIG. 7 is a schematic diagram of a hardware entity of the server in the embodiment of the present application. As shown in FIG. 7, the hardware entity of the server 700 includes: a processor 701, a communication interface 702, and a memory 703, wherein

Processor 701 generally controls the overall operation of server 700 .

Communication interface 702 may enable server 700 to communicate with other servers or electronic devices or platforms over a network.

The memory 703 is configured to store instructions and applications executable by the processor 701, and can also cache data to be processed or processed by each module in the processor 701 and the server 700 (for example, image data, audio data, voice communication data and video data) Communication data), can be realized by FLASH (flash memory) or RAM (Random Access Memory, random access memory);

Wherein, various hardware entities in the server are coupled together through the bus 704 . It can be understood that the bus 704 is used to realize connection and communication between these hardware entities.

In the several embodiments provided in this application, it should be understood that the disclosed devices and methods may be implemented in other ways. The device embodiments described above are only illustrative. For example, the division of the units is only a logical function division. In actual implementation, there may be other division methods, such as: multiple units or components can be combined, or May be integrated into another system, or some features may be ignored, or not implemented. In addition, the coupling, or direct coupling, or communication connection between the components shown or discussed may be through some interfaces, and the indirect coupling or communication connection of devices or units may be electrical, mechanical or other forms of.

The units described above as separate components may or may not be physically separated, and the components displayed as units may or may not be physical units, that is, they may be located in one place or distributed to multiple network units; Part or all of the units can be selected according to actual needs to achieve the purpose of the solution of this embodiment.

In addition, each functional unit in each embodiment of the present application can be integrated into one processing module, or each unit can be used as a single unit, or two or more units can be integrated into one unit; the above-mentioned integration The unit can be realized in the form of hardware or in the form of hardware plus software functional unit. Those of ordinary skill in the art can understand that all or part of the steps for realizing the above-mentioned method embodiments can be completed by hardware related to program instructions, and the aforementioned program can be stored in a computer-readable storage medium. When the program is executed, the It includes the steps of the above method embodiments; and the aforementioned storage medium includes: various media that can store program codes such as removable storage devices, ROM, RAM, magnetic disks or optical disks.

The methods disclosed in several method embodiments provided in this application can be combined arbitrarily to obtain new method embodiments under the condition of no conflict.

The features disclosed in several product embodiments provided in this application can be combined arbitrarily without conflict to obtain new product embodiments. The features disclosed in several method or device embodiments provided in this application can be combined arbitrarily without conflict to obtain new method embodiments or device embodiments.

The above is only a specific implementation of the application, but the scope of protection of the application is not limited thereto. Anyone familiar with the technical field can easily think of changes or substitutions within the technical scope disclosed in the application. Should be covered within the protection scope of this application. Therefore, the protection scope of the present application should be determined by the protection scope of the claims.

Industrial Applicability

Embodiments of the present application provide a video stream acquisition method and device, server, storage medium, and program product. After receiving a request message for video stream acquisition, the first task analysis service in the server determines whether it has Accessing the video stream; wherein, the request message is sent by the client to the first task analysis service based on a first mapping relationship, and the first mapping relationship is used to indicate that each task analysis service in the server Corresponding client: in the case that the first task analysis service does not access the video stream, the task management service in the server redirects the client to the second task analysis service based on the second mapping relationship , so that the client can obtain the video stream through the redirected second task analysis service; wherein, the second mapping relationship is used to indicate that each task analysis service has a corresponding access to the video stream; The above task management service is determined from multiple task analysis services in the server. In this way, the redirection mechanism can be used to realize the traceability function of the video, so as to ensure that the video access distribution system (i.e. The device where the flow is located) has a performance impact, and ensures that the internal forwarding function of the system is normal and effective.

Claims

A method for acquiring a video stream, wherein, applied to a server, the method includes:

The first task analysis service in the server determines whether it has accessed the video stream after receiving the request message for obtaining the video stream; wherein, the request message is sent by the client based on the first mapping relationship to the For the first task analysis service, the first mapping relationship is used to indicate the client corresponding to each task analysis service in the server;

When the first task analysis service does not access the video stream, the task management service in the server redirects the client to the second task analysis service based on the second mapping relationship, so that the client The terminal can obtain the video stream through the redirected second task analysis service; wherein, the second mapping relationship is used to indicate that each task analysis service has a corresponding access to the video stream; the task management service is Determined from multiple task analysis services in the server.
The method according to claim 1, wherein, in the case that the first task analysis service does not access the video stream, the task management service in the server assigns the client to the Redirecting to the second task analysis service, so that the client can obtain the video stream through the redirected second task analysis service, including:

When the first task analysis service does not access the video stream, the first task analysis service sends a query request message to the task management service; wherein, the query request message carries the video stream Flow identification information;

The task management service queries the task analysis service that has accessed the video stream according to the identification information and the second mapping relationship, and obtains a query result;

If the query result indicates that the second task analysis service in the server has accessed the video stream, the task management service sends the query result to the first task analysis service, so that the The client can obtain the video stream through the second task analysis service.
The method according to claim 2, wherein the task management service sends the query result to the first task analysis service, so that the client can obtain the video stream through the second task analysis service ,include:

The task management service sends the query result to the first task analysis service;

The first task analysis service sends the node address of the second task analysis service to the client, so that the client can establish a media connection with the second task analysis service according to the node address to obtain The video stream.
The method according to claim 2 or 3, wherein the task management service queries the task analysis service that has accessed the video stream according to the identification information and the second mapping relationship, and obtains a query result, including:

The task management service determines address information that has accessed the video stream according to the identification information and the second mapping relationship;

The task management service determines the task analysis service that has accessed the video stream according to the address information, and obtains a query result.
The method according to any one of claims 1 to 4, wherein the server includes a plurality of service nodes, and at least one task analysis service exists on each of the service nodes;

Correspondingly, the second mapping relationship is used to indicate that each of the service nodes has correspondingly accessed video streams;

Correspondingly, the method also includes:

determining a first service node among the plurality of service nodes as a task management node;

The task analysis service in the task management node is determined as the task management service.
The method according to any one of claims 1 to 5, wherein the method further comprises:

In the case that the first task analysis service has accessed the video stream, the first task analysis service establishes a media connection with the client;

The first task analysis service sends the accessed video stream to the client through the media connection.
The method according to any one of claims 1 to 6, wherein the method further comprises:

When the query result shows that no task analysis service that has accessed the video stream is found, the task management service determines the target task analysis service according to preset rules, so that the client can pass the target The task analysis service obtains the video stream.
The method according to claim 7, wherein the task management service determines a target task analysis service according to preset rules, so that the client can obtain the video stream through the target task analysis service, comprising:

The task management service determines the first task analysis service as the target task analysis service according to the first mapping relationship, so that the client can obtain the video stream through the first task analysis service.
The method according to claim 7, wherein the task management service determines a target task analysis service according to preset rules, so that the client can obtain the video stream through the target task analysis service, comprising:

The task management service determines the load of at least two task analysis services in the server;

The task management service sorts the loads of the at least two task analysis services according to the values from small to large, and obtains the sorting results;

The task management service determines the task analysis service with the smallest load as the target task analysis service according to the sorting result, so that the client can obtain the video stream through the task analysis service with the smallest load.
The method according to claim 7, wherein the task management service determines a target task analysis service according to preset rules, so that the client can obtain the video stream through the target task analysis service, comprising:

The task management service determines a third task analysis service according to the access type of the video stream, so that the client can obtain the video stream through the third task analysis service.
A device for acquiring a video stream, wherein the device includes:

The determining unit is configured such that the first task analysis service in the server determines whether it has accessed the video stream after receiving a request message for obtaining the video stream; wherein, the request message is the client based on the first mapping The relationship is sent to the first task analysis service, and the first mapping relationship is used to indicate the client corresponding to each task analysis service in the server;

A redirection unit configured to redirect the client to the second task analysis service based on the second mapping relationship when the first task analysis service does not access the video stream. service, so that the client can obtain the video stream through the redirected second task analysis service; wherein, the second mapping relationship is used to indicate that each task analysis service has correspondingly accessed video stream; The task management service is determined from a plurality of task analysis services in the server.
A server, comprising a memory and a processor, the memory stores a computer program that can run on the processor, and the processor implements the steps in the method of any one of claims 1 to 10 when executing the program.
A computer-readable storage medium, on which a computer program is stored, and when the computer program is executed by a processor, the steps in the method of any one of claims 1 to 10 are implemented.
A computer program product, the computer program product comprising a non-transitory computer-readable storage medium storing a computer program, when the computer program is read and executed by a computer, the method described in any one of claims 1 to 10 is realized in the steps.