[go: up one dir, main page]

CN108494595B - High-efficiency new-generation big data network implementation method - Google Patents

High-efficiency new-generation big data network implementation method Download PDF

Info

Publication number
CN108494595B
CN108494595B CN201810235148.1A CN201810235148A CN108494595B CN 108494595 B CN108494595 B CN 108494595B CN 201810235148 A CN201810235148 A CN 201810235148A CN 108494595 B CN108494595 B CN 108494595B
Authority
CN
China
Prior art keywords
data
message
router
interface
interface address
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Active
Application number
CN201810235148.1A
Other languages
Chinese (zh)
Other versions
CN108494595A (en
Inventor
王晓喃
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Daoji Intelligence Anhui Information Technology Co ltd
Original Assignee
Changshu Institute of Technology
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Changshu Institute of Technology filed Critical Changshu Institute of Technology
Priority to CN201810235148.1A priority Critical patent/CN108494595B/en
Publication of CN108494595A publication Critical patent/CN108494595A/en
Application granted granted Critical
Publication of CN108494595B publication Critical patent/CN108494595B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Images

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/08Configuration management of networks or network elements
    • H04L41/0803Configuration setting
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L45/00Routing or path finding of packets in data switching networks
    • H04L45/54Organization of routing tables
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L45/00Routing or path finding of packets in data switching networks
    • H04L45/74Address processing for routing
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L45/00Routing or path finding of packets in data switching networks
    • H04L45/74Address processing for routing
    • H04L45/745Address table lookup; Address filtering

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)
  • Mobile Radio Communication Systems (AREA)

Abstract

本发明提供了一种高效的新一代大数据网络实现方法,所述网络包括骨干网络、数据网络和移动网络;骨干网络包括两个以上的核心路由器,数据网络包括代理路由器、数据路由器和接入节点,移动网络包括一个移动路由器和两个以上的移动设备;所述大数据网络中的每个节点通过本发明所提供的网络实现方法,能够快速获取数据,从而大幅度提高了服务性能。本发明可应用于交通路况检控及农业工程化等诸多领域,具有广泛的应用前景。

Figure 201810235148

The invention provides an efficient new generation big data network implementation method, the network includes a backbone network, a data network and a mobile network; the backbone network includes more than two core routers, and the data network includes proxy routers, data routers and access The mobile network includes a mobile router and more than two mobile devices; each node in the big data network can quickly acquire data through the network implementation method provided by the present invention, thereby greatly improving service performance. The invention can be applied to many fields such as traffic road condition inspection and control and agricultural engineering, and has wide application prospects.

Figure 201810235148

Description

High-efficiency new-generation big data network implementation method
Technical Field
The invention relates to an implementation method, in particular to an efficient new generation big data network implementation method.
Background
The communication between nodes in the big data network is realized by forwarding and routing of intermediate nodes, so one of the key technologies to be solved for realizing the big data network is to reduce data transmission delay so as to enable users to quickly acquire network services. With the development of network technology, big data networks will become a mode for providing services in the future.
At present, the implementation mode of the big data network is realized through broadcasting, so that both delay and cost are large, and the network service performance is reduced. Therefore, how to reduce the delay and cost of providing services by a big data network becomes a hot issue of research in recent years.
Disclosure of Invention
The purpose of the invention is as follows: the invention aims to solve the technical problem of providing an efficient new generation big data network implementation method aiming at the defects of the prior art.
The technical scheme is as follows: the invention discloses a method for realizing a new generation of high-efficiency big data network, wherein the network comprises a backbone network, a data network and a mobile network; the backbone network comprises more than two core routers, the data network comprises a proxy router, a data router and an access node, and the mobile network comprises one mobile router and more than two mobile devices.
A core router contains X1 wired interfaces, X1 is a positive integer greater than 1; a proxy router comprises an upstream wired interface and X2 downstream wired interfaces, a data router comprises an upstream wired interface and X2 downstream wired interfaces, and X2 is a positive integer greater than 1; an access node comprising an upstream wired interface and a downstream wireless interface, a mobile router comprising an upstream wireless interface and a downstream wireless interface; a mobile device includes a wireless interface.
The upstream interface of the proxy router is connected with one interface of the core router, and each downstream interface of the proxy router is connected with the upstream interface of one data router; the upstream interface of a data router is connected with the downstream interface of a proxy router or a data router, and each downstream interface of the data router is connected with the upstream interfaces of other data routers or access nodes; the upstream interface of the access node is connected with the downstream interface of the data router, and the downstream interface of the access node is connected with the upstream interface link of the mobile router; the upstream interface of the mobile router is connected to a downstream interface link of an access node, and the downstream interface of the mobile router is connected to an interface link of the mobile device.
Each of the core routers, data routers, proxy routers, and access nodes have unique geographic coordinates.
Each interface of a core router is uniquely identified by an interface address, which is equal to j, and j takes values from 1 to X1.
The upstream interface and each downstream interface of a proxy router are uniquely identified by an interface address, and the interface address comprises a geographic abscissa and a geographic ordinate; a data network is uniquely identified by the interface address of the upstream interface of the proxy router of the network in which it resides.
The upstream interface and each downstream interface of a data router are respectively and uniquely identified by an interface address, the interface address is formed by geographical coordinates, and the geographical coordinates comprise a geographical abscissa and a geographical ordinate; the upstream interface and the downstream interface of one access node are both uniquely identified by an interface address, and the interface address is formed by geographic coordinates; the upstream interface and the downstream interface of a mobile router are both uniquely identified by an interface address, which is composed of geographical coordinates.
One kind of data is uniquely identified by a name, and one name is composed of geographical coordinates and a name ID; the mobile equipment realizes data communication through messages; a message is composed of a name field, a message type field, a source interface address set field, a destination interface address set field, an identification field and a load.
If one type of data has a length of m bits, a maximum length of a message payload is n bits, n and m are positive integers, m is greater than w1 xn, and w1 is a positive integer greater than 10, the data is divided into u data blocks and transmitted through u messages, as shown in equation (1); the length of the first u-1 data blocks is n, and the length of the last data block is m- (u-1) x n;
Figure GDA0002881747940000021
the message types are shown in the following table:
message type value Message name
1 Address configuration messages
2 Creating forwarding table messages
3 Data request message
4 Data acquisition messages
5 Data response message
The identification field of a message is only valid when the message type is 5, and the value of the identification field is 0 or 1; if the identification domain value is 0, the message load is the last data block of the type of data; if the identification field value is 1, the message load is indicated as other data blocks except the last data block in the type of data.
If the coordinates of the access node are (x1, y1), after the access node is started, the access node sets the interface address of the upstream interface of the access node to (x1, y1), the interface address of the downstream interface to (x1+ b1, y1+ b1), b1 is a non-zero integer, and the access node periodically performs the following interface address configuration operations:
step 101: start of
Step 102: the access node sends an address configuration message from the upstream interface, the geographic coordinate of the name domain value of the address configuration message is (x1, y1), the name ID is 0, the identifier is 0, the message type is 1, the source interface address set and the destination interface address set are both empty, and the load is empty.
Step 103: and judging whether the proxy router or the data router receives the address configuration message, if the proxy router receives the address configuration message, executing the step 105, and if not, executing the step 104.
Step 104: after receiving the address configuration message from the downstream interface, the data router sets the interface address of the downstream interface as the geographic coordinate in the name domain of the received address configuration message, and sets the interface address of the upstream interface as the geographic coordinate of the upstream interface. The data router sends an address configuration message from the upstream interface, the geographical coordinate of the name field value of the address configuration message is the geographical coordinate of the address configuration message, the name ID is 0, the identifier is 0, the message type is 1, the source interface address set and the destination interface address set are both empty, the load is empty, and step 103 is executed.
Step 105: after receiving the address configuration message from the downstream interface, the proxy router sets the interface address of the downstream interface as the geographic coordinate in the name domain of the received address configuration message, and sets the interface address of the upstream interface as the geographic coordinate of the proxy router.
Step 106: and (6) ending.
The proxy router and the data router can rapidly configure the address through the above process so as to ensure the correctness of data communication.
In the method of the invention, a mobile router sets the interface address of the upstream interface as the geographical coordinate (x2, y2) of the mobile router, sets the interface address of the downstream interface as (x2+ b2, y2+ b2), and b2 is a non-zero integer. A mobile device sets the interface address of its interface to its geographical coordinates. Each core router maintains a forwarding table, each forwarding table entry including geographic coordinates, an interface address and a lifecycle. After the agent router configures the interface address, the following operations are executed to create a forwarding table:
step 201: start of
Step 202: the proxy router sends a message for creating a forwarding table from an upstream interface, the geographical coordinates of the name domain value of the message for creating the forwarding table are the geographical coordinates of the proxy router, the name ID is 0, the identifier is 0, the message type is 2, the source interface address set and the destination interface address set are both empty, and the load is empty.
Step 203: and judging whether the proxy router or the core router receives the message for creating the forwarding table, if the proxy router receives the message for creating the forwarding table, executing the step 208, and if not, executing the step 204.
Step 204: after the core router receives the message for creating the forwarding table from an interface, if the interface address of the interface is k, the core router checks the forwarding table, and if a forwarding table entry exists, the geographic coordinate of the forwarding table entry is equal to the geographic coordinate in the name of the received message for creating the forwarding table and the interface address is equal to k, step 205 is executed, otherwise step 206 is executed.
Step 205: the core router receiving the message for creating the forwarding table selects a forwarding table entry, the geographic coordinate of the forwarding table entry is equal to the geographic coordinate in the name of the received message for creating the forwarding table, and the interface address is equal to k, sets the life cycle of the forwarding table entry to the maximum value, and executes step 207.
Step 206: and the core router receiving the message for creating the forwarding table creates a forwarding table entry, the geographic coordinate of the forwarding table entry is equal to the geographic coordinate in the name of the received message for creating the forwarding table, the interface address is equal to k, and the life cycle is set to be the maximum value.
Step 207: the core router having received the message of creating the forwarding table forwards the received message of creating the forwarding table from all interfaces except interface k, and performs step 203.
Step 208: the proxy router that received the create forwarding table message discards the create forwarding table message.
Step 209: and (6) ending.
The above process can correctly establish the forwarding table to ensure that the mobile device can correctly acquire the data.
In the method of the invention, each agent router, data router or access node respectively maintains a data table, and each data table item is composed of a data domain, a name domain and a life cycle domain. Each agent router, data router or access node maintains an index table, and each index table item is composed of an interface address set domain, a name domain and a life cycle domain.
If the data C3 consists of the name NA3, a proxy router saves the data C3 by creating a data table entry in which the data value is data C3, the name field value is name NA3, and the lifetime is maximum. Meanwhile, the proxy router creates an index table entry, the interface address set of the index table entry is null, the name domain value is NA3, and the life cycle is maximum. The data router or access node then saves the data C3 by performing the following process:
step 301: and starting.
Step 302: the data router or access node creates a data table entry in which the data value is data C3, the name field value is name NA3, and the lifetime is maximum. Meanwhile, the data router or the access node creates an index table entry, the interface address set of the index table entry is null, the name domain value is NA3, and the life cycle is the maximum value. The data router or the access node sends a data request message through an upstream interface, in the data request message, the geographic coordinate of the name domain value is the geographic coordinate of the data router or the access node, the name ID is 0, the message type is 3, the identifier is 0, and the source interface address set is formed by the geographic coordinate of the data router or the access node. The destination interface address set is empty and the load is empty.
Step 303: it is determined whether the data request message is received by the router or the data router, and if the data request message is received by the proxy router, step 308 is performed, otherwise step 304 is performed.
Step 304: after receiving the data request message, the data router checks the index table, if there is an index table entry, the interface address set field value of the index table entry is equal to the source interface address set field value of the received data request message, and the name field value is equal to the name of the received data request message, then step 305 is executed, otherwise step 306 is executed.
Step 305: the data router receiving the data request message selects an index entry, the interface address set field value of the index entry is equal to the source interface address set field value of the received data request message, and the name field value is equal to the name of the received data request message, the life cycle of the forwarding entry is set to the maximum value, and step 307 is executed.
Step 306: and the data router receiving the data request message creates an index table entry, the interface address set domain value of the index table entry is equal to the source interface address set domain value of the received data request message, the name domain value is equal to the name of the received data request message, and the life cycle of the forwarding table entry is set to be the maximum value.
Step 307: the data router receiving the data request message adds its own geographical coordinates to the source interface address set of the received data request message, and the geographical coordinates are used as the first element of the source interface address set, forwards the received data request message from the upstream interface, and executes step 303.
Step 308: after receiving the data request message, the proxy router checks the index table, if an index table entry exists, the interface address set field value of the index table entry is equal to the source interface address set field value of the received data request message, and the name field value is equal to the name of the received data request message, then step 309 is executed, otherwise step 310 is executed.
Step 309: the proxy router receiving the data request message selects an index entry, the interface address set field value of the index entry is equal to the source interface address set field value of the received data request message, and the name field value is equal to the name of the received data request message, the life cycle of the forwarding entry is set to the maximum value, and step 311 is executed.
Step 310: the proxy router receiving the data request message creates an index table entry, the interface address set domain value of the index table entry is equal to the source interface address set domain value of the received data request message, the name domain value is equal to the name of the received data request message, and the life cycle of the forwarding table entry is set to be the maximum value.
Step 311: and (6) ending.
The above process can correctly save the data to ensure that the mobile device can correctly acquire the data.
In the method of the invention, if data C3 is uniquely identified by name NA3, name NA3 is composed of geographical coordinates (x3, y3) and name ID NID3, the length of data C3 is m3 bits, the maximum length of a message load is n bits, n and m3 are positive integers, m3 is greater than w1 x n, the data is divided into u3 data blocks and transmitted by u3 messages, as shown in formula (2), the length of the first u3-1 data blocks is n, and the length of the last data block is m3- (u3-1) x n.
Figure GDA0002881747940000061
Each data router, proxy router or access node maintains a request table, each request table including a name field and an interface address set field.
Under the condition that the mobile device MD3 is connected with the mobile router MR3, the mobile router MR3 is connected with the access node AP3, the access node AP3 is located in the data network DN1, and the proxy router of the data network DN1 is PR1, if at least one index entry exists in the proxy router PR1, the name field value of the index entry is NA3, the mobile device MD3 obtains the data C3 through the following processes:
step 401: and starting.
Step 402: the mobile device MD3 sends a data acquisition message, where the name of the data acquisition message is NA3, the message type is 4, the identifier is 0, the source interface address set and the destination interface address set are null, and the load is null. After receiving the data acquisition message from the downstream interface, the mobile router MR3 forwards the data acquisition message from the upstream interface.
Step 403: after the access node AP3 receives the data get message, it looks at the request table, if there is a request table entry whose name field value is equal to the name of the received data get message, then step 427 is performed, otherwise step 404 is performed.
Step 404: the access node AP3 creates a request entry with a name field value equal to the name of the received data fetch message and a set of interface addresses equal to the set of source interface addresses of the received data fetch message. The access node AP3 looks at the data table and if there is a data table entry with a name field value equal to the name of the received data acquisition message, then step 405 is performed, otherwise step 409 is performed.
Step 405: the access node AP3 divides the data C3 into u3 data blocks, sets a variable u1, and sets an initial value of the variable u1 to 0.
Step 406: the access node AP3 increments the variable u1 by 1 and performs step 407 if u1 is less than u3, otherwise performs step 408.
Step 407: the access node AP3 creates a data response message with a name field equal to the name of the received data response message, a message type of 5, an identification field of 1, a source interface address set and a destination interface address set of null, and a load of u1 data blocks, and performs step 406.
Step 408: the access node AP3 creates a data response message with a name field equal to the name of the received data response message, a message type of 5, an identification field of 0, a source interface address set and a destination interface address set of null, and a payload of u1 data block, and performs step 427.
Step 409: the access node AP3 adds its geographical coordinates to the source interface address set of the received data response message, and the geographical coordinates are the first element of the source interface address set, and forwards the received data response message from the upstream interface.
Step 410: if the proxy router receives the data response message, step 420 is performed, and if the data router or the access node receives the data response message, step 411 is performed.
Step 411: the data router or the access node checks the request table after receiving the data response message, if there is a request table entry whose name field value is equal to the name of the received data response message, step 427 is executed, otherwise, step 412 is executed.
Step 412: the data router or the access node receiving the data response message creates a request table entry, the name field value of the request table entry is equal to the name of the received data response message, and the interface address set is equal to the source interface address set of the received data response message. The data router or access node looks at the data table and if there is a data entry with a name field value equal to the name of the received data response message, step 416 is performed, otherwise step 413 is performed.
Step 413: the data router or access node that received the data response message looks at the index table, and if there is one, the name field value of the index table is equal to the name of the received data response message, then step 414 is executed, otherwise step 415 is executed.
Step 414: the data router or access node receiving the data response message selects an index table having a name field value equal to the name of the received data response message, updates the destination interface address set of the data response message to an interface address set field value of the index table, selects an interface having an interface address equal to the first element of the destination interface address set of the data response message, adds the first element of the destination interface address set of the data response message to the source interface address set of the data response message as the first element of the source interface address set, deletes the first element from the destination interface address set of the data response message, sends the data response message from the selected interface, and performs step 410.
Step 415: the data router or access node receiving the data response message adds its own geographical coordinates to the source interface address set of the data response message and serves as the first element of the source interface address set, and sends the data response message from the upstream interface, and step 410 is executed.
Step 416: the data router or the access node that receives the data response message divides the data C3 into u3 data blocks, sets a variable u1, and the initial value of the variable u1 is 0.
Step 417: the data router or access node receiving the data response message increments the variable u1 by 1 and performs step 418 if u1 is less than u3 and otherwise performs step 419.
Step 418: the data router or the access node that receives the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 1, the source interface address set is null, the destination interface address set is the source interface address set of the received data response message, and the load is the u1 th data block, and step 417 is executed.
Step 419: the data router or the access node receiving the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 0, the interface address set is null, the destination interface address set is the source interface address set of the received data response message, and the load is the u1 th data block, and step 427 is executed.
Step 420: after receiving the data response message, the proxy router checks the request table, if there is a request table entry whose name field value is equal to the name of the received data response message, then step 427 is executed, otherwise step 421 is executed.
Step 421: the proxy router receiving the data response message creates a request table entry, the name field value of the request table entry is equal to the name of the received data response message, and the interface address set is equal to the source interface address set of the received data response message. The proxy router looks at the data table and if there is a data entry with a name field value equal to the name of the received data response message, then step 423 is performed, otherwise step 422 is performed.
Step 422: the proxy router receiving the data response message selects an index table having a name field value equal to the name of the received data response message, updates the destination interface address set of the data response message to an interface address set field value of the index table, selects an interface having an interface address equal to the first element of the destination interface address set of the data response message, adds the first element of the destination interface address set of the data response message to the source interface address set of the data response message as the first element of the source interface address set, deletes the first element from the destination interface address set of the data response message, sends the data response message from the selected interface, and performs step 410.
Step 423: the proxy router having received the data response message divides the data C3 into u3 data blocks, sets a variable u1, and the initial value of the variable u1 is 0.
Step 424: the data router receiving the data response message increments the variable u1 by 1, executes step 425 if u1 is less than u3, otherwise executes step 426.
Step 425: the data router receiving the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 1, the source interface address set is empty, the destination interface address set is the source interface address set of the received data response message, and the load is the u1 th data block, and step 424 is executed.
Step 426: the data router receiving the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 0, the interface address set is empty, the destination interface address set is the source interface address set of the received data response message, and the load is the u1 th data block.
Step 427: the access node, the data router or the proxy router looks at the request table, selects all request table entries with the name domain value equal to the name of the data response message, and performs the following operations for each request table entry: updating the destination interface address set of the data response message to the interface address set of the request table entry, if the destination interface address set is empty, forwarding the data response message from a downstream interface, if the destination interface address set is not empty, selecting an interface, wherein the interface address of the interface is equal to the first element of the destination interface address set, deleting the first element from the destination interface address set, forwarding the data response message from the interface, if the identification domain value of the data response message is 0, deleting the request table entry, otherwise, keeping the request table entry. If the data response message destination interface address set field value is null, then step 428 is performed, otherwise step 427 is re-performed.
Step 428: after receiving the data response message, the mobile router MR3 forwards the data response message from the downstream interface. After receiving the data response message, mobile device MD3 saves the data in the data response message.
Step 429: and (6) ending.
In the above process, after the access node, the data router or the proxy router receives the message with the message type of 5, if the data in the message type is stored, the steps 301 to 311 are executed to create the index table.
The above process can ensure that the mobile device acquires the data correctly.
In the method of the present invention, under the condition that data C3 is identified by name NA3, mobile device MD4 is connected to mobile router MR4 through a link, mobile router MR4 is connected to access node AP4 through a link, access node AP4 is located in data network DN2, and the proxy router of data network DN2 is PR2, if the name field value of any index entry of proxy router PR2 is not equal to NA3, mobile device MD4 obtains data C3 through the following process:
step 501: and starting.
Step 502: the mobile device MD4 sends a data acquisition message, where the name of the data acquisition message is NA3, the message type is 4, the identifier is 0, the source interface address set and the destination interface address set are null, and the load is null. After receiving the data acquisition message from the downstream interface, the mobile router MR4 forwards the data acquisition message from the upstream interface.
Step 503: after the access node AP4 receives the data get message, it looks at the request table, if there is a request table entry whose name field value is equal to the name of the received data get message, then step 520 is executed, otherwise step 504 is executed.
Step 504: the access node AP4 creates a request entry with a name field value equal to the name of the received data fetch message and a set of interface addresses equal to the set of source interface addresses of the received data fetch message. The access node AP4 adds its geographical coordinates to the source interface address set of the received data acquisition message and forwards the received data acquisition message from the upstream interface as the first element of the source interface address set.
Step 505: and judging whether the proxy router or the data router receives the data acquisition message, if the proxy router receives the data acquisition message, executing the step 508, and if not, executing the step 506.
Step 506: after receiving the data acquisition message, the data router checks the request table, if a request table entry exists, and the name field value of the request table entry is equal to the name of the received data acquisition message, then step 520 is executed, otherwise step 507 is executed.
Step 507: the data router receiving the data acquisition message creates a request table entry, the name field value of the request table entry is equal to the name of the received data acquisition message, and the interface address set is equal to the source interface address set of the received data acquisition message. The data router adds its own geographical coordinates to the source interface address set of the received data acquisition message, and the geographical coordinates are used as the first element of the source interface address set, forwards the received data acquisition message from the upstream interface, and executes step 505.
Step 508: after receiving the data acquisition message, the proxy router checks the request table, if there is a request table entry whose name field value is equal to the name of the received data acquisition message, then step 520 is executed, otherwise step 509 is executed.
Step 509: the proxy router receiving the data acquisition message creates a request table entry, the name field value of the request table entry is equal to the name of the received data acquisition message, and the interface address set is equal to the source interface address set of the received data acquisition message. The proxy router adds the geographical coordinates of the proxy router to a source interface address set of the received data acquisition message, and forwards the received data acquisition message from an upstream interface by taking the geographical coordinates as a first element of the source interface address set.
Step 510: if the core router receives the data acquisition message, step 511 is performed, and if the proxy router, the data router or the access node receives the data acquisition message, step 513 is performed.
Step 511: after the core router receives the data acquisition message from an interface, the interface address of the interface is z1, the core router checks the request table, if there is a request table entry, the name field value of the request table entry is equal to the name of the received data acquisition message, step 520 is executed, otherwise step 512 is executed.
Step 512: the core router that received the data fetch message from interface z1 creates a request entry with a name field value equal to the name of the received data fetch message and a set of interface addresses equal to the source interface address set of the received data fetch message. The core router adds interface address z1 to the source interface address set of the received data acquisition message with the interface address as the first element of the source interface address set, selects a forwarding entry with a geographic coordinate field value equal to the geographic coordinate in the name of the received data acquisition message, forwards the data acquisition message from the interface identified by the interface address of the forwarding entry, and performs step 510.
Step 513: the proxy router, data router or access node looks at the request table and if there is a request table entry whose name field value is equal to the name of the received data acquisition message, step 520 is performed, otherwise step 514 is performed.
Step 514: the proxy router, the data router or the access node which receives the data acquisition message creates a request table entry, the name field value of the request table entry is equal to the name of the received data acquisition message, and the interface address set is equal to the source interface address set of the received data acquisition message. The proxy router, data router or access node looks at the data table and if there is a data table entry with a name field value equal to the name of the received data acquisition message, step 516 is performed, otherwise step 515 is performed.
Step 515: the proxy router, the data router or the access node that receives the data acquisition message selects an index table, the name field value of the index table is equal to the name of the received data acquisition message, the destination interface address set of the data acquisition message is updated to the interface address set field value of the index table, an interface is selected, the interface address of the interface is equal to the first element of the destination interface address set of the data acquisition message, the first element of the destination interface address set of the data acquisition message is added to the source interface address set of the data acquisition message and is used as the first element of the source interface address set, the first element is deleted from the destination interface address set of the data acquisition message, the data acquisition message is sent from the selected interface, and step 513 is executed.
Step 516: the proxy router, the data router, or the access node that receives the data acquisition message divides the data C3 into u3 data blocks, sets a variable u1, and sets an initial value of the variable u1 to 0.
517: the proxy router, data router or access node receiving the data acquisition message increments the variable u1 by 1, if u1 is less than u3, step 518 is performed, otherwise step 519 is performed.
Step 518: the proxy router, the data router or the access node which receives the data acquisition message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 1, the source interface address set is empty, the destination interface address set is the source interface address set of the received data response message, and the load is the u1 data block, and step 517 is executed.
Step 519: the proxy router, the data router or the access node which receives the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 0, the interface address set is empty, the destination interface address set is the source interface address set of the received data response message, and the load is the u1 data blocks.
Step 520: the access node, the data router, the proxy router or the core router looks up the request table, selects all request table entries with the name field value equal to the name of the data response message, and for each request table entry, the core router, the access node, the data router or the proxy router performs the following operations: updating the destination interface address set of the data response message to the interface address set of the request table entry, if the destination interface address set is empty, forwarding the data response message from a downstream interface, if the destination interface address set is not empty, selecting an interface, wherein the interface address of the interface is equal to the first element of the destination interface address set, deleting the first element from the destination interface address set, forwarding the data response message from the interface, if the identification domain value of the data response message is 0, deleting the request table entry, otherwise, keeping the request table entry. If the data response message destination interface address set field value is null, step 521 is executed, otherwise step 520 is executed again.
Step 521: after receiving the data response message, the mobile router MR4 forwards the data response message from the downstream interface. After receiving the data response message, mobile device MD4 saves the data in the data response message.
Step 522: and (6) ending.
In the above process, after the access node, the data router or the proxy router receives the message with the message type of 5, if the data in the message type is stored, the steps 301 to 311 are executed to create the index table.
The above process can ensure that the mobile device acquires the data correctly.
Has the advantages that: the invention provides an efficient new generation big data network implementation method, and each node in the big data network can rapidly acquire data through the network implementation method provided by the invention, thereby greatly improving the service performance. The invention can be applied to various fields such as traffic road condition detection and control, agricultural engineering and the like, and has wide application prospect.
Drawings
The foregoing and/or other advantages of the invention will become further apparent from the following detailed description of the invention when taken in conjunction with the accompanying drawings.
Fig. 1 is a schematic view of an address configuration process according to the present invention.
Fig. 2 is a schematic diagram of a process for establishing a forwarding table according to the present invention.
Fig. 3 is a schematic diagram of a data saving process according to the present invention.
Fig. 4 is a schematic diagram of a data communication process according to the present invention.
Fig. 5 is a schematic diagram of a data acquisition process according to the present invention.
The specific implementation mode is as follows:
the invention provides an efficient new generation big data network implementation method, and each node in the big data network can rapidly acquire data through the network implementation method provided by the invention, thereby greatly improving the service performance. The invention can be applied to various fields such as traffic road condition detection and control, agricultural engineering and the like, and has wide application prospect.
Fig. 1 is a schematic view of an address configuration process according to the present invention. The network includes a backbone network, a data network, and a mobile network. The backbone network comprises more than two core routers, the data network comprises a proxy router, a data router and an access node, and the mobile network comprises one mobile router and more than two mobile devices.
A core router contains X1 wired interfaces, X1 being a positive integer greater than 1. A proxy router comprises an upstream wired interface and X2 downstream wired interfaces, a data router comprises an upstream wired interface and X2 downstream wired interfaces, and X2 is a positive integer greater than 1. An access node includes an upstream wired interface and a downstream wireless interface, and a mobile router includes an upstream wireless interface and a downstream wireless interface. A mobile device includes a wireless interface.
The upstream interface of the proxy router is connected to an interface of the core router, and each downstream interface of the proxy router is connected to an upstream interface of a data router. The upstream interface of one data router is connected to the downstream interfaces of the proxy routers or data routers, and each downstream interface of a data router is connected to the upstream interfaces of other data routers or access nodes. The upstream interface of the access node is connected with the downstream interface of the data router, and the downstream interface of the access node is connected with the upstream interface link of the mobile router. The upstream interface of the mobile router is connected to a downstream interface link of an access node, and the downstream interface of the mobile router is connected to an interface link of the mobile device.
Each of the core routers, data routers, proxy routers, and access nodes have unique geographic coordinates.
Each interface of a core router is uniquely identified by an interface address, which is equal to j, and j takes values from 1 to X1.
The upstream interface and each downstream interface of a proxy router are uniquely identified by an interface address that includes a geographic abscissa and a geographic ordinate. A data network is uniquely identified by the interface address of the upstream interface of the proxy router of the network in which it resides.
The upstream interface and each downstream interface of a data router are uniquely identified by an interface address, the interface address is formed by geographic coordinates, and the geographic coordinates comprise a geographic horizontal coordinate and a geographic vertical coordinate. The upstream interface and the downstream interface of an access node are both uniquely identified by an interface address, which is formed by geographical coordinates. The upstream interface and the downstream interface of a mobile router are both uniquely identified by an interface address, which is composed of geographical coordinates.
One type of data is uniquely identified by a name, and one name is composed of geographical coordinates and a name ID. The mobile device communicates data through messages. A message is composed of a name field, a message type field, a source interface address set field, a destination interface address set field, an identification field and a load.
If one type of data has a length of m bits, a maximum length of a message payload is n bits, n and m are positive integers, m is greater than w1 × n, and w1 is a positive integer greater than 10, the data is divided into u data blocks and transmitted through u messages, as shown in equation (1). The first u-1 data blocks have a length of n, and the last data block has a length of m- (u-1) x n.
Figure GDA0002881747940000141
The message types are shown in the following table:
Figure GDA0002881747940000142
Figure GDA0002881747940000151
the identification field of a message is valid only if the message type is 5, which has a value of 0 or 1. If the identification field value is 0, it indicates that the message payload is the last data block of that type of data. If the identification field value is 1, the message load is indicated as other data blocks except the last data block in the type of data.
If the coordinates of the access node are (x1, y1), after the access node is started, the access node sets the interface address of the upstream interface of the access node to (x1, y1), the interface address of the downstream interface to (x1+ b1, y1+ b1), b1 is a non-zero integer, and the access node periodically performs the following interface address configuration operations:
step 101: start of
Step 102: the access node sends an address configuration message from the upstream interface, the geographic coordinate of the name domain value of the address configuration message is (x1, y1), the name ID is 0, the identifier is 0, the message type is 1, the source interface address set and the destination interface address set are both empty, and the load is empty.
Step 103: and judging whether the proxy router or the data router receives the address configuration message, if the proxy router receives the address configuration message, executing the step 105, and if not, executing the step 104.
Step 104: after receiving the address configuration message from the downstream interface, the data router sets the interface address of the downstream interface as the geographic coordinate in the name domain of the received address configuration message, and sets the interface address of the upstream interface as the geographic coordinate of the upstream interface. The data router sends an address configuration message from the upstream interface, the geographical coordinate of the name field value of the address configuration message is the geographical coordinate of the address configuration message, the name ID is 0, the identifier is 0, the message type is 1, the source interface address set and the destination interface address set are both empty, the load is empty, and step 103 is executed.
Step 105: after receiving the address configuration message from the downstream interface, the proxy router sets the interface address of the downstream interface as the geographic coordinate in the name domain of the received address configuration message, and sets the interface address of the upstream interface as the geographic coordinate of the proxy router.
Step 106: and (6) ending.
Fig. 2 is a schematic diagram of a process for establishing a forwarding table according to the present invention. A mobile router sets the interface address of its upstream interface to its own geographical coordinates (x2, y2), sets the interface address of its downstream interface to (x2+ b2, y2+ b2), and b2 is a non-zero integer. A mobile device sets the interface address of its interface to its geographical coordinates. Each core router maintains a forwarding table, each forwarding table entry including geographic coordinates, an interface address, and a lifetime. After the agent router configures the interface address, the following operations are executed to create a forwarding table:
step 201: start of
Step 202: the proxy router sends a message for creating a forwarding table from an upstream interface, the geographical coordinates of the name domain value of the message for creating the forwarding table are the geographical coordinates of the proxy router, the name ID is 0, the identifier is 0, the message type is 2, the source interface address set and the destination interface address set are both empty, and the load is empty.
Step 203: and judging whether the proxy router or the core router receives the message for creating the forwarding table, if the proxy router receives the message for creating the forwarding table, executing the step 208, and if not, executing the step 204.
Step 204: after the core router receives the message for creating the forwarding table from an interface, if the interface address of the interface is k, the core router checks the forwarding table, and if a forwarding table entry exists, the geographic coordinate of the forwarding table entry is equal to the geographic coordinate in the name of the received message for creating the forwarding table and the interface address is equal to k, step 205 is executed, otherwise step 206 is executed.
Step 205: the core router receiving the message for creating the forwarding table selects a forwarding table entry, the geographic coordinate of the forwarding table entry is equal to the geographic coordinate in the name of the received message for creating the forwarding table, and the interface address is equal to k, sets the life cycle of the forwarding table entry to the maximum value, and executes step 207.
Step 206: and the core router receiving the message for creating the forwarding table creates a forwarding table entry, the geographic coordinate of the forwarding table entry is equal to the geographic coordinate in the name of the received message for creating the forwarding table, the interface address is equal to k, and the life cycle is set to be the maximum value.
Step 207: the core router having received the message of creating the forwarding table forwards the received message of creating the forwarding table from all interfaces except interface k, and performs step 203.
Step 208: the proxy router that received the create forwarding table message discards the create forwarding table message.
Step 209: and (6) ending.
Fig. 3 is a schematic diagram of a data saving process according to the present invention. Each agent router, data router or access node maintains a data table, and each data table is composed of a data field, a name field and a life cycle field. Each agent router, data router or access node maintains an index table, and each index table item is composed of an interface address set domain, a name domain and a life cycle domain.
If the data C3 consists of the name NA3, a proxy router saves the data C3 by creating a data table entry in which the data value is data C3, the name field value is name NA3, and the lifetime is maximum. Meanwhile, the proxy router creates an index table entry, the interface address set of the index table entry is null, the name domain value is NA3, and the life cycle is maximum. The data router or access node then saves the data C3 by performing the following process:
step 301: and starting.
Step 302: the data router or access node creates a data table entry in which the data value is data C3, the name field value is name NA3, and the lifetime is maximum. Meanwhile, the data router or the access node creates an index table entry, the interface address set of the index table entry is null, the name domain value is NA3, and the life cycle is the maximum value. The data router or the access node sends a data request message through an upstream interface, in the data request message, the geographic coordinate of the name domain value is the geographic coordinate of the data router or the access node, the name ID is 0, the message type is 3, the identifier is 0, and the source interface address set is formed by the geographic coordinate of the data router or the access node. The destination interface address set is empty and the load is empty.
Step 303: and judging whether the data request message is received by the proxy router or the data router, if the data request message is received by the proxy router, executing the step 308, otherwise, executing the step 304.
Step 304: after receiving the data request message, the data router checks the index table, if there is an index table entry, the interface address set field value of the index table entry is equal to the source interface address set field value of the received data request message, and the name field value is equal to the name of the received data request message, then step 305 is executed, otherwise step 306 is executed.
Step 305: the data router receiving the data request message selects an index entry, the interface address set field value of the index entry is equal to the source interface address set field value of the received data request message, and the name field value is equal to the name of the received data request message, the life cycle of the forwarding entry is set to the maximum value, and step 307 is executed.
Step 306: and the data router receiving the data request message creates an index table entry, the interface address set domain value of the index table entry is equal to the source interface address set domain value of the received data request message, the name domain value is equal to the name of the received data request message, and the life cycle of the forwarding table entry is set to be the maximum value.
Step 307: the data router receiving the data request message adds its own geographical coordinates to the source interface address set of the received data request message, and the geographical coordinates are used as the first element of the source interface address set, forwards the received data request message from the upstream interface, and executes step 303.
Step 308: after receiving the data request message, the proxy router checks the index table, if an index table entry exists, the interface address set field value of the index table entry is equal to the source interface address set field value of the received data request message, and the name field value is equal to the name of the received data request message, then step 309 is executed, otherwise step 310 is executed.
Step 309: the proxy router receiving the data request message selects an index entry, the interface address set field value of the index entry is equal to the source interface address set field value of the received data request message, and the name field value is equal to the name of the received data request message, the life cycle of the forwarding entry is set to the maximum value, and step 311 is executed.
Step 310: the proxy router receiving the data request message creates an index table entry, the interface address set domain value of the index table entry is equal to the source interface address set domain value of the received data request message, the name domain value is equal to the name of the received data request message, and the life cycle of the forwarding table entry is set to be the maximum value.
Step 311: and (6) ending.
Fig. 4 is a schematic diagram of a data communication process according to the present invention. If the data C3 is uniquely identified by a name NA3, the name NA3 is composed of geographical coordinates (x3, y3) and a name ID NID3, the length of the data C3 is m3 bits, the maximum length of one message payload is n bits, n and m3 are positive integers, and m3 is greater than w1 × n, the data is divided into u3 data blocks and transmitted through u3 messages, as shown in formula (2), the first u3-1 data blocks are n, and the last data block is m3- (u3-1) × n.
Figure GDA0002881747940000171
Each data router, proxy router or access node maintains a request table, each request table including a name field and an interface address set field.
Under the condition that the mobile device MD3 is connected with the mobile router MR3, the mobile router MR3 is connected with the access node AP3, the access node AP3 is located in the data network DN1, and the proxy router of the data network DN1 is PR1, if at least one index entry exists in the proxy router PR1, the name field value of the index entry is NA3, the mobile device MD3 obtains the data C3 through the following processes:
step 401: and starting.
Step 402: the mobile device MD3 sends a data acquisition message, where the name of the data acquisition message is NA3, the message type is 4, the identifier is 0, the source interface address set and the destination interface address set are null, and the load is null. After receiving the data acquisition message from the downstream interface, the mobile router MR3 forwards the data acquisition message from the upstream interface.
Step 403: after the access node AP3 receives the data get message, it looks at the request table, if there is a request table entry whose name field value is equal to the name of the received data get message, then step 427 is performed, otherwise step 404 is performed.
Step 404: the access node AP3 creates a request entry with a name field value equal to the name of the received data fetch message and a set of interface addresses equal to the set of source interface addresses of the received data fetch message. The access node AP3 looks at the data table and if there is a data table entry with a name field value equal to the name of the received data acquisition message, then step 405 is performed, otherwise step 409 is performed.
Step 405: the access node AP3 divides the data C3 into u3 data blocks, sets a variable u1, and sets an initial value of the variable u1 to 0.
Step 406: the access node AP3 increments the variable u1 by 1 and performs step 407 if u1 is less than u3, otherwise performs step 408.
Step 407: the access node AP3 creates a data response message with a name field equal to the name of the received data response message, a message type of 5, an identification field of 1, a source interface address set and a destination interface address set of null, and a load of u1 data blocks, and performs step 406.
Step 408: the access node AP3 creates a data response message with a name field equal to the name of the received data response message, a message type of 5, an identification field of 0, a source interface address set and a destination interface address set of null, and a payload of u1 data block, and performs step 427.
Step 409: the access node AP3 adds its geographical coordinates to the source interface address set of the received data response message, and the geographical coordinates are the first element of the source interface address set, and forwards the received data response message from the upstream interface.
Step 410: if the proxy router receives the data response message, step 420 is performed, and if the data router or the access node receives the data response message, step 411 is performed.
Step 411: the data router or the access node checks the request table after receiving the data response message, if there is a request table entry whose name field value is equal to the name of the received data response message, step 427 is executed, otherwise, step 412 is executed.
Step 412: the data router or the access node receiving the data response message creates a request table entry, the name field value of the request table entry is equal to the name of the received data response message, and the interface address set is equal to the source interface address set of the received data response message. The data router or access node looks at the data table and if there is a data entry with a name field value equal to the name of the received data response message, step 416 is performed, otherwise step 413 is performed.
Step 413: the data router or access node that received the data response message looks at the index table, and if there is one, the name field value of the index table is equal to the name of the received data response message, then step 414 is executed, otherwise step 415 is executed.
Step 414: the data router or access node receiving the data response message selects an index table having a name field value equal to the name of the received data response message, updates the destination interface address set of the data response message to an interface address set field value of the index table, selects an interface having an interface address equal to the first element of the destination interface address set of the data response message, adds the first element of the destination interface address set of the data response message to the source interface address set of the data response message as the first element of the source interface address set, deletes the first element from the destination interface address set of the data response message, sends the data response message from the selected interface, and performs step 410.
Step 415: the data router or access node receiving the data response message adds its own geographical coordinates to the source interface address set of the data response message and serves as the first element of the source interface address set, and sends the data response message from the upstream interface, and step 410 is executed.
Step 416: the data router or the access node that receives the data response message divides the data C3 into u3 data blocks, sets a variable u1, and the initial value of the variable u1 is 0.
Step 417: the data router or access node receiving the data response message increments the variable u1 by 1 and performs step 418 if u1 is less than u3 and otherwise performs step 419.
Step 418: the data router or the access node that receives the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 1, the source interface address set is null, the destination interface address set is the source interface address set of the received data response message, and the load is the u1 th data block, and step 417 is executed.
Step 419: the data router or the access node receiving the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 0, the interface address set is null, the destination interface address set is the source interface address set of the received data response message, and the load is the u1 th data block, and step 427 is executed.
Step 420: after receiving the data response message, the proxy router checks the request table, if there is a request table entry whose name field value is equal to the name of the received data response message, then step 427 is executed, otherwise step 421 is executed.
Step 421: the proxy router receiving the data response message creates a request table entry, the name field value of the request table entry is equal to the name of the received data response message, and the interface address set is equal to the source interface address set of the received data response message. The proxy router looks at the data table and if there is a data entry with a name field value equal to the name of the received data response message, then step 423 is performed, otherwise step 422 is performed.
Step 422: the proxy router receiving the data response message selects an index table having a name field value equal to the name of the received data response message, updates the destination interface address set of the data response message to an interface address set field value of the index table, selects an interface having an interface address equal to the first element of the destination interface address set of the data response message, adds the first element of the destination interface address set of the data response message to the source interface address set of the data response message as the first element of the source interface address set, deletes the first element from the destination interface address set of the data response message, sends the data response message from the selected interface, and performs step 410.
Step 423: the proxy router having received the data response message divides the data C3 into u3 data blocks, sets a variable u1, and the initial value of the variable u1 is 0.
Step 424: the data router receiving the data response message increments the variable u1 by 1, executes step 425 if u1 is less than u3, otherwise executes step 426.
Step 425: the data router receiving the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 1, the source interface address set is empty, the destination interface address set is the source interface address set of the received data response message, and the load is the u1 th data block, and step 424 is executed.
Step 426: the data router receiving the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 0, the interface address set is empty, the destination interface address set is the source interface address set of the received data response message, and the load is the u1 th data block.
Step 427: the access node, the data router or the proxy router looks at the request table, selects all request table entries with the name domain value equal to the name of the data response message, and performs the following operations for each request table entry: updating the destination interface address set of the data response message to the interface address set of the request table entry, if the destination interface address set is empty, forwarding the data response message from a downstream interface, if the destination interface address set is not empty, selecting an interface, wherein the interface address of the interface is equal to the first element of the destination interface address set, deleting the first element from the destination interface address set, forwarding the data response message from the interface, if the identification domain value of the data response message is 0, deleting the request table entry, otherwise, keeping the request table entry. If the data response message destination interface address set field value is null, then step 428 is performed, otherwise step 427 is re-performed.
Step 428: after receiving the data response message, the mobile router MR3 forwards the data response message from the downstream interface. After receiving the data response message, mobile device MD3 saves the data in the data response message.
Step 429: and (6) ending.
In the above process, after the access node, the data router or the proxy router receives the message with the message type of 5, if the data in the message type is stored, the steps 301 to 311 are executed to create the index table.
Fig. 5 is a schematic diagram of a data acquisition process according to the present invention. Under the condition that the data C3 is identified by a name NA3, the mobile device MD4 is link-connected with the mobile router MR4, the mobile router MR4 is link-connected with the access node AP4, the access node AP4 is located in the data network DN2, and the proxy router of the data network DN2 is PR2, if the name domain value of any index entry of the proxy router PR2 is not equal to the name NA3, the mobile device MD4 obtains the data C3 by the following process:
step 501: and starting.
Step 502: the mobile device MD4 sends a data acquisition message, where the name of the data acquisition message is NA3, the message type is 4, the identifier is 0, the source interface address set and the destination interface address set are null, and the load is null. After receiving the data acquisition message from the downstream interface, the mobile router MR4 forwards the data acquisition message from the upstream interface.
Step 503: after the access node AP4 receives the data get message, it looks at the request table, if there is a request table entry whose name field value is equal to the name of the received data get message, then step 520 is executed, otherwise step 504 is executed.
Step 504: the access node AP4 creates a request entry with a name field value equal to the name of the received data fetch message and a set of interface addresses equal to the set of source interface addresses of the received data fetch message. The access node AP4 adds its geographical coordinates to the source interface address set of the received data acquisition message and forwards the received data acquisition message from the upstream interface as the first element of the source interface address set.
Step 505: and judging whether the proxy router or the data router receives the data acquisition message, if the proxy router receives the data acquisition message, executing the step 508, and if not, executing the step 506.
Step 506: after receiving the data acquisition message, the data router checks the request table, if a request table entry exists, and the name field value of the request table entry is equal to the name of the received data acquisition message, then step 520 is executed, otherwise step 507 is executed.
Step 507: the data router receiving the data acquisition message creates a request table entry, the name field value of the request table entry is equal to the name of the received data acquisition message, and the interface address set is equal to the source interface address set of the received data acquisition message. The data router adds its own geographical coordinates to the source interface address set of the received data acquisition message, and the geographical coordinates are used as the first element of the source interface address set, forwards the received data acquisition message from the upstream interface, and executes step 505.
Step 508: after receiving the data acquisition message, the proxy router checks the request table, if there is a request table entry whose name field value is equal to the name of the received data acquisition message, then step 520 is executed, otherwise step 509 is executed.
Step 509: the proxy router receiving the data acquisition message creates a request table entry, the name field value of the request table entry is equal to the name of the received data acquisition message, and the interface address set is equal to the source interface address set of the received data acquisition message. The proxy router adds the geographical coordinates of the proxy router to a source interface address set of the received data acquisition message, and forwards the received data acquisition message from an upstream interface by taking the geographical coordinates as a first element of the source interface address set.
Step 510: if the core router receives the data acquisition message, step 511 is performed, and if the proxy router, the data router or the access node receives the data acquisition message, step 513 is performed.
Step 511: after the core router receives the data acquisition message from an interface, the interface address of the interface is z1, the core router checks the request table, if there is a request table entry, the name field value of the request table entry is equal to the name of the received data acquisition message, step 520 is executed, otherwise step 512 is executed.
Step 512: the core router that received the data fetch message from interface z1 creates a request entry with a name field value equal to the name of the received data fetch message and a set of interface addresses equal to the source interface address set of the received data fetch message. The core router adds interface address z1 to the source interface address set of the received data acquisition message with the interface address as the first element of the source interface address set, selects a forwarding entry with a geographic coordinate field value equal to the geographic coordinate in the name of the received data acquisition message, forwards the data acquisition message from the interface identified by the interface address of the forwarding entry, and performs step 510.
Step 513: the proxy router, data router or access node looks at the request table and if there is a request table entry whose name field value is equal to the name of the received data acquisition message, step 520 is performed, otherwise step 514 is performed.
Step 514: the proxy router, the data router or the access node which receives the data acquisition message creates a request table entry, the name field value of the request table entry is equal to the name of the received data acquisition message, and the interface address set is equal to the source interface address set of the received data acquisition message. The proxy router, data router or access node looks at the data table and if there is a data table entry with a name field value equal to the name of the received data acquisition message, step 516 is performed, otherwise step 515 is performed.
Step 515: the proxy router, the data router or the access node that receives the data acquisition message selects an index table, the name field value of the index table is equal to the name of the received data acquisition message, the destination interface address set of the data acquisition message is updated to the interface address set field value of the index table, an interface is selected, the interface address of the interface is equal to the first element of the destination interface address set of the data acquisition message, the first element of the destination interface address set of the data acquisition message is added to the source interface address set of the data acquisition message and is used as the first element of the source interface address set, the first element is deleted from the destination interface address set of the data acquisition message, the data acquisition message is sent from the selected interface, and step 513 is executed.
Step 516: the proxy router, the data router, or the access node that receives the data acquisition message divides the data C3 into u3 data blocks, sets a variable u1, and sets an initial value of the variable u1 to 0.
517: the proxy router, data router or access node receiving the data acquisition message increments the variable u1 by 1, if u1 is less than u3, step 518 is performed, otherwise step 519 is performed.
Step 518: the proxy router, the data router or the access node which receives the data acquisition message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 1, the source interface address set is empty, the destination interface address set is the source interface address set of the received data response message, and the load is the u1 data block, and step 517 is executed.
Step 519: the proxy router, the data router or the access node which receives the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 0, the interface address set is empty, the destination interface address set is the source interface address set of the received data response message, and the load is the u1 data blocks.
Step 520: the access node, the data router, the proxy router or the core router looks up the request table, selects all request table entries with the name field value equal to the name of the data response message, and for each request table entry, the core router, the access node, the data router or the proxy router performs the following operations: updating the destination interface address set of the data response message to the interface address set of the request table entry, if the destination interface address set is empty, forwarding the data response message from a downstream interface, if the destination interface address set is not empty, selecting an interface, wherein the interface address of the interface is equal to the first element of the destination interface address set, deleting the first element from the destination interface address set, forwarding the data response message from the interface, if the identification domain value of the data response message is 0, deleting the request table entry, otherwise, keeping the request table entry. If the data response message destination interface address set field value is null, step 521 is executed, otherwise step 520 is executed again.
Step 521: after receiving the data response message, the mobile router MR4 forwards the data response message from the downstream interface. After receiving the data response message, mobile device MD4 saves the data in the data response message.
Step 522: and (6) ending.
In the above process, after the access node, the data router or the proxy router receives the message with the message type of 5, if the data in the message type is stored, the steps 301 to 311 are executed to create the index table.
Example 1
Based on the simulation parameters in table 1, this embodiment simulates an efficient new-generation big data network implementation method in the present invention, and the performance analysis is as follows: when the amount of transmission data increases, the delay of data transmission increases, and when the amount of data transmission decreases, the delay of data transmission decreases, and the average delay of data acquisition is 2.5 s.
TABLE 1 simulation parameters
Figure GDA0002881747940000231
The present invention provides an efficient new generation big data network implementation method, and the method and the way for implementing the technical solution are many, the above description is only a preferred embodiment of the present invention, it should be noted that, for those skilled in the art, without departing from the principle of the present invention, several improvements and modifications may be made, and these improvements and modifications should also be regarded as the protection scope of the present invention. The components not specified in this embodiment can be implemented by the prior art.

