CN111163169B - Data forwarding method, device, equipment and medium - Google Patents

Abstract

The invention provides a data forwarding method, a device, equipment and a medium. The invention is applied to the technical field of communication. The method is applied to the first sub-control equipment and comprises the following steps: receiving a service signaling sent by the first terminal equipment, and forwarding the service signaling to the main control equipment; receiving a first service opening signaling carrying the first terminal equipment video network address and a second service opening signaling carrying the second terminal equipment video network address, which are sent by the main control equipment; forwarding the first service opening signaling to the first terminal equipment, and forwarding the second service opening signaling to the second terminal equipment; and forwarding the service data between the first terminal equipment and the second terminal equipment through the service data transmission channel. According to the invention, the service data can be sent to more terminal devices through the first sub-control device, so that the flow direction of the service data can be mastered more easily, and the flow explosion of the terminal devices can not be caused.

Description

A data forwarding method, device, equipment and medium

Technical field

The present invention relates to the field of communication technology, and in particular, to a data forwarding method, device, equipment and medium.

Background technique

The Internet of Vision is an important milestone in network development. It is a real-time network that can realize real-time transmission of high-definition video and push many Internet applications to high-definition video and high-definition face-to-face.

The existing technology uses HiSilicon chips to implement forwarding services. Not only is the chip cost high, but the number of analog sub-controllers is limited. If the data is forwarded directly point-to-point, the network data cannot be controlled, and the data traffic of the terminal device will be overwhelming.

Contents of the invention

In view of the above problems, embodiments of the present invention are proposed to provide a data forwarding method, device, equipment and medium that overcomes the above problems or at least partially solves the above problems.

In order to solve the above problems, firstly, in order to solve the above problems, an embodiment of the present invention discloses a data forwarding method, which is applied to the first sub-control device in the video network data processing system. The first sub-control device and The main control device, the first terminal device and the second terminal device are connected to multiple terminal devices respectively; the method includes:

Receive the service signaling sent by the first terminal device, and forward the service signaling to the main control device; the service signaling is used to request the communication between the first terminal device and the second terminal device. Establish business data transmission channels between them;

Receive the first service start signaling carrying the video network address of the first terminal device and the second service start signaling carrying the video network address of the second terminal device sent by the main control device;

Forward the first service opening signaling to the first terminal device, and forward the second service opening signaling to the second terminal device, so as to connect the first terminal device and the second terminal device. Establish business data transmission channels between terminal devices;

Forward service data between the first terminal device and the second terminal device through the service data transmission channel.

Preferably, forwarding service data between the first terminal device and the second terminal device through the service data transmission channel includes:

Receive multicast link control information and data source opening signaling sent by the main control device, where the link multicast path control information includes a multicast address;

Forward the multicast address and the data source opening signaling to the first terminal device;

Receive the service data sent by the first terminal device, and search the multicast information table according to the multicast address;

Forward the service data to the second terminal device according to the multicast information table.

Preferably, the multicast link control information also includes a replacement multicast address; before the step of forwarding the multicast address and the data source opening signaling to the first terminal device, the step further includes:

Determine whether the multicast address and the replacement multicast address are the same;

If they are different, replace the multicast address with the replacement multicast address.

Preferably, before the step of receiving the service signaling sent by the first terminal device and forwarding the service signaling to the main control device, the step further includes:

Establish a communication connection with the main control device, the first terminal device and the second terminal device;

Use heartbeats to maintain active states with the main control device, the first terminal device and the second terminal device.

Preferably, the main control device is connected to a second sub-control device, and the second sub-control device is connected to a plurality of terminal devices; the method further includes:

Determine whether the service data needs to be forwarded to multiple terminal devices connected to the second sub-control device according to the multicast information table;

When it is determined that the service data needs to be forwarded to multiple terminal devices connected to the second sub-control device, make multiple copies of the service data;

Forward the copied service data to multiple terminal devices connected to the second sub-control device.

In the second aspect, in order to solve the above problem, an embodiment of the present invention discloses a data forwarding device, which is applied to the first sub-control device in the video network data processing system. The first sub-control device is connected with the main control device and the third control device. A terminal device and a second terminal device are connected to multiple terminal devices respectively; the device includes:

The first receiving module is used to receive the service signaling sent by the first terminal device and forward the service signaling to the main control device; the service signaling is used to request that the first terminal device Establish a service data transmission channel with the second terminal device;

The second receiving module is configured to receive the first service start signaling carrying the video network address of the first terminal device and the second service start signaling carrying the video network address of the second terminal device sent by the main control device. ;

A service start signaling forwarding module, configured to forward the first service start signaling to the first terminal device, and forward the second service start signaling to the second terminal device, so as to Establish a service data transmission channel between the first terminal device and the second terminal device;

A first service data forwarding module is configured to forward service data between the first terminal device and the second terminal device through the service data transmission channel.

Preferably, the first service data forwarding module includes:

Information receiving submodule, used to receive multicast link control information and data source opening signaling sent by the main control device, where the link multicast path control information includes a multicast address;

A data forwarding submodule, configured to forward the multicast address and the data source opening signaling to the first terminal device;

A data search submodule, configured to receive the service data sent by the first terminal device and search the multicast information table according to the multicast address;

The service data forwarding submodule is configured to forward the service data to the second terminal device according to the multicast information table.

Preferably, the multicast link control information also includes a replacement multicast address; the device further includes:

Address determination submodule, used to determine whether the multicast address and the replacement multicast address are the same;

The address replacement submodule is used to replace the multicast address with the replacement multicast address if they are different.

Preferably, the device further includes:

A communication establishment module, configured to establish communication connections with the main control device, the first terminal device and the second terminal device;

A state maintenance module is used to maintain the activity state with the main control device, the first terminal device and the second terminal device using heartbeats.

Preferably, the main control device is connected to a second sub-control device, and the second sub-control device is connected to a plurality of terminal devices; the device further includes:

