WO2017219912A1 - Node control method and apparatus in distributed iptv system - Google Patents

Abstract

Disclosed are a node control method and apparatus in a distributed IPTV system. The method comprises: receiving an incremental file of each node in an IPTV system, which is sent by each client, the clients being arranged on the first nodes of the IPTV system, and each client being corresponding to one first node; determining a faulty first node among the multiple first nodes according to the received incremental files; and processing the faulty first node, so that the faulty first node returns to normal.

Description

Node control method and device in distributed network television IPTV system Technical field

The present application relates to, but is not limited to, the field of network television systems, and more particularly to a method and apparatus for controlling nodes in a distributed network television IPTV system.

Background technique

With the increase of users in the Internet Protocol Television (IPTV) system and the increase of the load, many modules adopt a distributed architecture. The statistical analysis of the actual data on the site often generates report data through the respective module nodes. The report data is uploaded to the statistics server for statistical analysis.

If an abnormality occurs on a node, you need to log in to the corresponding node to perform log analysis and troubleshoot the problem. However, as this method grows with the number of nodes, the analysis and location of abnormal problems are very cumbersome, and it is often necessary to switch back and forth between multiple nodes, which is inefficient.

Among them, different modules of IPTV often need to be deployed in different network environments. For this different network plane architecture, the control analysis requirements for each node are higher. In the current context, there are some similar function log collection tools, but the function is single, not flexible enough, and it is not supported for multiple network planes.

In summary, the current handling of abnormal nodes in the IPTV system is very cumbersome and inefficient.

Summary of invention

The following is an overview of the topics detailed in this document. This Summary is not intended to limit the scope of the claims.

The embodiment of the invention provides a method and a device for controlling a node in a distributed network television IPTV system, which can quickly process an abnormal node in the IPTV system and restore it to a normal state.

An embodiment of the present invention provides a method for controlling a node in a distributed network television IPTV system, which is applied to a server. The method includes:

Receiving, by each client, an incremental file of each first node in the IPTV system; wherein the client is disposed on the first node in the IPTV system, and each client corresponds to a first node;

Determining, according to the received delta file, a first node that has an abnormality in the plurality of first nodes;

The first node that has an abnormality is processed, so that the first node that has an abnormality returns to normal.

In an embodiment, the step of receiving an incremental file of each first node in the IPTV system sent by each client includes:

If the first node can directly communicate with the server, directly receiving the delta file of the first node sent by the client on the first node;

And if the first node is incapable of directly communicating with the server, receiving, by the second node, the incremental file of the first node transparently transmitted by the second node; wherein the second node is the first one of the IPTV system The first node in the node except the first node where the client is located, and can directly communicate with the server and the client, the second node and the first node are located in different network planes.

In an embodiment, the step of determining, according to the received delta file, the first node that has an abnormality in the plurality of first nodes includes:

Comparing the received delta file of each first node with the pre-stored delta file of each first node;

If the received delta file of the first node is different from the pre-stored delta file, it is determined that the first node is the first node that has an abnormality.

In an embodiment, the step of processing the first node in which the abnormality occurs includes:

Displaying, on the management interface of the server, information indicating that the first node having an abnormality has an abnormality;

Receiving a file query instruction input on the management interface, and sending the file query instruction to the client on the first node where the abnormality occurs, so that the client on the first node where the abnormality occurs obtains the first abnormality according to the file query instruction The file to be analyzed of the node;

Receiving a file to be analyzed sent by a client on the first node where the abnormality occurs, and displaying the file to be analyzed;

Receiving a processing instruction input on the management interface, and sending the processing instruction to the client on the first node where the abnormality occurs, so that the client on the first node where the abnormality occurs processes the first node that is abnormal according to the processing instruction .

In an embodiment, the step of sending a file query instruction to a client on the first node where the exception occurs includes:

If the first node in which the abnormality can directly communicate with the server, the file query instruction is directly sent to the client on the first node where the abnormality occurs;

If the first node in which the abnormality cannot communicate directly with the server, the file query command is transparently transmitted to the client on the first node where the abnormality occurs through the second node.

In an embodiment, the step of receiving a file to be analyzed sent by a client on a first node that has an abnormality includes:

If the first node that is abnormal can directly communicate with the server, directly receiving the file to be analyzed sent by the client on the first node where the abnormality occurs;

If the first node that is abnormal cannot directly communicate with the server, the client on the first node that has an abnormality receives the file to be analyzed transparently transmitted by the second node.

In an embodiment, the step of transmitting the processing instruction to the client on the first node where the exception occurs includes:

If the first node in which the abnormality can directly communicate with the server, the processing instruction is directly sent to the client on the first node where the abnormality occurs;

If the first node that has an abnormality cannot directly communicate with the server, the processing instruction is transparently transmitted to the client on the first node where the abnormality occurs through the second node.

In an embodiment, before the step of receiving the delta file of each first node in the IPTV system sent by each client, the method further includes:

Receiving registration information sent by each client, returning registration response information to the client, and performing keep-alive processing according to the heartbeat message sent by the client.

In an embodiment, the step of receiving the registration information sent by each client, returning the registration response information to the client, and performing the keep-alive processing according to the heartbeat message sent by the client includes:

If the first node can directly communicate with the server, directly receiving the registration information sent by the client on the first node, directly returning the registration response information to the client on the first node, and according to the client on the first node The heartbeat message sent directly is kept in a keep-alive process;

