CN110069359B - A method for data interaction between a control center and a station terminal and an integrated subway system - Google Patents

Abstract

The invention provides a method for data interaction between a control center and a station and a comprehensive subway system. The validity of the data request and the validity of the returned data are verified at the station and the control center respectively, and the control center and the station are realized. The real-time data interaction at the terminal ensures the accuracy and reliability of real-time data interaction. At the same time, the new data request of the control center and the existing data request may need to obtain some of the same data. In this method, the regular The update method is to add the data index in the new request, instead of directly copying and updating the data index to the two tables, which improves the speed of real-time data interaction and has wide application value.

Description

A method for data interaction between a control center and a station terminal and a comprehensive subway system

technical field

The invention belongs to the technical field of data interaction, and in particular relates to a method for data interaction between a control center and a station end and a comprehensive subway system.

Background technique

At present, urban transportation construction is in full swing. As the country further promotes the strategy of comprehensive pipe corridors and sponge cities, large and medium-sized cities in my country will surely set off a new round of underground engineering construction. Subway construction is vigorously promoted, and there are more and more subway operating lines in various places. The mileage is getting longer and longer, and the subway has become the first choice for citizens to travel. However, in the construction of urban transportation, the traditional subway network lines are invisible, there are many types, and the management and maintenance are very difficult. The operation of the subway has brought more and more challenges to the construction of the subway station. For complex subway construction, it is necessary to set up a monitoring system. The monitoring system adopts an integrated software and hardware platform and a dedicated communication network, such as power supply system, environment and equipment monitoring system, fire alarm system, signal system, broadcasting system, passenger information system, etc. Several professional real-time data and environmental parameters, and remote control of the operation of each professional system, which inevitably involves the compilation and configuration of thousands of operating equipment and hundreds of thousands of data measuring points, structure organization and logic application. Since there are multiple control center terminals and station terminals in the subway monitoring system, each control center may need to obtain data from multiple station terminals. Due to the large and complex data volume, the accuracy of the real-time interactive data of the subway monitoring system The requirements for performance, reliability and rapidity are getting higher and higher, and a series of solutions have been proposed for this problem, such as the publication number "CN106776854A", the name is "A data bonding structure and processing method suitable for the comprehensive monitoring system of the subway Method” Chinese patent, the relational real-time database of this patent is constructed using object-oriented technology, each physical device is represented as a data object in the relational real-time database, the gluer is designed according to the application requirements, and the application is interested in The data is rearranged into an orderly structure through data association, and the auxiliary information of the new structure is configured, and finally the most accurate data organization form is presented to advanced applications. The solution provided by this patent does not verify the collected data, so that There are certain errors in the acquired data, resulting in low analysis effectiveness of the collected subway data, which further leads to low accuracy and reliability of the subway monitoring system.

Contents of the invention

The object of the present invention is to provide a method for data interaction between a control center and a station terminal and a subway comprehensive system, which are used to solve the problem of low accuracy and reliability of the subway data monitoring system in the prior art.

In order to achieve the above object, the present invention provides a method for data interaction between the control center and the station, including the following technical solutions:

Method scheme 1, a method for data interaction between a control center and a station, including the following steps:

1) Each control center generates a data index according to the data access request, and the data index includes a table name, a row ID value, and a column subscription symbol; according to the data index, the station end to be accessed by the data request is judged, and the data index of the same station end is accessed organize together;

2) Each control center performs the first CRC redundancy check on the data index of the station to be accessed, and obtains the check code corresponding to the single data index of each station and the total check code of all data indexes; Obtain the global subscription information table corresponding to the station to be accessed through the data index of the terminal, the check code of each data index, and the name of the station to be accessed; send the global subscription information table corresponding to each station to the corresponding station;

3) The station to be accessed checks the received global subscription information table. If the verification is valid, the data index in the global subscription information table of the station to be accessed is added to the release table, and obtained according to the data index in the release table. Data on the site side to be accessed;

4) The station to be accessed sends the acquired data to each control center, and each control center publishes the data of the station to be accessed.

Method scheme two, on the basis of method scheme one, after obtaining the data of the station to be accessed according to the data index in the release table, each control center performs the second CRC redundancy check on the data index in the release table, and obtains the data to be accessed The check code corresponding to a single data index at the station end and the total check code of all data indexes.

Method 3: On the basis of method 2, each control center checks the check code corresponding to the single data index of the station to be accessed and the total check code of all data indexes. If the check is valid, each control center The control center publishes data on the station side to be accessed.

Method 4: On the basis of method 3, the data index generated according to the data access request exists within the set time, and if the data index is not subscribed beyond the set time, the data index is deleted.

Method scheme five, on the basis of method scheme four, the station to be accessed releases data according to the data index in the release table after a set time interval.

The present invention also provides a comprehensive subway system, including the following technical solutions:

System solution 1, a comprehensive subway system, including at least one control center and at least one station terminal, each control center is respectively connected to each station terminal by communication, each control center is used to generate a data index according to a data access request, and the data index includes table name, row ID value, and column subscription symbol; judge the station end to be accessed according to the data index, organize the data indexes that visit the same station end together; and perform the first CRC check on the data index of the station end to be accessed According to the data index of the station to be accessed, the check code of each data index and the name of the station to be accessed, the key is obtained The global subscription information table corresponding to the station to be accessed; the global subscription information table corresponding to each station is sent to the corresponding station; the station to be accessed checks the received global subscription information table, if the verification is valid, Then add the data index in the global subscription information table of the station to be accessed to the release table, and obtain the data of the station to be accessed according to the data index in the release table; and the station to be accessed sends the acquired data to each control center, Each control center distributes data on the station side to be accessed.

System scheme two, on the basis of system scheme one, after obtaining the data of the station to be accessed according to the data index in the release table, each control center performs the second CRC redundancy check on the data index in the release table, and obtains the data to be accessed The check code corresponding to a single data index at the station end and the total check code of all data indexes.

System scheme three, on the basis of system scheme two, each control center checks the check code corresponding to the single data index of the station to be accessed and the total check code of all data indexes. If the check is valid, each control center The control center publishes data on the station side to be accessed.

System Solution 4: On the basis of System Solution 3, the data index generated according to the data access request exists within the set time, and if the data index is not subscribed beyond the set time, the data index is deleted.

System scheme five, on the basis of system scheme four, the station to be accessed publishes data according to the data index in the release table after a set time interval.

The beneficial effects of the present invention are:

The present invention checks the validity of the data request and the validity of the returned data at the station and the control center, realizes the real-time data interaction between the control center and the station, and ensures the accuracy and reliability of the real-time data interaction. , each control center’s new data request and the existing data request may need to obtain some of the same data. In this method, the regular update method of the subscription table and the release table is to add the data index in the new request instead of directly The data index is copied and updated to two tables, which improves the speed of real-time data interaction and has wide application value.

Description of drawings

1 is a schematic flow diagram of a method for real-time data interaction between a control center and a station according to an embodiment of the present invention;

FIG. 2 is a schematic structural diagram of a method for real-time data interaction between a control center and a station according to an embodiment of the present invention.

Detailed ways

The specific embodiment of the present invention will be further described below in conjunction with accompanying drawing:

The present invention provides a comprehensive subway system, including at least one control center and at least one station terminal, and each control center is connected to each station terminal by communication, as shown in Figure 2, including two control centers and N station terminals. The system realizes the interaction of real-time data through the control center issuing the subscription form, and the station returns the release form. In order to judge the consistency of data sent and received by the control center and the station, it is necessary to perform a consistency check on the data index Key in the subscription table and the release table. Based on this system, the present invention provides a method for data interaction between the control center and the station end. The data interaction method can be applied to other integrated monitoring systems outside the primary subway. The specific method for the data interaction between the control center and the station end is shown in Figure 1 shown, including the following steps:

1. Send a station-side data access request. Each data in the subway comprehensive system has an id as a unique index, and each id corresponds to a row of data in a table, so an id may correspond to many fields.

2. Generally, what the control center wants to obtain is not all the data of an id, but the data of one or some fields. When a certain control center wants to obtain these data from multiple stations, the control center will first use the The data request generates a data index Key, Key={table name, row id value, column subscription symbol}.

3. The control center judges which station is to be accessed by the data request through the id, and organizes the Keys that access the same station together, assuming that there are N data index keys to access a certain station, and N is an integer.

4. Perform the first CRC cyclic redundancy check on the single data index Key accessing the station, and respectively obtain the check codes CC1-CCN corresponding to the single data index.

5. Add the check codes CC1 to CCN of a single data index to obtain the total check code CC of all Keys at this time.

6. The control center organizes the control center according to the data index Key of the station to be accessed, CC1~CCN corresponding to each data index, the number N of stations to be accessed, the total check code CC of the data index, and the name of the station to be accessed Subscription information table on the station side of this visit.

7. The control center can divide the subscription information table into M mutually unrelated parts, each part is the global subscription information table of a station by the control center, M is the number of stations, and M is an integer, that is, the control center will The key in the subscription information list of the station is added to the global subscription information table of the station, and the verification information is generated according to the verification method in steps 4 and 5 again, and the global subscription information table of the station is obtained. The structure of the global subscription information table is as follows Table 1 shows:

Table 1 Subscription information table of the station to be accessed

CC Number of objects N Subscribe to Key1+CC1 ... Subscribe to KeyN+CCN customer mark

Among them, the number of objects is the number of Keys in the subscription information, CC1~CCN is the check code of a single data index Key1~KeyN, CC is the total check code of Key1~KeyN, and the customer mark is the station name of the corresponding station.

8. The control center sends the global subscription information table of each station to be accessed to the message bus, and sends it to each station to be accessed via the message bus.

9. After receiving the subscription information, the corresponding station first performs cyclic redundancy check according to the methods in step 4 and step 5, compares the obtained check code with the check code in the global subscription information table, and checks the subscription Check whether the list is valid to determine whether the global subscription information table is damaged during transmission. If the verification is inconsistent, the data will be discarded.

10. If the verification is valid, after each station obtains the global subscription information table sent by the control center, it does not directly synchronize, but adds the data index Key in the global subscription information table to the local release table, according to the Key in the release table Obtain the data locally, and perform the second cyclic redundancy check on the Key in the release table according to the method in step 4 and step 5, and obtain the check code SC1-SCN and the total check code SC of a single Key.

11. According to the Key, SC1~SCN, N, SC and the name of the receiving control center, organize the publication and subscription form of the station as shown in Table 2, and the format is as follows:

Table 2 Station-side publish-subscribe information table

Among them, the number of objects N is the number of Keys in the subscription information, SC1~SCN is the check code of a single data index Key1~KeyN, SC is the total check code of Key1~KeyN, and the customer mark is the name of the corresponding control center.

12. The station will send the released data to each control center via the message bus. In order to verify that the data finally obtained by the control center is correct and complete, the control center will publish the check code of the single data index in the table and the checksum of the total data index Whether the code is equal to that in the global subscription information, that is, to judge whether CC and SC, CC1~CCN are equal, if all are equal, the data that passes the verification is available, and each control center publishes the data of each station, as shown in Figure 2. If any of the check codes are not equal, the control center will issue a synchronization command to force synchronization of the Key in the global subscription table of the corresponding station and the station of the control center.

13. The Key in the global subscription information table exists for a certain period of time. If there is no continuous subscription to the data index Key after timeout, the Key will be deleted in the subscription table, and then the control center will send an instruction to the corresponding station to delete the corresponding key in the release table of the station. the Key.

14. The station releases data through the data index Key in the table in a fixed time interval cycle.

The method of the present invention can realize the real-time data interaction between the control center and the station terminal. Before using the data, the method of the present invention checks the validity of the data request and the validity of the returned data respectively at the station terminal and the control center terminal, ensuring The accuracy and reliability of real-time data interaction. At the same time, the new data request of the control center may obtain some of the same data as the existing data request. In this method, the regular update method of the subscription information table and the release table is to add new The Key in the request, instead of directly copying and updating the Key to the two tables, improves the speed of real-time data interaction and has a wide range of application values.

Specific implementations have been given above, but the present invention is not limited to the above-described implementations. The basic idea of the present invention lies in the above-mentioned basic scheme. For those of ordinary skill in the art, according to the teaching of the present invention, it does not need to spend creative labor to design various deformation models, formulas, and parameters. Changes, modifications, substitutions and variations to the implementations without departing from the principle and spirit of the present invention still fall within the protection scope of the present invention.

Claims (10)

1. A method for control center and station end data interaction, is characterized in that, comprises the steps: 1) Each control center generates a data index according to the data access request, and the data index includes a table name, a row ID value, and a column subscription symbol; according to the data index, the station end to be accessed by the data request is judged, and the data index of the same station end is accessed organize together; 2) Each control center performs the first CRC redundancy check on the data index of the station to be accessed, and obtains the check code corresponding to the single data index of each station and the total check code of all data indexes; Obtain the global subscription information table corresponding to the station to be accessed through the data index of the terminal, the check code of each data index, and the name of the station to be accessed; send the global subscription information table corresponding to each station to the corresponding station; 3) The station to be accessed checks the received global subscription information table. If the verification is valid, the data index in the global subscription information table of the station to be accessed is added to the release table, and obtained according to the data index in the release table. Data on the site side to be accessed; 4) The station to be accessed sends the acquired data to each control center, and each control center publishes the data of the station to be accessed. 2. the method for control center and station end data interaction according to claim 1, it is characterized in that, after obtaining the data of the station end to be visited according to the data index in the release table, each control center carries out the data index in the release table The second CRC redundancy check is to obtain the check code corresponding to the single data index of the station to be accessed and the total check code of all data indexes. 3. The method for data interaction between the control center and the station end according to claim 2, characterized in that each control center obtains a check code corresponding to a single data index of the station end to be accessed and a total checksum of all data indexes The code is verified, and if the verification is valid, each control center releases the data of the station to be accessed. 4. The method for data interaction between the control center and the station according to claim 3, wherein the data index generated according to the data access request exists within the set time, and if the data index is not updated beyond the set time index subscription, delete the data index. 5. The method for data interaction between the control center and the station according to claim 4, wherein the station to be visited releases data according to the data index in the release table after a set time interval. 6. A comprehensive subway system, characterized in that it comprises at least one control center and at least one station end, each control center is respectively connected to each station end in communication, each control center is used to generate a data index according to a data access request, and the data The index includes table name, row ID value, and column subscription symbol; judge the station to be accessed by the data request according to the data index, and organize the data indexes that visit the same station together; and perform the first CRC check, obtain the check code corresponding to the single data index of each station and the total check code of all data indexes; according to the data index of the station to be accessed, the check code of each data index and the name of the station to be accessed Obtain the global subscription information table corresponding to the station to be accessed; send the global subscription information table corresponding to each station to the corresponding station; the station to be accessed will verify the received global subscription information table, if the verification If it is valid, add the data index in the global subscription information table of the station to be accessed to the release table, and obtain the data of the station to be accessed according to the data index in the release table; and the station to be accessed will send the acquired data to each controller Center, each control center releases the data of the station to be accessed. 7. subway integrated system according to claim 6, it is characterized in that, after obtaining the data of the station end to be visited according to the data index in the release table, each control center carries out the second CRC redundancy check to the data index in the release table Check, get the check code corresponding to the single data index of the station to be accessed and the total check code of all data indexes. 8. The comprehensive subway system according to claim 7, wherein each control center checks the check code corresponding to the single data index of the station end to be accessed and the total check code of all data indexes, if The verification is valid, and each control center releases the data of the station to be accessed. 9. The comprehensive subway system according to claim 8, wherein the data index generated according to the data access request exists within the set time, and if the data index is not subscribed to within the set time, the data index will be deleted. data index. 10. The comprehensive subway system according to claim 9, wherein the station terminal to be visited releases data according to the data index in the release table after a set time interval.

Images