CN101567769A - Data retransmission method, system and peer-to-peer node - Google Patents
Data retransmission method, system and peer-to-peer node Download PDFInfo
- Publication number
- CN101567769A CN101567769A CNA2008100668370A CN200810066837A CN101567769A CN 101567769 A CN101567769 A CN 101567769A CN A2008100668370 A CNA2008100668370 A CN A2008100668370A CN 200810066837 A CN200810066837 A CN 200810066837A CN 101567769 A CN101567769 A CN 101567769A
- Authority
- CN
- China
- Prior art keywords
- data
- peer node
- request message
- client
- retransmission request
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Images
Landscapes
- Computer And Data Communications (AREA)
Abstract
The embodiment of the invention discloses a data retransmission method, a system and a peer-to-peer node. The method is applied to the P2P field and comprises the following steps: receiving retransmission request information sent by a client side, inquiring whether data requested by the retransmission request information for retransmission is locally stored or not according to the retransmission request information; and transmitting the data to the client side when data requested by the data retransmission request information for retransmission is stored locally. The embodiment of the invention can realize packet loss and packet error retransmission of the data without huge content resources, thereby improving the transmission efficiency, and lightening the content resources and the load of the the peer-to-peer node used as the agent thereof.
Description
Technical field
The present invention relates to the network communications technology, be applied to the P2P technical field, relate in particular to a kind of data repeating method, system and peer node.
Background technology
Adopt P2P (Peer-to-Peer, peer-to-peer network) technology, can make the two or more PCs or miscellaneous equipment direct communication or the cooperation that are arranged in the P2P network, each other shared resource (as disposal ability, memory space and data etc.).The essence of P2P technology is Distributed Calculation, its maximum characteristics are that the ability of each computer on the network (particularly ustomer premises access equipment) can be not fully exerted, reduced in traditional Client/Server (client/server) network architecture, the costliness expenditure (comprising software, hardware, communication and human input etc.) that needs owing to server has also been avoided problems such as the computing capability bottleneck that may cause owing to adopt server and Single Point of Faliure.After adopting the P2P technology, make network system have lower operation cost and the extended capability of Geng Gao.
Referring to Fig. 1, be P2P overlay network (P2P Overlay) the networking schematic diagram of Peer (node)-Client (client) structure.Wherein, all Peer nodes are formed the P2P overlay network, have functions such as P2P searches, route; Hang under the Client under the Peer node,, carry out alternately with other Peer or Client by the route and the locating function of Peer node.Can adopt the Peer node of the comparatively stable network equipment of support P2P technology as the P2P stacking network, be responsible in the P2P stacking network, carrying out with the resource content be index distributed storage and search, at this moment, serve as the terminal node of Client and only consult alternately, and do not need the concrete topological structure and the operating mechanism thereof of perception P2P stacking network inside with the network equipment that serves as the Peer node.Like this, isolated mutual each other between the terminal node that time hangs under the different network equipments by stable network equipment comparatively, reduced owing to influencing each other of causing alternately.Each network equipment is preserved the local resource table, transaction table, transmits and key-value pair (Key/Value) table etc.; Wherein, the local resource table is used for the service available resource information of record local (each terminal node that this network equipment is hung down); Transaction table is used to manage the forwarding information of each resource content correspondence; Transmit and be used for when network device hardware is transmitted, providing forwarding information; Key/Value table is used to write down the resource information that is published on the P2P stacking network (for each resource, can come unique identification with an identifier key, as filename being carried out Hash, can obtain the key of a unique identification this document etc.) by hash function.The network equipment that utilize to support the P2P technology is as the Peer node, can be intelligently for terminal node agent service demand and corresponding network service is provided.
When the propagation of real-time service (for example IPTV) on the P2P network, need the P2P network to provide QoS to guarantee, so real-time service is relatively more responsive to time-delay, packet loss and the wrong bag of P2P network.But present industry does not have practical solution and can address this problem.
Summary of the invention
The embodiment of the invention provides a kind of data repeating method, system and peer node, in order to the data re-transmission problem behind packet loss, the wrong bag to take place on the transmission path between solving in the P2P network from the data source to terminal use.
The described data repeating method of the embodiment of the invention comprises:
Receive the retransmission request message that client sends,
Whether inquiry is local stores the data of described retransmission request message institute request retransmission;
When this locality stores the data of described data re-transmission request message institute request retransmission, described data are sent to client.
The described system of the embodiment of the invention comprises:
Client is used to send retransmission request message;
First peer node is used to receive the retransmission request message that client sends, and whether inquiry is local stores the data of described retransmission request message institute request retransmission; When this locality stores the data of described data re-transmission request message institute request retransmission, described data are sent to client.
The described peer node of the embodiment of the invention comprises:
Receiving element is used to receive retransmission request message;
Query unit is used to inquire about the local data that whether store described retransmission request message institute request retransmission;
Transmitting element is used for when query unit determines that this locality stores the data that described resend messages asks described data being sent.The embodiment of the invention also is not too stable present situation based on the P2P network performance, by memory module or side extension storage server are set on the peer node as client and content source agency in the P2P network, make in the content delivery process and error in data to take place or when losing, client only need send to retransmission request message the peer node of serving client, when storing the data of client institute request retransmission on the peer node of serving client, do not need a large amount of participations of content source can realize that the wrong bag of packet loss of data retransmits, improved efficiency of transmission, alleviated content source and as the burden of its agency's peer node.
Description of drawings
Fig. 1 is the P2P stacking network networking schematic diagram of the Peer-Client structure that provides of prior art;
The structural representation of the data re-transmission system that Fig. 2 provides for the embodiment of the invention;
The flow chart of the data repeating method that Fig. 3 provides for the embodiment of the invention;
The structural representation of the peer node that Fig. 4 provides for the embodiment of the invention.
Embodiment
The present invention is described in detail below in conjunction with drawings and Examples.
As shown in Figure 2, the structural representation of the data re-transmission system that provides for the embodiment of the invention.This system comprises content providers 201, and being used for provides content to the P2P network; Peer node (202,203) for supporting the network equipment of P2P technology, network node as the P2P overlay network, for client 206 provides the business interface that is connected the P2P overlay network with content providers 201, agent client 206 and content providers 201 participate in the P2P network activity and provide services on the Internet to client 206, specifically in the present embodiment, the peer node 202 that connects content providers 201 is used for the content information that content providers 201 provides is published to P2POverlay, and these data is offered simultaneously the peer node 203 of storage server 204 and reception data in the transmission data; The peer node 203 that connects client 206 is used for providing service according to the request of client 206 to it, and after the retransmission request message of receiving client 206, carries out data re-transmission to client 206; Storage server 204 is used for storing the content that peer node 202 receives, and storage server 205 is used for storing the content that peer node 203 receives; Client 206 is used for initiating content requests, carries out the wrong bag of packet loss and detect when receiving the content of being asked, and when finding the wrong bag of packet loss, initiates retransmission request message to the peer node 203 as its P2P agency, and receives the data that peer node 203 retransmits.
Above-mentioned storage server (204,205) also has the wrong bag of packet loss measuring ability, is used for initiating retransmission request message to connected peer node (202,203), and receiving the data that peer node retransmits (202,203) after finding the wrong bag of packet loss.
The said equipment is found packet loss by the sequence number that detects data, the verification by detecting data and find wrong the bag.
As shown in Figure 3, the flow chart of the data repeating method that provides for the embodiment of the invention, the method for present embodiment is applied among the P2P Overlay.Do not require among this P2P Overlay that content providers and client can support the P2P technology, but by supporting the P2P technology, acting on behalf of content providers and client and other equipment as the peer node of the node (Peer) of P2P network and finish information interaction, be that content providers only need be known the peer node that oneself is connected with client, and do not need to know that other nodes among the P2P Overlay just can obtain service from the P2P network.
When client 206 need be obtained certain resource from P2P Overlay, when for example name is called the movie resource of Q, the request that client 206 will be obtained film Q sends to peer node 203, peer node 203 is by searching at the P2P network, discovery can be found film Q by peer node 202, so send the request of obtaining film Q to peer node 202, because film Q actual storage is on content providers 201, peer node 202 need get access to film Q from content providers 201, and simultaneously with the content stores of film Q on storage server 204 and send to peer node 203, peer node 203 simultaneously with the content stores of film Q on storage server 205 and send to client 206.In the process of above-mentioned transmission film Q, in order to solve because of the problem of avoiding packet loss, Cuo Bao to cause, the data repeating method that the embodiment of the invention adopts comprises the steps:
S301, client 206 are detecting the data of receiving when connected peer node 203 receives data, after finding loss of data (packet loss) or data transmission errors (wrong bag), send retransmission request message to peer node 203, carry packet loss/wrong package informatin, data or the wrong data of transmission that request retransfers and loses.
Concrete, client 206 passes through to detect the sequence number of data (according to the host-host protocol difference, may be RTP (Real-time Transport Protocol, RTP) sequence number or the sequence number of other host-host protocol or byte sequence number) find packet loss, the verification by detecting data and find wrong the bag.
After S302, peer node 203 were received this retransmission request message, whether inquiry had been stored this retransmission request message on the storage server 205 and has been asked the data that retransfer, if having, and execution in step S303; If no, execution in step S304.
S303, peer node 203 send to client 206 with these data after obtaining the data that client 206 asks to retransfer from storage server 205.
The content that provides client 206 to be asked is provided for S304, peer node 203 is the peer node of film Q, finds peer node 202.
S305, peer node 203 send retransmission request message to the peer node 202 that film Q is provided, and request sends the data that 206 request retransmission of client transmit.
After S306, peer node 202 are received this retransmission request message, whether stored the data of this retransmission request message institute request retransmission on the inquiry storage server 204, if having, execution in step S307; If no, execution in step S309.
S307, peer node 202 send to peer node 203 with these data after obtaining the data that peer node 203 asks to retransfer from storage server 204.
After S308, peer node 203 are received described data, these data are sent to storage server 205 and client 206, the described data of storage server 205 storages.
S309, peer node 202 send retransmission request message to content providers 201, and request sends the data of 203 request retransmission of peer node.
S310, peer node 202 send to peer node 203 and storage server 204 with the data of receiving after receiving the data of its request retransmission that content providers 201 sends.After peer node 203 is received these data, these data are sent to storage server 205 and client 206, the described data of storage server 205 storages.
S311, the described data of receiving of storage server 204 storages.
In the present embodiment, content providers 201 will inform that at first peer node 202 oneself can provide the message of film Q, the corresponding relation of 202 recorded content providers of peer node 201 and film Q, and issue oneself can provide the message of film Q on P2POverlay.
In the embodiment of the invention, storage server also can possess the ability that packet loss/the mistake bag detects.When storage server detects loss of data or data transmission errors, send retransmission request message to the peer node that oneself connects, after the peer node of connection storage server is received the data re-transmission request message of storage server transmission, if oneself connects content providers, then the request content provider retransmits the data of storage server institute request retransmission, if oneself does not connect content providers, then request provides other peer node of this content to retransmit the data of storage server institute request retransmission.Storage server is stored after receiving the data of own institute request retransmission.
Above-mentioned storage server in the embodiment of the invention can be the memory module that is integrated on the peer node, also can be the independent storage server that is connected on the peer node.
As shown in Figure 4, the structural representation of the peer node that provides for the embodiment of the invention comprises:
Receiving element 41 is used to receive retransmission request message;
Query unit 42 is used to inquire about the local data that whether store described retransmission request message institute request retransmission;
Transmitting element 43 is used for when query unit 42 determines that this locality store the data that described resend messages asks described data being sent;
Memory cell 44 is used to store the data that receiving element receives.
The embodiment of the invention also is not too stable present situation based on the P2P network performance, by memory module or side extension storage server are set on the peer node as client and content source agency in the P2P network, make in the content delivery process and error in data to take place or when losing, client only need send to retransmission request message the peer node of serving client, when storing the data of client institute request retransmission on the peer node of serving client, do not need a large amount of participations of content source can realize that the wrong bag of packet loss of data retransmits, improved efficiency of transmission, alleviated content source and as the burden of its agency's peer node.
The above only is a preferred implementation of the present invention; for those skilled in the art; under the prerequisite that does not break away from the principle of the invention, any modification of being made, be equal to and replace and improve, all should be encompassed within protection scope of the present invention.
Claims (15)
1, a kind of data repeating method is applied to it is characterized in that in the P2P network, comprising:
Receive the retransmission request message that client sends,
Whether inquiry is local stores the data of described retransmission request message institute request retransmission;
When this locality stores the data of described data re-transmission request message institute request retransmission, described data are sent to client.
2, data repeating method according to claim 1 is characterized in that, described method also comprises:
When described data are not stored in this locality, send described retransmission request message to the data source end, receive the described data that described data source end resends, described data are sent to client.
3, data repeating method according to claim 1 is characterized in that, before client sent retransmission request message, described method also comprised:
Client receives data according to own content of being asked, and the data that receive are detected, when detecting loss of data or error in data, and the structure retransmission request message.
4, data repeating method according to claim 2 is characterized in that, the retransmission request message that described reception client sends is specially:
The peer node of serving client receives the retransmission request message that client sends;
Describedly send described retransmission request message to the data source end and be specially:
The peer node of serving client sends retransmission request message to the peer node of serving content providers.
5, data repeating method according to claim 4 is characterized in that, the data that described reception data source end resends are specially:
The peer node of serving client receives the data of the peer node transmission of serving content providers.
6, data repeating method according to claim 3 is characterized in that, the retransmission request message that described reception client sends is specially:
The peer node of serving content providers receives the retransmission request message of the client transmission of the peer node forwarding of serving client;
Sending described retransmission request message to the data source end is specially:
Serve the peer node of content providers and transmit the retransmission request message that receives to content providers.
7, data repeating method according to claim 6 is characterized in that, the data that reception data source end resends are specially:
Serve the data of the peer node received content provider transmission of content providers;
Described data are sent to client to be specially:
The peer node of serving content providers sends to client by the peer node of serving client with described data.
8, according to any described method in claim 1 or 2, it is characterized in that, be specially according to the local data that whether store described retransmission request message institute request retransmission of described retransmission request message inquiry:
Inquire about the data that whether store described retransmission request message institute request retransmission on locally-attached caching server according to described retransmission request message.
9, method according to claim 1 and 2 is characterized in that, receives after the described data that described data source end resends, and described method also comprises: the described data of buffer memory on local or locally-attached caching server.
10, a kind of network system is characterized in that, comprising:
Client is used to send retransmission request message;
First peer node is used to receive the retransmission request message that client sends, and whether inquiry is local stores the data of described retransmission request message institute request retransmission; When this locality stores the data of described data re-transmission request message institute request retransmission, described data are sent to client.
11, network system according to claim 10 is characterized in that, described client also was used to detect the data of reception before sending retransmission request message, when detecting loss of data or error in data, generates retransmission request message;
Described network system also comprises the data source end, when described data are not stored in described first peer node this locality, sends retransmission request message to described data source end;
Described data source end is used to receive the retransmission request message that first peer node sends, and sends the data that it is asked to first peer node.
12, network system according to claim 10 is characterized in that, described data source end is second peer node or content providers;
Described first peer node is the peer node of serving client;
Described second peer node is the peer node of serving content providers;
Described content providers also is used for providing content by described second peer node to described network system.
13, according to claim 10 or 11 described network systems, it is characterized in that, also comprise:
First storage device is used to store the data that first peer node receives;
Second storage device is used to store the data that second peer node receives.
14, a kind of peer node is characterized in that, comprising:
Receiving element is used to receive retransmission request message;
Query unit is used to inquire about the local data that whether store described retransmission request message institute request retransmission;
Transmitting element is used for when query unit determines that this locality stores the data that described resend messages asks described data being sent.
15, peer node according to claim 14 is characterized in that, described receiving element also is used to receive data;
Described peer node also comprises memory cell, is used to store the data that receiving element receives.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CNA2008100668370A CN101567769A (en) | 2008-04-22 | 2008-04-22 | Data retransmission method, system and peer-to-peer node |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CNA2008100668370A CN101567769A (en) | 2008-04-22 | 2008-04-22 | Data retransmission method, system and peer-to-peer node |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN101567769A true CN101567769A (en) | 2009-10-28 |
Family
ID=41283739
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CNA2008100668370A Pending CN101567769A (en) | 2008-04-22 | 2008-04-22 | Data retransmission method, system and peer-to-peer node |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN101567769A (en) |
Cited By (10)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101742702A (en) * | 2009-12-31 | 2010-06-16 | 中兴通讯股份有限公司 | Mobile internet service sharing system and method |
| CN102065064A (en) * | 2009-11-18 | 2011-05-18 | 中兴通讯股份有限公司 | Peer-to-peer overlay network, method for storing service contents and method for downloading same |
| CN102215435A (en) * | 2010-04-02 | 2011-10-12 | 科腾科技(北京)有限公司 | Push VOD (Video-On-Demand) system of digital television and push VOD method thereof |
| CN103117955A (en) * | 2013-01-16 | 2013-05-22 | 华为技术有限公司 | Method, device and system of message transmission |
| CN103563282A (en) * | 2011-03-11 | 2014-02-05 | 三星电子株式会社 | Harq method and apparatus for communication system |
| CN103988189A (en) * | 2011-12-08 | 2014-08-13 | 国际商业机器公司 | Method for detecting data loss of data transfer between information devices |
| CN105578263A (en) * | 2015-12-28 | 2016-05-11 | 山东泰信电子股份有限公司 | Method for playing and transmitting live programme, intelligent playing equipment and live telecasting equipment |
| CN111769909A (en) * | 2020-06-16 | 2020-10-13 | 上海英方软件股份有限公司 | Device and method for cascade retransmission based on market data |
| CN114050837A (en) * | 2022-01-17 | 2022-02-15 | 唯捷创芯(天津)电子技术股份有限公司 | Radio frequency module for automatically controlling harmonic impedance, electronic equipment and impedance adjusting method |
| CN114499777A (en) * | 2022-04-15 | 2022-05-13 | 四川腾盾科技有限公司 | Data transmission method for cluster unmanned system |
-
2008
- 2008-04-22 CN CNA2008100668370A patent/CN101567769A/en active Pending
Cited By (19)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102065064A (en) * | 2009-11-18 | 2011-05-18 | 中兴通讯股份有限公司 | Peer-to-peer overlay network, method for storing service contents and method for downloading same |
| WO2011060702A1 (en) * | 2009-11-18 | 2011-05-26 | 中兴通讯股份有限公司 | Peer-to-peer overlay network, service content storage method and service content download method |
| CN101742702B (en) * | 2009-12-31 | 2014-03-19 | 中兴通讯股份有限公司 | Mobile internet service sharing system and method |
| WO2010148843A1 (en) * | 2009-12-31 | 2010-12-29 | 中兴通讯股份有限公司 | System and method for mobile internet service sharing |
| CN101742702A (en) * | 2009-12-31 | 2010-06-16 | 中兴通讯股份有限公司 | Mobile internet service sharing system and method |
| US8819137B2 (en) | 2009-12-31 | 2014-08-26 | Zte Corporation | System and method for sharing mobile internet service |
| CN102215435A (en) * | 2010-04-02 | 2011-10-12 | 科腾科技(北京)有限公司 | Push VOD (Video-On-Demand) system of digital television and push VOD method thereof |
| CN102215435B (en) * | 2010-04-02 | 2013-07-31 | 科腾科技(北京)有限公司 | Push VOD (Video-On-Demand) system of digital television and push VOD method thereof |
| CN103563282A (en) * | 2011-03-11 | 2014-02-05 | 三星电子株式会社 | Harq method and apparatus for communication system |
| US9584282B2 (en) | 2011-03-11 | 2017-02-28 | Samsung Electronics Co., Ltd. | HARQ method and apparatus for communication system |
| US10069611B2 (en) | 2011-03-11 | 2018-09-04 | Samsung Electronics Co., Ltd | HARQ method and apparatus for communication system |
| CN103988189A (en) * | 2011-12-08 | 2014-08-13 | 国际商业机器公司 | Method for detecting data loss of data transfer between information devices |
| CN103988189B (en) * | 2011-12-08 | 2016-10-12 | 国际商业机器公司 | The method of the loss of data of detection data transmission between information equipment |
| CN103117955A (en) * | 2013-01-16 | 2013-05-22 | 华为技术有限公司 | Method, device and system of message transmission |
| CN103117955B (en) * | 2013-01-16 | 2016-08-03 | 华为技术有限公司 | Method for message transmission and device, system |
| CN105578263A (en) * | 2015-12-28 | 2016-05-11 | 山东泰信电子股份有限公司 | Method for playing and transmitting live programme, intelligent playing equipment and live telecasting equipment |
| CN111769909A (en) * | 2020-06-16 | 2020-10-13 | 上海英方软件股份有限公司 | Device and method for cascade retransmission based on market data |
| CN114050837A (en) * | 2022-01-17 | 2022-02-15 | 唯捷创芯(天津)电子技术股份有限公司 | Radio frequency module for automatically controlling harmonic impedance, electronic equipment and impedance adjusting method |
| CN114499777A (en) * | 2022-04-15 | 2022-05-13 | 四川腾盾科技有限公司 | Data transmission method for cluster unmanned system |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN101567769A (en) | Data retransmission method, system and peer-to-peer node | |
| US6490291B1 (en) | Device for data communications between wireless application protocol terminal and wireless application server, and method thereof | |
| US7929422B2 (en) | Method of moving a transport connection among network hosts | |
| US6963996B2 (en) | Session error recovery | |
| KR20140009931A (en) | Communication method of contents requester and contents provider for providing contents and real-time streaming contents in a contents centric network based on contents name | |
| JP6601784B2 (en) | Method, network component, and program for supporting context-aware content requests in an information-oriented network | |
| CN103248467A (en) | In-chip connection management-based RDMA communication method | |
| US20060265465A1 (en) | Method, apparatus and system for processing message bundles on a network | |
| WO2019100831A1 (en) | Transmission layer protocol adaptation method, and network element device and system | |
| US20130208723A1 (en) | System for switching between communication devices, switching method, and switching program | |
| CN102857354A (en) | Method, device and system for reporting alarm information | |
| EP1028561B1 (en) | Device for data communications between wireless application protocol terminal and wireless application server, and method thereof | |
| CN103581361A (en) | Domain name resolution proxy method, device and system | |
| JP5029685B2 (en) | Backup device | |
| US20080256245A1 (en) | Method and system for information exchange utilizing an asynchronous persistent store protocol | |
| GB2412464A (en) | Methods and system for using caches | |
| CN116233243A (en) | Communication system and method in weak network environment | |
| US20120054310A1 (en) | Terminal, intermediate node and communication method of the same | |
| EP3422674A1 (en) | A method of resolving a domain name by a dns server to a plurality of ip addresses based on location information of the user equipment | |
| CN114143382A (en) | Bilateral acceleration data transmission method and system | |
| CN101471954A (en) | Method for implementing network service, network service entity and intelligent network system | |
| Chen | Cafnet: A carry-and-forward delay-tolerant network | |
| CN108965494A (en) | Data transmission method and device in data system | |
| KR100333730B1 (en) | Method for Requesting Data Retransmission between Network Access Systems over Ethernet | |
| US20090328060A1 (en) | Http based bounding storage space protocol |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| C06 | Publication | ||
| PB01 | Publication | ||
| C10 | Entry into substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| C02 | Deemed withdrawal of patent application after publication (patent law 2001) | ||
| WD01 | Invention patent application deemed withdrawn after publication |
Application publication date: 20091028 |