If the first node cannot directly communicate with the server, receiving the registration information transparently transmitted by the client on the first node through the second node, and transparently transmitting the registration response information to the client on the first node through the second node, and The keep-alive process is performed according to the heartbeat message transparently transmitted by the client on the first node through the second node.

The embodiment of the present invention further provides a control device for a node in a distributed network television IPTV system, which is applied to a server, and the device includes:

a first receiving module, configured to receive an incremental file of each first node in the IPTV system sent by each client; wherein the client is disposed on the first node in the IPTV system, and each client corresponds to a first One node

Determining a module, configured to determine, according to the received delta file, a first node that has an abnormality in the plurality of first nodes;

The processing module is configured to process the first node that has an abnormality, so that the first node that has an abnormality returns to normal.

Embodiments of the present invention also provide a server, including the control device of a node in the distributed network television IPTV system described above.

An embodiment of the present invention further provides a method for controlling a node in a distributed network television IPTV system, which is applied to a client, and the method includes:

Obtaining an incremental file of the first node in the IPTV system, where the client is set on the first node;

Send the obtained delta file to the server.

In an embodiment, the step of acquiring the delta file of the first node in the IPTV system includes:

According to the scheduled task and the filtering condition in the preset configuration file, multiple incremental files in the first node are filtered to obtain an incremental file that satisfies the filtering condition.

In an embodiment, the step of sending the obtained delta file to the server includes:

If the first node can directly communicate with the server, the obtained incremental file is directly sent to the server;

If the first node cannot directly communicate with the server, the incremental file obtained by the second node is transparently transmitted to the server, and the second node is the first node of the plurality of first nodes in the IPTV system except the client. A first node that is external to, and can communicate directly with the server and the client, the second node is located at a different network plane than the first node.

In an embodiment, the method further includes:

Receiving a file query instruction sent by the server;

Obtaining a file to be analyzed from the first node according to the file query instruction, and sending the file to be analyzed to the server;

Receiving a processing instruction sent by the server, and processing the first node according to the processing instruction.

In an embodiment, the step of receiving a file query instruction sent by the server includes:

If the first node can directly communicate with the server, directly receiving a file query instruction sent by the server;

If the first node cannot directly communicate with the server, the receiving server queries the file through the second node for transparent transmission.

In an embodiment, the step of sending the file to be analyzed to the server includes:

If the first node can directly communicate with the server, the file to be analyzed is directly sent to the server;

If the first node cannot directly communicate with the server, the file to be analyzed is sent to the server through the second node.

In an embodiment, the step of receiving a processing instruction sent by the server includes:

If the first node can directly communicate with the server, directly receiving the processing instruction sent by the server;

If the first node cannot directly communicate with the server, the receiving server transmits a processing instruction transparently transmitted by the second node.

In an embodiment, the step of acquiring the delta file of the first node in the IPTV system Before, the method also includes:

Sending registration information to the server, receiving registration response information returned by the server, and sending a heartbeat message to the server.

In an embodiment, the step of sending the registration information to the server, receiving the registration response information returned by the server, and sending the heartbeat message to the server includes:

If the first node can directly communicate with the server, the registration information is directly sent to the server, the registration response information returned by the server is directly received, and the heartbeat message is directly sent to the server;

If the first node cannot directly communicate with the server, the second node sends the registration information to the server, receives the registration response information transparently transmitted by the server through the second node, and sends a heartbeat message to the server through the second node.

The embodiment of the present invention further provides a control device for a node in a distributed network television IPTV system, which is applied to a client, and the device includes:

Obtaining a module, configured to obtain an incremental file of the first node in the IPTV system, where the client is set on the first node;

The first sending module is configured to send the obtained delta file to the server.

Embodiments of the present invention also provide a client, including the control device of a node in the distributed network television IPTV system described above.

Embodiments of the present invention also provide a computer readable storage medium storing computer executable instructions that, when executed by a processor, implement a method of controlling a node in the distributed network television IPTV system.

The above aspects of the present invention include at least the following beneficial effects:

In an embodiment of the present invention, a first node in which an abnormality occurs in an IPTV system is determined according to an incremental file of each first node in the received IPTV system, and a first node in which an abnormality occurs is processed. It returns to normal, and it can quickly process the abnormal nodes in the IPTV system, restore the normal effect, simplify the processing flow, and improve the processing efficiency.

Other aspects will be apparent upon reading and understanding the drawings and detailed description.

BRIEF abstract

1 is a flowchart of a method for controlling a node in a distributed network television IPTV system according to a first embodiment of the present invention;

2 is a schematic structural diagram of a node control apparatus in a distributed network television IPTV system according to a second embodiment of the present invention;

3 is a flowchart of a method for controlling a node in a distributed network television IPTV system according to a fourth embodiment of the present invention;

4 is a schematic diagram of an interaction process between a client and a server in a fourth embodiment of the present invention;

5 is a schematic diagram of a process of interaction between a client and a server on an EPG node according to a fourth embodiment of the present invention;

6 is a schematic structural diagram of a node control apparatus in a distributed network television IPTV system according to a fifth embodiment of the present invention;

FIG. 7 is a schematic structural diagram of a control system of a node in a distributed network television IPTV system according to a seventh embodiment of the present invention.

Detailed

Exemplary embodiments of the present disclosure will be described in more detail below with reference to the accompanying drawings. While the embodiments of the present invention have been shown in the drawings, the embodiments Rather, these embodiments are provided so that this disclosure will be more fully understood and the scope of the disclosure will be fully disclosed.

First embodiment

As shown in FIG. 1 , a first embodiment of the present invention provides a method for controlling a node in a distributed network television IPTV system, which is applied to a server. The method includes:

Step 101: Receive an incremental file of each first node in the IPTV system sent by each client.

In an embodiment, the client is disposed on the first node in the IPTV system, and each client corresponds to a first node, that is, each client of the IPTV system is provided with a client. In addition, the above delta file can be a log. It will be appreciated that in the embodiments of the present invention, the form of the delta file is not limited.

In the first embodiment of the present invention, in order to ensure communication between the server and each client, before performing the above step 101, the method further includes: receiving registration information sent by each client to the client. The terminal returns registration response information, and performs a step of keep-alive processing according to the heartbeat message sent by the client. In order to ensure communication between the client and the server, the client can periodically send a heartbeat message to the server to enable the server to perform keep-alive processing.

In the first embodiment of the present invention, after receiving the delta file sent by each client, the server performs classification and collection processing on the delta files (for example, classification according to the first node identifier, etc.), And the index is established, so that when the user needs it, the incremental file corresponding to the keyword can be quickly queried by inputting a keyword in the management interface of the server.

Step 102: Determine, according to the received delta file, a first node that has an abnormality in the plurality of first nodes.

In the first embodiment of the present invention, the first occurrence of the abnormality may be determined by comparing the received delta file of each first node with the delta file of each first node stored in advance. node. If the incremental file of the received first node is different from the pre-stored incremental file, it is determined that the first node is the first node that has an abnormality.

Step 103: Process the first node that has an abnormality, so that the first node that has an abnormality returns to normal.

In a first embodiment of the invention, step 103 comprises the steps of:

In the first step, information indicating that the first node having an abnormality has an abnormality is displayed on the management interface of the server.

The second step is: receiving a file query instruction input on the management interface, and sending the file query instruction to the client on the first node where the abnormality occurs, so that the client on the first node where the abnormality occurs is obtained according to the file query instruction. The file to be analyzed of the abnormal first node.

In the first embodiment of the present invention, when the user finds the above-mentioned first for prompting an abnormality When there is abnormal information in the node, in order to quickly and accurately find out the problem of the first node where the abnormality occurs, more detailed files of the first node where the abnormality occurs may be further obtained (that is, the above-mentioned file to be analyzed, for example, a certain program) , configuration files, etc.). The user can obtain the file to be analyzed of the first node that has an abnormality by inputting a file query instruction on the management interface. The file query instruction is used to indicate that the file to be analyzed is obtained. It should be noted that, since the server communicates with multiple clients, in order to facilitate the user to quickly input a file query instruction to the client of the first node that has an abnormality on the management interface, all the services may be obtained from the server first. A list of clients, and then selects the client input file query instruction of the first node where the exception occurs.

In the third step, the file to be analyzed sent by the client on the first node where the abnormality occurs is received, and the file to be analyzed is displayed. Therefore, the user can accurately detect the problem of the first node that is abnormal according to the file to be analyzed, and facilitate subsequent operations.

The fourth step is to receive a processing instruction input on the management interface, and send the processing instruction to the client on the first node where the abnormality occurs, so that the client on the first node where the abnormality occurs is in accordance with the processing instruction A node performs processing.

In the first embodiment of the present invention, when the user sorts out the problem of the first node where the abnormality occurs, the first node that is abnormal may be processed simply and quickly by inputting the processing instruction on the management interface. Make it back to normal. The content of the processing instruction may be a deletion or modification of a certain program of the first node, an item in a configuration file, etc., by the client on the first node indicating that the abnormality occurs.

When there is no first node in the IPTV system where the abnormality occurs, but only the user wants to solve the performance of the first node, the performance data of the first node can be obtained by obtaining the file to be analyzed, and then understanding The operating state of the first node.

In the first embodiment of the present invention, since the network plane of each first node in the IPTV system may be different, there may be a first node that can directly communicate with the server, and there may be a direct connection with the service. The first node that communicates with the end, and the server supports configuration and listening of multiple network planes. Based on this, the foregoing step 101 is implemented as follows: if the first node can directly communicate with the server, the first node can directly receive the incremental file of the first node sent by the client on the first node; Communicate directly with the server, then connect And receiving, by the client on the first node, the incremental file of the first node transparently transmitted by the second node. The second node is the first one of the plurality of first nodes in the IPTV system except the first node where the client is located, and can directly communicate with the server and the client (the client refers to the client that sends the incremental file) A node, and the second node is located at a different network plane than the first node (the first node is the first node where the client sending the delta file is located).

Similarly, the receiving the registration information sent by each client, returning the registration response information to the client, and performing the keep-alive processing according to the heartbeat message sent by the client is: if the first node can directly When the server communicates, it directly receives the registration information sent by the client on the first node, directly returns the registration response information to the client on the first node, and protects according to the heartbeat message directly sent by the client on the first node. If the first node cannot directly communicate with the server, the client on the first node receives the registration information transparently transmitted by the second node, and transparently registers with the client on the first node through the second node. Responding to the information, and performing keep-alive processing according to the heartbeat message transparently transmitted by the client on the first node through the second node.

Similarly, the method for sending the file query instruction to the client on the first node where the abnormality occurs in the second step of step 103 is as follows: if the first node having the abnormality can communicate directly with the server, The file query instruction is sent to the client on the first node where the exception occurs; and if the first node in which the abnormality cannot directly communicate with the server, the file query command is transparently transmitted to the first node where the abnormality occurs through the second node. On the client.