A terminal device determination module, configured to determine whether the service data needs to be forwarded to multiple terminal devices connected to the second sub-control device according to the multicast information table;

A business data copying module, configured to copy multiple copies of the business data when it is determined that the business data needs to be forwarded to multiple terminal devices connected to the second sub-control device;

The second service data forwarding module is configured to forward multiple copied service data to multiple terminal devices connected to the second sub-control device.

In a third aspect, in order to solve the above problems, embodiments of the present invention disclose a computer-readable storage medium on which a computer program is stored. When the program is executed by a processor, the method in any one of the first aspects is implemented. step.

In a fourth aspect, in order to solve the above problem, an embodiment of the present invention discloses an electronic device, which includes a memory, a processor, and a computer program stored in the memory and executable on the processor. When the processor executes, the following is implemented: In one aspect the steps of any of the described methods.

Embodiments of the present invention include the following advantages:

In the present invention, the first terminal sends service signaling to the first sub-control device and initiates a service request, so that the first sub-control device forwards the service signaling to the main control device, and the main control device generates the start-up service signaling through the first sub-control device. The sub-control device sends the data to the first terminal device and the second terminal device respectively, thereby establishing a service data transmission channel between the first terminal device and the second terminal device, so that the first terminal device and the second terminal device can conduct business with each other. Data interaction: By copying and forwarding business data through the first sub-control device, orderly control of communication between each terminal device is achieved. Compared with the existing technology of using chips to forward data of terminal devices, it is more cost-effective and can be based on the first sub-control device. The device sends business data to more terminal devices, making it easier to grasp the flow of business data and preventing terminal devices from experiencing overwhelming traffic.

Description of drawings

Figure 1 is a block diagram of a data forwarding design scheme of the present invention;

Figure 2 is a step flow chart of a data forwarding method of the present invention;

Figure 3 is a flow chart of data forwarding steps according to the present invention;

Figure 4 is a flow chart of data forwarding steps according to the present invention;

Figure 5 is a functional block diagram of data forwarding according to the present invention;

Figure 6 is a structural diagram of a data forwarding device of the present invention;

Figure 7 is a schematic diagram of a video network according to the present invention;

Figure 8 is a schematic diagram of the hardware structure of a node server of the present invention;

Figure 9 is a schematic diagram of the hardware structure of an access switch according to the present invention;

Figure 10 is a schematic diagram of the hardware structure of an Ethernet protocol conversion gateway of the present invention.

Detailed ways

In order to make the above objects, features and advantages of the present invention more obvious and understandable, the present invention will be described in further detail below with reference to the accompanying drawings and specific embodiments.

Referring to Figure 1, a block diagram of a data forwarding design scheme of the present invention is shown. This method is applied in the video network, specifically as follows:

The X86 sub-control device is connected to the main control device through tcp socket communication and maintains the active state through heartbeats; the X86 sub-control device communicates with the terminal through tcp socket and maintains the active state through heartbeats. The main control device, sub-control device and terminal device are set in a 64-bit autonomous server (64-bit autonomous server system). Among them, the main control device is the brain of the entire autonomous server. The video network interface receives business instructions (such as starting a meeting, stopping a meeting, etc.). After parsing the video network packet to obtain the business instructions, the main control device sends the relevant business instructions to the video network through the video network interface; the sub-control device is connected to the main control device. Under the control device, business data in the video network needs to be sent and received by the sub-control device; the terminal device is connected under the sub-control device, and the terminal device can be a computer, camera monitoring equipment, video network terminal equipment, etc.

In the present invention, the 64-bit autonomous server is set in the main micro-cloud of the video network, and the terminal is set in the slave micro-cloud of the video network. There is a master control device in the same autonomous cloud, and the master control device is connected to There are multiple sub-control devices, and each sub-control device is connected to multiple terminal devices.

First, terminal device 1 initiates a service and sends a service signaling to the X86 sub-control device; then, the X86 sub-control device forwards the service signaling to the main control device, and the main control device sends an enable service signaling to the X86 sub-control device. , causing the X86 sub-control device to forward the service enablement signaling to terminal device 1 and other terminal devices, such as terminal device 2. When terminal device 1 and terminal device 1 receive the service enablement signaling, it means that terminal device 1 and terminal device 1 A business data transmission channel is established between 2; finally, terminal device 1 and terminal device 2 can interact with each other through the X86 sub-control device. If business data is established between terminal device 1, terminal device 2, and terminal device 3 transmission channel, then after terminal device 1 sends the data to be sent to the X86 sub-control device, the X86 sub-control device copies the above-mentioned transmission data and sends a copy of the same transmission data to terminal device 2 and terminal device 3 respectively.

Through the above data forwarding method, the present invention aims to realize the copying and forwarding of data within the autonomous cloud through the sub-control device, and orderly control the communication between the terminal devices.

Referring to Figure 2, a flow chart of steps of a data forwarding method of the present invention is shown, which may specifically include the following steps:

Step 201: Receive the service signaling sent by the first terminal device and forward the service signaling to the main control device; the service signaling is used to request the communication between the first terminal device and the third terminal device. A service data transmission channel is established between the two terminal devices.

In the embodiment of the present invention, the method is applied to the first sub-control device in the video network data processing system. The first sub-control device and the main control device, the first terminal device and the second terminal device are multiple terminal devices. Connect separately.

First, the first terminal device under the first sub-control device initiates a service request and sends service signaling to the first terminal. The service signaling includes the video network address of the first terminal device, the video network address of the second terminal, and also Including service types pre-established by the first terminal device and the second terminal device, such as live broadcast, video phone, conference and other service types.

Then, after receiving the service signaling, the first sub-control device will return a feedback message to the first terminal device to let the first terminal device know whether the service signaling is sent successfully; if the feedback message received by the first terminal device is If the characterization fails, the first terminal device sends service signaling to the first sub-control device again.

