CN101867623B - Peer-to-peer network service primitive system - Google Patents

Abstract

A peer-to-peer network service primitive system in the field of network communication technology, comprising: an application service module, a peer-to-peer communication module, a transmission network module, a user interface module, and an application interface module, wherein: the application service module is connected to the user interface module to transmit application For service communication information, the user interface module is connected to the peer-to-peer communication module to transmit application service communication information, the peer-to-peer communication module is connected to the application interface module to transmit API information of the application service, and the application interface module is connected to the transmission network module to transmit API information of the application service. The invention can simplify the development and deployment of the P2P application system, has flexible scalability, and can be used in P2P systems with DHT protocol and non-DHT protocol; multiple P2P applications can be supported on the same coverage layer, and the resource utilization of the system is improved. Reusability and optimized resource allocation efficiency; it can purify the P2P network environment and provide healthy P2P applications.

Description

peer-to-peer network service primitive system

technical field

The invention relates to a system in the technical field of network communication, in particular to a peer-to-peer network service primitive system.

Background technique

Peer-to-Peer network (P2P network for short) is a new communication network mode, each computer on the network has the same function, there is no master-slave distinction, any computer can be used as a server, Set shared resources for use by other computers in the network, and can also be used as a workstation to enjoy services such as massive resource sharing and downloading provided by other computers; the peer-to-peer network is the product of the combination of distributed systems and computer networks, which allows all network members to enjoy The function of "freedom, equality and interconnection". P2P is the abbreviation of English Peer-to-Peer (peer-to-peer), also known as "peer-to-peer". P2P communication technology is a new communication mode. A communication network based on P2P technology is a P2P network, or a peer-to-peer network. The rapid development of P2P network has already occupied more than half of the bandwidth resources of the current Internet, and it is called "a new generation of network technology that changes the Internet".

In recent years, P2P systems such as Bittorrent, PPLive and eMule have achieved great success. However, since P2P itself has no normative requirements, a large number of these P2P application functions are superimposed on each other, resulting in vicious competition and waste of limited network resources and development resources. In addition, developing a P2P system is also a relatively complicated work, and new system applications lack a platform for promotion. Therefore, only by reducing the complexity of the development and deployment of P2P application systems, providing a consistent P2P service system and simplified programming interfaces can the above problems be solved. At the same time, the most critical thing is that the peer-to-peer network service system must pay attention to two major problems caused by P2P applications: network efficiency and content security.

Through document retrieval to prior art, it is found that Sean Rhea et al. published "OpenDHT: A Public DHT Service and Its" in Proceedings of ACMSIGCOMM 2005, August 2005 (ACM Communications Special Interest Group Meeting, August 2005) by Sean Rhea et al. "Uses" ("OpenDHT: An Open Distributed Hash Table Service and Its Use") proposes an open DHT (Distributed Hash Table, Distributed Hash Table) service system, through several simple user interfaces Service command sending, receiving, deleting, etc., can easily implement a DHT-based P2P distributed application, but its disadvantage is that it is only limited to the DHT protocol, and it is not applicable to peer-to-peer networks that are not DHT protocols, and it only provides simple Interface services, making it unable to support complex application services. For network efficiency and content security issues, some restrictive measures have been adopted by ISPs (Internet Service Providers). But the problem is: the use of restrictions will cause the ISP to risk losing users, and it will also face legal issues; using the Cache (caching) method, equipment investment cannot keep up with the rapid increase in P2P traffic, and this additional investment will also affect benefit of the ISP. On the other hand, the joining of P2P nodes is random, so that the P2P network has become a fertile ground for the spread of malicious code, pornographic content, reactionary information, pirated resources, etc., and content security issues are very worthy of concern. This is also an important reason why the current P2P system is criticized.

Contents of the invention

The purpose of the present invention is to overcome the above-mentioned shortcomings in the prior art and provide a peer-to-peer network service primitive system. The present invention can simplify the development and deployment of the P2P application system through the internal service primitive and the extended service primitive, has flexible scalability, and can be used in the P2P system of the DHT protocol and the non-DHT protocol, so that the application range is greatly expanded . By providing a consistent application interface module, the present invention enables multiple P2P applications to be supported in the same Overlay (overlay layer), improves the reusability of system resources and optimizes resource allocation efficiency. By actively deploying security monitoring services and security audit strategies, the P2P network environment can be purified and healthy P2P applications can be provided.

The present invention is achieved through the following technical solutions:

The invention includes: an application service module, a peer-to-peer communication module, a transmission network module, a user interface module and an application interface module, wherein: the application service module is connected to the user interface module to transmit application service communication information, and the user interface module is connected to the peer-to-peer communication module To transmit application service communication information, the peer-to-peer communication module is connected to the application interface module to transmit API (application program interface) information of the application service, and the application interface module is connected to the transmission network module to transmit API information of the application service.

The application service module includes: a general service submodule, a registration service submodule and an extended service submodule, wherein: the general service submodule, the registration service submodule and the extended service submodule are respectively connected with the user interface module to transmit general service information, Register service information and extended service information.

The general service sub-module includes: a file sharing unit, a streaming media distribution unit and an IP voice unit, wherein: the file sharing unit is connected with the user interface module to transmit file sharing information, and the streaming media distribution unit is connected with the user interface module to transmit streaming media distribution information, the IP voice unit is connected with the user interface module to transmit IP voice information.

The user interface module includes: a general service interface submodule, a registration service interface submodule and an extended service interface submodule, wherein: the general service interface submodule is connected with the application service module to transmit general service information, and the general service interface submodule is connected to the The other communication modules are connected to transmit the API information of the general service, the registration service interface sub-module is connected to the application service module to transmit the registration service message, the registration service interface sub-module is connected to the peer-to-peer communication module to transmit the API message of the registration service, the extension service interface sub-module is connected to the The application service module is connected to transmit extended service information, and the extended service interface sub-module is connected to the peer-to-peer communication module to transmit API information of the extended service.

The transmission network module is a transmission network module based on OSI (Open Systems Interconnection), or a transmission network module based on TCP/IP (Transmission Control Protocol/Internet Protocol).

The application interface module includes: a node adapter submodule, an ISP submodule, a storage submodule, a receiving cache submodule and a sending cache submodule, wherein: the node adapter submodule connects with the ISP submodule to transmit service adaptation information, stores The module is connected with the ISP sub-module to transmit ISP service information, the receiving cache sub-module is connected with the node adapter sub-module to transmit received service information, and the sending cache sub-module is connected with the node adapter sub-module to transmit and send service information.

The working process of the present invention: when two peer nodes exchange messages, the message is first sent by the application service module of the first node, and then transmitted through the peer-to-peer communication module. The application service module between two peer nodes performs primitive cooperation between peer nodes through the peer-to-peer communication module, and communicates with the primitive language system through the user interface module and the application interface module. The user interface module realizes the registration and deregistration of users and services, and the application interface module provides users with the use of the service primitive system infrastructure to realize new application services, and can further register into the system through the user interface interface. Delivered by the transport network module to the transport network module of the second peer node and up to the peer communication module of this node. The peer-to-peer communication module realizes communication by transmitting the primitives of the network module. It is finally submitted to the application service module by the peer-to-peer communication module of the second peer node. So far, the application service communication between the two peer nodes is completed, and the entire communication process is realized by communication primitives.

Compared with prior art, the beneficial effect of the present invention is:

1. Provide an open API interface for P2P application development and call, which encapsulates the complexity of Overlay layer communication and greatly simplifies P2P application development. P2P application development only needs to focus on the implementation of application service primitives, while the monitoring and maintenance of the Overlay layer is managed by OpenP2P;

2. Provide on-demand deployment of specific functional service nodes in the Overlay layer to improve P2P network performance and have dynamic scalability;

3. Provide file sharing, streaming media distribution and VoIP integration services, and support users to use open APIs to develop their own P2P application services and service distribution;

4. Provide a security review mechanism for P2P content to prevent the release and access of malicious information.

Detailed ways

The following are further descriptions of the embodiments of the present invention: this embodiment is implemented under the premise of the technical solution of the present invention, and detailed implementation methods and specific operating procedures are provided, but the protection scope of the present invention is not limited to the following embodiments .

Example

This embodiment includes: an application service module, a peer-to-peer communication module, a transmission network module, a user interface module, and an application interface module, wherein: the application service module is connected to the user interface module to transmit application service communication information, and the user interface module and the peer-to-peer communication module The peer-to-peer communication module is connected to the application interface module to transmit the API information of the application service, and the application interface module is connected to the transmission network module to transmit the API information of the application service.

The application service module includes: a general service submodule, a registration service submodule and an extended service submodule, wherein: the general service submodule, the registration service submodule and the extended service submodule are respectively connected with the user interface module to transmit general service information, Register service information and extended service information.

The general service sub-module includes: a file sharing unit, a streaming media distribution unit and an IP voice unit, wherein: the file sharing unit is connected with the user interface module to transmit file sharing information, and the streaming media distribution unit is connected with the user interface module to transmit streaming media distribution information, the IP voice unit is connected with the user interface module to transmit IP voice information.

The registration service sub-module registers the services provided by the user.

The extended service sub-module is a service provided by the user.

The user interface module includes: a general service interface submodule, a registration service interface submodule and an extended service interface submodule, wherein: the general service interface submodule is connected to the general service submodule to transmit general service information, and the general service interface submodule is connected to the general service interface submodule The peer-to-peer communication module is connected to transmit the API information of the general service, the registration service interface sub-module is connected to the registration service sub-module to transmit the registration service message, the registration service interface sub-module is connected to the peer-to-peer communication module to transmit the API message of the registration service, and the extension service interface sub-module The module is connected to the extended service sub-module to transmit extended service information, and the extended service interface sub-module is connected to the peer-to-peer communication module to transmit API information of the extended service.

The transmission network module is an OSI-based transmission network module.

The application interface module includes: a node adapter submodule, an ISP submodule, a storage submodule, a receiving cache submodule and a sending cache submodule, wherein: the node adapter submodule connects with the ISP submodule to transmit service adaptation information, stores The module is connected with the ISP sub-module to transmit ISP service information, the receiving cache sub-module is connected with the node adapter sub-module to transmit received service information, and the sending cache sub-module is connected with the node adapter sub-module to transmit and send service information.

The node adapter sub-module maintains the overlay topology and transmits messages.

The ISP sub-module maintains the overlay topology and accelerates message delivery and network download through various supporting services provided by the ISP.

The storage sub-module stores service information provided by the ISP.

The receiving buffer submodule buffers the received information when the channel is congested or competed, and waits for processing.

The sending buffer submodule buffers the information to be sent when the channel is congested or competed, and waits for processing.

Described transmission network layer is the bottom interface layer of peer-to-peer network service primitive system, this layer carries out the transmission of network message, realizes three types of transmissions (namely: Transmission Control Protocol, User Data Packet Protocol list) by node adapter submodule broadcast and User Datagram Protocol multicast).

In this embodiment, the implementation details of P2P are encapsulated into the peer-to-peer communication module. The peer-to-peer communication module interacts with specific applications through messages upwards, interacts with the transmission network module through messages downwards, and interacts with the ISP internally through messages.

The format of the API information described in this embodiment is as follows:

1) The format of the application message sent by the user is as follows:

KeyOverlayID RouteType AppID Application Data

KeyOverlayID: Resource ID

RouteType: 0 means unicast; 1 means multicast

AppID: App unique identifier, need to use the registration service to obtain a globally unique ID

Application: Application commands and parameters

2), Overlay message format is as follows:

MsgType SrcOverlayID DstOverlayID Data

MsgType: 0 means topology maintenance; 1 means application message

SrcOverlayID: Source ID

DstOverlayID: Target ID

◆Data: commands and parameters

◆The command set for the topology maintenance message when MsgType=0 is as follows:

◆HelloNeighbour: Probe neighbor set

◆Join: join the covering layer

◆Leave: leave the overlay

◆GetNeibours: Get neighbor set

◆ElectSuperNode: select a super node

For the application message when MsgType=1, callback is realized by sending and distributing. If the target address is this node, the distribution application request is executed locally; otherwise, depending on the routing type of the application message, if it is multicast, the distribution needs to be executed locally, and the message is sent to other multicast members at the same time; if it is single broadcast, you only need to send the message to the next hop.

3) The ISP message format is as follows:

MsgType MsgCode Data

◆MsgType: 0 for request; 1 for response

◆MsgCode:

0 means GetTopInfo (get topology information)

1 stands for GetSepService (special service)

2 stands for GetSuperNodeInfo (get super node description information)

3 stands for PutNodeInfo (upload node information to ISP Facilities)

4 represents RegisterNode (registration node)

5 represents DestoryNode (logout node)

6 stands for CheckSecurity (check whether the information is safe)

In this embodiment, the application service module does not directly provide ISP services to developers, but uses encapsulated APIs for developers to use, which can protect ISP resources and security, and realize controllability and manageability through consistent interfaces . The P2P service primitive system adds extended service sub-modules through the open API, and expands into the open system of the P2P service primitive system in the form of plug-ins. The system uses a message-driven event processing model. Four basic APIs are currently provided: JoinOverlay (join the overlay), LeaveOverlay (leave the overlay), SendMsg (send a message), ReceiveMsg (receive a message). When a peer node joins OpenP2P, it will first connect to the aggregation server, judge the geographic location of the peer node from the aggregated information, and determine which responsible point the peer node monitors and assists in its communication.

