CN117979047A - Media resource allocation method, system and storage medium for live broadcast - Google Patents

Abstract

The present disclosure provides a method, system, storage medium and electronic device for allocating media resources for live broadcast. The method includes: obtaining multiple live broadcast services, grouping the multiple live broadcast services according to the service type to obtain multiple service groups; assigning initial weights to the target service group according to the service type; generating a consistent hash ring for the target service group according to the initial weight, and the consistent hash ring includes virtual nodes corresponding to the target live broadcast service; by detecting the number of virtual nodes, the number of connections of the client on the target live broadcast service is obtained, and when the number of connections reaches a threshold, the evaluation mechanism of the target live broadcast service is started; based on the running status of the target live broadcast service, the evaluation mechanism generates a status score; based on the status score and the initial weight, a dynamic weight is generated; based on the dynamic weight, a reset hash ring is constructed; and media resources are allocated according to the nodes on the reset hash ring. The problem of balanced load and allocation of media resources during live broadcast is solved.

Description

Media resource allocation method, system and storage medium for live broadcast

Technical Field

The present disclosure relates to the field of computer technology, and in particular to a media resource allocation method, system, and storage medium for live broadcasting.

Background technique

In general interactive live broadcast, the client watching the live broadcast connects to the server, and the scheduling service calculates the relevant resources configured in the service cluster and returns the best media service access point to the client. Because the relevant configurations of media servers are different and the carrying capacity is also different, a scheduling algorithm is needed to balance the resource allocation of different media servers.

Existing scheduling algorithms, such as polling, randomization, minimum load, least connection, consistent hashing, etc., do not fully consider the real-time load of the media server, and therefore cannot guarantee the balanced load and distribution of media resource services.

Summary of the invention

In view of this, the purpose of the present disclosure is to propose a media resource allocation method, system, storage medium and electronic device for live broadcast, which solves the problem of balanced load and allocation of media resources during live broadcast.

In order to achieve one of the above disclosed purposes, the present disclosure provides a method for allocating media resources for live broadcasting, the method comprising:

Acquire multiple live broadcast services, and group the multiple live broadcast services according to service types to obtain a service group;

According to the business type, assigning an initial weight to the target business group;

According to the initial weight, generating a consistent hash ring for the target service group, the consistent hash ring including a virtual node corresponding to the target live service, the target live service being a live service in the target service group;

By detecting the number of the virtual nodes, the number of client connections on the target live broadcast service is obtained, and when the number of connections reaches a threshold, an evaluation mechanism of the target live broadcast service is started;

Based on the running status of the target live broadcast service, the evaluation mechanism generates a status score;

generating a dynamic weight according to the state score and the initial weight;

Based on the dynamic weight, construct a reset hash ring;

Media resources are allocated according to the nodes on the reset consistent hashing ring.

As a further improvement of an implementation mode of the present disclosure, the target service group is generated into a consistent hash ring according to the initial weight, and the consistent hash ring includes a virtual node corresponding to the target live service, including:

Calculating the product of the initial weight and the cardinality of the virtual node;

Set the number of the virtual nodes corresponding to the target live broadcast service on the consistent hash ring;

The virtual nodes generated by the target live broadcast service are mapped to the consistent hash ring.

As a further improvement of an embodiment of the present disclosure, the evaluation mechanism generates a status score based on the running status of the target live broadcast service, including:

Obtaining the running status of the target live broadcast service;

Processing the running status of the target live broadcast service to obtain an actual load average of the target live broadcast service;

Preset the corresponding relationship between load mean and segment score;

The actual load mean value and the corresponding relationship are matched to obtain a status score of the target live broadcast service.

As a further improvement of an embodiment of the present disclosure, the generating of the dynamic weight according to the state score and the initial weight includes:

respectively allocating the calculation ratios of the state score and the initial weight;

Calculate the state score and the initial weight according to the calculation ratio to obtain the dynamic weight;

Wherein, the dynamic weight is smaller than the initial weight.

As a further improvement of an implementation mode of the present disclosure, after obtaining the number of connections of the client on the target live broadcast service, the method further includes:

If the number of connections does not exceed the threshold, it is determined whether the load of the target live broadcast service is uniform;

In response to the uneven load, setting a temporary weight according to the actual load;

Based on the temporary weights, a reset hash ring is constructed.

As a further improvement of an embodiment of the present disclosure, the priority of the temporary weight is greater than the priority of the dynamic weight, and the priority of the dynamic weight is greater than the priority of the initial weight.

