CN108718236B - Data transmission method for internet self-organizing convergence - Google Patents

Abstract

The data transmission method of Internet self-organizing confluence, for each specific message transmission request, CA procedure on the adjacent user terminal in the Internet will produce its transmission agent through interaction, also interact and produce the higher transmission agent in the larger regional scope between the transmission agents at the same time, this process can be repeated, so as to assemble and produce the highest transmission agent of the message in a backbone network regional scope; the converged transmission agent makes a transmission request to a CCN running on a backbone network, and authenticates the CCN by using a CA & CM server; all CCNs operating in the backbone network adaptively arrange transmission and local data caching schemes according to the received transmission request, and optimize the data transmission efficiency; on the premise of not changing the existing network architecture, good transmission performance is realized with lower occupation of backbone network bandwidth and lower deployment cost, and all nodes participating in transmission keep a uniform status, thereby greatly protecting the privacy of users.

Description

Data transmission method of Internet self-organized convergence

technical field

The present invention relates to an organization and implementation method for converging and optimizing point-to-multipoint/multipoint-to-multipoint data stream transmission in a self-organizing manner, in particular to a data transmission method for self-organizing confluence of the Internet.

Background technique

The Internet links together various computing terminals distributed in different regions of the world, and realizes the communication between any two terminals through the IP protocol. Although the communication between terminals on the Internet is mainly carried out in a point-to-point manner, in practical applications, most of the information dissemination in the Internet exists in a point-to-point (point-to-multipoint) form. For example, people like to visit popular websites, watch videos and news, go shopping, publish information to friends or followers through self-media, and conduct commercial activities on the Internet such as advertisement targeting, etc. With the rapid development of electronic information technology, the Internet has been connected to different professional equipment in almost all industries, as well as a large number of personal electronic consumer goods terminals, generating astronomical data traffic every day.

On the basis of the point-to-point communication protocol based on IP packet transmission, the realization of point-to-point transmission will have transmission efficiency problems. For example, when information is transmitted from a certain terminal to multiple receiving terminals, if multiple receiving terminals are in the same area, or Receiving at different times will lead to a waste of information transmission and reuse of network resources. Therefore, researching and developing high-efficiency point-to-point transmission protocols has always been a hot issue in interconnected communication technology.

The existing point-to-point protocol transmission protocols include IP multicast, P2P, and CDN. IP multicast replicates and forwards data packets through multicast routers to ensure that data packets are transmitted only once on each link, which can reduce bandwidth consumption. However, IP multicast must be supported by multicast routers. Most routers on the Internet are not multicast routers; multicast transmission is unreliable. Once a receiver packet is lost, it needs to be retransmitted by the source, and other receivers will receive the packet again, resulting in low efficiency; in addition, multicast Does not support any security authentication and is not suitable for secure communication.

P2P (Peer to Peer) is a point-to-point communication protocol. All nodes have equal status and cooperate to complete a certain transmission task. In the case of non-centralized distribution of nodes in P2P, a large number of transmissions cross the backbone network, which is easy to cause the backbone network congestion and reduce the transmission rate. Statistics show that as early as 2004, 40% of the Internet bandwidth has been occupied by P2P programs (ParkerA.The True Picture of Peer-to-Peer File sharing[J].2004,4(5):55-60.), in In 2006, 70% of the Internet bandwidth was occupied by P2P programs (Ouyang Rong, Lei Zhenming. Model Research and Performance Analysis of BitTorrent P2P System [J]. Journal of Beijing University of Posts and Telecommunications, 2006, 29(z2): 113-117.) , so the widespread use of P2P programs is gradually eating up the precious backbone network bandwidth resources, jeopardizing the data transmission of other Internet services.

CDN (Content Delivery Network) reduces the pressure on the backbone network by deploying a large number of cache servers at the edge of the network and redirecting requests from users in a certain area to the same cache server. This transmission method requires the deployment of a large number of high-performance CDN cache servers, so it requires a lot of expensive hardware resources. At the same time, within a certain range, the wider the CDN bandwidth, the better the service performance. Therefore, in order to provide high-quality services, the CDN needs a large amount of bandwidth resources, which further increases the deployment cost of the CDN. In addition, when the CDN mode is used for transmission, the user directly obtains data from the CDN cache server, and there is no data exchange between the user and the user, so the CDN mode does not utilize the user's upload bandwidth, which is a waste of existing resources.

In addition, in the existing information transmission across the Internet, the user's information security protection is a serious problem. First, the information source terminal (website) is often well known, and the user accesses the information source website through this known information, for example, the user logs in to a specific web page through a browser, or the user accesses the resources of the website through a client program. Either way, user requests are always pooled together and recorded and processed by a dedicated server cluster. Due to the direct connection of IP addresses, users directly expose their address information to the server cluster. The server cluster stores massive user requests through big data, and analyzes the behavior of a single user through data mining, social network analysis and other means to obtain information about a single user. Privacy Information. Secondly, the information source terminal has powerful information collection capabilities, and the information source terminal can grasp a large amount of user information through some means, such as a large number of client programs installed by users, the code of which is not open and transparent, and these client programs may have eavesdropping programs, snooping User privacy is transmitted to the information source terminal, and the information source terminal can master the user's private information. The above two aspects all show that the information providing source terminal on the Internet has powerful capabilities and has asymmetric information advantages for the information receiver, which means that the interests of the information receiving terminal user in Internet communication are easily damaged.

SUMMARY OF THE INVENTION

Aiming at the above-mentioned problems of the existing multi-party transmission protocols such as point-to-point Internet, the purpose of the present invention is to propose a data transmission method for self-organizing and converging of the Internet.

For achieving the above object, the technical scheme adopted in the present invention is as follows:

A data transmission method for Internet self-organization and convergence, comprising the following steps:

1) Run the CA program on each user terminal, and set up multiple CCNs and at least one CA&CM server on the backbone network;

CA programs are used to generate data requests, to interact and to transfer data;

CCN is used to receive data requests from CA programs, interact and match data requests between CCNs, and cooperate to generate a data transmission and storage scheme; a CA program is run on CCN, and the CA program running on CCN declares itself to represent CCN, CCN Receiving data requests from CA programs, interaction between CCNs and data transmission functions of CCNs are all performed through the CA programs running on CCNs;

CA&CM server is used to verify CCN;

2) For data requests of the same type, proxy CAs are generated through interactive election between CA programs that propose data requests of the same type within the same area network. The type of data request that is proxied;

3) The CCN receiving the data request of this type arranges the transmission and local data buffering scheme according to the transmission request received;

4) If there is a data transmission task, the CCN transmits data to the CA program through the proxy CA.

A further improvement in the present invention is that data requests are encapsulated into message pieces according to a fixed message format, and published and received in the form of message pieces; the data attributes of the message pieces include message code, transmission attribute, number of users, time stamp, description, hotspot flags and proxy bits;

The message codes are a series of codes that are generated by the CA&CM server and can be freely downloaded to classify all data resources in detail;

Transport properties are the actions involved in a data request, including publishing, receiving, and querying;

The number of users is the number of users who have the message code among the connected users;

The timestamp is the moment when the user generated the message piece;

Descriptions are used to supplement details that are missing after a data request is represented by a code;

The hotspot flag is used to mark the data request, and to optimize the transmission and distributed storage scheme of the data request;

The proxy bit is a flag bit used to describe whether the data request has generated a proxy.

A further improvement in the present invention is that the data attribute of the message piece further includes a preference attribute, which is used to record the user's access preference.

A further improvement in the present invention is that the message piece is packaged by the CA program running on the user terminal after collecting the data request sent by the user.

A further improvement in the present invention is that when the message code is generated, the message piece corresponding to the message code is marked as a common message piece in the hotspot flag; When the message code appears, the message piece corresponding to the message code is marked as a temporary message piece in the hotspot flag; after the message code is generated, if the number of times the message code appears in the network data request within a certain period of time exceeds the set value threshold, then the message piece corresponding to the message code is marked as a hot message piece in the hotspot flag; the message code corresponding to the message piece marked as a temporary message piece or a hot message piece, if it appears in the data request within a certain period of time The message code and the number of occurrences is not greater than the set threshold, then the message piece is marked as a common message piece.