Claims (5)

1.一种高效的新一代大数据网络实现方法,其特征在于,所述网络包括骨干网络、数据网络和移动网络;骨干网络包括两个以上的核心路由器,数据网络包括代理路由器、数据路由器和接入节点,移动网络包括一个移动路由器和两个以上的移动设备;1. an efficient new generation big data network implementation method is characterized in that, described network comprises backbone network, data network and mobile network; Backbone network comprises more than two core routers, and data network comprises proxy router, data router and Access node, the mobile network includes a mobile router and more than two mobile devices; 一个核心路由器包含X1个有线接口,X1为大于1的正整数;一个代理路由器包括一个上游有线接口和X2个下游有线接口,一个数据路由器包括一个上游有线接口和X2个下游有线接口,X2为大于1的正整数;一个接入节点包括一个上游有线接口和一个下游无线接口,一个移动路由器包括一个上游无线接口和一个下游无线接口;一个移动设备包括一个无线接口;A core router includes X1 wired interfaces, where X1 is a positive integer greater than 1; a proxy router includes an upstream wired interface and X2 downstream wired interfaces, and a data router includes an upstream wired interface and X2 downstream wired interfaces, where X2 is greater than A positive integer of 1; an access node includes an upstream wired interface and a downstream wireless interface, a mobile router includes an upstream wireless interface and a downstream wireless interface; a mobile device includes a wireless interface; 代理路由器的上游接口与核心路由器的一个接口相连,代理路由器的每个下游接口与一个数据路由器的上游接口相连;一个数据路由器的上游接口与代理路由器或者数据路由器的下游接口相连,数据路由器的每个下游接口与其他数据路由器或者接入节点的上游接口相连;接入节点的上游接口与数据路由器的下游接口相连,接入节点的下游接口与移动路由器的上游接口链路相连;移动路由器的上游接口与一个接入节点的下游接口链路相连,移动路由器的下游接口与移动设备的接口链路相连;The upstream interface of the proxy router is connected to an interface of the core router, each downstream interface of the proxy router is connected to the upstream interface of a data router; the upstream interface of a data router is connected to the downstream interface of the proxy router or the data router, and each downstream interface of the data router is connected to the downstream interface of the proxy router or the data router. Each downstream interface is connected to the upstream interface of other data routers or access nodes; the upstream interface of the access node is connected to the downstream interface of the data router, and the downstream interface of the access node is connected to the upstream interface link of the mobile router; the upstream interface of the mobile router The interface is connected to the downstream interface link of an access node, and the downstream interface of the mobile router is connected to the interface link of the mobile device; 每个核心路由器、数据路由器、代理路由器和接入节点都具有唯一的地理坐标;Each core router, data router, proxy router and access node has unique geographic coordinates; 一个核心路由器的每个接口由一个接口地址唯一标识,该接口地址等于j,j取值1~X1;Each interface of a core router is uniquely identified by an interface address, the interface address is equal to j, and j ranges from 1 to X1; 一个代理路由器的上游接口和每个下游接口由一个接口地址唯一标识,该接口地址包括地理横坐标和地理纵坐标;一个数据网络由所在网络的代理路由器的上游接口的接口地址唯一标识;The upstream interface of a proxy router and each downstream interface are uniquely identified by an interface address, and the interface address includes geographic abscissa and geographic ordinate; a data network is uniquely identified by the interface address of the upstream interface of the proxy router in the network; 一个数据路由器的上游接口和每个下游接口均由一个接口地址唯一标识,该接口地址由地理坐标构成,地理坐标包括地理横坐标和地理纵坐标;一个接入节点的上游接口和下游接口均由一个接口地址唯一标识,该接口地址由地理坐标构成;一个移动路由器的上游接口和下游接口均由一个接口地址唯一标识,该接口地址由地理坐标构成;The upstream interface and each downstream interface of a data router are uniquely identified by an interface address, which consists of geographic coordinates, which include geographic abscissas and geographic ordinates; the upstream and downstream interfaces of an access node are both represented by An interface address is uniquely identified, and the interface address is composed of geographic coordinates; both the upstream interface and the downstream interface of a mobile router are uniquely identified by an interface address, and the interface address is composed of geographic coordinates; 一种数据由一个名称唯一标识,一个名称由地理坐标和名称ID构成;移动设备通过消息实现数据通信;一个消息由名称域、消息类型域、源接口地址集合域、目的接口地址集合域、标识域和负载构成;A data is uniquely identified by a name, and a name is composed of geographic coordinates and a name ID; the mobile device realizes data communication through messages; a message is composed of a name field, a message type field, a source interface address collection field, a destination interface address collection field, and an identifier. Domain and payload composition; 如果一种类型的数据长度为m比特,一个消息负载的最大长度为n比特,n和m为正整数,m大于w1×n,w1为大于10的正整数,则该数据被分为u个数据块并通过u个消息来传输,如公式(1)所示;前u-1个数据块的长度为n,最后一个数据块的长度为m-(u-1)×n;If the length of a type of data is m bits, the maximum length of a message payload is n bits, n and m are positive integers, m is greater than w1×n, and w1 is a positive integer greater than 10, then the data is divided into u pieces The data blocks are transmitted through u messages, as shown in formula (1); the length of the first u-1 data blocks is n, and the length of the last data block is m-(u-1)×n;
Figure FDA0002881747930000021
Figure FDA0002881747930000021
消息类型如下表所示:The message types are shown in the following table: 消息类型值message type value 消息名称message name 11 地址配置消息address configuration message 22 创建转发表消息Create a forwarding table message 33 数据请求消息data request message 44 数据获取消息data acquisition message 55 数据响应消息data response message
一个消息的标识域只有在消息类型为5的时候有效,其值为0或者1;如果标识域值为0,则表明消息负载为该种类型数据的最后一个数据块;如果标识域值为1,则表明消息负载为该种类型数据中除了最后一个数据块的其他数据块;The identification field of a message is only valid when the message type is 5, and its value is 0 or 1; if the value of the identification field is 0, it indicates that the message payload is the last data block of this type of data; if the value of the identification field is 1 , it indicates that the message payload is other data blocks except the last data block in this type of data; 如果接入节点的坐标为(x1,y1),该接入节点启动后,它将自己的上游接口的接口地址设置为(x1,y1),下游接口的接口地址设置为(x1+b1,y1+b1),b1为一个非零整数,接入节点定期执行下述接口地址配置操作:If the coordinates of the access node are (x1, y1), after the access node is started, it sets the interface address of its upstream interface to (x1, y1) and the interface address of the downstream interface to (x1+b1, y1) +b1), b1 is a non-zero integer, the access node periodically performs the following interface address configuration operations: 步骤101:开始;Step 101: start; 步骤102:接入节点从上游接口发送一个地址配置消息,该地址配置消息的名称域值的地理坐标为(x1,y1),名称ID为0,标识为0,消息类型为1,源接口地址集合和目的接口地址集合均为空,负载为空;Step 102: The access node sends an address configuration message from the upstream interface, the geographic coordinates of the name field value of the address configuration message are (x1, y1), the name ID is 0, the identifier is 0, the message type is 1, and the source interface address is The set and destination interface address set are both empty, and the payload is empty; 步骤103:判断是代理路由器还是数据路由器接收到该地址配置消息,如果代理路由器接收到该地址配置消息,则执行步骤105,否则执行步骤104;Step 103: Determine whether the proxy router or the data router has received the address configuration message, if the proxy router receives the address configuration message, execute step 105, otherwise execute step 104; 步骤104:数据路由器从下游接口接收到该地址配置消息后,将该下游接口的接口地址设置为接收到的地址配置消息的名称域中的地理坐标,将自己的上游接口的接口地址设置为自己的地理坐标;该数据路由器从上游接口发送一个地址配置消息,该地址配置消息的名称域值的地理坐标为自己的地理坐标,名称ID为0,标识为0,消息类型为1,源接口地址集合和目的接口地址集合均为空,负载为空,执行步骤103;Step 104: After receiving the address configuration message from the downstream interface, the data router sets the interface address of the downstream interface to the geographic coordinates in the name field of the received address configuration message, and sets the interface address of its own upstream interface to its own The data router sends an address configuration message from the upstream interface, the geographic coordinates of the name field value of the address configuration message are its own geographic coordinates, the name ID is 0, the identifier is 0, the message type is 1, and the source interface address The set and the destination interface address set are both empty, and the payload is empty, and step 103 is executed; 步骤105:代理路由器从下游接口接收到该地址配置消息后,将该下游接口的接口地址设置为接收到的地址配置消息的名称域中的地理坐标,将自己的上游接口的接口地址设置为自己的地理坐标;Step 105: After receiving the address configuration message from the downstream interface, the proxy router sets the interface address of the downstream interface to the geographic coordinates in the name field of the received address configuration message, and sets the interface address of its own upstream interface to its own the geographic coordinates; 步骤106:结束。Step 106: End.
2.根据权利要求1所述的一种高效的新一代大数据网络实现方法,其特征在于,一个移动路由器将自己上游接口的接口地址设置为自己的地理坐标(x2,y2),将下游接口的接口地址设置为(x2+b2,y2+b2),b2为非零整数;一个移动设备将自己接口的接口地址设置为自己的地理坐标;每个核心路由器维护一个转发表,每个转发表项包括地理坐标,接口地址和生命周期;代理路由器配置接口地址后,执行下述操作创建转发表:2. a kind of efficient new generation big data network realization method according to claim 1 is characterized in that, a mobile router sets the interface address of its upstream interface as its own geographic coordinates (x2, y2), and the downstream interface The interface address is set to (x2+b2, y2+b2), b2 is a non-zero integer; a mobile device sets the interface address of its own interface to its own geographic coordinates; each core router maintains a forwarding table, each forwarding table Items include geographic coordinates, interface address and life cycle; after the proxy router configures the interface address, perform the following operations to create a forwarding table: 步骤201:开始;Step 201: start; 步骤202:代理路由器从上游接口发送一个创建转发表消息,该创建转发表消息的名称域值的地理坐标为该代理路由器的地理坐标,名称ID为0,标识为0,消息类型为2,源接口地址集合和目的接口地址集合均为空,负载为空;Step 202: The proxy router sends a forwarding table creation message from the upstream interface, the geographic coordinates of the name field value of the forwarding table creation message are the geographic coordinates of the proxy router, the name ID is 0, the identifier is 0, the message type is 2, the source The interface address set and destination interface address set are both empty, and the payload is empty; 步骤203:判断是代理路由器还是核心路由器接收到该创建转发表消息,如果代理路由器接收到该创建转发表消息,则执行步骤208,否则执行步骤204;Step 203: Determine whether the proxy router or the core router receives the create forwarding table message, if the proxy router receives the create forwarding table message, execute step 208, otherwise execute step 204; 步骤204:核心路由器从一个接口接收到该创建转发表消息后,如果该接口的接口地址为k,核心路由器查看转发表,如果存在一个转发表项,该转发表项的地理坐标等于接收到的创建转发表消息名称中的地理坐标且接口地址等于k,则执行步骤205,否则执行步骤206;Step 204: After the core router receives the message of creating a forwarding table from an interface, if the interface address of the interface is k, the core router checks the forwarding table. If there is a forwarding table entry, the geographic coordinates of the forwarding table entry are equal to the received message. Create the geographic coordinates in the message name of the forwarding table and the interface address is equal to k, then go to step 205, otherwise go to step 206; 步骤205:接收到该创建转发表消息的核心路由器选择一个转发表项,该转发表项的地理坐标等于接收到的创建转发表消息名称中的地理坐标且接口地址等于k,将该转发表项的生命周期设置为最大值,执行步骤207;Step 205: The core router that has received the message of creating a forwarding table selects a forwarding table entry, the geographic coordinates of the forwarding table entry are equal to the geographic coordinates in the name of the received message of creating a forwarding table and the interface address is equal to k, and the forwarding table entry is The life cycle is set to the maximum value, and step 207 is executed; 步骤206:接收到该创建转发表消息的核心路由器创建一个转发表项,该转发表项的地理坐标等于接收到的创建转发表消息名称中的地理坐标,接口地址等于k,生命周期设置为最大值;Step 206: The core router that receives the message of creating a forwarding table creates a forwarding table entry, the geographic coordinates of the forwarding table entry are equal to the geographic coordinates in the name of the received message of creating a forwarding table, the interface address is equal to k, and the life cycle is set to the maximum value. value; 步骤207:接收到该创建转发表消息的核心路由器从除了接口k以外的所有接口转发接收到的创建转发表消息,执行步骤203;Step 207: the core router that received the forwarding table creation message forwards the received forwarding table creation message from all interfaces except interface k, and executes step 203; 步骤208:接收到该创建转发表消息的代理路由器丢弃该创建转发表消息;Step 208: The proxy router that receives the message of creating a forwarding table discards the message of creating a forwarding table; 步骤209:结束。Step 209: End. 3.根据权利要求2所述的一种高效的新一代大数据网络实现方法,其特征在于,每个代理路由器、数据路由器或者接入节点各自维护一个数据表,每个数据表项由数据域,名称域和生命周期域构成;每个代理路由器、数据路由器或者接入节点各自维护一个索引表,每个索引表项由接口地址集合域,名称域和生命周期域构成;3. a kind of efficient new generation big data network realization method according to claim 2 is characterized in that, each proxy router, data router or access node maintains a data table respectively, and each data table item is determined by the data field. , the name field and the life cycle field; each proxy router, data router or access node maintains an index table, and each index table entry is composed of the interface address set field, the name field and the life cycle field; 如果数据C3由名称NA3构成,一个代理路由器通过创建一个数据表项来保存数据C3,在该数据表项中,数据值为数据C3,名称域值为名称NA3,生命周期为最大值;同时,该代理路由器创建一个索引表项,该索引表项的接口地址集合为空,名称域值为NA3,生命周期为最大值;则数据路由器或者接入节点则通过执行下述过程保存数据C3:If the data C3 consists of the name NA3, a proxy router saves the data C3 by creating a data table entry, in which the data value is the data C3, the name field value is the name NA3, and the lifetime is the maximum value; at the same time, The proxy router creates an index entry, the interface address set of the index entry is empty, the name field value is NA3, and the life cycle is the maximum value; then the data router or access node saves the data C3 by executing the following process: 步骤301:开始;Step 301: start; 步骤302:该数据路由器或者接入节点创建一个数据表项,在该数据表项中,数据值为数据C3,名称域值为名称NA3,生命周期为最大值;同时,该数据路由器或者接入节点创建一个索引表项,该索引表项的接口地址集合为空,名称域值为NA3,生命周期为最大值;该数据路由器或者接入节点通过上游接口发送一个数据请求消息,该数据请求消息中,名称域值的地理坐标为该数据路由器或者接入节点的地理坐标,名称ID为0,消息类型为3,标识为0,源接口地址集合由该数据路由器或者接入节点的地理坐标构成;目的接口地址集合为空,负载为空;Step 302: The data router or access node creates a data entry, in which the data value is data C3, the name field value is name NA3, and the life cycle is the maximum value; at the same time, the data router or access The node creates an index entry, the interface address set of the index entry is empty, the name field value is NA3, and the life cycle is the maximum value; the data router or access node sends a data request message through the upstream interface, the data request message , the geographic coordinates of the name field value are the geographic coordinates of the data router or access node, the name ID is 0, the message type is 3, the identifier is 0, and the source interface address set is composed of the geographic coordinates of the data router or access node. ;The destination interface address set is empty, and the payload is empty; 步骤303:判断是代理路由器还是数据路由器接收到该数据请求消息,如果代理路由器接收到该数据请求消息,则执行步骤308,否则执行步骤304;Step 303: Determine whether the proxy router or the data router receives the data request message, if the proxy router receives the data request message, then execute step 308, otherwise, execute step 304; 步骤304:数据路由器接收到该数据请求消息后,查看索引表,如果存在一个索引表项,该索引表项的接口地址集合域值等于接收到的数据请求消息的源接口地址集合域值,名称域值等于接收到的数据请求消息的名称,则执行步骤305,否则执行步骤306;Step 304: After receiving the data request message, the data router checks the index table. If there is an index entry, the interface address set field value of the index entry is equal to the source interface address set field value of the received data request message, and the name If the field value is equal to the name of the received data request message, then go to step 305, otherwise go to step 306; 步骤305:接收到该数据请求消息的数据路由器选择一个索引表项,该索引表项的接口地址集合域值等于接收到的数据请求消息的源接口地址集合域值,且名称域值等于接收到的数据请求消息的名称,将该转发表项的生命周期设置为最大值,执行步骤307;Step 305: The data router that received the data request message selects an index entry, the interface address set field value of the index entry is equal to the source interface address set field value of the received data request message, and the name field value is equal to the received data request message. The name of the data request message, set the life cycle of the forwarding entry to the maximum value, and execute step 307; 步骤306:接收到该数据请求消息的数据路由器创建一个索引表项,该索引表项的接口地址集合域值等于接收到的数据请求消息的源接口地址集合域值,名称域值等于接收到的数据请求消息的名称,将该转发表项的生命周期设置为最大值;Step 306: The data router that received the data request message creates an index entry, the interface address set field value of the index entry is equal to the source interface address set field value of the received data request message, and the name field value is equal to the received data request message. The name of the data request message, and the life cycle of the forwarding entry is set to the maximum value; 步骤307:接收到该数据请求消息的数据路由器将自己的地理坐标加入到接收到的数据请求消息的源接口地址集合中且该地理坐标作为源接口地址集合的第一个元素,从上游接口转发接收到的数据请求消息,执行步骤303;Step 307: The data router that has received the data request message adds its own geographic coordinates to the source interface address set of the received data request message, and the geographic coordinates are used as the first element of the source interface address set, and forwarded from the upstream interface The received data request message, go to step 303; 步骤308:代理路由器接收到该数据请求消息后,查看索引表,如果存在一个索引表项,该索引表项的接口地址集合域值等于接收到的数据请求消息的源接口地址集合域值,名称域值等于接收到的数据请求消息的名称,则执行步骤309,否则执行步骤310;Step 308: After receiving the data request message, the proxy router checks the index table, if there is an index entry, the interface address set field value of the index entry is equal to the source interface address set field value of the received data request message, name If the field value is equal to the name of the received data request message, go to step 309, otherwise go to step 310; 步骤309:接收到该数据请求消息的代理路由器选择一个索引表项,该索引表项的接口地址集合域值等于接收到的数据请求消息的源接口地址集合域值,且名称域值等于接收到的数据请求消息的名称,将该转发表项的生命周期设置为最大值,执行步骤311;Step 309: The proxy router that receives the data request message selects an index entry, the interface address set field value of the index entry is equal to the source interface address set field value of the received data request message, and the name field value is equal to the received data request message. The name of the data request message, set the life cycle of the forwarding entry to the maximum value, and execute step 311; 步骤310:接收到该数据请求消息的代理路由器创建一个索引表项,该索引表项的接口地址集合域值等于接收到的数据请求消息的源接口地址集合域值,名称域值等于接收到的数据请求消息的名称,将该转发表项的生命周期设置为最大值;Step 310: The proxy router that receives the data request message creates an index entry, the interface address set field value of the index entry is equal to the source interface address set field value of the received data request message, and the name field value is equal to the received data request message. The name of the data request message, and the life cycle of the forwarding entry is set to the maximum value; 步骤311:结束。Step 311: End. 4.根据权利要求3所述的一种高效的新一代大数据网络实现方法,其特征在于,如果数据C3由名称NA3唯一标识,名称NA3由地理坐标(x3,y3)和名称ID NID3构成,数据C3的长度为m3比特,一个消息负载的最大长度为n比特,n和m3为正整数,m3大于w1×n,则该数据被分为u3个数据块并通过u3个消息传输,如公式(2)所示,前u3-1个数据块的长度为n,最后一个数据块的长度为m3-(u3-1)×n;4. a kind of efficient new generation big data network realization method according to claim 3 is characterized in that, if data C3 is uniquely identified by name NA3, and name NA3 is made up of geographical coordinates (x3, y3) and name ID NID3, The length of data C3 is m3 bits, the maximum length of a message payload is n bits, n and m3 are positive integers, and m3 is greater than w1×n, then the data is divided into u3 data blocks and transmitted through u3 messages, such as the formula As shown in (2), the length of the first u3-1 data block is n, and the length of the last data block is m3-(u3-1)×n;
Figure FDA0002881747930000051
Figure FDA0002881747930000051
每个数据路由器、代理路由器或者接入节点各自保存一个请求表,一个请求表项包含名称域和接口地址集合域;Each data router, proxy router or access node saves a request table, and a request table entry includes the name field and the interface address set field; 在移动设备MD3与移动路由器MR3链路相连,移动路由器MR3与接入节点AP3链路相连,接入节点AP3位于数据网络DN1中,数据网络DN1的代理路由器为PR1的条件下,如果代理路由器PR1至少存在一个索引表项,该索引表项的名称域值为NA3,移动设备MD3则通过下述过程获取数据C3:Under the condition that the mobile device MD3 is linked to the mobile router MR3, the mobile router MR3 is linked to the access node AP3, the access node AP3 is located in the data network DN1, and the proxy router of the data network DN1 is PR1, if the proxy router PR1 At least one index entry exists, and the name field value of the index entry is NA3, and the mobile device MD3 obtains the data C3 through the following process: 步骤401:开始;Step 401: start; 步骤402:移动设备MD3发送一个数据获取消息,该数据获取消息中,名称为NA3,消息类型为4,标识为0,源接口地址集合和目的接口地址集合为空,负载为空;移动路由器MR3从下游接口接收到该数据获取消息后,从上游接口转发该数据获取消息;Step 402: The mobile device MD3 sends a data acquisition message. In the data acquisition message, the name is NA3, the message type is 4, the identifier is 0, the source interface address set and the destination interface address set are empty, and the load is empty; mobile router MR3 After receiving the data acquisition message from the downstream interface, forward the data acquisition message from the upstream interface; 步骤403:接入节点AP3接收到该数据获取消息后,查看请求表,如果存在一个请求表项,该请求表项的名称域值等于接收到的数据获取消息的名称,则执行步骤427,否则执行步骤404;Step 403: After the access node AP3 receives the data acquisition message, it checks the request table. If there is a request table entry, and the name field value of the request table entry is equal to the name of the received data acquisition message, step 427 is executed; otherwise, step 427 is executed. Go to step 404; 步骤404:接入节点AP3创建一个请求表项,该请求表项的名称域值等于接收到的数据获取消息的名称,且接口地址集合等于接收到的数据获取消息的源接口地址集合;接入节点AP3查看数据表,如果存在一个数据表项,该数据表项的名称域值等于接收到的数据获取消息的名称,则执行步骤405,否则执行步骤409;Step 404: the access node AP3 creates a request entry, the name field value of the request entry is equal to the name of the received data acquisition message, and the set of interface addresses is equal to the set of source interface addresses of the received data acquisition message; access The node AP3 checks the data table, if there is a data table entry, the name field value of the data table entry is equal to the name of the received data acquisition message, then executes step 405, otherwise executes step 409; 步骤405:接入节点AP3将数据C3划分为u3个数据块,设置变量u1,变量u1的初始值为0;Step 405: the access node AP3 divides the data C3 into u3 data blocks, sets the variable u1, and the initial value of the variable u1 is 0; 步骤406:接入节点AP3将变量u1递增1,如果u1小于u3,则执行步骤407,否则执行步骤408;Step 406: the access node AP3 increments the variable u1 by 1, if u1 is less than u3, then executes step 407, otherwise executes step 408; 步骤407:接入节点AP3创建一个数据响应消息,该数据响应消息的名称域值等于接收到的数据响应消息的名称,消息类型为5,标识域值为1,源接口地址集合和目的接口地址集合为空,负载为第u1个数据块,执行步骤406;Step 407: The access node AP3 creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 1, the source interface address set and the destination interface address The set is empty, the load is the u1th data block, and step 406 is executed; 步骤408:接入节点AP3创建一个数据响应消息,该数据响应消息的名称域值等于接收到的数据响应消息的名称,消息类型为5,标识域值为0,源接口地址集合和目的接口地址集合为空,负载为第u1个数据块,执行步骤427;Step 408: the access node AP3 creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 0, the source interface address set and the destination interface address The set is empty, the load is the u1th data block, and step 427 is executed; 步骤409:接入节点AP3将自己的地理坐标加入到接收到的数据响应消息的源接口地址集合中,且该地理坐标作为源接口地址集合的第一个元素,从上游接口转发接收到的数据响应消息;Step 409: The access node AP3 adds its own geographic coordinates to the source interface address set of the received data response message, and the geographic coordinates are used as the first element of the source interface address set, and forwards the received data from the upstream interface response message; 步骤410:如果代理路由器接收到该数据响应消息,则执行步骤420,如果是数据路由器或者接入节点接收到该数据响应消息,执行步骤411;Step 410: if the proxy router receives the data response message, execute step 420; if the data router or the access node receives the data response message, execute step 411; 步骤411:数据路由器或者接入节点接收到数据响应消息后查看请求表,如果存在一个请求表项,该请求表项的名称域值等于接收到的数据响应消息的名称,则执行步骤427,否则执行步骤412;Step 411: After receiving the data response message, the data router or the access node checks the request table. If there is a request table entry, and the name field value of the request table entry is equal to the name of the received data response message, step 427 is executed, otherwise Go to step 412; 步骤412:接收到该数据响应消息的数据路由器或者接入节点创建一个请求表项,该请求表项的名称域值等于接收到的数据响应消息的名称,且接口地址集合等于接收到的数据响应消息的源接口地址集合;该数据路由器或者接入节点查看数据表,如果存在一个数据表项,该数据表项的名称域值等于接收到的数据响应消息的名称,则执行步骤416,否则执行步骤413;Step 412: The data router or access node that received the data response message creates a request entry, the name field value of the request entry is equal to the name of the received data response message, and the interface address set is equal to the received data response The source interface address set of the message; the data router or access node checks the data table, if there is a data table entry, the name field value of the data table entry is equal to the name of the received data response message, then execute step 416, otherwise execute step 416 Step 413; 步骤413:接收到该数据响应消息的数据路由器或者接入节点查看索引表,如果存在一个索引表,该索引表的名称域值等于接收到的数据响应消息的名称,则执行步骤414,否则步骤415;Step 413: The data router or access node that received the data response message checks the index table, if there is an index table, and the name field value of the index table is equal to the name of the received data response message, then execute step 414, otherwise step 413 415; 步骤414:接收到该数据响应消息的数据路由器或者接入节点选择一个索引表,该索引表的名称域值等于接收到的数据响应消息的名称,将该数据响应消息的目的接口地址集合更新为该索引表的接口地址集合域值,选择一个接口,该接口的接口地址等于该数据响应消息目的接口地址集合的第一个元素,将该数据响应消息目的接口地址集合的第一个元素加入到该数据响应消息源接口地址集合并作为源接口地址集合的第一个元素,从该数据响应消息目的接口地址集合中删除第一个元素,从选中的接口发送该数据响应消息,执行步骤410;Step 414: The data router or access node that received the data response message selects an index table, and the name field value of the index table is equal to the name of the received data response message, and updates the destination interface address set of the data response message to The interface address set field value of the index table, select an interface whose interface address is equal to the first element of the destination interface address set of the data response message, and add the first element of the destination interface address set of the data response message to the The data response message source interface address set is taken as the first element of the source interface address set, the first element is deleted from the data response message destination interface address set, the data response message is sent from the selected interface, and step 410 is performed; 步骤415:接收到该数据响应消息的数据路由器或者接入节点将自己的地理坐标加入到该数据响应消息源接口地址集合并作为源接口地址集合的第一个元素,从上游接口发送该数据响应消息,执行步骤410;Step 415: The data router or access node that received the data response message adds its own geographic coordinates to the source interface address set of the data response message as the first element of the source interface address set, and sends the data response from the upstream interface message, go to step 410; 步骤416:接收到该数据响应消息的数据路由器或者接入节点将数据C3划分为u3个数据块,设置变量u1,变量u1的初始值为0;Step 416: The data router or access node that receives the data response message divides the data C3 into u3 data blocks, sets the variable u1, and the initial value of the variable u1 is 0; 步骤417:接收到该数据响应消息的数据路由器或者接入节点将变量u1递增1,如果u1小于u3,则执行步骤418,否则执行步骤419;Step 417: The data router or access node that has received the data response message increments the variable u1 by 1, if u1 is less than u3, execute step 418, otherwise execute step 419; 步骤418:接收到该数据响应消息的数据路由器或者接入节点创建一个数据响应消息,该数据响应消息的名称域值等于接收到的数据响应消息的名称,消息类型为5,标识域值为1,源接口地址集合为空,目的接口地址集合为接收到的数据响应消息的源接口地址集合,负载为第u1个数据块,执行步骤417;Step 418: The data router or access node that received the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, and the identification field value is 1 , the source interface address set is empty, the destination interface address set is the source interface address set of the received data response message, the load is the u1th data block, and step 417 is performed; 步骤419:接收到该数据响应消息的数据路由器或者接入节点创建一个数据响应消息,该数据响应消息的名称域值等于接收到的数据响应消息的名称,消息类型为5,标识域值为0,接口地址集合为空,目的接口地址集合为接收到的数据响应消息的源接口地址集合,负载为第u1个数据块,执行步骤427;Step 419: The data router or access node that received the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, and the identification field value is 0 , the interface address set is empty, the destination interface address set is the source interface address set of the received data response message, the load is the u1th data block, and step 427 is performed; 步骤420:代理路由器接收到该数据响应消息后,查看请求表,如果存在一个请求表项,该请求表项的名称域值等于接收到的数据响应消息的名称,则执行步骤427,否则执行步骤421;Step 420: After the proxy router receives the data response message, it checks the request table. If there is a request table entry, and the name field value of the request table entry is equal to the name of the received data response message, perform step 427, otherwise, perform step 427. 421; 步骤421:接收到该数据响应消息的代理路由器创建一个请求表项,该请求表项的名称域值等于接收到的数据响应消息的名称,且接口地址集合等于接收到的数据响应消息的源接口地址集合;该代理路由器查看数据表,如果存在一个数据表项,该数据表项的名称域值等于接收到的数据响应消息的名称,则执行步骤423,否则执行步骤422;Step 421: The proxy router that receives the data response message creates a request entry, the name field value of the request entry is equal to the name of the received data response message, and the interface address set is equal to the source interface of the received data response message Address collection; the proxy router checks the data table, if there is a data table entry, and the name field value of the data table entry is equal to the name of the received data response message, then execute step 423, otherwise execute step 422; 步骤422:接收到该数据响应消息的代理路由器选择一个索引表,该索引表的名称域值等于接收到的数据响应消息的名称,将该数据响应消息的目的接口地址集合更新为该索引表的接口地址集合域值,选择一个接口,该接口的接口地址等于该数据响应消息目的接口地址集合的第一个元素,将该数据响应消息目的接口地址集合的第一个元素加入到该数据响应消息源接口地址集合并作为源接口地址集合的第一个元素,从该数据响应消息目的接口地址集合中删除第一个元素,从选中的接口发送该数据响应消息,执行步骤410;Step 422: The proxy router that receives the data response message selects an index table, the name field value of the index table is equal to the name of the received data response message, and updates the destination interface address set of the data response message to the index table. The value of the interface address set field, select an interface whose interface address is equal to the first element of the destination interface address set of the data response message, and add the first element of the data response message destination interface address set to the data response message. The source interface address set is combined as the first element of the source interface address set, the first element is deleted from the destination interface address set of the data response message, the data response message is sent from the selected interface, and step 410 is performed; 步骤423:接收到该数据响应消息的代理路由器将数据C3划分为u3个数据块,设置变量u1,变量u1的初始值为0;Step 423: The proxy router that receives the data response message divides the data C3 into u3 data blocks, sets the variable u1, and the initial value of the variable u1 is 0; 步骤424:接收到该数据响应消息的数据路由器将变量u1递增1,如果u1小于u3,则执行步骤425,否则执行步骤426;Step 424: The data router that received the data response message increments the variable u1 by 1, if u1 is less than u3, then executes step 425, otherwise executes step 426; 步骤425:接收到该数据响应消息的数据路由器创建一个数据响应消息,该数据响应消息的名称域值等于接收到的数据响应消息的名称,消息类型为5,标识域值为1,源接口地址集合为空,目的接口地址集合为接收到的数据响应消息的源接口地址集合,负载为第u1个数据块,执行步骤424;Step 425: The data router that received the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 1, and the source interface address is The set is empty, the destination interface address set is the source interface address set of the received data response message, the load is the u1th data block, and step 424 is executed; 步骤426:接收到该数据响应消息的数据路由器创建一个数据响应消息,该数据响应消息的名称域值等于接收到的数据响应消息的名称,消息类型为5,标识域值为0,接口地址集合为空,目的接口地址集合为接收到的数据响应消息的源接口地址集合,负载为第u1个数据块;Step 426: The data router that received the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, the identification field value is 0, and the interface address set If it is empty, the destination interface address set is the source interface address set of the received data response message, and the load is the u1th data block; 步骤427:接入节点、数据路由器或者代理路由器查看请求表,选择所有名称域值等于该数据响应消息名称的请求表项,针对每个请求表项,该接入节点、数据路由器或者代理路由器执行下述操作:将该数据响应消息的目的接口地址集合更新为该请求表项的接口地址集合,如果该目的接口地址集合为空,则从下游接口转发该数据响应消息,如果该目的接口地址集合不为空,则选择一个接口,该接口的接口地址等于该目的接口地址集合的第一个元素,从该目的接口地址集合中删除第一个元素,从该接口转发该数据响应消息,如果该数据响应消息的标识域值为0,则删除该请求表项,否则保留该请求表项;如果该数据响应消息目的接口地址集合域值为空,则执行步骤428,否则重新执行步骤427;Step 427: The access node, data router or proxy router checks the request table, selects all request table entries whose name field value is equal to the name of the data response message, and for each request table entry, the access node, data router or proxy router executes The following operations: Update the destination interface address set of the data response message to the interface address set of the request entry. If the destination interface address set is empty, forward the data response message from the downstream interface. If the destination interface address set is empty, forward the data response message from the downstream interface. If it is not empty, select an interface whose interface address is equal to the first element of the destination interface address set, delete the first element from the destination interface address set, and forward the data response message from this interface. If the ID field value of the data response message is 0, delete the request entry, otherwise keep the request entry; if the destination interface address set field value of the data response message is empty, execute step 428, otherwise execute step 427 again; 步骤428:移动路由器MR3接收到该数据响应消息后,从下游接口转发该数据响应消息;移动设备MD3接收到该数据响应消息后保存该数据响应消息中的数据;Step 428: after receiving the data response message, the mobile router MR3 forwards the data response message from the downstream interface; the mobile device MD3 saves the data in the data response message after receiving the data response message; 步骤429:结束;Step 429: end; 上述过程中,接入节点,数据路由器或者代理路由器接收到消息类型为5的消息后,如果保存该消息类型中的数据,则执行步骤301~311创建索引表。In the above process, after the access node, the data router or the proxy router receives the message with the message type of 5, if the data in the message type is saved, steps 301 to 311 are executed to create an index table.
5.根据权利要求4所述的一种高效的新一代大数据网络实现方法,其特征在于,在数据C3由名称NA3标识,移动设备MD4与移动路由器MR4链路相连,移动路由器MR4与接入节点AP4链路相连,接入节点AP4位于数据网络DN2中,数据网络DN2的代理路由器为PR2的条件下,如果代理路由器PR2任何一个索引表项的名称域值都不等于NA3,则移动设备MD4通过下述过程获取数据C3:5. a kind of efficient new generation big data network realization method according to claim 4, is characterized in that, in data C3 is identified by name NA3, mobile device MD4 links to each other with mobile router MR4 link, and mobile router MR4 and access The node AP4 is connected to the link, the access node AP4 is located in the data network DN2, and the proxy router of the data network DN2 is PR2, if the name field value of any index entry of the proxy router PR2 is not equal to NA3, the mobile device MD4 Obtain data C3 through the following process: 步骤501:开始;Step 501: start; 步骤502:移动设备MD4发送一个数据获取消息,该数据获取消息中,名称为NA3,消息类型为4,标识为0,源接口地址集合和目的接口地址集合为空,负载为空;移动路由器MR4从下游接口接收到该数据获取消息后,从上游接口转发该数据获取消息;Step 502: The mobile device MD4 sends a data acquisition message. In the data acquisition message, the name is NA3, the message type is 4, the identifier is 0, the source interface address set and the destination interface address set are empty, and the load is empty; mobile router MR4 After receiving the data acquisition message from the downstream interface, forward the data acquisition message from the upstream interface; 步骤503:接入节点AP4接收到该数据获取消息后,查看请求表,如果存在一个请求表项,该请求表项的名称域值等于接收到的数据获取消息的名称,则执行步骤520,否则执行步骤504;Step 503: After the access node AP4 receives the data acquisition message, it checks the request table. If there is a request table entry, and the name field value of the request table entry is equal to the name of the received data acquisition message, step 520 is executed; otherwise, step 520 is executed. Go to step 504; 步骤504:接入节点AP4创建一个请求表项,该请求表项的名称域值等于接收到的数据获取消息的名称,且接口地址集合等于接收到的数据获取消息的源接口地址集合;接入节点AP4将自己的地理坐标加入到接收到的数据获取消息的源接口地址集合中且该地理坐标作为源接口地址集合的第一个元素,从上游接口转发接收到的数据获取消息;Step 504: the access node AP4 creates a request entry, the name field value of the request entry is equal to the name of the received data acquisition message, and the set of interface addresses is equal to the set of source interface addresses of the received data acquisition message; access Node AP4 adds its own geographic coordinates to the source interface address set of the received data acquisition message and this geographic coordinate is used as the first element of the source interface address set, and forwards the received data acquisition message from the upstream interface; 步骤505:判断是代理路由器还是数据路由器接收到该数据获取消息,如果代理路由器接收到该数据获取消息,则执行步骤508,否则执行步骤506;Step 505: Determine whether the proxy router or the data router has received the data acquisition message, if the proxy router receives the data acquisition message, perform step 508, otherwise perform step 506; 步骤506:数据路由器接收到该数据获取消息后,查看请求表,如果存在一个请求表项,该请求表项的名称域值等于接收到的数据获取消息的名称,则执行步骤520,否则执行步骤507;Step 506: After the data router receives the data acquisition message, it checks the request table. If there is a request table entry, and the name field value of the request table entry is equal to the name of the received data acquisition message, step 520 is performed, otherwise, step 520 is performed. 507; 步骤507:接收到该数据获取消息的数据路由器创建一个请求表项,该请求表项的名称域值等于接收到的数据获取消息的名称,且接口地址集合等于接收到的数据获取消息的源接口地址集合;该数据路由器将自己的地理坐标加入到接收到的数据获取消息的源接口地址集合中,且该地理坐标作为源接口地址集合的第一个元素,从上游接口转发接收到的数据获取消息,执行步骤505;Step 507: The data router that received the data acquisition message creates a request entry, the name field value of the request entry is equal to the name of the received data acquisition message, and the interface address set is equal to the source interface of the received data acquisition message Address set; the data router adds its own geographic coordinates to the source interface address set of the received data acquisition message, and the geographic coordinates are used as the first element of the source interface address set, and forwards the received data acquisition from the upstream interface message, go to step 505; 步骤508:代理路由器接收到该数据获取消息后,查看请求表,如果存在一个请求表项,该请求表项的名称域值等于接收到的数据获取消息的名称,则执行步骤520,否则执行步骤509;Step 508: After the proxy router receives the data acquisition message, it checks the request table. If there is a request table entry, and the name field value of the request table entry is equal to the name of the received data acquisition message, perform step 520, otherwise, perform step 508. 509; 步骤509:接收到该数据获取消息的代理路由器创建一个请求表项,该请求表项的名称域值等于接收到的数据获取消息的名称,且接口地址集合等于接收到的数据获取消息的源接口地址集合;该代理路由器将自己的地理坐标加入到接收到的数据获取消息的源接口地址集合中,且该地理坐标作为源接口地址集合的第一个元素,从上游接口转发接收到的数据获取消息;Step 509: The proxy router that receives the data acquisition message creates a request entry, the name field value of the request entry is equal to the name of the received data acquisition message, and the interface address set is equal to the source interface of the received data acquisition message Address set; the proxy router adds its own geographic coordinates to the source interface address set of the received data acquisition message, and the geographic coordinate is used as the first element of the source interface address set, and forwards the received data acquisition from the upstream interface information; 步骤510:如果核心路由器接收到该数据获取消息,则执行步骤511,如果是代理路由器、数据路由器或者接入节点接收到该数据获取消息,则执行步骤513;Step 510: If the core router receives the data acquisition message, execute step 511; if the proxy router, data router or access node receives the data acquisition message, execute step 513; 步骤511:核心路由器从一个接口接收到该数据获取消息后,该接口的接口地址为z1,查看请求表,如果存在一个请求表项,该请求表项的名称域值等于接收到的数据获取消息的名称,则执行步骤520,否则执行步骤512;Step 511: After the core router receives the data acquisition message from an interface, the interface address of the interface is z1, and checks the request table. If there is a request table entry, the name field value of the request table entry is equal to the received data acquisition message. name, go to step 520, otherwise go to step 512; 步骤512:从接口z1接收到该数据获取消息的核心路由器创建一个请求表项,该请求表项的名称域值等于接收到的数据获取消息的名称,且接口地址集合等于接收到的数据获取消息的源接口地址集合;该核心路由器将接口地址z1加入到接收到的数据获取消息的源接口地址集合中且该接口地址作为源接口地址集合的第一个元素,选择一个转发表项,该转发表项的地理坐标域值等于接收到的数据获取消息名称中的地理坐标,从该转发表项的接口地址所标识的接口转发该数据获取消息,执行步骤510;Step 512: The core router that received the data acquisition message from interface z1 creates a request entry, the name field value of the request entry is equal to the name of the received data acquisition message, and the interface address set is equal to the received data acquisition message The core router adds the interface address z1 to the source interface address set of the received data acquisition message and the interface address is used as the first element of the source interface address set, selects a forwarding entry, the forwarding The geographic coordinate domain value of the published item is equal to the geographic coordinate in the name of the received data acquisition message, and the data acquisition message is forwarded from the interface identified by the interface address of the forwarding item, and step 510 is executed; 步骤513:代理路由器、数据路由器或者接入节点查看请求表,如果存在一个请求表项,该请求表项的名称域值等于接收到的数据获取消息的名称,则执行步骤520,否则执行步骤514;Step 513: The proxy router, data router or access node checks the request table, if there is a request table entry, the name field value of the request table entry is equal to the name of the received data acquisition message, then go to step 520, otherwise go to step 514 ; 步骤514:接收到该数据获取消息的代理路由器、数据路由器或者接入节点创建一个请求表项,该请求表项的名称域值等于接收到的数据获取消息的名称,且接口地址集合等于接收到的数据获取消息的源接口地址集合;该代理路由器、数据路由器或者接入节点查看数据表,如果存在一个数据表项,该数据表项的名称域值等于接收到的数据获取消息的名称,则执行步骤516,否则执行步骤515;Step 514: The proxy router, data router or access node that receives the data acquisition message creates a request entry, the name field value of the request entry is equal to the name of the received data acquisition message, and the interface address set is equal to the received data acquisition message. The source interface address set of the data acquisition message; the proxy router, data router or access node looks at the data table, if there is a data table entry, the name field value of the data table entry is equal to the name of the received data acquisition message, then Go to step 516, otherwise go to step 515; 步骤515:接收到该数据获取消息的代理路由器、数据路由器或者接入节点选择一个索引表,该索引表的名称域值等于接收到的数据获取消息的名称,将该数据获取消息的目的接口地址集合更新为该索引表的接口地址集合域值,选择一个接口,该接口的接口地址等于该数据获取消息目的接口地址集合的第一个元素,将该数据获取消息目的接口地址集合的第一个元素加入到该数据获取消息源接口地址集合并作为源接口地址集合的第一个元素,从该数据获取消息目的接口地址集合中删除第一个元素,从选中的接口发送该数据获取消息,执行步骤513;Step 515: The proxy router, data router or access node that receives the data acquisition message selects an index table, the name field value of the index table is equal to the name of the received data acquisition message, and the destination interface address of the data acquisition message The set is updated to the interface address set field value of the index table, select an interface whose interface address is equal to the first element of the destination interface address set of the data acquisition message, and the first element of the data acquisition message destination interface address set The element is added to the source interface address set of the data acquisition message as the first element of the source interface address set, delete the first element from the destination interface address set of the data acquisition message, send the data acquisition message from the selected interface, and execute Step 513; 步骤516:接收到该数据获取消息的代理路由器、数据路由器或者接入节点将数据C3划分为u3个数据块,设置变量u1,变量u1的初始值为0;Step 516: The proxy router, data router or access node that receives the data acquisition message divides the data C3 into u3 data blocks, sets the variable u1, and the initial value of the variable u1 is 0; 步骤517:接收到该数据获取消息的代理路由器、数据路由器或者接入节点将变量u1递增1,如果u1小于u3,则执行步骤518,否则执行步骤519;Step 517: The proxy router, data router or access node that received the data acquisition message increments the variable u1 by 1, if u1 is less than u3, then executes step 518, otherwise executes step 519; 步骤518:接收到该数据获取消息的代理路由器、数据路由器或者接入节点创建一个数据响应消息,该数据响应消息的名称域值等于接收到的数据响应消息的名称,消息类型为5,标识域值为1,源接口地址集合为空,目的接口地址集合为接收到的数据响应消息的源接口地址集合,负载为第u1个数据块,执行步骤517;Step 518: The proxy router, data router or access node that received the data acquisition message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, and the identification field The value is 1, the source interface address set is empty, the destination interface address set is the source interface address set of the received data response message, the load is the u1th data block, and step 517 is executed; 步骤519:接收到该数据响应消息的代理路由器、数据路由器或者接入节点创建一个数据响应消息,该数据响应消息的名称域值等于接收到的数据响应消息的名称,消息类型为5,标识域值为0,接口地址集合为空,目的接口地址集合为接收到的数据响应消息的源接口地址集合,负载为第u1个数据块;Step 519: The proxy router, data router or access node that received the data response message creates a data response message, the name field value of the data response message is equal to the name of the received data response message, the message type is 5, and the identification field The value is 0, the interface address set is empty, the destination interface address set is the source interface address set of the received data response message, and the load is the u1th data block; 步骤520:接入节点、数据路由器、代理路由器或者核心路由器查看请求表,选择所有名称域值等于该数据响应消息名称的请求表项,针对每个请求表项,该核心路由器、接入节点、数据路由器或者代理路由器执行下述操作:将该数据响应消息的目的接口地址集合更新为该请求表项的接口地址集合,如果该目的接口地址集合为空,则从下游接口转发该数据响应消息,如果该目的接口地址集合不为空,则选择一个接口,该接口的接口地址等于该目的接口地址集合的第一个元素,从该目的接口地址集合中删除第一个元素,从该接口转发该数据响应消息,如果该数据响应消息的标识域值为0,则删除该请求表项,否则保留该请求表项;如果该数据响应消息目的接口地址集合域值为空,则执行步骤521,否则重新执行步骤520;Step 520: The access node, data router, proxy router or core router checks the request table, selects all request table entries whose name field value is equal to the name of the data response message, and for each request table entry, the core router, access node, The data router or proxy router performs the following operations: update the destination interface address set of the data response message to the interface address set of the request entry, if the destination interface address set is empty, forward the data response message from the downstream interface, If the destination interface address set is not empty, select an interface whose interface address is equal to the first element of the destination interface address set, delete the first element from the destination interface address set, and forward the In the data response message, if the value of the identification field of the data response message is 0, delete the request entry, otherwise keep the request entry; if the destination interface address set field of the data response message is empty, execute step 521, otherwise Re-execute step 520; 步骤521:移动路由器MR4接收到该数据响应消息后,从下游接口转发该数据响应消息;移动设备MD4接收到该数据响应消息后保存该数据响应消息中的数据;Step 521: after receiving the data response message, the mobile router MR4 forwards the data response message from the downstream interface; the mobile device MD4 saves the data in the data response message after receiving the data response message; 步骤522:结束;Step 522: end; 上述过程中,接入节点,数据路由器或者代理路由器接收到消息类型为5的消息后,如果保存该消息类型中的数据,则执行步骤301~311创建索引表。In the above process, after the access node, the data router or the proxy router receives the message with the message type of 5, if the data in the message type is saved, steps 301 to 311 are executed to create an index table.
CN201810235148.1A 2018-03-21 2018-03-21 High-efficiency new-generation big data network implementation method Active CN108494595B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN201810235148.1A CN108494595B (en) 2018-03-21 2018-03-21 High-efficiency new-generation big data network implementation method

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201810235148.1A CN108494595B (en) 2018-03-21 2018-03-21 High-efficiency new-generation big data network implementation method

