技术领域technical field
本发明涉及通信技术领域，特别是涉及一种通信方法和一种通信装置。The present invention relates to the technical field of communication, in particular to a communication method and a communication device.
背景技术Background technique
组播又称多目标广播、多播，为网络中使用的一种传输方式。组播的方式允许把所发消息传送给所有可能目的地中的一个经过选择的子集，即向明确指出的多种地址输送信息。组播是一种在一个发送者和多个接收者之间进行通信的方法。Multicast, also known as multi-target broadcast or multicast, is a transmission method used in the network. The method of multicasting allows sending a message to a selected subset of all possible destinations, that is, sending information to a variety of addresses that are clearly indicated. Multicast is a method of communication between one sender and multiple receivers.
当终端与服务器建立了某一路视频流的组播的调流业务后，服务器端需要管理该调流业务，目前的实现方法中，终端向节点服务器发起视频调流请求，节点服务器将视频调流请求发送到核心服务器后，核心服务器生成用来标识发送调流请求的终端识别码。在整个调流业务的过程中，终端识别码都将存在于核心服务器中，核心服务器查询识别码能够得知哪些终端在使用组播调流业务。当调流任务结束时，终端指示核心服务器将终端对应的识别码删除，核心服务器便得知哪个终端无需使用其调流业务。When the terminal and the server establish a multicast streaming service for a certain video stream, the server needs to manage the streaming service. In the current implementation method, the terminal initiates a video streaming request to the node server, and the node server sends the video streaming After the request is sent to the core server, the core server generates a terminal identification code used to identify the request to send the flow regulation. During the whole process of streaming service, the terminal identification code will exist in the core server, and the core server can know which terminals are using the multicast streaming service by querying the identification code. When the streaming task ends, the terminal instructs the core server to delete the identification code corresponding to the terminal, and the core server knows which terminal does not need to use its streaming service.
然而，当请求业务的终端的数量巨大时，核心服务器需要管理的识别码的数量也较多，因此会给核心服务器带来巨大的性能消耗。另外，识别码的数量越大，两个不同终端对应的识别码重复的概率也越大，可能会导致核心服务器在处理业务时出现错误的情况。However, when the number of terminals requesting services is huge, the core server needs to manage a large number of identification codes, which will bring huge performance consumption to the core server. In addition, the greater the number of identification codes, the greater the probability of duplication of identification codes corresponding to two different terminals, which may cause errors in the core server when processing services.
发明内容Contents of the invention
鉴于上述问题，提出了本发明实施例以便提供一种克服上述问题或者至少部分地解决上述问题的一种通信方法和相应的一种通信装置。In view of the above problems, embodiments of the present invention are proposed to provide a communication method and a corresponding communication device that overcome the above problems or at least partially solve the above problems.
为了解决上述问题，本发明实施例公开了一种通信方法，所述方法涉及终端，节点服务器以及核心服务器，所述终端与所述节点服务器连接，所述节点服务器与所述核心服务器连接，所述方法包括：In order to solve the above problems, the embodiment of the present invention discloses a communication method, the method involves a terminal, a node server and a core server, the terminal is connected to the node server, the node server is connected to the core server, the The methods described include:
所述核心服务器接收所述节点服务器发送的针对视频数据的调流请求消息，所述调流请求消息由所述终端发送至所述节点服务器；The core server receives a streaming request message sent by the node server for video data, and the streaming request message is sent by the terminal to the node server;
所述核心服务器根据所述调流请求消息，获取针对所述视频数据的调流业务的标识信息；The core server acquires identification information of a streaming service for the video data according to the streaming request message;
所述核心服务器向所述节点服务器发送所述视频数据和所述针对所述视频数据的调流业务的标识信息，以使所述节点服务器采用所述针对所述视频数据的调流业务的标识信息，向所述终端发送所述视频数据。The core server sends the video data and the identification information of the streaming service for the video data to the node server, so that the node server adopts the identification of the streaming service for the video data information, and send the video data to the terminal.
可选地，所述核心服务器根据所述调流请求消息，获取针对所述视频数据的调流业务的标识信息的步骤包括：Optionally, the step of obtaining, by the core server, identification information of a streaming service for the video data according to the streaming request message includes:
所述核心服务器判断是否存在针对所述视频数据的调流业务；The core server judges whether there is a streaming service for the video data;
若存在针对所述视频数据的调流业务，则所述核心服务器从获取所述调流业务的标识信息；If there is a streaming service for the video data, the core server obtains the identification information of the streaming service;
若不存在所述针对所述视频数据的调流业务的标识信息，则所述核心服务器控制节点服务器建立调流业务，并生成所述针对所述视频数据的调流业务的标识信息。If there is no identification information of the stream adjustment service for the video data, the core server controls the node server to establish a stream adjustment service, and generates the identification information of the stream adjustment service for the video data.
可选地，所述方法还包括所述核心服务器为所述终端配置所述针对所述视频数据的调流业务。Optionally, the method further includes the core server configuring the streaming service for the video data for the terminal.
可选地，所述核心服务器判断是否存在针对所述视频数据的调流业务的步骤包括：Optionally, the step of the core server judging whether there is a streaming service for the video data includes:
所述核心服务器获取调流地址列表集合；The core server obtains a list set of streaming addresses;
所述核心服务器从所述调流地址列表集合中，判断是否存在所述视频数据对应的调流地址列表；The core server determines whether there is a flow regulation address list corresponding to the video data from the flow regulation address list set;
若存在所述视频数据对应的调流地址列表，则所述核心服务器确定为存在针对所述视频数据的调流业务；If there is a streaming address list corresponding to the video data, the core server determines that there is a streaming service for the video data;
若不存在所述视频数据对应的调流地址列表，则所述核心服务器确定为不存在针对所述视频数据的调流业务。If there is no streaming address list corresponding to the video data, the core server determines that there is no streaming service for the video data.
可选地，所述核心服务器为所述终端配置所述针对所述视频数据的调流业务的步骤包括：Optionally, the step of the core server configuring the streaming service for the video data for the terminal includes:
所述核心服务器生成并发送调流业务添加消息至所述节点服务器，所述节点服务器用于根据调流业务添加消息向所述终端发送所述视频数据。The core server generates and sends a streaming service adding message to the node server, and the node server is configured to send the video data to the terminal according to the streaming service adding message.
可选地，所述核心服务器控制节点服务器建立调流业务的步骤包括：所述核心服务器生成并发送调流业务建立消息至所述节点服务器，所用节点服务器用于根据所述调流业务建立消息建立调流业务。Optionally, the step of the core server controlling the node server to establish the flow regulation service includes: the core server generates and sends a flow regulation service establishment message to the node server, and the used node server is used to establish the flow regulation service according to the flow regulation service establishment message Establish a transfer business.
相应的，本发明实施例还公开了一种通信方法，所述方法涉及终端，节点服务器以及核心服务器，所述终端与所述节点服务器连接，所述节点服务器与所述核心服务器连接，所述方法包括：Correspondingly, the embodiment of the present invention also discloses a communication method, the method involves a terminal, a node server and a core server, the terminal is connected to the node server, the node server is connected to the core server, the Methods include:
当所述节点服务器接收所述核心服务器发送的调流业务添加消息，所述节点服务器获取调流地址列表；When the node server receives the flow regulation service adding message sent by the core server, the node server obtains a flow regulation address list;
所述节点服务器获取所述终端的网络地址；The node server acquires the network address of the terminal;
所述节点服务器将所述终端的网络地址添加到所述调流地址列表中；The node server adds the network address of the terminal to the flow regulation address list;
所述节点服务器向所述终端的网络地址发送所述视频数据以及所述针对所述视频数据的调流业务的标识信息。The node server sends the video data and the identification information of the streaming service for the video data to the network address of the terminal.
可选地，所述节点服务器采用所述针对所述视频数据的调流业务的标识信息，向所述终端发送所述视频数据的步骤包括：Optionally, the step of sending the video data to the terminal by the node server using the identification information of the streaming service for the video data includes:
当所述节点服务器接收所述核心服务器发送的调流业务添加消息，所述节点服务器获取调流地址列表；When the node server receives the flow regulation service adding message sent by the core server, the node server obtains a flow regulation address list;
所述节点服务器获取所述终端的网络地址；The node server acquires the network address of the terminal;
所述节点服务器将所述终端的网络地址添加到所述调流地址列表中；The node server adds the network address of the terminal to the flow regulation address list;
所述节点服务器向所述终端的网络地址发送所述视频数据以及所述针对所述视频数据的调流业务的标识信息。The node server sends the video data and the identification information of the streaming service for the video data to the network address of the terminal.
可选地，所述方法还包括：Optionally, the method also includes:
当所述节点服务器接收所述核心服务器发送的调流业务建立消息，所述节点服务器建立与所述标识信息对应的调流地址列表。When the node server receives the flow regulation service establishment message sent by the core server, the node server creates a flow regulation address list corresponding to the identification information.
相应的，本发明实施例还公开了一种通信装置，所述装置涉及终端，节点服务器以及核心服务器，所述终端与所述节点服务器连接，所述节点服务器与所述核心服务器连接，所述装置包括：Correspondingly, the embodiment of the present invention also discloses a communication device, the device involves a terminal, a node server and a core server, the terminal is connected to the node server, the node server is connected to the core server, the Devices include:
位于所述核心服务器的调流请求消息接收模块，用于接收所述节点服务器发送的针对视频数据的调流请求消息，所述调流请求消息由所述终端发送至所述节点服务器；The flow regulation request message receiving module located at the core server is configured to receive a flow regulation request message for video data sent by the node server, and the flow regulation request message is sent to the node server by the terminal;
位于所述核心服务器的标识信息获取模块，用于根据所述调流请求消息，获取针对所述视频数据的调流业务的标识信息；An identification information acquisition module located at the core server, configured to acquire identification information of a flow adjustment service for the video data according to the flow adjustment request message;
位于所述核心服务器的视频数据和标识信息发送模块，用于向所述节点服务器发送所述视频数据和所述针对所述视频数据的调流业务的标识信息，以使所述节点服务器采用所述针对所述视频数据的调流业务的标识信息，向所述终端发送所述视频数据。The video data and identification information sending module located at the core server is configured to send the video data and the identification information of the streaming service for the video data to the node server, so that the node server adopts the The identification information of the streaming service for the video data, and send the video data to the terminal.
可选地，所述标识信息获取模块包括：Optionally, the identification information acquisition module includes:
位于所述核心服务器的调流业务判断子模块，用于判断是否存在针对所述视频数据的调流业务；The streaming service judging submodule located at the core server is used to judge whether there is a streaming service for the video data;
位于所述核心服务器的标识信息调用子模块，用于从所述预设存储位置中获取所述针对所述视频数据的调流业务的标识信息；An identification information calling submodule located in the core server, configured to acquire the identification information of the streaming service for the video data from the preset storage location;
位于所述核心服务器的调流业务建立子模块，用于若不存在所述针对所述视频数据的调流业务的标识信息，则指示节点服务器建立调流业务；The flow adjustment service establishment submodule located at the core server is used to instruct the node server to establish a flow adjustment service if there is no identification information of the flow adjustment service for the video data;
位于所述核心服务器的标识信息生成子模块，用于生成所述针对所述视频数据的调流业务的标识信息。The identification information generation sub-module located in the core server is configured to generate the identification information of the streaming service for the video data.
可选地，所述装置还包括位于所述核心服务器的调流业务配置模块，用于为所述终端配置所述针对所述视频数据的调流业务。Optionally, the device further includes a streaming service configuration module located in the core server, configured to configure the streaming service for the video data for the terminal.
可选地，所述调流业务判断子模块包括：Optionally, the flow regulating service judging submodule includes:
位于所述核心服务器的地址列表集合获取单元，用于获取调流地址列表集合；The address list set acquisition unit located in the core server is used to acquire the flow regulation address list set;
位于所述核心服务器的调流地址列表判断单元，用于从所述调流地址列表集合中，判断是否存在所述视频数据对应的调流地址列表；The flow regulation address list judging unit located in the core server is used to judge whether there is a flow regulation address list corresponding to the video data from the flow regulation address list set;
位于所述核心服务器的调流业务存在确定单元，用于若存在所述视频数据对应的调流地址列表，则确定存在针对所述视频数据的调流业务；The flow regulation service existence determination unit located in the core server is used to determine that there is a flow regulation service for the video data if there is a flow regulation address list corresponding to the video data;
位于所述核心服务器的调流业务不存在确定单元，用于若不存在所述视频数据对应的调流地址列表，则确定不存在针对所述视频数据的调流业务。The flow regulation service non-existence determination unit located in the core server is configured to determine that there is no flow regulation service for the video data if there is no flow regulation address list corresponding to the video data.
可选地，所述标识信息生成子模块包括：Optionally, the identification information generating submodule includes:
位于所述核心服务器的请求信息识别单元，用于从所述视频请求消息中，识别出所述终端请求的视频数据的请求信息；A request information identification unit located in the core server, configured to identify the request information of the video data requested by the terminal from the video request message;
位于所述核心服务器的标识信息关系表获取单元，用于获取标识信息关系表；The identification information relationship table acquisition unit located in the core server is used to acquire the identification information relationship table;
位于所述核心服务器的随机数生成单元，用于生成所述预设位数的随机数；A random number generating unit located in the core server, configured to generate a random number with the preset number of digits;
位于所述核心服务器的标识信息判断单元，用于查询所述标识信息关系表，判断是否存在与所述随机数相同的标识信息；An identification information judging unit located in the core server, configured to query the identification information relationship table, and determine whether there is identification information identical to the random number;
位于所述核心服务器的重新执行单元，用于若存在与所述随机数相同的标识信息，重新执行所述节点服务器生成所述预设位数的随机数的步骤；A re-execution unit located in the core server, configured to re-execute the step of generating the random number with the preset number of digits by the node server if there is the same identification information as the random number;
位于所述核心服务器的标识信息确定单元，用于若不存在与所述随机数相同的标识信息，将所述随机数确定为针对所述视频数据的调流业务的标识信息；An identification information determining unit located at the core server, configured to determine the random number as the identification information for the streaming service of the video data if there is no identification information identical to the random number;
位于所述核心服务器的标识信息保存单元，用于将所述视频请求消息对应的请求信息与所述针对所述视频数据的调流业务的标识信息的对应关系，保存于所述标识信息关系表中。An identification information storage unit located at the core server, configured to store the corresponding relationship between the request information corresponding to the video request message and the identification information of the streaming service for the video data in the identification information relationship table middle.
可选地，调流业务添加子模块包括：位于所述核心服务器的业务添加消息生成与发送单元，用于生成并发送调流业务添加消息至所述节点服务器。Optionally, the flow adjustment service adding sub-module includes: a service addition message generation and sending unit located in the core server, configured to generate and send a flow adjustment service addition message to the node server.
可选地，调流业务建立子模块包括：位于所述核心服务器的业务建立消息生成与发送单元，用于生成并发送调流业务建立消息至所述节点服务器。Optionally, the flow regulation service establishment sub-module includes: a service establishment message generating and sending unit located in the core server, configured to generate and send a flow regulation service establishment message to the node server.
相应的，本发明实施例还公开了一种通信装置，所述装置涉及终端，节点服务器以及核心服务器，所述终端与所述节点服务器连接，所述节点服务器与所述核心服务器连接，所述装置包括：Correspondingly, the embodiment of the present invention also discloses a communication device, the device involves a terminal, a node server and a core server, the terminal is connected to the node server, the node server is connected to the core server, the Devices include:
位于所述节点服务器的调流请求消息发送模块，用于接收所述终端发送针对视频数据的调流请求消息，并将所述调流请求消息发送至所述核心服务器；A flow regulation request message sending module located at the node server, configured to receive a flow regulation request message sent by the terminal for video data, and send the flow regulation request message to the core server;
位于所述节点服务器的视频数据和标识信息模块，用于接收所述核心服务器，针对所述调流请求消息返回的视频数据和针对所述视频数据的调流业务的标识信息；The video data and identification information module located at the node server is used to receive the video data returned by the core server for the flow regulation request message and the identification information of the flow regulation service for the video data;
位于所述节点服务器的视频数据发送模块，用于采用所述针对所述视频数据的调流业务的标识信息，向所述终端发送所述视频数据。The video data sending module located in the node server is configured to send the video data to the terminal by using the identification information of the streaming service for the video data.
可选地，所述视频数据发送模块包括：Optionally, the video data sending module includes:
位于所述节点服务器的调流地址列表获取子模块，用于当所述节点服务器接收所述核心服务器发送的调流业务添加消息，获取调流地址列表；The flow regulation address list acquisition submodule located in the node server is used to obtain the flow regulation address list when the node server receives the flow regulation service addition message sent by the core server;
位于所述节点服务器的网络地址获取子模块，用于获取所述终端的网络地址；The network address obtaining submodule located in the node server is used to obtain the network address of the terminal;
位于所述节点服务器的第一网络地址添加子模块，用于将所述终端的网络地址添加到所述调流地址列表中；The first network address adding submodule located in the node server is configured to add the network address of the terminal to the flow regulation address list;
位于所述节点服务器的第一视频数据以及标识信息发送子模块，用于向所述终端的网络地址发送所述视频数据以及所述针对所述视频数据的调流业务的标识信息。The first video data and identification information sending submodule located at the node server is configured to send the video data and the identification information of the streaming service for the video data to the network address of the terminal.
可选地，所述装置还包括：位于所述节点服务器的调流地址列表建立子模块，用于当所述节点服务器接收所述核心服务器发送的调流业务建立消息，建立与所述标识信息对应的调流地址列表。Optionally, the device further includes: a flow regulation address list establishment submodule located at the node server, configured to establish a flow regulation service establishment message related to the identification information when the node server receives the flow regulation service establishment message sent by the core server. Corresponding flow address list.
本发明实施例还公开了一种通信装置，包括：The embodiment of the present invention also discloses a communication device, including:
一个或多个处理器；和one or more processors; and
其上存储有指令的一个或多个机器可读介质，当由所述一个或多个处理器执行时，使得所述装置执行如上所述的一个或多个的通信方法。One or more machine-readable media having instructions stored thereon, when executed by the one or more processors, cause the apparatus to perform one or more communication methods as described above.
本发明实施例还公开了一种计算机可读存储介质，其存储的计算机程序使得处理器执行如上任一项所述的通信方法。The embodiment of the present invention also discloses a computer-readable storage medium, which stores a computer program to enable a processor to execute the communication method described in any one of the above items.
本发明实施例包括以下优点：在本发明实施例中，所述核心服务器接收所述节点服务器发送的针对视频数据的调流请求消息，所述调流请求消息由所述终端发送至所述节点服务器，所述核心服务器根据所述调流请求消息，获取针对所述视频数据的调流业务的标识信息，所述核心服务器向所述节点服务器发送所述视频数据和所述针对所述视频数据的调流业务的标识信息，以使所述节点服务器采用所述针对所述视频数据的调流业务的标识信息，向所述终端发送所述视频数据，从而实现了针对视频数据的调流业务生成标识信息，核心服务器在管理调流业务时只需管理较少数量的标识信息，降低了核心服务器的性能消耗，也降低了核心服务器在处理调流业务时出错的概率。The embodiment of the present invention has the following advantages: In the embodiment of the present invention, the core server receives the streaming request message sent by the node server for video data, and the streaming request message is sent to the node by the terminal The server, the core server obtains the identification information of the stream adjustment service for the video data according to the stream adjustment request message, and the core server sends the video data and the video data for the video data to the node server. The identification information of the flow regulation service of the video data, so that the node server uses the identification information of the flow regulation service for the video data to send the video data to the terminal, thereby realizing the flow regulation service for the video data To generate identification information, the core server only needs to manage a small amount of identification information when managing the flow adjustment business, which reduces the performance consumption of the core server and reduces the probability of errors when the core server processes the flow adjustment business.
附图说明Description of drawings
图1是本发明的一种通信方法实施例一的步骤流程图；FIG. 1 is a flow chart of the steps of Embodiment 1 of a communication method of the present invention;
图2是本发明的一种通信方法实施例二的步骤流程图；FIG. 2 is a flow chart of the steps of Embodiment 2 of a communication method of the present invention;
图3是本发明的一种通信装置实施例三的结构框图；Fig. 3 is a structural block diagram of Embodiment 3 of a communication device of the present invention;
图4是本发明的一种通信装置实施例四的结构框图；FIG. 4 is a structural block diagram of Embodiment 4 of a communication device of the present invention;
图5是本发明的一种视联网的组网示意图；Fig. 5 is a schematic diagram of networking of a video network according to the present invention;
图6是本发明的一种节点服务器的硬件结构示意图；Fig. 6 is a schematic diagram of the hardware structure of a node server of the present invention;
图7是本发明的一种接入交换机的硬件结构示意图；FIG. 7 is a schematic diagram of a hardware structure of an access switch of the present invention;
图8是本发明的一种以太网协转网关的硬件结构示意图。FIG. 8 is a schematic diagram of a hardware structure of an Ethernet protocol conversion gateway according to the present invention.
具体实施方式Detailed ways
为使本发明的上述目的、特征和优点能够更加明显易懂，下面结合附图和具体实施方式对本发明作进一步详细的说明。In order to make the above objects, features and advantages of the present invention more comprehensible, the present invention will be further described in detail below in conjunction with the accompanying drawings and specific embodiments.
目前的组播方式中，当终端与服务器建立了某一路视频流的组播的调流业务后，服务器端需要管理该调流业务，目前的实现方法中，终端向节点服务器发起视频调流请求，节点服务器将视频调流请求发送到核心服务器后，核心服务器生成用来标识发送调流请求的终端识别码。在整个调流业务的过程中，终端识别码都将存在于核心服务器中，核心服务器查询识别码能够得知哪些终端在使用组播调流业务。当调流任务结束时，终端指示核心服务器将终端对应的识别码删除，核心服务器便得知哪个终端无需使用其调流业务。In the current multicast mode, when the terminal and the server establish a multicast streaming service for a certain video stream, the server needs to manage the streaming service. In the current implementation method, the terminal initiates a video streaming request to the node server , after the node server sends the video streaming request to the core server, the core server generates a terminal identification code used to identify the sending of the streaming request. During the whole process of streaming service, the terminal identification code will exist in the core server, and the core server can know which terminals are using the multicast streaming service by querying the identification code. When the streaming task ends, the terminal instructs the core server to delete the identification code corresponding to the terminal, and the core server knows which terminal does not need to use its streaming service.
然而，当请求业务的终端的数量巨大时，核心服务器需要管理的识别码的数量也较多，因此会给核心服务器带来巨大的性能消耗。另外，识别码的数量越大，两个不同终端对应的识别码重复的概率也越大，会导致核心服务器在处理业务时出现错误的情况。However, when the number of terminals requesting services is huge, the core server needs to manage a large number of identification codes, which will bring huge performance consumption to the core server. In addition, the greater the number of identification codes, the greater the probability of duplication of identification codes corresponding to two different terminals, which will cause errors in the core server when processing services.
针对目前的组播方式中存在的问题，本发明实施例的核心构思之一在于，当核心服务器接收所述节点服务器发送的针对视频数据的调流请求消息后，生成视频数据的调流业务的标识信息，在所述调流业务的进行过程中，所述核心服务器对视频数据的调流业务的标识信息进行管理。Aiming at the problems existing in the current multicast mode, one of the core ideas of the embodiments of the present invention is that, after the core server receives the streaming request message for the video data sent by the node server, it generates the streaming service of the video data. Identification information. During the process of the flow adjustment service, the core server manages the identification information of the video data flow adjustment service.
参照图1，示出了本发明的一种通信方法实施例一的步骤流程图，所述方法涉及终端，节点服务器以及核心服务器，所述终端与所述节点服务器连接，所述节点服务器与所述核心服务器连接，具体可以包括如下步骤：Referring to FIG. 1 , it shows a flow chart of the steps of Embodiment 1 of a communication method of the present invention, the method involves a terminal, a node server and a core server, the terminal is connected to the node server, the node server is connected to the The above-mentioned core server connection may specifically include the following steps:
步骤101，所述核心服务器接收所述节点服务器发送的针对视频数据的调流请求消息，所述调流请求消息由所述终端发送至所述节点服务器；Step 101, the core server receives a streaming request message for video data sent by the node server, and the streaming request message is sent by the terminal to the node server;
其中，所述调流请求消息用于请求服务器发送对应的视频数据。另外，所述核心服务器用于管理各种调流业务以及管理节点服务器，而所述节点服务器可以为协转服务器，所述协转服务器用于接入不同厂商的监控前端设备，视频监控设备，视频监控系统，视频监控联网平台等等。具体应用在本发明实施例中，当用户想要观看某一路的监控视频时，可以通过终端向所述节点服务器发送调流请求消息。Wherein, the streaming request message is used to request the server to send corresponding video data. In addition, the core server is used to manage various streaming services and manage node servers, and the node server can be a co-transfer server, and the co-transfer server is used to access monitoring front-end equipment and video surveillance equipment from different manufacturers. Video surveillance system, video surveillance networking platform, etc. Specific application In the embodiment of the present invention, when a user wants to watch a surveillance video of a certain channel, the terminal may send a streaming request message to the node server.
步骤102，所述核心服务器根据所述调流请求消息，获取针对所述视频数据的调流业务的标识信息；Step 102, the core server acquires identification information of a streaming service for the video data according to the streaming request message;
在本发明的实施例中，每一路视频数据都具有其对应的调流业务，调流业务用于将对应的视频数据发送到请求该视频数据的终端，而每个调流业务都有对其进行唯一标识的标识信息，核心服务器根据该标识信息便能确定对应的视频数据以及该视频数据对应的调流业务。In the embodiment of the present invention, each channel of video data has its corresponding streaming service, and the streaming service is used to send the corresponding video data to the terminal requesting the video data, and each streaming service has its own The identification information for unique identification, the core server can determine the corresponding video data and the streaming service corresponding to the video data according to the identification information.
可选地，所述核心服务器根据所述调流请求消息，获取针对所述视频数据的调流业务的标识信息可以包括以下子步骤：Optionally, the acquisition by the core server of the identification information of the streaming service for the video data according to the streaming request message may include the following substeps:
子步骤S11，所述核心服务器判断是否存在针对所述视频数据的调流业务；Sub-step S11, the core server judges whether there is a streaming service for the video data;
所述核心服务器在接收到调流请求消息后，先判断是否存在针对所述视频数据的调流业务，若已经存在针对所述视频数据的调流业务，则将所述终端加入该调流业务中，若不存在针对所述视频数据的调流业务，则新建一个所述视频数据的调流业务。After receiving the streaming request message, the core server first judges whether there is a streaming service for the video data, and if there is already a streaming service for the video data, then add the terminal to the streaming service , if there is no streaming service for the video data, create a new streaming service for the video data.
其中，所述核心服务器判断是否存在针对所述视频数据的调流业务的步骤包括：Wherein, the step of the core server judging whether there is a streaming service for the video data includes:
子步骤S111，所述核心服务器获取调流地址列表集合；Sub-step S111, the core server obtains a list set of flow regulation addresses;
在本发明实施例中，每一路视频数据的调流业务对应一个调流地址列表，而调流地址列表用于记录终端的网络地址，节点服务器向所述调流地址列表中的网络地址发送视频数据来实现调流过程。而所述调流地址列表集合中包括各路视频数据对应的调流地址列表。所述调流地址列表集合保存于所述节点服务器的预设存储位置中，所述节点服务器可以调用预设存储位置上的调流地址列表集合，完成获取过程。In the embodiment of the present invention, the flow regulation service of each channel of video data corresponds to a flow regulation address list, and the flow regulation address list is used to record the network address of the terminal, and the node server sends the video to the network address in the flow regulation address list. Data to realize the flow adjustment process. The flow regulation address list set includes a flow regulation address list corresponding to each channel of video data. The flow regulation address list set is stored in a preset storage location of the node server, and the node server can call the flow regulation address list set in the preset storage location to complete the acquisition process.
子步骤S112，所述核心服务器从所述调流地址列表集合中，判断是否存在所述视频数据对应的调流地址列表；Sub-step S112, the core server judges whether there is a flow regulation address list corresponding to the video data from the flow regulation address list set;
需要说明的是，每一路视频数据的视频数据唯一对应一个调流地址列表。所述节点服务器可以查询所述调流地址列表集合，判断是否存在视频数据唯一对应一个调流地址列表。It should be noted that the video data of each channel of video data uniquely corresponds to a stream regulation address list. The node server may query the flow regulation address list set, and determine whether there is a flow regulation address list uniquely corresponding to video data.
子步骤S113，若存在所述视频数据对应的调流地址列表，则所述核心服务器确定存在针对所述视频数据的调流业务；Sub-step S113, if there is a streaming address list corresponding to the video data, the core server determines that there is a streaming service for the video data;
当检测到调流地址列表集合中存在所述视频数据对应的调流地址列表，则所述核心服务器确定已经建立所述视频数据对应视频的调流业务，也就是说所述核心服务器正在进行所述调流业务，需要把所述终端也加进该调流业务。When it is detected that there is a flow regulation address list corresponding to the video data in the flow regulation address list set, the core server determines that the flow regulation service of the video corresponding to the video data has been established, that is to say, the core server is performing the For the above flow adjustment service, it is necessary to add the terminal to the flow adjustment service.
子步骤S115，若不存在所述视频数据对应的调流地址列表，则所述核心服务器确定不存在针对所述视频数据的调流业务。In sub-step S115, if there is no streaming address list corresponding to the video data, the core server determines that there is no streaming service for the video data.
当检测到调流地址列表集合中并不存在所述视频数据对应的调流地址列表，则所述核心服务器确定未建立所述视频请求消息对应视频的调流业务，也就是说所述节点服务器并没有对视频数据进行调流，需要针对所述终端请求的视频数据新建一个调流业务。When it is detected that there is no stream address list corresponding to the video data in the stream address list set, the core server determines that the video stream service corresponding to the video request message has not been established, that is to say, the node server The video data is not stream-regulated, and a new stream-regulated service needs to be created for the video data requested by the terminal.
子步骤S12，若存在针对所述视频数据的调流业务，则所述核心服务器获取所述调流业务的标识信息；Sub-step S12, if there is a streaming service for the video data, the core server obtains the identification information of the streaming service;
子步骤S13，若不存在所述针对所述视频数据的调流业务的标识信息，则所述核心服务器控制节点服务器建立调流业务，并生成所述针对所述视频数据的调流业务的标识信息。Sub-step S13, if there is no identification information of the flow regulation service for the video data, the core server controls the node server to establish the flow regulation service, and generates the identification information of the flow regulation service for the video data information.
所述核心服务器生成并发送调流业务建立消息至所述节点服务器，所述节点服务器用于根据所述调流业务建立消息建立调流业务。The core server generates and sends a flow regulation service establishment message to the node server, and the node server is configured to establish a flow regulation service according to the flow regulation service establishment message.
另外，所述核心服务器还会为所述终端配置所述针对所述视频数据的调流业务，具体地，所述核心服务器生成并发送调流业务添加消息至所述节点服务器，所述节点服务器用于根据调流业务添加消息向所述终端发送所述视频数据。In addition, the core server will also configure the stream regulation service for the video data for the terminal, specifically, the core server generates and sends a stream regulation service addition message to the node server, and the node server It is used to send the video data to the terminal according to the streaming service adding message.
在本发明一种可选的实施例中，所述生成所述针对所述视频数据的调流业务的标识信息的步骤可以包括以下子步骤：In an optional embodiment of the present invention, the step of generating the identification information of the streaming service for the video data may include the following substeps:
子步骤S131，所述核心服务器从所述视频请求消息中，识别出所述终端请求的视频数据的请求信息；Sub-step S131, the core server identifies the request information of the video data requested by the terminal from the video request message;
子步骤S132，所述核心服务器获取标识信息关系表；Sub-step S132, the core server obtains the identification information relationship table;
其中，所述标识信息关系表存储着所述视频请求消息对应的请求信息与所述针对所述视频数据的调流业务的标识信息的对应关系。Wherein, the identification information relationship table stores the corresponding relationship between the request information corresponding to the video request message and the identification information of the streaming service for the video data.
子步骤S133，所述核心服务器生成所述预设位数的随机数；Sub-step S133, the core server generates a random number with the preset number of digits;
在本发明的实施例中，为了防止不同视频数据的调流业务的标识信息发生重复，应设置较大的预设位数，例如，所述预设位数可以设置为12位。In the embodiment of the present invention, in order to prevent the identification information of the streaming service of different video data from being repeated, a larger preset number of bits should be set, for example, the preset number of bits can be set to 12 bits.
子步骤S134，所述核心服务器查询所述标识信息关系表，判断是否存在与所述随机数相同的标识信息；Sub-step S134, the core server queries the identification information relationship table to determine whether there is identification information identical to the random number;
子步骤S135，若存在与所述随机数相同的标识信息，则核心服务器重新执行所述节点服务器生成所述预设位数的随机数的步骤；Sub-step S135, if there is the same identification information as the random number, the core server re-executes the step of generating the random number with the preset number of digits by the node server;
子步骤S136，若不存在与所述随机数相同的标识信息，所述核心服务器将所述随机数确定为针对所述视频数据的调流业务的标识信息；Sub-step S136, if there is no identification information identical to the random number, the core server determines the random number as the identification information for the streaming service of the video data;
子步骤S137，所述核心服务器将所述视频请求消息对应的请求信息与所述针对所述视频数据的调流业务的标识信息的对应关系，保存于所述标识信息关系表中。In sub-step S137, the core server saves the corresponding relationship between the request information corresponding to the video request message and the identification information of the streaming service for the video data in the identification information relationship table.
步骤103，所述核心服务器向所述节点服务器发送所述视频数据和所述针对所述视频数据的调流业务的标识信息，以使所述节点服务器采用所述针对所述视频数据的调流业务的标识信息，向所述终端发送所述视频数据。Step 103, the core server sends the identification information of the video data and the streaming service for the video data to the node server, so that the node server adopts the streaming service for the video data service identification information, and send the video data to the terminal.
在本发明实施例中，所述核心服务器接收所述节点服务器发送的针对视频数据的调流请求消息，所述调流请求消息由所述终端发送至所述节点服务器，所述核心服务器根据所述调流请求消息，获取针对所述视频数据的调流业务的标识信息，所述核心服务器向所述节点服务器发送所述视频数据和所述针对所述视频数据的调流业务的标识信息，以使所述节点服务器采用所述针对所述视频数据的调流业务的标识信息，向所述终端发送所述视频数据，从而实现了针对视频数据的调流业务生成标识信息，核心服务器在管理调流业务时只需管理较少数量的标识信息，降低了核心服务器的性能消耗，也降低了核心服务器在处理调流业务时出错的概率。In the embodiment of the present invention, the core server receives a flow adjustment request message for video data sent by the node server, the flow adjustment request message is sent by the terminal to the node server, and the core server according to the The flow adjustment request message, to obtain the identification information of the flow adjustment service for the video data, the core server sends the video data and the identification information of the flow adjustment service for the video data to the node server, so that the node server sends the video data to the terminal by using the identification information of the flow regulation service for the video data, thereby realizing the generation of identification information for the flow regulation service of the video data, and the core server is managing Only a small amount of identification information needs to be managed during the flow adjustment business, which reduces the performance consumption of the core server and reduces the error probability of the core server when processing the flow adjustment business.
参照图2，示出了本发明的一种通信方法实施例二的步骤流程图，所述方法涉及终端，节点服务器以及核心服务器，所述终端与所述节点服务器连接，所述节点服务器与所述核心服务器连接，具体可以包括如下步骤：Referring to Fig. 2, it shows a flow chart of the steps of Embodiment 2 of a communication method of the present invention, the method involves a terminal, a node server and a core server, the terminal is connected to the node server, the node server is connected to the The above-mentioned core server connection may specifically include the following steps:
步骤202，所述节点服务器接收所述终端发送针对视频数据的调流请求消息，并将所述调流请求消息发送至所述核心服务器；Step 202, the node server receives the stream adjustment request message sent by the terminal for video data, and sends the stream adjustment request message to the core server;
当所述节点服务器接受到所述终端发送针对视频数据的调流请求消息后，所述节点服务器需要把终端请求的视频数据发送到所述终端，而在此之前，所述节点服务器首先把调流请求消息发送到核心服务器，由核心服务器对调流请求消息进行解析。After the node server receives the stream adjustment request message sent by the terminal for video data, the node server needs to send the video data requested by the terminal to the terminal. The stream request message is sent to the core server, and the core server parses the stream request message.
步骤203，所述节点服务器接收所述核心服务器，针对所述调流请求消息返回的视频数据和针对所述视频数据的调流业务的标识信息；Step 203, the node server receives the video data returned by the core server for the flow regulation request message and the identification information of the flow regulation service for the video data;
其中，针对所述调流请求消息返回的视频数据为终端请求的视频，而所述标识信息与所述视频数据的调流业务唯一相对，节点服务器可以通过查询所述标识信息得到其对应的调流业务，从而实现对调流业务的管理。Wherein, the video data returned by the streaming request message is the video requested by the terminal, and the identification information is uniquely opposite to the streaming service of the video data, and the node server can obtain its corresponding scheduling service by querying the identification information. Streaming services, so as to realize the management of streaming services.
步骤204，所述节点服务器采用所述针对所述视频数据的调流业务的标识信息，向所述终端发送所述视频数据。Step 204, the node server sends the video data to the terminal using the identification information of the streaming service for the video data.
所述节点服务器在接收到针对所述调流请求消息返回的视频数据和针对所述视频数据的调流业务的标识信息，需要向所述终端发送其请求的视频数据，具体应用在本发明实施例中，所述节点服务器采用所述针对所述视频数据的调流业务的标识信息，向所述终端发送所述视频数据，以使终端得知获得的视频数据为标识信息对应的视频数据。After the node server receives the video data returned by the flow regulation request message and the identification information of the flow regulation service for the video data, it needs to send the requested video data to the terminal, which is specifically applied in the implementation of the present invention. In an example, the node server sends the video data to the terminal using the identification information of the streaming service for the video data, so that the terminal knows that the obtained video data is the video data corresponding to the identification information.
其中，当节点服务器判断出已经建立了所述终端请求的视频数据的调流业务，将终端加入到所述调流业务便可以实现向终端发送所述数据，具体地，所述节点服务器采用所述针对所述视频数据的调流业务的标识信息，向所述终端发送所述视频数据的步骤包括以下子步骤:Wherein, when the node server determines that the video data streaming service requested by the terminal has been established, adding the terminal to the streaming service can realize sending the data to the terminal. Specifically, the node server adopts the For the identification information of the streaming service of the video data, the step of sending the video data to the terminal includes the following substeps:
子步骤S21，当所述节点服务器接收所述核心服务器发送的调流业务添加消息，所述节点服务器获取调流地址列表；Sub-step S21, when the node server receives the flow regulation service addition message sent by the core server, the node server obtains a flow regulation address list;
需要说明的是，所述调流地址列表保存着终端的网络地址，节点服务器向所述调流地址列表上的网络地址发送视频数据从而实现调流业务。It should be noted that the flow regulation address list stores the network address of the terminal, and the node server sends video data to the network address on the flow regulation address list to realize the flow regulation service.
子步骤S22，所述节点服务器获取所述终端的网络地址；Sub-step S22, the node server obtains the network address of the terminal;
在本发明实施例中，所述调流请求消息可以包括所述终端的网络地址，所述节点服务器终端对所述调流请求消息解析便可得到所述终端的网络地址。In the embodiment of the present invention, the flow adjustment request message may include the network address of the terminal, and the node server terminal can obtain the network address of the terminal after parsing the flow adjustment request message.
子步骤S23，所述节点服务器将所述终端的网络地址添加到所述调流地址列表中；Sub-step S23, the node server adds the network address of the terminal to the flow regulation address list;
当所述节点服务器将所述终端的网络地址添加到所述调流地址列表后，可以将所述调流地址列表更新至核心服务器，以使所述核心服务器能够及时管理调流任务，本发明对此不作进一步地限定。After the node server adds the network address of the terminal to the flow regulation address list, it can update the flow regulation address list to the core server, so that the core server can manage the flow regulation task in time. The present invention This is not further limited.
子步骤S24，所述节点服务器向所述终端的网络地址发送所述视频数据以及所述针对所述视频数据的调流业务的标识信息。In sub-step S24, the node server sends the video data and the identification information of the streaming service for the video data to the network address of the terminal.
当节点服务器判断并未建立所述终端请求的视频数据的调流业务，所述节点服务器需要新建一个所述终端请求的视频数据的调流业务，具体地，当所述节点服务器接收所述核心服务器发送的调流业务建立消息，所述节点服务器建立与所述标识信息对应的调流地址列表。When the node server judges that the video data streaming service requested by the terminal has not been established, the node server needs to create a video data streaming service requested by the terminal. Specifically, when the node server receives the core In the flow adjustment service establishment message sent by the server, the node server creates a flow adjustment address list corresponding to the identification information.
在本发明实施例中，所述节点服务器接收所述终端发送针对视频数据的调流请求消息，并将所述调流请求消息发送至所述核心服务器，所述节点服务器接收所述核心服务器，针对所述调流请求消息返回的视频数据和针对所述视频数据的调流业务的标识信息，所述节点服务器采用所述针对所述视频数据的调流业务的标识信息，向所述终端发送所述视频数据，从而实现了针对视频数据的调流业务生成标识信息，节点服务器在管理调流业务时只需管理较少数量的标识信息，降低了节点服务器的性能消耗，也降低了节点服务器在处理调流业务时出错的概率。In the embodiment of the present invention, the node server receives the stream regulation request message sent by the terminal for video data, and sends the stream regulation request message to the core server, and the node server receives the core server, For the video data returned by the streaming request message and the identification information of the streaming service for the video data, the node server uses the identification information of the streaming service for the video data to send to the terminal The video data, thereby realizing the generation of identification information for the streaming service of video data, the node server only needs to manage a small number of identification information when managing the streaming service, which reduces the performance consumption of the node server and also reduces the cost of the node server. Probability of making mistakes when processing flow transfer business.
需要说明的是，对于方法实施例，为了简单描述，故将其都表述为一系列的动作组合，但是本领域技术人员应该知悉，本发明实施例并不受所描述的动作顺序的限制，因为依据本发明实施例，某些步骤可以采用其他顺序或者同时进行。其次，本领域技术人员也应该知悉，说明书中所描述的实施例均属于优选实施例，所涉及的动作并不一定是本发明实施例所必须的。It should be noted that, for the method embodiment, for the sake of simple description, it is expressed as a series of action combinations, but those skilled in the art should know that the embodiment of the present invention is not limited by the described action sequence, because According to the embodiment 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 belong to preferred embodiments, and the actions involved are not necessarily required by the embodiments of the present invention.
参照图3，示出了本发明的一种通信装置实施例三的结构框图，所述装置涉及终端，节点服务器以及核心服务器，所述终端与所述节点服务器连接，所述节点服务器与所述核心服务器连接，其特征在于，具体可以包括如下模块：Referring to FIG. 3 , it shows a structural block diagram of Embodiment 3 of a communication device of the present invention, the device involves a terminal, a node server and a core server, the terminal is connected to the node server, and the node server is connected to the The core server connection is characterized in that it may specifically include the following modules:
位于所述核心服务器的调流请求消息接收模块301，用于接收所述节点服务器发送的针对视频数据的调流请求消息，所述调流请求消息由所述终端发送至所述节点服务器；The flow regulation request message receiving module 301 located at the core server is configured to receive a flow regulation request message sent by the node server for video data, and the flow regulation request message is sent by the terminal to the node server;
位于所述核心服务器的标识信息获取模块302，用于根据所述调流请求消息，获取针对所述视频数据的调流业务的标识信息；An identification information acquisition module 302 located at the core server, configured to acquire identification information of a flow adjustment service for the video data according to the flow adjustment request message;
位于所述核心服务器的视频数据和标识信息发送模块303，用于向所述节点服务器发送所述视频数据和所述针对所述视频数据的调流业务的标识信息，以使所述节点服务器采用所述针对所述视频数据的调流业务的标识信息，向所述终端发送所述视频数据。The video data and identification information sending module 303 located at the core server is configured to send the video data and the identification information of the streaming service for the video data to the node server, so that the node server adopts The identification information of the streaming service for the video data is sent to the terminal.
本发明实施例中，所述标识信息获取模块包括：In the embodiment of the present invention, the identification information acquisition module includes:
位于所述核心服务器的调流业务判断子模块，用于判断是否存在针对所述视频数据的调流业务；The streaming service judging submodule located at the core server is used to judge whether there is a streaming service for the video data;
位于所述核心服务器的标识信息调用子模块，用于从所述预设存储位置中获取所述针对所述视频数据的调流业务的标识信息；An identification information calling submodule located in the core server, configured to acquire the identification information of the streaming service for the video data from the preset storage location;
位于所述核心服务器的调流业务建立子模块，用于若不存在所述针对所述视频数据的调流业务的标识信息，则指示节点服务器建立调流业务；The flow adjustment service establishment submodule located at the core server is used to instruct the node server to establish a flow adjustment service if there is no identification information of the flow adjustment service for the video data;
位于所述核心服务器的标识信息生成子模块，用于生成所述针对所述视频数据的调流业务的标识信息。The identification information generation sub-module located in the core server is configured to generate the identification information of the streaming service for the video data.
本发明实施例中，所述装置还包括位于所述核心服务器的调流业务配置模块，用于为所述终端配置所述针对所述视频数据的调流业务。In the embodiment of the present invention, the device further includes a streaming service configuration module located in the core server, configured to configure the streaming service for the video data for the terminal.
本发明实施例中，所述调流业务判断子模块包括：In the embodiment of the present invention, the sub-module for judging the flow adjustment service includes:
位于所述核心服务器的地址列表集合获取单元，用于获取调流地址列表集合；The address list set acquisition unit located in the core server is used to acquire the flow regulation address list set;
位于所述核心服务器的调流地址列表判断单元，用于从所述调流地址列表集合中，判断是否存在所述视频数据对应的调流地址列表；The flow regulation address list judging unit located in the core server is used to judge whether there is a flow regulation address list corresponding to the video data from the flow regulation address list set;
位于所述核心服务器的调流业务存在确定单元，用于若存在所述视频数据对应的调流地址列表，则确定存在针对所述视频数据的调流业务；The flow regulation service existence determination unit located in the core server is used to determine that there is a flow regulation service for the video data if there is a flow regulation address list corresponding to the video data;
位于所述核心服务器的调流业务不存在确定单元，用于若不存在所述视频数据对应的调流地址列表，则确定不存在针对所述视频数据的调流业务。The flow regulation service non-existence determination unit located in the core server is configured to determine that there is no flow regulation service for the video data if there is no flow regulation address list corresponding to the video data.
在本发明实施例中，所述标识信息生成子模块包括：In the embodiment of the present invention, the identification information generating submodule includes:
位于所述核心服务器的请求信息识别单元，用于从所述视频请求消息中，识别出所述终端请求的视频数据的请求信息；A request information identification unit located in the core server, configured to identify the request information of the video data requested by the terminal from the video request message;
位于所述核心服务器的标识信息关系表获取单元，用于获取标识信息关系表；The identification information relationship table acquisition unit located in the core server is used to acquire the identification information relationship table;
位于所述核心服务器的随机数生成单元，用于生成所述预设位数的随机数；A random number generating unit located in the core server, configured to generate a random number with the preset number of digits;
位于所述核心服务器的标识信息判断单元，用于查询所述标识信息关系表，判断是否存在与所述随机数相同的标识信息；An identification information judging unit located in the core server, configured to query the identification information relationship table, and determine whether there is identification information identical to the random number;
位于所述核心服务器的重新执行单元，用于若存在与所述随机数相同的标识信息，重新执行所述节点服务器生成所述预设位数的随机数的步骤；A re-execution unit located in the core server, configured to re-execute the step of generating the random number with the preset number of digits by the node server if there is the same identification information as the random number;
位于所述核心服务器的标识信息确定单元，用于若不存在与所述随机数相同的标识信息，将所述随机数确定为针对所述视频数据的调流业务的标识信息；An identification information determining unit located at the core server, configured to determine the random number as the identification information for the streaming service of the video data if there is no identification information identical to the random number;
位于所述核心服务器的标识信息保存单元，用于将所述视频请求消息对应的请求信息与所述针对所述视频数据的调流业务的标识信息的对应关系，保存于所述标识信息关系表中。An identification information storage unit located at the core server, configured to store the corresponding relationship between the request information corresponding to the video request message and the identification information of the streaming service for the video data in the identification information relationship table middle.
在本发明实施例中，调流业务添加子模块包括：位于所述核心服务器的业务添加消息生成与发送单元，用于生成并发送调流业务添加消息至所述节点服务器。In the embodiment of the present invention, the flow adjustment service adding sub-module includes: a service addition message generation and sending unit located in the core server, configured to generate and send a flow adjustment service addition message to the node server.
在本发明实施例中，调流业务建立子模块包括：位于所述核心服务器的业务建立消息生成与发送单元，用于生成并发送调流业务建立消息至所述节点服务器。In the embodiment of the present invention, the flow adjustment service establishment sub-module includes: a service establishment message generating and sending unit located in the core server, configured to generate and send a flow adjustment service establishment message to the node server.
参照图4，示出了本发明的一种通信装置实施例四的结构框图，所述装置涉及终端，节点服务器以及核心服务器，所述终端与所述节点服务器连接，所述节点服务器与所述核心服务器连接，其特征在于，具体可以包括如下模块：Referring to FIG. 4 , it shows a structural block diagram of Embodiment 4 of a communication device of the present invention, the device involves a terminal, a node server and a core server, the terminal is connected to the node server, and the node server is connected to the The core server connection is characterized in that it may specifically include the following modules:
所述节点服务器，所述节点服务器包括调流请求消息发送模块，视频数据和标识信息模块，视频数据发送模块；The node server, the node server includes a streaming request message sending module, a video data and identification information module, and a video data sending module;
调流请求消息发送模块401，用于接收所述终端发送针对视频数据的调流请求消息，并将所述调流请求消息发送至所述核心服务器；A flow regulation request message sending module 401, configured to receive a flow regulation request message sent by the terminal for video data, and send the flow regulation request message to the core server;
视频数据和标识信息模块402，用于接收所述核心服务器，针对所述调流请求消息返回的视频数据和针对所述视频数据的调流业务的标识信息；The video data and identification information module 402 is configured to receive the video data returned by the core server for the stream adjustment request message and the identification information of the stream adjustment service for the video data;
视频数据发送模块403，用于采用所述针对所述视频数据的调流业务的标识信息，向所述终端发送所述视频数据。The video data sending module 403 is configured to send the video data to the terminal by using the identification information of the streaming service for the video data.
在本发明实施例中，所述视频数据发送模块包括：In an embodiment of the present invention, the video data sending module includes:
调流地址列表获取子模块，用于当所述节点服务器接收所述核心服务器发送的调流业务添加消息，获取调流地址列表；The flow regulation address list acquisition submodule is used to obtain the flow regulation address list when the node server receives the flow regulation service addition message sent by the core server;
网络地址获取子模块，用于获取所述终端的网络地址；A network address obtaining submodule, configured to obtain the network address of the terminal;
第一网络地址添加子模块，用于将所述终端的网络地址添加到所述调流地址列表中；The first network address adding submodule is used to add the network address of the terminal to the list of streaming addresses;
第一视频数据以及标识信息发送子模块，用于向所述终端的网络地址发送所述视频数据以及所述针对所述视频数据的调流业务的标识信息。The first video data and identification information sending submodule is configured to send the video data and the identification information of the streaming service for the video data to the network address of the terminal.
在本发明实施例中，所述装置还包括：In an embodiment of the present invention, the device further includes:
调流地址列表建立子模块，用于当所述节点服务器接收所述核心服务器发送的调流业务建立消息，建立与所述标识信息对应的调流地址列表。The flow regulation address list establishment sub-module is used for establishing a flow regulation address list corresponding to the identification information when the node server receives the flow regulation service establishment message sent by the core server.
对于装置实施例而言，由于其与方法实施例基本相似，所以描述的比较简单，相关之处参见方法实施例的部分说明即可。As for the device embodiment, since it is basically similar to the method embodiment, the description is relatively simple, and for related parts, please refer to the part of the description of the method embodiment.
本发明实施例还提供了一种装置，包括：The embodiment of the present invention also provides a device, including:
包括处理器、存储器及存储在所述存储器上并能够在所述处理器上运行的计算机程序，该计算机程序被处理器执行时实现上述一种通信方法实施例的各个过程，且能达到相同的技术效果，为避免重复，这里不再赘述。It includes a processor, a memory, and a computer program stored on the memory and capable of running on the processor. When the computer program is executed by the processor, it implements the various processes of the above-mentioned communication method embodiment, and can achieve the same Technical effects, in order to avoid repetition, will not be repeated here.
本发明实施例还提供了一种计算机可读存储介质，计算机可读存储介质上存储计算机程序，计算机程序被处理器执行时实现上述一种通信方法实施例的各个过程，且能达到相同的技术效果，为避免重复，这里不再赘述。The embodiment of the present invention also provides a computer-readable storage medium, on which a computer program is stored. When the computer program is executed by a processor, each process of the above-mentioned communication method embodiment is realized, and the same technology can be achieved. Effect, in order to avoid repetition, will not repeat them here.
视联网是网络发展的重要里程碑，是一个实时网络，能够实现高清视频实时传输，将众多互联网应用推向高清视频化，高清面对面。The Internet of Vision is an important milestone in the development of the network. 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, high-definition face-to-face.
视联网采用实时高清视频交换技术，可以在一个网络平台上将所需的服务，如高清视频会议、视频监控、智能化监控分析、应急指挥、数字广播电视、延时电视、网络教学、现场直播、VOD点播、电视邮件、个性录制(PVR)、内网(自办)频道、智能化视频播控、信息发布等数十种视频、语音、图片、文字、通讯、数据等服务全部整合在一个系统平台，通过电视或电脑实现高清品质视频播放。The Internet of View adopts real-time high-definition video exchange technology, which can provide required services on one network platform, such as high-definition video conferencing, video surveillance, intelligent monitoring and analysis, emergency command, digital broadcast TV, time-lapse TV, online teaching, live broadcast , VOD on demand, TV mail, personalized recording (PVR), intranet (self-managed) channel, intelligent video broadcast control, information release and other dozens of video, voice, picture, text, communication, data and other services are all integrated in one System platform, realize high-definition quality video playback through TV or computer.
为使本领域技术人员更好地理解本发明实施例，以下对视联网进行介绍：In order to enable those skilled in the art to better understand the embodiments of the present invention, the Internet of Things is introduced as follows:
视联网所应用的部分技术如下所述：Some of the technologies applied in the Internet of Things are as follows:
网络技术(Network Technology)Network Technology
视联网的网络技术创新改良了传统以太网(Ethernet)，以面对网络上潜在的巨大视频流量。不同于单纯的网络分组包交换(Packet Switching)或网络电路交换(CircuitSwitching)，视联网技术采用Packet Switching满足Streaming需求。视联网技术具备分组交换的灵活、简单和低价，同时具备电路交换的品质和安全保证，实现了全网交换式虚拟电路，以及数据格式的无缝连接。The network technology innovation of the Internet of View has improved the traditional Ethernet (Ethernet) to face the potentially huge video traffic on the network. Different from pure network packet switching (Packet Switching) or network circuit switching (Circuit Switching), video networking technology uses Packet Switching to meet Streaming requirements. The Internet of Vision technology has the flexibility, simplicity and low price of packet switching, and at the same time has the quality and security guarantee of circuit switching, realizing the seamless connection of switched virtual circuits and data formats throughout the network.
交换技术(Switching Technology)Switching Technology
视联网采用以太网的异步和包交换两个优点，在全兼容的前提下消除了以太网缺陷，具备全网端到端无缝连接，直通用户终端，直接承载IP数据包。用户数据在全网范围内不需任何格式转换。视联网是以太网的更高级形态，是一个实时交换平台，能够实现目前互联网无法实现的全网大规模高清视频实时传输，将众多网络视频应用推向高清化、统一化。Video networking adopts the two advantages of Ethernet asynchronous and packet switching, eliminates the defects of Ethernet under the premise of full compatibility, has end-to-end seamless connection of the whole network, directly connects to user terminals, and directly carries IP data packets. User data does not require any format conversion within the entire network. Video networking is a more advanced form of Ethernet. It is a real-time switching platform, which can realize the real-time transmission of large-scale high-definition video in the whole network that cannot be realized by the Internet at present, and push many network video applications to high-definition and unification.
服务器技术(Server Technology)Server Technology
视联网和统一视频平台上的服务器技术不同于传统意义上的服务器，它的流媒体传输是建立在面向连接的基础上，其数据处理能力与流量、通讯时间无关，单个网络层就能够包含信令及数据传输。对于语音和视频业务来说，视联网和统一视频平台流媒体处理的复杂度比数据处理简单许多，效率比传统服务器大大提高了百倍以上。The server technology on the Internet of View and unified video platform is different from the server in the traditional sense. Its streaming media transmission is based on connection-oriented, and its data processing capability has nothing to do with traffic and communication time. A single network layer can contain information command and data transmission. For voice and video services, the complexity of video streaming and unified video platform streaming media processing is much simpler than data processing, and the efficiency is greatly improved by more than 100 times compared with traditional servers.
储存器技术(Storage Technology)Storage Technology
统一视频平台的超高速储存器技术为了适应超大容量和超大流量的媒体内容而采用了最先进的实时操作系统，将服务器指令中的节目信息映射到具体的硬盘空间，媒体内容不再经过服务器，瞬间直接送达到用户终端，用户等待一般时间小于0.2秒。最优化的扇区分布大大减少了硬盘磁头寻道的机械运动，资源消耗仅占同等级IP互联网的20％，但产生大于传统硬盘阵列3倍的并发流量，综合效率提升10倍以上。The ultra-high-speed storage technology of the unified video platform adopts the most advanced real-time operating system in order to adapt to the super-large capacity and super-large-flow media content, and maps the program information in the server command to the specific hard disk space, and the media content no longer passes through the server. It is delivered directly to the user terminal in an instant, and the user generally waits for less than 0.2 seconds. The optimized sector distribution greatly reduces the mechanical movement of the hard disk head seeking. The resource consumption is only 20% of that of IP Internet at the same level, but the concurrent traffic generated is 3 times larger than that of the traditional hard disk array, and the overall efficiency is increased by more than 10 times.
网络安全技术(Network Security Technology)Network Security Technology
视联网的结构性设计通过每次服务单独许可制、设备与用户数据完全隔离等方式从结构上彻底根除了困扰互联网的网络安全问题，一般不需要杀毒程序、防火墙，杜绝了黑客与病毒的攻击，为用户提供结构性的无忧安全网络。The structural design of the Internet of View completely eradicates the network security problems that plague the Internet through the individual licensing system for each service, complete isolation of equipment and user data, and generally does not require anti-virus programs and firewalls, preventing hackers and virus attacks , to provide users with a structured worry-free security network.
服务创新技术(Service Innovation Technology)Service Innovation Technology
统一视频平台将业务与传输融合在一起，不论是单个用户、私网用户还是一个网络的总合，都不过是一次自动连接。用户终端、机顶盒或PC直接连到统一视频平台，获得丰富多彩的各种形态的多媒体视频服务。统一视频平台采用“菜谱式”配表模式来替代传统的复杂应用编程，可以使用非常少的代码即可实现复杂的应用，实现“无限量”的新业务创新。The unified video platform integrates business and transmission together, whether it is a single user, a private network user or the sum of a network, it is just an automatic connection. User terminals, set-top boxes or PCs are directly connected to the unified video platform to obtain rich and colorful multimedia video services in various forms. The unified video platform adopts the "recipe-style" table matching mode to replace the traditional complex application programming. It can realize complex applications with very little code and realize "unlimited" new business innovations.
视联网的组网如下所述：The networking of the Internet of View is as follows:
视联网是一种集中控制的网络结构，该网络可以是树型网、星型网、环状网等等类型，但在此基础上网络中需要有集中控制节点来控制整个网络。Vision networking is a network structure with centralized control. The network can be a tree network, star network, ring network, etc., but on this basis, a centralized control node is required in the network to control the entire network.
如图5所示，视联网分为接入网和城域网两部分。As shown in Figure 5, the Internet of View is divided into two parts: the access network and the metropolitan area network.
接入网部分的设备主要可以分为3类：节点服务器，接入交换机，终端(包括各种机顶盒、编码板、存储器等)。节点服务器与接入交换机相连，接入交换机可以与多个终端相连，并可以连接以太网。The equipment in the access network can be mainly divided into three categories: node servers, access switches, and terminals (including various set-top boxes, encoding boards, memory, etc.). The node server is connected with the access switch, and the access switch can be connected with multiple terminals and can be connected with Ethernet.
其中，节点服务器是接入网中起集中控制功能的节点，可控制接入交换机和终端。节点服务器可直接与接入交换机相连，也可以直接与终端相连。Wherein, the node server is a node with centralized control function in the access network, which can control the access switches and terminals. The node server can be directly connected to the access switch, and can also be directly connected to the terminal.
类似的，城域网部分的设备也可以分为3类：城域服务器，节点交换机，节点服务器。城域服务器与节点交换机相连，节点交换机可以与多个节点服务器相连。Similarly, the devices in the MAN part can also be divided into three categories: MAN servers, node switches, and node servers. The metro server is connected to the node switch, and the node switch can be connected to multiple node servers.
其中，节点服务器即为接入网部分的节点服务器，即节点服务器既属于接入网部分，又属于城域网部分。Wherein, 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, which can control node switches and node servers. The metro server can be directly connected to the node switch, or directly connected to the node server.
由此可见，整个视联网络是一种分层集中控制的网络结构，而节点服务器和城域服务器下控制的网络可以是树型、星型、环状等各种结构。It can be seen that the entire Vision Network is a layered centralized control network structure, while the network controlled by the node server and the metro server can be in various structures such as tree, star, and ring.
形象地称，接入网部分可以组成统一视频平台(虚线圈中部分)，多个统一视频平台可以组成视联网；每个统一视频平台可以通过城域以及广域视联网互联互通。Vividly speaking, 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 the metropolitan area and the wide area video network.
视联网设备分类Classification of Internet of Things devices
1.1本发明实施例的视联网中的设备主要可以分为3类：服务器，交换机(包括以太网网关)，终端(包括各种机顶盒，编码板，存储器等)。视联网整体上可以分为城域网(或者国家网、全球网等)和接入网。1.1 The devices in the Internet of View in the embodiment of the present invention can be mainly divided into three categories: servers, switches (including Ethernet gateways), terminals (including various set-top boxes, encoding boards, memory, etc.). As a whole, the Internet of Things can be divided into a metropolitan area network (or a national network, a global network, etc.) and an access network.
1.2其中接入网部分的设备主要可以分为3类：节点服务器，接入交换机(包括以太网网关)，终端(包括各种机顶盒，编码板，存储器等)。1.2 The equipment in the access network can be mainly divided into three categories: node servers, access switches (including Ethernet gateways), terminals (including various set-top boxes, encoding boards, storage, etc.).
各接入网设备的具体硬件结构为：The specific hardware structure of each access network device is:
节点服务器：Node server:
如图6所示，主要包括网络接口模块701、交换引擎模块702、CPU模块703、磁盘阵列模块704；As shown in Figure 6, it mainly includes a network interface module 701, a switching engine module 702, a CPU module 703, and a disk array module 704;
其中，网络接口模块701，CPU模块703、磁盘阵列模块704进来的包均进入交换引擎模块702；交换引擎模块702对进来的包进行查地址表705的操作，从而获得包的导向信息；并根据包的导向信息把该包存入对应的包缓存器706的队列；如果包缓存器706的队列接近满，则丢弃；交换引擎模702轮询所有包缓存器队列，如果满足以下条件进行转发：1)该端口发送缓存未满；2)该队列包计数器大于零。磁盘阵列模块704主要实现对硬盘的控制，包括对硬盘的初始化、读写等操作；CPU模块703主要负责与接入交换机、终端(图中未示出)之间的协议处理，对地址表705(包括下行协议包地址表、上行协议包地址表、数据包地址表)的配置，以及，对磁盘阵列模块704的配置。Wherein, network interface module 701, the bag that CPU module 703, disk array module 704 come in all enters switching engine module 702; The guide information of packet stores this packet into the queue of corresponding packet cache 706; If the queue of packet cache 706 is close to full, then discards; Switching engine module 702 polls all packet cache queues, and forwards if the following conditions are met: 1) The sending buffer of the port is not full; 2) The queue packet counter is greater than zero. The disk array module 704 mainly realizes the control to the hard disk, including operations such as initialization, reading and writing to the hard disk; configuration (including downlink protocol packet address table, uplink protocol packet address table, and data packet address table), and configuration of the disk array module 704 .
接入交换机：Access switch:
如图7所示，主要包括网络接口模块(下行网络接口模块801、上行网络接口模块802)、交换引擎模块803和CPU模块804；As shown in Figure 7, mainly include network interface module (downlink network interface module 801, uplink network interface module 802), switching engine module 803 and CPU module 804;
其中，下行网络接口模块801进来的包(上行数据)进入包检测模块805；包检测模块805检测包的目地地址(DA)、源地址(SA)、数据包类型及包长度是否符合要求，如果符合，则分配相应的流标识符(stream-id)，并进入交换引擎模块803，否则丢弃；上行网络接口模块802进来的包(下行数据)进入交换引擎模块803；CPU模块804进来的数据包进入交换引擎模块803；交换引擎模块803对进来的包进行查地址表806的操作，从而获得包的导向信息；如果进入交换引擎模块803的包是下行网络接口往上行网络接口去的，则结合流标识符(stream-id)把该包存入对应的包缓存器807的队列；如果该包缓存器807的队列接近满，则丢弃；如果进入交换引擎模块803的包不是下行网络接口往上行网络接口去的，则根据包的导向信息，把该数据包存入对应的包缓存器807的队列；如果该包缓存器807的队列接近满，则丢弃。Wherein, the packet (upstream data) that the downstream network interface module 801 comes in enters the packet detection module 805; Whether the destination address (DA), the source address (SA), the data packet type and the packet length of the packet detection module 805 detection packet meet the requirements, if Meet, then distribute corresponding flow identifier (stream-id), and enter switching engine module 803, otherwise discard; The packet (downstream data) that upstream network interface module 802 comes in enters switching engine module 803; The data packet that CPU module 804 comes in Enter the switching engine module 803; the switching engine module 803 checks the operation of the address table 806 for the incoming packet, so as to obtain the orientation information of the packet; if the packet entering the switching engine module 803 goes from the downstream network interface to the upstream network interface, then in combination Flow identifier (stream-id) stores this packet into the queue of corresponding packet cache 807; If the queue of this packet cache 807 is close to full, then discards; If the packet that enters switching engine module 803 is not downlink network interface, goes up If the data packet goes to the network interface, the data packet is stored in the queue of the corresponding packet buffer 807 according to the direction information of the packet; if the queue of the packet buffer 807 is nearly full, it is discarded.
交换引擎模块803轮询所有包缓存器队列，在本发明实施例中分两种情形：Switching engine module 803 polls all packet buffer queues, divides two kinds of situations in the embodiment of the present invention:
如果该队列是下行网络接口往上行网络接口去的，则满足以下条件进行转发：1)该端口发送缓存未满；2)该队列包计数器大于零；3)获得码率控制模块产生的令牌；If the queue goes from the downlink network interface to the uplink network interface, the following conditions are met for forwarding: 1) the port sending buffer is not full; 2) the queue packet counter is greater than zero; 3) the token generated by the code rate control module is obtained ;
如果该队列不是下行网络接口往上行网络接口去的，则满足以下条件进行转发：1)该端口发送缓存未满；2)该队列包计数器大于零。If the queue does not go from the downlink network interface to the uplink network interface, the following conditions are met for forwarding: 1) the sending buffer of the port is not full; 2) the packet counter of the queue is greater than zero.
码率控制模块808是由CPU模块804来配置的，在可编程的间隔内对所有下行网络接口往上行网络接口去的包缓存器队列产生令牌，用以控制上行转发的码率。The code rate control module 808 is configured by the CPU module 804, and generates tokens for all packet buffer queues going from the downlink network interface to the uplink network interface within a programmable interval to control the uplink forwarding code rate.
CPU模块804主要负责与节点服务器之间的协议处理，对地址表806的配置，以及，对码率控制模块808的配置。The CPU module 804 is mainly responsible for protocol processing with the node server, configuration of the address table 806 , and configuration of the code rate control module 808 .
以太网协转网关：Ethernet protocol conversion gateway :
如图8所示，主要包括网络接口模块(下行网络接口模块901、上行网络接口模块902)、交换引擎模块903、CPU模块904、包检测模块905、码率控制模块908、地址表906、包缓存器907和MAC添加模块909、MAC删除模块910。As shown in Figure 8, it mainly includes network interface modules (downlink network interface module 901, uplink network interface module 902), switching engine module 903, CPU module 904, packet detection module 905, code rate control module 908, address table 906, packet Buffer 907, MAC adding module 909, and MAC deleting module 910.
其中，下行网络接口模块901进来的数据包进入包检测模块905；包检测模块905检测数据包的以太网MAC DA、以太网MAC SA、以太网length or frame type、视联网目地地址DA、视联网源地址SA、视联网数据包类型及包长度是否符合要求，如果符合则分配相应的流标识符(stream-id)；然后，由MAC删除模块910减去MAC DA、MAC SA、length or frame type(2byte)，并进入相应的接收缓存，否则丢弃；Wherein, the data packet coming in from the downlink network interface module 901 enters the packet detection module 905; the packet detection module 905 detects the Ethernet MAC DA, Ethernet MAC SA, Ethernet length or frame type, visual networking destination address DA, visual networking Source address SA, depending on whether the network data packet type and packet length meet the requirements, if so, assign a corresponding stream identifier (stream-id); then, subtract MAC DA, MAC SA, length or frame type by the MAC deletion module 910 (2byte), and enter the corresponding receiving buffer, otherwise discard;
下行网络接口模块901检测该端口的发送缓存，如果有包则根据包的视联网目地地址DA获知对应的终端的以太网MAC DA，添加终端的以太网MAC DA、以太网协转网关的MACSA、以太网length or frame type，并发送。The downlink network interface module 901 detects the sending buffer of the port, if there is a packet, the Ethernet MAC DA of the corresponding terminal is known according to the visual network destination address DA of the packet, and the Ethernet MAC DA of the terminal, the MACSA of the Ethernet protocol conversion gateway, and the MACSA of the Ethernet protocol conversion gateway are added. 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:
主要包括网络接口模块、业务处理模块和CPU模块；例如，机顶盒主要包括网络接口模块、视音频编解码引擎模块、CPU模块；编码板主要包括网络接口模块、视音频编码引擎模块、CPU模块；存储器主要包括网络接口模块、CPU模块和磁盘阵列模块。It mainly includes a network interface module, a business processing module and a CPU module; for example, a set-top box mainly includes a network interface module, an video and audio codec engine module, and a CPU module; an encoding board mainly includes a network interface module, an video and audio encoding engine module, and a CPU module; It mainly includes network interface module, CPU module and disk array module.
1.3城域网部分的设备主要可以分为2类：节点服务器，节点交换机，城域服务器。其中，节点交换机主要包括网络接口模块、交换引擎模块和CPU模块；城域服务器主要包括网络接口模块、交换引擎模块和CPU模块构成。1.3 The equipment of the metropolitan area network can be mainly divided into two categories: node server, node switch, and metropolitan area server. Among them, the node switch mainly includes a network interface module, a switching engine module and a CPU module; the metro server mainly includes a network interface module, a switching engine module and a CPU module.
2、视联网数据包定义2. Definition of Internet of Things data package
2.1接入网数据包定义2.1 Definition of access network data packet
接入网的数据包主要包括以下几部分：目的地址(DA)、源地址(SA)、保留字节、payload(PDU)、CRC。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 table below, the data packets of the access network mainly include the following parts:
其中：in:
目的地址(DA)由8个字节(byte)组成，第一个字节表示数据包的类型(例如各种协议包、组播数据包、单播数据包等)，最多有256种可能，第二字节到第六字节为城域网地址，第七、第八字节为接入网地址；The destination address (DA) consists of 8 bytes (byte), 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 byte to the sixth byte is the address of the metropolitan area network, and the seventh and eighth bytes are the address of the access network;
源地址(SA)也是由8个字节(byte)组成，定义与目的地址(DA)相同；The source address (SA) is also composed of 8 bytes (byte), and the definition is the same as that of the destination address (DA);
保留字节由2个字节组成；Reserved bytes consist of 2 bytes;
payload部分根据不同的数据报的类型有不同的长度，如果是各种协议包的话是64个字节，如果是单组播数据包话是32+1024＝1056个字节，当然并不仅仅限于以上2种；The payload part has different lengths according to different datagram types. If it is a variety of protocol packets, 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 Above 2 types;
CRC有4个字节组成，其计算方法遵循标准的以太网CRC算法。CRC consists of 4 bytes, and its calculation method follows the standard Ethernet CRC algorithm.
2.2城域网数据包定义2.2 MAN packet definition
城域网的拓扑是图型，两个设备之间可能有2种、甚至2种以上的连接，即节点交换机和节点服务器、节点交换机和节点交换机、节点交换机和节点服务器之间都可能超过2种连接。但是，城域网设备的城域网地址却是唯一的，为了精确描述城域网设备之间的连接关系，在本发明实施例中引入参数：标签，来唯一描述一个城域网设备。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 2 connections between node switches and node servers, node switches and node switches, and node switches and node servers. kind of connection. However, the MAN address of the MAN device is unique. In order to accurately describe the connection relationship between MAN devices, a parameter: label is introduced in the embodiment of the present invention to uniquely describe a MAN device.
本说明书中标签的定义和MPLS(Multi-Protocol Label Switch，多协议标签交换)的标签的定义类似，假设设备A和设备B之间有两个连接，那么数据包从设备A到设备B就有2个标签，数据包从设备B到设备A也有2个标签。标签分入标签、出标签，假设数据包进入设备A的标签(入标签)是0x0000，这个数据包离开设备A时的标签(出标签)可能就变成了0x0001。城域网的入网流程是集中控制下的入网过程，也就意味着城域网的地址分配、标签分配都是由城域服务器主导的，节点交换机、节点服务器都是被动的执行而已，这一点与MPLS的标签分配是不同的，MPLS的标签分配是交换机、服务器互相协商的结果。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 packets from device A to device B have 2 labels, the packet from device B to device A also has 2 labels. The label is divided into an incoming label and an outgoing label. Assuming that the label (incoming label) of the data packet entering device A is 0x0000, the label (outgoing label) of the 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 all dominated by the metropolitan area server, and the node switches and node servers are all passively executed. Different from MPLS label allocation, MPLS label allocation is the result of mutual negotiation between switches and servers.
如下表所示，城域网的数据包主要包括以下几部分：As shown in the table below, the data packet of the MAN mainly includes the following parts:
即目的地址(DA)、源地址(SA)、保留字节(Reserved)、标签、payload(PDU)、CRC。其中，标签的格式可以参考如下定义：标签是32bit，其中高16bit保留，只用低16bit，它的位置是在数据包的保留字节和payload之间。That is, destination address (DA), source address (SA), reserved byte (Reserved), label, payload (PDU), and CRC. Among them, the format of the label can refer to the following definition: the label is 32bit, of which the high 16bit is reserved, and only the low 16bit is used, and its position is between the reserved byte of the data packet and the payload.
本说明书中的各个实施例均采用递进的方式描述，每个实施例重点说明的都是与其他实施例的不同之处，各个实施例之间相同相似的部分互相参见即可。Each embodiment in this specification is described in a progressive manner, each embodiment focuses on the difference from other embodiments, and the same and similar parts of each embodiment can be referred to each other.
本领域内的技术人员应明白，本发明实施例的实施例可提供为方法、装置、或计算机程序产品。因此，本发明实施例可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且，本发明实施例可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。Those skilled in the art should understand that the embodiments of the present invention may be provided as methods, devices, or computer program products. Accordingly, embodiments of the invention may take the form of an entirely hardware embodiment, an entirely software embodiment, or an embodiment combining 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 present 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 present invention. It should be understood that each procedure and/or block in the flowchart and/or block diagram, and a combination of procedures and/or blocks in the flowchart and/or block diagram can be realized by computer program messages. These computer program messages may be provided to a general purpose computer, special purpose computer, embedded processor, or processor of other programmable data processing terminal equipment to produce a machine such that the messages executed by the computer or processor of other programmable data processing terminal equipment Produce means for realizing the functions specified in one or more procedures of the flowchart and/or one or more blocks of the block diagram.
这些计算机程序消息也可存储在能引导计算机或其他可编程数据处理终端设备以特定方式工作的计算机可读存储器中，使得存储在该计算机可读存储器中的消息产生包括消息装置的制造品，该消息装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。These computer program messages may also be stored in a computer-readable memory capable of directing a computer or other programmable data processing terminal to operate in a specific manner, such that the messages stored in the computer-readable memory produce an article of manufacture comprising message means, the The message device realizes the function specified in one or more procedures of the flowchart and/or one or more blocks of the block diagram.
这些计算机程序消息也可装载到计算机或其他可编程数据处理终端设备上，使得在计算机或其他可编程终端设备上执行一系列操作步骤以产生计算机实现的处理，从而在计算机或其他可编程终端设备上执行的消息提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。These computer program messages may also be loaded onto a computer or other programmable data processing terminal equipment, so that a series of operational steps are performed on the computer or other programmable terminal equipment to produce computer-implemented The message executed above provides steps for implementing the function specified in the flow chart process or processes and/or block diagram block or blocks.
尽管已描述了本发明实施例的优选实施例，但本领域内的技术人员一旦得知了基本创造性概念，则可对这些实施例做出另外的变更和修改。所以，所附权利要求意欲解释为包括优选实施例以及落入本发明实施例范围的所有变更和修改。Having described preferred embodiments of embodiments of the present invention, additional changes and modifications to these embodiments can be made by those skilled in the art once the basic inventive concept is appreciated. Therefore, the appended claims are intended to be interpreted to cover the preferred embodiment and all changes and modifications which fall within the scope of the embodiments of the present invention.
最后，还需要说明的是，在本文中，诸如第一和第二等之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来，而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、物品或者终端设备不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、物品或者终端设备所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排除在包括所述要素的过程、方法、物品或者终端设备中还存在另外的相同要素。Finally, it should also be noted that in this text, relational terms such as first and second etc. are only used to distinguish one entity or operation from another, and do not necessarily require or imply that these entities or operations, any such actual relationship or order exists. Furthermore, the term "comprises", "comprises" or any other variation thereof is intended to cover a non-exclusive inclusion such that a process, method, article, or terminal equipment comprising a set of elements includes not only those elements, but also includes elements not expressly listed. other elements identified, or also include elements inherent in such a process, method, article, or terminal equipment. Without further limitations, an element defined by the phrase "comprising a ..." does not exclude the presence of additional identical elements in the process, method, article or terminal device comprising said element.
以上对本发明所提供的一种通信方法和一种通信装置，进行了详细介绍，本文中应用了具体个例对本发明的原理及实施方式进行了阐述，以上实施例的说明只是用于帮助理解本发明的方法及其核心思想；同时，对于本领域的一般技术人员，依据本发明的思想，在具体实施方式及应用范围上均会有改变之处，综上所述，本说明书内容不应理解为对本发明的限制。A communication method and a communication device provided by the present invention have been introduced in detail above. In this paper, specific examples are used to illustrate the principle and implementation of the present invention. The description of the above embodiments is only used to help understand the present invention. The method of the invention and its core idea; at the same time, for those of ordinary skill in the art, according to the idea of the present invention, there will be changes in the specific implementation and scope of application. In summary, the content of this specification should not be understood To limit the present invention.
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201911400732.9ACN111225241B (en) | 2019-12-30 | 2019-12-30 | A communication method and device |
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201911400732.9ACN111225241B (en) | 2019-12-30 | 2019-12-30 | A communication method and device |
| Publication Number | Publication Date |
|---|---|
| CN111225241A CN111225241A (en) | 2020-06-02 |
| CN111225241Btrue CN111225241B (en) | 2023-07-28 |
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201911400732.9AActiveCN111225241B (en) | 2019-12-30 | 2019-12-30 | A communication method and device |
| Country | Link |
|---|---|
| CN (1) | CN111225241B (en) |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112565907A (en)* | 2020-11-25 | 2021-03-26 | 上海连尚网络科技有限公司 | Video acquisition method, electronic device and storage medium |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101159849A (en)* | 2007-10-19 | 2008-04-09 | 中兴通讯股份有限公司 | Living broadcast method for interactive network television system |
| CN101309157A (en)* | 2007-05-16 | 2008-11-19 | 上海贝尔阿尔卡特股份有限公司 | Multicast service management method and apparatus thereof |
| CN102195788A (en)* | 2011-05-25 | 2011-09-21 | 中国联合网络通信集团有限公司 | Application layer multicast system and streaming media data processing method |
| CN110572433A (en)* | 2019-08-05 | 2019-12-13 | 视联动力信息技术股份有限公司 | A video scheduling method, system and device |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN100479433C (en)* | 2005-11-14 | 2009-04-15 | 华为技术有限公司 | Base station in wide-band wireless access-in system and method for realizing multi-cast business |
| CN100426886C (en)* | 2006-03-17 | 2008-10-15 | 华为技术有限公司 | Method for realizing stream media service |
| CN101155053B (en)* | 2006-09-25 | 2011-03-30 | 华为技术有限公司 | Method and system for realizing multicast/broadcast service |
| CN100466832C (en)* | 2006-09-30 | 2009-03-04 | 中兴通讯股份有限公司 | A multicast member management method for wireless local area network IP multicast frame transmission |
| CN101175198A (en)* | 2006-11-02 | 2008-05-07 | 华为技术有限公司 | Network TV service control method and system, terminal and application processing module |
| CN101222414B (en)* | 2007-01-11 | 2012-08-08 | 华为技术有限公司 | Device, system and method for implementing multicast communication |
| CN101321152B (en)* | 2007-06-06 | 2013-06-12 | 上海贝尔阿尔卡特股份有限公司 | Method and apparatus for receiving multimedia business and auxiliarily receiving multimedia business |
| CN100547965C (en)* | 2007-06-29 | 2009-10-07 | 中国科学院计算技术研究所 | A method for allocating multicast connections in a broadband wireless communication network |
| CN101335907B (en)* | 2007-06-29 | 2011-04-06 | 上海贝尔阿尔卡特股份有限公司 | Method and apparatus for controlling multicast service transmission in base station |
| CN101141688A (en)* | 2007-10-12 | 2008-03-12 | 中兴通讯股份有限公司 | Channel multicast address generating method and transmitting method |
| CN101442435B (en)* | 2008-12-25 | 2012-04-04 | 华为技术有限公司 | Service data management method and device of distributed system and distributed system |
| KR101365417B1 (en)* | 2009-08-19 | 2014-02-20 | 한국전자통신연구원 | System and method for providing iptv service |
| CN101771553B (en)* | 2010-03-01 | 2012-08-29 | 浙江大学 | Method for transmitting multimedia multicasting service |
| CN102215456B (en)* | 2010-04-07 | 2013-11-06 | 华为技术有限公司 | Multicast control method and device |
| CN105025388A (en)* | 2014-04-25 | 2015-11-04 | 中国电信股份有限公司 | System and method for video content transmission |
| CN105897827A (en)* | 2015-11-27 | 2016-08-24 | 乐视云计算有限公司 | Server node, local area network server cluster and realizing method thereof |
| CN105847399A (en)* | 2016-04-25 | 2016-08-10 | 乐视控股（北京）有限公司 | Server scheduling method and device |
| CN110392094B (en)* | 2019-06-03 | 2021-03-19 | 网宿科技股份有限公司 | Method for acquiring service data and converged CDN system |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101309157A (en)* | 2007-05-16 | 2008-11-19 | 上海贝尔阿尔卡特股份有限公司 | Multicast service management method and apparatus thereof |
| CN101159849A (en)* | 2007-10-19 | 2008-04-09 | 中兴通讯股份有限公司 | Living broadcast method for interactive network television system |
| CN102195788A (en)* | 2011-05-25 | 2011-09-21 | 中国联合网络通信集团有限公司 | Application layer multicast system and streaming media data processing method |
| CN110572433A (en)* | 2019-08-05 | 2019-12-13 | 视联动力信息技术股份有限公司 | A video scheduling method, system and device |
| Publication number | Publication date |
|---|---|
| CN111225241A (en) | 2020-06-02 |
| Publication | Publication Date | Title |
|---|---|---|
| CN111431966B (en) | Service request processing method and device, electronic equipment and storage medium | |
| CN110475102A (en) | A kind of monitoring data processing method and system based on view networking | |
| CN109996086A (en) | A kind of view networking service method for inquiring status and device | |
| CN110602266A (en) | Domain name resolution method and system | |
| CN110224988B (en) | Image data processing method, system and device and storage medium | |
| CN110650171B (en) | Video networking service scheduling system and method | |
| CN111131911B (en) | A kind of multicast method and device | |
| CN111245733B (en) | Data transmission method and device | |
| CN110266577A (en) | A method for establishing a tunnel and a visual networking system | |
| CN110519549A (en) | A kind of conference terminal list obtaining method and system | |
| CN111064923B (en) | Monitoring data processing method and device and storage medium | |
| CN110784683B (en) | A management method, device and storage medium for monitoring resources | |
| CN110166363B (en) | A kind of multicast link monitoring method and device | |
| CN111225241B (en) | A communication method and device | |
| CN109861929B (en) | Data caching processing method and device | |
| CN110636044A (en) | Network access method, system, device and storage medium of a virtual terminal | |
| CN110417792A (en) | Communication method, system, gateway device and storage medium | |
| CN110120937A (en) | Resource acquiring method, system, equipment and computer readable storage medium | |
| CN110289974A (en) | Data stream processing method, system and device, and storage medium | |
| CN110336710A (en) | Terminal testing method, system, device and storage medium | |
| CN110099307A (en) | A kind of joint connecting method, view networking and computer readable storage medium | |
| CN111355916B (en) | Method, device, device and storage medium for establishing video networking communication connection | |
| CN110995517B (en) | Data transmission method and device, electronic equipment and storage medium | |
| CN110636110B (en) | Method and device for monitoring data flow regulation | |
| CN110557594A (en) | Video call processing method and device and storage medium |
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant | ||
| CP03 | Change of name, title or address | ||
| CP03 | Change of name, title or address | Address after:33rd Floor, No.1 Huasheng Road, Yuzhong District, Chongqing 400013 Patentee after:VISIONVERA INFORMATION TECHNOLOGY Co.,Ltd. Country or region after:China Address before:100000 Beijing Dongcheng District Qinglong Hutong 1 Song Hua Building A1103-1113 Patentee before:VISIONVERA INFORMATION TECHNOLOGY Co.,Ltd. Country or region before:China |