Similarly, in the third step of step 103, the implementation of the to-be-analyzed file sent by the client on the first node that receives the abnormality is: if the first node that is abnormal can communicate directly with the server, Receiving the file to be analyzed sent by the client on the first node where the abnormality occurs; and if the first node having the abnormality cannot directly communicate with the server, receiving the client on the first node that has the abnormality through the second node The document to be analyzed.

Similarly, in the fourth step of step 103, the processing instruction is sent to the client on the first node where the exception occurs: if the first node that has an abnormality can directly communicate with the server, the processing will be directly processed. The instruction is sent to the client on the first node where the exception occurs; and if the first node in which the exception occurs cannot directly communicate with the server, the processing command is transparently transmitted to the client on the first node where the abnormality occurs through the second node. end.

In the first embodiment of the present invention, information of interaction between the server and each client (example) Such as incremental files, file query instructions, files to be analyzed, processing instructions, etc. can be transmitted by means of File Transfer Protocol (FTP) or message communication. In order to improve security performance, the sent message may be encrypted according to actual needs. For example, the server sends an encrypted message to the client, so that after receiving the encrypted message, the client controls the user authority according to the message. To proceed to the next step. If the user right is the administrator authority, the user rights controlled by the message may be: filtering and obtaining related information from a file in a certain location, modifying a configuration item of a configuration file, and viewing attribute information of a file. Execute a command, query the response result, view the performance data of the client machine, and execute a script.

Transmitting information (such as processing instructions, etc.) to the client on the first node by using the second node, and the client on the first node transparently transmitting information to the server through the second node (for example, the file to be analyzed) In other words, in fact, the server transmits information to the client on the first node through the client on the second node. Similarly, the client on the first node also passes through the client on the second node. Transparently transmit information to the server.

It can be seen that, in the first embodiment of the present invention, the first node in which an abnormality occurs in the IPTV system is determined according to the incremental file of each first node in the received IPTV system, and the first node in which the abnormality occurs The processing is performed to restore the normal operation, and the abnormal node in the IPTV system is processed in time and quickly, so that the normal effect is restored, the processing flow is simplified, and the processing efficiency is improved. In addition, the process of handling exceptions can be visually presented to the user, thereby improving the user experience.

Second embodiment

As shown in FIG. 2, a second embodiment of the present invention provides a control device for a node in a distributed network television IPTV system, which is applied to a server. The device includes:

The first receiving module 201 is configured to receive an incremental file of each first node in the IPTV system sent by each client, where the client is disposed on the first node in the IPTV system, and each client corresponds to one First node;

The determining module 202 is configured to determine, according to the received delta file, a first node that has an abnormality in the plurality of first nodes;

The processing module 203 is configured to process the first node that has an abnormality, so that the first node that has an abnormality returns to normal.

The first receiving module 201 includes:

The first receiving unit is configured to directly receive the delta file of the first node sent by the client on the first node if the first node can directly communicate with the server;

a second receiving unit, configured to: if the first node cannot directly communicate with the server, receive a delta file of the first node transparently transmitted by the client on the first node by using the second node; wherein, the second node is A first node of the plurality of first nodes in the IPTV system except the first node where the client is located, and capable of directly communicating with the server and the client, where the second node and the first node are located in different network planes.

The determining module 202 includes:

a comparison unit, configured to compare the received delta file of each first node with a pre-stored delta file of each first node;

The determining unit is configured to: if the received delta file of the first node is different from the pre-stored delta file, determine that the first node is the first node that has an abnormality.

The processing module 203 includes:

a display unit configured to display, on the management interface of the server, information indicating that the first node having an abnormality has an abnormality;

The third receiving unit is configured to receive the file query instruction input on the management interface, and send the file query instruction to the client on the first node where the abnormality occurs, so that the client on the first node where the abnormality occurs is based on the file query The instruction acquires a file to be analyzed of the first node that has an abnormality;

a fourth receiving unit, configured to receive the to-be-analyzed file sent by the client on the first node where the abnormality occurs, and display the file to be analyzed;

a fifth receiving unit, configured to receive a processing instruction input on the management interface, and send the processing instruction to the client on the first node where the abnormality occurs, so that the client on the first node where the abnormality occurs appears according to the processing instruction The first node of the exception is processed.

The third receiving unit includes:

The first processing sub-unit is configured to directly send the file query instruction to the client on the first node where the abnormality occurs if the first node that is abnormal can directly communicate with the server;

The second processing sub-unit is configured to transparently transmit the file query instruction to the client on the first node where the abnormality occurs by the second node if the first node that is abnormal cannot directly communicate with the server.

The fourth receiving unit includes:

The third processing sub-unit is configured to directly receive the to-be-analyzed file sent by the client on the first node where the abnormality occurs if the first node that is abnormal can directly communicate with the server;

The fourth processing sub-unit is configured to: if the first node that is abnormal cannot directly communicate with the server, receive the to-be-analyzed file transparently transmitted by the client on the first node that has an abnormality through the second node.

The fifth receiving unit includes:

The fifth processing sub-unit is configured to directly send the processing instruction to the client on the first node where the abnormality occurs if the first node in which the abnormality can directly communicate with the server;

The sixth processing subunit is configured to: if the first node in which the abnormality occurs cannot directly communicate with the server, the processing instruction is transparently transmitted to the client on the first node where the abnormality occurs through the second node.

Wherein, the device further comprises:

The second receiving module is configured to receive registration information sent by each client, return registration response information to the client, and perform keep-alive processing according to the heartbeat message sent by the client.

The second receiving module includes:

The sixth receiving unit is configured to: if the first node can directly communicate with the server, directly receive the registration information sent by the client on the first node, and directly return the registration response information to the client on the first node, and according to The heartbeat message sent directly by the client on the first node is keep-alived;