Finally, the first sub-control device forwards the service signaling to the main control device. The main control device parses the service signaling and obtains the video network address of the first terminal device, the video network address of the second terminal device, and the video network address of the first terminal device. The requested task type. The main control device generates a multicast information table based on the video network address of the first terminal device, the video network address of the second terminal device, and the request task type of the first terminal device. Specifically, the multicast information table contains the identities of all terminal devices connected to the network under each sub-control device under the main control device. If the second terminal device is in another autonomous cloud, the identity of the second terminal device will also be passed through the service The signaling is added to the multicast information table, and the master control device changes the status identifiers of the first terminal device and the second terminal device to the on state in the multicast information table. For example, the identifiers of the first terminal device and the second terminal device in the multicast information table are changed from 0 to 1, where 0 indicates no service and 1 indicates no service.

After that, the main control device generates the first service start signaling and the second service start signaling. The data header of the first service start signaling carries the video network address of the first terminal device, and the data header of the second service start signaling carries the video network address of the first terminal device. The data header carries the video network address of the second terminal device. The main control device will send the first service start signaling and the second service start signaling to the first sub-control device.

Step 202: Receive the first service start signaling carrying the video network address of the first terminal device and the second service start signaling carrying the video network address of the second terminal device sent by the main control device.

In the embodiment of the present invention, the first sub-control device receives the first service start signaling and the second service start signaling respectively.

Step 203: Forward the first service opening signaling to the first terminal device, and forward the second service opening signaling to the second terminal device, so as to connect the first terminal device and the second terminal device. A service data transmission channel is established between the second terminal devices.

In the embodiment of the present invention, the first sub-control device reads the data headers of the first service start signaling and the second service start signaling, forwards the first service start signaling to the first terminal device, and forwards the second service start signaling to the first terminal device. The order is forwarded to the second terminal device, so that the first terminal device and the second terminal device know that a service data transmission channel has been established between the first terminal device and the second terminal device, so that the first terminal device and the second terminal device can prepare the transmission /Preparation for receiving data.

Step 204: Forward the service data between the first terminal device and the second terminal device through the service data transmission channel.

In the embodiment of the present invention, the first terminal device sends the service data to the first sub-control device, and the first sub-control device reads the multicast information table sent by the main control device, and obtains the terminal device with the open flag in the multicast information table. , for example, the terminal device identified as 1 in the multicast information table; sends the service data to the second terminal device. Correspondingly, the second terminal can also send its own service data to the second sub-control device. The first sub-control device reads the multicast information table sent by the main control device and obtains the terminal device with the open flag in the multicast information table. Forward the service data sent by the second terminal to the first terminal device.

Preferably, in the embodiment of the present invention, the second terminal device can represent multiple terminal devices that are different from the first terminal device, and the first terminal device and the multiple terminal devices can establish service data transmission channels through the above method. After receiving the service data, the first sub-control device can copy the service data through the multicast information table, and send a copy of the copied service data to other terminal devices.

In the embodiment of the present invention, the first terminal sends service signaling to the first sub-control device and initiates a service request, so that the first sub-control device forwards the service signaling to the main control device, and the main control device generates start-up service signaling. By sending the first sub-control device to the first terminal device and the second terminal device respectively, a service data transmission channel is established between the first terminal device and the second terminal device, so that the first terminal device and the second terminal device can Interact business data with each other. It achieves orderly control of the communication of each terminal device. Compared with the existing technology that uses chips to forward data of terminal devices, it is more cost-effective. It can send business data to more terminal devices based on the first sub-control device, making it easier to master. The flow of business data.

Referring to Figure 3, a flow chart of data forwarding steps of the present invention is shown. details as follows:

Step 301: Establish a communication connection between the sub-control device, the main control device and the terminal device.

In the embodiment of the present invention, communication connections with the main control device, the first terminal device and the second terminal device are established; and heartbeats are used to maintain communication with the main control device, the first terminal device and the second terminal device. activity status.

Specifically, a communication connection is established between the first sub-control device, the main control device, the first terminal device and the second terminal device through the video network interface; wherein, the first sub-control device is connected to the main control device through tcp socket communication, The first sub-control device communicates with the first terminal device and the second terminal device through TCP socket. The first sub-control device and the main control device notify their respective statuses through heartbeats, and determine whether the main control device and the first sub-control device are online based on the heartbeat. The first sub-control device and the first terminal device and the second terminal device notify through heartbeats Their respective statuses are determined based on the heartbeat whether the first sub-control device, the first terminal device and the second terminal device are online. The first sub-control device notifies the main control device of the network access status of the first terminal device and the second terminal device through the heartbeat command. , and at the same time, the main control device saves it after receiving the network access status of the terminal device.

Preferably, there are multiple terminal devices under the first sub-control device, such as terminal device 1, terminal device 2, terminal device 3, terminal device 5, etc. The first sub-control device can establish a communication connection with the above-mentioned terminal devices. The present invention does not Make restrictions.

Step 302: The first terminal device sends service signaling to the first sub-control device.

In the embodiment of the present invention, the first terminal device sends a request to establish a service in the form of service signaling to the first sub-control device. The service signaling carries the video network address of the first terminal device, the video network address of the second terminal device, and the task type. The service signaling is used to request the establishment of a service data transmission channel between the first terminal device and the second terminal device.

Preferably, the service signaling may carry the video network addresses of multiple terminal devices, and the service signaling is used to request the establishment of service data transmission channels between the first terminal device and the multiple terminal devices.

Step 303: The first sub-control device forwards the service signaling to the main control device.

In the embodiment of the present invention, the sub-control device will not perform any processing on the received data. The first sub-control device forwards the service signaling sent by the first terminal device to the main control device.

Step 304: The main control device sends service start signaling to the first sub-control device.