A further improvement in the present invention is that the proxy CA represents other CA programs with the same data request, and the proxy CA records the address information of the CA programs it represents and the number of users it represents in an independent data request storage list, and creates CA proxy form.

A further improvement in the present invention is that the agent CA includes a local area network agent and a multi-level routing agent;

The local area network agent sends out data requests to the upper-level network on behalf of all CA programs in the local area network that request the same data request;

The routing agent sends data requests to the upper-level network on behalf of the CA program of all users connected to a router or the agent CA of the next-level router network;

The top-level routing agent is used to communicate with the next-level routing agents CA, CCN and CA&CM server.

A further improvement in the present invention is that the generation method of the local area network agent is:

The CA program generates a data request and broadcasts the data request to other CA programs in the same local area network. After other CA programs receive the broadcast data request, they store the data request in their own data request list; each CA program internally sets the data request. The proxy CA election module checks the data request list in real time, and counts the total number of users who have issued the same data request for each data request; when the total number of users for a certain data request is greater than the set threshold, the proxy CA election module elects the data The requested proxy CA; the proxy CA creates a child process to perform the proxy CA function.

A further improvement in the present invention is that the generation method of the routing agent CA is:

After the local area network proxy CA is generated in a local area network, the local area network proxy CA discovers other local area network information under the same router through the interaction function of CA programs of different local area networks, and interacts with the local area network proxy CA to query data requests to obtain the local area network proxy CA information in other local area networks; The local area network proxy CA establishes connections with other local area network proxy CAs and exchanges the data requests of their respective proxies, and elects the local area network proxy CA according to the election;

After establishing contact between the second-level routing agent CAs connected to the same router and exchanging the data requests they represent, the routing agent CA of the router is elected.

A further improvement in the present invention is that, if the router tree hierarchical structure of the network is similar to a tree structure, the pruning operation is performed on the structure to make it a tree structure.

A further improvement in the present invention is that the CA proxy form is recorded in the proxy CA for recording the IP address of the CA program represented by the proxy CA or the host IP address and port of the secondary proxy CA; the CA proxy form simultaneously records IP address information of the upper-level proxy CA of the proxy CA.

A further improvement in the present invention is that, in step 4), the method that CCN carries out data transmission to the CA program through the proxy CA is:

The CCN transmits the data to the proxy CA, and the proxy CA finds the proxy CA program according to the CA proxy form and distributes the data to the CA program;

If there are multi-level proxy CAs, the higher-level proxy CA looks up the proxy next-level proxy CA through the CA proxy form, and distributes data to the next-level proxy CA.

A further improvement in the present invention is that the data request is marked with a specific identification code, and the CA proxy form is marked or named with the specific identification code; when transmitting data to the proxy CA, a specific identification code is embedded in the header of the data message. Identification code: When the proxy CA receives the data message, it analyzes the header to obtain the specific identification code, and searches for the corresponding CA proxy form according to the specific identification code.

A further improvement in the present invention is that there is a health check module in the CA program, which is used to regularly check whether the proxy CA of the CA program is alive. If the detection finds that the proxy CA is not alive, then the CA programs will re-elect to generate a new proxy CA. ;

The health check module of the CA program where the proxy CA is located regularly checks the CA programs it represents. If the proxy CA finds that a CA program in its CA proxy form is offline, it will delete the CA program from the CA proxy form.

A further improvement in the present invention is that the newly added CA program in the local area network first sends a broadcast message to the local area network to detect whether the data request sent by it already has an agent CA: if an existing agent CA is found, the newly added CA program will automatically The proxy CA acts as its own proxy CA, and at the same time actively reports its existence to the proxy CA. After the proxy CA receives the report, it adds the CA program in the CA proxy form; if no proxy CA is found, the proxy CA is elected in the local area network.

A further improvement in the present invention is that after a new proxy CA is generated, the new proxy CA uses the message interaction function of the CA programs of different local area networks to discover other local area network information connected to the same router, and initiates user terminals in these local area networks. The routing proxy CA searches the request. After finding the routing proxy CA, it asks the routing proxy CA whether a routing proxy CA has been generated under the current router. If a routing proxy CA has been generated, the new proxy CA sends a message to the generated routing proxy CA, indicating that it has It is a new proxy CA, and the generated routing proxy CA adds the information of the new proxy CA in the CA proxy form; if no routing proxy CA is generated, then generate a new routing proxy according to the method of routing proxy generation under the same router. CA.

A further improvement in the present invention is that the user can set whether to enable the mobile agent CA function. If the mobile agent CA function is not enabled, when it is detected that the current CA program is in the mobile terminal, the mobile terminal will not become the agent CA; Mobile proxy CA function, when it is detected that the current CA program is in a mobile terminal, the mobile terminal can also become a proxy CA.

A further improvement in the present invention is that the method for the CA&CM server to verify the CCN is:

A pair of asymmetric encryption public keys and private keys are pre-generated on the CA&CM server. A legal CCN has the right to obtain the private key from the CA&CM server. The proxy CA obtains the public key from the CA&CM server, and uses whether the public key and the private key match to verify. CCN.

A further improvement in the present invention is that if the CCN authentication fails, the proxy CA sends an alarm to the remote CA&CM server.

A further improvement in the present invention is that, if the user terminal is a resource producer, the user terminal actively contacts the CCN through the CA program, and sends a resource release data request to the CCN.

A further improvement in the present invention is that, in step 3), the method that the CCN receiving the data request of this type arranges the transmission and local data buffering scheme according to the received transmission request is:

1) After the CCN receives the data request with the receiving attribute sent by the agent CA, the CCN searches for the data request with the publishing attribute that matches the data request with the receiving attribute;

2) The CCN where the matching data request with the publishing attribute is located sends a request to the CA program that publishes the data request with the publishing attribute, and receives and caches the corresponding resources;

3) the CCN where the matched data request with the release attribute is located transmits the cached corresponding resources to the CCN in step 1, and the CCN caches the received corresponding resources;

4) The CCN in the step 1 sends the cached corresponding resource to the proxy CA that makes the data request with the receiving attribute.

Compared with the prior art, the present invention has the following beneficial effects:

The present invention is a transmission scheme composed of the CA program running on the client, the CCN on the backbone network and the CA&CM server cooperating with each other. For each specific message transmission request, if it is a release type transmission request, the CA program on the adjacent client in the Internet will directly find the nearest CCN running on the backbone network through the network topology discovery method, and use the CA program's own Resource information is encapsulated into release type message pieces and sent to the nearest CCN running on the backbone network. If it is a type of transmission request such as reception/query/preference, then the CA program generates a transmission agent through interaction, and at the same time, the transmission agents also interact to generate a higher-level transmission agent in a larger area. This process can be repeated, so that in the The highest-level transmission agent that aggregates and generates the message within a local area network; the aggregated transmission agent makes a transmission request to the nearest CCN running on the backbone network, and uses the CA&CM server to authenticate the CCN; the CCN running on the backbone network receives The resource information query request is initiated to other CCNs, and other CCNs running on the backbone network aggregate resource information and send it to the aggregated transmission agent. The transmission agent forwards the data to the next-level agent layer by layer. The forwarding structure of the application layer is formed under the same area by the CCN and the transmission agent. Compared with the existing transmission method, the present invention has significant advantages in the following aspects:

1. Since only a small number of packets between the source server and CCN need to pass through the backbone network during the transmission process, compared with the scattered distribution of P2P nodes, the interaction of a large number of data packets needs to pass through the backbone network. This method can significantly reduce the backbone network. The occupation of network resources is conducive to improving the overall transmission quality of the Internet.

2. Since the new devices that need to be introduced in the transmission process are only CCNs in various regions, they are cloud computing nodes and can be rented directly from cloud service providers, and CCNs only require general bandwidth conditions, so compared to CDN transmission, CDN When the cache server needs ultra-high bandwidth, this method can save a lot of deployment costs. In addition, since the method forms a tree structure among users, and uses the tree structure to complete data distribution, the upload bandwidth of the users can be fully utilized, so the method fully utilizes the existing network resources.

3. The IP information of each CA program in the present invention is only kept in the agency CA related to it. In the data transmission, the provider receiver of the data cannot know the IP address of the data receiver, effectively protecting the privacy of the user. At the same time, during the transmission process, all entities participating in the transmission are in a balanced position, and there is no strong information body, which prevents the strong information body from collecting and analyzing user preferences, which greatly protects the privacy of users and improves network security performance. This transmission protocol will not affect the existing profit model of the Internet such as advertisement-targeted push. Because although there is no strong node that can analyze the behavior of a single user, the CA program can use the preference attribute in the message piece to send out its own information demand expectation, and the transmission scheme of the present invention can also realize the existing profit model of the Internet such as directional push. Since the analysis process is not directed to any single user, the present invention does not compromise the privacy of the user. In addition, the CA program of the method can use an open source method to open the source code, and the user can compile and install it independently, so as to prevent the behavior of embedding a Trojan program, and effectively protect the user's privacy.

Description of drawings

FIG. 1 is a system structure diagram of the present invention—a working diagram of the entire system. In the figure, A, B, C, D, E, F, G, H, I, J, K, L, each symbol represents a transmission agent. CA 1, CA2...CAt, each symbol represents a CA program.

FIG. 2 is a system structure diagram of the present invention—CA program model in the same local area network.

FIG. 3 is a system structure diagram of the present invention—a proxy CA program model under the same router.

FIG. 4 is a system structure diagram of the present invention—a three-layer network structure model.

FIG. 5 is a system structure diagram of the present invention—a distribution diagram of CCN and CA&CM servers in the Internet.

FIG. 6 is the generation principle of the local area network proxy of the present invention.

FIG. 7 shows the principle of network topology discovery of the present invention.

FIG. 8 is the generation principle of the routing proxy of the present invention.

FIG. 9 is a handshake protocol diagram for the routing agent of the present invention to verify whether the CCN identity is legal.

FIG. 10 is the message message format broadcasted by each CA program in the local area network of the present invention.

FIG. 11 is a local area network proxy claiming sovereignty message of the present invention.

FIG. 12 is a message for the local area network proxy of the present invention to request information of other local area network proxy.

FIG. 13 is an information message of other subnet users responding to the local area network proxy of the present invention.

Detailed ways

The present invention will be described in detail below with reference to the accompanying drawings.

Key terms in the present invention are explained as follows:

1) Message slice (Message)

The message piece is encapsulated by the CA program running on the user terminal after collecting the data request sent by the user. The present invention utilizes a data structure called a message slice to encapsulate the requests of data publishing/querying/receiving expected by network users. That is, the data request is encapsulated into message pieces according to a fixed message format, and published and received in the form of message pieces. The data attributes include but are not limited to: message code, transmission attribute, number of users, timestamp, description, hotspot The flag bit, agent bit and CRLF are described as follows: The message code is a unified code, which is a series of codes used to classify all message resources in detail. It is generated by the CA&CM server and can be downloaded freely. A series of codes for classifying resources in detail, message pieces can be named with the corresponding message codes; transmission attributes record the actions involved in the transmission of messages, including: publish/receive/query/preference, etc., which can be further expanded; the number of users It refers to the number of users who have the message code among the users who are in contact with each other for a specific message code; the timestamp is the moment when the user generates the message piece; the description is the detailed description of the message piece, which is used to supplement the omission after the message is indicated by the code The details of the data; the hotspot flag bit is used to mark the data request, and the transmission and distributed storage scheme used to optimize the data request; the proxy bit is a flag bit used to describe whether the data request has generated a proxy; CRLF is the A carriage return linefeed character used to indicate the end of a message fragment.

In addition, in order to inherit the practice of collecting users' access preferences and releasing data in a targeted manner to improve user experience in the existing Internet transmission mode, the message piece may also include some data attributes that reflect the user's access preferences.

2) CA program

The CA (chinwag agent) program runs on each user terminal connected to the Internet, accepts requests from users to publish/receive/query/preference, etc., and encapsulates the requested messages into message pieces. At the same time, the CA program also contacts other CA programs with the same message code in the network according to certain rules. After finding all CA programs with the same message code in the network, according to the proxy CA election method in the present invention, an information transmission channel is established among these CA programs according to the transmission attribute, so as to realize the information transmission task. It should be noted here that the query task in the transmission attribute will be completed by CCN through distributed query.

3) Routing topology hierarchy

The Internet consists of three levels of networks, namely backbone network, regional network and user network. The backbone network is a high-speed network connecting multiple regional networks. The regional network is a city-scale network, and the user network is connected to the regional network through multi-level routers. The three-layer structure adopts router coupling connection. The user network is at the bottom of the network topology, and a large number of users are in the local area network composed of private addresses. They are connected to the external network through a gateway. The multi-level routing connection between the gateway and the external network forms a network routing topology and finally connects to the backbone network. The hierarchical network topology constitutes the regional network network structure. A typical area network structure includes core layer, aggregation layer and access layer. The core layer provides high-speed data forwarding for the data aggregation layer and interconnects with the backbone network. The data aggregation layer aggregates the services accessed by the data access layer. The access layer provides nearby access for various types of users. Users access the metropolitan area network structure through the access layer.

In such a structure, each level router is connected to one or more networks aggregated by the next level routers, or user terminals (such as computers, smart phones, etc.) with various purposes. If the CA program needs to find other CA programs with the same message code in the network, it must first penetrate the intranet, and use the SNMP protocol to find other CA programs and establish an interconnection, and then analyze the respective messages on this basis. code to establish the information transfer mechanism.

4) Proxy transmission mechanism

In order to protect user privacy and improve transmission efficiency, in the process of the CA program transmitting messages through gateways and routers, the present invention selects a proxy CA according to the proxy CA election method for each message code in each level of network, which is used for On behalf of all CA programs about this message code in the network at this level, we call it agent CA, and use SNMP protocol to find the agent CA with the same message code in the upper-level network and establish an interconnection relationship. In this project, the IP address of the proxy CA program does not need to be notified to the upper-level network communication, thus protecting user privacy; during data transmission, the CA proxy form in CCN and proxy CAs at all levels is used to The data is forwarded layer by layer, and finally delivered to the LAN agent, which can serve a large number of users at the same time by using LAN broadcast or LAN multicast.

5) Proxy CA

The proxy CA represents other CA programs with the same data request (other CAs except itself), and the proxy CA records the address information of the CA programs it represents and the number of users it proxy in the independent data request storage list, and creates a CA proxy form. Another function of the CA program is to act as a proxy for other CA programs or proxy CAs with the same code message within a local area network or connected to the same router, and to make requests for publishing/receiving/querying/preferences to the upper-level network. When a CA program undertakes such proxy work, it is also called a proxy CA. The proxy CA can also be called a transmission agent, because its main function is to be responsible for the proxy transmission of data when transmitting data. At the same time, the proxy CA election method is the local area network proxy election method and the routing proxy election method.

Proxy CA is divided into two types: LAN proxy and routing proxy, which are briefly described as follows.

The local area network agent, on behalf of all the CA programs in the local area network requesting the same message code, submits a request for information transmission to the upper-level network. The CA program in each local area network uses the local area network broadcast protocol to contact other terminals running the CA program in the local area network. The CA program jointly analyzes the content of the message pieces generated by all CA programs. When the message pieces of a code meet certain requirements (for example, the number of CA programs expected to perform receiving/querying reaches a certain threshold, which will be agreed separately), the CA program will The local area network agent that transmits the message fragment will be elected by LAN broadcast negotiation.

