CN113485821A - High-reliability video conference system, control method thereof and storage medium - Google Patents
High-reliability video conference system, control method thereof and storage medium Download PDFInfo
- Publication number
- CN113485821A CN113485821A CN202111046561.1A CN202111046561A CN113485821A CN 113485821 A CN113485821 A CN 113485821A CN 202111046561 A CN202111046561 A CN 202111046561A CN 113485821 A CN113485821 A CN 113485821A
- Authority
- CN
- China
- Prior art keywords
- service
- cluster
- node
- communication node
- client
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/48—Program initiating; Program switching, e.g. by interrupt
- G06F9/4806—Task transfer initiation or dispatching
- G06F9/4843—Task transfer initiation or dispatching by program, e.g. task dispatcher, supervisor, operating system
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/90—Details of database functions independent of the retrieved data types
- G06F16/95—Retrieval from the web
- G06F16/955—Retrieval from the web using information identifiers, e.g. uniform resource locators [URL]
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/50—Allocation of resources, e.g. of the central processing unit [CPU]
- G06F9/5005—Allocation of resources, e.g. of the central processing unit [CPU] to service a request
- G06F9/5027—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resource being a machine, e.g. CPUs, Servers, Terminals
- G06F9/505—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resource being a machine, e.g. CPUs, Servers, Terminals considering the load
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/542—Event management; Broadcasting; Multicasting; Notifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/544—Buffers; Shared memory; Pipes
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/546—Message passing systems or structures, e.g. queues
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2209/00—Indexing scheme relating to G06F9/00
- G06F2209/54—Indexing scheme relating to G06F9/54
- G06F2209/541—Client-server
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2209/00—Indexing scheme relating to G06F9/00
- G06F2209/54—Indexing scheme relating to G06F9/54
- G06F2209/547—Messaging middleware
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Software Systems (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Databases & Information Systems (AREA)
- Multimedia (AREA)
- Data Mining & Analysis (AREA)
- Two-Way Televisions, Distribution Of Moving Picture Or The Like (AREA)
- Telephonic Communication Services (AREA)
Abstract
The invention discloses a high-reliability video conference system, a control method thereof and a storage medium, wherein the system comprises: the cluster scheduling node acquires a service connection request sent by a client, selects a target cluster communication node according to the cluster load, and sends the service connection request to the target cluster communication node; the target cluster communication node establishes connection with the client according to the service connection request; the cluster scheduling node forwards the service request sent by the client to the target cluster communication node, and the target cluster communication node selects a target cluster service node according to cluster load balance and sends service acquisition information to the target cluster service node; the cluster service node returns service information to the target cluster communication node according to the service acquisition information; and the target cluster communication node returns the service information. By implementing the invention, the high-efficiency transmission of the video conference service information is realized; and the system can effectively work in a low-bandwidth network environment, and meets the requirements of users on real-time and high-efficiency transmission.
Description
Technical Field
The invention relates to the technical field of computer network application services, in particular to a high-reliability video conference system, a control method thereof and a storage medium.
Background
The current multimedia network communication technology is rapidly developed, the video conference technology is rapidly and gradually developed, and the application field is wider. First, as the international organization for standardization sets a series of standards regarding video encoding, particularly the MPEG4 standard of ISO/IEC, it becomes possible to provide high-quality images for video conferences over low-bandwidth networks. Secondly, due to the increasing available bandwidth, the improving network performance, and the widespread use of computers and personal mobile terminals, people are more inclined to change the traditional offline meeting into online meeting. Therefore, software-based video conference systems are rapidly and smoothly developing, and have been widely deployed and applied in various industries.
The software-based video conference Web is a major hotspot direction in the development of multimedia industry in the last two years, and the Web video conference is a problem that a user does not need to download software or install plug-ins at a client in advance, and does not need to reduce the security level of a system or worry about the version compatibility of a browser. The video conference webpage is directly opened, interaction based on audio, video and data can be carried out in all directions, and the interaction difficulty of the video conference is greatly reduced by the mode.
Most of the traditional existing systems work in a single-server mode, and the deployment is relatively simple. However, as the application scale is enlarged and the number of users is increased, the service gradually exposes the disadvantages of low operation efficiency, small user capacity, poor expandability and the like. Therefore, there is a great need to develop a video conference system that meets the requirements of high load capacity, real-time efficient transmission, and the like.
Disclosure of Invention
In view of this, embodiments of the present invention provide a high-reliability video conference system, a control method thereof, and a storage medium, so as to solve the technical problem in the prior art that the transmission efficiency of a video conference system is low.
The technical scheme provided by the invention is as follows:
a first aspect of an embodiment of the present invention provides a high-reliability video conference system, including: the method comprises the steps that a cluster scheduling node, a plurality of cluster communication nodes and a plurality of cluster service nodes are used, the cluster scheduling node obtains a service connection request sent by a client, selects a target cluster communication node according to cluster load and sends the service connection request to the target cluster communication node; the target cluster communication node establishes connection with a client according to the service connection request; the cluster scheduling node forwards a service request sent by the client to the target cluster communication node, the target cluster communication node selects a target cluster service node according to cluster load balance, and sends service acquisition information to the target cluster service node according to a uniform resource location address in the service request; the target cluster service node returns service information to the target cluster communication node according to the service acquisition information; and the target cluster communication node sends the service information to the client.
Optionally, the cluster scheduling node includes an Apache component, the cluster communication node includes a Jetty component, a load balancing group is formed by a plurality of Jetty components, the Apache component manages the load balancing group, the Apache component receives a service connection request sent by a client, and queries a load condition of each Jetty component in the load balancing group according to the service connection request to determine a target cluster communication node; and the Apache component updates the load information in the load balancing group according to the load change of the target cluster communication node.
Optionally, after establishing connection with a client according to the service connection request, the target trunking communication node creates connected session state information in a memory, sends a unique identifier to the client according to the session state information, and backs up the session state information to other trunking communication nodes; and after the Apache component detects that the Jetty component of the target cluster communication node fails, controlling the backup cluster communication node to process the service request of the client.
Optionally, Red5 software is installed in both the cluster communication node and the cluster service node, the cluster communication node is an Edge node in a Red5 cluster, the cluster service node is an Origin node in a Red5 cluster, and the cluster communication component is connected with the corresponding cluster service node according to a Red5 embedded Mina component; when a new cluster communication node is added in the Red5 cluster, the new cluster communication node broadcasts an access message and initiates connection to a corresponding cluster service node; when a new cluster service node is added to the Red5 cluster, the associated cluster communication node connects with the new cluster service node.
Optionally, after the cluster communication node establishes connection with the client, a service request of the client is monitored according to Red5, and after the service request of the client is received, connection is established with a corresponding cluster service node, and the service request is sent to the cluster service node; and the cluster service node returns a request resource according to the service request.
Optionally, when the cluster communication node receives service information returned by the cluster service node, the data packet in the service information is stored in a cache region; and when the cluster communication node receives a new service request, judging whether data corresponding to the service request exists in the cache region, and if so, sending a data packet in the cache region to the client.
Optionally, the target cluster communication node generates shared data according to the received service request and the returned service information, and sends the shared data to the cluster scheduling node; and when other cluster communication nodes receive the same service request as the shared data, acquiring the shared data from the cluster scheduling node, and responding to the service request.
Optionally, the working mode of the cluster communication node is a working mode of a connection state machine; deploying a video conference application program on the cluster service node, and distributing video conference content access service according to an access rule; and the identity identifiers and the performance parameters of the cluster service nodes and the cluster scheduling nodes are stored in a knowledge base of the intelligent integrated identifier network.
A second aspect of the embodiments of the present invention provides a method for controlling a high-reliability video conference system, including: controlling a cluster scheduling node to acquire a service connection request sent by a client; controlling to send the service connection request to a target cluster communication node, wherein the target cluster communication node is selected according to a cluster load; controlling the target cluster communication node to establish connection with a client according to the service connection request; controlling the cluster scheduling node to forward the service request sent by the client to the target cluster communication node; controlling the target cluster communication node to select a target cluster service node according to cluster load balance, and sending service acquisition information to the target cluster service node according to a uniform resource location address in the service request; controlling the target cluster service node to return service information to the target cluster communication node according to the service acquisition information; and controlling the target cluster communication node to send the service information to the client.
A third aspect of the embodiments of the present invention provides a computer-readable storage medium storing computer instructions for causing a computer to execute the high-reliability video conference system according to any one of the second aspect and the second aspect of the embodiments of the present invention.
The technical scheme provided by the invention has the following effects:
the high-reliability video conference system, the control method thereof and the storage medium provided by the embodiment of the invention are provided with the cluster scheduling node, the cluster communication node and the cluster service node, and the high-efficiency transmission of video conference service information is realized through the communication between the nodes; meanwhile, a load balancing mechanism is integrated in the system, and the cluster scheduling node selects an optimal target cluster communication node for information transmission according to the cluster load, so that the system can effectively work in a low-bandwidth network environment, and the real-time and efficient transmission requirements of users are met.
The high-reliability video conference system provided by the embodiment of the invention adopts Red5 as a server for bearing HRVC application programs, and performs cluster management on the HRVC application programs in a mode of external interconnection and dynamic injection. For the system, the HRVC application program is not required to be changed, the flexibility of the system structure is improved, and the complexity of deployment is reduced. For users, the service provided by the original node is not greatly different from the service provided by the HRVC system, but the performance of the HRVC system is greatly improved compared with the performance of the original node.
In the high-reliability video conference system provided by the embodiment of the invention, the plurality of service nodes exist simultaneously and work cooperatively, and when a certain service node fails, other service nodes can still be used without failure, for example, when one cluster communication node fails, other cluster communication nodes can still be used. The method can ensure the continuous operation of the whole cluster system. Meanwhile, the system can also transfer the fault, continue the service to the user, and improve the availability reliability of the system (the availability reliability mainly refers to the average time without fault of the system, namely the time ratio used when the system is engaged in productive activity).
The high-reliability video conference system provided by the embodiment of the invention can improve the performance by changing the structure of the system and the like. In the system, all software, hardware and other matched structures for providing services can be regarded as resources, and the requirements of the HRVC system on large load capacity and real-time and high efficiency of transmission can be met by increasing the used storage components, increasing the number of service nodes, upgrading the software and even changing the system structure of the system.
The HRVC system provided by the invention realizes the expansion of the original HRVC system and overcomes the defects of low operation efficiency, small user capacity, poor expansibility and the like. Besides providing video conference service, mechanisms such as load balancing, fault transfer, node dynamic management, shared data stream allocation and the like are integrated, the system architecture of the video conference is optimized, the reliability and the expandability of the system are improved, the requirements of users on large load capacity and real-time and efficient transmission are met, and the system can effectively work in a low-bandwidth network environment.
The high-reliability video conference system provided by the embodiment of the invention is developed based on the Red5 streaming media server and is a Web video conference system supported by an intelligent melt identification network system. The system adopts Flash to develop a human-computer interaction interface, realizes background management of the server based on Java EE technology, and performs data interaction with the client through protocols such as HTTP, RTMP and the like. The service supports multiple functions of audio and video communication, electronic whiteboards, character chatting, document conversion, desktop sharing and the like, room modes in various forms such as conference rooms, chatting rooms and the like are arranged at the webpage end, and a user can directly open a video conference webpage to obtain corresponding services only by using a browser with flash installed at the client.
Drawings
In order to more clearly illustrate the embodiments of the present invention or the technical solutions in the prior art, the drawings used in the description of the embodiments or the prior art will be briefly described below, and it is obvious that the drawings in the following description are some embodiments of the present invention, and other drawings can be obtained by those skilled in the art without creative efforts.
Fig. 1 is a block diagram of a highly reliable video conferencing system according to an embodiment of the present invention;
fig. 2 is a flowchart of a control method of a highly reliable video conference system according to an embodiment of the present invention;
fig. 3 is a schematic structural diagram of a computer-readable storage medium provided in accordance with an embodiment of the present invention.
Detailed Description
In order to make the objects, technical solutions and advantages of the embodiments of the present invention clearer, the technical solutions in the embodiments of the present invention will be clearly and completely described below with reference to the drawings in the embodiments of the present invention, and it is obvious that the described embodiments are some, but not all, embodiments of the present invention. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present invention.
An embodiment of the present invention provides a high-reliability video conference system, as shown in fig. 1, including: the method comprises the steps that a cluster scheduling node, a plurality of cluster communication nodes and a plurality of cluster service nodes are used, the cluster scheduling node obtains a service connection request sent by a client, selects a target cluster communication node according to cluster load and sends the service connection request to the target cluster communication node; the target cluster communication node establishes connection with a client according to the service connection request; the cluster scheduling node forwards the service request sent by the client to the target cluster communication node, the target cluster communication node selects a target cluster service node according to cluster load balance, and sends service acquisition information to the target cluster service node according to a uniform resource location address in the service request; the target cluster service node returns service information to the target cluster communication node according to the service acquisition information; and the target cluster communication node sends the service information to the client.
The high-reliability video conference system provided by the embodiment of the invention is provided with the cluster scheduling node, the cluster communication node and the cluster service node, and the high-efficiency transmission of video conference service information is realized through the communication among the nodes; meanwhile, a load balancing mechanism is integrated in the system, and the cluster scheduling node selects an optimal target cluster communication node for information transmission according to the cluster load, so that the system can effectively work in a low-bandwidth network environment, and the real-time and efficient transmission requirements of users are met.
As an optional implementation manner of the embodiment of the present invention, a Group Dispatch Node (GDN) is used as an access entry of a High Reliable Video Conference system (HRVC), is connected to a client downward, is connected to a cluster communication Node upward, and is also responsible for controlling and managing the entire cluster system. When a client sends a service request to the system, the service request is sent to the cluster scheduling node, and the cluster scheduling node can dynamically monitor the condition of the internal load of the cluster and select the optimal cluster communication node as a target communication node to forward the client request. In addition, the cluster scheduling node can also detect the connection state among all cluster communication nodes in the system, and automatically complete the isolation of the fault node. In addition, the cluster scheduling node can also reduce the transmission of redundant data in the system network, can allocate the data flow direction among all communication nodes in the cluster, and caches the shared data. The knowledge base in the intelligent fusion identification network can inquire the information such as the identity identification, the performance parameters and the like of the cluster scheduling node.
The intelligent fusion identification network longitudinally associates the service level and the network level of the existing Internet so as to facilitate the service and the network space to cooperatively mobilize and intelligently fuse the resources to which the service and the network space belong. Meanwhile, the intelligent melt identification network transversely decouples the service space from the network space, comprises an intelligent plane formed by a service intelligent object and a network intelligent object, and comprises an operation plane formed by a service operation object and a network operation object, so as to realize the separation of control management and function execution, and facilitate the dynamic adjustment of the service and the network according to requirements. In addition, the intelligent identification network introduces a knowledge space containing a service/network object identification base and a service/network object knowledge base to identify various entities and virtual objects and carry out fine-grained explanation on static and dynamic attribute characteristics and requirement description of the entities and the virtual objects. The service/network object identification library comprises two types of information, namely ID (identifier) and SA (static attribute), wherein the ID is a whole-network unique identity symbol of the service/network object, and the SA is static multidimensional attribute quantitative information of the service/network object, such as CPU performance, memory capacity, link bandwidth, required security level, required service quality level and the like. The service/network object knowledge base is used for collecting dynamic multidimensional attribute quantitative information of the service/network object.
The cluster Communication Node (GCN) is connected with the cluster scheduling Node downward and with the cluster service Node upward, and the function of information interaction agent is realized in the system. When a Client sends a service request to a system, a cluster communication node receives the service connection request forwarded by a cluster scheduling node and establishes session connection with the Client, and then acquires corresponding service from the cluster service node, so that the concurrent load of the cluster service node can be effectively shared. In addition, the working mode used by the cluster communication node is the working mode of the connection state machine, so that faults can be isolated, namely if a certain cluster communication node has a fault, other nodes in the cluster can also normally operate, and the fault tolerance rate of the system is high.
The cluster Service Node (GSN) deploys the HRVC videoconference application, connects with the cluster communication Node downward, and is the actual provider of the Service. The information sharing among a plurality of cluster service nodes is avoided, and the video conference content access service is distributed according to the access rule, wherein the access rule is established by the cluster communication nodes under the cluster framework. The information such as the identity identification, the performance parameters and the like of the cluster service node can be inquired in a knowledge base in the intelligent integrated identification network.
In one embodiment, the cluster scheduling node, the cluster communication node and the cluster service node are all deployed with corresponding application software, and the main functions of the system are realized in a software control mode. The application software deployed on the cluster scheduling node is Apache or Terracotta Server. The application software deployed on the cluster communication node is Red5 or Terracotta Driver. The application software deployed on the cluster service node is Red 5.
As an optional implementation manner of the embodiment of the present invention, an Apache component (GDN) on a cluster scheduling nodeApache) And Red5 Embedded Jetty component (denoted as GCN) on the Cluster communication nodeRed5 Jetty) And the access control module of the high-reliability video conference system is used for being responsible for load balancing and fault transfer in the system. Specifically, when a client sends a service connection request to the system, the GDNApacheThe component intercepts the service connection request. The component then transparently passes the message to the appropriate Red5 embedded Jetty component in the GCN. Then, GCNRed5 JettyThe component provides a Web server through which request messages sent by clients are received and processed. GDN (GDN)ApacheThe component is a control scheduling center of an access control module and does not need to be applied to a clientAnd the change is carried out, so that the relative independence between the client and the server is ensured.
In one embodiment, multiple GCNsRed5 JettyForming a load balancing group, GDNApacheThe component is responsible for maintaining the load balancing group and uniformly managing the GCNRed5 JettyThe provided Web response service is a control scheduling center of the access control module. Adding new GCN in load balancing group if necessaryRed5 JettyComponent, needs to register in advance. Specifically, when Client sends HTTP service connection request, GDN (scheduling center) is controlledApacheIs responsible for intercepting the connection request from the client to the service and inquiring the GCN in the current clusterRed5 JettySelecting an optimal node according to the load condition, and then forwarding the service connection request of the Client to the Target node; the node Target GCNRed5 JettyAnd receiving and processing the forwarded service connection request, and establishing connection with the Client. In addition, GCNRed5 JettyAfter establishing connection with the client, actively sending to the GDNApacheSending payload information, GDNApacheAccording to GCNRed5 JettyUpdating the GCN maintained by itselfRed5 JettyLoad information.
In one embodiment, the access control module can also implement a failover mechanism for the system, specifically by using the GCN's in each GCNRed5 JettyWith session information replication therebetween, i.e. at each GCNRed5 JettyAnd its backup node. Specifically, when the Client and the GCN are connectedRed5 JettyAfter connection establishment, GCNRed5 JettyCreating the Session state information of the connection in the memory, generating a unique identifier Session ID according to the Session state information, sending the unique identifier to the client, and backing up the Session state information to other GCNs at preset time intervalsRed5 Jetty. GDN as control dispatching centerApacheDetection of GCNRed5 JettyAfter failure, backup GCN in load balancing group can be controlledRed5 JettyThe next Client request transmission is processed immediately. Since session state information has already been backed up, the client and the backup GCNRed5 JettyNewly established connectionThe previous session state can be restored and properly processed.
As an optional implementation manner of the embodiment of the present invention, the cluster communication node and the cluster service node constitute a service providing module of the system. Wherein, the cluster communication node and the cluster service node are both installed with Red5 software, the GCN is set as Edge node in Red5 cluster and is recorded as GCNEdge(ii) a The GSN corresponds to the Origin node, and an HRVC video conference application program is deployed on the Origin node and is recorded as the GSNOrigin. When the service providing function is realized, the Red5 embedded Mina component in different GCN nodes is connected with the Red5 embedded Mina component in different GSN nodes and the information interaction is carried out.
In an embodiment, when a new cluster communication node is added to the Red5 cluster, the new cluster communication node broadcasts an access message and initiates a connection to a corresponding cluster service node; meanwhile, after connection, all nodes update their own communication lists. When a new cluster service node is added to the Red5 cluster, the new cluster service node broadcasts a connection to the associated cluster communication node. GCN associated with the nodeEdgeThe node will automatically connect with it and if the connection fails, the connection will be resumed every time. It is noted here that different GSNsOriginAnd no information interaction is carried out between the nodes. GCN in Red5 cluster during operation of service provisioning moduleEdgeAnd GSNOriginThe nodes start the related process to periodically and continuously inquire and monitor the connection state of other nodes, and if some node is newly added or quitted, the mode can ensure that the communication list of each node is updated in time.
In an embodiment, after the trunking communication node establishes connection with the client, according to the service request of Red5 monitored by the client, when the service request of the client is received, a related process is started to periodically and continuously connect the corresponding trunking service node, and meanwhile, the trunking service node establishes monitoring and waits for connection from the trunking communication node. After the connection is established, the cluster communication node sends the service request to the cluster service node and waits for the return of the requested resource; and after receiving the request message, the cluster service node returns the requested resource to the cluster communication node. And the cluster communication node forwards the returned request resource to the Client.
In one embodiment, the GCNEdgeThe node maintains a cache when it receives a request from the GSNOriginThe node may store the data packet in a cache, the GCN if there is a request from the clientEdgeThe node can reply to it very quickly. GCN if the cache does not have the resources desired by the clientEdgeWill go to GSNOriginA data packet is requested. GCNEdgeTo GSNOriginThe request packet sent includes many types, including metadata packets in addition to the actual packet. For some data packets, such as audio-video data packets, GSNOriginThe node sends some metadata packets with index numbers to GCNEdgeFor maintaining buffers without sending actual content.
Specifically, the above caching process may be implemented as follows: the Client sends a service request to the GCN and the data is received into the cache of the Edge component of Red5 in the GCN. Secondly, the Edge component of Red5 in GCN and the Origin component of Red5 in GSN interact information, and GSN returns corresponding service information to GCN. The GCN then returns service information to the Client.
As an optional implementation manner of the embodiment of the present invention, the cluster scheduling node and the cluster communication node constitute a shared data management module of the system. The shared data management module realizes the sharing of data in the system, thereby reducing the data transmission process. Because the Red5 is deployed on the cluster communication node and the Terracotta component is deployed on the cluster scheduling node, data between the GDN and each GCN can be managed uniformly through the Terracotta cluster and the Red5 cluster, and data sharing is achieved. Specifically, the Terracotta cluster work mode has a master mode and a slave mode, and the GCN serves as the master mode and is marked as the GCNTerracotta DriverGDN is configured as slave mode, denoted GDNTerracotta Server。
In one embodiment, the data management mechanism in the shared data management module can be implemented as follows: when the cluster scheduling node sends a service request of a client to a target cluster communication node, the target communication node returns service information of the cluster service node according to the service request, then shared data is generated according to the received service request and the returned service information, and the shared data is sent to the cluster scheduling node; and when other cluster communication nodes receive the same service request as the shared data, acquiring the shared data from the cluster scheduling node, and responding to the service request.
Therefore, the shared information generated by the GCN is uniformly managed and scheduled by the GDN, and other GCNs in the cluster do not need to be notified in a broadcasting mode. The GDN can deliver the shared data information according to the service requirement of the GCN, and when the cluster does not change the shared information or receives the service request, no data is transmitted between GCN nodes, so that the load pressure of an HRVC internal network can be greatly reduced, the requirement of the conventional video conference system on high throughput is met, and the video conference system can effectively work in a large-scale high-load network environment.
The high-reliability video conference system provided by the embodiment of the invention adopts Red5 as a server for bearing HRVC application programs, and performs cluster management on the HRVC application programs in a mode of external interconnection and dynamic injection. For the system, the HRVC application program is not required to be changed, the flexibility of the system structure is improved, and the complexity of deployment is reduced. For users, the service provided by the original node is not greatly different from the service provided by the HRVC system, but the performance of the HRVC system is greatly improved compared with the performance of the original node.
In the high-reliability video conference system provided by the embodiment of the invention, the plurality of service nodes exist simultaneously and work cooperatively, and when a certain service node fails, other service nodes can still be used without failure, for example, when one cluster communication node fails, other cluster communication nodes can still be used. The method can ensure the continuous operation of the whole cluster system. Meanwhile, the system can also transfer the fault, continue the service to the user, and improve the availability reliability of the system (the availability reliability mainly refers to the average time without fault of the system, namely the time ratio used when the system is engaged in productive activity).
The high-reliability video conference system provided by the embodiment of the invention can improve the performance by changing the structure of the system and the like. In the system, all software, hardware and other matched structures for providing services can be regarded as resources, and the requirements of the HRVC system on large load capacity and real-time and high efficiency of transmission can be met by increasing the used storage components, increasing the number of service nodes, upgrading the software and even changing the system structure of the system.
The HRVC system provided by the invention realizes the expansion of the original HRVC system and overcomes the defects of low operation efficiency, small user capacity, poor expansibility and the like. Besides providing video conference service, mechanisms such as load balancing, fault transfer, node dynamic management, shared data stream allocation and the like are integrated, the system architecture of the video conference is optimized, the reliability and the expandability of the system are improved, the requirements of users on large load capacity and real-time and efficient transmission are met, and the system can effectively work in a low-bandwidth network environment.
The high-reliability video conference system provided by the embodiment of the invention is developed based on the Red5 streaming media server and is a Web video conference system supported by an intelligent melt identification network system. The system adopts Flash to develop a human-computer interaction interface, realizes background management of the server based on Java EE technology, and performs data interaction with the client through protocols such as HTTP, RTMP and the like. The service supports multiple functions of audio and video communication, electronic whiteboards, character chatting, document conversion, desktop sharing and the like, room modes in various forms such as conference rooms, chatting rooms and the like are arranged at the webpage end, and a user can directly open a video conference webpage to obtain corresponding services only by using a browser with flash installed at the client.
An embodiment of the present invention further provides a control method for a high-reliability video conference system, as shown in fig. 2, where the control method can be applied to the high-reliability video conference system in the foregoing embodiment, and the control method includes the following steps:
step S101: controlling a cluster scheduling node to acquire a service connection request sent by a client; the cluster scheduling Node (GDN) is used as an access entry of a High Reliable Video Conference system (HRVC), is connected to a client in a downward direction, is connected to a cluster communication Node in an upward direction, and is also responsible for controlling and managing the whole cluster system. When a client sends a service request to the system, the service request is sent to the cluster scheduling node, and the cluster scheduling node can dynamically monitor the condition of the internal load of the cluster and select the optimal cluster communication node as a target communication node to forward the client request. In addition, the cluster scheduling node can also detect the connection state among all cluster communication nodes in the system, and automatically complete the isolation of the fault node. In addition, the cluster scheduling node can also reduce the transmission of redundant data in the system network, can allocate the data flow direction among all communication nodes in the cluster, and caches the shared data. The knowledge base in the intelligent fusion identification network can inquire the information such as the identity identification, the performance parameters and the like of the cluster scheduling node.
Step S102: controlling to send the service connection request to a target cluster communication node, wherein the target cluster communication node is selected according to a cluster load; the Group Communication Node (GCN) is connected to the Group scheduling Node downward and to the Group service Node upward, and the function of the information exchange agent is implemented in the system. When a Client sends a service request to a system, a cluster communication node receives the service connection request forwarded by a cluster scheduling node and establishes session connection with the Client, and then acquires corresponding service from the cluster service node, so that the concurrent load of the cluster service node can be effectively shared. In addition, the working mode used by the cluster communication node is the working mode of the connection state machine, so that faults can be isolated, namely if a certain cluster communication node has a fault, other nodes in the cluster can also normally operate, and the fault tolerance rate of the system is high.
Step S103: controlling the target cluster communication node to establish connection with a client according to the service connection request; specifically, when the connection is established, the Client and the target cluster communication node implement protocol handshake, and the cluster communication node establishes the connection and maintains the current connection state, so that the ranges displayed by the uniform resource locator addresses can be connected with each other. The url (uniform Resource locator) is included in the service connection request sent by the client.
Step S104: controlling the cluster scheduling node to forward the service request sent by the client to the target cluster communication node; specifically, after the target cluster communication node establishes a connection with the client, the cluster scheduling node may send a service request sent by the client to the target cluster communication node. The service request may be request information sent by the client to request the service resource.
Step S105: and controlling the target cluster communication node to select a target cluster service node according to cluster load balance, and sending service acquisition information to the target cluster service node according to the uniform resource positioning address in the service request. Specifically, the cluster communication node uses the uniform resource location address transmitted by the Client, and then acquires the corresponding service from the cluster service node. When the cluster communication node selects the cluster service node to acquire the service information, the corresponding cluster service node can be selected according to the load balancing principle, and the service acquisition information is sent to the corresponding cluster service node.
Step S106: controlling the cluster service node to return service information to the target cluster communication node according to the service acquisition information; specifically, the cluster service node distributes the video conference content access service according to the access rule and returns service information to the cluster communication node.
Step S107: and controlling the target cluster communication node to send the service information to the client.
The control method of the high-reliability video conference system provided by the embodiment of the invention adopts the cluster scheduling node, the cluster communication node and the cluster service node, and realizes the high-efficiency transmission of the video conference service information through the communication between the nodes; meanwhile, a load balancing mechanism is integrated in the system, and the cluster scheduling node selects an optimal target cluster communication node for information transmission according to the cluster load, so that the system can effectively work in a low-bandwidth network environment, and the real-time and efficient transmission requirements of users are met.
For a detailed description of the functions of the control method of the high-reliability video conference system provided by the embodiment of the present invention, reference is made to the description of the high-reliability video conference system in the above embodiment.
An embodiment of the present invention further provides a storage medium, as shown in fig. 3, on which a computer program 601 is stored, where the instructions, when executed by a processor, implement the steps of the high-reliability video conference system in the foregoing embodiment. The storage medium is also stored with audio and video stream data, characteristic frame data, an interactive request signaling, encrypted data, preset data size and the like. The storage medium may be a magnetic Disk, an optical Disk, a Read-Only Memory (ROM), a Random Access Memory (RAM), a Flash Memory (Flash Memory), a Hard Disk (Hard Disk Drive, abbreviated as HDD) or a Solid State Drive (SSD), etc.; the storage medium may also comprise a combination of memories of the kind described above.
It will be understood by those skilled in the art that all or part of the processes of the methods of the embodiments described above can be implemented by a computer program, which can be stored in a computer-readable storage medium, and when executed, can include the processes of the embodiments of the methods described above. The storage medium may be a magnetic Disk, an optical Disk, a Read-Only Memory (ROM), a Random Access Memory (RAM), a Flash Memory (Flash Memory), a Hard Disk (Hard Disk Drive, abbreviated as HDD), a Solid State Drive (SSD), or the like; the storage medium may also comprise a combination of memories of the kind described above.
Although the embodiments of the present invention have been described in conjunction with the accompanying drawings, those skilled in the art may make various modifications and variations without departing from the spirit and scope of the invention, and such modifications and variations fall within the scope defined by the appended claims.
Claims (10)
1. A highly reliable video conferencing system, comprising: a cluster scheduling node, a plurality of cluster communication nodes and a plurality of cluster service nodes,
the cluster scheduling node acquires a service connection request sent by a client, selects a target cluster communication node according to cluster load, and sends the service connection request to the target cluster communication node;
the target cluster communication node establishes connection with a client according to the service connection request;
the cluster scheduling node forwards a service request sent by the client to the target cluster communication node, the target cluster communication node selects a target cluster service node according to cluster load balance, and sends service acquisition information to the target cluster service node according to a uniform resource location address in the service request;
the target cluster service node returns service information to the target cluster communication node according to the service acquisition information;
and the target cluster communication node sends the service information to the client.
2. The highly reliable video conferencing system of claim 1, wherein the cluster scheduling node comprises an Apache component, the cluster communication node comprises a Jetty component, a plurality of Jetty components form a load balancing group, an Apache component manages the load balancing group,
the Apache component receives a service connection request sent by a client, inquires the load condition of each Jetty component in the load balancing group according to the service connection request, and determines a target cluster communication node;
and the Apache component updates the load information in the load balancing group according to the load change of the target cluster communication node.
3. The highly reliable video conferencing system of claim 2,
after the target cluster communication node establishes connection with a client according to the service connection request, creating connected session state information in a memory, sending a unique identifier to the client according to the session state information, and backing up the session state information to other cluster communication nodes;
and after the Apache component detects that the Jetty component of the target cluster communication node fails, controlling the backup cluster communication node to process the service request of the client.
4. The high-reliability video conference system according to claim 1, wherein Red5 software is installed in both the cluster communication node and the cluster service node, the cluster communication node is an Edge node in a Red5 cluster, the cluster service node is an Origin node in a Red5 cluster, and the cluster communication component is connected with the corresponding cluster service node according to a Red5 embedded Mina component;
when a new cluster communication node is added in the Red5 cluster, the new cluster communication node broadcasts an access message and initiates connection to a corresponding cluster service node;
when a new cluster service node is added to the Red5 cluster, the associated cluster communication node connects with the new cluster service node.
5. The highly reliable video conferencing system of claim 4,
after the cluster communication node is connected with the client, monitoring a service request of the client according to Red5, after receiving the service request of the client, establishing connection with the corresponding cluster service node, and sending the service request to the cluster service node;
and the cluster service node returns a request resource according to the service request.
6. The highly reliable video conferencing system of claim 1,
when the cluster communication node receives the service information returned by the cluster service node, the data packet in the service information is stored in a cache region;
and when the cluster communication node receives a new service request, judging whether data corresponding to the service request exists in the cache region, and if so, sending a data packet in the cache region to the client.
7. The highly reliable video conferencing system of claim 1,
the target cluster communication node generates shared data according to the received service request and the returned service information, and sends the shared data to the cluster scheduling node;
and when other cluster communication nodes receive the same service request as the shared data, acquiring the shared data from the cluster scheduling node, and responding to the service request.
8. The highly reliable video conferencing system of claim 1,
the working mode of the cluster communication node is the working mode of a connection state machine;
deploying a video conference application program on the cluster service node, and distributing video conference content access service according to an access rule;
and the identity identifiers and the performance parameters of the cluster service nodes and the cluster scheduling nodes are stored in a knowledge base of the intelligent integrated identifier network.
9. A control method of a high-reliability video conference system is characterized by comprising the following steps:
controlling a cluster scheduling node to acquire a service connection request sent by a client;
controlling to send the service connection request to a target cluster communication node, wherein the target cluster communication node is selected according to a cluster load;
controlling the target cluster communication node to establish connection with a client according to the service connection request;
controlling the cluster scheduling node to forward the service request sent by the client to the target cluster communication node;
controlling the target cluster communication node to select a target cluster service node according to cluster load balance, and sending service acquisition information to the target cluster service node according to a uniform resource location address in the service request;
controlling the target cluster service node to return service information to the target cluster communication node according to the service acquisition information;
and controlling the target cluster communication node to send the service information to the client.
10. A computer-readable storage medium characterized in that the computer-readable storage medium stores computer instructions for causing the computer to execute the control method of the highly reliable video conference system according to claim 9.
Priority Applications (2)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111046561.1A CN113485821A (en) | 2021-09-08 | 2021-09-08 | High-reliability video conference system, control method thereof and storage medium |
| PCT/CN2021/126265 WO2023035374A1 (en) | 2021-09-08 | 2021-10-26 | Highly reliable video conferencing system, control method therefor, and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111046561.1A CN113485821A (en) | 2021-09-08 | 2021-09-08 | High-reliability video conference system, control method thereof and storage medium |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN113485821A true CN113485821A (en) | 2021-10-08 |
Family
ID=77947336
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202111046561.1A Pending CN113485821A (en) | 2021-09-08 | 2021-09-08 | High-reliability video conference system, control method thereof and storage medium |
Country Status (2)
| Country | Link |
|---|---|
| CN (1) | CN113485821A (en) |
| WO (1) | WO2023035374A1 (en) |
Cited By (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114070889A (en) * | 2021-11-10 | 2022-02-18 | 北京百度网讯科技有限公司 | Configuration method, traffic forwarding method, device, storage medium, and program product |
| CN114153580A (en) * | 2021-11-25 | 2022-03-08 | 邦道科技有限公司 | Cross-multi-cluster work scheduling method and device |
| CN115801877A (en) * | 2022-11-15 | 2023-03-14 | 联洋国融(北京)科技有限公司 | Data transmission platform and method |
| WO2023035374A1 (en) * | 2021-09-08 | 2023-03-16 | 北京交通大学 | Highly reliable video conferencing system, control method therefor, and storage medium |
Citations (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103699447A (en) * | 2014-01-08 | 2014-04-02 | 北京航空航天大学 | Cloud computing-based transcoding and distribution system for video conference |
Family Cites Families (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US11165868B2 (en) * | 2017-03-30 | 2021-11-02 | Microsoft Technology Licensing, Llc | Systems and methods for achieving session stickiness for stateful cloud services with non-sticky load balancers |
| CN111355731B (en) * | 2020-02-28 | 2022-09-30 | 北京奇艺世纪科技有限公司 | Resource access method, device, resource access system, equipment and storage medium |
| CN112015544A (en) * | 2020-06-30 | 2020-12-01 | 苏州浪潮智能科技有限公司 | Load balancing method, device and equipment of k8s cluster and storage medium |
| CN113485821A (en) * | 2021-09-08 | 2021-10-08 | 北京交通大学 | High-reliability video conference system, control method thereof and storage medium |
-
2021
- 2021-09-08 CN CN202111046561.1A patent/CN113485821A/en active Pending
- 2021-10-26 WO PCT/CN2021/126265 patent/WO2023035374A1/en unknown
Patent Citations (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103699447A (en) * | 2014-01-08 | 2014-04-02 | 北京航空航天大学 | Cloud computing-based transcoding and distribution system for video conference |
Non-Patent Citations (2)
| Title |
|---|
| 孙涛: "面向云的视频会议系统设计与实现", 《中国优秀硕士学位论文全文数据库 信息科技辑（电子期刊）》 * |
| 张宏科 等: "智融标识网络基础研究", 《电子学报》 * |
Cited By (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2023035374A1 (en) * | 2021-09-08 | 2023-03-16 | 北京交通大学 | Highly reliable video conferencing system, control method therefor, and storage medium |
| CN114070889A (en) * | 2021-11-10 | 2022-02-18 | 北京百度网讯科技有限公司 | Configuration method, traffic forwarding method, device, storage medium, and program product |
| CN114070889B (en) * | 2021-11-10 | 2023-11-14 | 北京百度网讯科技有限公司 | Configuration method, traffic forwarding device, storage medium, and program product |
| CN114153580A (en) * | 2021-11-25 | 2022-03-08 | 邦道科技有限公司 | Cross-multi-cluster work scheduling method and device |
| CN115801877A (en) * | 2022-11-15 | 2023-03-14 | 联洋国融(北京)科技有限公司 | Data transmission platform and method |
Also Published As
| Publication number | Publication date |
|---|---|
| WO2023035374A1 (en) | 2023-03-16 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN113485821A (en) | High-reliability video conference system, control method thereof and storage medium | |
| EP3490224B1 (en) | Data synchronization method and system | |
| US10367852B2 (en) | Multiplexed demand signaled distributed messaging | |
| JP4848275B2 (en) | Method for managing streaming media services | |
| USRE44560E1 (en) | Data processing system, information processing apparatus, data processing method and computer program | |
| CA2515652C (en) | Systems and methods for collaborative communication | |
| JP4845321B2 (en) | Distributed edge network architecture | |
| US20070025363A1 (en) | Distributed system for delivery of information via a digital network | |
| CN111615066A (en) | Distributed micro-service registration and calling method based on broadcast | |
| US8812718B2 (en) | System and method of streaming data over a distributed infrastructure | |
| CN105681462A (en) | Cluster system based on message router, and data communication transfer method | |
| WO2018040168A1 (en) | Distributed-cache synchronization method, apparatus, and system | |
| Do et al. | Robust video-on-demand streaming in peer-to-peer environments | |
| US9473316B2 (en) | Resource consumption reduction via meeting affinity | |
| CN112671554A (en) | Node fault processing method and related device | |
| CN111756780B (en) | Method for synchronizing connection information and load balancing system | |
| CN114640633B (en) | Load balancer, realization method thereof, load balancing method and gateway system | |
| CN107438098B (en) | Dynamic content distribution method and system | |
| CN112104789B (en) | Cross-center seat automatic switching method, device, equipment and storage medium | |
| CN114143569B (en) | Webpage recording and live broadcasting method and system | |
| CN114827097A (en) | Communication network construction method and device and computer equipment | |
| CN108023772B (en) | Abnormal node repairing method, device and related equipment | |
| CN116886672A (en) | Conference capacity adaptive processing method, server and readable storage medium | |
| CN111083210A (en) | Streaming media service scheduling method and system | |
| CN116016695A (en) | Data transmission method and device for cooperative service between nodes |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| RJ01 | Rejection of invention patent application after publication | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20211008 |