In the embodiment of the present invention, after receiving the service signaling, the main control device generates a multicast information table and a multicast address according to the terminal device address carried in the service signaling and the requested service type. Among them, the multicast address in one service cannot be repeated with other services. Through the multicast address, you can know which terminal device is performing the service and with whom it is conducting the service. At the same time, the multicast information table contains the master control device. The identities of all terminal devices connected to the network under each sub-control device. If the second terminal device is in another autonomous cloud, the identity of the second terminal device will also be added to the multicast information table through service signaling. The master control device Change the status identifiers of the first terminal device and the second terminal device in the multicast information table to the on state. For example, the identifiers of the first terminal device and the second terminal device in the multicast information table are changed from 0 to 1, where 0 indicates no service and 1 indicates no service.

After that, the main control device checks whether the first sub-control device is designated as a converter based on the MAC address of the first sub-control device in the preconfiguration file, and checks whether the first sub-control device is an upper or lower boundary sub-control device. If so, then The master device will regenerate a globally unique replacement multicast address.

Finally, the main control device generates the first service start signaling and the second service start signaling respectively. The data header of the first service start signaling carries the video network address of the first terminal device, and the data header of the second service start signaling carries the video network address of the first terminal device. It carries the video network address of the second terminal device. The main control device sends the first service start signaling and the second service start signaling to the first sub-control device.

Step 305: The first sub-control device forwards the service start signaling to the first terminal device and the second terminal device.

In the embodiment of the present invention, the first sub-control device reads the data headers of the first service start signaling and the second service start signaling, forwards the first service start signaling to the first terminal device, and forwards the second service start signaling to the first terminal device. The order is forwarded to the second terminal device, so that the first terminal device and the second terminal device know that a service data transmission channel has been established between the first terminal device and the second terminal device, so that the first terminal device and the second terminal device can prepare the transmission /Preparation for receiving data.

Step 306: The first sub-control device receives the multicast link control information and data source opening signaling sent by the main control device.

In this embodiment of the present invention, the first sub-control device receives the multicast link control information and data source opening signaling sent by the main control device, and the link multicast path control information includes a multicast address.

Specifically, the main control device sends the multicast link control information to the first sub-control device, where the multicast link control information includes multiple multicast information tables representing different services, multicast addresses, and replacement multicast addresses. At the same time, the anchor device turns on the link switch between the first terminal device and the second terminal device, generates a data source opening signaling, and sends it to the first sub-control device.

Step 307: The first sub-control device forwards the data source opening signaling and multicast address to the first terminal device.

Specifically, it is determined whether the multicast address and the replacement multicast address are the same; if they are different, the multicast address is replaced with the replacement multicast address.

In the embodiment of the present invention, the data source open signaling is used to notify the first terminal device that it can start sending service data to the first sub-control device. The multicast address is used by the first terminal to use the multicast address as the destination video network address and send service data to the first sub-control device.

After receiving the multicast link control information, the first sub-control device determines whether the multicast address in the multicast link control information and the replacement multicast address are the same.

If they are the same, forward the multicast address and the data source opening signaling to the first terminal device;

If they are not the same, the replacement multicast address and the data source opening signaling are forwarded to the first terminal device.

After receiving the data source opening signaling, the first terminal device uses the multicast address or the replacement multicast address as the destination video network address, and sends the service data to the first sub-control device.

Step 308: The first sub-control device forwards the service data to the second terminal device according to the multicast information table.

In this embodiment of the present invention, because the first sub-control device may be carrying out multiple groups of services at the same time, there are multiple multicast information tables in the first sub-control device. After receiving the service data sent by the first terminal device, the first sub-control device searches the corresponding multicast information table according to the multicast address. The first terminal device forwards the service data to the terminal device whose terminal device identifier is 1 in the multicast information table and is different from the first terminal device, that is, the second terminal device.

Referring to Figure 4, a flow chart of data forwarding steps of the present invention is shown. The main control device is connected to a second sub-control device, and the second sub-control device is connected to a plurality of terminal devices. Specific steps are as follows:

Step 401: Determine whether the service data needs to be forwarded to multiple terminal devices connected to the second sub-control device according to the multicast information table.

In the embodiment of the present invention, the first sub-control device, the second sub-control device are connected to the main control device, the first terminal device is connected to the first sub-control device, and many terminal devices are connected to the second sub-control device.

After multiple terminal devices under the first terminal device and the second sub-control device have established services, the first sub-control device needs to search the multicast information table to determine whether the service data sent by the first terminal device needs to be forwarded to the second sub-control device. Sub-control equipment.

Specifically, after the first terminal device forwards the service signaling to the main control device through the first sub-control terminal, because the main control device knows the information of all sub-control devices connected to itself and all terminal devices under these sub-control devices, Including: video network address, Mac address and other information, so the main control device obtains the video network address of the terminal device carried in the business signaling after parsing the business signaling, and then based on the video network address of the terminal device carried in the business signaling The address knows whether it is necessary to send the service data sent by the first terminal to the second sub-control device and record it in the multicast information table. If necessary, the main control sends the multicast link control information and data source opening signaling to One copy of the second sub-control equipment.

Step 402: When it is determined that the service data needs to be forwarded to multiple terminal devices connected to the second sub-control device, make multiple copies of the service data.

In the embodiment of the present invention, after receiving the service data sent by the first terminal device, the first sub-control device sends the service data to the second sub-control device through the anchor information table, and the second sub-control device sends the service data to the second sub-control device according to the multicast control information. The identification of the terminal device in the table copies the business data into multiple copies.

Step 403: Forward the copied service data to multiple terminal devices connected to the second sub-control device.

In this embodiment of the present invention, the second sub-control device sends a copy of the service data to the terminal device identified as 1 in each multicast information table and which is different from the first terminal device.

In the embodiment of the present invention, when a terminal device needs to send service data to multiple other terminal devices, it only needs to send one copy of the service data to the sub-control device, and then the sub-control service device copies and forwards the service data to other terminals. The equipment solves the problems in the existing technology that point-to-point data transmission is prone to overflowing data traffic and network data cannot be controlled.

