[go: up one dir, main page]

CN116032895B - Bypass intelligent media server scheduling method, system, equipment and medium - Google Patents

Bypass intelligent media server scheduling method, system, equipment and medium Download PDF

Info

Publication number
CN116032895B
CN116032895B CN202211595358.4A CN202211595358A CN116032895B CN 116032895 B CN116032895 B CN 116032895B CN 202211595358 A CN202211595358 A CN 202211595358A CN 116032895 B CN116032895 B CN 116032895B
Authority
CN
China
Prior art keywords
server
scheduling
protocol
data
script
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Active
Application number
CN202211595358.4A
Other languages
Chinese (zh)
Other versions
CN116032895A (en
Inventor
钱波
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Shanghai Yuanjing Information Technology Co ltd
Original Assignee
Shanghai Yuanjing Information Technology Co ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Shanghai Yuanjing Information Technology Co ltd filed Critical Shanghai Yuanjing Information Technology Co ltd
Priority to CN202211595358.4A priority Critical patent/CN116032895B/en
Publication of CN116032895A publication Critical patent/CN116032895A/en
Application granted granted Critical
Publication of CN116032895B publication Critical patent/CN116032895B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Classifications

    • YGENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
    • Y02TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
    • Y02DCLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
    • Y02D10/00Energy efficient computing, e.g. low power processors, power management or thermal management

Landscapes

  • Data Exchanges In Wide-Area Networks (AREA)

Abstract

The invention belongs to the technical field of communication and discloses a bypass intelligent server scheduling method, a bypass intelligent server scheduling system, intelligent server scheduling equipment and a bypass intelligent server scheduling medium, wherein the method comprises the following steps that firstly, a detection process is started by using the bypass intelligent server scheduling method, and the weight proportion of a multi-server architecture is readjusted and calculated according to a resource occupancy rate, a hot loading script and an early warning model for a period of time; and step two, sending data according to the ssdp protocol to enable the media engine to adjust and match different strategy modes so as to schedule the server. The invention improves the strategy selection speed of the calculation server through the alarm model, improves the utilization rate of the server, reduces the running of the server, dynamically adjusts the weight, improves the high availability of the server program group, maximally utilizes the idle server, reduces the service response time, obtains IO (input output) and CPU (input output) energy consumption calculation through the ssdp protocol, counts the alarm model data, reasonably utilizes the resources of each server, has static stability, and ensures the performance utilization efficiency.

Description

Bypass intelligent media server scheduling method, system, equipment and medium
Technical Field
The invention belongs to the technical field of communication, and particularly relates to a bypass-mode intelligent media server scheduling method, system, equipment and medium.
Background
Currently, media servers are signaling services, forwarding services, storage services, inference services (AI) or other service type servers, collectively referred to as media services, having multiple servers or clusters, respectively. In order to reasonably allocate server resources, the original method is to find all servers according to signaling of a signaling server, randomly assign a certain server to be a forwarding service or store after finding a plurality of servers, infer, or directly assign a certain server to be a forwarding service according to weight, or assign a server according to occupancy rate such as CPU (instant get). Weights are typically given a normalized number for servers, e.g., server 1:0.7 server 2:0.3, then seventy percent probability would be given for server 1, thirty percent probability for server 2, and transition probability matrix is [0.7,0.3].
Through the above analysis, the problems and defects existing in the prior art are as follows:
The actual cpu, gpu, memory, disk, network bandwidth occupancy, disk IO requests and power consumption performance of the existing multiple servers are continuously changed, and some servers may already occupy relatively large resources for a long time, but the weight is still heavy over time due to too simple calculation (calculation according to the instant occupancy), so that the servers cannot be reasonably allocated under the condition that media service and AI reasoning service exist and a storage service architecture is constructed.
Disclosure of Invention
Aiming at the problems existing in the prior art, the invention provides an intelligent server scheduling method in a bypass mode. The servers include sip signaling dispatch servers, other media servers. When the client links up, the client can indicate that the client is a release identity or a subscription identity, the signaling scheduling server schedules and distributes other servers, for example, the streaming media server comprises a main server and an edge server, the AI reasoning server comprises a main reasoning server and an edge reasoning server, and the storage server comprises a main storage server and an edge storage server. The weight initially configured by the primary server is relatively heavy.
The invention is realized in such a way that the intelligent server scheduling method of the bypass mode comprises the following steps:
Step one, each physical server starts a bypass monitoring process watch, the process detects cpu, gpu, memory and disk io of the physical server, the process sends detected data according to ssdp protocol, the sip signaling service process obtains cpu, gpu, io and other resource occupation ratios according to ssdp protocol, the servers are deleted through a hot loading strategy script and an early warning model, and the weight proportion of each server under the condition of calculating multiple servers is readjusted;
and in the hot loading script application process, after the signaling server is started, the event detection script is changed according to the operating system file, and when the script file is changed, the script is read again to acquire a weight formula, so that the server scheduling strategy is updated.
Step two, the bypass process watch sends monitoring data according to ssdp protocol, each server process adds script files and executes functions, the code quantity is very small, the script files can send own functions, IP addresses and the like, the sip center signaling scheduling server detects how many servers are nearby and the functions of each server through ssdp protocol, and simultaneously changes scheduling strategies through hot loading scripts, and a media engine adjusts and matches different strategy modes to schedule the servers, so that the bypass mode scheduling of resources is achieved.
Further, the published data are sequentially transmitted to the streaming media server in a data stream mode at a push end, after the sip center signaling scheduling server detects that the data stream reaches the streaming media server, the server of the current local area network and the functions thereof are detected through ssdp protocol in the streaming media server, meanwhile, the scheduling strategy of the sip center signaling scheduling server is changed through python hot loading script or c++ hot loading script or lua hot loading script or js hot loading script which are prepared in directory service contained in the reasoning server, the streaming media server adjusts the corresponding strategy of a matching mode between an origin main service and an edge server according to the scheduling strategy of the sip center signaling scheduling server, then the sip center signaling scheduling server calls the main reasoning server and the edge reasoning server in the reasoning server to conduct data stream reasoning, the storage server stores the processed data stream, and the sip center signaling scheduling server transmits the processed data stream to a player in a play subscription position through directly calling the data stream in the streaming media server or the data file in the storage server.
Further, the policy mode in the second step includes a bandwidth occupancy rate type and an IO bandwidth type;
Assume that different servers occupy different network card interfaces;
the bandwidth occupancy rate is a strategy with high network bandwidth occupancy rate in weight proportion;
the weight proportion calculation process of the bandwidth occupancy rate comprises the following steps:
X=a*0.4+b*0.3+c*0.1+d*0.1+e*0.1
wherein a is the network bandwidth occupancy rate, b is the CPU occupancy rate, c is the GPU occupancy rate, d is the disk IO occupancy rate, and e is the memory storage block occupancy rate;
the weight proportion calculation process of the IO bandwidth type is as follows:
X=f/total*0.5+a*0.5
Where f is the number of disk IO requests, total is the maximum disk IO request, and the value can be obtained from the configuration of the server.
Further, the specific process of the scheduling is as follows:
the server calculates Y value once every n (n < = 20) seconds, and calculates average Y/n=X/(60/n) once every minute, wherein the average Y/n=X/(60/n) is a time unit group every 5 minutes, and the average Y/n is (Y1, Y2, Y3, Y4 and Y5), and only 5 values of 5 minutes can be stored;
and determining the minimum value as the server with the highest weight according to the Y/n value sent by each server.
The server groups do not directly communicate with each other, data is sent according to ssdp protocol, and each basic weight is dynamically adjusted in the script according to different functions.
Further, the early warning model includes the following data:
CPU warns;
i, electricity utilization warning;
J, temperature warning;
k, warning of insufficient memory;
a disk shortage warning;
further, alarm model data within 5 minutes are stored in the server, and the server to be selected is directly deleted according to the early warning model.
The distributed data are sequentially transmitted to a streaming media server in a data stream mode at a push stream end, after the sip center signaling scheduling server detects that the data stream reaches the streaming media server, the server of the current local area network and the functions thereof are detected through ssdp protocol in the streaming media server, meanwhile, the scheduling strategy of the sip center signaling scheduling server is changed through the python hot loading script or the c++ hot loading script or the iua hot loading script or the js hot loading script which are prepared in directory service contained in the reasoning server, the streaming media server adjusts the corresponding strategy of a matching mode between an origin main service and an edge server according to the scheduling strategy of the sip center signaling scheduling server, then the main reasoning server and the edge reasoning server in the sip center signaling scheduling server are called to conduct data stream reasoning, the processed data stream is stored by the storage server, the data stream in the streaming media server or the data file in the storage server is directly called, the data stream or the data file in the storage server is transmitted to a player in a display screen, and the data file is combined with a DLAN (digital subscriber).
Another object of the present invention is to provide a bypass-type intelligent server scheduling system for implementing the bypass-type intelligent server scheduling method, wherein the bypass-type intelligent server scheduling system
The degree system comprises:
a) The user-defined search discovery protocol ssiop, the multicast module and the user network protocol comprise sending and receiving;
1 transmitting module
To multicast address 239.255.255.123, port 18000 sends an identity, including its own IP address, name, type, location position, cpu occupancy, gpu occupancy, io occupancy, etc. For indicating its identity and network address, e.g. streaming media forwarding service, sip signaling module, AI reasoning module, etc.
2 Receiving module
The multicast address 239.255.255.123 is added, the port 18000 receives information, and searches the interested service from each identity, such as searching all the streaming media forwarding servers.
B) A signaling gateway service for signaling transmission;
The Sip signaling exchange protocol server is supported and used for recording all devices, such as all streaming media forwarding servers, and recording cpu, gpu, io occupancy and other information of all servers. Responsible for informing the flow diversion.
C) And the event early warning module is used for event editing and event script.
The formula calculation can be changed at any time in the event of writing, and even the interface can be provided for changing. And acquiring from the multicast address 239.255.255.123 and the port 18000, [ ssiop ], acquiring the occupancy rate, early warning the event, and deleting the sip service if the occupancy rate is larger than the early warning value.
The system provided by the embodiment of the invention firstly searches the equipment in the current local area network by using a search protocol ssiop, wherein the equipment comprises camera equipment, routing equipment, PC end equipment and mobile end equipment, and remotely manages all network equipment supporting the protocol by the protocol, including monitoring network state, modifying network equipment configuration, receiving network event warning, and simultaneously combining streaming media transmission protocol RTSP, RTMP, RTP, RTCP, collecting TS and PS streams, transmitting the streaming media protocol to a signaling and gateway module, interacting with AB protocol, then transmitting the collected streaming data to a media engine module by using a search protocol ssiop module, after detecting that the data stream reaches the media engine by using a sip center signaling scheduling server, detecting the server of the current local area network and the function thereof by using ssiop protocol, simultaneously changing the scheduling strategy of the sip center signaling scheduling server by using a Pjack hot loading script or c++ hot loading script or js hot loading script which is prepared in directory services contained in the reasoning server, adjusting the matching mode between an origin signaling main signaling server and an edge server by using the media transmission protocol RTSP, RTMP, RTP, RTCP, then transmitting the collected streaming data to a media engine module by using the search protocol ssiop module, and simultaneously displaying the matching mode between the origin signaling main signaling server and the edge signaling server by using the client and the client in the client module, and directly calling the client in the client module by using the client in a client module to display the inferred client in the client to display case of the client to store the data in the client in the display module, the event warning module transmits the event editing data and the event script data to the display module in the form of data streams.
It is a further object of the present invention to provide a computer device comprising a memory and a processor, the memory storing a computer program which, when executed by the processor, causes the processor to perform the steps of the bypass mode intelligent server scheduling method.
Another object of the present invention is to provide a computer readable storage medium storing a computer program which, when executed by a processor, causes the processor to perform the steps of the bypass mode intelligent server scheduling method.
Another object of the present invention is to provide an information data processing terminal for implementing the bypass-mode intelligent server scheduling system.
In combination with the above technical solution and the technical problems to be solved, please analyze the following aspects to provide the following advantages and positive effects:
According to the invention, the CPU occupation, the memory occupation and the disk block occupation rate are calculated, the io occupation is calculated, and the bypass mode is calculated, so that the self-defined protocol of ssiop sends data, and the servers are not interfered with each other.
The alarm model improves the strategy selection speed of the calculation server, improves the utilization rate of the server, reduces the running of the server, improves the high availability of a server program group by dynamically adjusting the weight, maximally utilizes an idle server, reduces the service response time, obtains IO (input output) and CPU (input output) energy consumption calculation and statistics warning by adopting a ssiop protocol, and reasonably utilizes the resources of each server, has static stability and ensures the performance utilization.
The expected benefits and commercial values converted by the technical scheme of the invention are that the server is automatically found and deployed, the deployment time is reduced, the log and various information are acquired according to ssiop protocol, the time for detecting errors is reduced, the maintenance is not needed to be combined with a plurality of commands, all the information can be acquired from the sip server, and a large amount of operation and maintenance time is saved.
The technical scheme of the invention fills the technical blank in the domestic and foreign industries, after the server is started, the server process is started at any time to join the automatic model, the server is automatically linked into a server group, and the calculation service is provided according to the thermal integration script, so that the media service, the storage service and the reasoning service are fully automatically carried out without the need of designating a matched server, such as the storage service of the media service video stream and the AI reasoning service of the video stream.
The technical scheme of the invention solves the technical problems that people are always desirous of solving but are not successful all the time, and greatly reduces the operation and maintenance difficulty. Intelligent auto-pairing services.
Drawings
FIG. 1 is a flow chart of an intelligent server scheduling method in a bypass mode provided by an embodiment of the invention;
FIG. 2 is a flow chart of a data presentation process provided by an embodiment of the present invention;
fig. 3 is a schematic diagram of a signal data processing procedure of an intelligent server scheduling system according to an embodiment of the present invention.
Detailed Description
The present invention will be described in further detail with reference to the following examples in order to make the objects, technical solutions and advantages of the present invention more apparent. It should be understood that the specific embodiments described herein are for purposes of illustration only and are not intended to limit the scope of the invention.
In order to fully understand how the invention may be embodied by those skilled in the art, this section is an illustrative embodiment in which the claims are presented for purposes of illustration.
The intelligent server scheduling method of the bypass mode provided by the embodiment of the invention comprises the following steps:
s101, starting a detection process in a bypass mode, and readjusting and calculating the weight proportion of the multi-server architecture according to the resource occupancy rate, the hot loading script and the early warning model for a period of time;
S102, sending data according to ssiop protocols enables the media engine to adjust and match different strategy modes to schedule the server. The server can exert maximum efficiency according to the function hit, and other servers can acquire corresponding data according to the ssdp protocol.
In the embodiment of the present invention, the policy mode in S102 includes a bandwidth occupancy type and an IO bandwidth type;
Assume that different servers occupy different network card interfaces;
the bandwidth occupancy rate is a strategy with high network bandwidth occupancy rate in weight proportion;
the weight proportion calculation process comprises the following steps:
X=a*0.4+b*0.3+c*0.1+d*0.1+e*0.1
wherein a is network bandwidth occupancy, b is CPU occupancy, c is GPU occupancy, d is disk storage block occupancy, and e is memory storage block occupancy;
the weight proportion calculation process of the IO bandwidth type is as follows:
X=f/total*0.5+a*0.5
where f is the number of disk IO requests, and total is the maximum disk IO request.
In the embodiment of the invention, the specific scheduling process is as follows:
The server calculates Y values once every n (n < = 20) seconds, and calculates an average value Y=X/(60/n) once every minute, wherein each half hour is a time unit group, and the time unit group is (Y1, Y2, Y3...Y30), and only 30 values of half hour can be stored;
and determining the minimum value as the server with the highest weight according to the Y/n value sent by each server.
The server groups do not directly communicate with each other, data is sent according to ssdp protocol, and each basic weight is dynamically adjusted in the script according to different functions. The script embeds the early warning signaling, exceeds the specified threshold value, the server does not announce the offline, only announces that the server does not accept more service instructions, still serves the client point which is already linked to exist, if the energy consumption of cpu and the like is high (the service is possibly occupied by other processes), the server script announces that the server is offline, the sip deletes the server candidate, meanwhile, the sip signaling server returns the streaming media server address according to the calculated X value, the streaming media server uses the script to calculate the storage server address and the reasoning server address according to the calculation formula, and notifies the storage server and the reasoning server.
If the subscription is made, the subscriber acquires a server address acquisition stream from the sip server or stores a video file.
And determining the weight proportion of the server according to the actual obtained resource occupancy. And (3) adopting a hot loading script, changing a strategy mode by the script, dynamically calculating a script formula, rapidly deleting server candidates according to early warning information (ssdp protocol), and subdividing server weight proportion according to functions.
In an embodiment of the present invention, the early warning model includes the following data:
CPU warns;
i, electricity utilization warning;
J, temperature warning;
k, warning of insufficient memory;
a disk shortage warning;
and storing alarm model data within 5 minutes in the server, and directly deleting the server to be selected according to the early warning model.
In the embodiment of the invention, the method for displaying the data to the subscriber by the scheduling method comprises the following steps:
The distributed data are sequentially transmitted to a streaming media server in a data stream mode at a push stream end, after the sip center signaling scheduling server detects that the data stream reaches the streaming media server, the server of the current local area network and the functions thereof are detected through ssdp protocol in the streaming media server, meanwhile, the scheduling strategy of the sip center signaling scheduling server is changed through the python hot loading script or the c++ hot loading script or the iua hot loading script or the js hot loading script which are prepared in directory service contained in the reasoning server, the streaming media server adjusts the corresponding strategy of a matching mode between an origin main service and an edge server according to the scheduling strategy of the sip center signaling scheduling server, then the main reasoning server and the edge reasoning server in the sip center signaling scheduling server are called to conduct data stream reasoning, the processed data stream is stored by the storage server, the data stream in the streaming media server or the data file in the storage server is directly called, the data stream or the data file in the storage server is transmitted to a player in a display screen, and the data file is combined with a DLAN (digital subscriber).
Another object of an embodiment of the present invention is to provide a bypass-mode intelligent server scheduling system for implementing the bypass-mode intelligent server scheduling method, where the bypass-mode intelligent server scheduling system includes:
The media engine module comprises a media calculation layer and ssiop protocols and is used for carrying out matching modes of the origin main service and the edge server;
a signaling and gateway module for interacting with the search protocol ssiop module;
The reasoning engine module comprises a capability AP layer and ssiop protocols and is used for carrying out directory services and main reasoning services, wherein the directory services comprise python scripts, C++ scripts, lua scripts and js scripts;
A search protocol ssiop module for searching and discovering devices and various occupancy protocols;
The storage module comprises a capacity AP layer and an SSDP protocol and is used for storing data information;
And the event warning module is used for event editing and event script.
The system provided by the embodiment of the invention firstly searches equipment in the current local area network by using a search protocol SSDP, comprising camera equipment, routing equipment, PC end equipment and mobile end equipment, and remotely manages all network equipment supporting the protocol by using a snmp protocol, comprising monitoring network state, modifying network equipment configuration, receiving network event warning, simultaneously combining a streaming media transmission protocol RTSP, RTMP, RTP, RTCP, collecting TS and PS streams, transmitting the streaming media protocol to a signaling and gateway module, interacting with an AB protocol, then transmitting the collected streaming data to a media engine module by the search protocol SSDP module, detecting that a data stream reaches a media engine by a sip center signaling scheduling server, detecting a server and functions thereof of the current local area network by the SSDP protocol, simultaneously changing a scheduling strategy of the sip center signaling scheduling server by using a Pthon hot loading script or a js hot loading script which is prepared in a directory service contained in an inference server, adjusting the streaming media protocol between a signaling main service and an edge server according to a scheduling strategy of the sip center signaling scheduling server, then transmitting the collected streaming data to a media engine module by the search protocol SSDP module, and directly calling the client in the client module to a client module according to a client policy of the client 53 server or a client, and displaying the data stream in a client-side layer server, and directly subscribing the data stream in a client-oriented data-layer server by the inferred client module if the client is displayed in the client-side server, the event warning module transmits the event editing data and the event script data to the display module in the form of data streams.
It should be noted that the embodiments of the present invention can be realized in hardware, software, or a combination of software and hardware. The hardware portions may be implemented using dedicated logic and the software portions may be stored in a memory for execution by a suitable instruction execution system, such as a microprocessor or dedicated design hardware. Those of ordinary skill in the art will appreciate that the apparatus and methods described above may be implemented using computer executable instructions and/or embodied in processor control code, such as provided on a carrier medium such as a magnetic disk, CD or DVD-ROM, a programmable memory such as read only memory (firmware), or a data carrier such as an optical or electronic signal carrier. The device of the present invention and its modules may be implemented by hardware circuitry, such as very large scale integrated circuits or gate arrays, semiconductors such as logic chips, transistors, etc., or programmable hardware devices such as field programmable gate arrays, programmable logic devices, etc., as well as software executed by various types of processors, or by a combination of the above hardware circuitry and software, such as firmware.
The foregoing is merely illustrative of specific embodiments of the present invention, and the scope of the invention is not limited thereto, but any modifications, equivalents, improvements and alternatives falling within the spirit and principles of the present invention will be apparent to those skilled in the art within the scope of the present invention.