The routing agent is the CA program of all users connected to a router, or the agent CA that is the agent of the second-level router network. The agent CA is elected according to certain rules. It is used to proxy the above CA program/agent CA and uses the SNMP protocol. Find the CA program/agent CA of the upper-level network, establish a communication link, negotiate to generate a higher-level agent CA, or establish an agent transmission mechanism. The top-level routing agent is used to communicate with the next-level routing agents CA, CCN and CA&CM server.

6) CA proxy form

The CA proxy form is recorded in the proxy CA. For a specific type of message, it is used to record the host IP address of the secondary proxy CA represented by the proxy CA, or the IP address of the proxy CA in the local area network and the proxy CA. The host IP address of the upper-level proxy CA of the CA (the purpose is to make the CA proxy form form a double-linked list structure, which is convenient for proxy CA information search). The CA proxy form is only stored in the proxy CA, and each level of CA proxy will generate a CA proxy form. The CA proxy form is not transmitted to the upper-level host when the information fragment submits the transmission request to the upper-level CA agent or CCN, thus protecting the user's privacy information.

7) CCN cloud computing server

CCN (Confluence Computing Node) cloud computing confluence node server is responsible for information transmission and distributed storage tasks on the backbone network. Specifically, CCN is used to receive data requests from CA programs, interact and match data requests between CCNs, and cooperate to generate a data transmission and storage scheme; a CA program is run on CCN, and the CA program running on CCN declares itself on behalf of CCN. , the CCN receives the data request of the CA program, the interaction between the CCNs and the data transmission function of the CCN are all performed through the CA program running on the CCN.

8) CA&CM server

The CA&CM server (Authentication&Coding Message) is used in the present invention to generate and maintain message codes, and to authenticate the validity of the CCN server.

In terms of generating and maintaining message codes, the server uses manual or big data analysis methods to classify and code messages in the Internet. When the message code is generated, the message piece corresponding to the message code is marked as a common message piece in the hotspot flag; after the message code is generated, if the message code does not appear in the network data request within a certain period of time, the message The message piece corresponding to the code is marked as a temporary message piece in the hotspot flag; after the message code is generated, if the number of times the message code appears in the network data request within a certain period of time exceeds the set threshold, the message code corresponds to The message piece is marked as a hot message piece in the hot spot flag; the message code corresponding to the message piece marked as a temporary message piece or a hot message piece, if the message code appears in the data request within a certain period of time and the number of occurrences is not equal. If it is greater than the set threshold, the message piece is marked as a normal message piece.

In terms of authenticating the legitimacy of the CCN server, a pair of asymmetric encryption public keys and private keys are pre-generated on the CA&CM server. The legitimate CCN has the right to obtain the private key from the CA&CM server, and the proxy CA obtains the public key from the CA&CM server. Whether the public and private keys match to verify the CCN. If the CCN authentication fails, the proxy CA sends an alarm to the remote CA&CM server.

Fig. 2, Fig. 3, Fig. 4 and Fig. 5 form the system structure diagram of the present invention together, and the basic steps of the data transmission method of the Internet self-organization and confluence of the present invention are as follows: each user end of the local area network runs a CA program, the CA program Obtain the information that users need to publish/receive/query/preference through the information collection module, and encapsulate the information and the message code defined by the CA&CM server into message pieces, broadcast them in the local area network, and send them to the CA programs of other users in the local area network; the message pieces are in the The message pieces are generated in CA programs and then exchanged between CA programs. Multiple CA programs in the local area network summarize each type of message piece, and each type of message piece is negotiated between CA programs to generate a local area network agent, which is responsible for publishing/receiving/querying/preference of this type of message piece The request task; Local area network proxy generation mainly describes how to elect a suitable proxy CA in the local area network to proxy all CAs of the same message type in the local area network. The LAN agent analyzes the local network topology through the SNMP protocol, and finds the LAN agents in other subnets under the same router. Request tasks such as preferences; routing agent generation mainly describes how to elect a proxy CA among all LAN agents under the same router to act as a proxy for all LAN agents of the same message type under the router, and how routing agents step by level according to the routing topology hierarchy Converge and generate upwards. Under the routing topology hierarchy, the next-level routing agent continuously aggregates and generates new routing agents through the SNMP protocol, and finally finds a CCN that also runs the CA program; any legal CCN can be authenticated by a CA&CM server; when the routing agent finds During CCN, the CA running on CCN declares itself as a CCN server, and the routing agent will verify the legitimacy of the CCN through the CA&CM server; after the verification is passed, the routing agent will submit the proxy message publishing/receiving/query/preference request to CCN . The CCN acquisition information describes how the CCN communicates with the routing agent to complete the information acquisition. CCN aggregates all the collected requests for message publishing/reception/query/preference to form an optimized message transmission and storage scheme among all CCNs. The resource distribution map generated by CCN describes how distributed storage is performed between CCNs to generate a resource distribution map. Through the cooperation between CAs and CCNs at all levels, the tasks of sending and receiving messages can be realized. Transmission scheme generation describes how to use CCN, routing agent and LAN agent to complete the data transmission process.

Referring to Fig. 1, the data transmission method of the Internet self-organized confluence of the present invention comprises the following steps:

1) Run the CA program on each user terminal, and set up multiple CCNs and at least one CA&CM server on the backbone network;

CA programs are used to generate data requests, to interact and to transfer data;

CCN is used to receive data requests from CA programs, interact and match data requests between CCNs, and cooperate to generate a data transmission and storage scheme; a CA program is run on CCN, and the CA program running on CCN declares itself to represent CCN, CCN Receiving data requests from CA programs, interaction between CCNs and data transmission functions of CCNs are all performed through the CA programs running on CCNs;

CA&CM server is used to verify CCN;

2) For data requests of the same type, proxy CAs are generated through interactive election between CA programs that propose data requests of the same type within the same area network. The type of data request that is proxied;

3) The CCN receiving the data request of this type arranges the transmission and local data buffering scheme according to the transmission request received;

4) If there is a data transmission task, the CCN transmits data to the CA program through the proxy CA. Specifically, the CCN transmits the data to the proxy CA, and the proxy CA searches the proxy CA program according to the CA proxy form and distributes the data to the CA program; if there are multi-level proxy CAs, the higher-level proxy CA searches the proxy CA through the CA proxy form. The next-level proxy CA, and distribute data to the next-level proxy CA.

The data request is marked with a specific identification code, and the CA proxy form is marked or named with the specific identification code; when transmitting data to the proxy CA, a specific identification code is embedded in the header of the data message; the proxy CA receives the specific identification code. In the data message, the specific identification code is obtained by analyzing the header, and the corresponding CA proxy form is searched according to the specific identification code.

The invention consists of three parts, including: CA program, CCN cloud computing confluence node and CA&CM server.

1. CA program

In the present invention, each client will run a CA program, and the functions of the CA program include the following points: 1) message generation; 2) message interaction; 3) proxy CA generation and operation; 4) mobile terminal identification.

1.1 Message Generation

The message generation mainly includes: 1) Acquiring tasks. The CA program running on the client accepts data transmission request tasks generated by users, and the request tasks include information release, reception, and query. The CA program is usually associated with the browser program and collects the requested tasks generated by the user. 2) Information coding. For the obtained task, the message is encoded according to the unified message encoding and the message message format (both of the message encoding and the message message format can be downloaded from the CA&CM server) to generate a message slice.

1.2 Message interaction

Message interaction between CA programs in the same local area network: CA programs in the same local area network use local area network broadcast to send message pieces to other CA programs in the local area network. Message interaction between CA programs in different local area networks: CA programs in a local area network obtain information on other local area networks directly connected to the same router or indirectly through multi-level routers by detecting network topology, and use TCP/IP protocol to establish connections and perform message interaction.

1.3 Proxy CA generation and operation

Proxy CA is a functional module of CA. The proxy CA includes a local area network proxy and a routing proxy, which are respectively used to proxy the transmission tasks of message pieces of the same message type under the same local area network and under the same router. The tasks of proxy CA include: 1) Create CA proxy form; 2) Health check and CA program deletion; 3) CA program addition.

The method of generating the LAN proxy is as follows:

The CA program generates message pieces and broadcasts the message pieces to other CA programs in the local area network. After receiving the broadcast message pieces, other CA programs store them in their own message piece lists. There is a proxy CA election module inside each CA program. The proxy CA election module is responsible for checking the list of message pieces in real time, and counting the total number of users of message pieces with the same message code. When the total number of users of message pieces of a certain message code reaches a certain device After a certain threshold (the threshold can be dynamically set in the configuration file), the proxy CA election module elects the proxy CA for this type of message piece. After the proxy CA is elected, the proxy CA election module creates a subprocess to execute the proxy CA function. The proxy CA keeps track of the total number of user requests for message fragments of a certain type, recording them in a separate message fragment storage list. In addition, the proxy CA uses the CA proxy form to record the information of all CA programs in the local area that generate message pieces of this type.

The generation principle of LAN proxy is as follows:

Referring now to FIG. 6, the principle of local area network proxy generation will be described. Step 1, the CA program first opens the UDP 8124 port as the LAN communication port. In step 2, the CA program obtains the user request. In the third step, the CA program encapsulates the user request into message pieces. In step 4, the CA program broadcasts a local area network proxy query message to the local area network. In step 5, the CA program determines whether a local area network proxy has been generated according to the query result in step 4. If so, go to step 6, directly use the existing local area network proxy, and the process of generating the local area network proxy ends; if not, go to step 7, Each CA program periodically generates a series of message pieces, and encapsulates the message pieces into packets for broadcasting to the local area network. Step 8: After the CA program receives the broadcast message fragment message, it establishes a local message fragment list. In step 9, the CA program regularly checks whether each message piece times out. If it times out, go to step 10, the CA program cleans up the outdated message pieces. The timeout period of the message slice needs to be dynamically configured in the configuration file. After the cleaning is completed, if there is no message fragment timeout, go to step 11, immediately check whether the cumulative number of each message fragment reaches a certain threshold, if it exceeds this threshold (the threshold is set by the configuration file), then go to step 12 step. Otherwise, go back to step 7. In step 12, a CA program in the local area network checks that it should be the agent of a certain message piece, and then proceeds to step 13 to broadcast a message declaring sovereignty to the local area network. Step 14: When other CA programs receive a message declaring sovereignty, they check the local message fragment list to verify whether the CA program declaring sovereignty is legal. If it is illegal, go to step 15, reply a negative message, and re-select the CA program as the local area network agent of the message piece through the principle of majority rule among CA programs. If it is legal, go to step 16, reply a confirmation message, and the LAN proxy authentication is successful. When the CA program elects the LAN agent, among all CAs of the same type under the same LAN, the CA program with the earliest timestamp of the message piece, the CA program with the largest bandwidth, or the CA program with the strongest processing performance can be selected as the LAN agent. The method can be flexibly configured according to the actual network environment, as long as the same area adopts a consistent election method. In the case of the same time stamp, the same bandwidth, or the same processing performance, the CA program with the smallest IP address is selected as the local area network agent.

The routing proxy is generated as follows:

As shown in Figure 3, many local area networks are often connected to the same router. Each local area network is called a subnet here. For a certain type of message piece (that is, a message piece with a certain message code), it may be in the subnet. Generate a proxy CA. Routing agent generation is to select a CA program to represent all agent CAs under the router from each agent CA under the same router. Such a CA program is called a routing agent. Routing proxy generation requires the following steps: 1) NAT port mapping: For LANs with private addresses, NAT port mapping needs to be used to ensure two-way communication between hosts on the intranet. 2) Agent CAs in each local area network under the same router interact to generate routing agents. 3) The lower-level routing agent converges to the upper layer according to the router tree hierarchy: the routing agent uses the SNMP protocol to find all subnet information of the higher-level router, and generates a higher-level routing agent according to step 2. Routing agents converge up the router tree hierarchy until the nearest CCN is found. If the router tree hierarchy of the network is similar to a tree structure, the structure is pruned to make it a tree structure.

1) NAT port mapping

For LANs with public addresses, they can communicate with the external network directly; for LANs with private addresses, because private addresses cannot be used directly on the public network, a certain method needs to be used for NAT intranet port mapping. Commonly used NAT intranet penetration schemes include UDP hole punching or STUN protocol, but these methods require another known server deployed in the public network environment. The present invention adopts the UPnP protocol. How the UPnP protocol works:

1. First, both the control point and the device must obtain the IP address before proceeding to the next step;

2. The control point must first look for UPnP devices on the entire network, and the devices on the network must also announce their own existence;

3. The control point needs to obtain a description of the equipment, including what kind of services these equipment provide;

4. The control point sends action information to the device;

5. The control point monitors the state of the device, and takes corresponding processing actions when the state changes;

Through the UPnP protocol, the port of the machine can be mapped to an external network port, and the mutual access of the external network can be realized through the external network port + the external network IP. For LANs with private addresses, each host maps ports to the port range starting from 8124 and onwards.

2) Agent CAs in each local area network under the same router interact to generate routing agents

It mainly includes two parts: 1) SNMP network topology discovery. 2) Routing proxy generation based on network topology discovery. The proxy CA in a local area network uses SNMP network topology discovery to obtain network topology information, and then based on the discovered network topology, the proxy CA searches for other local area networks under the same router, and exchanges messages with the surviving hosts in it to generate routing proxy generation.

SNMP network topology discovery

The following describes the SNMP network topology discovery process with reference to Figure 7. This process is based on graph theory BFS search. In step 1, the agent CA adds the gateway ip of the local area network where it is located to the search queue. Step 2, determine whether the queue is empty, if so, go to step 3, use the graph theory link method to store the network topology, and end. If not, go to step 4, dequeue the queue head element (that is, the IP address of the router), and initiate an SNMP request to it. Step 5: Obtain subnet information, interface information, directly connected router information and MAC address information corresponding to each exit of the router. Step 6, the router IP that is directly connected to the router and has not been accessed joins the BFS search queue, and then returns to step 2.

Routing proxy generation based on network topology discovery

Next, referring to FIG. 8 , the flow of generating the routing proxy will be described. Step 1, when the CA program in a local area network becomes the proxy CA of the message piece, the proxy CA reads the information of other local area networks connected to the gateway through SNMP protocol; Step 2, the proxy CA starts from port 8124 to detect other local area networks externally the public network address; step 3, check whether the probe port is alive; if the probe port is not alive, go to step 4; step 4, the port number is incremented by 1, go back to step 2, and continue to probe; if the probe port is alive , then go to step 5; step 5, send a request to the port to query the proxy CA of a certain type of message piece; step 6, after the surviving hosts in other LANs receive the query message, send the proxy CA to the request The information is returned, and the proxy CAs store each other's information; step 7, check whether the proxy CA has been generated according to the information returned in step 6, if the proxy CA has been generated, then proceed to step 8, and use the existing proxy CA as its own proxy CA; if no proxy CA is generated, go to step 9. Step 9, check whether all other LANs have been probed; if not, go back to Step 2; if all probes are completed, go to Step 10; Step 10, proxy CAs of each LAN under the same router broadcast each other to select the router The general agent of all subnets, namely the routing agent; if the router is directly connected to other routers, it is discovered through the SNMP protocol, and the routing agent prunes the discovered complex network topology to form a typical tree structure, and then route The agents converge layer by layer according to the hierarchical structure of the tree, that is, repeat steps 1 to 10, and continue to find new routing agents; after several layer-by-layer aggregation, they reach the CCN, and the highest-level routing agent communicates with the CCN to complete the identity. Authentication, messaging, and data transfer.

Among all proxy CAs under the same router, the proxy CA with the earliest timestamp of the message fragment, or the proxy CA with the largest bandwidth, or the proxy CA with the strongest processing performance is elected as the routing proxy. The election method can be flexibly configured according to the actual network environment. As long as the same region adopts a consistent method of elections. When the time stamp is the same, the bandwidth is the same, or the processing performance is the same, the proxy CA with the smallest IP address is selected as the routing proxy.