As a further improvement of an implementation mode of the present disclosure, the running status of the target live broadcast service includes at least one of the number of CPU cores, current memory occupancy, current bandwidth usage and the current number of users.

Based on the same inventive concept, the present disclosure also provides a media resource allocation system for live broadcast, including:

A first acquisition module is used to acquire multiple live broadcast services, and group the multiple live broadcast services according to service types to obtain a service group;

A first allocation module, configured to allocate an initial weight to a target service group according to the service type;

A first generating module is used to generate a separate consistent hash ring for the target service group according to the initial weight, wherein the consistent hash ring includes virtual nodes corresponding to the target live service one by one, and the target live service is a live service in the target service group;

A detection module, configured to obtain the number of client connections on the target live broadcast service by detecting the number of the virtual nodes, and start an evaluation mechanism for the target live broadcast service when the number of connections reaches a threshold;

A second generating module, configured to generate a status score based on the running status of the target live broadcast service by the evaluation mechanism;

A third generation module generates a dynamic weight according to the state score and the initial weight;

A construction module, for constructing a reset hash ring based on the dynamic weight;

The second allocation module is used to allocate media resources according to the nodes on the reset consistent hash ring.

Based on the same inventive concept, the present disclosure also provides a non-transitory computer-readable storage medium, which stores computer instructions, and the computer instructions are used to enable a computer to execute any of the above-mentioned media resource allocation methods for live broadcast.

Based on the same inventive concept, the present disclosure also provides an electronic device, including: a processor and a memory; the memory stores a computer program, and when the computer program is executed by the processor, the processor executes the steps of any of the above-mentioned media resource allocation methods for live broadcast.

Compared with the prior art, the technical effect of the present invention is that: the present invention classifies live broadcast services with large differences in the number of viewers, so as to avoid excessive differences in the allocation of media resources between different live broadcast services; through real-time comprehensive evaluation of the target live broadcast service, combined with the preset initial weight and the real-time updated status score, the target live broadcast service is allocated nodes to ensure that the resources of the target live broadcast service are not overloaded or idle, thus saving the resources of the target live broadcast service and ensuring the stability and quality requirements of the live broadcast process.

BRIEF DESCRIPTION OF THE DRAWINGS

In order to more clearly illustrate the technical solutions in the present disclosure or related technologies, the drawings required for use in the implementation methods or related technical descriptions will be briefly introduced below. Obviously, the drawings described below are only implementation methods of the present disclosure. For ordinary technicians in this field, other drawings can be obtained based on these drawings without paying creative work.

FIG1 is a flow chart of a method for allocating media resources for live broadcasting provided by an embodiment of the present disclosure;

FIG2 is a flowchart of constructing a consistent hash ring provided by another embodiment of the present disclosure;

FIG3 is a flow chart of adding temporary weights provided by another embodiment of the present disclosure;

FIG4 is a flow chart of obtaining a status score provided by another embodiment of the present disclosure;

FIG5 is a flow chart of obtaining dynamic weights provided by another embodiment of the present disclosure;

FIG6 is a flow chart of a method for allocating media resources for live broadcasting provided by another embodiment of the present disclosure;

FIG7 is a schematic diagram of media resource allocation for live broadcasting provided by another embodiment of the present disclosure;

FIG8 is a schematic diagram of a hardware structure of an electronic device provided in an embodiment of the present disclosure.

Detailed ways

The present invention will be described in detail below in conjunction with the specific embodiments shown in the accompanying drawings. However, these embodiments do not limit the present invention, and any structural, methodological, or functional changes made by a person skilled in the art based on these embodiments are all within the scope of protection of the present invention.

Embodiments It should be noted that, unless otherwise defined, the technical terms or scientific terms used in the embodiments of the present disclosure should be understood by people with ordinary skills in the field to which the present disclosure belongs. The "first", "second" and similar words used in the embodiments of the present disclosure do not indicate any order, quantity or importance, but are only used to distinguish different components. "Include" or "comprising" and similar words mean that the elements or objects appearing before the word include the elements or objects listed after the word and their equivalents, without excluding other elements or objects.

There are many problems with the allocation of media resources in existing live broadcast services: (1) Different services use different media resources. For example, some services have relatively few people participating in live broadcast interactions, while others have up to thousands of people participating in live broadcast interactions. Therefore, the media resources occupied by different live broadcast services vary greatly, and resources cannot be accurately allocated. (2) The number of media CPU cores or memory varies, resulting in different carrying capacities, making it impossible to allocate resources appropriately. (3) When the media resource service is dynamically expanded, if the service resources use polling or random methods, they cannot be quickly shared by the service cluster. (4) In special circumstances, such as service anomalies, when the media service load varies greatly and requires manual intervention, the current load balancing strategy cannot meet the requirements.

The embodiment of the present disclosure provides a method for allocating media resources for live broadcasting. As shown in FIG1 , the method for allocating media resources for live broadcasting includes the following steps:

Step S100, obtaining multiple live broadcast services, and grouping the multiple live broadcast services according to service types to obtain a service group.

Specifically, the load strategy needs to allocate service nodes according to the business type. The number of viewers of different types of live broadcast services or different levels of live broadcast services varies greatly. At the same time, in order to isolate the services, live broadcast services with similar types or similar number of viewers are grouped and assigned to the same business group, and media resources are allocated to the same business group. This avoids the target live broadcast services with large load differences from jointly allocating media resources.

Step S200: assigning an initial weight to the target service group according to the service type.

Specifically, the initialization weight is allocated according to the overall configuration and service performance of the target service group, wherein the overall configuration and service performance include but are not limited to the viewing level, the preset live video quality requirements, CPU resources, memory and set quality parameters, etc.

Step S300: Based on the initial weight, each service group generates a separate consistent hash ring, and the consistent hash ring includes a virtual node corresponding to the target live broadcast service.

Specifically, for distributed storage, different machines store data of different objects. We use hash functions to establish a mapping relationship from data to servers. The consistent hash ring is a virtual ring structure that organizes the entire hash value space into a virtual ring. The nodes are mapped to the consistent hash ring through the hash function, so that each node can determine its position on the consistent hash ring.

The hash ring has certain balance, monotonicity, smoothness and stability. Balance means that the consistent hash ring distributes data to all nodes as much as possible to avoid extremely uneven distribution; monotonicity means that when adding or reducing nodes, the original results are mostly unaffected, and the new data is distributed to the newly added nodes as much as possible; balance means that there should be a smooth transition for adding or reducing nodes; stability means that when a node goes down, only the data of that node will be relocated to other nodes, so only the data of that node needs to be migrated.

In one possible implementation of the present disclosure, step S300, as shown in FIG2 , further includes:

Step S310, calculating the product of the initial weight and the cardinality of the virtual node;

Step S320, setting the number of the virtual nodes corresponding to the target live broadcast service on the consistent hash ring;

Step S330, mapping the virtual nodes generated by the target live broadcast service to the consistent hash ring.

Specifically, when building a consistent hash ring, the number of virtual nodes corresponding to the target live broadcast service on the consistent hash ring is set according to the result obtained by multiplying the initial weight by the virtual node base, and the virtual nodes generated by the target live broadcast service are mapped to the consistent hash ring according to the set number.

It should be noted that the cardinality of virtual nodes refers to the number of virtual nodes corresponding to one actual node. The purpose of introducing virtual nodes is to solve the problem of uneven data distribution caused by a small number of nodes in the consistent hash ring. By increasing the number of virtual nodes, the distribution density of nodes on the hash ring can be increased, thereby improving the uniformity of data distribution.

Step S400, by detecting the number of the virtual nodes, the number of client connections on the target live broadcast service is obtained, and when the number of connections reaches a threshold, an evaluation mechanism for the target live broadcast service is started.

Specifically, the number of virtual nodes corresponds to the number of client connections in the target live broadcast service, more specifically, the number of virtual nodes corresponds to the number of client connections in the target live broadcast service one by one; according to different service types, a threshold is set for the number of client connections. When the threshold is not exceeded, the initial weight can represent the load occupied by the target live broadcast service. When the number of connections exceeds the threshold, it is necessary to restart the evaluation mechanism of the target live broadcast service and reallocate media resources.

In one possible implementation of the present disclosure, after step S400, as shown in FIG3 , the following is further included:

Step S401, if the number of connections does not exceed the threshold, it is determined whether the load of the target live broadcast service is uniform;

Step S402, in response to the uneven load, setting a temporary weight according to the actual load;

Step S403: construct a reset consistent hash ring based on the temporary weight.