The seventh receiving unit is configured to: if the first node cannot directly communicate with the server, receive the registration information transparently transmitted by the client on the first node through the second node, and reach the client on the first node through the second node. Transparently pass the registration response message and pass the first client according to the first node The heartbeat message transparently transmitted by the two nodes is subjected to keep-alive processing.

In the second embodiment of the present invention, the first node in which an abnormality occurs in the IPTV system is determined according to the delta file of each first node in the received IPTV system, and the first node in which the abnormality occurs is processed. To restore it to normal, to achieve timely and rapid processing of abnormal nodes in the IPTV system, to restore normal results, simplify the processing flow, improve processing efficiency.

It should be noted that the control device of the node in the distributed network television IPTV system provided by the second embodiment of the present invention is a device that applies the above-mentioned control method of a node in a distributed network television IPTV system applied to a server, that is, the foregoing application to the service All embodiments of the control method of the nodes in the distributed network television IPTV system are applicable to the device, and both can achieve the same or similar beneficial effects.

Third embodiment

A third embodiment of the present invention provides a server, including the above-mentioned control device for a node in a distributed network television IPTV system applied to a server.

It should be noted that the server provided by the third embodiment of the present invention is a server that includes the foregoing control device of a node in a distributed network television IPTV system applied to a server, that is, the distributed network television IPTV system applied to the server. All embodiments of the node's control device are applicable to the server and both achieve the same or similar benefits.

Fourth embodiment

As shown in FIG. 3, a fourth embodiment of the present invention provides a method for controlling a node in a distributed network television IPTV system, which is applied to a client, and the method includes:

Step 301: Acquire an incremental file of the first node in the IPTV system.

The client is set on the first node.

In the fourth embodiment of the present invention, multiple incremental files in the first node may be filtered according to the timing task and the filtering condition in the configuration file preset in the first node, to obtain an increment that satisfies the filtering condition. file. The above configuration file may be set by an engineer according to experience, and the timed task refers to obtaining an incremental file satisfying the filtering condition every time period.

In the fourth embodiment of the present invention, in order to ensure communication between the server and the client, Before the step 301, the method further includes: sending the registration information to the server, receiving the registration response information returned by the server, and sending a heartbeat message to the server, so that the server performs the step of keeping alive.

Step 302: Send the obtained delta file to the server.

In the fourth embodiment of the present invention, if the first node is the first node where the abnormality occurs, the method further includes the following steps:

The first step is to receive a file query instruction sent by the server.

The file query instruction is used to indicate that the file to be analyzed is obtained.

In the second step, according to the file query instruction, the file to be analyzed is obtained from the first node, and the file to be analyzed is sent to the server.

In the third step, the processing instruction sent by the server is received, and the first node is processed according to the processing instruction.

The content of the processing instruction may be a deletion or modification of a certain program of the first node, an item in a configuration file, etc., by the client on the first node indicating that the abnormality occurs.

In the fourth embodiment of the present invention, since the network plane of each first node in the IPTV system may be different, there may be a first node that can directly communicate with the server, and there may be a direct connection with the server. The first node to communicate. Based on this, the implementation of the foregoing step 302 includes: if the first node can directly communicate with the server, the obtained incremental file is directly sent to the server; and if the first node cannot directly communicate with the server, Then, the obtained incremental file is transparently transmitted to the server through the second node. The second node is a first node of the plurality of first nodes in the IPTV system except the first node where the client is located, and can directly communicate with the server and the client, where the second node and the first node are located in different networks. flat.

Similarly, the file query instruction sent by the receiving server is implemented as follows: if the first node can directly communicate with the server, the file query instruction sent by the server is directly received; and if the first node cannot directly communicate with the server When the communication is performed, the file query instruction transparently transmitted by the server through the second node is received.

Similarly, the foregoing implementation manner of sending the file to be analyzed to the server is: if the first node can directly communicate with the server, the file to be analyzed is directly sent to the server; The node cannot directly communicate with the server, and the file to be analyzed is sent to the server through the second node.

Similarly, the processing instruction sent by the receiving server is implemented as follows: if the first node can directly communicate with the server, directly receiving the processing instruction sent by the server; and if the first node cannot directly communicate with the server And receiving a processing instruction transparently transmitted by the server through the second node.

Similarly, the foregoing sending the registration information to the server, receiving the registration response information returned by the server, and sending the heartbeat message to the server is implemented as follows: if the first node can directly communicate with the server, the device directly sends the message to the server. The registration information directly receives the registration response information returned by the server, and directly sends a heartbeat message to the server. If the first node cannot directly communicate with the server, the second node sends the registration information to the server, and receives the server. The registration response information transparently transmitted by the second node, and the heartbeat message is sent to the server through the second node.

In the fourth embodiment of the present invention, the obtained incremental file of the first node is sent to the server, so that the server can determine that the IPTV system appears according to the incremental file received by each first node. The abnormal first node processes the first node that has an abnormality, and restores it to normal. It solves the problem that the processing of the abnormal node in the IPTV system is very cumbersome and inefficient, and the fast processing of the IPTV system occurs. An abnormal node to restore normal effects.

In the fourth embodiment of the present invention, the foregoing method is further illustrated by taking an interaction process between a client and a server on a first node that can directly communicate with the server. The server can be located at the central node of the IPTV system. As shown in FIG. 4, the interaction process between the client and the server is:

Step 401: The client sends a registration message to the server.

Step 402: The server returns registration response information to the client.

