Disclosure of Invention
In view of the foregoing, it is necessary to provide a data communication method, apparatus, device and storage medium, so as to solve the problem that in the prior art, the amount of data collected by the collection server is large, and there is a large amount of invalid data, and the digital twin platform needs to screen the data before simulation, so that the running state of the simulation device cannot be simulated in real time.
In order to achieve the technical purpose, the application adopts the following technical scheme:
in a first aspect, the present application provides a data communication method, including:
establishing a proxy server, and respectively establishing connection between the digital twin platform and the proxy server and connection between the acquisition server and the proxy server;
packaging the real-time data of the equipment acquired by the acquisition server into a plurality of data packets with different data packet subjects, and sending the data packets to the proxy server;
setting a target data packet theme subscribed by the digital twin platform, and receiving data packets corresponding to the target data packet theme from a plurality of data packets of the proxy server.
In some possible implementations, building a proxy server, respectively building a connection between the digital twin platform and the proxy server and a connection between the acquisition server and the proxy server, including:
constructing a proxy server between the digital twin platform and the acquisition server, and setting a URL address of the proxy server;
when the connection between the digital twin platform/acquisition server and the proxy server fails, modifying the configuration file of the digital twin platform/acquisition server;
based on the configuration file, the connection between the digital twin platform and the proxy server and the connection between the acquisition server and the proxy server are respectively established.
In some possible implementations, the method includes encapsulating real-time data of a device acquired by an acquisition server into a plurality of data packets with different data packet subjects, and sending the plurality of data packets to a proxy server, where the method includes:
sorting and classifying the equipment real-time data to obtain a plurality of kinds of equipment real-time data;
respectively packaging the real-time data of each class of equipment to obtain a plurality of data packets, and setting a data packet theme according to the classification type;
and sending the data packet to the proxy server.
In some possible implementations, encapsulating the real-time data of each class of device to obtain a plurality of data packets, and setting the theme of the data packets according to the class of classification, including:
converting the real-time data of the equipment into data in a preset format;
encrypting and packaging each kind of preset format data into a data packet;
the data packets of the same classification category are set as the same data packet theme.
In some possible implementations, setting a target data packet theme subscribed by the digital twin platform, and receiving a data packet corresponding to the target data packet theme from a plurality of data packets of the proxy server, including:
modifying a configuration file subscription target data packet theme of the digital twin platform based on a preset data communication protocol;
and if the data packet theme in the proxy server is the target data packet theme, receiving the data packet corresponding to the target data packet theme from a plurality of data packets of the proxy server.
In some possible implementations, a packet theme subscribed to by the digital twin platform is set, and when the transmitted packet theme is the packet theme subscribed to by the digital twin platform, the transmitted packet is received, and then the method includes: analyzing the data packet, and correlating the real-time data of the equipment obtained by analysis to a simulation model for simulation.
In some possible implementations, parsing the data packet, associating the parsed device real-time data to a simulation model for simulation includes:
determining a decryption rule according to the encryption mode, and decrypting the data packet to obtain preset format data;
associating the data with a preset format to a simulation model in the digital twin platform, and driving the simulation model to simulate;
when the simulation is abnormal, the proxy server feeds back abnormal information to the acquisition server to stop data transmission.
In a second aspect, the present application also provides a data communication apparatus, comprising:
the connection module is used for building a proxy server, and respectively building the connection between the digital twin platform and the proxy server and the connection between the acquisition server and the proxy server;
the packaging module is used for packaging the real-time data of the equipment acquired by the acquisition server into a plurality of data packets with different data packet subjects and sending the data packets to the proxy server;
the receiving module is used for setting a target data packet theme subscribed by the digital twin platform and receiving data packets corresponding to the target data packet theme from a plurality of data packets of the proxy server.
In a third aspect, the application also provides a data communication device comprising a memory and a processor, wherein,
a memory for storing a program;
and a processor coupled to the memory for executing the program stored in the memory to implement the steps in the data communication method in any one of the above implementations.
In a fourth aspect, the present application also provides a computer readable storage medium storing a computer readable program or instructions which, when executed by a processor, enable the implementation of the steps in a data communication method in any one of the above implementations.
The beneficial effects of adopting the embodiment are as follows: the application relates to a data communication method, a device, equipment and a storage medium, which are used for realizing data communication between a digital twin platform and an acquisition server, wherein the data communication method comprises the following steps: building a proxy server, and respectively building the connection between the digital twin platform and the proxy server and the connection between the acquisition server and the proxy server; packaging the equipment real-time data acquired by the acquisition server into a plurality of data packets with different data packet subjects, and sending the data packets to the proxy server; setting a target data packet theme subscribed by the digital twin platform, and receiving a data packet corresponding to the target data packet theme from the plurality of data packets of the proxy server. According to the application, the proxy server is used as a middleware for carrying out data communication between the digital twin platform and the acquisition server, the equipment to be transmitted is packaged into the data packet, the data packet theme is set, the digital twin platform subscribes to the target data packet theme, the data packet is received only when the data packet theme is the subscribed target data packet theme, the data volume of the transmitted invalid data is greatly reduced, the pressure of the digital twin platform for processing the data is relieved, the digital twin platform can quickly carry out simulation, the real-time performance of the simulation of the digital twin platform is improved, and the running state of the equipment can be known in time.
Detailed Description
The following detailed description of preferred embodiments of the application is made in connection with the accompanying drawings, which form a part hereof, and together with the description of the embodiments of the application, are used to explain the principles of the application and are not intended to limit the scope of the application.
Before describing embodiments of the present application, related words are explained:
URL address: uniform Resource Locator Address, uniform resource locator, commonly called web Address, web Address for short, is a character string on the Internet for describing information resource Address (Address);
port number: an identification of network communications that is used to identify different programs or services so that network devices can more effectively identify the destination and source of the communications;
digital twinning: the method fully utilizes data such as a physical model, sensor update, operation history and the like, integrates simulation processes of multiple disciplines, multiple physical quantities, multiple scales and multiple probabilities, and completes mapping in a virtual space so as to reflect the full life cycle process of corresponding entity equipment;
digital twin platform: is a virtual platform established by a digital twin technology;
and (3) collecting a server: various sensors can be used for collecting various parameters of each device in real time when the device is operated;
proxy server: the middleware connected with the digital twin platform as the acquisition server comprises, but is not limited to, a computer;
DES: all Data Encryption Standard, data encryption standard, is a block algorithm that uses key encryption.
In the description of the present application, the meaning of "a plurality" is two or more, unless explicitly defined otherwise.
Reference herein to "an embodiment" means that a particular feature, structure, or characteristic described in connection with the embodiment may be included in at least one embodiment of the application. The appearances of such phrases in various places in the specification are not necessarily all referring to the same embodiment, nor are separate or alternative embodiments mutually exclusive of other embodiments. Those of skill in the art will explicitly and implicitly appreciate that the embodiments described herein may be combined with other embodiments.
The application provides a data communication method, a data communication device, data communication equipment and a storage medium, and the data communication method, the data communication device, the data communication equipment and the storage medium are respectively described below.
Referring to fig. 1, fig. 1 is a flow chart of an embodiment of a data communication method provided by the present application, and a specific embodiment of the present application discloses a data communication method, which includes:
s101, building a proxy server, and respectively building connection between a digital twin platform and the proxy server and connection between an acquisition server and the proxy server;
s102, packaging real-time data of equipment acquired by an acquisition server into a plurality of data packets with different data packet subjects, and sending the data packets to a proxy server;
s103, setting a target data packet theme subscribed by the digital twin platform, and receiving data packets corresponding to the target data packet theme from a plurality of data packets of the proxy server.
In the above embodiment, the real-time process simulation of the steel mill process system is described, and accurate modeling needs to be performed according to key operation equipment to ensure the modularization of the parts of each action equipment, and then the manufactured model data is imported into the digital twin platform, and the equipment operation action data collected in real time drives the digital twin platform to perform real-time simulation.
The method comprises the steps that a proxy server is built between the digital twin platform and the acquisition server, and two-way communication between the digital twin platform and the acquisition server is realized through the proxy server, and it is noted that only the acquisition server normally transmits equipment operation data to the digital twin platform in real time, and when some special conditions occur, the digital twin platform can also transmit the data to the acquisition server in a reverse direction.
The steel mill process system has a plurality of different devices, the running conditions of all the devices are required to be known, the real-time running data of the different devices and the different types are respectively packaged into data packets, the corresponding data packet theme is also sent to the proxy server side when the data packets are sent, and whether the digital twin platform receives the corresponding data packets is judged through the data packet theme.
According to a preset data communication protocol, the data packet theme received by the digital twin platform is set, so that the digital twin platform can only receive the data packet corresponding to the target data packet theme, a large amount of useless information is prevented from being received by the digital twin platform, the time for data arrangement by the digital twin platform is saved, the running condition of analog equipment can be simulated by the digital twin platform in real time, and the abnormal condition of the equipment can be processed in time.
Compared with the prior art, the data communication method provided by the embodiment is used for realizing data communication between the digital twin platform and the acquisition server, and the data communication method comprises the following steps: building a proxy server, and respectively building the connection between the digital twin platform and the proxy server and the connection between the acquisition server and the proxy server; packaging the equipment real-time data acquired by the acquisition server into a plurality of data packets with different data packet subjects, and sending the data packets to the proxy server; setting a target data packet theme subscribed by the digital twin platform, and receiving a data packet corresponding to the target data packet theme from the plurality of data packets of the proxy server. According to the embodiment of the application, the proxy server is used as a middleware for carrying out data communication between the digital twin platform and the acquisition server, the equipment to be transmitted is packaged into the data packet, the data packet theme is set, the digital twin platform subscribes to the target data packet theme, the data packet is received only when the data packet theme is the subscribed target data packet theme, the data volume of the transmitted invalid data is greatly reduced, the pressure of the digital twin platform for processing the data is relieved, the digital twin platform can quickly carry out simulation, the real-time performance of the simulation of the digital twin platform is improved, and the running state of the equipment can be known in time.
Referring to fig. 2, fig. 2 is a flow chart of an embodiment of step S101 in fig. 1 provided by the present application, in some embodiments of the present application, a proxy server is built, and a connection between a digital twin platform and the proxy server and a connection between an acquisition server and the proxy server are respectively established, including:
s201, constructing a proxy server between a digital twin platform and an acquisition server, and setting a URL address of the proxy server;
s202, when the connection between the digital twin platform/acquisition server and the proxy server fails, modifying the configuration file of the digital twin platform/acquisition server;
s203, based on the configuration file, the connection between the digital twin platform and the proxy server and the connection between the acquisition server and the proxy server are respectively established.
In the above embodiment, after the proxy server is set up between the digital twin platform and the acquisition server, the proxy server may generate a default URL address, where the URL address may include a port number, and when the URL address and the port number of the proxy server are required to be the same as those of the digital twin platform and the acquisition server, the connection between the digital twin platform and the acquisition server may be set up.
It should be noted that, the URL address and port number of the proxy server are set by configuring in the configuration file of the proxy server installation directory, and if not configured, the default URL address and port number of the proxy server are used.
Judging whether the URL address and the port number of the digital twin platform are consistent with those of the proxy server, and if so, establishing connection between the digital twin platform or the acquisition server and the proxy server, and if not, correspondingly modifying the configuration file of the digital twin platform/the configuration file of the acquisition server.
The configuration file and the program file are installed under the same catalog, the format of the configuration file is an xml format, the URL address and the port number are contained in the configuration file, only the URL address and the port number in the configuration file are required to be changed, the connection between the digital twin platform and the proxy server and the connection between the acquisition server and the proxy server are established, and the connection between the digital twin platform and the acquisition server is established through the proxy server.
Referring to fig. 3, fig. 3 is a flowchart of an embodiment of step S102 in fig. 1 provided by the present application, in some embodiments of the present application, real-time data of a device collected by a collecting server is packaged into a plurality of data packets with different data packet subjects, and the plurality of data packets are sent to a proxy server, including:
s301, sorting and classifying the equipment real-time data to obtain a plurality of kinds of equipment real-time data;
s302, respectively packaging real-time data of each class of equipment to obtain a plurality of data packets, and setting a data packet theme according to the classification class;
s303, the data packet is sent to the proxy server.
In the above embodiment, according to different collected devices, the data is classified according to the device types, and then the device various parameter data of each type, such as temperature, pressure, running time, etc., are classified, so as to obtain device real-time data of a plurality of types of device types and parameter types, and after the collection, the device real-time data can be directly sorted, thereby improving the efficiency of data processing and saving time.
The encapsulation of the real-time data of the equipment is also an encryption process, the safety of the data is ensured, the data packet obtained by encapsulation is a data message, the data packet theme is the name of the corresponding data message, and after the data packet theme is set, the data packet theme is automatically associated with the data packet.
And sending the data packet and the data packet theme to the proxy server through a preset data communication protocol. As a preferred embodiment, the preset data communication protocol is a TCP/IP network protocol, or may be a UDP protocol, that is, the data interaction is performed by adopting the mqtt communication mode, which is not limited in the present application, and is implemented by an application layer protocol above the preset data communication protocol.
Referring to fig. 4, fig. 4 is a flowchart of an embodiment of step S302 in fig. 3, where in some embodiments of the present application, real-time data of each type of device is respectively encapsulated to obtain a plurality of data packets, and a data packet theme is set according to a classification type, which includes:
s401, converting real-time data of equipment into preset format data;
s402, encrypting and packaging each type of preset format data into a data packet;
s403, setting the data packets of the same classification type as the same data packet theme.
In the above embodiment, the preset format may be set according to actual needs, and as a preferred embodiment, the preset format in the present application is a JSON format, and the real-time data of the device after sorting and classifying is converted into a standard JSON format string, that is, the preset format data.
The method and the device can encrypt the data in a plurality of modes, and encrypt the preset format data of each type by using the DES, namely, the encapsulation process of the real-time data of the device is completed, and the description of the DES belongs to an encryption mode in the prior art, and the encryption process is not repeated.
The data packet theme is the name of one type of data, so that the data contents of different types can be visually distinguished, and the set data packet theme name must be the same for each type of data, so that the data output is prevented from being wrong.
In some embodiments of the present application, setting a target packet theme subscribed by the digital twin platform, and receiving a packet corresponding to the target packet theme from a plurality of packets of the proxy server, including:
modifying a configuration file subscription target data packet theme of the digital twin platform based on a preset data communication protocol;
and if the data packet theme in the proxy server is the target data packet theme, receiving the data packet corresponding to the target data packet theme from a plurality of data packets of the proxy server.
In the above embodiment, the preset data communication protocol is formed by using a driven service and class library, and the protocol definition content between the two communication platforms includes:
protocol format: the format of the communication data includes the start and end marks, frame header, frame end, data length, data check, etc.
The data transmission mode is as follows: the data transmission modes comprise serial transmission, parallel transmission, synchronous transmission and asynchronous transmission.
Transmission rate: the rate of data transmission, i.e. the number of data bits transmitted per second.
Data coding mode: the coding mode of the data message is, for example, ASCII code and binary code.
Transmission control: the control mode in the data transmission process, such as action signal control, error control and retransmission mechanism.
And (3) data processing: the processing mode of the data is specified, for example, data compression, encryption, decryption, decompression, etc.
Error handling: error handling such as error detection, error correction, error reporting, etc.
Protocol negotiation: the manner in which the negotiation is specified, i.e., the two-party communication needs to negotiate the version of the communication protocol, support characteristics, etc., before it is established.
The subscription target data package theme is realized by modifying the configuration file of the digital twin platform, the subscription of the digital twin platform can be configured by a subscore item in the configuration file, and the data package of the theme name can be obtained from the proxy service middleware by configuring the theme name issued after the encapsulation of the previous acquisition server.
In some embodiments of the present application, a packet theme subscribed to by the digital twin platform is set, and when the transmitted packet theme is the packet theme subscribed to by the digital twin platform, the transmitted packet is received, and then the method includes: analyzing the data packet, and correlating the real-time data of the equipment obtained by analysis to a simulation model for simulation.
Referring to fig. 5, fig. 5 is a flow chart of an embodiment of a data packet analysis simulation provided by the present application, in some embodiments of the present application, analyzing a data packet, associating real-time data of an apparatus obtained by analysis to a simulation model for simulation, including:
s501, determining a decryption rule according to an encryption mode, and decrypting the data packet to obtain preset format data;
s502, associating preset format data to a simulation model in a digital twin platform, and driving the simulation model to simulate;
s503, when the simulation is abnormal, the proxy server feeds back abnormal information to the acquisition server to stop data transmission.
In the above embodiment, since the package needs to encrypt the real-time data of the device, when the data packet is parsed, the data packet needs to be encrypted, and the decryption rule is determined by the encryption method, in this embodiment, the decryption rule is determined according to the DES encryption method, and the data packet is decrypted to obtain the preset format data.
The simulation model in the digital twin platform can directly use the preset format data, and the preset format data is required to be associated with the corresponding simulation model in the digital twin platform, so that the simulation model is driven to perform simulation, the actual running condition of the equipment is known, and the monitoring of the equipment workflow is realized.
The acquisition server and the digital twin platform are in bidirectional communication, the digital twin platform can also publish own information through a data packet theme, and then the acquisition server subscribes to the data packet theme, so that the digital twin platform can also receive data information. When the simulation is abnormal, the simulation model is possibly problematic, or the actual equipment operation is about to be abnormal, at this time, the digital twin platform feeds back the abnormality to the acquisition server through the proxy server, stops acquiring data, and closes the communication link through the proxy server.
It should be noted that, in the present application, there is a process that needs to be fed back, if the acquisition server issues a data packet subject successfully, the proxy server feeds back a success code to the acquisition server, if the communication sender fails to issue, the proxy server feeds back a failure code to the acquisition server; if the subscription of the digital twin platform is successful, the proxy server feeds back a subscription success code to the digital twin platform; if the subscription of the digital twin platform fails, the proxy server feeds back a subscription failure code to the digital twin platform.
In order to better implement the data communication method according to the embodiment of the present application, referring to fig. 6 correspondingly to the data communication method, fig. 6 is a schematic structural diagram of an embodiment of a data communication device according to the present application, and the embodiment of the present application provides a data communication device 600, including:
the connection module 610 is configured to build a proxy server, and respectively establish a connection between the digital twin platform and the proxy server and a connection between the acquisition server and the proxy server;
the encapsulation module 620 is configured to encapsulate real-time data of the device acquired by the acquisition server into a plurality of data packets with different data packet topics, and send the plurality of data packets to the proxy server;
the receiving module 630 is configured to set a target packet theme subscribed by the digital twin platform, and receive a packet corresponding to the target packet theme from a plurality of packets in the proxy server.
What needs to be explained here is: the apparatus 600 provided in the foregoing embodiments may implement the technical solutions described in the foregoing method embodiments, and the specific implementation principles of the foregoing modules or units may be referred to the corresponding content in the foregoing method embodiments, which is not repeated herein.
Referring to fig. 7, fig. 7 is a schematic structural diagram of a data communication device according to an embodiment of the present application. Based on the data communication method, the application also correspondingly provides data communication equipment which can be a mobile terminal, a desktop computer, a notebook computer, a palm computer, a server and other computing equipment. The data communication device includes a processor 710, a memory 720, and a display 730. Fig. 7 shows only some of the components of the data communication device, but it should be understood that not all of the illustrated components are required to be implemented and that more or fewer components may be implemented instead.
Memory 720 may be an internal storage unit of the data communication device in some embodiments, such as a hard disk or memory of the data communication device. The memory 720 may also be an external storage device of the data communication device in other embodiments, such as a plug-in hard disk, smart Media Card (SMC), secure Digital (SD) Card, flash Card (Flash Card) or the like. Further, the memory 720 may also include both internal storage units and external storage devices of the data communication device. The memory 720 is used for storing application software installed on the data communication device and various types of data, such as program codes for installing the data communication device. Memory 720 may also be used to temporarily store data that has been output or is to be output. In one embodiment, the memory 720 has stored thereon a data communication program 740, and the data communication program 740 is executable by the processor 710 to implement the data communication method according to the embodiments of the present application.
The processor 710 may in some embodiments be a central processing unit (Central Processing Unit, CPU), microprocessor or other data processing chip for executing program code or processing data stored in the memory 720, such as performing data communication methods, etc.
The display 730 may be an LED display, a liquid crystal display, a touch-sensitive liquid crystal display, an OLED (Organic Light-Emitting Diode) touch, or the like in some embodiments. Display 730 is used to display information at the data communication device and to display a visual user interface. The components 710-730 of the data communication device communicate with each other via a system bus.
In one embodiment, the steps in the data communication method as described above are implemented when the processor 710 executes the data communication program 740 in the memory 720.
The present embodiment also provides a computer-readable storage medium having stored thereon a data communication program which, when executed by a processor, implements the steps of:
establishing a proxy server, and respectively establishing connection between the digital twin platform and the proxy server and connection between the acquisition server and the proxy server;
packaging the real-time data of the equipment acquired by the acquisition server into a plurality of data packets with different data packet subjects, and sending the data packets to the proxy server;
setting a target data packet theme subscribed by the digital twin platform, and receiving data packets corresponding to the target data packet theme from a plurality of data packets of the proxy server.
In summary, the data communication method, device, equipment and storage medium provided in this embodiment are used to implement data communication between a digital twin platform and an acquisition server, where the data communication method includes: building a proxy server, and respectively building the connection between the digital twin platform and the proxy server and the connection between the acquisition server and the proxy server; packaging the equipment real-time data acquired by the acquisition server into a plurality of data packets with different data packet subjects, and sending the data packets to the proxy server; setting a target data packet theme subscribed by the digital twin platform, and receiving a data packet corresponding to the target data packet theme from the plurality of data packets of the proxy server. According to the application, the proxy server is used as a middleware for carrying out data communication between the digital twin platform and the acquisition server, the equipment to be transmitted is packaged into the data packet, the data packet theme is set, the digital twin platform subscribes to the target data packet theme, the data packet is received only when the data packet theme is the subscribed target data packet theme, the data volume of the transmitted invalid data is greatly reduced, the pressure of the digital twin platform for processing the data is relieved, the digital twin platform can quickly carry out simulation, the real-time performance of the simulation of the digital twin platform is improved, and the running state of the equipment can be known in time.
The present application is not limited to the above-mentioned embodiments, and any changes or substitutions that can be easily understood by those skilled in the art within the technical scope of the present application are intended to be included in the scope of the present application.