Publications (2)

Publication Number Publication Date
CN108494595A CN108494595A (en) 2018-09-04
CN108494595B true CN108494595B (en) 2021-03-26

Family

ID=63318932

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201810235148.1A Active CN108494595B (en) 2018-03-21 2018-03-21 High-efficiency new-generation big data network implementation method

Country Status (1)

Country Link
CN (1) CN108494595B (en)

Families Citing this family (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN109218021B (en) * 2018-10-24 2021-02-05 常熟理工学院 A Secure New Generation IoT Data Communication Method
CN109768893B (en) * 2019-03-04 2021-06-18 常熟理工学院 An efficient implementation method of big data network data communication

Citations (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN103108308A (en) * 2011-11-15 2013-05-15 中兴通讯股份有限公司 Method, network element and user end for achieving identity location separation and distribution interface identification

Family Cites Families (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US8099104B2 (en) * 2004-02-26 2012-01-17 Telcordia Licensing Company Llc Location based services for integrated cellular and LAN networks
CN103096299B (en) * 2011-11-01 2017-09-15 中兴通讯股份有限公司 The method and LISP networks of a kind of mobile node dynamic access station location marker
CN106507428B (en) * 2016-10-19 2019-05-07 常熟理工学院 A Data Communication Method for Future Mobile Networks
CN106792978B (en) * 2017-03-29 2021-03-16 常熟理工学院 A cloud-based intelligent vehicle networking data communication method

Patent Citations (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN103108308A (en) * 2011-11-15 2013-05-15 中兴通讯股份有限公司 Method, network element and user end for achieving identity location separation and distribution interface identification

Also Published As

Publication number Publication date
CN108494595A (en) 2018-09-04

Similar Documents

Publication Publication Date Title
CN109088778B (en) Data communication implementation method for future mobile network
CN106941449B (en) A Network Data Communication Method Based on Demand Mechanism
CN110138663B (en) Method for implementing new generation network using data as center
CN109246785B (en) A Realization Method of Future Mobile Network
CN110113264A (en) A kind of caching and route implementation method for naming data network
CN109150723B (en) A method for implementing routing communication in the Internet of Things
CN109005567B (en) Mobile network implementation method based on cluster
CN106973017A (en) A kind of quick network data communication method
CN108494595B (en) High-efficiency new-generation big data network implementation method
CN110233889B (en) Network data communication implementation method based on cache mechanism
CN109462549B (en) A New Generation Wireless Mobile Network Implementation Method
CN107979645B (en) A method for implementing the Internet of Things
CN108494688A (en) A kind of Future Data network implementation approach of low-cost
CN105188104A (en) Wireless network communication implementation method
CN106936711A (en) A kind of network data communication method of stability and high efficiency
CN111245725B (en) Future network implementation method based on distribution
CN109768893B (en) An efficient implementation method of big data network data communication
CN108512700B (en) A data communication implementation method of software-defined network
CN110380971B (en) Network data communication method based on buffer mechanism
CN107949000B (en) A low-latency opportunistic network implementation method
CN108965138B (en) Method for implementing new generation multimedia sensor network
CN107948180B (en) A New Generation Network Realization Method Based on Multipath
CN108770030B (en) Data communication method of next generation wireless network
CN111416773B (en) A Fast Big Data Network Implementation Method
CN108055204A (en) A kind of big data network communication implementation method

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination
GR01 Patent grant
GR01 Patent grant
TR01 Transfer of patent right

Effective date of registration: 20220406

Address after: 230000 room 1414, building D, Yinhe happiness Plaza, intersection of Luzhou Avenue and Fuzhou Road, Baohe District, Hefei City, Anhui Province

Patentee after: Hefei keyiguo Information Technology Co.,Ltd.

Address before: 215500 School of computer science and engineering, Changshu Institute of Technology (southeast campus), Changshu City, Suzhou City, Jiangsu Province

Patentee before: CHANGSHU INSTITUTE OF TECHNOLOGY

Effective date of registration: 20220406

Address after: 222000 room 13016, No. 201, sunshine free trade building, Lianyungang District, Lianyungang Area, China (Jiangsu) pilot Free Trade Zone, Lianyungang City, Jiangsu Province

Patentee after: Lianyungang Yunqiao Information Technology Co.,Ltd.

Address before: 230000 room 1414, building D, Yinhe happiness Plaza, intersection of Luzhou Avenue and Fuzhou Road, Baohe District, Hefei City, Anhui Province

Patentee before: Hefei keyiguo Information Technology Co.,Ltd.

TR01 Transfer of patent right
TR01 Transfer of patent right

Effective date of registration: 20231222

Address after: 233600 Star Garden Incubator in the Optoelectronics Standardization Plant, Economic Development Zone, Guoyang County, Bozhou City, Anhui Province

Patentee after: Daoji Intelligence (Anhui) Information Technology Co.,Ltd.

Address before: 222000 room 13016, No. 201, sunshine free trade building, Lianyungang District, Lianyungang Area, China (Jiangsu) pilot Free Trade Zone, Lianyungang City, Jiangsu Province

Patentee before: Lianyungang Yunqiao Information Technology Co.,Ltd.

TR01 Transfer of patent right