Specifically, the concept of temporary weights is introduced in this embodiment. By default, temporary weights do not work, that is, when the load of the target live broadcast service is evenly distributed, it is the default case; when the target live broadcast service encounters special extreme conditions, which will cause uneven load, the temporary weights can be adjusted according to the load requirements.

In a specific embodiment, the consistent hash ring will be adjusted based on the temporary weight, which can be used for manual intervention when the automatic load cannot meet special circumstances; in addition, the temporary weight can be set to zero, and the business group set to zero in the entire cluster will temporarily not receive new requests. When the business group load is alleviated, the temporary weight can be reset, or restored to the dynamic weight adjustment state.

In an implementation manner of the present disclosure, the priority of the temporary weight is greater than the priority of the dynamic weight, and the priority of the dynamic weight is greater than the priority of the initial weight.

Specifically, the priority of temporary weight is greater than dynamic weight and initial weight. In extreme cases, when temporary weight is used, initial weight and dynamic weight will be temporarily invalid to avoid overloading of target live broadcast business. The priority of dynamic weight is greater than initial weight. When the number of client connections is greater than the load capacity of initial weight, the concept of dynamic weight is introduced. Therefore, when there is dynamic weight, the value of dynamic weight can ensure the uniform distribution of media resources.

Step S500: Based on the running status of the target live broadcast service, the evaluation mechanism generates a status score.

Specifically, in the process of generating dynamic weights, a status score must first be generated. The status score reflects the operating status of the target live broadcast service, and a dynamic weight is allocated based on its operating status.

In one possible implementation of the present disclosure, step S500, as shown in FIG4 , further includes:

Step S510, obtaining the running status of the target live broadcast service;

Step S520, processing the running state of the target live broadcast service to obtain the actual load average of the target live broadcast service;

Step S530, preset the corresponding relationship between the load mean and the segment score;

Step S540, matching the actual load mean and the corresponding relationship to obtain a status score of the target live broadcast service.

Specifically, according to the operating status of each target live broadcast service reporting group, the load average of each target live broadcast service can be comprehensively obtained through calculation, analysis and evaluation. The corresponding relationship between the load average and the segment score is preset in advance. The load average from small to large corresponds to the score from small to large. The load average obtained from actual operation and the segment score are matched to obtain the status score of each target live broadcast service.

In one implementable manner of the present disclosure, the running status of the target live broadcast service includes at least one of the number of CPU cores, current memory occupancy, current bandwidth usage, and the current number of users.

The number of CPU cores of the target live broadcast service, the memory usage of the live broadcast device, the broadband speed of the live broadcast subject and the number of viewers watching the live broadcast all affect the operating status of the target live broadcast service and can be used as parameters to judge the operating status of the target live broadcast service.

Step S600, generating a dynamic weight according to the state score and the initial weight.

Specifically, the status score of the target live broadcast service and the initial weight of the target live broadcast service jointly generate a dynamic weight, wherein the initial weight includes the fixed requirements and status of the target live broadcast service, such as the parameters of the hardware equipment or the preset live broadcast requirements, etc. The status score includes the dynamically changing parameters of the target live broadcast service during operation. The fixed demand status and dynamic operating conditions of the target live broadcast service are combined to ensure the operation quality while ensuring stable operation.

In one possible implementation of the present disclosure, step S600, as shown in FIG5 , further includes:

Step S610, respectively allocating the calculation ratio of the state score and the initial weight;

Step S620, calculating the state score and the initial weight according to the calculation ratio to obtain the dynamic weight; wherein the dynamic weight is smaller than the initial weight.

Specifically, the proportion of the state score accounts for one part, and the proportion of the initial weight accounts for another part. For example, if the proportion of the state score is α and the proportion of the initial weight is β, then α+β=1, and the dynamic weight is A=αB+βC; among them, B is the state score and C is the initial weight.

Among them, the dynamic weight is smaller than the initial weight to prevent the dynamic weight of individual live broadcast services from increasing infinitely and causing other load problems after exceeding the initial weight.

Step S700: construct a reset hash ring based on the dynamic weight.

Step S800: Allocate media resources according to the nodes on the reset hash ring.

Specifically, after adjusting the dynamic weight, the consistent hash ring is reconstructed according to the dynamic weight, so that the next time the client connects, the access point of the target live broadcast service will be allocated according to the dynamic weight, thereby achieving the purpose of allocating media resources according to the target live broadcast service.

In some specific embodiments of the present disclosure, as shown in FIG6 , another method for allocating resources for live broadcast is proposed, including:

Step S101, obtaining a target live broadcast service;

Step S102, obtaining an initial weight according to the target live broadcast service, and generating a corresponding consistent hash ring;

Step S103, calculating the number of connections of the target live broadcast service;

Step S104, determining whether the number of connections exceeds a threshold, if so, executing step S105, if not, executing step S107;

Step S105, starting an evaluation mechanism for the target live broadcast service to obtain a status score for the target live broadcast service;

Step S106, obtaining a dynamic weight according to the state score and the initial weight;

Step S107, determining whether a temporary weight needs to be set, if yes, executing step S108, if no, executing step S109;

Step S108, after resetting the hash ring according to the temporary weight, execute step S1011;

Step S109, determining whether the dynamic weight is adjusted, if yes, executing step S1010, if not, executing step S1011;

Step S1010, after resetting the hash ring according to the dynamic weight, execute step S1011;

Step S1011, allocating media resources according to the reset hash ring.

As shown in FIG. 7 , another embodiment of the present disclosure discloses a media resource allocation system for live broadcast, including:

A first acquisition module is used to acquire multiple live broadcast services, and group the multiple live broadcast services according to service types to obtain a service group;

A first allocation module, configured to allocate an initial weight to a target service group according to the service type;

A first generating module is used to generate a consistent hash ring for the target service group according to the initial weight, wherein the consistent hash ring includes a virtual node corresponding to the target live service, and the target live service is a live service in the target service group;

A detection module, configured to obtain the number of client connections on the target live broadcast service by detecting the number of virtual nodes, and to start an evaluation mechanism for the target live broadcast service when the number of connections reaches a threshold;

A second generating module, configured to generate a status score based on the running status of the target live broadcast service by the evaluation mechanism;

A third generation module generates a dynamic weight according to the state score and the initial weight;

A construction module, for constructing a reset hash ring based on the dynamic weight;

The second allocation module is used to allocate media resources according to the nodes on the reset hash ring.

In one possible implementation of the present disclosure, the first generation module includes:

A first calculation module calculates the product of the initial weight and the cardinality of the virtual node;

A setting module is used to set the number of virtual nodes corresponding to the target live broadcast service on the consistent hash ring;

A mapping module maps the virtual nodes generated by the target live broadcast service to a consistent hash ring.

In one possible implementation of the present disclosure, the second generation module includes:

A second acquisition module is used to acquire the running status of the target live broadcast service;

A processing module, processing the running state of the target live broadcast service, and obtaining an actual load average of the target live broadcast service;

Preset module, preset the corresponding relationship between load mean and segment score;

A matching module matches the actual load mean and the corresponding relationship to obtain a status score of the target live broadcast service.

In one possible implementation of the present disclosure, the third generation module includes:

An allocation module, which allocates the calculation ratio of the state score and the initial weight respectively;

The second calculation module calculates the state score and the initial weight according to the calculation ratio to obtain the dynamic weight; wherein the dynamic weight is smaller than the initial weight.

In one possible implementation of the present disclosure, the following further includes:

The judgment module judges whether the load of the target live broadcast service is uniform if the number of connections does not exceed the threshold;

A response module, in response to the uneven load, sets a temporary weight according to the actual load;

The reset module constructs a reset consistent hash ring based on the temporary weight.

This system classifies target live broadcast services with large differences in the number of viewers to avoid excessive disparity in media resource allocation between different target live broadcast services; through real-time comprehensive evaluation of target live broadcast services, nodes are allocated to target live broadcast services to ensure that the resources of the target live broadcast services are not overloaded or idle, thus saving the resources of the target live broadcast services and ensuring the stability of the live broadcast process.

8 shows a more specific schematic diagram of the hardware structure of an electronic device provided in this embodiment, and the device may include: a processor 1010, a memory 1020, an input/output interface 1030, a communication interface 1040, and a bus 1050. The processor 1010, the memory 1020, the input/output interface 1030, and the communication interface 1040 are connected to each other in communication within the device through the bus 1050.

The processor 1010 can be implemented by a general-purpose CPU (Central Processing Unit), a microprocessor, an application-specific integrated circuit (ASIC), or one or more integrated circuits, and is used to execute relevant programs to implement the technical solutions provided in the implementation methods of this specification.