Claims (6)

1.一种旁路方式的智能服务器调度方法,其特征在于,所述旁路方式的智能服务器调度方法包括:1. A bypass intelligent server scheduling method, characterized in that the bypass intelligent server scheduling method comprises: 步骤一,使用旁路方式启动检测进程,根据资源占有率、热加载脚本和预警模型重新调整计算多服务器架构的服务器权重比重;Step 1: Use bypass mode to start the detection process, and readjust the server weight ratio of the multi-server architecture according to resource occupancy, hot loading script and early warning model; 步骤二,根据ssdp协议发送数据使媒体引擎调整匹配不同的策略模式来调度服务器;Step 2: Send data according to the SSDP protocol to enable the media engine to adjust and match different strategy modes to schedule the server; 每个物理服务器启动一个旁路监测进程watch,该进程去检测物理服务器的cpu、gpu、内存、磁盘io,进程根据ssdp协议发送检测到的数据,由sip信令服务进程再根据ssdp协议获取cpu、gpu、io资源占有率,通过热加载策略脚本和马尔可夫预警模型来删除服务器,重新调整计算多种服务器情况下各个服务器的权重比重;Each physical server starts a bypass monitoring process watch, which detects the CPU, GPU, memory, and disk IO of the physical server. The process sends the detected data according to the SSDP protocol, and the SIP signaling service process obtains the CPU, GPU, and IO resource occupancy rate according to the SSDP protocol. The server is deleted through the hot loading strategy script and the Markov early warning model, and the weight ratio of each server is recalculated in the case of multiple servers. 所述方法包含的热加载脚本应用过程为:The hot loading script application process included in the method is: 信令服务器在启动以后,会根据操作系统文件改变事件检测脚本,当脚本文件发生变化时,重新读取脚本获取权重公式,从而更新服务器调度策略,策略模式包括带宽占有率型以及IO带宽类型;After the signaling server is started, it will change the event detection script according to the operating system file. When the script file changes, it will re-read the script to obtain the weight formula, thereby updating the server scheduling strategy. The strategy modes include bandwidth occupancy type and IO bandwidth type. 调度方法将数据展示给订阅者的方法为:The scheduling method displays data to subscribers as follows: 将已发布的数据在推流端以数据流的形式依次传输至流媒体服务器中,sip中心信令调度服务器检测到数据流到达流媒体服务器后,通过流媒体服务器中的ssdp协议侦测当前局域网的服务器以及其职能,同时通过推理服务器包含的目录服务中已经准备好的python热加载脚本或者c++热加载脚本或者lua热加载脚本或者js热加载脚本改变sip中心信令调度服务器的调度策略,流媒体服务器根据sip中心信令调度服务器的调度策略调整origin主服务与边缘服务器之间的匹配模式的相应策略,然后sip中心信令调度服务器调用推理服务器中的主推理服务器与边缘推理服务器进行数据流推理,存储服务器将处理好的数据流进行存储,sip中心信令调度服务器通过直接调用流媒体服务器中的数据流或者存储服务器中的数据文件,传输至展示play订阅中的播放器处,结合大屏DLAN协议,将数据展示给订阅者;The published data is transmitted to the streaming media server in the form of data streams at the push end. After the SIP central signaling scheduling server detects that the data stream has arrived at the streaming media server, it detects the server and its function in the current LAN through the SSDP protocol in the streaming media server. At the same time, the scheduling strategy of the SIP central signaling scheduling server is changed through the Python hot loading script, C++ hot loading script, Lua hot loading script or JS hot loading script prepared in the directory service contained in the inference server. The streaming media server adjusts the corresponding strategy of the matching mode between the origin main service and the edge server according to the scheduling strategy of the SIP central signaling scheduling server. Then, the SIP central signaling scheduling server calls the main inference server and the edge inference server in the inference server to perform data stream inference. The storage server stores the processed data stream. The SIP central signaling scheduling server directly calls the data stream in the streaming media server or the data file in the storage server, and transmits it to the player in the display play subscription, and displays the data to the subscriber in combination with the large screen DLAN protocol. 所述步骤二中策略模式包括带宽占有率型以及IO带宽类型;The strategy mode in step 2 includes bandwidth occupancy type and IO bandwidth type; 假设不同的服务器占用的网卡接口不同;Assume that different servers occupy different network card interfaces; 所述带宽占有率型为权值比重中网络带宽占有率高的策略;The bandwidth occupancy type is a strategy in which the network bandwidth occupancy is high in the weight ratio; 所述带宽占有率型的权值比重计算过程为:The bandwidth occupancy rate weight ratio calculation process is as follows: X=a*0.4+b*0.3+c*0.1+d*0.1+e*0.1X=a*0.4+b*0.3+c*0.1+d*0.1+e*0.1 式中,a为网络带宽占有率,b为CPU占有率,c为GPU占有率,d为磁盘存储块占有率,e为内存存储块占有率;In the formula, a is the network bandwidth occupancy, b is the CPU occupancy, c is the GPU occupancy, d is the disk storage block occupancy, and e is the memory storage block occupancy; 所述IO带宽类型的权值比重计算过程为:The weight ratio calculation process of the IO bandwidth type is as follows: X=(f/total)*0.5+a*0.5X=(f/total)*0.5+a*0.5 式中,f为磁盘io请求个数,total为最大磁盘IO请求。In the formula, f is the number of disk IO requests, and total is the maximum disk IO request. 2.如权利要求1所述旁路方式的智能服务器调度方法,其特征在于,所述调度服务器的具体过程为:2. The bypass intelligent server scheduling method according to claim 1, wherein the specific process of scheduling the server is: 服务器每隔n秒钟计算一次Y值,n<=20,每一分钟求一次均值Y=X/(60/n),每半小时为一个时间单位组,为Y1,Y2,Y3......Y30,只存储半小时的值30个;根据每个服务器发送的Y/n值,确定最小值为权重最高的服务器,根据存储的5分钟之内的报警模型数据直接删除掉待选服务器;The server calculates the Y value every n seconds, n<=20, and calculates the average value Y=X/(60/n) every minute. Each half hour is a time unit group, which is Y1, Y2, Y3...Y30. Only 30 half-hour values are stored. According to the Y/n value sent by each server, the server with the minimum value is determined as the server with the highest weight. According to the alarm model data stored within 5 minutes, the candidate server is directly deleted. 所述预警模型包括如下数据:cpu警告、用电警告、温度警告、内存不足警告、磁盘不足警告。The early warning model includes the following data: CPU warning, power usage warning, temperature warning, insufficient memory warning, and insufficient disk warning. 3.一种实施如权利要求1-2任意一项所述调度方法的旁路方式的智能服务器调度系统,其特征在于,所述旁路方式的智能服务器调度系统包括:3. An intelligent server scheduling system in a bypass mode for implementing the scheduling method according to any one of claims 1 to 2, characterized in that the intelligent server scheduling system in a bypass mode comprises: 媒体引擎模块,包括媒体计算层和SSDP协议,用于进行origin主服务和边缘服务器的匹配;The media engine module includes the media computing layer and the SSDP protocol, which is used to match the origin main service with the edge server; 信令和网关模块,用于与搜索协议SSDP模块交互;Signaling and gateway module, used to interact with the search protocol SSDP module; 推理引擎模块,包括能力AP层和SSDP协议,用于进行目录服务以及主推理服务,所述目录服务包括python脚本、C++脚本、lua脚本以及js脚本;The inference engine module includes the capability AP layer and the SSDP protocol, and is used to perform directory services and main inference services. The directory services include python scripts, C++ scripts, lua scripts, and js scripts. 搜索协议SSDP模块,用于搜索协议SSDP;Search protocol SSDP module, used to search protocol SSDP; 存储模块,包括能力AP层和SSDP协议,用于存储数据信息;Storage module, including capability AP layer and SSDP protocol, used to store data information; 展示模块,包括播放器以及大屏DLNA协议;Display module, including player and large screen DLNA protocol; 事件警示模块,用于事件编辑和事件脚本。Event alert module, used for event editing and event scripting. 4.一种利用权利要求3所述的旁路方式的智能服务器调度系统的调度方法,其特征在于,包括:4. A scheduling method of an intelligent server scheduling system using the bypass method of claim 3, characterized in that it comprises: 首先使用搜索协议SSDP搜索当前局域网内的设备,包括摄像设备,路由设备,PC端设备,移动端设备,并通过snmp协议远程管理所有支持这种协议的网络设备,包括监视网络状态、修改网络设备配置、接收网络事件警告,同时结合流媒体传输协议RTSP、RTMP、RTP、RTCP,收集TS,PS流,将流媒体协议传输至信令和网关模块中,与AB协议进行交互;First, use the search protocol SSDP to search for devices in the current LAN, including cameras, routers, PC devices, and mobile devices, and remotely manage all network devices that support this protocol through the SNMP protocol, including monitoring network status, modifying network device configuration, and receiving network event warnings. At the same time, combine the streaming media transmission protocols RTSP, RTMP, RTP, and RTCP to collect TS and PS streams, transmit the streaming media protocol to the signaling and gateway modules, and interact with the AB protocol; 然后搜索协议SSDP模块将收集的流数据传输至媒体引擎模块,sip中心信令调度服务器检测到数据流到达媒体引擎后,通过ssdp协议侦测当前局域网的服务器以及其职能,同时通过推理服务器包含的目录服务中已经准备好的python热加载脚本或者c++热加载脚本或者lua热加载脚本或者js热加载脚本改变sip中心信令调度服务器的调度策略,媒体引擎根据sip中心信令调度服务器的调度策略调整origin主服务与边缘服务器之间的匹配模式的相应策略;Then the search protocol SSDP module transmits the collected stream data to the media engine module. After the SIP center signaling scheduling server detects that the data stream has arrived at the media engine, it detects the server and its function in the current LAN through the SSDP protocol. At the same time, it changes the scheduling strategy of the SIP center signaling scheduling server through the prepared Python hot loading script, C++ hot loading script, Lua hot loading script, or JS hot loading script in the directory service contained in the inference server. The media engine adjusts the corresponding strategy of the matching mode between the origin main service and the edge server according to the scheduling strategy of the SIP center signaling scheduling server. 然后sip中心信令调度服务器根据GPU,CPU,MEMORY以及DISK中的占用情况调用推理服务器中的主推理服务器与边缘推理服务器进行数据流推理,存储服务器将处理好的数据流进行存储,sip中心信令调度服务器通过直接调用流媒体服务器中的数据流或者存储服务器中的数据文件,传输至展示模块中的html5player或者mobile player处,结合大屏DLAN协议,将数据展示给订阅者,同时,如果有预警出现,事件警示模块将事件编辑数据和事件脚本数据以数据流的形式传输至展示模块。Then, the SIP center signaling scheduling server calls the main inference server and the edge inference server in the inference server to perform data flow inference according to the occupancy of GPU, CPU, MEMORY and DISK. The storage server stores the processed data flow. The SIP center signaling scheduling server directly calls the data flow in the streaming media server or the data file in the storage server, and transmits it to the HTML5 player or mobile player in the display module. Combined with the large-screen DLAN protocol, the data is displayed to subscribers. At the same time, if an early warning occurs, the event warning module transmits the event editing data and event script data to the display module in the form of a data stream. 5.一种计算机可读存储介质,存储有计算机程序,所述计算机程序被处理器执行时,使得所述处理器执行如权利要求1-2任意一项所述旁路方式的智能服务器调度方法的步骤。5. A computer-readable storage medium storing a computer program, wherein when the computer program is executed by a processor, the processor executes the steps of the bypass intelligent server scheduling method as described in any one of claims 1-2. 6.一种信息数据处理终端,其特征在于,所述信息数据处理终端用于实现如权利要求3所述旁路方式的智能服务器调度系统。6. An information data processing terminal, characterized in that the information data processing terminal is used to implement the intelligent server scheduling system in a bypass mode as described in claim 3.
CN202211595358.4A 2022-12-13 2022-12-13 Bypass intelligent media server scheduling method, system, equipment and medium Active CN116032895B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202211595358.4A CN116032895B (en) 2022-12-13 2022-12-13 Bypass intelligent media server scheduling method, system, equipment and medium

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202211595358.4A CN116032895B (en) 2022-12-13 2022-12-13 Bypass intelligent media server scheduling method, system, equipment and medium