3) The lower-level routing agent converges to the upper-level according to the router tree hierarchy

As shown in Figure 4, this is a typical three-layer network architecture model of the regional network, including the core layer, the aggregation layer and the access layer. The hierarchical relationship between the adjacent two-layer routes is obvious, but the lower-layer routers are often connected to multiple routers. In this way, during the routing proxy election, the lower-layer routes may be proxied by multiple routing agents at the same time, which is undesirable. To this end, a pruning scheme is proposed to ensure that a lower-layer router only connects to one router during routing proxy election. Assuming that the set of router IPs connected to a lower-level router is {ip ₁ , ip ₂ ...... ip _n }, calculate the 128-bit information digest of SHA-1 for each IP in the IP set, and select the smallest information digest one as an uplink router. This ensures that the lower-layer routers are connected to the upper-layer routers in a balanced manner. After the pruning operation is completed, the network topology can form a typical tree structure, and routing agents are generated layer by layer according to the router agent election policy. After finally converging to the top-level core router, the top-level routing agent interacts with the CCN. Convergence means that the proxy CA under the same router elects a new proxy CA through the election mechanism, and the new proxy CA uses the same election mechanism to converge layer by layer according to the tree structure of the network.

It should be noted that if the upper-level router B of a router A is connected to multiple routers at the same level as router A, then the routing agent A of router A searches for the routing agent of the router at the same level as follows: The routing agent A uses the SNMP protocol to find A local area network of a subtree formed by one of the routers at the same level, and detects any surviving host in the local area network, the surviving host returns to its local area network proxy, and the local area network proxy stores its upper-level proxy, so according to the proxy form, it has similar Due to the characteristics of the doubly linked list, iterative query can be used to find the routing agents of routers at the same level as router A.

The tasks of proxy CA include: 1) Create CA proxy form; 2) Health check and CA program deletion; 3) CA program addition.

Create CA Proxy Form

The CA proxy form is recorded in the proxy CA. For a specific message, it is used to record the IP address of the CA program represented by the proxy CA or the host IP address and port of the secondary proxy CA; the CA proxy form also records the proxy CA. The IP address information of the upper-level proxy CA of the CA, thus forming a double-linked list structure, which is convenient for the subsequent search of the proxy CA.

Health Check and CA Program Removal

The health check module in the CA program where the proxy CA is located regularly detects whether the upper-level proxy of the proxy CA is alive. If the upper-level proxy does not survive, the proxy CA renegotiates with the same-level proxy CA to generate a new proxy CA. The new proxy CA requests other proxy CAs at the same level as it, obtains the information of the upper-level proxy CA of the new proxy CA, and reports the new proxy CA information to the upper-level proxy CA, and the upper-level proxy CA updates the CA proxy form . At the same time, the health check module of each proxy CA will also regularly check all the secondary proxy CA/CA programs of its proxy. Correspondingly add or delete the information about the CA/CA program of the second-level agent.

CA program added

For the newly added CA program, it will send a broadcast message to the local area network to detect whether the message type of its agent already has a proxy CA. 1) If an existing proxy CA is found, the newly added CA program will automatically use the existing proxy CA as its own. At the same time, the proxy CA will actively report its existence to the proxy CA. After the proxy CA receives the report, it will add the CA program in the CA proxy form; 2) If no proxy CA is found, use the local area network proxy election method to elect a new proxy CA. . Then, the proxy CA uses the message interaction function of the CA programs of different LANs to discover the information of other LANs connected to the same router, and searches for messages to the surviving hosts in the routing agent. After finding the routing agent, it asks whether the current router has Generate a routing agent. If a routing agent has been generated, the proxy CA sends a message to the generated routing agent, indicating that it is a new proxy CA, and the generated routing agent adds the information of the proxy CA in the CA proxy form; if not generated Routing agent, then generate a new routing agent according to the method of generating routing agents in different LANs under the same router.

1.4 Mobile identification

Detect whether the terminal where the current CA program is located is a mobile terminal. If so, the mobile terminal will not become a proxy CA; because the mobile terminal has precious traffic and low power, it is not suitable to perform functions with intensive data requests and large traffic consumption. There is a mobile terminal identification module, the user can set whether to enable the mobile agent CA function in the system. If the mobile agent CA function is not enabled, then when the current CA program is detected in the mobile terminal, the mobile terminal will not become the agent CA. If the user actively enables the mobile proxy CA function, when it is detected that the current CA program is in the mobile terminal, the mobile terminal can also become the proxy CA.

2. CCN Cloud Computing Convergence Node Server

CCN (Confluence Computing Node) cloud computing confluence node server is responsible for information transmission and distributed storage tasks on the backbone network. Specifically, the CCN receives the data request of the CA program, interacts and matches the data request between the CCNs to generate a resource distribution map, and cooperates between the CCNs to generate a data transmission and storage scheme. As shown in Figure 5, a CA program runs on the CCN. The CA program running on the CCN declares itself to represent the CCN. The CCN receives the data request of the CA program, the interaction between the CCNs and the data transmission function of the CCN are all run on the CCN. The CA procedure is carried out. The CCN is arranged on the network close to the backbone network. According to the structure, geographical distribution, and message transmission and distribution characteristics of the backbone network, the present invention needs to arrange a certain number of CCNs.

CCN receives data requests from CA programs

Before the CCN receives the data request from the CA program, in order to prevent malicious nodes from impersonating the CCN to steal information, the CCN needs to be authenticated. As shown in Figure 9, the process of CCN identity authentication is as follows:

1) The CA&CM server generates a set of public and private keys for asymmetric encryption;

2) The CA&CM server uses the private connection to send the private key to the CCN, and the routing agent downloads the corresponding public key from the CA&CM server;

3) The routing agent uses a random algorithm to generate a 128-bit random number, encrypts it with the public key, generates an identity authentication message and sends it to the CCN to be determined.

4) After CCN receives the identity authentication message, it extracts the encrypted information string and decrypts it with its own private key. After decryption, the decrypted information generates an identity authentication response message and sends it back to the routing agent, and the routing agent compares whether the string in the response message is consistent with the string generated by itself.

5) If it is consistent, the authentication is passed; if it is inconsistent, it is not passed, and an alarm is sent to the remote CA&CM server.

Generate resource distribution map

The CCN accepts the request message fragments of the routing agent generated by the aggregation of message fragments, and the transmission attribute in each message fragment records the actions involved in the transmission of the message, including: publish/receive/query/preference, etc. In addition, CCN will also receive release type message pieces from resource producers. The CCN stores the message pieces of the nearby area, and all the CCNs jointly record the message pieces of all the areas, so that the information graph of all resource producers and consumers is formed in the CCN.

For resource producers, they will encapsulate their own stored resources into release-type message pieces, and actively contact the CCN on the nearest backbone network, and send the release-type message pieces to CCN, which can parse distribution-type message pieces. . That is, if the user terminal is a resource producer, the user terminal actively contacts the CCN through the CA program, and sends a resource release data request to the CCN. Although resource producers actively contact CCN, in fact, resource producers exposing their own IP information to CCN will not have much impact, because big data analysis of published information content does not have much commercial value, so resource producers There is no need to worry about privacy leaks caused by big data analysis.

In the above-mentioned transmission process, the information that optimizes the user experience by accessing the user's preferences in the current Internet can still be encapsulated in the above-mentioned message fragments in a certain way, but this information is: 1) Whether it is added entirely by the user; 2) In the process of multi-layer proxy CA transmission, the user's terminal IP address is hidden, thereby avoiding excessive mining of the user's private information.

Collaborate to generate a data transfer and storage solution:

1) After a specific CCN receives the data request with the receiving attribute sent by the proxy CA, the specific CCN searches for the data request with the publishing attribute that matches the data request with the receiving attribute through the distributed system formed between the CCNs. ;

2) The CCN where the matching data request with the publishing attribute is located sends a request to the CA program that publishes the data request with the publishing attribute, and receives and caches the corresponding resources;