Step 403: After receiving the registration response information, the client sends a heartbeat message to the server.

Step 404: The server returns a heartbeat keep-alive response to the client to perform a keep-alive process.

Step 405: The client starts a timing task.

Step 406: The client sends the obtained incremental file to the server.

Step 407, if the server finds that the first node is abnormal according to the received delta file, step 408 is performed;

Step 408: The server displays, on the management interface, information indicating that the first node that has an abnormality has an abnormality;

Step 409: The server receives a file query instruction input by the user from the management interface.

Step 410: The server sends a file query instruction to the client.

Step 411: The client obtains the file to be analyzed according to the file query instruction.

Step 412: The client sends the file to be analyzed to the server.

Step 413: After receiving the file to be analyzed, the server displays the file to be analyzed.

Step 414: The server receives a processing instruction input by the user on the management interface.

Step 415, the server sends the processing instruction to the client.

In step 416, the client processes the first node to restore the normal state.

Further, in the fourth embodiment of the present invention, the above method is further explained by an example. It is assumed that the IPTV system includes an electronic program guide (EPG) module, a content data management (CP) module, and a chip library, wherein the node of the network architecture is an EPG module is located in an independent network plane, and the library is in a separate network plane, the CP module All nodes are located in a separate network plane, and the server is located at a central node. It can communicate with the network plane of the CP module and the network plane where the library is located. However, the network plane of the EPG module cannot communicate with the network plane of the EPG module. In communication with the library, according to the network architecture, the client on each node is configured, and the communication server configuration item in the client on the node of the EPG module is set to the address of the library, and after the configuration is completed, the operation is started. Here, the interaction process between the client and the server on an EPG node in the EPG module is taken as an example. As shown in Figure 5, the interaction process between the client and the server on the node is:

Step 501: The client sends a registration message to the server through the client on the library.

Step 502: The server returns registration response information to the client through the library.

Step 503: After receiving the registration response information, the client sends a heartbeat message to the server through the client on the library.

Step 504, the server returns a heartbeat keep-alive response to the client through the client on the library, Keep alive;

Step 505, the client starts a timing task.

Step 506: The client obtains the incremental file, and sends the obtained incremental file to the server through the client on the library.

In step 507, the server processes the received delta file, and finds that the node is abnormal. The abnormal problem is that the user cannot browse a template on the node.

Step 508: Log in to the management interface of the server, and obtain all client lists from the server.

In step 509, the server returns all client lists.

Step 510: Find the client of the EPG node that has an abnormality, first analyze the incremental file (such as a log) that has been uploaded by the node, and after analyzing, find that the EPG of the node fails to obtain the template from the library, and the download is not performed. If you need to obtain the log information about the template on the EPG node, you need to check the related configuration file and whether the port listening of the download client is normal. You can use the client to transparently pass the file query command on the library. The instruction includes obtaining a log instruction of a keyword, obtaining an instruction of the configuration file, and obtaining an instruction of the port listening condition to the abnormal EPG node.

Step 511: The abnormal EPG node acquires a file to be analyzed according to the content of the file query instruction (the file to be analyzed includes corresponding log related information, configuration file information of a certain location, and port listening condition of the download client program);

Step 512: The abnormal EPG node transparently transmits the file to be analyzed to the server through the client on the library, and the server displays the received file to be analyzed.

In step 513, the user finds that a certain configuration item is abnormal according to the file to be analyzed, and causes the network communication to be abnormal. The client on the library sends a processing instruction for modifying the configuration item to the client on the EPG node.

Step 514: After receiving the processing instruction, the client on the EPG node re-applies the configuration to make the EPG node operate normally, and the template information is normally downloaded from the library.

It should be noted that, in this example, when the user finds that an EPG node is abnormal, in order to avoid similar problems on other EPG nodes, the user may input a file for obtaining configuration files of all EPG nodes by using the server management interface. Query instructions to make guests on each EPG node The client reports the configuration file of the EPG node through the client on the library, so that the user can check whether the EPG nodes have similar problems. If any, the EPG node with similar problems is processed to eliminate the abnormality.

Fifth embodiment

As shown in FIG. 6, a fifth embodiment of the present invention provides a control device for a node in a distributed network television IPTV system, which is applied to a client, and the device includes:

The obtaining module 601 is configured to obtain an incremental file of the first node in the IPTV system, where the client is set on the first node;

The first sending module 602 is configured to send the obtained delta file to the server.

The obtaining module 601 includes:

The obtaining unit is configured to filter, according to the scheduled task and the filtering condition in the preset configuration file, multiple incremental files in the first node to obtain an incremental file that satisfies the filtering condition.

The first sending module 602 includes:

The first sending unit is configured to directly send the obtained incremental file to the server if the first node can directly communicate with the server;

The second sending unit is configured to: if the first node cannot directly communicate with the server, the incremental file obtained by the second node is transparently transmitted to the server, where the second node is a plurality of first nodes in the IPTV system. The second node is located at a different network plane than the first node except that the first node of the client is located and can directly communicate with the server and the client.

Wherein, the device further comprises:

a third receiving module, configured to receive a file query instruction sent by the server;

The second sending module is configured to: obtain, according to the file query instruction, the file to be analyzed from the first node, and send the file to be analyzed to the server;

The fourth receiving module is configured to receive a processing instruction sent by the server, and process the first node according to the processing instruction.

The third receiving module includes:

The eighth receiving unit is configured to directly directly communicate with the server if the first node can directly communicate with the server Receiving a file query instruction sent by the server;