Referring to Figure 5, a functional block diagram of data forwarding according to the present invention is shown. details as follows:

In the embodiment of the present invention, the data forwarding business process is mainly divided into two parts, unicast service and multicast service.

Unicast service: The terminal device initiates a service request (service signaling) and sends it to the X86 sub-control device. The X86 sub-control device forwards the service request to the main control service device. The main control service device generates the service signaling and sends it to the X86 sub-control device. Forwarded to the corresponding terminal device to notify the terminal device of service establishment. Afterwards, the main control device generates data source open information (data source open signaling) and multicast link control information, and sends them to the X86 sub-control device. The broadcast link control information includes the multicast address and the replacement multicast address. , multicast information table; the X86 sub-control device sends the data source opening information carrying the multicast address or replacement multicast address to the terminal device. The X86 sub-control device sends service data to the terminal device that initiates the service request.

Multicast service: The terminal device sends audio and video data to the X86 sub-control device according to the multicast address or alternative multicast address; the X86 sub-control device determines according to the multicast information table to copy and forward the above service data to the X86 sub-control device. Other terminal devices, or forward the service data to other X86 sub-control devices, and then the other X86 sub-control devices copy and forward the service data to the terminal devices below them.

Beneficial effects of the above embodiments:

In the present invention, the first terminal sends service signaling to the first sub-control device and initiates a service request, so that the first sub-control device forwards the service signaling to the main control device, and the main control device generates the start-up service signaling through the first sub-control device. The sub-control device sends the data to the first terminal device and the second terminal device respectively, thereby establishing a service data transmission channel between the first terminal device and the second terminal device, so that the first terminal device and the second terminal device can conduct business with each other. Data interaction: By copying and forwarding business data through the first sub-control device, orderly control of communication between each terminal device is achieved. Compared with the existing technology of using chips to forward data of terminal devices, it is more cost-effective and can be based on the first sub-control device. The device sends business data to more terminal devices, making it easier to grasp the flow of business data and preventing terminal devices from experiencing overwhelming traffic.

It should be noted that for the sake of simple description, the method embodiments are expressed as a series of action combinations. However, those skilled in the art should know that the embodiments of the present invention are not limited by the described action sequence because According to embodiments of the present invention, certain steps may be performed in other orders or simultaneously. Secondly, those skilled in the art should also know that the embodiments described in the specification are preferred embodiments, and the actions involved are not necessarily necessary for the embodiments of the present invention.

Referring to Figure 6, there is shown a structural diagram of a data forwarding device of the present invention, which is applied to the first sub-control device in the video network data processing system. The first sub-control device, the main control device, and the first terminal device And the second terminal device is connected to multiple terminal devices respectively; specifically, it may include the following modules:

Communication establishment module 601, used to establish communication connections with the main control device, the first terminal device and the second terminal device;

The state maintenance module 602 is used to maintain the activity state with the main control device, the first terminal device and the second terminal device using heartbeats.

The first receiving module 603 is used to receive the service signaling sent by the first terminal device and forward the service signaling to the main control device; the service signaling is used to request that the first terminal Establish a service data transmission channel between the device and the second terminal device;

The second receiving module 604 is configured to receive the first service start signaling carrying the video network address of the first terminal device and the second service start signaling carrying the video network address of the second terminal device sent by the main control device. make;

The service start signaling forwarding module 605 is used to forward the first service start signaling to the first terminal device, and forward the second service start signaling to the second terminal device, so as to Establishing a service data transmission channel between the first terminal device and the second terminal device;

The first service data forwarding module 606 is configured to forward service data between the first terminal device and the second terminal device through the service data transmission channel.

Preferably, the first service data forwarding module 606 also includes the following sub-modules:

Information receiving submodule, used to receive multicast link control information and data source opening signaling sent by the main control device, where the link multicast path control information includes a multicast address;

The multicast link control information also includes a replacement multicast address;

The address judgment module sub-module is used to judge whether the multicast address and the replacement multicast address are the same;

The address replacement module sub-module is used to replace the multicast address with the replacement multicast address if they are different.

A data forwarding submodule, configured to forward the multicast address and the data source opening signaling to the first terminal device;

A data search submodule, configured to receive the service data sent by the first terminal device and search the multicast information table according to the multicast address;

The service data forwarding submodule is configured to forward the service data to the second terminal device according to the multicast information table.

Preferably, the main control device is connected to a second sub-control device, and the second sub-control device is connected to a plurality of terminal devices; the device further includes:

A terminal device determination module, configured to determine whether the service data needs to be forwarded to multiple terminal devices connected to the second sub-control device according to the multicast information table;

A business data copying module, configured to copy multiple copies of the business data when it is determined that the business data needs to be forwarded to multiple terminal devices connected to the second sub-control device;

The second service data forwarding module is configured to forward multiple copied service data to multiple terminal devices connected to the second sub-control device.

Based on the same inventive concept, another embodiment of the present invention provides a computer-readable storage medium on which a computer program is stored. When the program is executed by a processor, the steps in the method described in any of the above embodiments of the present application are implemented. .

Based on the same inventive concept, another embodiment of the present invention provides an electronic device, including a memory, a processor, and a computer program stored in the memory and executable on the processor. When the processor executes, any one of the above mentioned aspects of the present application is implemented. Steps in the methods described in the examples.

As for the device embodiment, since it is basically similar to the method embodiment, the description is relatively simple. For relevant details, please refer to the partial description of the method embodiment.

In order for those skilled in the art to better understand the embodiments of the present invention, the video network is introduced below:

The networking of the video network is as follows:

The visual network is a centralized control network structure. The network can be a tree network, a star network, a ring network, etc., but on this basis, a centralized control node is needed in the network to control the entire network.

As shown in Figure 7, the video network is divided into two parts: the access network and the metropolitan area network.

The equipment in the access network can be mainly divided into three categories: node servers, access switches, and terminals (including various set-top boxes, coding boards, memories, etc.). The node server is connected to the access switch, and the access switch can be connected to multiple terminals and can be connected to Ethernet.