Concrete advantages of this embodiment:

1. By downloading the service system based on OpenP2P, it can support streaming media distribution, file sharing, VoIP, etc. under the same Overlay structure. Provide file sharing, streaming distribution and VoIP integration services, and support users to use open APIs to develop their own P2P application services and service distribution. It enables P2P users to publish their own interest channels and form their own circles; in addition, they also benefit from the high-quality network services provided by the P2P service primitive system.

2. You can develop your own OpenP2P-based application services according to the general application API interface, and publish them to the Overlay network to gather your own interest circle.

3. The Overlay network cooperates with the ISP, and the ISP deploys reliable supervision services, guides traffic distribution to match the Overlay and the physical layer, and provides participating Peer nodes with more optimized and guaranteed network performance than the usual P2P system. Provides an open API interface for P2P application development and calls, encapsulates the complexity of Overlay layer communication, and greatly simplifies P2P application development. P2P application development only needs to focus on the implementation of application service primitives, while the monitoring and maintenance of the Overlay layer is managed by the P2P service primitive system. The current popular P2P system providers such as PPLive can use the interface service of the P2P service primitive system to improve the quality of its streaming media distribution and the tension with ISP.

4. A variety of scalable special server clusters provided by the ISP, such as anti-Churn servers, NAT penetration auxiliary servers, etc., guarantee the performance of application services, and can continue to expand according to the needs of the application. Provide on-demand deployment of specific function service nodes at the Overlay layer to improve P2P network performance and have dynamic scalability. This allows ISPs to deploy regulatory strategies through this P2P service primitive architecture. The main goal of this regulatory strategy is to guide traffic or share revenue.

5. Through the security policy server provided by each ISP monitoring point and OpenP2P itself, it is allowed to use security policies at different levels to ensure the safe application of P2P. Provide a security review mechanism for P2P content to prevent the release and access of malicious information.

Claims (5)

1. A peer-to-peer network service primitive system, characterized in that it includes: an application service module, a peer-to-peer communication module, a transmission network module, a user interface module and an application interface module, wherein: the application service module is connected to the user interface module for transmission Application service communication information, the user interface module is connected to the peer-to-peer communication module to transmit application service communication information, the peer-to-peer communication module is connected to the application interface module to transmit API information of the application service, and the application interface module is connected to the transmission network module to transmit API information of the application service ; The application service module includes: a general service submodule, a registration service submodule and an extended service submodule, wherein: the general service submodule, the registration service submodule and the extended service submodule are respectively connected with the user interface module to transmit general service information, Register service information and extended service information. 2. The peer-to-peer network service primitive system according to claim 1, wherein said general service submodule comprises: a file sharing unit, a streaming media distribution unit and an IP voice unit, wherein: the file sharing unit is connected with the user The interface module is connected to transmit file sharing information, the streaming media distribution unit is connected to the user interface module to transmit streaming media distribution information, and the IP voice unit is connected to the user interface module to transmit IP voice information. 3. The peer-to-peer network service primitive system according to claim 1, wherein said user interface module comprises: general service interface submodule, registration service interface submodule and extended service interface submodule, wherein: general service interface submodule The service interface sub-module is connected to the application service module to transmit general service information, the general service interface sub-module is connected to the peer-to-peer communication module to transmit API information of general services, the registration service interface sub-module is connected to the application service module to transmit registration service messages, and the registration service interface The sub-module is connected to the peer-to-peer communication module to transmit the API message of the registration service, the extended service interface sub-module is connected to the application service module to transmit the extended service information, and the extended service interface sub-module is connected to the peer-to-peer communication module to transmit the API information of the extended service. 4. The peer-to-peer network service primitive system according to claim 1, wherein the transmission network module is an OSI-based transmission network module, or a TCP/IP-based transmission network module. 5. The peer-to-peer network service primitive system according to claim 1, wherein said application interface module comprises: a node adapter submodule, an ISP submodule, a storage submodule, a receiving cache submodule and a sending cache submodule module, wherein: the node adapter sub-module is connected to the ISP sub-module to transmit service adaptation information, the storage sub-module is connected to the ISP sub-module to transmit ISP service information, and the receiving cache sub-module is connected to the node adapter sub-module to transmit and receive service information, The sending cache submodule is connected with the node adapter submodule to transmit the sent service information.