The memory 1020 may be implemented in the form of ROM (Read Only Memory), RAM (Random Access Memory), static storage device, dynamic storage device, etc. The memory 1020 may store an operating system and other application programs. When the technical solutions provided in the embodiments of this specification are implemented by software or firmware, the relevant program codes are stored in the memory 1020 and are called and executed by the processor 1010.

The input/output interface 1030 is used to connect the input/output module to realize information input and output. The input/output module can be configured in the device as a component (not shown in the figure), or it can be externally connected to the device to provide corresponding functions. The input device may include a keyboard, a mouse, a touch screen, a microphone, various sensors, etc., and the output device may include a display, a speaker, a vibrator, an indicator light, etc.

The communication interface 1040 is used to connect a communication module (not shown) to realize communication interaction between the device and other devices. The communication module can realize communication through a wired mode (such as USB, network cable, etc.) or a wireless mode (such as mobile network, WIFI, Bluetooth, etc.).

The bus 1050 includes pathways that transmit information between the various components of the device (eg, the processor 1010 , the memory 1020 , the input/output interface 1030 , and the communication interface 1040 ).

It should be noted that, although the above device only shows the processor 1010, the memory 1020, the input/output interface 1030, the communication interface 1040 and the bus 1050, in the specific implementation process, the device may also include other components necessary for normal operation. In addition, it can be understood by those skilled in the art that the above device may also only include the components necessary for implementing the implementation scheme of this specification, and does not necessarily include all the components shown in the figure.

The electronic device of the above-mentioned implementation mode is used to implement the corresponding media resource allocation method for live broadcast in any of the above-mentioned implementation modes, and has the beneficial effects of the corresponding method implementation mode, which will not be repeated here.

Based on the same inventive concept, corresponding to any of the above-mentioned implementation methods, the present disclosure also provides a non-transitory computer-readable storage medium, wherein the non-transitory computer-readable storage medium stores computer instructions, and the computer instructions are used to enable the computer to execute the media resource allocation method for live broadcast as described in any of the above implementation methods.

The computer-readable medium of this embodiment includes permanent and non-permanent, removable and non-removable media, and information storage can be achieved by any method or technology. Information can be computer-readable instructions, data structures, modules of programs, or other data. Examples of computer storage media include, but are not limited to, phase change memory (PRAM), static random access memory (SRAM), dynamic random access memory (DRAM), other types of random access memory (RAM), read-only memory (ROM), electrically erasable programmable read-only memory (EEPROM), flash memory or other memory technology, read-only compact disk read-only memory (CD-ROM), digital versatile disk (DVD) or other optical storage, magnetic cassettes, magnetic tape magnetic disk storage or other magnetic storage devices or any other non-transmission media that can be used to store information that can be accessed by a computing device.

The computer instructions stored in the storage medium of the above-mentioned implementation manner are used to enable the computer to execute the media resource allocation method for live broadcast as described in any of the above-mentioned implementation manners, and have the beneficial effects of the corresponding method implementation manners, which will not be repeated here.

Those skilled in the art should understand that the discussion of any of the above embodiments is merely illustrative and is not intended to imply that the scope of the present disclosure (including the claims) is limited to these examples. This narrative style of the specification is only for the sake of clarity, and those skilled in the art should take the specification as a whole. Under the concept of the present disclosure, the above embodiments or technical features in different embodiments may be appropriately combined, the steps may be implemented in any order, and there are many other variations of different aspects of the embodiments of the present disclosure as described above, which are not provided in detail for the sake of simplicity.

In addition, to simplify the description and discussion, and in order not to make the embodiments of the present disclosure difficult to understand, the known power/ground connections to the integrated circuit (IC) chips and other components may or may not be shown in the provided figures. In addition, the device can be shown in the form of a block diagram to avoid making the embodiments of the present disclosure difficult to understand, and this also takes into account the fact that the details of the implementation of these block diagram devices are highly dependent on the platform on which the embodiments of the present disclosure will be implemented (that is, these details should be fully within the scope of understanding of those skilled in the art). Where specific details (e.g., circuits) are set forth to describe exemplary embodiments of the present disclosure, it is obvious to those skilled in the art that the embodiments of the present disclosure can be implemented without these specific details or with changes in these specific details. Therefore, these descriptions should be considered illustrative rather than restrictive.

Although the present disclosure has been described in conjunction with specific embodiments of the present disclosure, many replacements, modifications and variations of these embodiments will be apparent to those skilled in the art from the foregoing description. For example, other memory architectures (e.g., dynamic RAM (DRAM)) can use the embodiments discussed.

