CN103067396A - Three-dimensional (3d) geographic information system (GIS) asynchronous communication transmission system and method of asynchronous communication transmission - Google Patents

Abstract

A three-dimensional GIS asynchronous communication transmission system, including a client and a server, wherein: the client sends a three-dimensional spatial data query message to the server after establishing a connection with the server, and the server receives and analyzes the three-dimensional spatial data query message, and converts it into a three-dimensional spatial database query task , execute the database query task and return the query result, serialize the data in the query result into a byte stream form, and compress it to obtain a compressed data packet, obtain the communication handle of the client, and send the compressed data packet according to the communication handle To the client, the client receives the compressed data package, performs data reorganization, decompression and deserialization operations on the compressed data package, obtains the 3D spatial data object to be queried, and performs operations such as 3D visualization and 3D spatial analysis.

Description

3D GIS Asynchronous Communication Transmission System and Its Asynchronous Communication Transmission Method

technical field

The invention relates to network technology, in particular to a three-dimensional GIS asynchronous communication transmission system and an asynchronous communication transmission method thereof.

Background technique

With the growing demand for integrated management of large-scale 3D GIS data, data security, and multi-user shared applications in a distributed environment, the traditional two-tier client/database server 3D GIS network application With the continuous increase of the scale, the increase of the number of concurrent users, the load pressure of the database server is too large, and the serious I/O bottleneck and performance bottleneck of the database server are caused by the concurrent access of multiple users, so that the multi-user concurrent 3D GIS can meet the smooth Real-time applications such as visualization and high-performance 3D spatial analysis have encountered insurmountable obstacles. In order to reduce the I/O bottleneck of the database server and the load pressure caused by multi-user concurrency, a multi-layer architecture of client, application server and database server is generally adopted: the application server and database server are respectively deployed on different hosts. The user interface and part of the application processing logic are deployed on the client, the application server undertakes part of the processing logic, and the data is deployed on the database server. This multi-layer architecture requires efficient network communication for the interaction between the client and the application server, and between the application server and the database server.

Network transmission mode directly determines the performance of network application software. The network transmission mode is divided into synchronous mode and asynchronous mode. The characteristic of synchronous network transmission is that after the client sends a request, the next request must be sent after the server responds. The characteristic of this working mode is that the client cannot send multiple messages concurrently, resulting in low efficiency of client data scheduling. Asynchronous network transmission means that after the client sends a request, it can send the next request without waiting for the response from the server. Its advantage is that it avoids message synchronization time and improves data scheduling efficiency. The asynchronous transmission strategy helps to efficiently utilize the network and reduce the impact of high latency. However, both the synchronous transmission mode and the asynchronous traditional mode do not carry out message processing, scheduling task processing, compression processing, and transmission method processing for 3D spatial objects according to the characteristics of 3D spatial data scheduling and 3D visualization of the 3D GIS platform. The 3D GIS platform achieves efficient network data scheduling and network transmission effects.

Contents of the invention

In view of this, it is necessary to provide a 3D GIS asynchronous communication transmission system and its transmission method to effectively combine 3D spatial data scheduling and data network transmission to achieve the best network data scheduling and transmission efficiency.

A three-dimensional GIS asynchronous communication transmission system provided by the present invention includes a client and a server, and the server includes a three-dimensional spatial database for managing three-dimensional GIS data such as terrain data, image data, urban three-dimensional model data and its attribute data, and User connection authority data, wherein: the client includes: a first communication module, configured to encapsulate the connection request into a connection message, and send the connection message to the server; the server includes: a monitoring module, configured to monitor the The connection message of the client is to analyze the connection request parameters in the connection message; the judging module is used to obtain the user connection authority data from the three-dimensional space database, and judge whether the parameters of the connection request are correct, wherein the monitoring module is also used to Establishing a connection with the client when the parameters of the connection request are correct, the first communication module is further configured to encapsulate the three-dimensional spatial data query request into a three-dimensional spatial data query message and send it to the server, and the monitoring module is also configured to For receiving the three-dimensional spatial data query messages, and sequentially put them into the three-dimensional spatial data query message queue; the second communication module is used for successively taking out the three-dimensional spatial data query messages from the three-dimensional spatial data query message queue, and handing over the three-dimensional spatial data query messages to the communication thread The idle thread in the pool performs parsing and processing, and converts the three-dimensional spatial data query message into a three-dimensional spatial database query task, and puts it into the database query task queue; the three-dimensional spatial data scheduling module is used to schedule data from the scheduling thread pool and the database connection pool Respectively take out the idle scheduling thread and the database connection to execute the three-dimensional spatial database query task, and return the query result, wherein the second communication module is also used to receive the query result, and serialize the data in the query result into characters form of throttling, and perform compression to obtain a compressed data packet, obtain the communication handle of the client, and send the compressed data packet to the client according to the communication handle, and the first communication module is also used to receive The compressed data package; the client further includes a data processing module for performing data reorganization, decompression and deserialization operations on the compressed data package to obtain a three-dimensional space object to be queried.

The present invention also provides a three-dimensional GIS asynchronous communication transmission method for communication between a client and a server, wherein the server includes a three-dimensional spatial database for managing terrain data, image data, city three-dimensional model data and their attributes Three-dimensional GIS data such as data and user connection authority data, described method comprises the following steps: described server opens communication monitoring, monitors the connection request of described client; Described client encapsulates connection request into connection message, and connection message is sent to The server; the server listens to the connection message of the client, and parses the connection request parameters in the connection message; the server obtains user connection authority data from the three-dimensional spatial database, and determines whether the connection request parameters are correct; if If the parameters of the connection request are correct, the server establishes a connection with the client; the client encapsulates the three-dimensional spatial data query request into a three-dimensional spatial data query message and sends it to the server; the server receives the three-dimensional spatial data query message and sends it to the server; Spatial data query messages, and put them in the three-dimensional spatial data query message queue in turn; the server takes out the three-dimensional spatial data query messages in turn from the three-dimensional spatial data query message queue, and submits them to the idle threads in the communication thread pool for parsing and processing, and Convert the three-dimensional spatial data query message into a three-dimensional spatial database query task, and put it into the database query task queue; the server takes out idle scheduling threads and database connections from the scheduling thread pool and database connection pool to execute the three-dimensional spatial database query task , and return the query result; the server receives the query result, serializes the data in the query result into a byte stream form, and compresses it to obtain a compressed data packet; the server obtains the communication handle of the client , and send the compressed data packet to the client according to the communication handle; the client receives the compressed data packet; the client performs data reassembly, decompression and deserialization on the compressed data packet Transformation operation to obtain the three-dimensional space object to be queried.

The three-dimensional GIS asynchronous communication transmission system and its communication transmission method in the present invention establish a connection with the server through a client connection request, then send a three-dimensional spatial data query message to the server, and use idle threads to process the three-dimensional spatial data query message, thereby improving the The efficiency of network data scheduling and transmission avoids the delay of synchronization.

Description of drawings

Fig. 1 is a block diagram of a three-dimensional GIS asynchronous communication transmission system in an embodiment of the present invention;

FIG. 2 is a flowchart of a method for asynchronous communication transmission using the three-dimensional GIS asynchronous communication transmission system shown in FIG. 1 in an embodiment of the present invention.

Detailed ways

Embodiments of the present invention are described in detail below, examples of which are shown in the drawings, wherein the same or similar reference numerals designate the same or similar elements or elements having the same or similar functions throughout. The embodiments described below by referring to the figures are exemplary only for explaining the present invention and should not be construed as limiting the present invention.

In the description of the present invention, the orientation or positional relationship indicated by the terms "inner", "outer", "longitudinal", "transverse", "upper", "lower", "top", "bottom" etc. are based on the drawings The orientations or positional relationships shown are only for the convenience of describing the invention and do not require the invention to be constructed and operated in a specific orientation, and thus should not be construed as limitations on the invention.

Please refer to FIG. 1 . FIG. 1 is a block diagram of a three-dimensional GIS asynchronous communication transmission system in an embodiment of the present invention.

In this embodiment, the 3D GIS asynchronous communication transmission system includes a server 10 and a client 20, wherein the server 10 includes: a monitoring module 102, a second communication module 104, a judging module 106, a 3D spatial database 110 and a 3D spatial data scheduling module 112. The client 20 includes a first communication module 202 and a data processing module 204 .

In this embodiment, the three-dimensional spatial database 110 includes vector model data, terrain data and underground data, wherein the vector model data includes geometric data, material data, texture data and shared model data, and the terrain data includes DEM data and DOM data.

In this embodiment, the first communication module 202 is configured to encapsulate the connection request into a connection message, and send the connection message to the server 10 .

The monitoring module 102 is configured to monitor the connection message of the client, and analyze connection request parameters in the connection message.

The judging module 106 is used to obtain user connection authorization data from the three-dimensional space database 110, and judge whether the parameters of the connection request are correct.

In this embodiment, the monitoring module 102 is also used to establish a connection with the client 20 when the parameters of the connection request are correct, and the first communication module 202 is also used to encapsulate the three-dimensional spatial data query request The three-dimensional spatial data query message is sent to the server 10, and the listening module 102 is also configured to receive the three-dimensional spatial data query message and put it into the three-dimensional spatial data query message queue in sequence.

In this embodiment, the first communication module 202 fetches a message from the head of the message queue sequentially by taking an idle thread from the message sending thread pool, and sends the message to the server 10. The thread locks and waits for the server 10 to return a message.

The second communication module 104 is used to successively take out the three-dimensional spatial data query message from the three-dimensional spatial data query message queue, hand it over to an idle thread in the communication thread pool for parsing and processing, and convert the three-dimensional spatial data query message into a three-dimensional spatial database query task , put into the database query task queue.

In this embodiment, the second communication module 104 compresses the DEM data and DOM data using wavelet transform compression coding method, and the city 3D model data is converted into lossless data through the data stream formed by coding its 3D geometric data. Compression, its texture data is also compressed by wavelet transform compression coding method.

The three-dimensional spatial data dispatching module 112 is used to take idle dispatching threads and database connections from the dispatching thread pool and the database connection pool to execute the three-dimensional spatial database query task, and return the query result.

In this embodiment, the second communication module 104 is further configured to receive the query result, serialize the data in the query result into a byte stream, and compress to obtain a compressed data packet, and obtain the The communication handle of the client 20, and send the compressed data packet to the client 20 according to the communication handle, and the first communication module 202 is also configured to receive the compressed data packet.

In this embodiment, the IP address and port number of the client 20 are saved in the three-dimensional space database 110 , and the second communication module 104 acquires the communication handle through the IP address and port number of the client 20 .

In this embodiment, after the first communication module 202 receives the message of data return from the server 10, it sends the notification to the data receiving thread, and the message sending thread is set to an idle state and unlocked, and is recycled to the message sending thread pool. In the idle thread queue, during this process, the client 20 continuously takes out idle threads from the message sending thread pool and sequentially takes out pending messages from the message queue to perform the same message sending, locking, waiting for return notification, notification data receiving thread, unlocking, etc. Operation, the data receiving thread starts to receive data after receiving the data receiving notification.

The data processing module 204 is used to perform data reorganization, decompression and deserialization operations on the compressed data package to obtain the three-dimensional space object to be queried.

In this embodiment, the data processing module 204 performs data reassembly, decompression and deserialization operations according to the header information of the compressed data packet. The header information includes: the type of the message and the total length of the data packet. The data processing module 204 in the client 20 determines the type of data through the message type, and ensures the complete and accurate reception of the data through the total length of the data packet.

In this embodiment, the second communication module 104 is further configured to receive the query result, serialize the data in the query result into a form of byte stream, and perform compression to obtain a compressed data packet.

In this embodiment, the judging module 106 is also used to judge whether the size of the compressed data packet is greater than a fixed value, and the second communication module 104 performs a process on the compressed data packet when the compressed data packet is larger than a fixed value Subcontract. In this embodiment, the fixed value is 64KB.

In this embodiment, when the second communication module 104 divides the compressed data packets into packets, the data packet size is set as a fixed value, and when the remaining part of the compressed data packets after the packetization is smaller than the fixed value, no packetization is performed. Bag.

In this embodiment, the second communication module 104 does not divide the compressed data packet into packets when the compressed data packet is less than or equal to a fixed value.

In this embodiment, the second communication module 104 divides the compressed data packets to avoid a large number of packet loss and retransmission phenomena.

Please refer to FIG. 2 . FIG. 2 is a flowchart of a method for asynchronous communication transmission using the 3D GIS asynchronous communication transmission system shown in FIG. 1 in an embodiment of the present invention.

In this embodiment, the three-dimensional spatial database 110 includes vector model data, terrain data, and underground data, wherein the vector model data includes geometric data, material data, texture data, and shared model data, and the terrain data includes DEM data and DOM data.

In step S200 , the monitoring module 102 in the server 10 starts communication monitoring to monitor the connection request of the client 20 .

In step S202 , the first communication module 202 in the client 20 encapsulates the connection request into a connection message, and sends the connection message to the server 10 .

In step S204, the monitoring module 102 in the service 10 monitors the connection message of the client 20, and parses the connection request parameters in the connection message.

In step S206, the judging module 106 in the server 10 acquires user connection authorization data from the three-dimensional spatial database 110, and judges whether the parameters of the connection request are correct.

If the parameters of the connection request are correct, then in step S208, the server 10 establishes a connection with the client 20 .

In step S210 , the first communication module 202 in the client 20 encapsulates the three-dimensional spatial data query request into a three-dimensional spatial data query message and sends it to the server 10 .

In this embodiment, the first communication module 202 fetches a message from the head of the message queue sequentially by taking an idle thread from the message sending thread pool, and sends the message to the server 10. The thread locks and waits for the server 10 to return a message.

In step S212, the monitoring module 102 in the server 10 receives the three-dimensional spatial data query messages, and puts them in the three-dimensional spatial data query message queue in sequence.

In step S214, the second communication module 104 in the server 10 sequentially fetches the three-dimensional spatial data query messages from the three-dimensional spatial data query message queue, and submits the three-dimensional spatial data query messages to the idle threads in the communication thread pool for parsing and processing, and sends the three-dimensional spatial data query messages The message is converted into a three-dimensional spatial database query task and put into the database query task queue.

In this embodiment, the second communication module 104 compresses the DEM data and DOM data using wavelet transform compression coding method, and the city 3D model data is converted into lossless data through the data stream formed by coding its 3D geometric data. Compression, its texture data is also compressed by wavelet transform compression coding method.

In step S216, the 3D spatial data scheduling module 112 in the server 10 fetches idle scheduling threads and database connections from the scheduling thread pool and the database connection pool to execute the 3D spatial database query task, and returns the query result.

In step S218, the second communication module 104 in the server 10 receives the query result, serializes the data in the query result into a form of byte stream, and performs compression to obtain a compressed data packet.

In other embodiments of the present invention, the three-dimensional GIS asynchronous communication transmission method further includes step S220, the judgment module 106 in the server 10 judges whether the size of the compressed data package is greater than a fixed value. In this embodiment, the fixed value is 64KB.

If the size of the compressed data packet is greater than a fixed value, then in step S222, the second communication module 104 in the server 10 divides the compressed data packet into packets.

In this embodiment, when the second communication module 104 divides the compressed data packets into packets, the data packet size is set as a fixed value, and when the remaining part of the compressed data packets after the packetization is smaller than the fixed value, no packetization is performed. Bag.

In this embodiment, the second communication module 104 divides the compressed data packets to avoid a large number of packet loss and retransmission phenomena.

In step S224, the second communication module 104 in the server 10 obtains the communication handle of the client 20, and sends the compressed data packet to the client 20 according to the communication handle.

In this embodiment, the IP address and port number of the client 20 are saved in the three-dimensional space database 110 , and the second communication module 104 acquires the communication handle through the IP address and port number of the client 20 .

If the size of the compressed data packet is less than or equal to a fixed value, then the compressed data packet does not need to be divided into packets, and directly enters step S224.

In step S226, the first communication module 202 of the client 20 receives the compressed data packet.

In this embodiment, after the first communication module 202 receives the message of data return from the server 10, it sends the notification to the data receiving thread, and the message sending thread is unlocked and recycled to the idle thread queue in the message sending thread pool. In this process, the client 20 continuously takes out idle threads from the message sending thread pool and successively takes out pending messages from the message queue to perform the same message sending, locking, waiting for return notification, notification data receiving thread, unlocking and other operations. After receiving the data receiving notification, start data receiving.

In step S228, the data processing module 204 of the client 20 performs data reorganization, decompression and deserialization operations on the compressed data packet to obtain the data object to be queried, and unlocks the client 20.

In this embodiment, the processing module 204 in the client 20 performs data reassembly by parsing header information of the compressed data packet, so as to obtain a complete compressed data packet.

In this embodiment, the header information of the compressed data packet includes: the type of message and the total length of the data packet, the processing module 204 in the client 20 determines the type of data by the message type, and ensures the data by the total length of the data packet complete and accurate reception.

The three-dimensional GIS asynchronous communication transmission system 10 and its communication transmission method in the present invention establish a connection with the server 10 through the connection request of the client 20, and then send a three-dimensional spatial data query message to the server 10, and use idle threads to process the three-dimensional spatial data query Messages improve network data scheduling and transmission efficiency and avoid synchronization delays.

Although the present invention has been described with reference to the current preferred embodiments, those skilled in the art should understand that the above-mentioned preferred embodiments are only used to illustrate the present invention, and are not used to limit the protection scope of the present invention. Any modifications, equivalent replacements, improvements, etc. made within the spirit and scope of principles shall be included in the protection scope of the present invention.

Claims (12)

1. three-dimension GIS asynchronous communication transmission system, comprise client and server, comprise the three-dimensional space data storehouse in the described server, be used for the three-dimension GIS data such as management terrain data, image data, city three-dimensional modeling data and attribute data thereof and user and connect permissions data, it is characterized in that described three-dimension GIS asynchronous communication transmission system comprises:

Described client comprises:

First communication module is used for connection request is packaged into connection message, and connection message is sent to described server;

Described server comprises:

Monitor module, be used for monitoring the described connection message of described client, resolve the connection request parameter in the connection message;

Judge module, be used for obtaining the user from the three-dimensional space data storehouse and connect permissions data, whether the parameter of judging described connection request is correct, wherein, described monitoring module also is used for parameter at described connection request and sets up when correct and being connected of described client, described first communication module is used for that also the three-dimensional space data query requests is packaged into the three-dimensional space data query messages and sends to described server, described monitoring module also is used for receiving described three-dimensional space data query messages, and is put into successively in the formation of three-dimensional space data query messages;

Second communication module, be used for taking out successively the three-dimensional space data query messages from the formation of three-dimensional space data query messages, the idle thread of transferring in the communication thread pond is carried out dissection process, and the three-dimensional space data query messages is converted to three-dimensional space data library inquiry task, put in the data base querying task queue;

The three-dimensional space data scheduler module, be used for respectively taking out idle scheduling thread from scheduling thread pond and database connection pool and be connected execution three-dimensional space data library inquiry task with database, and return Query Result, wherein, described second communication module also is used for receiving described Query Result, data sequence in the described Query Result is turned to the form of byte stream, and compress and obtain compressed data packets, obtain the communication handle of described client, and according to described communication handle described compressed data packets being sent to described client, described first communication module also is used for receiving described compressed data packets;

Described client also comprises data processing module, is used for described compressed data packets is carried out data recombination, decompression and solution sequence operation, obtains three dimensions object to be checked.

2. three-dimension GIS asynchronous communication transmission system as claimed in claim 1, it is characterized in that, described first communication module takes out a piece of news successively by take out the head of an idle thread from message queue from message send-thread pond, send a message to described server, this thread is made as busy condition and locks waits for described server return messages.

3. three-dimension GIS asynchronous communication transmission system as claimed in claim 1, it is characterized in that, after described first communication module is received the message that described server data returns, this notice is issued the data receiver thread, this message send-thread is made as idle condition and release, and is recovered in the idle thread formation in the message send-thread pond.

4. three-dimension GIS asynchronous communication transmission system as claimed in claim 1, it is characterized in that, whether the size that described judge module also is used for judging described compressed data packets greater than fixed value, and described second communication module carries out subpackage to described compressed data packets in described compressed data packets during greater than fixed value.

5. three-dimension GIS asynchronous communication transmission system as claimed in claim 4 is characterized in that, described second communication module also is used for directly described compressed data packets being sent to described client in described compressed data packets during less than or equal to fixed value.

6. such as claim 4 or 5 described three-dimension GIS asynchronous communication transmission systems, it is characterized in that described data processing module carries out data recombination by the header information of resolving described compressed data packets, to obtain complete compressed data packets.

7. three-dimension GIS asynchronous communication transmission method, be used for communicating by letter between client and the server, wherein, comprise the three-dimensional space data storehouse in the described server, be used for the three-dimension GIS data such as management terrain data, image data, city three-dimensional modeling data and attribute data thereof and user and connect permissions data, it is characterized in that, said method comprising the steps of:

Described server open communication is monitored, and monitors the connection request of described client;

Described client is packaged into connection message with connection request, and connection message is sent to described server;

Described server is monitored the described connection message of described client, resolves the connection request parameter in the connection message;

Server obtains the user from described three-dimensional space data storehouse and connects permissions data, judges whether the parameter of described connection request is correct;

If the parameter of described connection request is correct, then described server is set up and being connected of described client;

Described client is packaged into the three-dimensional space data query messages with the three-dimensional space data query requests and sends to described server;

Described server receives described three-dimensional space data query messages, and is put into successively in the formation of three-dimensional space data query messages;

Described server takes out the three-dimensional space data query messages successively from the formation of three-dimensional space data query messages, the idle thread of transferring in the communication thread pond is carried out dissection process, and the three-dimensional space data query messages is converted to three-dimensional space data library inquiry task, put in the data base querying task queue;

Described server is connected with database connection pool from the scheduling thread pond and is taken out respectively idle scheduling thread and is connected execution three-dimensional space data library inquiry task with database, and returns Query Result;

Described server receives described Query Result, and the data sequence in the described Query Result is turned to the form of byte stream, and compresses and obtain compressed data packets;

Described server obtains the communication handle of described client, and according to described communication handle described compressed data packets is sent to described client;

The described compressed data packets of described client;

Described client is carried out data recombination, decompression and solution sequence operation to described compressed data packets, obtains three dimensions object to be checked.

8. three-dimension GIS asynchronous communication transmission method as claimed in claim 7, it is characterized in that, described client is taken out a piece of news successively by take out the head of an idle thread from message queue from message send-thread pond, send a message to described server, this thread is made as busy condition and locks waits for described server return messages.

9. three-dimension GIS asynchronous communication transmission method as claimed in claim 1, it is characterized in that, after described client is received the message that described server data returns, this notice is issued the data receiver thread, this message send-thread is made as idle condition and release, and is recovered in the idle thread formation in the message send-thread pond.

10. three-dimension GIS asynchronous communication transmission method as claimed in claim 7 is characterized in that, and is further comprising the steps of:

Described server judges that whether the size of described compressed data packets is greater than fixed value;

Described server during greater than fixed value, carries out subpackage to described compressed data packets in the size of described compressed data packets;

Compressed data packets after the subpackage is sent to described client according to described communication handle.

11. three-dimension GIS asynchronous communication transmission method as claimed in claim 10 is characterized in that, and is further comprising the steps of:

Described server directly is sent to described client with described compressed data packets according to described communication handle in the size of described compressed data packets during less than or equal to fixed value.

12. such as claim 10 or 11 described three-dimension GIS asynchronous communication transmission methods, it is characterized in that described client is carried out data recombination by the header information of resolving described compressed data packets, to obtain complete compressed data packets.

Images