The ninth receiving unit is configured to: if the first node cannot directly communicate with the server, receive the file query command transparently transmitted by the server through the second node.

The second sending module includes:

The third sending unit is configured to directly send the file to be analyzed to the server if the first node can directly communicate with the server;

The fourth sending unit is configured to: if the first node cannot directly communicate with the server, send the file to be analyzed to the server by using the second node.

The fourth receiving module includes:

a tenth receiving unit, configured to directly receive a processing instruction sent by the server if the first node can directly communicate with the server;

The eleventh receiving unit is configured to receive a processing instruction transparently transmitted by the server through the second node if the first node cannot directly communicate with the server.

Wherein, the device further comprises:

The third sending module is configured to send the registration information to the server, receive the registration response information returned by the server, and send a heartbeat message to the server.

The third sending module includes:

The fifth sending unit is configured to: if the first node can directly communicate with the server, send the registration information directly to the server, directly receive the registration response information returned by the server, and directly send a heartbeat message to the server;

The sixth sending unit is configured to: if the first node cannot directly communicate with the server, send the registration information to the server by using the second node, and receive the registration response information transparently transmitted by the server through the second node, and pass the second node. Send a heartbeat message to the server.

In the fifth embodiment of the present invention, the obtained incremental file of the first node is sent to the server, so that the server can determine that the IPTV system appears according to the incremental file received by each first node. The abnormal first node processes the first node that has an abnormality, so that it returns to normal, and solves the problem that the processing of the abnormal node in the IPTV system is very cumbersome and efficient. The problem of low speed has reached the point of quickly processing the abnormal nodes in the IPTV system and returning them to normal effects.

It should be noted that the control device of the node in the distributed network television IPTV system provided by the fifth embodiment of the present invention is a device that applies the above-mentioned control method of a node in a distributed network television IPTV system applied to a client, that is, the above application to a client All embodiments of the control method of the nodes in the distributed network television IPTV system are applicable to the device, and both can achieve the same or similar beneficial effects.

Sixth embodiment

A sixth embodiment of the present invention provides a client, including the above-mentioned control device for a node in a distributed network television IPTV system applied to a client.

It should be noted that the client provided by the sixth embodiment of the present invention is a client that includes the foregoing control device for a node in a distributed network television IPTV system applied to a client, that is, the distributed network television IPTV system applied to the client. All embodiments of the node's control device are applicable to the client and both achieve the same or similar benefits.

Seventh embodiment

As shown in FIG. 7, an embodiment of the present invention provides a control system for a node in a distributed network television IPTV system, where the control system includes: the server 701 and a plurality of clients 702. The client 702 is disposed on the first node in the IPTV system, and each client 702 corresponds to a first node. In addition, the number of clients 702 in FIG. 7 is three. It can be understood that in the seventh embodiment of the present invention, the actual number of clients 702 is not limited.

Embodiments of the present invention also provide a computer readable storage medium storing computer executable instructions that, when executed by a processor, implement a node in a distributed network television IPTV system of the first embodiment described above Control Method.

Embodiments of the present invention also provide a computer readable storage medium storing computer executable instructions that, when executed by a processor, implement a node in a distributed network television IPTV system of the fourth embodiment described above Control Method.

The above is an embodiment of the present invention, and it should be noted that those skilled in the art can make several improvements without departing from the principles of the present application. Retouching, these improvements and retouchings should also be considered as protection of this application.

Industrial applicability

In an embodiment of the present invention, a first node in which an abnormality occurs in an IPTV system is determined according to an incremental file of each first node in the received IPTV system, and a first node in which an abnormality occurs is processed. It returns to normal, and it can quickly process the abnormal nodes in the IPTV system, restore the normal effect, simplify the processing flow, and improve the processing efficiency.

Claims (22)

