CN108540820B - Stream data management method, device and computer readable storage medium - Google Patents
Stream data management method, device and computer readable storage medium Download PDFInfo
- Publication number
- CN108540820B CN108540820B CN201810433121.3A CN201810433121A CN108540820B CN 108540820 B CN108540820 B CN 108540820B CN 201810433121 A CN201810433121 A CN 201810433121A CN 108540820 B CN108540820 B CN 108540820B
- Authority
- CN
- China
- Prior art keywords
- stream data
- target
- address
- multicast
- data
- 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
Links
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04N—PICTORIAL COMMUNICATION, e.g. TELEVISION
- H04N21/00—Selective content distribution, e.g. interactive television or video on demand [VOD]
- H04N21/20—Servers specifically adapted for the distribution of content, e.g. VOD servers; Operations thereof
- H04N21/21—Server components or server architectures
- H04N21/218—Source of audio or video content, e.g. local disk arrays
- H04N21/2187—Live feed
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04N—PICTORIAL COMMUNICATION, e.g. TELEVISION
- H04N21/00—Selective content distribution, e.g. interactive television or video on demand [VOD]
- H04N21/20—Servers specifically adapted for the distribution of content, e.g. VOD servers; Operations thereof
- H04N21/25—Management operations performed by the server for facilitating the content distribution or administrating data related to end-users or client devices, e.g. end-user or client device authentication, learning user preferences for recommending movies
- H04N21/262—Content or additional data distribution scheduling, e.g. sending additional data at off-peak times, updating software modules, calculating the carousel transmission frequency, delaying a video stream transmission, generating play-lists
- H04N21/26208—Content or additional data distribution scheduling, e.g. sending additional data at off-peak times, updating software modules, calculating the carousel transmission frequency, delaying a video stream transmission, generating play-lists the scheduling operation being performed under constraints
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04N—PICTORIAL COMMUNICATION, e.g. TELEVISION
- H04N21/00—Selective content distribution, e.g. interactive television or video on demand [VOD]
- H04N21/60—Network structure or processes for video distribution between server and client or between remote clients; Control signalling between clients, server and network components; Transmission of management data between server and client, e.g. sending from server to client commands for recording incoming content stream; Communication details between server and client
- H04N21/63—Control signaling related to video distribution between client, server and network components; Network processes for video distribution between server and clients or between remote clients, e.g. transmitting basic layer and enhancement layers over different transmission paths, setting up a peer-to-peer communication via Internet between remote STB's; Communication protocols; Addressing
- H04N21/64—Addressing
- H04N21/6405—Multicasting
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04N—PICTORIAL COMMUNICATION, e.g. TELEVISION
- H04N21/00—Selective content distribution, e.g. interactive television or video on demand [VOD]
- H04N21/60—Network structure or processes for video distribution between server and client or between remote clients; Control signalling between clients, server and network components; Transmission of management data between server and client, e.g. sending from server to client commands for recording incoming content stream; Communication details between server and client
- H04N21/63—Control signaling related to video distribution between client, server and network components; Network processes for video distribution between server and clients or between remote clients, e.g. transmitting basic layer and enhancement layers over different transmission paths, setting up a peer-to-peer communication via Internet between remote STB's; Communication protocols; Addressing
- H04N21/643—Communication protocols
Landscapes
- Engineering & Computer Science (AREA)
- Multimedia (AREA)
- Signal Processing (AREA)
- Databases & Information Systems (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
- Two-Way Televisions, Distribution Of Moving Picture Or The Like (AREA)
Abstract
The application discloses a stream data management method, a stream data management device and a computer readable storage medium, and relates to the technical field of communication processing. The stream data management method comprises the following steps: acquiring multimedia multicast stream data according to the multicast address and processing the multimedia multicast stream data into target stream data in a target format; outputting the processed target stream data to a target address according to the corresponding relation between the preset multicast address and the target address; and monitoring the state of the target stream data according to the target address, and outputting alarm information when the state of the target stream data is abnormal, wherein the alarm information comprises the relevant address, the identification information and the state description information of the target stream data. The method, the device and the computer readable storage medium can be used for improving the automation degree of the multimedia stream data scheduling and realizing the dynamic monitoring of the data scheduling.
Description
Technical Field
The present application relates to the field of communications technologies, and in particular, to a method and an apparatus for stream data management, and a computer-readable storage medium.
Background
With the popularization of intelligent terminals and the great reduction of the bandwidth cost of mobile networks, the application range and the popularity of live broadcast and on-demand broadcast are wider and wider. In order to share the multimedia live broadcast or on-demand stream data of the broadcast television network to users in other networks, a service provider typically physically interfaces SDI (digital component serial interface) of related devices (such as a CP6000 transmitter, a satellite receiver, a television station cable signal card, and the like) in the broadcast television network to a physical matrix based on the physical matrix, and then receives SDI interface signals through a hardware coding device, converts the SDI interface signals into target stream data in a specified format, and configures the target stream data to a cloud clipping system. However, the scheduling process of the entire stream data is less automated.
Disclosure of Invention
In view of the above, embodiments of the present application provide a stream data management method, an apparatus and a computer-readable storage medium, which can be used to improve the automation degree of multimedia stream data scheduling and implement dynamic monitoring of data scheduling.
An embodiment of the present application provides a stream data management method, which is applied to a server, and the method includes: acquiring multimedia multicast stream data according to the multicast address and processing the multimedia multicast stream data into target stream data in a target format; outputting the processed target stream data to the target address according to the preset corresponding relation between the multicast address and the target address; and monitoring the state of the target stream data according to the target address, and outputting alarm information when the state of the target stream data is abnormal, wherein the alarm information comprises a relevant address, identification information and state description information of the target stream data.
An aspect of the present embodiment further provides a stream data management apparatus, including: the processing module is used for acquiring multimedia multicast stream data according to the multicast address and processing the acquired multimedia multicast stream data into target stream data in a target format; the output module is used for outputting the processed target stream data to the target address according to the preset corresponding relation between the multicast address and the target address; the monitoring module is used for monitoring the state of the target stream data according to the target address; and the alarm module is used for outputting alarm information when the monitoring module monitors that the state of the target stream data is abnormal, wherein the alarm information comprises the related address, the identification information and the state description information of the target stream data.
An aspect of the embodiments of the present application further provides a computer-readable storage medium, on which a computer program is stored, where the computer program is executed by a processor to implement the streaming data management method.
According to the embodiments of the application, multimedia multicast stream data is obtained according to the multicast address and processed into target stream data in a target format, then the processed target stream data is output to the target address according to the corresponding relation between the multicast address and the target address, and meanwhile the state of the target stream data is monitored according to the target address, so that automatic scheduling and dynamic monitoring of the stream data are realized. In addition, because the corresponding relation between the multicast address and the target address is fixed, the frequency of changing the stream data acquisition address when the multicast address is in butt joint with the playing system can be reduced, the operation and maintenance efficiency is greatly improved, and the operation and maintenance cost is reduced.
Drawings
Fig. 1 is a schematic application environment diagram of a stream data management method according to an embodiment of the present application;
fig. 2 is a schematic flow chart illustrating an implementation of a stream data management method according to an embodiment of the present application;
fig. 3 is a schematic flow chart illustrating an implementation of a stream data management method according to another embodiment of the present application;
fig. 4 is a schematic diagram illustrating a configuration target address in a stream data management method according to an embodiment of the present application;
fig. 5 is a schematic structural diagram of a stream data management apparatus according to an embodiment of the present application;
fig. 6 is a schematic structural diagram of a stream data management apparatus according to another embodiment of the present application;
fig. 7 is a schematic hardware structure diagram of a server according to an embodiment of the present application.
Detailed Description
To further clarify the technical measures and effects taken by the present application to achieve the intended purpose of the invention, the following detailed description is given, along with the accompanying drawings and preferred embodiments, of specific embodiments, structures, features and effects according to the present application.
Please refer to fig. 1, which is a schematic diagram of an application environment of a stream data management method according to an embodiment of the present application. As shown in fig. 1, taking sharing video multicast stream data to a live platform as an example, first, basic information for stream data scheduling is set by a front-end device, such as: input configuration information and output configuration information of stream data to be scheduled, and the like. The front-end device may be, for example, an intelligent mobile terminal such as a smart phone, a tablet computer, and a laptop, or another computer terminal that is not capable of performing data processing during movement.
Then, under the dispatching of the dispatching server, the stream data processing cluster receives the video multicast stream data from broadcasting and television equipment (such as a CP6000 transmitter, a satellite receiver and a television station cable signal card machine) of the satellite machine room according to the basic information set by the front-end equipment, and carries out transcoding and de-interlacing processing on the received video multicast stream data to obtain target stream data with specified definition and code rate, and pushes the target stream data to the stream receiving server cluster.
Then, under the scheduling of the scheduling server, the target stream data is converted into data in an http flv format through the stream receiving cluster, and the data is configured to a live broadcast cloud clipping system to be used for editing personnel to clip videos. The scheduling server can complete the automatic scheduling of the streaming data by calling the interfaces of the media + marathon. In addition, in the process of dispatching the streaming data, the dispatching server can also detect the dispatching condition of the flv streaming data by calling a media + marathon interface and dynamically allocating a monitoring process through a monitoring server cluster.
Referring to fig. 2, fig. 2 is a schematic flow chart illustrating an implementation of a stream data management method according to an embodiment of the present application. The stream data management method provided by the embodiment can be applied to the scheduling server shown in fig. 1. As shown in fig. 2, the method mainly includes the following steps:
201. acquiring multimedia multicast stream data according to the multicast address and processing the multimedia multicast stream data into target stream data in a target format;
multicast (Multicast) refers to a point-to-multipoint network connection between a sender and multiple receivers, and the sender only needs to copy one copy of the same data packet when transmitting the same data to multiple receivers at the same time. The broadcast and television equipment of the satellite room usually sends the satellite signal of the television to the demultiplexing equipment in a multicast mode.
The scheduling server is preset with multicast addresses of a plurality of multimedia multicast stream data multicast by the broadcasting and television equipment, acquires corresponding multimedia multicast stream data from the broadcasting and television equipment according to the multicast addresses, and then processes the multimedia multicast stream data into target stream data in a target format supported by a live broadcast or on-demand system.
202. Outputting the processed target stream data to a target address according to the corresponding relation between the preset multicast address and the target address;
the one-to-one correspondence relationship between the multicast address and the target address is preset in the scheduling server. And outputting the processed target stream data to a corresponding target address according to the relation so that the live broadcast or on-demand system can acquire the target stream data according to the target address and distribute the target stream data to each terminal device for playing.
203. And monitoring the state of the target stream data according to the target address, and outputting alarm information when the state of the target stream data is abnormal.
Specifically, the state information of the target stream data is acquired in real time according to the target address and analyzed, and whether the state of the target stream data is abnormal or not is judged, such as whether the situations of flow break, mute, silence and the like occur or not. Once the situations of the above-mentioned flow break, static frame, silence and the like are found, alarm information is output according to a preset output mode. The alarm information may include, but is not limited to, the associated address of the streaming data, identification information, source and status description information. The identification information may be, for example, a signal name. The associated address includes a corresponding multicast address and/or destination address.
According to the stream data management method provided by the embodiment, the multimedia multicast stream data is acquired according to the multicast address and processed into the target stream data in the target format, then the processed target stream data is output to the target address according to the corresponding relation between the multicast address and the target address, and meanwhile, the state of the target stream data is monitored according to the target address, so that the automatic scheduling and the dynamic monitoring of the stream data are realized. In addition, because the corresponding relation between the multicast address and the target address is fixed, the frequency of changing the stream data acquisition address when the multicast address is in butt joint with the playing system can be reduced, the operation and maintenance efficiency is greatly improved, and the operation and maintenance cost is reduced.
Referring to fig. 3, fig. 3 is a schematic flow chart illustrating an implementation of a stream data management method according to another embodiment of the present application. The stream data management method provided by the embodiment can be applied to the scheduling server shown in fig. 1. As shown in fig. 3, the method mainly includes the following steps:
301. configuring corresponding target addresses for multimedia multicast stream data of different sources according to configuration instructions sent by a client;
302. storing the corresponding relation between the multicast address of the multimedia multicast stream data of different sources and the corresponding target address;
the present embodiment is based on a physical Matrix (Stream Matrix) implementation. The physical matrix is a device which outputs M video and audio signals to N outputs at will by an array switching method, and the input and output of the device have M × N combinations. Before performing streaming data scheduling, as shown in fig. 4, an administrator may set a correspondence relationship between input configuration information and output configuration information through a client on a configuration web page (web) provided by a scheduling server. Wherein inputting configuration information may include, but is not limited to: identification information, source and multicast address of the multimedia multicast stream data. The identification information may be a signal name of the multimedia multicast stream data. The output configuration information may include, but is not limited to: target address, target definition, and target code rate. The target address is an address corresponding to the storage position of the multimedia multicast stream data after transcoding, format conversion and other processing. In practical applications, the target address may be a Uniform Resource Locator (URL) address. The target definition and the target code rate are definition and code rate of the multimedia multicast stream data after transcoding, format conversion and the like. The code rate, which may also be referred to as a sampling rate, refers to the number of data bits transmitted per unit time during data transmission, and is typically in kbps (kilobits per second).
Specifically, the receiving client configures corresponding target addresses for the multimedia multicast stream data of different sources through a configuration instruction sent by a configuration webpage based on configuration operation of a user, and stores a corresponding relationship between the multicast address of the multimedia multicast stream data of different sources and the corresponding target address in a database.
303. Acquiring multimedia multicast stream data according to the multicast address and processing the multimedia multicast stream data into target stream data in a target format;
specifically, with reference to fig. 1, an API (Application Programming Interface) of Marathon is called, and a data processing process is started in the streaming data processing server cluster. Then, through the data processing process, multimedia multicast stream data is obtained according to the multicast address in the input configuration information, and the obtained multimedia multicast stream data is transcoded and deinterlaced according to a preset transcoding rule, so that stream data with target definition and target code rate is obtained. Then, using an RTMP Protocol (Real Time Messaging Protocol), the stream data with the target definition and the target code rate is pushed to a streaming media server (Crtmpserver) to connect the streaming cluster. Then, calling an API of Marathon to start a stream pulling process (Rtmpstreammaker), and using RTMP to pull stream data with target definition and target bitrate from a Crtmpserver stream receiving cluster through the Rtmpmaker and converting the stream data into target stream data in a target format. Among them, Marathon is a container arrangement framework of apache messos, which is mainly used to schedule and run resident services (long-running services).
It will be appreciated that the output devices for multicast streaming data may be a satellite receiver, a cable card reader, and a CP6000 codec in general. The satellite receiver is used for receiving satellite signals, the cable card reader is used for receiving cable television signals of a television station, and the CP6000 codec is used for remotely transmitting video signals. The multicast stream data output by these three types of devices is usually interlaced ts (transport stream) stream data, so that it is necessary to perform de-interlacing processing while transcoding the acquired multimedia multicast stream data. De-interlacing is the conversion of interlaced video to progressive video.
Optionally, the stream data processing server cluster is an FFmpeg server cluster, and the data processing process is an FFmpeg process. FFmpeg is a set of open source computer programs that can be used to record, convert digital audio, video, and convert them into streams. In this embodiment, the FFmpeg process is mainly used for transcoding of stream data. The FFmpeg process is used for processing the multicast stream data, and the multicast stream data allows a plurality of clients to receive the multicast stream data at the same time, so the multicast stream data is not limited by the number of SDI physical ports, and the expansibility is not limited theoretically, so a physical matrix and hardware coding equipment are saved, and the cost can be reduced.
Optionally, the target format is an HTTP-FLV format, that is, an FLV file transmitted by an HTTP protocol (HyperText transfer protocol).
304. Outputting the processed target stream data to a target address according to the corresponding relation between the preset multicast address and the target address;
specifically, in the correspondence between the input configuration information and the output configuration information, a destination address corresponding to a multicast address of the currently processed multimedia multicast stream data is searched. And then outputting the target stream data in the HTTP-FLV format obtained by processing according to the searched target address.
305. Sending the target address to a playing system so that the playing system acquires target stream data from the target address;
the playback system may be an on-demand system or a live system. The sending destination address may be based on a play data request sent by the play system, or may be actively pushed to the play system by the scheduling server according to a preset pushing rule. And the playing system acquires corresponding target stream data in the HTTP-FLV format according to the target address and is used for subsequently providing the target stream data for the live broadcast or on-demand user. Optionally, in addition to the target address, the definition and the bit rate of the target stream data may be provided to the playing system for use.
Target stream data are output to a specified target address, and each target stream data is identified by using a URL address, so that when scheduling is carried out, the scheduling of signals can be completed only by changing the Rtmp input address of the Rtmpramer, and the content of the stream data does not need to be changed by frequently configuring and changing the stream data address through a cooperation department and a downstream platform during scheduling, so that a lot of labor cost can be saved.
Further, after finishing the scheduling of the stream data, caching the input configuration information corresponding to the scheduled stream data and the corresponding relationship of the input configuration information in a Redis or similar database for use in subsequent alteration or destruction of the stream data. Where Redis is a key-value database.
306. Monitoring the state of target stream data according to the target address;
307. and when the state of the target stream data is abnormal, outputting alarm information.
Specifically, an API of Marathon is called, a monitoring (Streammonitor) process is started in a monitoring server cluster, and the Streammonitor acquires state information of target stream data in real time according to a target address and reports the state information to a scheduling server. The scheduling server analyzes the state information of the target stream data and judges whether the state of the target stream data is abnormal, such as whether cutoff, silent frame, silence and the like occur. Once the situations of the above-mentioned flow break, static frame, silence and the like are found, alarm information is output according to a preset output mode. The alarm information may include, but is not limited to, the associated address of the streaming data, identification information, source and status description information. The identification information may be, for example, a signal name. The associated address includes a corresponding multicast address and/or destination address. In one practical application, the alarm information may be as follows:
a signal source: [ CCTV5+ ] [ Tianjin Tyda ]
A signal device: [ ID: 40] [ CCTV5+ ] Normal
SID：[TJ01D0301100]
Matrix: [ SMatrix ]
EID：[TJ01S1000500000]
And (3) encoding: soft-woven FLV
[ failure to read frame data ] [ http: // 10.61.22.6: 20005/10000294.flv ]
Or, the Streammonitor acquires the state information of the target stream data in real time and reports the state information to the alarm server, and the alarm server analyzes the state information of the target stream data.
The output mode of the alarm information can be, for example, a mode of sending an instant communication message, sending a short message, making an alarm call or sending an alarm mail. The content of the source end is reflected in the alarm, operation and maintenance personnel can conveniently determine what content is wrong in any place only if the mobile phone has a network, live broadcast or on-demand broadcast is influenced, and then the operation and maintenance personnel of the corresponding platform and the operation personnel of the corresponding content can be contacted in time to carry out emergency treatment.
The streaming data management method provided by this embodiment completes the automatic scheduling of streaming data through the mess Marathon, and dynamically allocates a monitoring process to monitor the state of HTTP-FLV streaming data, thereby implementing the automatic scheduling and dynamic monitoring of streaming data. Furthermore, by combining the FFmpeg with the meso Marathon, the video signal of the satellite machine room is converted into a stream format which can be supported by a video live broadcast system or a video-on-demand system, and is output to the live broadcast or on-demand system, and meanwhile, the scheduling capability of changing the video signal without changing the URL address is also provided, so that the condition that the URL address is frequently changed when the video signal is in butt joint with the on-demand or live broadcast system is avoided, the operation and maintenance efficiency is greatly improved, and the operation and maintenance cost is reduced.
Fig. 5 is a schematic structural diagram of a stream data management apparatus according to an embodiment of the present application. The stream data management apparatus provided in the present embodiment is an execution subject of the stream data management method in the embodiment shown in fig. 2 described above. As shown in fig. 5, the stream data management apparatus provided in this embodiment mainly includes:
a processing module 501, configured to obtain multimedia multicast stream data according to the multicast address, and process the obtained multimedia multicast stream data into target stream data in a target format;
an output module 502, configured to output the processed target stream data to the target address according to a preset corresponding relationship between the multicast address and the target address;
a monitoring module 503, configured to monitor a state of the target stream data according to the target address;
the alarm module 504 is configured to output alarm information when the monitoring module monitors that the state of the target stream data is abnormal, where the alarm information includes a relevant address, identification information, and state description information of the target stream data.
For a specific process of each function module in this embodiment to implement each function, please refer to the specific content described in the embodiment shown in fig. 2, which is not described herein again.
The stream data management device provided in this embodiment acquires multimedia multicast stream data according to a multicast address and processes the multimedia multicast stream data into target stream data in a target format, and then outputs the processed target stream data to the target address according to a corresponding relationship between the multicast address and the target address, and monitors a state of the target stream data according to the target address, thereby implementing automatic scheduling and dynamic monitoring of the stream data. In addition, because the corresponding relation between the multicast address and the target address is fixed, the frequency of changing the stream data acquisition address when the multicast address is in butt joint with the playing system can be reduced, the operation and maintenance efficiency is greatly improved, and the operation and maintenance cost is reduced.
Fig. 6 is a schematic structural diagram of a stream data management apparatus according to another embodiment of the present application. The stream data management apparatus provided by the present embodiment is the execution subject of the stream data management method in the above-described embodiments shown in fig. 2 and 3. As shown in fig. 6, the stream data management apparatus provided in the present embodiment mainly includes:
a processing module 501, configured to obtain multimedia multicast stream data according to the multicast address, and process the obtained multimedia multicast stream data into target stream data in a target format;
an output module 502, configured to output the processed target stream data to the target address according to a preset corresponding relationship between the multicast address and the target address;
a monitoring module 503, configured to monitor a state of the target stream data according to the target address;
the alarm module 504 is configured to output alarm information when the monitoring module 503 monitors that the state of the target stream data is abnormal, where the alarm information includes an address, identification information, and state description information related to the target stream data.
Further, the monitoring module 503 is specifically configured to invoke a Marathon interface, start a monitoring process at the monitoring server cluster, obtain the state information of the target stream data according to the target address through the monitoring process, analyze the state information of the target stream data, and determine whether the state of the target stream data is abnormal.
Further, the processing module 501 includes:
the transcoding module 5011 is configured to invoke a Marathon interface, start a data processing process on the streaming data processing server cluster, obtain the multimedia multicast stream data according to a multicast address through the data processing process, perform transcoding and de-interlacing on the obtained multimedia multicast stream data according to a preset transcoding rule, obtain stream data with a target definition and a target code rate, and push the stream data to the streaming media server to connect to the streaming cluster by using a real-time message transmission protocol;
the format conversion module 5012 is configured to invoke an interface of Marathon to start a stream pulling process, acquire the stream data from the stream server connection cluster by using the real-time messaging protocol through the stream pulling process, and process the stream data into the target stream data in the target format.
Further, the apparatus further comprises:
the sending module 601 is configured to send the target address to a playing system, so that the playing system obtains the target stream data from the target address.
Further, the apparatus further comprises:
the configuration module 602 is configured to configure corresponding destination addresses for the multimedia multicast stream data of different sources according to the configuration instruction sent by the client, and store a corresponding relationship between the multicast address of the multimedia multicast stream data of different sources and the corresponding destination address.
For a specific process of each function module in this embodiment to implement each function, please refer to the specific contents described in the embodiments shown in fig. 2 and fig. 3, which is not described herein again.
The streaming data management device provided by this embodiment completes the automatic scheduling of streaming data through the mess Marathon, and dynamically allocates a monitoring process to monitor the state of HTTP-FLV streaming data, thereby implementing the automatic scheduling and dynamic monitoring of streaming data. Furthermore, by combining the FFmpeg with the meso Marathon, the video signal of the satellite machine room is converted into a stream format which can be supported by a video live broadcast system or a video-on-demand system, and is output to the live broadcast or on-demand system, and meanwhile, the scheduling capability of changing the video signal without changing the URL address is also provided, so that the condition that the URL address is frequently changed when the video signal is in butt joint with the on-demand or live broadcast system is avoided, and the operation and maintenance efficiency is greatly improved.
Referring to fig. 7, fig. 7 is a hardware structure diagram of a server according to an embodiment of the present application.
The server described in this embodiment includes:
a memory 701, a processor 702 and a computer program stored in the memory 701 and executable on the processor 702, when the processor 702 executes the computer program, the method for managing stream data described in the embodiments of fig. 2 and 3 is implemented.
Further, the server further includes:
at least one input device 703 and at least one output device 704.
The memory 701, the processor 702, the input device 703, and the output device 704 are connected by a bus 705.
The input device 703 may be a camera, a touch panel, a physical button, a mouse, or the like. The output device 704 may specifically be a display screen.
The Memory 701 may be a high-speed Random Access Memory (RAM) Memory or a non-volatile Memory (non-volatile Memory), such as a disk Memory. The memory 701 is used for storing a set of executable program code, and the processor 702 is coupled to the memory 701.
Further, the present application also provides a computer-readable storage medium, which may be disposed in the server in the foregoing embodiments, and the computer-readable storage medium may be the memory in the foregoing embodiment shown in fig. 7, or a memory configured in the server. The computer-readable storage medium has stored thereon a computer program which, when executed by a processor, implements the streaming data management method described in the foregoing embodiments shown in fig. 2 and 3. Further, the computer-readable storage medium may be various media that can store program codes, such as a usb disk, a removable hard disk, a Read-Only Memory (ROM), a RAM, a magnetic disk, or an optical disk.
It is noted that, herein, relational terms such as first and second, and the like may be used solely to distinguish one entity or action from another entity or action without necessarily requiring or implying any actual such relationship or order between such entities or actions. Also, the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus. Without further limitation, an element defined by the phrase "comprising an … …" does not exclude the presence of other identical elements in a process, method, article, or apparatus that comprises the element.
Those skilled in the art will appreciate that all or part of the steps for implementing the above embodiments may be implemented by hardware, or may be implemented by a program instructing relevant hardware, and the program may be stored in a computer-readable storage medium, and the above-mentioned storage medium may be a read-only memory, a magnetic disk, an optical disk, or the like.
Although the present application has been described with reference to a preferred embodiment, it should be understood that various changes, substitutions and alterations can be made herein without departing from the spirit and scope of the application, and all changes, substitutions and alterations that fall within the spirit and scope of the application are to be understood as being included within the following description of the preferred embodiment.
Claims (10)
1. A stream data management method is applied to a server, and is characterized by comprising the following steps:
acquiring multimedia multicast stream data according to the multicast address and processing the multimedia multicast stream data into target stream data in a target format;
outputting the processed target stream data to the target address according to the preset corresponding relation between the multicast address and the target address;
monitoring the state of the target stream data according to the target address, and outputting alarm information when the state of the target stream data is abnormal, wherein the alarm information comprises a relevant address, identification information and state description information of the target stream data, the multicast address is a multicast address of a plurality of multimedia multicast stream data multicast by broadcasting and television equipment in a scheduling server, the target address is a target address configured in the scheduling server and corresponding to the multicast address, and a physical matrix is formed between the multicast address and the target address.
2. The method of claim 1, wherein said monitoring the status of said target stream data based on said target address comprises:
calling a Marathon interface, starting a monitoring process on the monitoring server cluster, and acquiring the state information of the target stream data through the monitoring process according to the target address;
analyzing the state information of the target stream data, and judging whether the state of the target stream data is abnormal or not.
3. The method of claim 1, wherein the obtaining multimedia multicast stream data and processing the multimedia multicast stream data into target stream data in a target format according to the multicast address comprises:
calling a Marathon interface, and starting a data processing process in the streaming data processing server cluster;
acquiring the multimedia multicast streaming data according to the multicast address through the data processing process;
according to a preset transcoding rule, carrying out transcoding and de-interlacing processing on the acquired multimedia multicast stream data to obtain stream data with target definition and target code rate, and pushing the stream data to a stream media server connection cluster by using a real-time message transmission protocol;
calling an interface of Marathon to start a stream pulling process, and acquiring the stream data from the stream media server stream receiving cluster by using the real-time message transmission protocol through the stream pulling process;
and processing the stream data into target stream data in the target format.
4. The method according to claim 1, wherein after outputting the processed target stream data to the target address according to a preset correspondence between the multicast address and the target address, the method further comprises:
and sending the target address to a playing system so that the playing system acquires the target stream data from the target address.
5. The method according to any one of claims 1 to 4, wherein before acquiring multimedia multicast stream data according to the multicast address and processing the multimedia multicast stream data into target stream data in a target format, the method comprises:
configuring corresponding target addresses for multimedia multicast stream data of different sources according to configuration instructions sent by a client;
and storing the corresponding relation between the multicast address of the multimedia multicast stream data of each different source and the corresponding target address.
6. A stream data management apparatus, characterized in that the apparatus comprises:
the processing module is used for acquiring multimedia multicast stream data according to the multicast address and processing the acquired multimedia multicast stream data into target stream data in a target format;
the output module is used for outputting the processed target stream data to the target address according to the preset corresponding relation between the multicast address and the target address;
the monitoring module is used for monitoring the state of the target stream data according to the target address;
and the alarm module is used for outputting alarm information when the monitoring module monitors that the state of the target stream data is abnormal, wherein the alarm information comprises a related address, identification information and state description information of the target stream data, the multicast address is a multicast address of a plurality of multimedia multicast stream data multicast by broadcasting and television equipment in a scheduling server, the target address is a target address configured in the scheduling server and corresponding to the multicast address, and a physical matrix is formed between the multicast address and the target address.
7. The apparatus of claim 6,
the monitoring module is specifically configured to invoke a Marathon interface, start a monitoring process at the monitoring server cluster, acquire state information of the target stream data according to the target address through the monitoring process, analyze the state information of the target stream data, and determine whether the state of the target stream data is abnormal.
8. The apparatus of claim 6, wherein the processing module comprises:
the transcoding module is used for calling a Marathon interface, starting a data processing process on the streaming data processing server cluster, acquiring the multimedia multicast streaming data according to the multicast address through the data processing process, transcoding and deinterlacing the acquired multimedia multicast streaming data according to a preset transcoding rule to obtain streaming data with target definition and target code rate, and pushing the streaming data to the streaming media server receiving cluster by using a real-time message transmission protocol;
and the format conversion module is used for calling an interface of Marathon to start a pull flow process, acquiring the stream data from the stream media server connection cluster by using the real-time message transmission protocol through the pull flow process, and processing the stream data into target stream data in the target format.
9. The apparatus of claim 6, wherein the apparatus further comprises:
the sending module is used for sending the target address to a playing system so that the playing system obtains the target stream data from the target address;
and the configuration module is used for configuring corresponding target addresses for the multimedia multicast stream data of different sources according to the configuration instruction sent by the client, and storing the corresponding relation between the multicast addresses of the multimedia multicast stream data of different sources and the corresponding target addresses.
10. A computer-readable storage medium on which a computer program is stored, the computer program, when executed by a processor, implementing a stream data management method according to any one of claims 1 to 5.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201810433121.3A CN108540820B (en) | 2018-05-08 | 2018-05-08 | Stream data management method, device and computer readable storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201810433121.3A CN108540820B (en) | 2018-05-08 | 2018-05-08 | Stream data management method, device and computer readable storage medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN108540820A CN108540820A (en) | 2018-09-14 |
| CN108540820B true CN108540820B (en) | 2020-09-15 |
Family
ID=63476592
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201810433121.3A Active CN108540820B (en) | 2018-05-08 | 2018-05-08 | Stream data management method, device and computer readable storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN108540820B (en) |
Families Citing this family (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110769268A (en) * | 2019-11-07 | 2020-02-07 | 网易（杭州）网络有限公司 | Data flow monitoring method and device |
Citations (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1905499A (en) * | 2006-08-11 | 2007-01-31 | 杭州华为三康技术有限公司 | Method and system for transmitting streaming media via network and converter |
| CN1933480A (en) * | 2005-09-13 | 2007-03-21 | 李晓耕 | Method for multimedia data switching gateway |
| CN101193289A (en) * | 2006-11-22 | 2008-06-04 | 中兴通讯股份有限公司 | A real time conversion method from MPEG-4 transmission code stream to Internet stream media alliance stream |
| CN202014343U (en) * | 2011-04-22 | 2011-10-19 | 赛特斯网络科技(南京)有限责任公司 | Video stream analyzer used for network system |
| CN103281560A (en) * | 2013-06-08 | 2013-09-04 | 无锡北斗星通信息科技有限公司 | Satellite digital television program broadcast quality detecting system |
| CN103312599A (en) * | 2013-05-09 | 2013-09-18 | 李冰 | Multi-network routing gateway system |
| CN104661044A (en) * | 2015-02-14 | 2015-05-27 | 广州珠江数码集团有限公司 | Broadcasting and TV OTT (over the top) integration terminal and implementing method thereof |
| EP2282475B1 (en) * | 2009-08-04 | 2018-02-07 | Orange | Method and device for restoring multimedia content |
-
2018
- 2018-05-08 CN CN201810433121.3A patent/CN108540820B/en active Active
Patent Citations (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1933480A (en) * | 2005-09-13 | 2007-03-21 | 李晓耕 | Method for multimedia data switching gateway |
| CN1905499A (en) * | 2006-08-11 | 2007-01-31 | 杭州华为三康技术有限公司 | Method and system for transmitting streaming media via network and converter |
| CN101193289A (en) * | 2006-11-22 | 2008-06-04 | 中兴通讯股份有限公司 | A real time conversion method from MPEG-4 transmission code stream to Internet stream media alliance stream |
| EP2282475B1 (en) * | 2009-08-04 | 2018-02-07 | Orange | Method and device for restoring multimedia content |
| CN202014343U (en) * | 2011-04-22 | 2011-10-19 | 赛特斯网络科技(南京)有限责任公司 | Video stream analyzer used for network system |
| CN103312599A (en) * | 2013-05-09 | 2013-09-18 | 李冰 | Multi-network routing gateway system |
| CN103281560A (en) * | 2013-06-08 | 2013-09-04 | 无锡北斗星通信息科技有限公司 | Satellite digital television program broadcast quality detecting system |
| CN104661044A (en) * | 2015-02-14 | 2015-05-27 | 广州珠江数码集团有限公司 | Broadcasting and TV OTT (over the top) integration terminal and implementing method thereof |
Also Published As
| Publication number | Publication date |
|---|---|
| CN108540820A (en) | 2018-09-14 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US20240275859A1 (en) | Delivering Notification Information | |
| CN101159830B (en) | Apparatus for receiving adaptive broadcast signal and method thereof | |
| US8832750B2 (en) | Media synchronization within home network using set-top box as gateway | |
| CN102263959B (en) | Direct broadcast transfer method and system | |
| CN111010614A (en) | Method, device, server and medium for displaying live caption | |
| CN101889425B (en) | Apparatus and method for simulcast over variable bandwidth channel | |
| CN101371570B (en) | A method and apparatus for providing a picture in picture service | |
| CN106941629B (en) | Real-time live broadcast method based on SIP + RTP and RTMP protocol intercommunication | |
| CA2722460A1 (en) | Screen sharing and video conferencing system and method | |
| US20110321062A1 (en) | Capturing events from and providing targeted messages to a digital media device | |
| US11792469B2 (en) | Allocation of video recording functionality | |
| CN114040232B (en) | Screen projection system, screen projection method, electronic equipment and storage medium | |
| CN103931203A (en) | Terminal device, server device, information processing method, program, and collaborative application supply system | |
| US20150074242A1 (en) | Transmitting apparatus, transmitting method, receiving apparatus, receiving method, program, and content distribution system | |
| US11395050B2 (en) | Receiving apparatus, transmitting apparatus, and data processing method | |
| Kano et al. | Data Compression Analysis of Multimedia Video on Demand and DEMAND TV Broadcast Systems on the Network | |
| CN108540820B (en) | Stream data management method, device and computer readable storage medium | |
| CN112822435A (en) | Security method, device and system allowing user to easily access | |
| EP3951597A1 (en) | Video content processing systems and methods | |
| CN101754024B (en) | Multiplexing device and multiplexing method | |
| CN113347138B (en) | Transmission method, device, computer equipment and storage medium for transcoding data stream | |
| CN112995766B (en) | Method and device for identifying IPTV multi-channel video stream | |
| CN111193941B (en) | Method, device and equipment for transmitting media data and storage medium | |
| KR20090122883A (en) | Simplified transmission method for a stream of signals between a transmitter and an electornic device | |
| KR100748273B1 (en) | Method and Device for providing broadcasting service according to broadcasting organization by user |
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 |