Publications (2)

Publication Number Publication Date
CN116032895A CN116032895A (en) 2023-04-28
CN116032895B true CN116032895B (en) 2024-12-24

Family

ID=86069796

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202211595358.4A Active CN116032895B (en) 2022-12-13 2022-12-13 Bypass intelligent media server scheduling method, system, equipment and medium

Country Status (1)

Country Link
CN (1) CN116032895B (en)

Families Citing this family (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN117057527B (en) * 2023-06-30 2024-05-14 东风设备制造有限公司 Intelligent operation and maintenance method and system for industrial Internet of things of automobile manufacturing equipment

Citations (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN103096146A (en) * 2011-11-04 2013-05-08 华为软件技术有限公司 Media information issuing method and issuing management server
CN110333939A (en) * 2019-06-17 2019-10-15 腾讯科技(成都)有限公司 Task mixed scheduling method, device, dispatch server and Resource Server

Family Cites Families (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US9253051B2 (en) * 2012-02-23 2016-02-02 Ericsson Ab System and method for delivering content in a content delivery network
US9438487B2 (en) * 2012-02-23 2016-09-06 Ericsson Ab Bandwith policy management in a self-corrected content delivery network
CN104021078B (en) * 2014-06-13 2016-07-06 中国民航信息网络股份有限公司 Software supervision device and method
CN113973092B (en) * 2020-07-24 2024-05-24 中国移动通信集团浙江有限公司 Link resource scheduling method, device, computing equipment and computer storage medium
CN113676750A (en) * 2021-08-20 2021-11-19 重庆菲莫科技有限公司 Stream media server cluster management system
CN115002126B (en) * 2022-04-30 2024-01-12 苏州浪潮智能科技有限公司 Service scheduling method and device based on edge server cluster

Patent Citations (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN103096146A (en) * 2011-11-04 2013-05-08 华为软件技术有限公司 Media information issuing method and issuing management server
CN110333939A (en) * 2019-06-17 2019-10-15 腾讯科技(成都)有限公司 Task mixed scheduling method, device, dispatch server and Resource Server

Also Published As

Publication number Publication date
CN116032895A (en) 2023-04-28

Similar Documents

Publication Publication Date Title
US8949436B2 (en) System and method for controlling peer-to-peer connections
JP6293969B2 (en) Method and system for triggering efficient application synchronization
CN109150987B (en) Two-layer container cluster elastic expansion method based on host layer and container layer
WO2019209415A1 (en) Microservice platform with messaging system
CN113811013B (en) Cluster capacity dynamic adjustment method, equipment, storage media and communication system
CN101841553B (en) Method, user node and server for requesting location information of resources on network
US9521178B1 (en) Dynamic bandwidth thresholds
US12407897B2 (en) Peer-managed content distribution network
CN103201984B (en) For the system and method for the dynamic-configuration of the overlay network based on ISN memory
CN114071168B (en) Mixed-flow live stream scheduling method and device
EP4618503A1 (en) Data transmission processing method and device, storage medium, and electronic device
CN116032895B (en) Bypass intelligent media server scheduling method, system, equipment and medium
EP1627500B1 (en) Service management using multiple service location managers
CN101662508B (en) Method for data transmission based on point-to-point protocol, device and system thereof
CN113867946A (en) Method, device, storage medium and electronic equipment for accessing resources
JP2013207324A (en) Method for selecting video in environment where plural image compression formats exist
Pal et al. A survey on adaptive multimedia streaming
US8467313B1 (en) PHY bandwidth estimation from backpressure patterns
JP6107218B2 (en) Control device, control method, and control program
CN114095508A (en) Method for P2P transmission under same switch
CN115695919B (en) Decentralized video processing method, device, and electronic device
KR100705582B1 (en) Service providing method and device thereof in multiple network system
WO2014121605A1 (en) Method, device and system for supporting always online infrastructure of multi-terminal application
CN113810461A (en) Bandwidth control method, device, equipment and readable storage medium
CN111327872B (en) A one-to-many access networking code stream distribution method and system

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination
GR01 Patent grant
GR01 Patent grant