A method for controlling a node in a distributed network television IPTV system is applied to a server, and the method includes: Receiving, by each client, an incremental file of each first node in the IPTV system; wherein the client is disposed on a first node in the IPTV system, and each client corresponds to a first node; Determining, according to the received delta file, a first node that has an abnormality in the plurality of first nodes; The first node that has an abnormality is processed, so that the first node that has an abnormality returns to normal. The method of claim 1, wherein the step of receiving a delta file for each first node in the IPTV system transmitted by each client comprises: And if the first node can directly communicate with the server, directly receiving an incremental file of the first node sent by the client on the first node; Receiving, by the second node, a delta file of the first node transparently transmitted by the client on the first node, where the first node is incapable of directly communicating with the server; wherein the second node a first node of the plurality of first nodes in the IPTV system except the first node where the client is located, and capable of directly communicating with the server and the client, the second node and the first node The nodes are on different network planes. The method of claim 1, wherein the determining, according to the received delta file, the step of determining a first node in the plurality of first nodes that comprises an abnormality comprises: Comparing the received delta file of each first node with the pre-stored delta file of each first node; If the received delta file of the first node is different from the pre-stored delta file, it is determined that the first node is the first node that has an abnormality. The method of claim 2 wherein said step of processing said first node in which an anomaly occurs comprises: Displaying, on the management interface of the server, information indicating that the first node having an abnormality has an abnormality; Receiving a file query instruction input on the management interface, and sending the file query instruction to a client on the first node where the abnormality occurs, so that the client on the first node where the abnormality occurs according to the file query instruction Obtaining a file to be analyzed of the first node in which the abnormality occurs; Receiving the to-be-analyzed file sent by the client on the first node where the abnormality occurs, and displaying the to-be-analyzed file; Receiving a processing instruction input on the management interface, and sending the processing instruction to a client on the first node where the abnormality occurs, so that the client on the first node where the abnormality occurs is abnormal according to the processing instruction The first node is processed. The method of claim 4, wherein the step of transmitting the file query instruction to a client on the first node where the exception occurs comprises: If the first node that is abnormal can directly communicate with the server, the file query instruction is directly sent to the client on the first node where the abnormality occurs; If the first node that is abnormal cannot directly communicate with the server, the file query command is transparently transmitted to the client on the first node where the abnormality occurs through the second node. The method of claim 4, wherein the step of receiving the file to be analyzed sent by the client on the first node where the abnormality occurs comprises: If the first node that is abnormal can directly communicate with the server, directly receiving the to-be-analyzed file sent by the client on the first node where the abnormality occurs; And receiving, by the second node, the to-be-analyzed file transparently transmitted by the client on the first node that has an abnormality, if the first node that is abnormal cannot directly communicate with the server. The method of claim 4 wherein said step of transmitting said processing instruction to a client on a first node where an exception occurs comprises: If the first node that is abnormal can directly communicate with the server, the processing instruction is directly sent to the client on the first node where the abnormality occurs; If the first node that has an abnormality cannot directly communicate with the server, the processing instruction is transparently transmitted by the second node to the client on the first node where the abnormality occurs. The method of claim 2, wherein before the step of receiving the delta file of each of the first nodes in the IPTV system transmitted by each client, the method further comprises: Receiving registration information sent by each client, returning registration response information to the client, and performing keep-alive processing according to the heartbeat message sent by the client. The method of claim 8, wherein the receiving the registration information sent by each client, returning the registration response information to the client, and performing the keep-alive processing according to the heartbeat message sent by the client, include: If the first node can directly communicate with the server, directly receiving the registration information sent by the client on the first node, and directly returning the registration response information to the client on the first node, and Performing a keep-alive process according to the heartbeat message directly sent by the client on the first node; Receiving, by the second node, the registration information that is transparently transmitted by the client on the first node through the second node, if the first node is incapable of directly communicating with the server, The client on the node transparently transmits the registration response information, and performs a keep-alive process according to the heartbeat message transparently transmitted by the client on the first node through the second node. A device for controlling a node in a distributed network television IPTV system is applied to a server, and the device includes: a first receiving module, configured to receive an incremental file of each first node in the IPTV system sent by each client; wherein the client is disposed on a first node in the IPTV system, and each client corresponds to a first node; Determining a module, configured to determine, according to the received delta file, a first node that has an abnormality in the plurality of first nodes; The processing module is configured to process the first node that has an abnormality, so that the first node that has an abnormality returns to normal. A server comprising a control device for a node in a distributed network television IPTV system according to claim 10. A method for controlling a node in a distributed network television IPTV system is applied to a client, and the method includes: Obtaining a delta file of the first node in the IPTV system, where the client is set on the first node; Send the obtained delta file to the server. The method of claim 12, wherein the step of acquiring the delta file of the first node in the IPTV system comprises: The plurality of delta files in the first node are filtered according to the timing task and the filtering condition in the preset configuration file, to obtain an incremental file that satisfies the filtering condition. The method of claim 12, wherein the step of transmitting the obtained delta file to the server comprises: If the first node can directly communicate with the server, the obtained incremental file is directly sent to the server; And if the first node is incapable of directly communicating with the server, the incremental file is transparently transmitted to the server by using the second node, where the second node is multiple first nodes in the IPTV system. The first node, except for the first node where the client is located, and capable of directly communicating with the server and the client, the second node and the first node are located in different network planes. The method of claim 14 further comprising: Receiving a file query instruction sent by the server; Acquiring, according to the file query instruction, the file to be analyzed from the first node, and sending the file to be analyzed to the server; Receiving a processing instruction sent by the server, and processing the first node according to the processing instruction. The method of claim 15, wherein the step of receiving a file query instruction sent by the server comprises: If the first node can directly communicate with the server, directly receiving a file query instruction sent by the server; And if the first node cannot directly communicate with the server, receiving a file query instruction transparently transmitted by the server by the second node. The method of claim 15, wherein the step of transmitting the file to be analyzed to the server comprises: If the first node can directly communicate with the server, the file to be analyzed is directly sent to the server; And if the first node cannot directly communicate with the server, sending, by the second node, the file to be analyzed to the server. The method of claim 15, wherein the step of receiving the processing instruction sent by the server comprises: If the first node can directly communicate with the server, directly receiving a processing instruction sent by the server; And if the first node cannot directly communicate with the server, receiving, by the server, a processing instruction transparently transmitted by the second node. The method of claim 14, wherein before the step of acquiring the delta file of the first node in the IPTV system, the method further comprises: Sending registration information to the server, receiving registration response information returned by the server, and sending a heartbeat message to the server. The method of claim 19, wherein the step of transmitting registration information to the server, receiving registration response information returned by the server, and transmitting a heartbeat message to the server comprises: If the first node can directly communicate with the server, send the registration information directly to the server, directly receive the registration response information returned by the server, and directly send a heartbeat message to the server; If the first node is incapable of directly communicating with the server, the second node sends registration information to the server, and receives registration response information transparently transmitted by the server through the second node. And sending a heartbeat message to the server by using the second node. A control device for a node in a distributed network television IPTV system is applied to a client, and the device includes: An acquiring module, configured to acquire a delta file of the first node in the IPTV system, where the client is set on the first node; The first sending module is configured to send the obtained delta file to the server. A client comprising a control device for a node in a distributed network television IPTV system according to claim 21.

Images