CN107959704B - Data processing method and home gateway - Google Patents
Data processing method and home gateway Download PDFInfo
- Publication number
- CN107959704B CN107959704B CN201610907771.8A CN201610907771A CN107959704B CN 107959704 B CN107959704 B CN 107959704B CN 201610907771 A CN201610907771 A CN 201610907771A CN 107959704 B CN107959704 B CN 107959704B
- Authority
- CN
- China
- Prior art keywords
- resource data
- notification
- terminal
- home gateway
- node
- 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
- 238000003672 processing method Methods 0.000 title claims abstract description 11
- 238000000034 method Methods 0.000 claims description 21
- 230000005540 biological transmission Effects 0.000 claims description 15
- 238000012216 screening Methods 0.000 claims description 6
- 238000010586 diagram Methods 0.000 description 13
- 230000004044 response Effects 0.000 description 12
- 238000009826 distribution Methods 0.000 description 11
- 230000006870 function Effects 0.000 description 11
- 238000004590 computer program Methods 0.000 description 7
- 238000003860 storage Methods 0.000 description 6
- 238000004891 communication Methods 0.000 description 4
- 239000012634 fragment Substances 0.000 description 4
- 230000003287 optical effect Effects 0.000 description 4
- 238000005516 engineering process Methods 0.000 description 3
- 230000010365 information processing Effects 0.000 description 2
- 230000003993 interaction Effects 0.000 description 2
- 238000007726 management method Methods 0.000 description 2
- 230000001360 synchronised effect Effects 0.000 description 2
- 238000009825 accumulation Methods 0.000 description 1
- 230000001186 cumulative effect Effects 0.000 description 1
- 238000004519 manufacturing process Methods 0.000 description 1
- 239000013307 optical fiber Substances 0.000 description 1
- 238000004904 shortening Methods 0.000 description 1
- 238000011144 upstream manufacturing Methods 0.000 description 1
Images
Classifications
-
- 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/1074—Peer-to-peer [P2P] networks for supporting data block transmission mechanisms
- H04L67/1078—Resource delivery mechanisms
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L12/00—Data switching networks
- H04L12/66—Arrangements for connecting between networks having differing types of switching systems, e.g. gateways
-
- 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/1087—Peer-to-peer [P2P] networks using cross-functional networking aspects
- H04L67/1093—Some peer nodes performing special functions
-
- 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/1095—Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Computing Systems (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The invention discloses a data processing method, which comprises the following steps: the home gateway receives a first notification; the first notification is used for notifying the home gateway that the first terminal is to acquire first resource data; the first terminal is a terminal connected with the home gateway in a downlink manner and can provide services for other P2P nodes in a P2P network when being used as a peer P2P node; responding to the first notification, and when the first terminal receives the first resource data, the home gateway acquires the first resource data passing through the home gateway; and locally saving the acquired first resource data, and synchronizing the first resource data information to a server, so that the home gateway can provide services aiming at the first resource data for the other P2P nodes. The invention also discloses a home gateway.
Description
Technical Field
The present invention relates to a Content Delivery Network (CDN), and in particular, to a data processing method and a home gateway.
Background
Peer-to-Peer content delivery network (P2P CDN) technology is a new CDN technology that utilizes user equipment as a CDN content service edge node to serve other users. The core idea of the P2P CDN is to implement content distribution service between user equipments through user terminal equipments whose identities are equal to each other by using user resources, that is, different user equipments serve as different P2P nodes to provide video content distribution service for video service requests of other user equipments, which is different from a client/server (C/S) transmission model of a conventional CDN, in which a content service edge node server provides service for video service requests of user equipments.
In a P2P CDN, when each P2P client receiving video receives video content, the client also serves as a server to provide service capability for other users trying to receive the video, but since each terminal device has limited service capability, one P2P client (serving as a P2P node) can generally only serve 2-3 other P2P nodes, thereby greatly affecting the service capability of the P2P system.
Disclosure of Invention
In order to solve the existing technical problem, embodiments of the present invention provide a data processing method and a home gateway.
The technical scheme of the embodiment of the invention is realized as follows:
the embodiment of the invention provides a data processing method, which is applied to a home gateway and comprises the following steps:
receiving a first notification; the first notification is used for notifying the home gateway that the first terminal is to acquire first resource data; the first terminal is a terminal connected downwards to the home gateway, and can provide services for other P2P nodes in a P2P network when serving as a Peer-to-Peer (P2P) node;
responding to the first notification, and when the first terminal receives the first resource data, acquiring the first resource data passing through the first terminal;
and locally saving the acquired first resource data, and synchronizing the first resource data information to a server, so that the home gateway can provide services aiming at the first resource data for the other P2P nodes.
In the foregoing solution, the receiving the first notification includes:
and receiving a first notification directly sent by the first terminal.
In the foregoing solution, the receiving the first notification includes:
receiving a first notification sent by the server; the first notification sent by the server is a notification obtained by processing the service information corresponding to the first resource data for the notification sent by the first terminal to the server or a notification directly forwarded by the notification sent by the first terminal to the server.
In the foregoing solution, before the first resource data passing through the method is acquired, the method further includes:
receiving first information sent by the first terminal; the first information characterizes transmission related information of the first resource data;
accordingly, the acquiring the first resource data passing through itself includes:
screening out the data packets of the first resource data from the data packets passing through the first information by using the first information;
and analyzing the screened data packet to obtain the first resource data.
In the above scheme, before the first terminal selects the requested service content according to the user operation and requests the provider of the first resource data from the server, the home gateway receives a first notification.
In the foregoing solution, after the first terminal acquires the provider of the first resource data from the server, and before the first terminal requests the corresponding provider for the first resource data, the home gateway receives a first notification.
An embodiment of the present invention further provides a home gateway, including:
a receiving unit configured to receive a first notification; the first notification is used for notifying the home gateway that the first terminal is to acquire first resource data; the first terminal is a terminal connected with the home gateway in a down mode and can provide services for other P2P nodes in a P2P network when being used as a P2P node;
an obtaining unit, configured to respond to the first notification, and when the first terminal receives the first resource data, obtain the first resource data that passes through the first terminal;
the synchronization unit is used for locally storing the acquired first resource data; and synchronizing the first resource data information to a server to enable the home gateway to provide the other P2P nodes with a service for the first resource data.
In the foregoing solution, the receiving unit is specifically configured to:
receiving a first notification directly sent by the first terminal;
or,
receiving a first notification sent by the server; the first notification sent by the server is a notification obtained by processing the service information corresponding to the first resource data for the notification sent by the first terminal to the server or a notification directly forwarded by the notification sent by the first terminal to the server.
In the above scheme, the receiving unit is further configured to receive first information sent by the first terminal; the first information characterizes transmission related information of the first resource data;
correspondingly, the obtaining unit is specifically configured to:
screening out the data packets of the first resource data from the data packets passing through the first information by using the first information;
and analyzing the screened data packet to obtain the first resource data.
In the foregoing solution, the receiving unit is configured to receive a first notification before the first terminal selects the requested service content according to a user operation and requests the server for the provider of the first resource data.
In the foregoing solution, the receiving unit is configured to receive a first notification after the first terminal acquires the provider of the first resource data from the server and before the first terminal requests the corresponding provider for the first resource data.
According to the data processing method and the home gateway provided by the embodiment of the invention, the home gateway receives a first notification; the first notification is used for notifying the home gateway that the first terminal is to acquire first resource data; the first terminal is a terminal connected with the home gateway in a downlink manner and can provide services for other P2P nodes in a P2P network when being used as a peer P2P node; the home gateway responds to the first notification, and when the first terminal receives the first resource data, the home gateway acquires the first resource data passing through the home gateway; the home gateway locally stores the acquired first resource data and synchronizes the first resource data information to the server, so that the home gateway can provide services for the first resource data for other P2P nodes, and the home gateway serves as a P2P node to provide services for other P2P nodes, thereby greatly improving the overall service capability of the P2P system.
Drawings
In the drawings, which are not necessarily drawn to scale, like reference numerals may describe similar components in different views. Like reference numerals having different letter suffixes may represent different examples of similar components. The drawings illustrate generally, by way of example, but not by way of limitation, various embodiments discussed herein.
FIG. 1 is a schematic diagram of a P2P CDN system in the related art;
fig. 2 is a schematic diagram of a network structure in which a terminal device in the related art is connected to the internet in a broadband access manner;
FIG. 3 is a flow chart illustrating a method of data processing according to an embodiment of the present invention;
fig. 4 is a flowchart illustrating a method for providing a service by a home gateway according to a second embodiment of the present invention;
fig. 5 is a schematic flow chart of a method for providing a service by a home gateway according to an embodiment of the present invention;
fig. 6 is a schematic structural diagram of a fourth home gateway according to an embodiment of the present invention.
Detailed Description
The present invention will be described in further detail with reference to the accompanying drawings and examples.
Fig. 1 is a schematic diagram of a P2P CDN system architecture. As shown in fig. 1, the P2P CDN system mainly includes a policy center and a Tracker server. Wherein,
the policy center provides configuration functions for various policies involved in the P2P CDN system, including content pre-push policy management, Tracker scheduling policy management, and the like.
The Tracker server realizes the global control and scheduling functions of the P2P CDN system and is a uniform entrance server accessed by end users. The Tracker server maintains the IP addresses and port number information of all file downloaders, periodically performs content pre-pushing when the set-top box terminal P2P node is started and is in an idle state, and returns a P2P node list capable of providing distribution service of certain video content when certain user equipment requests to acquire the content.
Meanwhile, in the content delivery process of the P2P CDN technology, in order to shorten the transmission delay when one P2P node serves another P2P node, the shortest content delivery transmission path (route) is selected as much as possible. For example, when a scheduling Server (Tracker Server) of the P2PCDN system receives a request from a user a to obtain a certain content, it is preferable that the P2P nodes provide a service for the user a when it is retrieved that exactly other P2P nodes (possibly more than one node) in a neighborhood where the user a is located (e.g., under the same Broadband Remote Access Server (BRAS)) can provide the content distribution service for the user a currently.
The service flow of the existing P2P CDN system for obtaining video content service by a user includes:
step A1: a user X1 selects a video program a to be watched by a video player on a Personal Computer (PC) or a set-top box; meanwhile, a P2P client on the terminal equipment is registered on a Tracker server as a P2P node X1 and informs the server that the server is on-line; user X2 selects a desired video program a to be viewed by a video player on a device such as a PC or set-top box; meanwhile, a P2P client on the terminal equipment is registered on a Tracker server as a P2P node X2 and informs the server that the server is on-line;
here, when the P2P node X1 acquires video program a, the video service of video program a may be subsequently provided as a server to other P2P nodes.
And B: the P2P node X1 of user X1 (now acting as the recipient of the video service) requests the Tracker server for a list of other P2P nodes (video service providers) that can provide the current content a distribution service; the P2P node X2 of user X2 (now acting as the recipient of the video service) requests the Tracker server for a list of other P2P nodes (video service providers) that can provide the current content a distribution service;
and C: after receiving a request of a P2P node X1, a Tracker server (scheduling center) synthesizes self-collected P2P node information (whether storage content A, service capacity and the like exist) and distance information between the P2P nodes and a P2P node X1, and returns an information list of a plurality of candidate P2P nodes which can provide services for the P2P node X1; after receiving a request of a P2P node X2, integrating the P2P node information (whether storage content A, service capability and the like exist) collected by the node and the distance information between the P2P nodes and the P2P node X2, and returning an information list of a plurality of candidate P2P nodes which can provide services for the P2P node X2;
here, for each P2P node in the list, its information includes the IP address (necessary) and port (optional) information of the P2P node, etc.
Step D: the P2P node X1 is connected to other P2P nodes to request to acquire the data fragments of the video content according to the P2P node list information, obtains video content service, and plays the video content for the user after acquiring the video content; and the P2P node X1 is connected to the P2P node X1 to request to acquire data fragments of the video content A according to the P2P node list information, obtain a video content service, and play the video content for the user after acquiring the video content.
As can be seen from the above description, currently, each P2P client receiving video also serves as a server to provide live broadcast service capability for other users attempting to receive the video when receiving video content, but since each terminal device has limited service capability (limited by processing capability of the terminal, read rate of Input/Output (I/O) of the disk, upstream network bandwidth, and other factors), it can generally only provide service for 2-3 other P2P nodes, thereby greatly affecting service capability of the system.
In addition, for live video, when more P2P users request to receive the live service, the later accessed users can only receive the service by multiple tiers as the lower tier users of the upper tier users, thus, the live video content will have a large delay after the relay service of the multiple tiers of P2P nodes, and the live delay will also increase cumulatively with the increase of the cumulative level of the P2P nodes serving the lower tier nodes. Therefore, when providing live broadcast service through the P2P system, more devices that may provide live broadcast service need to be mined as the P2P nodes of the primary service, thereby improving the overall service capability of the P2P system and shortening live broadcast delay.
Similarly, for the on-demand service, since the service data can be stored in the storage device of the upper layer user in a pre-distribution manner, there is no delay accumulation problem caused by the multi-layer overlay service of the live broadcast service, but there is also a problem that the service capability of the terminal device is limited (limited by the processing capability of the terminal, the disk I/O reading rate, the uplink network bandwidth, and the like), resulting in the overall service capability of the P2P system being insufficient.
Meanwhile, fig. 2 is a schematic diagram of a network structure connected to the internet in a wired broadband access manner. As shown in fig. 2, the home gateway is an end device of the operator network in the home, is located at the center of the user home network, and is responsible for connecting and managing each service terminal device in the home, and is connected to a network side Optical line terminal (OLT, Optical line terminal) of the access network connected to the home, a BRAS, and other devices, thereby implementing a function of accessing the service of the wired broadband network. The OLT is used for connecting terminal equipment of an optical fiber trunk line, and is optical access network equipment connected with the gateway equipment; BRAS is a broadband access server, located at the edge of various large IP networks, and provides access, authentication and charging functions for broadband users of metropolitan area networks, for example, home gateways can help users access to the internet through the equipment.
In the access network based on the wired broadband, when a user accesses the internet through various devices such as a set top box, a PC, a mobile phone, and the like, the user needs to access the internet through home gateway devices (through devices such as an OLT, a BRAS, and the like), in other words, in a P2P CDN system, various service data of a terminal as a P2P node can be sent to other devices not in the home network of the user through the home gateway.
Based on this, in various embodiments of the invention: the home gateway receives a first notification; the first notification is used for notifying the home gateway that the first terminal is to acquire first resource data; the first terminal is a terminal connected with the home gateway in a down mode and can provide services for other P2P nodes in a P2P network when being used as a P2P node; responding to the first notification, and when the first terminal receives the first resource data, acquiring the first resource data passing through the first terminal; and locally saving the acquired first resource data, and synchronizing the first resource data information to a server, so that the home gateway can provide services aiming at the first resource data for the other P2P nodes.
That is to say, in various embodiments of the present invention, by utilizing the characteristic that data of a home terminal must pass through a home gateway, a P2P node function is newly added on the home gateway, and a terminal device such as a set-top box is newly added on a terminal device such as a set-top box and a P2P node on the home gateway to notify the home gateway device that the home gateway device itself is to acquire service data, so that the home gateway can synchronously store the service data when the home gateway can acquire the service data from a terminal device such as a set-top box or a PC connected to the home gateway (subordinate) thereof, so that the home gateway device also becomes a P2P node service provider having the service data content in a P2P network, and can provide the service data for other P2P nodes.
Example one
The embodiment of the invention provides a data processing method which is applied to a home gateway and is suitable for a P2P CDN system.
The data processing method of the embodiment of the invention, as shown in fig. 3, includes the following steps:
step 301: the home gateway receives a first notification;
here, the first notification is used to notify the home gateway that the first terminal is to acquire the first resource data.
The first terminal is a terminal connected downwards to the home gateway and can serve other P2P nodes in the P2P network when serving as a P2P node.
In practical application, in the P2P CDN, the first resource data may be video data; correspondingly, the first terminal may be a set-top box or a terminal device such as a PC having a video playing function.
In practical application, the timing when the home gateway receives the first notification may be: the first terminal receives the service content selected by the user and requests the server for the provider of the first resource data. That is, the home gateway receives a first notification before the first terminal selects the requested service content according to a user operation and requests the provider of the first resource data to the server.
The timing of the home gateway receiving the first notification may also be: after the first terminal acquires the provider of the first resource data, the first terminal requests the corresponding provider for the first resource data. That is, after the first terminal acquires the provider of the first resource data from the server and before requesting the first resource data from the corresponding provider, the home gateway receives a first notification.
In practical application, the home gateway may receive the first notification by one of the following methods:
in a first mode, the first terminal directly sends the first notification to the home gateway, that is, in a local area network communication mode, that is, the home gateway receives the first notification directly sent by the first terminal.
In a second mode, the first terminal sends the first notification to the home gateway through a relay of a server, that is, the home gateway relays communication through the server, that is, the home gateway receives the first notification sent by the server; the first notification sent by the server is a notification obtained by processing the service information corresponding to the first resource data for the notification sent by the first terminal to the server or a notification directly forwarded by the notification sent by the first terminal to the server.
Here, the performing of the service information processing corresponding to the first resource data means: adding and/or deleting some necessary service information corresponding to the first resource data, such as: increase service expiration, etc.
Step 302: responding to the first notification, and when the first terminal receives the first resource data, the home gateway acquires the first resource data passing through the home gateway;
here, in actual application, after obtaining the transmission related information of the first resource data, the first terminal, for example: when the first terminal is provided with various information such as the IP address of at least one P2P node of the first resource data, the IP packet number of the first resource data, or the receiving time of receiving the first resource data, the information related to transmission can be notified to the home gateway, so that the home gateway can quickly locate and screen out the data to be stored.
Based on this, in an embodiment, before performing this step, the method may further include:
receiving first information sent by the first terminal; the first information characterizes transmission related information of the first resource data;
accordingly, the specific implementation of this step may include:
screening out the data packets of the first resource data from the data packets passing through the first information by using the first information;
and analyzing the screened data packet to obtain the first resource data.
Therefore, the home gateway can quickly locate and screen the P2P service resource data needing to be acquired from all network data passing through the home gateway (the home gateway may be connected with other terminal equipment except the first terminal, such as other computers, mobile phones and the like), so that the processing mode that the home gateway needs to analyze each packet of a large number of data packets is simplified, and the processing efficiency is improved.
Step 303: and the home gateway locally stores the acquired first resource data and synchronizes the information of the first resource data to a server.
Here, the purpose of the home gateway locally saving the first resource data and synchronizing the first resource data information to the server is to: when the home gateway is a P2P node, the home gateway can provide the service for the first resource data for the other P2P nodes.
According to the data processing method provided by the embodiment of the invention, a home gateway receives a first notification; the first notification is used for notifying the home gateway that the first terminal is to acquire first resource data; the first terminal is a terminal connected with the home gateway in a downlink manner and can provide services for other P2P nodes in a P2P network when being used as a peer P2P node; the home gateway responds to the first notification, and when the first terminal receives the first resource data, the home gateway acquires the first resource data passing through the home gateway; the home gateway locally stores the acquired first resource data and synchronizes the first resource data information to the server, so that the home gateway can provide services for the first resource data for other P2P nodes, and the home gateway serves as a P2P node to provide services for other P2P nodes, thereby greatly improving the overall service capability of the P2P system.
In addition, receiving first information sent by the first terminal; the first information characterizes transmission related information of the first resource data; the home gateway screens out a data packet of the first resource data from data packets passing through the home gateway by using the first information; the home gateway analyzes the screened data packet to obtain the first resource data, and can quickly locate and screen the P2P service resource data needing to be obtained from all network data passing through the home gateway (the home gateway may be connected with other terminal equipment except the first terminal, such as other computers, mobile phones and the like).
Example two
On the basis of the first embodiment, the present embodiment describes in detail how the home gateway serves as a P2P node to provide services for other P2P nodes, by taking a set-top box as an example.
It should be noted that: the P2P node on each device refers to: the device is provided with a functional module with P2P.
As shown in fig. 4, the process of providing the home gateway as the P2P node for other P2P nodes mainly includes the following steps:
step 401: a user X selects a certain video program A to be watched through a first video player on a first set top box;
step 402: the first video player sends a content access request to a first P2P node on the first set-top box according to the request of a user;
here, the content access request carries the website of program a.
Step 403: after receiving the request, the first P2P node processes the request, that is, registers the request on a Tracker server, and informs the server that the server is online, so as to prepare to acquire the content of the program a from the P2P CDN;
step 404: the first P2P node informs the second P2P node on the home gateway that the content service of the program A will be started;
here, in practical application, the specific implementation of this step may include:
step 404 a: the first P2P node sending notifications directly to the second P2P node;
step 404 b: the second P2P node returns a response to the first P2P node after receiving the notification.
That is, the first P2P node and the second P2P node communicate over a local area network to enable the first P2P node to inform the second P2P node that it will begin to acquire the content service for program A.
The specific implementation of this step may also include:
step 404A: the first P2P node sends a notification to a Tracker server;
step 404B: after receiving the notification, the Tracker server returns a response to the first P2P node;
step 404C: the Tracker server forwards the received notification to a second P2P node;
step 404D: the second P2P node returns a response to the Tracker server.
That is, the second P2P node relays communication with the second P2P node through the Tracker server to realize that the first P2P node notifies the second P2P node that itself will start to acquire the content service of the program a.
Step 405: the first P2P node (now acting as the recipient of the video service) requests from the Tracker server a list of other P2P nodes (video service providers) that can provide the current program a distribution service;
step 406: after receiving the request of the first P2P node, the Tracker server returns an information list of a plurality of candidate P2P nodes which can provide service for the first P2P node;
here, the Tracker server integrates the P2P node information collected by itself (whether there is content for storing program a, service capability, etc.), and the distance information between these P2P nodes and the first P2P node, and returns an information list of several candidate P2P nodes that can provide service for the first P2P node.
Wherein, for each P2P node in the list, the information includes the IP address (necessary) and port (optional) information of the P2P node, etc.
Step 407: the first P2P node selects a third P2P node and a super P2P node as providers of the content of the program A according to the P2P node list information, and requests the data of the program A from the super P2P node;
step 408: after receiving the request, the super P2P node authenticates the first P2P node;
step 409: after the authentication is passed, the super P2P node sends the data of the program A to the first P2P;
step 410: after receiving the response, the first P2P node requests the data of the program A from the third P2P node;
step 411: after receiving the request, the third P2P node authenticates the first P2P node;
step 412: after the authentication is passed, the third P2P node sends the data of the program A to the first P2P node through the home gateway to the first P2P node;
here, it should be noted that: in practical applications, the super P2P node (which has stronger service capability compared with other nodes capable of providing service, i.e. can provide service for more P2P nodes) is optional, and the super P2P node does not necessarily exist in the network; in addition, the first P2P node does not necessarily get service through the super P2P node.
When the first P2P node does not get service through the super P2P node, then steps 407-409 are not performed.
Step 413: after receiving the data of the program A, the home gateway acquires the data of the program A and stores the data locally;
step 414: the home gateway sends a resource synchronization condition to the Tracker server to inform the Tracker server that the Tracker server has the data of the program A;
step 415: after receiving the information, the Tracker server updates the resource list of the Tracker server;
step 416: the Tracker server returns a synchronous response to the home gateway;
step 417: after receiving the data of the program A, the first P2P node locally stores the data of the program A;
step 418: the first P2P node sends resource synchronization condition to the Tracker server to inform the Tracker server that the server has the data of the program A;
step 419: after receiving the information, the Tracker server updates the resource list of the Tracker server;
step 420: the Tracker server returns a synchronization response to the first P2P node;
step 421: the first P2P node returns the data for program a to the first video player;
step 422: the first video player plays the program A;
in practical application, steps 418 to 420 and 421 to 422 are executed without any sequence.
Step 423: when a user Y selects a video program A to be watched through a second video player on a second set top box, a fourth P2P node on the second set top box is registered on a Tracker server to inform the server that the server is on-line;
here, the interaction between the second video player and the fourth P2P node is the same as described for step 402.
Step 424: the fourth P2P node (now acting as the recipient of the video service) requests the Tracker server for a list of other P2P nodes (video service providers) that can provide the current program a distribution service;
step 425: after receiving the request of the fourth P2P node, the Tracker server returns an information list of a plurality of candidate P2P nodes which can provide service for the fourth P2P node;
here, the Tracker server integrates the P2P node information collected by itself (whether there is content for storing program a, service capability, etc.), and the distance information between these P2P nodes and the fourth P2P node, and returns an information list of several candidate P2P nodes that can provide service for the fourth P2P node.
Wherein, for each P2P node in the list, the information includes the IP address (necessary) and port (optional) information of the P2P node, etc.
Step 426: and the fourth P2P node is connected to other P2P nodes to request to acquire the data fragments of the program A according to the P2P node list information, acquires a video content service, and plays the video content for the user after acquiring the video content.
When the video content is acquired, the video content service of the program a may be acquired through a home gateway, or may be acquired through the first P2P node.
As can be seen from the above description, in this embodiment, the timing for the first set-top box to notify the home gateway itself that the content service of the program a is to be acquired is: the first set top box receives the service selected by the user and requests the Tracker server for the content provider of program a.
EXAMPLE III
On the basis of the first embodiment, the present embodiment describes in detail how the home gateway serves as a P2P node to provide services for other P2P nodes, by taking a set-top box as an example.
It should be noted that: the P2P node on each device refers to: the device is provided with a functional module with P2P.
The difference from the second embodiment is that: the first set top box informs the home gateway that the content service of the program A is to be acquired at the following time: the first P2P node on the first set top box after obtaining the list of information for candidate P2P nodes from the Tracker server and before requesting data for the program from the corresponding P2P node.
As shown in fig. 5, the process of providing the home gateway as the P2P node for other P2P nodes mainly includes the following steps:
step 501: a user X selects a certain video program A to be watched through a first video player on a first set top box;
step 502: the first video player sends a content access request to a first P2P node on the first set-top box according to the request of a user;
here, the content access request carries the website of program a.
Step 503: after receiving the request, the first P2P node processes the request, that is, registers the request on a Tracker server, and informs the server that the server is online, so as to prepare to acquire the content of the program a from the P2P CDN;
step 504: the first P2P node (now acting as the recipient of the video service) requests from the Tracker server a list of other P2P nodes (video service providers) that can provide the current program a distribution service;
step 505: after receiving the request of the first P2P node, the Tracker server returns an information list of a plurality of candidate P2P nodes which can provide service for the first P2P node;
here, the Tracker server integrates the P2P node information collected by itself (whether there is content for storing program a, service capability, etc.), and the distance information between these P2P nodes and the first P2P node, and returns an information list of several candidate P2P nodes that can provide service for the first P2P node.
Wherein, for each P2P node in the list, the information includes the IP address (necessary) and port (optional) information of the P2P node, etc.
Step 506: the first P2P node selects a third P2P node and a super P2P node as providers of the content of the program A according to the P2P node list information, and requests the data of the program A from the super P2P node;
step 507: after receiving the request, the super P2P node authenticates the first P2P node;
step 508: after the authentication is passed, the super P2P node sends the data of the program A to the first P2P;
here, in practical application, the super P2P node (which has stronger service capability compared to other nodes capable of providing service, i.e. can provide service for more P2P nodes) is optional, and the super P2P node does not necessarily exist in the network; in addition, the first P2P node does not necessarily get service through the super P2P node.
When the first P2P node is not getting service through the super P2P node, then Steps 506-508 are not performed.
Step 509: after the first P2P node receives the data, the first P2P node informs a second P2P node on the home gateway that the content service of the program A will be started to be acquired;
here, in practical application, the specific implementation of this step may include:
step 509 a: the first P2P node sending notifications directly to the second P2P node;
step 509 b: the second P2P node returns a response to the first P2P node after receiving the notification.
That is, the first P2P node and the second P2P node communicate over a local area network to enable the first P2P node to inform the second P2P node that it will begin to acquire the content service for program A.
The specific implementation of this step may also include:
step 509A: the first P2P node sends a notification to a Tracker server;
step 509B: after receiving the notification, the Tracker server returns a response to the first P2P node;
step 509C: the Tracker server forwards the received notification to a second P2P node;
step 509D: the second P2P node returns a response to the Tracker server.
That is, the second P2P node relays communication with the second P2P node through the Tracker server to realize that the first P2P node notifies the second P2P node that itself will start to acquire the content service of the program a.
Step 510: after the home gateway is notified, the first P2P node requests the data of the program A from the third P2P node;
step 511: after receiving the request, the third P2P node authenticates the first P2P node;
step 512: after the authentication is passed, the third P2P node sends the data of the program A to the first P2P node through the home gateway to the first P2P node;
step 513: after receiving the data of the program A, the home gateway acquires the data of the program A and stores the data locally;
step 514: the home gateway sends a resource synchronization condition to the Tracker server to inform the Tracker server that the Tracker server has the data of the program A;
step 515: after receiving the information, the Tracker server updates the resource list of the Tracker server;
step 516: the Tracker server returns a synchronous response to the home gateway;
517: after receiving the data of the program A, the first P2P node locally stores the data of the program A;
step 518: the first P2P node sends resource synchronization condition to the Tracker server to inform the Tracker server that the server has the data of the program A;
step 519: after receiving the information, the Tracker server updates the resource list of the Tracker server;
step 520: the Tracker server returns a synchronization response to the first P2P node;
step 521: the first P2P node returns the data for program a to the first video player;
step 522: the first video player plays the program A;
here, in practical applications, the steps 518 to 520 and 521 to 522 are not executed in sequence.
Step 523: when a user Y selects a video program A to be watched through a second video player on a second set top box, a fourth P2P node on the second set top box is registered on a Tracker server to inform the server that the server is on-line;
here, the interaction between the second video player and the fourth P2P node is the same as described for step 402.
Step 524: the fourth P2P node (now acting as the recipient of the video service) requests the Tracker server for a list of other P2P nodes (video service providers) that can provide the current program a distribution service;
step 525: after receiving the request of the fourth P2P node, the Tracker server returns an information list of a plurality of candidate P2P nodes which can provide service for the fourth P2P node;
here, the Tracker server integrates the P2P node information collected by itself (whether there is content for storing program a, service capability, etc.), and the distance information between these P2P nodes and the fourth P2P node, and returns an information list of several candidate P2P nodes that can provide service for the fourth P2P node.
Wherein, for each P2P node in the list, the information includes the IP address (necessary) and port (optional) information of the P2P node, etc.
Step 526: and the fourth P2P node is connected to other P2P nodes to request to acquire the data fragments of the program A according to the P2P node list information, acquires a video content service, and plays the video content for the user after acquiring the video content.
When the video content is acquired, the video content service of the program a may be acquired through a home gateway, or may be acquired through the first P2P node.
Example four
In order to implement the method of the embodiment of the present invention, the embodiment provides a home gateway, which is suitable for a P2P CDN system.
As shown in fig. 6, the home gateway according to the embodiment of the present invention includes:
a receiving unit 61 for receiving a first notification; the first notification is used for notifying the home gateway that the first terminal is to acquire first resource data; the first terminal is a terminal connected with the home gateway in a down mode and can provide services for other P2P nodes in a P2P network when being used as a P2P node;
an obtaining unit 62, configured to, in response to the first notification, obtain the first resource data that passes through itself when the first terminal receives the first resource data;
a synchronization unit 63, configured to locally save the acquired first resource data; and synchronizing the first resource data information to a server to enable the home gateway to provide the other P2P nodes with a service for the first resource data.
In practical application, in the P2P CDN, the first resource data may be video data; correspondingly, the first terminal may be a set-top box or a terminal device such as a PC having a video playing function.
In practical application, the timing when the home gateway receives the first notification may be: the first terminal receives the service content selected by the user and requests the server for the provider of the first resource data. That is, the receiving unit 61 is configured to receive the first notification before the first terminal selects the requested service content according to the user operation and requests the server for the provider of the first resource data.
The timing of the home gateway receiving the first notification may also be: after the first terminal acquires the provider of the first resource data, the first terminal requests the corresponding provider for the first resource data. That is, the receiving unit 61 is configured to receive the first notification after the first terminal acquires the provider of the first resource data from the server and before the first terminal requests the corresponding provider for the first resource data.
In actual application, the receiving unit 61 may receive the first notification by one of the following manners:
in a first mode, the first terminal directly sends the first notification to the home gateway, that is, through a local area network, that is, the receiving unit 61 receives the first notification directly sent by the first terminal.
In a second mode, the first terminal transmits the first notification to the home gateway through a relay of a server, that is, the receiving unit 61 receives the first notification transmitted by the server; the first notification sent by the server is a notification obtained by processing the service information corresponding to the first resource data for the notification sent by the first terminal to the server or a notification directly forwarded by the notification sent by the first terminal to the server.
Wherein the performing of the service information processing corresponding to the first resource data means: adding and/or deleting some necessary service information corresponding to the first resource data, such as: increase service expiration, etc.
Here, in actual application, after obtaining the transmission related information of the first resource data, the first terminal, for example: when the first terminal is provided with various information such as the IP address of at least one P2P node of the first resource data, the IP packet number of the first resource data, or the receiving time of receiving the first resource data, the information related to transmission can be notified to the home gateway, so that the home gateway can quickly locate and screen out the data to be stored.
Based on this, in an embodiment, the receiving unit 61 is further configured to receive first information sent by the first terminal; the first information characterizes transmission related information of the first resource data;
correspondingly, the obtaining unit 62 is specifically configured to:
screening out the data packets of the first resource data from the data packets passing through the first information by using the first information;
and analyzing the screened data packet to obtain the first resource data.
Therefore, the home gateway can quickly locate and screen the P2P service resource data needing to be acquired from all network data passing through the home gateway (the home gateway may be connected with other terminal equipment except the first terminal, such as other computers, mobile phones and the like), so that the processing mode that the home gateway needs to analyze each packet of a large number of data packets is simplified, and the processing efficiency is improved.
The purpose of the synchronization unit to locally save the first resource data and synchronize the first resource data information to the server is to: when the home gateway is a P2P node, the home gateway can provide the service for the first resource data for the other P2P nodes.
In practical applications, the receiving unit 61 may be implemented by a transceiver in a home gateway; the obtaining Unit 62 and the synchronizing Unit 63 may be implemented by a Central Processing Unit (CPU) of a home gateway, a Microprocessor (MCU), a Digital Signal Processor (DSP), or a Programmable logic Array (FPGA) in combination with a transceiver.
In the home gateway provided by the embodiment of the present invention, the receiving unit 61 receives a first notification; the first notification is used for notifying the home gateway that the first terminal is to acquire first resource data; the first terminal is a terminal connected with the home gateway in a downlink manner and can provide services for other P2P nodes in a P2P network when being used as a peer P2P node; the obtaining unit 62 responds to the first notification, and obtains the first resource data passing through itself when the first terminal receives the first resource data; the synchronization unit 63 locally stores the acquired first resource data, and synchronizes the first resource data information to the server, so that the home gateway can provide services for the other P2P nodes with respect to the first resource data, and the home gateway serves as a P2P node to provide services for other P2P nodes, thereby greatly improving the overall service capability of the P2P system.
In addition, the receiving unit 61 receives first information transmitted by the first terminal; the first information characterizes transmission related information of the first resource data; the obtaining unit 62 uses the first information to screen out the data packet of the first resource data from the data packet passing through itself; the obtaining unit 62 analyzes the screened data packet to obtain the first resource data, and the home gateway can quickly locate and screen the P2P service resource data to be obtained from all network data passing through the home gateway (the home gateway may be connected with other terminal devices except the first terminal, such as other computers, mobile phones, etc.), so that the processing efficiency is greatly improved.
As will be appreciated by one skilled in the art, embodiments of the present invention may be provided as a method, system, or computer program product. Accordingly, the present invention may take the form of a hardware embodiment, a software embodiment, or an embodiment combining software and hardware aspects. Furthermore, the present invention may take the form of a computer program product embodied on one or more computer-usable storage media (including, but not limited to, disk storage, optical storage, and the like) having computer-usable program code embodied therein.
The present invention is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems), and computer program products according to embodiments of the invention. It will be understood that each flow and/or block of the flow diagrams and/or block diagrams, and combinations of flows and/or blocks in the flow diagrams and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to a processor of a general purpose computer, special purpose computer, embedded processor, or other programmable data processing apparatus to produce a machine, such that the instructions, which execute via the processor of the computer or other programmable data processing apparatus, create means for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be stored in a computer-readable memory that can direct a computer or other programmable data processing apparatus to function in a particular manner, such that the instructions stored in the computer-readable memory produce an article of manufacture including instruction means which implement the function specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be loaded onto a computer or other programmable data processing apparatus to cause a series of operational steps to be performed on the computer or other programmable apparatus to produce a computer implemented process such that the instructions which execute on the computer or other programmable apparatus provide steps for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
The above description is only a preferred embodiment of the present invention, and is not intended to limit the scope of the present invention.
Claims (7)
1. A data processing method, applied to a home gateway, the method comprising:
receiving a first notification; the first notification is used for notifying the home gateway that the first terminal needs to acquire first resource data; the first terminal is a terminal connected with the home gateway in a downlink manner and can provide services for other P2P nodes in a P2P network when being used as a peer P2P node; the other P2P nodes are terminals which are connected with other home gateways except the home gateway in a downlink mode and are used as P2P nodes;
responding to the first notification, and when the first terminal receives the first resource data, acquiring the first resource data passing through the first terminal;
locally saving the acquired first resource data, and synchronizing the first resource data information to a server, so that the home gateway can provide services for the other P2P nodes aiming at the first resource data;
the timing of the home gateway receiving the first notification includes:
the home gateway receives a first notification before the first terminal selects the requested service content according to the user operation and requests the provider of the first resource data from the server; or,
after the first terminal acquires the provider of the first resource data from the server and before the first resource data is requested to the corresponding provider, the home gateway receives a first notification.
2. The method of claim 1, wherein receiving the first notification comprises:
and receiving a first notification directly sent by the first terminal.
3. The method of claim 1, wherein receiving the first notification comprises:
receiving a first notification sent by the server; the first notification sent by the server is a notification obtained by processing the service information corresponding to the first resource data for the notification sent by the first terminal to the server or a notification directly forwarded by the notification sent by the first terminal to the server.
4. The method of claim 1, wherein prior to obtaining the first resource data that passes through itself, the method further comprises:
receiving first information sent by the first terminal; the first information characterizes transmission related information of the first resource data;
accordingly, the acquiring the first resource data passing through itself includes:
screening out the data packets of the first resource data from the data packets passing through the first information by using the first information;
and analyzing the screened data packet to obtain the first resource data.
5. A home gateway, characterized in that the home gateway comprises:
a receiving unit configured to receive a first notification; the first notification is used for notifying the home gateway that the first terminal needs to acquire first resource data; the first terminal is a terminal connected with the home gateway in a down mode and can provide services for other P2P nodes in a P2P network when being used as a P2P node; the other P2P nodes are terminals which are connected with other home gateways except the home gateway in a downlink mode and are used as P2P nodes;
an obtaining unit, configured to respond to the first notification, and when the first terminal receives the first resource data, obtain the first resource data that passes through the first terminal;
the synchronization unit is used for locally storing the acquired first resource data; and synchronizing the first resource data information to a server to enable the home gateway to provide the other P2P nodes with services for the first resource data;
the timing of the home gateway receiving the first notification includes:
the receiving unit is used for the first terminal to select the requested service content according to the user operation and receive a first notification before requesting the provider of the first resource data from the server; or,
the receiving unit is configured to receive a first notification after the first terminal acquires the provider of the first resource data from the server and before the first terminal requests the corresponding provider for the first resource data.
6. The home gateway according to claim 5, wherein the receiving unit is specifically configured to:
receiving a first notification directly sent by the first terminal;
or,
receiving a first notification sent by the server; the first notification sent by the server is a notification obtained by processing the service information corresponding to the first resource data for the notification sent by the first terminal to the server or a notification directly forwarded by the notification sent by the first terminal to the server.
7. The home gateway according to claim 5, wherein the receiving unit is further configured to receive first information sent by the first terminal; the first information characterizes transmission related information of the first resource data;
correspondingly, the obtaining unit is specifically configured to:
screening out the data packets of the first resource data from the data packets passing through the first information by using the first information;
and analyzing the screened data packet to obtain the first resource data.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201610907771.8A CN107959704B (en) | 2016-10-18 | 2016-10-18 | Data processing method and home gateway |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201610907771.8A CN107959704B (en) | 2016-10-18 | 2016-10-18 | Data processing method and home gateway |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN107959704A CN107959704A (en) | 2018-04-24 |
| CN107959704B true CN107959704B (en) | 2020-01-03 |
Family
ID=61954470
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201610907771.8A Active CN107959704B (en) | 2016-10-18 | 2016-10-18 | Data processing method and home gateway |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN107959704B (en) |
Families Citing this family (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109347968B (en) | 2018-11-07 | 2021-09-24 | 网宿科技股份有限公司 | Method, equipment and system for downloading data blocks of resource file |
| CN111432231B (en) * | 2020-04-26 | 2023-04-07 | 中移（杭州）信息技术有限公司 | Content scheduling method of edge network, home gateway, system and server |
| CN114285788B (en) * | 2020-09-18 | 2023-06-20 | 华为技术有限公司 | Equipment connection method, device and equipment |
| CN112769958B (en) * | 2021-02-05 | 2022-10-04 | 上海哔哩哔哩科技有限公司 | Point-to-point network scheduling method and system |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102461076A (en) * | 2009-06-04 | 2012-05-16 | 瑞典爱立信有限公司 | Method and arrangement for obtaining a media object for a device in a local network |
| CN102904935A (en) * | 2012-09-25 | 2013-01-30 | 中国联合网络通信集团有限公司 | Downloading method, downloading device and downloading system based on home gateway |
Family Cites Families (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US8422397B2 (en) * | 2007-12-28 | 2013-04-16 | Prodea Systems, Inc. | Method and apparatus for rapid session routing |
| US8831032B2 (en) * | 2008-03-05 | 2014-09-09 | Telefonaktiebolaget L M Ericsson (Publ) | SIP-HTTP application correlator |
-
2016
- 2016-10-18 CN CN201610907771.8A patent/CN107959704B/en active Active
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102461076A (en) * | 2009-06-04 | 2012-05-16 | 瑞典爱立信有限公司 | Method and arrangement for obtaining a media object for a device in a local network |
| CN102904935A (en) * | 2012-09-25 | 2013-01-30 | 中国联合网络通信集团有限公司 | Downloading method, downloading device and downloading system based on home gateway |
Also Published As
| Publication number | Publication date |
|---|---|
| CN107959704A (en) | 2018-04-24 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN109640348B (en) | Multi-service MEC network architecture, and method and device for processing multi-service data stream | |
| US20200304508A1 (en) | Method and device for providing authentication in network-based media processing (nbmp) system | |
| US8059560B2 (en) | Tree-type network system, node device, broadcast system, broadcast method, and the like | |
| CN102281190B (en) | Networking method for load balancing apparatus, server and client access method | |
| US20150317583A1 (en) | Business Scheduling Method and Apparatus and Convergence Device | |
| CN107959704B (en) | Data processing method and home gateway | |
| CN113572835B (en) | Data processing method, network element equipment and readable storage medium | |
| CN105391979B (en) | A kind of method and apparatus of business processing | |
| US20130304877A1 (en) | System and method for dynamic configuration of isn store-based overlay network | |
| JP5011433B2 (en) | Method for determining a pair group in the vicinity of another pair, related server, and analysis apparatus | |
| EP2709337B1 (en) | Service data processing method, device and system | |
| US20240022520A1 (en) | Network Connection Handoff | |
| CN115669075A (en) | Private network device and private lan connection, content discovery, data transmission and control method | |
| CN108924609A (en) | Method, electronic equipment, device and the storage medium of transmission of flow media data | |
| CN113382065A (en) | File downloading method, device, system, equipment and storage medium | |
| CN110445723A (en) | A kind of network data dispatching method and fringe node | |
| WO2016180284A1 (en) | Service node allocation method, device, cdn management server and system | |
| CN103916489A (en) | Method and system for resolving single-domain-name multi-IP domain name | |
| JP5726302B2 (en) | Secret or protected access to a network of nodes distributed across a communication architecture using a topology server | |
| CN112217910A (en) | Video service access method, device, network equipment and storage medium | |
| CN112788135B (en) | Resource scheduling method, equipment and storage medium | |
| WO2014117508A1 (en) | Content delivery network and content management method in content delivery network | |
| US10750246B2 (en) | Distributed architecture for mobile streaming content delivery | |
| US11671515B2 (en) | Methods, network node and client device for acquisition and delivery of resources in a communications network | |
| KR20090047426A (en) | The methodology of transmmting live data that uses p2p relays and server's resource concurrently |
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 |