Among them, the node server is a node with a centralized control function in the access network and can control access switches and terminals. The node server can be directly connected to the access switch or directly connected to the terminal.

Similarly, the equipment in the metropolitan area network can also be divided into three categories: metropolitan area servers, node switches, and node servers. Metro servers are connected to node switches, and node switches can be connected to multiple node servers.

Among them, the node server is the node server of the access network part, that is, the node server belongs to both the access network part and the metropolitan area network part.

The metropolitan area server is a node with a centralized control function in the metropolitan area network and can control node switches and node servers. Metro servers can be directly connected to node switches or node servers.

It can be seen that the entire Vision Network is a hierarchical centralized control network structure, and the network controlled by the node server and the metropolitan area server can be a tree, star, ring and other structures.

To put it graphically, the access network part can form a unified video platform (the part in the dotted circle), and multiple unified video platforms can form a video network; each unified video platform can be interconnected through metropolitan and wide-area video networks.

Visual network device classification

1.1 The equipment in the visual network according to the embodiment of the present invention can be mainly divided into three categories: servers, switches (including Ethernet gateways), and terminals (including various set-top boxes, coding boards, memories, etc.). The video network as a whole can be divided into metropolitan area network (or national network, global network, etc.) and access network.

1.2 The equipment in the access network can be mainly divided into three categories: node servers, access switches (including Ethernet gateways), and terminals (including various set-top boxes, encoding boards, memories, etc.).

The specific hardware structure of each access network equipment is:

Node server:

As shown in Figure 8, it mainly includes a network interface module 201, a switching engine module 202, a CPU module 203, and a disk array module 204;

Among them, the incoming packets from the network interface module 201, the CPU module 203, and the disk array module 204 all enter the switching engine module 202; the switching engine module 202 performs an operation on the address table 205 for the incoming packets, thereby obtaining the packet guidance information; and based on The packet guidance information stores the packet in the corresponding queue of the packet buffer 206; if the queue of the packet buffer 206 is close to full, it is discarded; the switching engine module 202 polls all packet buffer queues and forwards if the following conditions are met: 1) The send buffer of the port is not full; 2) The packet counter of the queue is greater than zero. The disk array module 204 mainly implements the control of the hard disk, including initialization, reading and writing of the hard disk and other operations; the CPU module 203 is mainly responsible for protocol processing with the access switch and terminal (not shown in the figure), and the address table 205 (including the configuration of the downstream protocol packet address table, the upstream protocol packet address table, and the data packet address table), and the configuration of the disk array module 204.

Access switch:

As shown in Figure 9, it mainly includes network interface modules (downlink network interface module 301, uplink network interface module 302), switching engine module 303 and CPU module 304;

Among them, the incoming packets (uplink data) from the downlink network interface module 301 enter the packet detection module 305; the packet detection module 305 detects whether the destination address (DA), source address (SA), data packet type and packet length of the packet meet the requirements. If If it matches, the corresponding stream identifier (stream-id) is assigned and enters the switching engine module 303, otherwise it is discarded; the incoming packets (downlink data) from the uplink network interface module 302 enter the switching engine module 303; the incoming data packets from the CPU module 304 Enter the switching engine module 303; the switching engine module 303 performs the operation of looking up the address table 306 for the incoming packet, thereby obtaining the packet guidance information; if the packet entering the switching engine module 303 is from the downlink network interface to the uplink network interface, then the combination The flow identifier (stream-id) stores the packet in the queue of the corresponding packet buffer 307; if the queue of the packet buffer 307 is close to full, it is discarded; if the packet entering the switching engine module 303 is not a downstream network interface, it is sent to the upstream interface. If the data packet goes to the network interface, the data packet is stored in the queue of the corresponding packet buffer 307 according to the packet steering information; if the queue of the packet buffer 307 is close to full, it is discarded.

The switching engine module 303 polls all packet buffer queues. In this embodiment of the present invention, there are two situations:

If the queue goes from the downlink network interface to the uplink network interface, the following conditions are met for forwarding: 1) The send buffer of the port is not full; 2) The packet counter of the queue is greater than zero; 3) The token generated by the code rate control module is obtained ;

If the queue does not go from the downstream network interface to the upstream network interface, the following conditions are met for forwarding: 1) The send buffer of the port is not full; 2) The packet counter of the queue is greater than zero.

The code rate control module 208 is configured by the CPU module 204 and generates tokens in the packet buffer queues of all downlink network interfaces going to the uplink network interface within a programmable interval to control the code rate of uplink forwarding.

The CPU module 304 is mainly responsible for protocol processing with the node server, configuration of the address table 306, and configuration of the code rate control module 308.

Ethernet protocol conversion gateway :

As shown in Figure 10, it mainly includes the network interface module (downlink network interface module 401, uplink network interface module 402), switching engine module 403, CPU module 404, packet detection module 405, code rate control module 408, address table 406, packet Cache 407, MAC adding module 409, and MAC deleting module 410.

Among them, the data packets coming from the downlink network interface module 401 enter the packet detection module 405; the packet detection module 405 detects the Ethernet MAC DA, Ethernet MAC SA, Ethernet length or frame type, video network destination address DA, and video network of the data packet. Whether the source address SA, network data packet type and packet length meet the requirements, if so, a corresponding stream identifier (stream-id) is allocated; then, the MAC deletion module 410 subtracts the MAC DA, MAC SA, length or frame type. (2byte), and enter the corresponding receive buffer, otherwise discard;

The downlink network interface module 401 detects the sending buffer of the port. If there is a packet, it obtains the Ethernet MAC DA of the corresponding terminal according to the visual network destination address DA of the packet, and adds the Ethernet MAC DA of the terminal, the MACSA of the Ethernet protocol conversion gateway, Ethernet length or frame type, and send.

The functions of other modules in the Ethernet protocol conversion gateway are similar to those of the access switch.

terminal:

Mainly includes network interface module, business processing module and CPU module; for example, set-top box mainly includes network interface module, video and audio coding engine module, CPU module; encoding board mainly includes network interface module, video and audio coding engine module, CPU module; memory It mainly includes network interface module, CPU module and disk array module.

1.3 The equipment in the metropolitan area network can be mainly divided into two categories: node servers, node switches, and metropolitan area servers. Among them, node switches mainly include network interface modules, switching engine modules and CPU modules; metro servers mainly include network interface modules, switching engine modules and CPU modules.

2. Definition of video network data packets

2.1 Access network data packet definition

The data packet of the access network mainly includes the following parts: destination address (DA), source address (SA), reserved bytes, payload (PDU), and CRC.

As shown in the following table, the data packets of the access network mainly include the following parts:

DA SA Reserved Payload CRC

in:

The destination address (DA) consists of 8 bytes. The first byte indicates the type of data packet (such as various protocol packets, multicast data packets, unicast data packets, etc.). There are up to 256 possibilities. The second to sixth bytes are the metropolitan area network address, and the seventh and eighth bytes are the access network address;

The source address (SA) is also composed of 8 bytes and has the same definition as the destination address (DA);

Reserved bytes consist of 2 bytes;

The payload part has different lengths according to different datagram types. If it is a various protocol packet, it is 64 bytes. If it is a single multicast data packet, it is 32+1024=1056 bytes. Of course, it is not limited to The above 2 types;

CRC consists of 4 bytes, and its calculation method follows the standard Ethernet CRC algorithm.

2.2 MAN data packet definition

The topology of the metropolitan area network is a graph. There may be two or even more than two types of connections between two devices, that is, there may be more than two connections between node switches and node servers, node switches and node switches, and node switches and node servers. kind of connection. However, the metropolitan area network address of a metropolitan area network device is unique. In order to accurately describe the connection relationship between metropolitan area network devices, a parameter: label is introduced in the embodiment of the present invention to uniquely describe a metropolitan area network device.

The definition of labels in this manual is similar to the definition of labels in MPLS (Multi-Protocol Label Switch, Multi-Protocol Label Switching). Assuming that there are two connections between device A and device B, then the data packet from device A to device B has 2 labels, the data packet from device B to device A also has 2 labels. Labels are divided into incoming labels and outgoing labels. Assume that the label (incoming label) of a data packet entering device A is 0x0000. The label (outgoing label) of this data packet when it leaves device A may become 0x0001. The network access process of the metropolitan area network is a network access process under centralized control, which means that the address allocation and label allocation of the metropolitan area network are dominated by the metropolitan area server, and the node switches and node servers are only passively executed. It is different from the label allocation of MPLS. The label allocation of MPLS is the result of mutual negotiation between switches and servers.

As shown in the following table, the data packets of the metropolitan area network mainly include the following parts:

DA SA Reserved Label Payload CRC

That is, destination address (DA), source address (SA), reserved bytes (Reserved), label, payload (PDU), and CRC. Among them, the format of the label can refer to the following definition: the label is 32 bits, of which the high 16 bits are reserved and only the low 16 bits are used. Its position is between the reserved bytes of the data packet and the payload.

Based on the above characteristics of the Video Network, one of the core concepts of the embodiments of the present invention is proposed. Following the protocol of the Video Network, the sub-control device forwards service data to other terminal devices.

Each embodiment in this specification is described in a progressive manner. Each embodiment focuses on its differences from other embodiments. The same and similar parts between the various embodiments can be referred to each other.

It should be understood by those skilled in the art that embodiments of the present invention may be provided as methods, devices, or computer program products. Thus, embodiments of the present invention may take the form of an entirely hardware embodiment, an entirely software embodiment, or an embodiment that combines software and hardware aspects. Furthermore, embodiments of the invention may take the form of a computer program product embodied on one or more computer-usable storage media (including, but not limited to, disk storage, CD-ROM, optical storage, etc.) having computer-usable program code embodied therein.

Embodiments of the invention are described with reference to flowcharts and/or block diagrams of methods, terminal devices (systems), and computer program products according to embodiments of the invention. It will be understood that each process and/or block in the flowchart illustrations and/or block diagrams, and combinations of processes and/or blocks in the flowchart illustrations and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to a processor of a general-purpose computer, special-purpose computer, embedded processor, or other programmable data processing terminal device to produce a machine such that the instructions are executed by the processor of the computer or other programmable data processing terminal device. Means are generated for implementing the functions specified in the process or processes of the flowchart diagrams and/or the block or blocks of the block diagrams.

These computer program instructions may also be stored in a computer-readable memory that causes a computer or other programmable data processing terminal equipment to operate in a particular manner, such that the instructions stored in the computer-readable memory produce an article of manufacture including the instruction means, the The instruction means implements the functions specified in a process or processes of the flowchart and/or a block or blocks of the block diagram.

These computer program instructions can also be loaded onto a computer or other programmable data processing terminal equipment, so that a series of operating steps are performed on the computer or other programmable terminal equipment to produce computer-implemented processing, thereby causing the computer or other programmable terminal equipment to perform a computer-implemented process. The instructions executed on provide steps for implementing the functions specified in a process or processes of the flow diagrams and/or a block or blocks of the block diagrams.

Although preferred embodiments of the embodiments of the present invention have been described, those skilled in the art will be able to make additional changes and modifications to these embodiments once the basic inventive concepts are apparent. Therefore, it is intended that the appended claims be construed to include the preferred embodiments and all changes and modifications that fall within the scope of embodiments of the invention.

Finally, it should be noted that in this article, relational terms such as first and second are only used to distinguish one entity or operation from another entity or operation, and do not necessarily require or imply that these entities or any such actual relationship or sequence between operations. Furthermore, the terms "comprises," "comprises," or any other variation thereof are intended to cover a non-exclusive inclusion such that a process, method, article, or end device that includes a list of elements includes not only those elements, but also elements not expressly listed or other elements inherent to such process, method, article or terminal equipment. Without further limitation, an element defined by the statement "comprises a..." does not exclude the presence of additional identical elements in a process, method, article or terminal device including the stated element.