The embodiments of the present disclosure are intended to cover all such substitutions, modifications and variations that fall within the broad scope of the appended claims. Therefore, any omissions, modifications, equivalent substitutions, improvements, etc. made without departing from the spirit and principles of the embodiments of the present disclosure shall be included in the scope of protection of the present disclosure.

Claims (10)

1. A method for media resource allocation for live broadcast, the method comprising:

Acquiring a plurality of live broadcast services, and grouping the live broadcast services according to service types to obtain a plurality of service groups;

According to the service type, an initial weight is allocated to a target service group;

generating a consistency hash ring from the target service group according to the initial weight, wherein the consistency hash ring comprises virtual nodes corresponding to target live services, and the target live services are live services in the target service group;

Obtaining the connection quantity of the clients on the target live broadcast service by detecting the quantity of the virtual nodes, and starting an evaluation mechanism of the target live broadcast service when the connection quantity reaches a threshold value;

Generating a state score by the assessment mechanism based on the running state of the target live service;

Generating a dynamic weight according to the state score and the initial weight;

Building a reset hash ring based on the dynamic weights;

and distributing media resources according to the nodes on the reset hash ring.

2. The method for media resource allocation for live broadcast according to claim 1, wherein the generating a consistent hash ring for the target service group according to the initial weight, the consistent hash ring including a virtual node corresponding to the target live service, comprises:

calculating the product of the initial weight and the cardinality of the virtual node;

setting the number of the virtual nodes corresponding to the target live broadcast service on the consistency hash ring;

And mapping the virtual node generated by the target live broadcast service to a consistent hash ring.

3. The method for media resource allocation for live as in claim 1, wherein the evaluation mechanism generates a status score based on the operational status of the target live service, comprising:

acquiring the running state of the target live broadcast service;

Processing the running state of the target live broadcast service to obtain the actual load average value of the target live broadcast service;

presetting a corresponding relation between a load mean value and a segmentation score;

And matching the actual load mean value with the corresponding relation to obtain the state score of the target live broadcast service.

4. The method of claim 1, wherein generating dynamic weights from the status scores and the initial weights comprises:

respectively distributing the calculated proportion of the state scores and the initial weights;

Calculating the state score and the initial weight according to the calculated proportion to obtain the dynamic weight;

wherein the dynamic weight is less than the initial weight.

5. The method for media resource allocation for live broadcast according to claim 3, wherein after obtaining the number of connections of the client on the target live broadcast service, the method further comprises:

Judging whether the load of the target live broadcast service is uniform or not if the number of the connections does not exceed a threshold value;

setting temporary weights according to actual loads in response to the uneven loads;

based on the temporary weights, a reset hash ring is constructed.

6. The method of claim 5, wherein the temporary weight has a priority greater than a priority of the dynamic weight, and wherein the dynamic weight has a priority greater than a priority of the initial weight.

7. The method for media resource allocation for live broadcast according to claim 3, wherein the running state of the target live broadcast service includes at least one of a CPU core number, a current memory occupancy condition, a current bandwidth usage condition, and a current user number.

8. A media resource distribution system for live broadcast, the system comprising:

the first acquisition module is used for acquiring a plurality of live broadcast services, and grouping the live broadcast services according to the service type to obtain a plurality of service groups;

the first allocation module is used for allocating initial weights to the target service groups according to the service types;

The first generation module is used for generating a consistency hash ring for the target service group according to the initial weight, wherein the consistency hash ring comprises virtual nodes corresponding to the target live service, and the target live service is the live service in the target service group;

The detection module is used for obtaining the connection quantity of the client on the target live broadcast service by detecting the quantity of the virtual nodes, and starting an evaluation mechanism of the target live broadcast service when the connection quantity reaches a threshold value;

the second generation module is used for generating a state score based on the running state of the target live broadcast service by the evaluation mechanism;

the third generation module generates dynamic weights according to the state scores and the initial weights;

A building module for building a reset hash ring based on the dynamic weights;

And the second distribution module is used for distributing media resources according to the nodes on the reset consistency hash ring.

9. A non-transitory computer readable storage medium storing computer instructions for causing a computer to perform the media resource allocation method for live broadcast of any of claims 1 to 7.

10. An electronic device, comprising: a processor and a memory;

The memory stores a computer program which, when executed by the processor, causes the processor to perform the steps of the media resource allocation method for live broadcast according to any of claims 1 to 7.