3) The CCN where the matched data request with the publishing attribute is located transmits the cached corresponding resources to the specific CCN, and the specific CCN caches the received corresponding resources;

4) The specific CCN sends the cached corresponding resource to the proxy CA that made the data request with the receive attribute.

3. CA&CM server

The CA&CM server (Authentication&Coding Message) is used in this paper to generate and maintain message codes, and to authenticate the validity of CCN.

In terms of generating and maintaining message codes, the server uses manual or big data analysis methods to classify and code messages in the Internet. The encoded messages are divided into 2 categories: 1) Basic messages, which will be permanently valid and represent the most commonly used messages in the Internet; 2) Temporary messages, temporary message codes are temporarily generated in response to special circumstances, if the message code is temporarily valid for a period of time After that, the temporary message of some kind of code no longer appears in the network data transmission, the temporary message will be marked, and the marking will be used to optimize the information transmission and distributed storage scheme. This is realized by the hot spot flag bit of message encoding. According to the results of statistical analysis of information transmission in the network, the message codes with large current information transmission traffic are marked to optimize message transmission and distributed storage scheme.

In terms of verifying the legitimacy of CCN, the CA&CM server can generate paired asymmetric encryption keys. CCN has the right to log in to the CA&CM server through a private link to obtain the private key. When the routing agent needs to verify the validity of the CCN, the routing agent can Request the CA&CM server to obtain the public key corresponding to the CCN. If the public key and the private key can match, the CCN authentication passes; otherwise, the CCN authentication fails.

proxy transport mechanism

Resource data may be directly transmitted by the CA program, or may be assisted by the CCN+ proxy CA. The basic principle is that if the number of requests is small, the CA program will transmit them directly, and when the number of requests is large, the CCN+ proxy CA will assist in the transmission. By constructing a cost model, the transmission cost, CCN cost and benefit are comprehensively considered to select the optimal transmission method. When the value of revenue/(transmission cost + CCN cost) is higher than a certain threshold (set dynamically in the configuration file), CCN+ proxy CA is used for auxiliary distribution; when its value is less than the threshold, CA program is used for direct transmission. The benefit refers to the economic value brought by data transmission, the transmission cost refers to the resource consumption cost of proxy CA tree distribution, and the CCN cost refers to the hardware and bandwidth cost of configuring the CCN. 1) When the CA program is used for direct transmission, the scale of resource consumers is small, and the resource consumer directly initiates a request to obtain resources from the CA program of the resource producer; 2) When the CCN + proxy CA assisted transmission is used, the proxy transmission mechanism is used: The resource consumer generates a message packet whose transmission attribute is received, and gradually aggregates it to the CCN 1 by generating a local area network agent and a routing agent. If the resource data is cached on CCN1, then CCN1 directly forwards the resource data to the routing agent; if CCN1 does not cache the resource data, then CCN1 requests all CCNs to find the resource producer information of the relevant message pieces, if the resource information is found in At CCN2, CCN1 initiates a transmission request to CCN2. If CCN2 itself stores the resource, it directly forwards the resource to CCN1; otherwise, CCN2 initiates a request to the resource producer, caches it locally in CCN2, and forwards it to CCN1 at the same time. CCN1 caches the received resource data, and at the same time, CCN1 forwards the resource data to the routing agent. After the routing agent receives the resource data from the resource producer, the routing agent sends the resource to the lower-level agent CA according to the proxy form. A message code is embedded in the header of the data message. When each level of proxy CA receives the data, it analyzes the header to obtain the message code, and the proxy CA finds the corresponding CA proxy form according to the message code, and delivers the data to the next-level proxy CA/CA program. Until the LAN agent is reached, finally the LAN agent is responsible for distributing the message to the resource consumers. It should be noted that the resource distribution process can be optimized using a certain algorithm.

Communication system message format

The main communication message formats used in the present invention are described below, including the local area network CA program communication message format and the intermediate routing layer communication message format.

The format of the communication message generated by the LAN agent:

FIG. 10 is the message message format of the mutual broadcast of CA programs in the local area network of the present invention. This is a message that the CA program obtains and then encapsulates the message generated by the user into message pieces, and periodically broadcasts the message to the surrounding CA programs.

FIG. 11 is a local area network proxy broadcast message of the present invention. This is a message that declares the sovereignty of message slices to other CA programs in the local area network when a CA program finds itself as an alternate proxy CA.

The routing agent generates the communication packet format:

FIG. 12 is a message of a proxy CA requesting other proxy CAs according to the present invention. This is a request message sent by a proxy CA to other subnet CAs when it searches for other proxy CAs under the same router.

FIG. 13 shows other subnet hosts responding to the proxy CA information message according to the present invention.

The present invention is a transmission scheme formed by mutual cooperation between CA program, CCN and CA&CM server running on the client. For each specific message transmission request, the CA program on the adjacent client in the Internet will generate its transmission agent through interaction, and at the same time, the transmission agents will also interact to generate a higher-level transmission agent in a larger area. This process can Repeat, so that the highest-level transport agent that generates the message is aggregated within a backbone network area; the converged transport agent makes a transmission request to a CCN running on the backbone network, and uses the CA&CM server to authenticate the CCN; running on the backbone network All CCNs in the network adaptively arrange transmission and local data buffering schemes according to the received transmission requests to optimize data transmission efficiency; the present invention can use lower backbone network bandwidth occupation and lower bandwidth on the premise of not changing the existing network architecture. It achieves good transmission performance at a low deployment cost, and all nodes participating in the transmission maintain a balanced position, which greatly protects the privacy of users.

The invention uses the CA program, CCN and CA&CM server to connect the information publishers and information receivers in the Internet, and at the same time uses the proxy transmission mechanism to reduce the occupation of the backbone network bandwidth. Cloud server, so the deployment cost of the present invention is lower. Therefore, the present invention can realize point-to-face/face-to-face transmission with lower backbone network bandwidth occupation and lower deployment cost. At the same time, the present invention puts all participating entities in a balanced position in the process of information transmission, eliminates the excessive analysis and use of users' private information by powerful individuals in the current Internet information transmission, greatly protects users' privacy, and improves network security performance.

Claims (21)

1. a data transmission method of Internet self-organized confluence, is characterized in that, comprises the following steps: 1) run the CA program on each user terminal, and set up multiple CCNs and at least one CA&CM server on the backbone network; wherein, CA represents a chat agent, CCN represents a cloud computing confluence node, and CA&CM represents authentication and message encoding; CA programs are used to generate data requests, to interact and to transfer data; CCN is used to receive data requests from CA programs running on user terminals, interact and match data requests between CCNs, and cooperate to generate a data transmission and storage scheme; a CA program is run on CCN, and the CA program running on CCN declares to the outside world It represents the CCN itself, and the CCN receives the data request of the CA program running on the user terminal, the interaction between the CCNs and the data transmission function of the CCN are all performed through the CA program running on the CCN; CA&CM server is used to verify CCN; 2) For data requests of the same type, proxy CAs are generated through interactive election between CA programs that propose data requests of the same type within the same area network. The type of data request that is proxied; 3) The CCN receiving the data request of this type arranges the transmission and local data buffering scheme according to the transmission request received; 4) If there is a data transmission task, the CCN transmits data to the CA program running on the user terminal through the proxy CA. 2. the data transmission method of Internet self-organized confluence as claimed in claim 1, is characterized in that, data request is encapsulated into message piece according to fixed message format, and is issued and received in the form of message piece; Described message piece The data attributes include message code, transmission attribute, number of users, timestamp, description, hotspot flag bit and proxy bit; The message codes are a series of codes that are generated by the CA&CM server and can be freely downloaded to classify all data resources in detail; Transport properties are the actions involved in a data request, including publishing, receiving, and querying; The number of users is the number of users who have the message code among the connected users; The timestamp is the moment when the user generated the message piece; Descriptions are used to supplement details that are missing after a data request is represented by a code; The hotspot flag is used to mark the data request, and to optimize the transmission and distributed storage scheme of the data request; The proxy bit is a flag bit used to describe whether the data request has generated a proxy. 3 . The data transmission method for self-organized confluence on the Internet according to claim 2 , wherein the data attribute of the message piece further comprises a preference attribute, which is used to record the user's access preference. 4 . 4 . The data transmission method for self-organized confluence on the Internet according to claim 2 , wherein the message piece is packaged by a CA program running on the user terminal after collecting the data request sent by the user. 5 . 5. the data transmission method of Internet self-organized confluence as claimed in claim 2, is characterized in that, when message code is produced, the message piece corresponding to this message code is marked as ordinary message piece in hot spot flag position; After generation, if the message code no longer appears in the data request within a certain period of time, the message piece corresponding to the message code will be marked as a temporary message piece in the hotspot flag; If the number of times the message code appears in the request exceeds the set threshold, the message piece corresponding to the message code is marked as a hot message piece in the hotspot flag; the message piece marked as a temporary message piece or a hot message piece corresponds to Message code. If the message code appears in the data request within a certain period of time and the number of occurrences is not greater than the set threshold, the message piece is marked as a common message piece. 6. The data transmission method of Internet self-organized confluence as claimed in claim 1, is characterized in that, described proxy CA agent other has the CA program of identical data request, and proxy CA records its all in independent data request storage list. Agent's CA program address information and the number of users of the agent, and create a CA agent form. 7. The data transmission method of Internet self-organized confluence as claimed in claim 6, is characterized in that, described agent CA comprises local area network agent and multi-level routing agent; The local area network agent sends out data requests to the upper-level network on behalf of all CA programs with the same data request in the local area network; The routing agent sends data requests to the upper-level network on behalf of the CA program of all users connected to a router or the agent CA of the next-level router network; The top-level routing agent is used to communicate with the next-level routing agents CA, CCN and CA&CM server. 8. the data transmission method of Internet self-organized confluence as claimed in claim 7 is characterized in that, the generation method of local area network agent is: The CA program running on the user terminal generates a data request, and broadcasts the data request to the CA program running on other user terminals in the same local area network. The CA program running on other user terminals receives the broadcast data request and stores the data request. In its own data request list; the proxy CA election module set inside the CA program running on each user terminal checks the data request list in real time, and counts the total number of users who have issued the same data request for each data request; After the total number of users requesting data is greater than the set threshold, the proxy CA election module elects the proxy CA for the data request; the proxy CA creates a child process to execute the proxy CA function. 9. the data transmission method of Internet self-organized convergence as claimed in claim 7 is characterized in that, the generation method of routing agent CA is: After a local area network proxy CA is generated in a local area network, the local area network proxy CA discovers other local area network information under the same router through the interaction function of the CA programs running on the user terminals of different local area networks, and interacts with the local area network proxy CA to query data requests, and obtain other local area network information. LAN proxy CA information; LAN proxy CAs establish connections with other LAN proxy CAs and exchange data requests from their respective proxies to elect a LAN proxy CA; After establishing contact between the second-level routing agent CAs connected to the same router and exchanging the data requests they represent, the routing agent CA of the router is elected. 10. The data transmission method of Internet self-organized confluence as claimed in claim 9, it is characterized in that, if the router tree hierarchy structure of network is similar to tree structure, then this structure is carried out pruning operation, make it become tree shape structure. 11. The data transmission method of Internet self-organized confluence as claimed in claim 6, wherein the CA proxy form is recorded in the proxy CA, for recording the IP address or the secondary level of the CA program represented by the proxy CA The host IP address and port of the proxy CA; the CA proxy form also records the IP address information of the upper-level proxy CA of the proxy CA. 12. the data transmission method of Internet self-organized confluence as claimed in claim 11, is characterized in that, in step 4) in, the method that CCN carries out data transmission to the CA program that runs on user terminal by described agent CA is: The CCN transmits the data to the proxy CA, and the proxy CA finds the proxy CA program according to the CA proxy form and distributes the data to the CA program; If there are multi-level proxy CAs, the higher-level proxy CA looks up the proxy next-level proxy CA through the CA proxy form, and distributes data to the next-level proxy CA. 13. The data transmission method of Internet self-organized confluence as claimed in claim 12, characterized in that, the data request is marked as a specific identification code, and the CA agent form is marked or named with the specific identification code; When transmitting data, a specific identification code is embedded in the header of the data message; when the proxy CA receives the data message, it analyzes the header to obtain the specific identification code, and searches for the corresponding CA proxy form according to the specific identification code. 14. The data transmission method of Internet self-organized confluence as claimed in claim 6, it is characterized in that, there is a health check module in CA program, is used for regularly checking whether the agent CA of CA program is alive, if the detection finds that agent CA is not alive , then a new proxy CA is re-elected between CA programs; The health check module of the CA program where the proxy CA is located regularly checks the CA programs it represents. If the proxy CA finds that a CA program in its CA proxy form is offline, it will delete the CA program from the CA proxy form. 15. The data transmission method of Internet self-organized confluence as claimed in claim 8, it is characterized in that, the CA program newly added in the local area network first sends broadcast message to local area network to detect whether the data request it sends out already has agent CA: If there is a proxy CA, the newly added CA program will automatically use the existing proxy CA as its own proxy CA, and actively report its existence to the proxy CA. After the proxy CA receives the report, it will add the CA program in the CA proxy form; if If no proxy CA is found, a proxy CA is elected in the local area network. 16. The data transmission method of Internet self-organized confluence as claimed in claim 8, it is characterized in that, after the new proxy CA is generated, the new proxy CA utilizes the message interaction function of the CA program running on the user terminal of different local area networks to find out with it. Connect other LAN information under the same router, and initiate routing proxy CA search requests to user terminals in these LANs. After finding routing proxy CA, ask routing proxy CA whether routing proxy CA has been generated under the current router, and if routing proxy CA has been generated Proxy CA, the new proxy CA sends a message to the generated routing proxy CA, indicating that it is the newly added proxy CA, and the generated routing proxy CA adds the information of the new proxy CA in the CA proxy form; if no proxy CA is generated If the routing agent CA is used, a new routing agent CA is generated according to the method of generating routing agents under the same router. 17. the data transmission method of Internet self-organized confluence as claimed in claim 6, it is characterized in that, whether user can be set to open mobile agent CA function, if do not open mobile agent CA function, then detect when current CA program is in mobile terminal , the mobile terminal will not become a proxy CA; if the user actively activates the mobile proxy CA function, when it is detected that the current CA program is in the mobile terminal, the mobile terminal can also become a proxy CA. 18. The data transmission method of Internet self-organized confluence as claimed in claim 1, is characterized in that, the method that CA&CM server verifies CCN is: A pair of asymmetric encryption public keys and private keys are pre-generated on the CA&CM server. A legal CCN has the right to obtain the private key from the CA&CM server. The proxy CA obtains the public key from the CA&CM server, and uses whether the public key and the private key match to verify. CCN. 19. The data transmission method of Internet self-organized confluence as claimed in claim 18, wherein if the CCN authentication fails, the proxy CA sends an alarm to the remote CA&CM server. 20. The data transmission method of Internet self-organized confluence as claimed in claim 1, is characterized in that, if the user terminal is a resource producer, then the user terminal actively contacts CCN through CA program, and sends a resource release data request to CCN. 21. The data transmission method of Internet self-organized confluence as claimed in claim 1, is characterized in that, in step 3) in, the CCN that receives described this type of data request arranges transmission and local data cache according to the transmission request received The method of the scheme is: a) After the CCN receives the data request with the receiving attribute sent by the agent CA, the CCN searches for the data request with the publishing attribute that matches the data request with the receiving attribute; b) The CCN where the matching data request with the publishing attribute is located sends a request to the CA program running on the user terminal that publishes the data request with the publishing attribute, and receives and caches the corresponding resources; c) the CCN where the matched data request with the publishing attribute is located transmits the cached corresponding resources to the CCN in step a), and the CCN caches the received corresponding resources; d) The CCN in the step a) sends the cached corresponding resource to the proxy CA that makes the data request with the receiving attribute.

Images