The above is a detailed introduction to the data forwarding method, device, equipment and medium provided by the present invention. This article uses specific examples to illustrate the principles and implementation modes of the present invention. The description of the above embodiments is only for It helps to understand the method and its core idea of the present invention; at the same time, for those of ordinary skill in the field, there will be changes in the specific implementation and application scope according to the idea of the present invention. In summary, the content of this specification It should not be construed as a limitation of the invention.

Claims (8)

1. The data forwarding method is characterized by being applied to first sub-control equipment in an Internet of view data processing system, wherein the first sub-control equipment is respectively connected with a main control equipment, a first terminal equipment and a plurality of terminal equipment of a second terminal equipment; the method comprises the following steps:

receiving a service signaling sent by the first terminal equipment, and forwarding the service signaling to the main control equipment; the service signaling is used for requesting to establish a service data transmission channel between the first terminal equipment and the second terminal equipment;

receiving a first service opening signaling carrying the first terminal equipment video network address and a second service opening signaling carrying the second terminal equipment video network address, which are sent by the main control equipment;

Forwarding the first service opening signaling to the first terminal equipment, and forwarding the second service opening signaling to the second terminal equipment so as to establish a service data transmission channel between the first terminal equipment and the second terminal equipment; the first service opening signaling is used for changing the state of the first terminal device into a service state, and the second service opening signaling is used for changing the state of the second terminal device into the service state;

forwarding service data between the first terminal device and the second terminal device through the service data transmission channel;

the forwarding the service data between the first terminal device and the second terminal device through the service data transmission channel includes:

receiving multicast link control information and a data source opening signaling sent by the main control equipment, wherein the multicast link control information comprises a multicast address and the alternative multicast address; the alternative multicast address is generated when the master control device determines that the first sub-control device is designated as a converter and is an upper and lower boundary sub-control device;

determining a target multicast address according to the multicast address and the alternative multicast address;

Forwarding the target multicast address and the data source opening signaling to the first terminal device;

receiving service data sent by the first terminal equipment, and searching a multicast information table according to the target multicast address;

and forwarding the service data to the second terminal equipment according to the multicast information table.

2. The method of claim 1, wherein the multicast link control information further comprises a replacement multicast address; before the step of forwarding the multicast address and the data source opening signaling to the first terminal device, the method further includes:

judging whether the multicast address and the alternative multicast address are the same;

if the multicast addresses are different, replacing the multicast addresses with the replacement multicast addresses.

3. The method of claim 1, wherein before the step of receiving the service signaling sent by the first terminal device and forwarding the service signaling to the master device, further comprises:

establishing communication connection with the main control equipment, the first terminal equipment and the second terminal equipment;

and maintaining the active states of the master control equipment, the first terminal equipment and the second terminal equipment by using heartbeats.

4. The method of claim 1, wherein the master device is connected to a second slave device, the second slave device being connected to a plurality of terminal devices; the method further comprises the steps of:

determining whether the service data needs to be forwarded to a plurality of terminal devices connected with the second control device according to the multicast information table;

when determining that the service data needs to be forwarded to a plurality of terminal devices connected with the second branch control device, copying the service data for a plurality of copies;

and forwarding the copied multiple service data to multiple terminal devices connected with the second control device.

5. The data forwarding device is characterized by being applied to first sub-control equipment in an Internet of view data processing system, wherein the first sub-control equipment is respectively connected with a main control equipment, a first terminal equipment and a plurality of terminal equipment of a second terminal equipment; the device comprises:

the first receiving module is used for receiving the service signaling sent by the first terminal equipment and forwarding the service signaling to the main control equipment; the service signaling is used for requesting to establish a service data transmission channel between the first terminal equipment and the second terminal equipment;

The second receiving module is used for receiving a first service opening signaling carrying the first terminal equipment video network address and a second service opening signaling carrying the second terminal equipment video network address, which are sent by the main control equipment; the first service opening signaling is used for changing the state of the first terminal device into a service state, and the second service opening signaling is used for changing the state of the second terminal device into the service state;

the starting service signaling forwarding module is used for forwarding the first service starting signaling to the first terminal equipment and forwarding the second service starting signaling to the second terminal equipment so as to establish a service data transmission channel between the first terminal equipment and the second terminal equipment;

the first service data forwarding module is used for forwarding service data between the first terminal equipment and the second terminal equipment through the service data transmission channel;

the first service data forwarding module includes:

the information receiving sub-module is used for receiving multicast link control information and a data source opening signaling sent by the main control equipment, wherein the multicast link control information comprises a multicast address and a replacement multicast address; the alternative multicast address is generated when the master control device determines that the first sub-control device is designated as a converter and is an upper and lower boundary sub-control device;

A data forwarding sub-module, configured to determine a target multicast address according to the multicast address and the alternative multicast address, and forward the target multicast address and the data source opening signaling to the first terminal device;

the data searching sub-module is used for receiving the service data sent by the first terminal equipment and searching a multicast information table according to the target multicast address;

and the service data forwarding sub-module is used for forwarding the service data to the second terminal equipment according to the multicast information table.

6. The apparatus of claim 5, wherein the multicast link control information further comprises a replacement multicast address; the device further comprises:

the address judging module sub-module is used for judging whether the multicast address and the alternative multicast address are the same or not;

and the address replacement module sub-module is used for replacing the multicast address with the replacement multicast address if the multicast address is different.

7. A computer readable storage medium, on which a computer program is stored, characterized in that the program, when being executed by a processor, implements the steps of the method according to any of claims 1-4.

8. An electronic device comprising a memory, a processor and a computer program stored on the memory and executable on the processor, wherein the processor performs the steps of the method according to any of claims 1-4.