CN113381990B - Method and system for intercommunication between on-demand terminals - Google Patents
Method and system for intercommunication between on-demand terminals Download PDFInfo
- Publication number
- CN113381990B CN113381990B CN202110621194.7A CN202110621194A CN113381990B CN 113381990 B CN113381990 B CN 113381990B CN 202110621194 A CN202110621194 A CN 202110621194A CN 113381990 B CN113381990 B CN 113381990B
- Authority
- CN
- China
- Prior art keywords
- target
- demand
- terminal
- signaling
- signaling server
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000000034 method Methods 0.000 title claims description 30
- 230000011664 signaling Effects 0.000 claims abstract description 218
- 230000004044 response Effects 0.000 claims description 33
- 238000010586 diagram Methods 0.000 description 4
- 230000009471 action Effects 0.000 description 3
- 230000008569 process Effects 0.000 description 3
- 239000002699 waste material Substances 0.000 description 2
- 230000005540 biological transmission Effects 0.000 description 1
- 230000003111 delayed effect Effects 0.000 description 1
- 230000003993 interaction Effects 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 230000000750 progressive effect Effects 0.000 description 1
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L65/00—Network arrangements, protocols or services for supporting real-time applications in data packet communication
- H04L65/60—Network streaming of media packets
- H04L65/61—Network streaming of media packets for supporting one-way streaming services, e.g. Internet radio
- H04L65/612—Network streaming of media packets for supporting one-way streaming services, e.g. Internet radio for unicast
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L65/00—Network arrangements, protocols or services for supporting real-time applications in data packet communication
- H04L65/60—Network streaming of media packets
- H04L65/75—Media network packet handling
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
- H04L67/104—Peer-to-peer [P2P] networks
- H04L67/1044—Group management mechanisms
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
- H04L67/104—Peer-to-peer [P2P] networks
- H04L67/1044—Group management mechanisms
- H04L67/1046—Joining mechanisms
Landscapes
- Engineering & Computer Science (AREA)
- Multimedia (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Physics & Mathematics (AREA)
- Computing Systems (AREA)
- Mathematical Physics (AREA)
- Theoretical Computer Science (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
When the on-demand terminal needs to order a target video, a signaling server connected with the on-demand terminal firstly determines terminal identifications of all target on-demand terminals with the target video, then inquires an IP address and a port of a target signaling server connected with each target on-demand terminal from a Redis cluster according to the terminal identifications, and connects the signaling server with each target signaling server based on the IP address and the port of each target signaling server to enable the on-demand terminal to be communicated with each target on-demand terminal. The establishment of the intercommunication among the on-demand terminals in the invention does not need to forward the signaling message through the Redis cluster, so that the time spent on the intercommunication among the on-demand terminals can not be influenced when the number of the on-demand terminals is more and more, thereby improving the data communication efficiency among the on-demand terminals to a certain extent.
Description
Technical Field
The invention relates to the technical field of on-demand terminals, in particular to a method and a system for mutual communication between on-demand terminals.
Background
Currently, when a video is requested by a video-on-demand terminal, the video-on-demand terminal checks a target video-on-demand terminal with the video from a background P2P (Peer to Peer) system, and sends a signaling message carrying a terminal identifier of the target video-on-demand terminal to a signaling Server, the signaling Server forwards the signaling message to a Remote Dictionary Server (Redis) cluster, and forwards the signaling message to all signaling servers through a message queue of the Redis cluster, each signaling Server determines whether each connected video-on-demand terminal is matched with the terminal identifier according to the terminal identifier in the signaling message, and when the signaling message is matched, the signaling Server forwards the signaling message to the target video-on-demand terminal.
Therefore, the communication among all the on-demand terminals is realized by the Redis cluster forwarding signaling message. However, as the number of the on-demand terminals increases, the signaling messages that the Redis cluster needs to forward also increases, and the situation that the forwarding of the signaling messages by the Redis cluster is delayed is easy to occur, so that the communication between the on-demand terminals needs to take a long time, and the data communication efficiency between the on-demand terminals is further affected.
Disclosure of Invention
In view of this, the present invention discloses a method and a system for intercommunication between on-demand terminals, so as to implement that after determining terminal identifiers of all target on-demand terminals having target videos, a signaling server connected with the on-demand terminals directly queries an IP address and a port of a target signaling server connected with each target on-demand terminal from a Redis cluster based on the terminal identifiers, thereby implementing that the signaling server connected with the on-demand terminals is connected with each target server based on the IP address and the port of each target signaling server, and further implementing intercommunication between the on-demand terminals needing to request the target videos and the target on-demand terminals having the target videos.
A method for mutual communication between on-demand terminals is applied to a signaling server, and the method comprises the following steps:
determining terminal identifications of all target on-demand terminals with target videos required to be on-demand by on-demand terminals, wherein the on-demand terminals are connected with the signaling server;
inquiring the IP address and the port of a target signaling server connected with each target on-demand terminal from a Redis cluster according to the terminal identification;
and connecting the signaling server with each target signaling server based on the IP address and the port of each target signaling server, so that the on-demand terminal and each target on-demand terminal can communicate with each other.
Optionally, the determining the terminal identifiers of all target on-demand terminals that have target videos that are required to be on-demand by the on-demand terminal specifically includes:
acquiring a signaling message sent by the on-demand terminal, wherein the signaling message contains a unique identifier of the target video;
and acquiring the terminal identifications of all target on-demand terminals with the target video from a scheduling server based on the signaling message.
Optionally, the connecting the signaling server with each target signaling server based on the IP address and the port of each target signaling server, so that the on-demand terminal and each target on-demand terminal communicate with each other, specifically includes:
establishing connection with each target signaling server based on the IP address and port of each target signaling server;
forwarding a signaling message sent by the on-demand terminal to the corresponding target on-demand terminal through each target signaling server, wherein the signaling message contains the unique identifier of the target video;
acquiring a response message sent by each target on-demand terminal through the corresponding target signaling server, wherein the response message is generated after each target on-demand terminal determines that the target video exists;
and forwarding the response message to the on-demand terminal, so that the on-demand terminal communicates with the target on-demand terminal which sends the response message based on the response message.
Optionally, a P2P connection is established between the on-demand terminal and each target on-demand terminal.
A system for intercommunication between on-demand terminals, which is applied to a signaling server, the system comprising:
the determining unit is used for determining the terminal identifications of all target on-demand terminals with target videos required to be on-demand by the on-demand terminals, and the on-demand terminals are connected with the signaling server;
the query unit is used for querying the IP address and the port of a target signaling server connected with each target on-demand terminal from the Redis cluster according to the terminal identifier;
and the intercommunication establishing unit is used for connecting the signaling server with each target signaling server based on the IP address and the port of each target signaling server so as to enable the on-demand terminal to communicate with each target on-demand terminal.
Optionally, the determining unit is specifically configured to:
acquiring a signaling message sent by the on-demand terminal, wherein the signaling message contains a unique identifier of the target video;
and acquiring the terminal identifications of all target on-demand terminals with the target video from a scheduling server based on the signaling message.
Optionally, the mutual communication establishing unit specifically includes:
a connection establishing subunit, configured to establish a connection with each of the target signaling servers based on the IP address and the port of each of the target signaling servers;
the information forwarding unit is used for forwarding a signaling message sent by the on-demand terminal to the corresponding target on-demand terminal through each target signaling server, wherein the signaling message contains the unique identifier of the target video;
an obtaining subunit, configured to obtain a response message sent by each target on-demand terminal through the corresponding target signaling server, where the response message is generated after each target on-demand terminal determines that the target video exists;
and the forwarding subunit is used for forwarding the response message to the on-demand terminal, so that the on-demand terminal communicates with the target on-demand terminal which sends the response message based on the response message.
Optionally, a P2P connection is established between the on-demand terminal and each of the target on-demand terminals.
According to the technical scheme, when the on-demand terminal needs to order the target video, the signaling server connected with the on-demand terminal firstly determines the terminal identifications of all target on-demand terminals with the target video, then inquires the IP address and the port of the target signaling server connected with each target on-demand terminal from a Redis cluster according to the terminal identifications, and connects the signaling server with each target signaling server based on the IP address and the port of each target signaling server to enable the on-demand terminal to be communicated with each target on-demand terminal. Therefore, after the terminal identifications of all target on-demand terminals with target videos are determined, the signaling server can directly inquire the IP address and the port of the target signaling server connected with each target on-demand terminal from the Redis cluster based on the terminal identifications, so that the signaling server connected with the on-demand terminal is connected with each target server based on the IP address and the port of each target signaling server, and further mutual communication between the on-demand terminal needing to play the target videos and the target on-demand terminal with the target videos is realized. The Redis cluster is only used for providing the IP address and the port of the target signaling server, and the establishment of mutual communication among the on-demand terminals does not need to forward the signaling message through the Redis cluster, so that the time spent on mutual communication among the on-demand terminals can not be influenced when the number of the on-demand terminals is more and more, and the data communication efficiency among the on-demand terminals is improved to a certain extent.
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, it is obvious that the drawings in the following description are only embodiments of the present invention, and for those skilled in the art, other drawings can be obtained according to the disclosed drawings without creative efforts.
Fig. 1 is a flowchart of a method for intercommunication between on-demand terminals according to an embodiment of the present invention;
FIG. 2 is a flowchart of a method for communication between on-demand terminals and each target on-demand terminal according to an embodiment of the present invention;
FIG. 3 is a diagram illustrating an example of intercommunication among on-demand terminals according to an embodiment of the present invention;
fig. 4 is a schematic structural diagram of a system for intercommunication among on-demand terminals according to an embodiment of the present invention.
Detailed Description
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 only a part of the embodiments of the present invention, and not all of the embodiments. 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.
The embodiment of the invention discloses a method and a system for intercommunication between on-demand terminals, which are used for realizing that a signaling server connected with the on-demand terminals directly inquires an IP address and a port of a target signaling server connected with each target on-demand terminal from a Redis cluster based on terminal identifications after determining the terminal identifications of all target on-demand terminals with target videos, thereby realizing that the signaling server connected with the on-demand terminals is connected with each target server based on the IP address and the port of each target signaling server, and further realizing intercommunication between the on-demand terminals needing to request the target videos and the target on-demand terminals with the target videos.
Referring to fig. 1, a flowchart of a method for intercommunication between on-demand terminals disclosed in the embodiment of the present invention is applied to a signaling server, and the method includes:
step S101, determining terminal identifications of all target on-demand terminals with target videos which are required to be on-demand by on-demand terminals;
in practical application, the on-demand terminal and the signaling server are specifically connected through a TCP (Transmission Control Protocol).
When the on-demand terminal needs to play a certain target video, other on-demand terminals with the target video need to be determined first, and the embodiment determines the other on-demand terminals with the target video as the target on-demand terminals, so that the target video is obtained from the target on-demand terminals. In practical application, the terminal identifications of all target on-demand terminals with the target video can be obtained from the scheduling server.
The terminal identifier may be a terminal ID.
Step S102, inquiring the IP address and the port of a target signaling server connected with each target on-demand terminal from a Redis cluster according to the terminal identification;
all free on-demand terminal nodes and corresponding target signaling servers are recorded in the Redis cluster, and the IP address and the port of each target signaling server are recorded so as to forward the signaling message sent by the on-demand terminal to each target signaling server.
It should be noted that the Redis cluster includes a master Redis and a plurality of slave rediss connected to the master Redis.
Step S103, based on the IP address and the port of each target signaling server, the signaling server is connected with each target signaling server, so that the on-demand terminal and each target on-demand terminal are communicated with each other.
In this embodiment, the on-demand terminal that needs to request the target video is connected to the signaling server that executes the method for communicating with the on-demand terminal, and one target on-demand terminal is connected to one target signaling server. When the on-demand terminal is connected with the target on-demand terminal, the on-demand terminal can directly acquire the required target video from the target on-demand terminal.
In practical applications, a P2P connection may be established between the on-demand terminal and the target on-demand.
To sum up, the invention discloses a method for intercommunication between on-demand terminals, when the on-demand terminal needs to order a target video, a signaling server connected with the on-demand terminal firstly determines terminal identifications of all target on-demand terminals with the target video, then inquires an IP address and a port of a target signaling server connected with each target on-demand terminal from a Redis cluster according to the terminal identifications, and connects the signaling server with each target signaling server based on the IP address and the port of each target signaling server, so that the on-demand terminal and each target on-demand terminal can be intercommunicated. Therefore, after the terminal identifications of all target on-demand terminals with target videos are determined, the signaling server can directly inquire the IP address and the port of the target signaling server connected with each target on-demand terminal from the Redis cluster based on the terminal identifications, so that the signaling server connected with the on-demand terminal is connected with each target server based on the IP address and the port of each target signaling server, and further mutual communication between the on-demand terminal needing to play the target videos and the target on-demand terminal with the target videos is realized. The Redis cluster is only used for providing the IP address and the port of the target signaling server, and the establishment of mutual communication among the on-demand terminals does not need to forward the signaling message through the Redis cluster, so that the time spent on mutual communication among the on-demand terminals can not be influenced when the number of the on-demand terminals is more and more, and the data communication efficiency among the on-demand terminals is improved to a certain extent.
To further optimize the above embodiment, step S101 may specifically include:
acquiring a signaling message sent by an on-demand terminal, wherein the signaling message contains a unique identifier of a target video;
and acquiring the terminal identifications of all target on-demand terminals with the target video from a scheduling server based on the signaling message.
In this embodiment, when the on-demand terminal needs to order the target video, the on-demand terminal sends a signaling message to the connected signaling server to request to watch the target video, and the signaling server requests to acquire the terminal identifiers of all target on-demand terminals with the target video from the scheduling server according to the unique identifier of the target video included in the signaling message.
To further optimize the above embodiment, referring to fig. 2, a flowchart of a method for mutual communication between a video-on-demand terminal and each target video-on-demand terminal disclosed in the embodiment of the present invention, that is, step S103 may specifically include:
step S201, based on the IP address and the port of each target signaling server, establishing connection with each target signaling server;
after the signaling server queries the IP address and port of the target signaling server connected to each target on-demand terminal from the Redis cluster, the signaling server may establish a connection with each target signaling server based on the IP address and port of each target signaling server.
Step S202, a signaling message sent by the on-demand terminal is forwarded to the corresponding target on-demand terminal through each target signaling server;
the signaling message includes a unique identifier of the target video, and the unique identifier of the target video may be an ID of the target video.
Step S203, acquiring a response message sent by each target on-demand terminal through the corresponding target signaling server;
wherein the response message is generated after each of the target on-demand terminals determines that the target video is available.
Step S204, the response message is forwarded to the on-demand terminal, so that the on-demand terminal and the target on-demand terminal which sends the response message communicate with each other based on the response message.
When the on-demand terminal and the target on-demand terminal are communicated with each other, the target on-demand terminal can directly send the target video to the on-demand terminal.
In summary, the invention predetermines the target on-demand terminal with the target video, the IP address and the port of the target signaling server connected thereto, so that the signaling server in the invention can directly forward the signaling message sent by the on-demand terminal to the corresponding target on-demand terminal through each target signaling server. Compared with the traditional scheme that the Redis cluster needs to forward the signaling message sent by the on-demand terminal to all the signaling servers, the method and the system for transmitting the signaling message do not need to forward the signaling message to the signaling server without the target video, so that the waste of communication resources is reduced to a certain extent.
To facilitate an understanding of the method of communicating between on-demand terminals, a specific embodiment of the present invention is also provided.
Referring to fig. 3, an exemplary diagram of intercommunication among on-demand terminals disclosed in the embodiment of the present invention is assumed that a user a is a certain on-demand terminal, the user a has a file1 video and a file2 video, the user a currently needs to on-demand a file3 video (i.e., a target video), a user B (i.e., a target video terminal) has a file2 video and a file3 video, and the user a and the user B are not connected to the same server.
The user A is connected to the signaling server A, the signaling server A is a public network address, the user A sends a signaling message to the signaling server A to request to watch the file3 video, and the signaling message contains the unique identification of the file3 video.
The signaling server a inquires all target on-demand terminals (including the user B) with the file3 video from the scheduling server a based on the signaling message, and the scheduling server a returns the terminal identifications of all target on-demand terminals with the file3 video to the signaling server a.
And the signaling server A queries the IP address and the port of the target signaling server connected with each target on-demand terminal from the Redis cluster according to the terminal identifiers of all the target on-demand terminals.
Assuming that the target on-demand terminal only comprises a user B, a signaling server A sends a signaling message sent by the user A to the signaling server B according to an IP address and a port of the signaling server B (public network address) connected with the user B, the signaling server B sends a response message to the signaling server A after determining that the video of file3 exists, the signaling server A forwards the response message to the user A, and the user A establishes P2P connection with the user B after receiving the response message, so that the user B sends the video of file3 to the user A.
Corresponding to the method embodiment, the invention also discloses a system for mutual communication between the on-demand terminals.
Referring to fig. 4, a schematic structural diagram of a system for intercommunication between on-demand terminals disclosed in the embodiment of the present invention, the system is applied to a signaling server, and the system includes:
a determining unit 301, configured to determine terminal identifiers of all target on-demand terminals that have target videos that are required to be on-demand by an on-demand terminal, where the on-demand terminal is connected to the signaling server;
when the on-demand terminal needs to play a certain target video, other on-demand terminals with the target video need to be determined first, and the embodiment determines the other on-demand terminals with the target video as the target on-demand terminals, so that the target video is obtained from the target on-demand terminals. In practical applications, the terminal identifiers of all target on-demand terminals with the target videos can be obtained from the scheduling server.
The terminal identifier may be a terminal ID.
A query unit 302, configured to query, according to the terminal identifier, an IP address and a port of a target signaling server connected to each target on-demand terminal from a Redis cluster;
all free on-demand terminal nodes and corresponding target signaling servers are recorded in the Redis cluster, and the IP address and the port of each target signaling server are recorded so as to forward the signaling message sent by the on-demand terminal to each target signaling server.
It should be noted that the Redis cluster includes a master Redis and a plurality of slave rediss connected to the master Redis.
An intercommunication establishing unit 303, configured to connect the signaling server with each target signaling server based on the IP address and the port of each target signaling server, so that the on-demand terminal and each target on-demand terminal communicate with each other.
In the embodiment, the on-demand terminal which needs to request the target video is connected with the signaling server which executes the intercommunication method between the on-demand terminals, one target on-demand terminal is connected with one target signaling server, and when the on-demand terminal is not connected with the target on-demand terminal, the on-demand terminal needs to perform information interaction with the target on-demand terminal through the signaling server and the target signaling server. When the on-demand terminal is connected with the target on-demand terminal, the on-demand terminal can directly acquire the required target video from the target on-demand terminal.
In practical applications, a P2P connection may be established between the on-demand terminal and the target on-demand.
To sum up, the invention discloses a system for intercommunication between on-demand terminals, when the on-demand terminals need to order target videos, a signaling server connected with the on-demand terminals firstly determines terminal identifications of all target on-demand terminals with the target videos, then inquires the IP address and port of the target signaling server connected with each target on-demand terminal from a Redis cluster according to the terminal identifications, and connects the signaling server with each target signaling server based on the IP address and port of each target signaling server, so that the on-demand terminals and each target on-demand terminal can intercommunicate. Therefore, after the terminal identifications of all target on-demand terminals with target videos are determined, the signaling server can directly inquire the IP address and the port of the target signaling server connected with each target on-demand terminal from the Redis cluster based on the terminal identifications, so that the signaling server connected with the on-demand terminal is connected with each target server based on the IP address and the port of each target signaling server, and further mutual communication between the on-demand terminal needing to play the target videos and the target on-demand terminal with the target videos is realized. The Redis cluster is only used for providing the IP address and the port of the target signaling server, and the establishment of mutual communication among the on-demand terminals does not need to forward the signaling message through the Redis cluster, so that the time spent on mutual communication among the on-demand terminals can not be influenced when the number of the on-demand terminals is more and more, and the data communication efficiency among the on-demand terminals is improved to a certain extent.
To further optimize the above embodiment, the determination unit 301 may specifically be adapted to
Acquiring a signaling message sent by the on-demand terminal, wherein the signaling message contains a unique identifier of the target video;
and acquiring the terminal identifications of all target video-on-demand terminals with the target video from a scheduling server based on the signaling message.
In this embodiment, when the on-demand terminal needs to order the target video, the on-demand terminal sends a signaling message to the connected signaling server to request to watch the target video, and the signaling server requests to acquire the terminal identifiers of all target on-demand terminals with the target video from the scheduling server according to the unique identifier of the target video included in the signaling message.
To further optimize the above embodiment, the mutual communication establishing unit 303 may specifically include:
a connection establishing subunit, configured to establish a connection with each of the target signaling servers based on the IP address and the port of each of the target signaling servers;
the information forwarding unit is used for forwarding a signaling message sent by the on-demand terminal to the corresponding target on-demand terminal through each target signaling server, wherein the signaling message contains the unique identifier of the target video;
an obtaining subunit, configured to obtain a response message sent by each target on-demand terminal through the corresponding target signaling server, where the response message is generated after each target on-demand terminal determines that the target video exists;
and the forwarding subunit is used for forwarding the response message to the on-demand terminal, so that the on-demand terminal communicates with the target on-demand terminal which sends the response message based on the response message.
When the on-demand terminal and the target on-demand terminal are communicated with each other, the target on-demand terminal can directly send the target video to the on-demand terminal.
In summary, the invention predetermines the target on-demand terminal with the target video, the IP address and the port of the target signaling server connected thereto, so that the signaling server in the invention can directly forward the signaling message sent by the on-demand terminal to the corresponding target on-demand terminal through each target signaling server. Compared with the traditional scheme that the Redis cluster needs to forward the signaling message sent by the on-demand terminal to all the signaling servers, the method and the system for sending the video-on-demand message do not need to forward the signaling message to the signaling server without the target video, and therefore waste of communication resources is reduced to a certain extent.
It should be noted that, for the specific working principle of each component in the system embodiment, please refer to the corresponding part of the method embodiment, which is not described herein again.
Finally, it should also be noted that, in this document, relational terms such as first and second, and the like are used solely to distinguish one entity or action from another entity or action without necessarily requiring or implying any actual such relationship or order between such entities or actions. Also, the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus. Without further limitation, an element defined by the phrase "comprising an … …" does not exclude the presence of other identical elements in a process, method, article, or apparatus that comprises the element.
The embodiments in the present description are described in a progressive manner, each embodiment focuses on differences from other embodiments, and the same and similar parts among the embodiments are referred to each other.
The previous description of the disclosed embodiments is provided to enable any person skilled in the art to make or use the present invention. Various modifications to these embodiments will be readily apparent to those skilled in the art, and the generic principles defined herein may be applied to other embodiments without departing from the spirit or scope of the invention. Thus, the present invention is not intended to be limited to the embodiments shown herein but is to be accorded the widest scope consistent with the principles and novel features disclosed herein.
Claims (6)
1. A method for mutual communication between on-demand terminals is applied to a signaling server, and the method comprises the following steps:
determining terminal identifications of all target on-demand terminals with target videos required to be on-demand by on-demand terminals, wherein the on-demand terminals are connected with the signaling server;
inquiring the IP address and the port of a target signaling server connected with each target on-demand terminal from a Redis cluster according to the terminal identification;
connecting the signaling server with each target signaling server based on the IP address and the port of each target signaling server, and enabling the on-demand terminal to communicate with each target on-demand terminal;
the connecting the signaling server with each target signaling server based on the IP address and the port of each target signaling server to enable the on-demand terminal to communicate with each target on-demand terminal, specifically comprising:
establishing connection with each target signaling server based on the IP address and port of each target signaling server;
forwarding a signaling message sent by the on-demand terminal to the corresponding target on-demand terminal through each target signaling server, wherein the signaling message contains the unique identifier of the target video;
acquiring a response message sent by each target on-demand terminal through the corresponding target signaling server, wherein the response message is generated after each target on-demand terminal determines that the target video exists;
and forwarding the response message to the on-demand terminal, so that the on-demand terminal communicates with the target on-demand terminal which sends the response message based on the response message.
2. The method according to claim 1, wherein the determining the terminal identifiers of all target on-demand terminals having the target videos that are required to be on-demand by the on-demand terminals specifically comprises:
acquiring a signaling message sent by the on-demand terminal, wherein the signaling message contains the unique identifier of the target video;
and acquiring the terminal identifications of all target on-demand terminals with the target video from a scheduling server based on the signaling message.
3. The method of claim 1, wherein a P2P connection is established between the on-demand terminal and each of the target on-demand terminals.
4. A system for intercommunication between on-demand terminals, which is applied to a signaling server, the system comprising:
the determining unit is used for determining the terminal identifications of all target on-demand terminals with target videos required to be on-demand by the on-demand terminals, and the on-demand terminals are connected with the signaling server;
the query unit is used for querying the IP address and the port of a target signaling server connected with each target on-demand terminal from the Redis cluster according to the terminal identifier;
an intercommunication establishing unit, configured to connect the signaling server with each target signaling server based on an IP address and a port of each target signaling server, so that the on-demand terminal and each target on-demand terminal communicate with each other;
the mutual communication establishing unit specifically includes:
a connection establishing subunit, configured to establish a connection with each of the target signaling servers based on the IP address and the port of each of the target signaling servers;
the information forwarding unit is used for forwarding a signaling message sent by the on-demand terminal to the corresponding target on-demand terminal through each target signaling server, wherein the signaling message contains the unique identifier of the target video;
an obtaining subunit, configured to obtain a response message sent by each target on-demand terminal through the corresponding target signaling server, where the response message is generated after each target on-demand terminal determines that the target video exists;
and the forwarding subunit is used for forwarding the response message to the on-demand terminal, so that the on-demand terminal communicates with the target on-demand terminal which sends the response message based on the response message.
5. The system according to claim 4, wherein the determining unit is specifically configured to:
acquiring a signaling message sent by the on-demand terminal, wherein the signaling message contains a unique identifier of the target video;
and acquiring the terminal identifications of all target on-demand terminals with the target video from a scheduling server based on the signaling message.
6. The system of claim 4, wherein a P2P connection is established between the on-demand terminal and each of the target on-demand terminals.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110621194.7A CN113381990B (en) | 2021-06-03 | 2021-06-03 | Method and system for intercommunication between on-demand terminals |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110621194.7A CN113381990B (en) | 2021-06-03 | 2021-06-03 | Method and system for intercommunication between on-demand terminals |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN113381990A CN113381990A (en) | 2021-09-10 |
| CN113381990B true CN113381990B (en) | 2022-06-10 |
Family
ID=77575615
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202110621194.7A Active CN113381990B (en) | 2021-06-03 | 2021-06-03 | Method and system for intercommunication between on-demand terminals |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113381990B (en) |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101123718A (en) * | 2007-09-13 | 2008-02-13 | 华为技术有限公司 | Multi-media ordering method and system and multimedia terminal |
| CN201766618U (en) * | 2010-07-02 | 2011-03-16 | 深圳市快播科技有限公司 | Network on-demand playing system |
| CN102316135A (en) * | 2010-07-02 | 2012-01-11 | 深圳市快播科技有限公司 | Network on-demand method and system |
| CN103458318A (en) * | 2013-07-26 | 2013-12-18 | 深圳市融创天下科技股份有限公司 | Media data transmission method and system |
| CN111818360A (en) * | 2020-09-14 | 2020-10-23 | 平安国际智慧城市科技股份有限公司 | Media on-demand method, system and device |
Family Cites Families (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US7626950B2 (en) * | 2004-08-18 | 2009-12-01 | At&T Intellectual Property, I,L.P. | SIP-based session control among a plurality of multimedia devices |
| WO2007140812A1 (en) * | 2006-06-02 | 2007-12-13 | Telefonaktiebolaget Lm Ericsson (Publ) | Method and apparatuses for establishing a session between a client terminal and a media supply system to transport a unicast media stream over an ip network |
| CN108235051B (en) * | 2017-12-29 | 2020-08-21 | 福建中金在线信息科技有限公司 | Live broadcast system and method for storing and acquiring live broadcast data |
| CN108366278B (en) * | 2018-02-01 | 2020-08-28 | 北京奇艺世纪科技有限公司 | User interaction implementation method and device in video playing |
-
2021
- 2021-06-03 CN CN202110621194.7A patent/CN113381990B/en active Active
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101123718A (en) * | 2007-09-13 | 2008-02-13 | 华为技术有限公司 | Multi-media ordering method and system and multimedia terminal |
| CN201766618U (en) * | 2010-07-02 | 2011-03-16 | 深圳市快播科技有限公司 | Network on-demand playing system |
| CN102316135A (en) * | 2010-07-02 | 2012-01-11 | 深圳市快播科技有限公司 | Network on-demand method and system |
| CN103458318A (en) * | 2013-07-26 | 2013-12-18 | 深圳市融创天下科技股份有限公司 | Media data transmission method and system |
| CN111818360A (en) * | 2020-09-14 | 2020-10-23 | 平安国际智慧城市科技股份有限公司 | Media on-demand method, system and device |
Also Published As
| Publication number | Publication date |
|---|---|
| CN113381990A (en) | 2021-09-10 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN101170523B (en) | File transmission system, method and file forward decision server | |
| US8099764B2 (en) | Secure push and status communication between client and server | |
| CN103795689A (en) | Resource subscription method and device | |
| CN106230896A (en) | A kind of information push method, Apparatus and system | |
| CN110933180A (en) | Communication establishing method and device, load equipment and storage medium | |
| WO2008040248A1 (en) | A method and system for transmitting email and a push mail server | |
| JP2000276432A (en) | Dynamic load distribution system for transaction message | |
| KR101473660B1 (en) | Web-based real time data pushing method and system thereof | |
| CN105743958A (en) | Terminal-to-terminal communication method and device | |
| CN104486327A (en) | Method and client side of communication between pages and long connection servers | |
| WO2011015020A1 (en) | File transmission method, system and client | |
| CN111131188A (en) | Communication connection method, server, client, and storage medium | |
| JP4771744B2 (en) | IMPS client state information synchronization method | |
| RU2003128959A (en) | METHOD FOR MAINTAINING SHORT MESSAGES THROUGH MOBILE INTELLECTUAL NETWORK | |
| CN109510748B (en) | Node and node interaction method and system | |
| US20140201376A1 (en) | Method and system for the handling of redundant long poll | |
| CN113381990B (en) | Method and system for intercommunication between on-demand terminals | |
| CN106790609B (en) | Data transmission method and device | |
| CN110365790B (en) | Message transmission method and device, cascade networking equipment and readable storage medium | |
| CN111737029A (en) | Server, data pushing method and data pushing system | |
| KR101746226B1 (en) | Method for exchanging information using smart grid in universal plug and play | |
| US11612007B2 (en) | Low power dissipation Bluetooth mesh network system and communication method | |
| CN112202780B (en) | Data transmission method, device, equipment and medium based on double sockets | |
| CN109379443B (en) | Method for realizing distributed message queue facing to Internet of things | |
| CN110474781B (en) | Method and device for forwarding multicast data |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |