CN107959704A - A kind of data processing method and home gateway - Google Patents

Abstract

The present invention discloses a data processing method, including: a home gateway receives a first notification; the first notification is used to notify the home gateway that the first terminal will acquire first resource data; the first terminal is the The terminal connected to the home gateway, and as a peer-to-peer P2P node can provide services for other P2P nodes in the P2P network; in response to the first notification, when the first terminal receives the first resource data, the home The gateway acquires the first resource data passing through itself; locally saves the acquired first resource data, and synchronizes the information of the first resource data to the server, so that the home gateway can serve as the other P2P node A service for the first resource data is provided. The invention also discloses a home gateway at the same time.

Description

A data processing method and home gateway

technical field

The present invention relates to a content distribution network (CDN, Content Delivery Network), in particular to a data processing method and a home gateway.

Background technique

Peer-to-peer connection content distribution network (P2P CDN, Peer to Peer CDN) technology is a new CDN technology that uses user equipment as an edge node of CDN content service to serve other users. The core idea of P2P CDN is to use user resources to realize content distribution services between user devices through user terminal devices with equal identities, that is, different user devices serve as different P2P nodes to request video services for other user devices. Provide video content distribution service, which is different from the client/server (C/S) transmission model of traditional CDN where the content service edge node server provides service for the video service request of the user equipment.

In P2P CDN, when each P2P client receiving video receives video content, it also acts as a server to provide service capabilities for other users who try to receive the video. However, due to the limited service capability of each terminal device, a P2P client (as a P2P node) generally can only provide services for 2-3 other P2P nodes, thus greatly affecting the service capability of the P2P system.

Contents of the invention

In order to solve the existing technical problems, the embodiment of the present invention provides a data processing method and a home gateway.

The technical scheme of the embodiment of the present invention is realized like this:

An embodiment of the present invention provides a data processing method applied to a home gateway, including:

Receive a first notification; the first notification is used to notify the home gateway that the first terminal will obtain first resource data; the first terminal is a terminal connected to the home gateway, and serves as a peer-to-peer (P2P , Peer to Peer) node can provide services for other P2P nodes in the P2P network;

In response to the first notification, when the first terminal receives the first resource data, acquire the first resource data passing through itself;

Save the obtained first resource data locally, and synchronize the information of the first resource data to a server, so that the home gateway can provide services for the other P2P nodes with respect to the first resource data.

In the above solution, the receiving the first notification includes:

Receive the first notification directly sent by the first terminal.

In the above solution, the receiving the first notification includes:

receiving the first notification sent by the server; the first notification sent by the server is a notification after the service information corresponding to the first resource data is processed on the notification sent by the first terminal to the server or is A notification that directly forwards the notification sent by the first terminal to the server.

In the above solution, before obtaining the first resource data passing through itself, the method further includes:

receiving first information sent by the first terminal; the first information represents transmission-related information of the first resource data;

Correspondingly, the acquisition of the first resource data through itself includes:

using the first information to filter out the data packets of the first resource data from the data packets passing through itself;

Analyzing the filtered data packets to obtain the first resource data.

In the above solution, the home gateway receives 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.

In the above solution, after the first terminal obtains 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 the first notification.

The embodiment of the present invention also provides a home gateway, including:

a receiving unit, configured to receive a first notification; the first notification is used to notify the home gateway that the first terminal will acquire first resource data; the first terminal is a terminal connected to the home gateway, and As a P2P node, it can provide services for other P2P nodes in the P2P network;

An acquiring unit, configured to respond to the first notification, when the first terminal receives the first resource data, acquire the first resource data passing through itself;

A synchronizing unit, configured to store the obtained first resource data locally; and synchronize the information of the first resource data to a server, so that the home gateway can provide the other P2P nodes with data service.

In the above solution, the receiving unit is specifically used for:

receiving a first notification directly sent by the first terminal;

or,

receiving the first notification sent by the server; the first notification sent by the server is a notification after the service information corresponding to the first resource data is processed on the notification sent by the first terminal to the server or is A notification that directly forwards the notification sent by the first terminal to the server.

In the above solution, the receiving unit is further configured to receive first information sent by the first terminal; the first information represents transmission-related information of the first resource data;

Correspondingly, the acquisition unit is specifically used for:

using the first information to filter out the data packets of the first resource data from the data packets passing through itself;

Analyzing the filtered data packets to obtain the first resource data.

In the above solution, the receiving unit 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.

In the above solution, the receiving unit is configured to receive the first resource data after the first terminal obtains the provider of the first resource data from the server and before requesting the first resource data from the corresponding provider. Notice.

In the data processing method and the home gateway provided by the embodiments of the present invention, the home gateway receives a first notification; the first notification is used to notify the home gateway that the first terminal will acquire first resource data; the first terminal is The terminal connected to the home gateway and as a peer-to-peer P2P node can provide services for other P2P nodes in the P2P network; the home gateway responds to the first notification, when the first terminal receives the first When acquiring resource data, acquire the first resource data passing through itself; the home gateway saves the acquired first resource data locally, and synchronizes the information of the first resource data to the server, so that the home gateway The service for the first resource data can be provided for the other P2P nodes, and the home gateway serves as the P2P node for other P2P nodes. In this way, the overall service capability of the P2P system can be greatly improved.

Description of drawings

In the drawings (which are not necessarily drawn to scale), like reference numerals may describe like parts in different views. Similar reference numbers with different letter suffixes may indicate different instances of similar components. The drawings generally illustrate the various embodiments discussed herein, by way of example and not limitation.

FIG. 1 is a schematic diagram of the architecture of a P2P CDN system in the related art;

FIG. 2 is a schematic diagram of a network structure in which a terminal device is connected to the Internet in a wired broadband access mode in the related art;

3 is a schematic flow chart of a data processing method according to Embodiment 1 of the present invention;

FIG. 4 is a schematic flowchart of a method for providing a service by a home gateway in Embodiment 2 of the present invention;

FIG. 5 is a schematic flowchart of a method for providing a service by a home gateway in Embodiment 3 of the present invention;

FIG. 6 is a schematic structural diagram of a home gateway according to Embodiment 4 of the present invention.

Detailed ways

The present invention will be further described in detail below in conjunction with the accompanying drawings and embodiments.

Figure 1 is a schematic diagram of a P2P CDN system architecture. It can be seen from Figure 1 that the P2P CDN system mainly includes a policy center and a Tracker server. in,

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, etc.

The Tracker server realizes the global control and scheduling function of the P2P CDN system, and is a unified entry server accessed by end users. The Tracker server maintains the IP address and port number information of all downloaders of the file. After the set-top box terminal P2P node is started and is in an idle state, the Tracker server regularly performs content pre-push, and when a certain user device requests to obtain a certain video content, it returns the available information. A list of P2P nodes that provide distribution services for this content.

At the same time, in the content distribution process of P2P CDN technology, in order to shorten the transmission delay when a P2P node serves another P2P node, the shortest content distribution transmission path (route) will be selected as much as possible. For example, when the dispatching server (tracker server) of the P2PCDN system receives a request from user A to obtain a certain content, it retrieves information in the adjacent area where user A is located (for example, the same broadband remote access server ( When there are currently other P2P nodes (maybe more than one) in the BRAS (Broadband Remote Access Server) device that can provide content distribution services for it, these P2P nodes should be preferred to provide services for user A.

The business process for users to obtain video content services in the existing P2P CDN system includes:

Step A1: User X1 selects a certain video program A to watch through a video player on a personal computer (PC, Personal Computer) or a set-top box; at the same time, the P2P client on its terminal device registers with the Tracker server as a P2P node X1 The user X2 selects the desired video program A through the video player on the PC or set-top box; at the same time, the P2P client on the terminal device registers on the Tracker server as a P2P node X2, and informs the server self is online;

Here, when the P2P node X1 obtains the video program A, it can subsequently serve as a server to provide video services of the video program A to other P2P nodes.

Step B: User X1's P2P node X1 (as the receiver 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; user X2's P2P node X2 (this As the receiver of the video service) request the Tracker server for the list of other P2P nodes (video service providers) that can provide the distribution service of the current content A;

Step C: After receiving the request from P2P node X1, the Tracker server (scheduling center) synthesizes the P2P node information collected by itself (whether there is storage content A, service capability, etc.), and the distance information between these P2P nodes and P2P node X1, Return the information list of several candidate P2P nodes that can provide services to P2P node X1; after receiving the request from P2P node X2, synthesize the P2P node information collected by itself (whether there is storage content A, service capabilities, etc.), and these The distance information between the P2P node and the P2P node X2 returns to the P2P node X2 an information list of several candidate P2P nodes that can provide services for it;

Here, for each P2P node in the list, its information includes the IP address (required) and port (optional) information of the P2P node.

Step D: According to the P2P node list information, P2P node X1 connects to other P2P nodes to request data fragments of the video content, obtain video content services, and play video content for users after obtaining video content; P2P node X1 according to P2P Node list information, connect to P2P node X1 to request to obtain data fragments of video content A, obtain video content services, and play video content for users after obtaining video content.

It can be seen from the above description that each P2P client receiving video currently serves as a server to provide live broadcast service capabilities for other users who try to receive the video when receiving video content. However, due to the service capability of each terminal device Limited (limited by terminal processing capability, disk input/output (I/O, Input/Output) read rate, uplink network bandwidth and other factors), generally only can provide services for 2-3 other P2P nodes, thus greatly Affects the serviceability of the system.

In addition, for live video, when more P2P users request to receive the live broadcast service, the users who access later can only receive the service as the lower-level users of the upper-level users through multi-layer superposition. Video content will generate a large delay, and as the cumulative level of P2P upper-level nodes serving lower-level nodes increases, the live broadcast delay will also increase cumulatively. Therefore, when providing live broadcast services through the P2P system, it is necessary to tap more devices that may provide live broadcast services as first-level service P2P nodes, thereby improving the overall service capability of the P2P system and shortening the 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 through pre-distribution, there is also the problem of time delay accumulation caused by the multi-layer overlay service of the live service, but there is also a limited service capability of the terminal equipment (Limited by factors such as terminal processing capability, disk I/O read rate, and uplink network bandwidth), resulting in insufficient overall service capability of the P2P system.

Meanwhile, FIG. 2 is a schematic diagram of a network structure connected to the Internet through wired broadband access. As shown in Figure 2, the home gateway is the terminal device of the operator's network in the home. It is located in the center of the user's home network and is responsible for connecting and managing various service terminal devices in the home. Terminals (OLT, Optical Line Terminal), BRAS and other devices are connected to realize the function of wired broadband network access services. Among them, the OLT is used to connect the terminal equipment of the optical fiber trunk line, which is the optical access network equipment connected to the gateway equipment; the BRAS is the broadband access server, which is located at the edge of various large-scale IP networks and provides access , authentication and billing functions, for example, a home gateway can help users access the Internet through this device.

For the access network based on wired broadband, when users access the Internet through various devices such as set-top boxes, PCs, and mobile phones, they need to connect to the Internet through home gateway devices (via OLT, BRAS, etc.). In the CDN system, all kinds of business data of the terminal as a P2P node can only be sent to other devices not in the home network where it is located through the home gateway.

Based on this, in various embodiments of the present invention: the home gateway receives the first notification; the first notification is used to notify the home gateway that the first terminal will obtain the first resource data; the first terminal is The terminal connected to the home gateway, and as a P2P node, can provide services for other P2P nodes in the P2P network; in response to the first notification, when the first terminal receives the first resource data, obtain the passed The first resource data of itself; locally save the acquired first resource data, and synchronize the information of the first resource data to the server, so that the home gateway can provide the other P2P nodes with The service of the first resource data.

That is to say, in various embodiments of the present invention, utilizing the characteristic that the data of the home terminal must pass through the home gateway, a new P2P node function is added on the home gateway, and a new P2P node function is added on terminal devices such as set-top boxes and on the home gateway. Add the function of terminal devices such as set-top boxes to notify the home gateway device that it will obtain service data, so that the home gateway can store the service data synchronously when its downstream connected (subordinate) set-top boxes or PCs and other terminal devices obtain service data, so that The home gateway device also becomes a P2P node service provider with the content of the service data in the P2P network, and can provide the service data for other P2P nodes.

Embodiment one

The embodiment of the present invention provides a data processing method, which is applied to a home gateway and is applicable to a P2P CDN system.

The method for data processing in the embodiment of the present invention, as shown in Figure 3, comprises 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 will acquire the first resource data.

Wherein, the first terminal is a terminal connected to the home gateway, and as a P2P node, it can provide services for other P2P nodes in the P2P network.

In actual 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 with a video playing function, such as a PC.

In practical application, the time when the home gateway receives the first notification may be: before 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 to say, 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 home gateway receives the first notification.

The timing for the home gateway to receive the first notification may also be: after the first terminal acquires the provider of the first resource data and before requesting the first resource data from the corresponding provider. That is to say, 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 the first notification.

In actual application, the home gateway may receive the first notification in one of the following ways:

In the first manner, the first terminal directly sends the first notification to the home gateway, that is, through local area network communication, that is, the home gateway receives the first notification directly sent by the first terminal .

In the second way, the first terminal sends the first notification to the home gateway through the relay of the server, that is, relays the communication through the server, that is, the home gateway receives the first notification sent by the server. A notification; the first notification sent by the server is a notification sent by the first terminal to the server after processing service information corresponding to the first resource data or a notification sent by the first terminal Notifications to the server are forwarded directly to the notifications.

Here, the processing of service information corresponding to the first resource data refers to: adding and/or deleting some necessary service information corresponding to the first resource data, such as: increasing service validity period and so on.

Step 302: Responding to the first notification, when the first terminal receives the first resource data, the home gateway acquires the first resource data passing through itself;

Here, in actual application, after the first terminal acquires information related to the transmission of the first resource data, such as: the IP address of at least one P2P node that provides the first resource data for the first terminal, the When receiving various information such as the IP packet number of the first resource data or the receiving time of receiving the first resource data, the home gateway may be notified of these transmission related information, so that the home gateway can quickly locate, Filter out the data that needs to be saved.

Based on this, in an embodiment, before performing this step, the method may also include:

receiving first information sent by the first terminal; the first information represents transmission-related information of the first resource data;

Correspondingly, the specific implementation of this step may include:

using the first information to filter out the data packets of the first resource data from the data packets passing through itself;

Analyzing the filtered data packets to obtain the first resource data.

In this way, the home gateway can quickly locate and screen the P2P data that needs to be obtained from all the network data passing through itself (the home gateway may also be connected to other terminal devices other than the first terminal, such as other computers, mobile phones, etc.). The business resource data simplifies the processing method that the home gateway needs to analyze each packet of a large number of data packets, and improves the processing efficiency.

Step 303: The home gateway saves the acquired first resource data locally, and synchronizes the information of the first resource data to a server.

Here, the purpose of the home gateway saving the first resource data locally and synchronizing the first resource data information to the server is: when the home gateway acts as a P2P node, the home gateway can serve as the other The P2P node provides a service for the first resource data.

In the data processing method provided by the embodiment of the present invention, the home gateway receives a first notification; the first notification is used to notify the home gateway that the first terminal will acquire first resource data; the first terminal is the first resource data of the home A terminal connected to the gateway, and as a peer-to-peer P2P node, can provide services for other P2P nodes in the P2P network; the home gateway responds to the first notification, and when the first terminal receives the first resource data , acquire the first resource data passing through itself; the home gateway saves the acquired first resource data locally, and synchronizes the information of the first resource data to a server, so that the home gateway can be used for all The other P2P nodes provide services for the first resource data, and the home gateway serves as a P2P node to provide services for other P2P nodes. In this way, the overall service capability of the P2P system can be greatly improved.

In addition, the first information sent by the first terminal is received; the first information represents the transmission-related information of the first resource data; the home gateway uses the first information to filter data packets passing through itself get the data packet of the first resource data; the home gateway parses and screens out the data packet to obtain the first resource data, and the home gateway can obtain the first resource data from all the network data passing through itself (there may be connected under the home gateway except the first The P2P service resource data to be obtained can be quickly located and screened in other terminal devices other than a terminal, such as other computers, mobile phones, etc., so that the processing efficiency is greatly improved.

Embodiment two

On the basis of the first embodiment, this embodiment takes a set-top box as an example to describe in detail the process of how the home gateway serves as a P2P node to provide services for other P2P nodes.

It should be noted that: the P2P node on each device refers to: the device is equipped with a P2P functional module.

As shown in Figure 4, the process that the home gateway serves as a P2P node for other P2P nodes mainly includes the following steps:

Step 401: User X selects a desired video program A through the first video player on the first set-top box;

Step 402: the first video player sends a content access request to the first P2P node on the first set-top box according to the user's request;

Here, the content access request carries the URL of program A.

Step 403: After receiving the request, the first P2P node processes the request, that is, registers with the Tracker server, and informs the server that it is online, so as to prepare to obtain the content of program A from the P2P CDN;

Step 404: the first P2P node notifies the second P2P node on the home gateway that it will start to acquire the content service of program A;

Here, in actual application, the specific implementation of this step may include:

Step 404a: the first P2P node directly sends a notification to the second P2P node;

Step 404b: After receiving the notification, the second P2P node returns a response to the first P2P node.

That is to say, the first P2P node communicates with the second P2P node through the local area network, so that the first P2P node notifies the second P2P node that it will start to acquire the content service of program A.

The specific implementation of this step may also include:

Step 404A: the first P2P node sends a notification to the 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 the second P2P node;

Step 404D: The second P2P node returns a response to the Tracker server.

That is to say, the second P2P node relays the communication with the second P2P node through the Tracker server, so that the first P2P node notifies the second P2P node that it will start to acquire the content service of program A.

Step 405: the first P2P node (at this time as the receiver 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 406: After receiving the request from the first P2P node, the Tracker server returns an information list of several candidate P2P nodes that can provide services to the first P2P node;

Here, the Tracker server integrates the P2P node information collected by itself (whether the content of program A is stored, service capabilities, etc.), and the distance information between these P2P nodes and the first P2P node, and returns to the first P2P node to provide services for it The information list of several candidate P2P nodes.

Wherein, for each P2P node in the list, its information includes the IP address (required) and port (optional) information of the P2P node.

Step 407: According to the P2P node list information, the first P2P node selects the third P2P node and the super P2P node as the content provider of program A, and requests the data of 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 passing the authentication, the super P2P node sends the data of program A to the first P2P;

Step 410: After receiving the response, the first P2P node requests the data of 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 passing the authentication, the third P2P node sends the data of program A to the first P2P node through the home gateway;

Here, it needs to be explained that in practical applications, super P2P nodes (compared with other nodes that can provide services, have stronger service capabilities, that is, they can provide services for more P2P nodes) are optional. There does not necessarily exist a super P2P node in ; in addition, the first P2P node does not necessarily obtain services through the super P2P node.

When the first P2P node does not obtain the service through the super P2P node, steps 407-409 are not executed.

Step 413: After receiving the data of program A, the home gateway acquires the data of program A and stores it locally;

Step 414: The home gateway sends the resource synchronization information to the Tracker server to inform the Tracker server that it has program A data;

Step 415: After the Tracker server receives the information, it updates its own resource list;

Step 416: the Tracker server returns a synchronous response to the home gateway;

Step 417: After receiving the data of program A, the first P2P node stores the data of program A locally;

Step 418: The first P2P node sends the resource synchronization information to the Tracker server to inform the Tracker server that it has program A data;

Step 419: After the Tracker server receives the information, it updates its own resource list;

Step 420: the Tracker server returns a synchronous response to the first P2P node;

Step 421: the first P2P node returns the data of program A to the first video player;

Step 422: The first video player plays program A;

Here, in actual application, steps 418-420 and 421-422 are executed in no order.

Step 423: When user Y selects a certain video program A desired to watch through the second video player on the second set-top box, the fourth P2P node on the second set-top box registers on the Tracker server and informs the server that it has gone online;

Here, the interaction between the second video player and the fourth P2P node is the same as the description of step 402 .

Step 424: the fourth P2P node (at this time as the receiver 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 from the fourth P2P node, the Tracker server returns an information list of several candidate P2P nodes that can provide services to the fourth P2P node;

Here, the Tracker server integrates the P2P node information collected by itself (whether there is stored program A content, service capabilities, etc.), and the distance information between these P2P nodes and the fourth P2P node, and returns to the fourth P2P node to provide services for it The information list of several candidate P2P nodes.

Wherein, for each P2P node in the list, its information includes the IP address (required) and port (optional) information of the P2P node.

Step 426: According to the P2P node list information, the fourth P2P node connects to other P2P nodes to request data fragments of program A, obtain video content services, and play video content for users after obtaining video content.

Wherein, when acquiring video content, the video content service of program A may be acquired through the home gateway, or the video content service of program A may be acquired through the first P2P node.

It can be seen from the above description that in this embodiment, the timing when the first set-top box notifies the home gateway that it will obtain the content service of program A is: the first set-top box receives the service selected by the user and requests the tracker server for the content service of program A. before the content provider.

Embodiment three

On the basis of the first embodiment, this embodiment takes a set-top box as an example to describe in detail the process of how the home gateway serves as a P2P node to provide services for other P2P nodes.

It should be noted that: the P2P node on each device refers to: the device is equipped with a P2P functional module.

The difference from Embodiment 2 is that the timing when the first set-top box notifies the home gateway that it will obtain the content service of program A is: after the first P2P node on the first set-top box obtains the information list of candidate P2P nodes from the Tracker server and sends the corresponding before the P2P node requests the program's data.

As shown in Figure 5, the process that the home gateway serves as a P2P node for other P2P nodes mainly includes the following steps:

Step 501: User X selects a certain video program A desired to watch through the first video player on the first set-top box;

Step 502: the first video player sends a content access request to the first P2P node on the first set-top box according to the user's request;

Here, the content access request carries the URL of program A.

Step 503: After receiving the request, the first P2P node processes the request, that is, registers with the Tracker server, and informs the server that it is online, so as to prepare to obtain the content of program A from the P2P CDN;

Step 504: the first P2P node (at this time as the receiver 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 505: After receiving the request from the first P2P node, the Tracker server returns an information list of several candidate P2P nodes that can provide services to the first P2P node;

Here, the Tracker server integrates the P2P node information collected by itself (whether the content of program A is stored, service capabilities, etc.), and the distance information between these P2P nodes and the first P2P node, and returns to the first P2P node to provide services for it The information list of several candidate P2P nodes.

Wherein, for each P2P node in the list, its information includes the IP address (required) and port (optional) information of the P2P node.

Step 506: According to the P2P node list information, the first P2P node selects the third P2P node and the super P2P node as the content provider of the program A, 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 passing the authentication, the super P2P node sends the data of program A to the first P2P;

Here, in practical applications, super P2P nodes (compared with other nodes that can provide services, have stronger service capabilities, that is, can provide services for more P2P nodes) are optional, and there may not be super nodes in the network. P2P node; In addition, the first P2P node does not necessarily obtain services through the super P2P node.

When the first P2P node does not obtain the service through the super P2P node, steps 506-508 are not performed.

Step 509: After receiving the data, the first P2P node notifies the second P2P node on the home gateway to start acquiring the content service of program A;

Here, in actual application, the specific implementation of this step may include:

Step 509a: the first P2P node directly sends a notification to the second P2P node;

Step 509b: After receiving the notification, the second P2P node returns a response to the first P2P node.

That is to say, the first P2P node communicates with the second P2P node through the local area network, so that the first P2P node notifies the second P2P node that it will start to acquire the content service of program A.

The specific implementation of this step may also include:

Step 509A: the first P2P node sends a notification to the 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 the second P2P node;

Step 509D: the second P2P node returns a response to the Tracker server.

That is to say, the second P2P node relays the communication with the second P2P node through the Tracker server, so that the first P2P node notifies the second P2P node that it will start to acquire the content service of program A.

Step 510: After notifying the home gateway, the first P2P node requests the data of 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 passing the authentication, the third P2P node sends the data of program A to the first P2P node through the home gateway;

Step 513: After receiving the data of program A, the home gateway acquires the data of program A and stores it locally;

Step 514: The home gateway sends the resource synchronization information to the Tracker server to inform the Tracker server that it has program A data;

Step 515: After the Tracker server receives the information, it updates its own resource list;

Step 516: the Tracker server returns a synchronous response to the home gateway;

Step 517: After receiving the data of program A, the first P2P node stores the data of program A locally;

Step 518: The first P2P node sends the resource synchronization information to the Tracker server to inform the Tracker server that it has program A data;

Step 519: After the Tracker server receives the information, it updates its own resource list;

Step 520: the Tracker server returns a synchronization response to the first P2P node;

Step 521: the first P2P node returns the data of program A to the first video player;

Step 522: The first video player plays program A;

Here, in actual application, steps 518-520 and 521-522 are executed in no order.

Step 523: When user Y selects a certain video program A desired to watch through the second video player on the second set-top box, the fourth P2P node on the second set-top box registers on the Tracker server and informs the server that it has gone online;

Here, the interaction between the second video player and the fourth P2P node is the same as the description of step 402 .

Step 524: The fourth P2P node (as the receiver of the video service at this time) requests the Tracker server for a list of other P2P nodes (video service providers) that can provide the distribution service of the current program A;

Step 525: After receiving the request from the fourth P2P node, the Tracker server returns an information list of several candidate P2P nodes that can provide services to the fourth P2P node;

Here, the Tracker server integrates the P2P node information collected by itself (whether there is stored program A content, service capabilities, etc.), and the distance information between these P2P nodes and the fourth P2P node, and returns to the fourth P2P node to provide services for it The information list of several candidate P2P nodes.

Wherein, for each P2P node in the list, its information includes the IP address (required) and port (optional) information of the P2P node.

Step 526: According to the P2P node list information, the fourth P2P node connects to other P2P nodes to request data fragments of program A, obtain video content services, and play video content for users after obtaining video content.

Wherein, when acquiring video content, the video content service of program A may be acquired through the home gateway, or the video content service of program A may be acquired through the first P2P node.

Embodiment four

In order to realize the method of the embodiment of the present invention, the embodiment provides a home gateway suitable for a P2P CDN system.

As shown in Figure 6, the home gateway of the embodiment of the present invention includes:

The receiving unit 61 is configured to receive a first notification; the first notification is used to notify the home gateway that the first terminal will acquire first resource data; the first terminal is a terminal connected to the home gateway, And as a P2P node, it can provide services for other P2P nodes in the P2P network;

An acquiring unit 62, configured to respond to the first notification, when the first terminal receives the first resource data, acquire the first resource data passing through itself;

A synchronizing unit 63, configured to store the obtained first resource data locally; and synchronize the information of the first resource data to a server, so that the home gateway can provide the other P2P nodes with Resource data service.

Wherein, in actual 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 with a video playing function such as a PC.

In practical application, the time when the home gateway receives the first notification may be: before 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 to say, 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 for the home gateway to receive the first notification may also be: after the first terminal acquires the provider of the first resource data and before requesting the first resource data from the corresponding provider. That is to say, the receiving unit 61 is configured to receive the first resource data after the first terminal obtains the provider of the first resource data from the server and before requesting the first resource data from the corresponding provider. a notice.

In actual application, the receiving unit 61 may receive the first notification in one of the following ways:

In the first way, the first terminal directly sends the first notification to the home gateway, that is, through local area network communication, that is, the receiving unit 61 receives the first notification directly sent by the first terminal. Notice.

In the second way, the first terminal sends the first notification to the home gateway through the transfer of the server, that is, transfers the communication through the server, that is, the receiving unit 61 receives the notification sent by the server. The first notification: the first notification sent by the server is a notification after the service information corresponding to the first resource data is processed on the notification sent by the first terminal to the server, or it is a notification sent by the first terminal Notifications sent to the server are forwarded directly to the notifications.

Wherein, the processing of service information corresponding to the first resource data refers to: adding and/or deleting some necessary service information corresponding to the first resource data, such as: increasing service validity period and so on.

Here, in actual application, after the first terminal acquires information related to the transmission of the first resource data, such as: the IP address of at least one P2P node that provides the first resource data for the first terminal, the When receiving various information such as the IP packet number of the first resource data or the receiving time of receiving the first resource data, the home gateway may be notified of these transmission related information, so that the home gateway can quickly locate, Filter out the data that needs to be saved.

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 represents transmission-related information of the first resource data;

Correspondingly, the acquiring unit 62 is specifically configured to:

using the first information to filter out the data packets of the first resource data from the data packets passing through itself;

Analyzing the filtered data packets to obtain the first resource data.

In this way, the home gateway can quickly locate and screen the P2P data that needs to be obtained from all the network data passing through itself (the home gateway may also be connected to other terminal devices other than the first terminal, such as other computers, mobile phones, etc.). The business resource data simplifies the processing method that the home gateway needs to analyze each packet of a large number of data packets, and improves the processing efficiency.

The purpose of the synchronization unit saving the first resource data locally and synchronizing the first resource data information to the server is: when the home gateway is a P2P node, the home gateway can be the other P2P node A service for the first resource data is provided.

During actual application, the receiving unit 61 can be realized by a transceiver in the home gateway; Unit), a digital signal processor (DSP, Digital Signal Processor) or a programmable logic array (FPGA, Field-Programmable Gate Array) combined 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 to notify the home gateway that the first terminal will acquire first resource data; the first terminal is the The terminal connected to the home gateway, and as a peer-to-peer P2P node can provide services for other P2P nodes in the P2P network; the acquisition unit 62 responds to the first notification, when the first terminal receives the first resource data, obtain the first resource data passed through itself; the synchronization unit 63 saves the obtained first resource data locally, and synchronizes the information of the first resource data to the server, so that the family The gateway can provide the other P2P nodes with services for the first resource data, and the home gateway as a P2P node provides services for other P2P nodes. In this way, the overall service capability of the P2P system can be greatly improved.

In addition, the receiving unit 61 receives the first information sent by the first terminal; the first information represents the transmission-related information of the first resource data; the obtaining unit 62 uses the first information to obtain The data packets of the first resource data are screened out from its own data packets; the acquisition unit 62 parses the screened data packets to obtain the first resource data, and the home gateway can obtain all network data (home gateway There may be other terminal devices other than the first terminal (such as other computers, mobile phones, etc.) to quickly locate and filter the P2P service resource data that needs to be obtained. In this way, the processing efficiency is greatly improved.

Those skilled in the art should understand that the embodiments of the present invention may be provided as methods, systems, or computer program products. Accordingly, the present invention can 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 and optical storage, etc.) 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 should be understood that each procedure and/or block in the flowchart and/or block diagram, and a combination of procedures and/or blocks in the flowchart and/or block diagram can be realized by computer program instructions. These computer program instructions may be provided to a general purpose computer, special purpose computer, embedded processor, or processor of other programmable data processing equipment to produce a machine such that the instructions executed by the processor of the computer or other programmable data processing equipment produce a An apparatus for realizing the functions specified in one or more procedures of the flowchart and/or one or more blocks of the block diagram.

These computer program instructions may also be stored in a computer-readable memory capable of directing a computer or other programmable data processing apparatus to operate in a specific manner, such that the instructions stored in the computer-readable memory produce an article of manufacture comprising instruction means, the instructions The device realizes the function specified in one or more procedures of the flowchart and/or one or more blocks of the block diagram.

These computer program instructions can also be loaded onto a computer or other programmable data processing device, causing a series of operational steps to be performed on the computer or other programmable device to produce a computer-implemented process, thereby The instructions provide steps for implementing the functions specified in the flow chart or blocks of the flowchart and/or the block or blocks of the block diagrams.

The above descriptions are only preferred embodiments of the present invention, and are not intended to limit the protection scope of the present invention.

Claims (11)

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 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, 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.

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. The method according to any of claims 1 to 4, wherein 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 from the server.

6. The method according to any one of claims 1 to 4, wherein the home gateway receives the first notification after the first terminal obtains the provider of the first resource data from the server and before requesting the first resource data from the corresponding provider.

7. 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 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.

8. The home gateway according to claim 7, 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.

9. The home gateway according to claim 7, 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.

10. The home gateway according to any of claims 7 to 9, wherein the receiving unit is configured to receive the 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 from the server.

11. The home gateway according to any one of claims 7 to 9, wherein the receiving unit is configured to receive a first notification after the first terminal acquires the provider of the first resource data from a server and before the first terminal requests the corresponding provider for the first resource data.