CN117539439B - Lightweight real-time application development method, device, equipment and storage medium - Google Patents
Lightweight real-time application development method, device, equipment and storage medium Download PDFInfo
- Publication number
- CN117539439B CN117539439B CN202410028227.0A CN202410028227A CN117539439B CN 117539439 B CN117539439 B CN 117539439B CN 202410028227 A CN202410028227 A CN 202410028227A CN 117539439 B CN117539439 B CN 117539439B
- Authority
- CN
- China
- Prior art keywords
- application
- real
- time
- containerized
- user terminal
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F8/00—Arrangements for software engineering
- G06F8/20—Software design
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/30—Monitoring
- G06F11/3003—Monitoring arrangements specially adapted to the computing system or computing system component being monitored
- G06F11/302—Monitoring arrangements specially adapted to the computing system or computing system component being monitored where the computing system component is a software system
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/30—Monitoring
- G06F11/3051—Monitoring arrangements for monitoring the configuration of the computing system or of the computing system component, e.g. monitoring the presence of processing resources, peripherals, I/O links, software programs
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F8/00—Arrangements for software engineering
- G06F8/30—Creation or generation of source code
- G06F8/31—Programming languages or programming paradigms
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/44—Arrangements for executing specific programs
- G06F9/455—Emulation; Interpretation; Software simulation, e.g. virtualisation or emulation of application or operating system execution engines
- G06F9/45533—Hypervisors; Virtual machine monitors
- G06F9/45558—Hypervisor-specific management and integration aspects
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/44—Arrangements for executing specific programs
- G06F9/455—Emulation; Interpretation; Software simulation, e.g. virtualisation or emulation of application or operating system execution engines
- G06F9/45533—Hypervisors; Virtual machine monitors
- G06F9/45558—Hypervisor-specific management and integration aspects
- G06F2009/45562—Creating, deleting, cloning virtual machine instances
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/44—Arrangements for executing specific programs
- G06F9/455—Emulation; Interpretation; Software simulation, e.g. virtualisation or emulation of application or operating system execution engines
- G06F9/45533—Hypervisors; Virtual machine monitors
- G06F9/45558—Hypervisor-specific management and integration aspects
- G06F2009/45595—Network integration; Enabling network access in virtual machine instances
-
- Y—GENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
- Y02—TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
- Y02D—CLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
- Y02D10/00—Energy efficient computing, e.g. low power processors, power management or thermal management
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Software Systems (AREA)
- General Engineering & Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Physics & Mathematics (AREA)
- Computing Systems (AREA)
- Quality & Reliability (AREA)
- Mathematical Physics (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The invention relates to the technical field of application development, and discloses a lightweight real-time application development method, a device, equipment and a storage medium, wherein the method comprises the following steps: the real-time application is containerized to obtain containerized application; distributing mirror image applications contained in the containerized applications to the edge nodes; the method comprises the steps that real-time data output by a user terminal after mirror image application is used are collected through an edge node, and containerized application is monitored based on the real-time data; and judging whether to develop the containerized application in real time based on the monitoring result. According to the invention, the real-time application is distributed to the edge node after being containerized, and the real-time data output by the user terminal is acquired through the edge node, so that the development of the real-time application after the distributed acquisition and monitoring of the real-time data is realized, the technical problems of data congestion, data processing delay and the like caused by the need of uniformly scheduling all the data in the prior art are avoided, and the development efficiency of the real-time application can be further improved.
Description
Technical Field
The present invention relates to the field of application development technologies, and in particular, to a method, an apparatus, a device, and a storage medium for lightweight real-time application development.
Background
In the context of the rapid development of information technology and the high demands of users for the response speed of applications, real-time applications have grown. A real-time application is an application or system that is capable of responding to events and data on-the-fly or nearly-on-the-fly, which generally requires processing of input data and the production of corresponding output in a very short time to meet the real-time needs of a user or system.
The existing real-time application development method generally uploads all user demands to a server to be developed after unified scheduling processing, however, due to the increase of the user body volume, the data generated by the real-time application is also increased. Therefore, when the existing real-time application development method is applied to a scene with high concurrency such as large data volume, high data receiving and transmitting frequency, the technical problems of data congestion and delay of data processing can occur, so that development efficiency is low. Based on this, there is a need in the industry for a method that can improve the development efficiency of real-time applications.
The foregoing is provided merely for the purpose of facilitating understanding of the technical solutions of the present invention and is not intended to represent an admission that the foregoing is prior art.
Disclosure of Invention
The invention mainly aims to provide a light-weight real-time application development method, a light-weight real-time application development device, light-weight real-time application development equipment and a storage medium, and aims to solve the technical problem that the existing real-time application development method is low in efficiency under a scene of high data concurrency.
In order to achieve the above object, the present invention provides a lightweight real-time application development method, which includes the steps of:
the method comprises the steps of containerizing a real-time application to obtain a containerized application, wherein the real-time application is constructed according to acquired user demand data;
distributing mirror image applications contained in the containerized applications to edge nodes, wherein the edge nodes are connected with user terminals;
acquiring real-time data output by the user terminal after the mirror image application is used by the edge node, and monitoring the containerized application based on the real-time data;
and judging whether to develop the containerized application in real time based on the monitoring result.
Optionally, the step of containerizing the real-time application to obtain the containerized application includes:
acquiring user demand data, and determining an objective function based on the user demand data, wherein the objective function is stored in a preset function library;
and calling the objective function to construct a real-time application, and containerizing the real-time application in a manner of packaging the real-time application into a portable container to obtain the containerized application.
Optionally, the step of distributing the mirror application contained in the containerized application to an edge node includes:
acquiring node information of an edge node, and determining an optimal application distribution mode corresponding to the edge node based on the node information, wherein the optimal application distribution mode comprises a cloud distribution mode, a local network distribution mode and a storage medium distribution mode;
and distributing the mirror image application contained in the containerized application to the edge node according to the optimal application distribution mode.
Optionally, before the step of collecting, by the edge node, real-time data output by the user terminal after the mirror application is used and monitoring the containerized application based on the real-time data, the method further includes:
acquiring terminal basic elements of the user terminal through the edge node, wherein the terminal basic elements comprise user identifiers and equipment identifiers of the user terminal;
searching in an abnormal terminal library by taking the terminal basic elements as keywords, and judging whether the user terminal belongs to the abnormal terminal library or not, wherein the abnormal terminal library is constructed based on a alliance chain;
if the user terminal belongs to an abnormal terminal library, judging that the user terminal is an abnormal terminal, terminating the connection between the edge node and the user terminal, and outputting an abnormal report.
Optionally, after the step of searching in the abnormal terminal library by using the terminal basic element as a keyword and judging whether the user terminal belongs to an abnormal terminal based on a search result, the method further includes:
if the user terminal does not belong to the abnormal terminal library, inquiring behavior data corresponding to the user terminal in a database by taking the terminal basic element as a keyword;
judging whether the user terminal has abnormal behaviors according to the behavior data;
if the user terminal has abnormal behaviors, determining the user terminal as abnormal equipment, and storing terminal basic elements corresponding to the abnormal equipment into the abnormal terminal library;
and if the user terminal does not have abnormal behaviors, executing the steps of acquiring the real-time data output by the user terminal after the mirror image application is used by the edge node and monitoring the containerized application based on the real-time data.
Optionally, the step of collecting, by the edge node, real-time data output by the user terminal after using the mirroring application includes:
writing a data acquisition script based on a data transmission protocol compatible with the edge node and the user terminal;
and executing the data acquisition script in the edge node to obtain real-time data output by the user terminal.
Optionally, the step of determining whether to develop the containerized application in real time based on the monitoring result includes:
judging whether the containerized application has a developable project or not based on a monitoring result;
if the development project exists, constructing a DAG task according to the priority and the dependency relationship corresponding to the development project, wherein the arrangement mode of the DAG task is pipeline arrangement;
and developing the containerized application in real time according to the DAG task.
In addition, in order to achieve the above object, the present invention also proposes a lightweight real-time application development apparatus including:
the application construction module is used for containerizing the real-time application to obtain containerized application, and the real-time application is constructed according to the acquired user demand data;
the application distribution module is used for distributing the mirror image application contained in the containerized application to an edge node, and the edge node is connected with a user terminal;
the application monitoring module is used for acquiring real-time data output by the user terminal after the mirror image application is used through the edge node and monitoring the containerized application based on the real-time data;
and the application development module is used for judging whether to develop the containerized application in real time based on the monitoring result.
In addition, to achieve the above object, the present invention also proposes a lightweight real-time application development apparatus, the apparatus comprising: a memory, a processor, and a lightweight real-time application development program stored on the memory and executable on the processor, the lightweight real-time application development program configured to implement the steps of the lightweight real-time application development method as described above.
In addition, in order to achieve the above object, the present invention also proposes a storage medium having stored thereon a lightweight real-time application development program which, when executed by a processor, implements the steps of the lightweight real-time application development method as described above.
The method comprises the steps of obtaining a containerized application by containerizing a real-time application, wherein the real-time application is constructed according to acquired user demand data; distributing mirror image applications contained in the containerized applications to edge nodes, wherein the edge nodes are connected with user terminals; acquiring real-time data output by the user terminal after the mirror image application is used by the edge node, and monitoring the containerized application based on the real-time data; and judging whether to develop the containerized application in real time based on the monitoring result. Compared with the traditional real-time application development method, the method disclosed by the invention has the advantages that the real-time application is distributed to the edge nodes after being containerized, and the real-time data output by the user terminal is acquired through the edge nodes, so that the development of the real-time application after the distributed acquisition and monitoring of the real-time data is realized, the technical problems of data congestion, data processing delay and the like caused by the fact that the unified scheduling processing is required for all the data in the prior art are avoided, and the development efficiency of the real-time application can be further improved.
Drawings
FIG. 1 is a schematic structural diagram of a lightweight real-time application development device for a hardware operating environment according to an embodiment of the present invention;
FIG. 2 is a flow chart of a first embodiment of a lightweight real-time application development method of the present invention;
FIG. 3 is a flow chart of a second embodiment of the lightweight real-time application development method of the present invention;
FIG. 4 is a flow chart of a third embodiment of a lightweight real-time application development method according to the present invention;
fig. 5 is a block diagram of a first embodiment of a lightweight real-time application development device according to the present invention.
The achievement of the objects, functional features and advantages of the present invention will be further described with reference to the accompanying drawings, in conjunction with the embodiments.
Detailed Description
It should be understood that the specific embodiments described herein are for purposes of illustration only and are not intended to limit the scope of the invention.
Referring to fig. 1, fig. 1 is a schematic structural diagram of a lightweight real-time application development device of a hardware running environment according to an embodiment of the present invention.
As shown in fig. 1, the lightweight real-time application development device may include: a processor 1001, such as a central processing unit (Central Processing Unit, CPU), a communication bus 1002, a user interface 1003, a network interface 1004, a memory 1005. Wherein the communication bus 1002 is used to enable connected communication between these components. The user interface 1003 may include a Display, an input unit such as a Keyboard (Keyboard), and the optional user interface 1003 may further include a standard wired interface, a wireless interface. The network interface 1004 may optionally include a standard wired interface, a Wireless interface (e.g., a Wireless-Fidelity (Wi-Fi) interface). The Memory 1005 may be a high-speed random access Memory (Random Access Memory, RAM) or a stable nonvolatile Memory (NVM), such as a disk Memory. The memory 1005 may also optionally be a storage device separate from the processor 1001 described above.
Those skilled in the art will appreciate that the architecture shown in fig. 1 is not limiting of a lightweight real-time application development device, and may include more or fewer components than shown, or may combine certain components, or a different arrangement of components.
As shown in fig. 1, an operating system, a network communication module, a user interface module, and a lightweight real-time application development program may be included in the memory 1005 as one type of storage medium.
In the lightweight real-time application development device shown in fig. 1, the network interface 1004 is mainly used for data communication with a network server; the user interface 1003 is mainly used for data interaction with a user; the processor 1001 and the memory 1005 in the lightweight real-time application development device of the present invention may be disposed in the lightweight real-time application development device, and the lightweight real-time application development device calls the lightweight real-time application development program stored in the memory 1005 through the processor 1001 and executes the lightweight real-time application development method provided by the embodiment of the present invention.
The embodiment of the invention provides a lightweight real-time application development method, and referring to fig. 2, fig. 2 is a schematic flow chart of a first embodiment of the lightweight real-time application development method.
In this embodiment, the lightweight real-time application development method includes the following steps:
step S10: and the real-time application is containerized to obtain containerized application, and the real-time application is constructed according to the acquired user demand data.
It should be noted that, the execution body of the method of this embodiment may be a terminal device having functions of application construction, data processing, and program running, for example, a smart phone, a smart watch, or the like, or may be an electronic device having the same or similar functions, for example, the lightweight real-time application development device described above. Hereinafter, this embodiment and the following embodiments will be described by taking a lightweight real-time application development device (hereinafter referred to as development device) as an example.
It will be appreciated that the real-time application may be an application or system capable of responding to events and data immediately or nearly immediately, which generally requires processing of incoming data and the production of corresponding output in a very short period of time to meet the real-time requirements of the user or system. In particular, the real-time applications described above may include hard real-time applications (e.g., industrial automation applications, flight control applications, etc.) and soft real-time applications (e.g., video streaming applications, financial transaction type applications, etc.), to which the present embodiment is not limited.
It should be appreciated that the containerized application described above is an application that packages an application and all its dependent items (e.g., libraries, configuration files, and environment variables) into a single container. In particular, the containerized application may be a stand-alone unit that contains all of the applications and all of the components required for their operation, which allows the containerized application to operate in different environments without being affected by external environments. In addition, the independent units contained in the containerized application can share the kernel of the host operating system without running a complete virtual operating system, which makes the containerized application start up fast and occupies less system resources.
Step S20: and distributing the mirror image application contained in the containerized application to an edge node, wherein the edge node is connected with a user terminal.
It should be noted that the above-mentioned mirror applications may be differentiated from independent units in the containerized applications, and each mirror application includes an application program corresponding to the containerized application in running and all the components required by the application program.
It should be understood that the edge node may refer to a computing device or a server node distributed at an edge of a network or at a remote geographic location, and the user terminal may include an internet of things device, a sensor, a mobile device, or an edge computing server, which is not limited in this embodiment.
Step S30: and acquiring real-time data output by the user terminal after the mirror image application is used by the edge node, and monitoring the containerized application based on the real-time data.
It should be noted that the real-time data may include sensor data (such as temperature, humidity, pressure, light, sound, etc.), location data (such as longitude, latitude, etc.), network data (such as network bandwidth, network delay, packet loss rate, etc.), security data (such as digital certificate information, secret key, privacy item, etc.), and the embodiment is not limited thereto.
In a specific implementation, after detecting that the user terminal uses the mirror image application, the edge node may collect real-time data from the user terminal at intervals of a preset time (for example, 30 seconds, 1 minute, etc.), and compare the collected real-time data with a preset threshold, so as to monitor the containerized application.
Step S40: and judging whether to develop the containerized application in real time based on the monitoring result.
In a specific implementation, if the real-time data output by the user terminal with the preset duty ratio (for example, 50% and 80%) fed back by the monitoring result exceeds the preset threshold, then it may be determined that real-time development of the containerized application is required at this time. For example, assuming that the preset threshold corresponding to the preset response feedback time is 20ms, the preset duty ratio is 50%, and the response feedback time of 60% of the user terminals acquired at a certain moment exceeds 20ms, then parameters related to the response feedback time in the containerized application can be called at this moment, and the containerized application is developed in real time based on the parameters until the response feedback time corresponding to the developed containerized application is less than or equal to 20ms, and then the developed containerized application is resent to the user terminals through the edge node.
According to the embodiment, the containerized application is obtained by containerizing the real-time application, and the real-time application is constructed according to the acquired user demand data; distributing mirror image applications contained in the containerized applications to edge nodes, wherein the edge nodes are connected with user terminals; acquiring real-time data output by the user terminal after the mirror image application is used by the edge node, and monitoring the containerized application based on the real-time data; and judging whether to develop the containerized application in real time based on the monitoring result. Compared with the traditional real-time application development method, the method disclosed by the embodiment has the advantages that the real-time application is distributed to the edge nodes after being containerized, and the real-time data output by the user terminal is acquired through the edge nodes, so that the development of the real-time application after the distributed acquisition and monitoring of the real-time data is realized, the technical problems of data congestion, data processing delay and the like caused by the fact that the unified scheduling processing is required for all the data in the prior art are avoided, and the development efficiency of the real-time application can be improved.
Referring to fig. 3, fig. 3 is a flow chart of a second embodiment of the lightweight real-time application development method of the present invention.
Based on the first embodiment, in this embodiment, the step S10 may include:
step S101: and acquiring user demand data, and determining an objective function based on the user demand data, wherein the objective function is stored in a preset function library.
Step S102: and calling the objective function to construct a real-time application, and containerizing the real-time application in a manner of packaging the real-time application into a portable container to obtain the containerized application.
It should be noted that the portable container refers to a containerized application that can run smoothly in different environments without modification or recompilation of the application.
Further, in this embodiment, in order to take different application distribution manners when facing different edge nodes, so as to improve the distribution efficiency, the step S20 may include:
step S201: acquiring node information of an edge node, and determining an optimal application distribution mode corresponding to the edge node based on the node information, wherein the optimal application distribution mode comprises a cloud distribution mode, a local network distribution mode and a storage medium distribution mode.
It should be noted that, the node information may include an identifier (for distinguishing different nodes), operating system information (for compatibility checking), network configuration (for network communication and connection), node status (for monitoring node operation conditions), log information (for troubleshooting and auditing), and the like, which is not limited in this embodiment.
It should be understood that the local network distribution manner may be distributed through FTP (File Transfer Protocol ), SCP (Secure Copy Protocol, secure copy protocol), HTTP (Hypertext Transfer Protocol ) server, etc., and the storage medium distribution manner may be distributed through USB (Universal Serial Bus ) drive, DVD, etc., which is not limited in this embodiment.
Step S202: and distributing the mirror image application contained in the containerized application to the edge node according to the optimal application distribution mode.
Based on the first embodiment, in this embodiment, in order to avoid a data transmission error between the edge node and the user terminal, the step S30 may include:
step S301: and writing a data acquisition script based on a data transmission protocol compatible with the edge node and the user terminal.
It should be appreciated that the data transfer protocols described above may include, but are not limited to, TCP (Transmission Control Protocol ), UDP (User Datagram Protocol, user datagram protocol), RTP (Real-time Transport Protocol ), MQTT (Message Queuing Telemetry Transport, message queue telemetry transport), SMTP (Simple Mail Transfer Protocol, simple mail transport protocol), FTP (File Transfer Protocol ), and the like.
Step S302: and executing the data acquisition script in the edge node to obtain real-time data output by the user terminal.
Based on the first embodiment, in this embodiment, in order to further improve the development efficiency of the containerized application, the step S40 may include:
step S401: and judging whether the containerized application has a developable project or not based on the monitoring result.
Step S402: if the development project exists, a DAG task is constructed according to the priority and the dependency relationship corresponding to the development project, and the arrangement mode of the DAG task is pipeline arrangement.
It should be noted that the DAG (Directed Acyclic Graph ) task may be a task composed of a plurality of developable projects, where there is a priority order and a dependency relationship between the developable projects.
Step S403: and developing the containerized application in real time according to the DAG task.
In a specific implementation, the DAG tasks described above may be performed, thereby enabling real-time development of containerized applications.
According to the embodiment, the user demand data are obtained, and the objective function is determined based on the user demand data and is stored in a preset function library; calling the objective function to construct a real-time application, and containerizing the real-time application in a manner of packaging the real-time application into a portable container to obtain a containerized application; acquiring node information of an edge node, and determining an optimal application distribution mode corresponding to the edge node based on the node information, wherein the optimal application distribution mode comprises a cloud distribution mode, a local network distribution mode and a storage medium distribution mode; distributing mirror image applications contained in the containerized applications to the edge nodes according to the optimal application distribution mode; writing a data acquisition script based on a data transmission protocol compatible with the edge node and the user terminal; executing the data acquisition script in the edge node to obtain real-time data output by the user terminal; judging whether the containerized application has a developable project or not based on a monitoring result; if the development project exists, constructing a DAG task according to the priority and the dependency relationship corresponding to the development project, wherein the arrangement mode of the DAG task is pipeline arrangement; and developing the containerized application in real time according to the DAG task. Compared with the traditional real-time application development method, the method of the embodiment adopts different application distribution modes when facing different edge nodes, thereby improving the distribution efficiency; meanwhile, the DAG task is constructed through the priority and the dependency relationship corresponding to the developable project, so that the development efficiency of the containerized application is further improved.
Referring to fig. 4, fig. 4 is a flow chart of a third embodiment of the lightweight real-time application development method of the present invention.
Based on the foregoing embodiments, in this embodiment, in order to implement anomaly detection on the user terminal on the premise of ensuring data security, before the step S30, the method may further include:
step S21: and acquiring terminal basic elements of the user terminal through the edge node, wherein the terminal basic elements comprise user identifiers and equipment identifiers of the user terminal.
Step S22: searching in an abnormal terminal library by taking the terminal basic element as a keyword, and judging whether the user terminal belongs to the abnormal terminal library or not, wherein the abnormal terminal library is constructed based on a alliance chain.
It should be noted that, the federated chain is a type of blockchain, and in an abnormal terminal library constructed by the federated chain, the terminal base element is generally only allowed to be checked, and is not allowed to be modified or deleted for non-administrative staff.
It should be understood that the above-mentioned abnormal terminal library may be a database, which contains terminal basic elements of several abnormal terminals.
Step S23: if the user terminal belongs to an abnormal terminal library, judging that the user terminal is an abnormal terminal, terminating the connection between the edge node and the user terminal, and outputting an abnormal report.
It is understood that the above-mentioned abnormal terminal may refer to a user terminal having abnormal behavior (e.g., steal user privacy, export network virus, send a large number of requests in a short time to cause data congestion, etc.).
It should be appreciated that since the present embodiment is to establish a connection between a user terminal and a development device through several edge nodes. In the process, if an abnormal terminal exists, the problem of data security can be brought to other normal user terminals. Therefore, the above-described data security problem can be avoided by terminating the connection of the edge node with the abnormal terminal and outputting an abnormality report to alert the administrator.
Step S24: and if the user terminal does not belong to the abnormal terminal library, inquiring behavior data corresponding to the user terminal in a database by taking the terminal basic element as a keyword.
Step S25: judging whether the user terminal has abnormal behaviors according to the behavior data.
In a specific implementation, even if a certain user terminal does not belong to an abnormal terminal library, the abnormal behavior of the user terminal in the historical data transmission process is only represented, and the abnormal behavior in the current data transmission process cannot be described. Therefore, in this embodiment, the behavior data corresponding to the user terminal may be queried in the database with the terminal basic element of the user terminal as a key, so as to determine whether the user terminal has abnormal behavior based on the behavior data.
Step S26: if the user terminal has abnormal behaviors, the user terminal is determined to be abnormal equipment, and terminal basic elements corresponding to the abnormal equipment are stored in the abnormal terminal library.
Step S27: and if the user terminal does not have abnormal behaviors, executing the steps of acquiring the real-time data output by the user terminal after the mirror image application is used by the edge node and monitoring the containerized application based on the real-time data.
In this embodiment, the terminal basic element of the user terminal is obtained through the edge node, where the terminal basic element includes a user identifier and a device identifier of the user terminal; searching in an abnormal terminal library by taking the terminal basic elements as keywords, and judging whether the user terminal belongs to the abnormal terminal library or not, wherein the abnormal terminal library is constructed based on a alliance chain; if the user terminal belongs to an abnormal terminal library, judging that the user terminal is an abnormal terminal, terminating the connection between the edge node and the user terminal, and outputting an abnormal report; if the user terminal does not belong to the abnormal terminal library, inquiring behavior data corresponding to the user terminal in a database by taking the terminal basic element as a keyword; judging whether the user terminal has abnormal behaviors according to the behavior data; if the user terminal has abnormal behaviors, determining the user terminal as abnormal equipment, and storing terminal basic elements corresponding to the abnormal equipment into the abnormal terminal library; and if the user terminal does not have abnormal behaviors, executing the steps of acquiring the real-time data output by the user terminal after the mirror image application is used by the edge node and monitoring the containerized application based on the real-time data. Compared with the traditional real-time application development method, the method of the embodiment judges whether the user terminal is an abnormal terminal or not through the abnormal terminal library constructed based on the alliance chain, and disconnects the abnormal terminal from the edge node, so that the negative influence of the abnormal terminal on the real-time application development method of the embodiment is avoided while the privacy data of the normal user terminal is ensured not to be leaked.
In addition, the embodiment of the invention also provides a storage medium, wherein the storage medium is stored with a light-weight real-time application development program, and the light-weight real-time application development program realizes the steps of the light-weight real-time application development method when being executed by a processor.
Referring to fig. 5, fig. 5 is a block diagram illustrating a first embodiment of a lightweight real-time application development apparatus according to the present invention.
As shown in fig. 5, the lightweight real-time application development device according to the embodiment of the present invention includes:
the application construction module 501 is configured to implement containerization on a real-time application to obtain a containerized application, where the real-time application is constructed according to the acquired user demand data;
an application distribution module 502, configured to distribute a mirror application included in the containerized application to an edge node, where the edge node is connected to a user terminal;
an application monitoring module 503, configured to collect, by using the edge node, real-time data output by the user terminal after the mirror application is used, and monitor the containerized application based on the real-time data;
and the application development module 504 is configured to determine whether to develop the containerized application in real time based on the monitoring result.
According to the embodiment, the containerized application is obtained by containerizing the real-time application, and the real-time application is constructed according to the acquired user demand data; distributing mirror image applications contained in the containerized applications to edge nodes, wherein the edge nodes are connected with user terminals; acquiring real-time data output by the user terminal after the mirror image application is used by the edge node, and monitoring the containerized application based on the real-time data; and judging whether to develop the containerized application in real time based on the monitoring result. Compared with the traditional real-time application development method, the method disclosed by the embodiment has the advantages that the real-time application is distributed to the edge nodes after being containerized, and the real-time data output by the user terminal is acquired through the edge nodes, so that the development of the real-time application after the distributed acquisition and monitoring of the real-time data is realized, the technical problems of data congestion, data processing delay and the like caused by the fact that the unified scheduling processing is required for all the data in the prior art are avoided, and the development efficiency of the real-time application can be improved.
Based on the first embodiment of the lightweight real-time application development device of the present invention, a second embodiment of the lightweight real-time application development device of the present invention is presented.
In this embodiment, the application construction module 501 is further configured to obtain user demand data, and determine an objective function based on the user demand data, where the objective function is stored in a preset function library; and calling the objective function to construct a real-time application, and containerizing the real-time application in a manner of packaging the real-time application into a portable container to obtain the containerized application.
Further, the application distribution module 502 is further configured to obtain node information of an edge node, and determine an optimal application distribution mode corresponding to the edge node based on the node information, where the optimal application distribution mode includes a cloud distribution mode, a local network distribution mode, and a storage medium distribution mode; and distributing the mirror image application contained in the containerized application to the edge node according to the optimal application distribution mode.
Further, the application distribution module 502 is further configured to obtain, by using the edge node, a terminal basic element of the user terminal, where the terminal basic element includes a user identifier and a device identifier of the user terminal; searching in an abnormal terminal library by taking the terminal basic elements as keywords, and judging whether the user terminal belongs to the abnormal terminal library or not, wherein the abnormal terminal library is constructed based on a alliance chain; if the user terminal belongs to an abnormal terminal library, judging that the user terminal is an abnormal terminal, terminating the connection between the edge node and the user terminal, and outputting an abnormal report.
Further, the application distribution module 502 is further configured to query, if the user terminal does not belong to an abnormal terminal library, behavior data corresponding to the user terminal in a database with the terminal basic element as a keyword; judging whether the user terminal has abnormal behaviors according to the behavior data; if the user terminal has abnormal behaviors, determining the user terminal as abnormal equipment, and storing terminal basic elements corresponding to the abnormal equipment into the abnormal terminal library; and if the user terminal does not have abnormal behaviors, executing the steps of acquiring the real-time data output by the user terminal after the mirror image application is used by the edge node and monitoring the containerized application based on the real-time data.
Further, the application monitoring module 503 is further configured to write a data acquisition script based on a data transmission protocol compatible with the edge node and the user terminal; and executing the data acquisition script in the edge node to obtain real-time data output by the user terminal.
Further, the application development module 504 is further configured to determine whether a developable project exists in the containerized application based on the monitoring result; if the development project exists, constructing a DAG task according to the priority and the dependency relationship corresponding to the development project, wherein the arrangement mode of the DAG task is pipeline arrangement; and developing the containerized application in real time according to the DAG task.
Other embodiments or specific implementation manners of the lightweight real-time application development device of the present invention may refer to the above method embodiments, and will not be described herein.
It should be noted that, in this document, the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or system that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or system. Without further limitation, an element defined by the phrase "comprising one … …" does not exclude the presence of other like elements in a process, method, article, or system that comprises the element.
The foregoing embodiment numbers of the present invention are merely for the purpose of description, and do not represent the advantages or disadvantages of the embodiments.
From the above description of embodiments, it will be clear to a person skilled in the art that the above embodiment method may be implemented by means of software plus a necessary general hardware platform, but may of course also be implemented by means of hardware, but in many cases the former is a preferred embodiment. Based on this understanding, the technical solution of the present invention may be embodied essentially or in a part contributing to the prior art in the form of a software product stored in a storage medium (e.g. read-only memory/random-access memory, magnetic disk, optical disk), comprising instructions for causing a terminal device (which may be a mobile phone, a computer, a server, or a network device, etc.) to perform the method according to the embodiments of the present invention.
The foregoing description is only of the preferred embodiments of the present invention, and is not intended to limit the scope of the invention, but rather is intended to cover any equivalents of the structures or equivalent processes disclosed herein or in the alternative, which may be employed directly or indirectly in other related arts.
Claims (7)
1. A lightweight real-time application development method, characterized in that the method comprises the steps of:
the method comprises the steps of containerizing a real-time application to obtain a containerized application, wherein the real-time application is constructed according to acquired user demand data;
distributing mirror image applications contained in the containerized applications to edge nodes, wherein the edge nodes are connected with user terminals;
acquiring real-time data output by the user terminal after the mirror image application is used by the edge node, and monitoring the containerized application based on the real-time data;
judging whether to develop the containerized application in real time based on the monitoring result;
the step of containerizing the real-time application to obtain the containerized application comprises the following steps:
acquiring user demand data, and determining an objective function based on the user demand data, wherein the objective function is stored in a preset function library;
calling the objective function to construct a real-time application, and containerizing the real-time application in a manner of packaging the real-time application into a portable container to obtain a containerized application;
the step of distributing the mirror application contained in the containerized application to an edge node includes:
acquiring node information of an edge node, and determining an optimal application distribution mode corresponding to the edge node based on the node information, wherein the node information comprises an identifier, operating system information, network configuration, node state and log information, and the optimal application distribution mode comprises a cloud distribution mode, a local network distribution mode and a storage medium distribution mode;
distributing mirror image applications contained in the containerized applications to the edge nodes according to the optimal application distribution mode;
the step of judging whether to develop the containerized application in real time based on the monitoring result comprises the following steps:
judging whether the containerized application has a developable project or not based on a monitoring result;
if the development project exists, constructing a DAG task according to the priority and the dependency relationship corresponding to the development project, wherein the arrangement mode of the DAG task is pipeline arrangement;
and developing the containerized application in real time according to the DAG task.
2. The method for developing a lightweight real-time application according to claim 1, wherein the step of collecting, by the edge node, real-time data output by the user terminal after using the mirror application and monitoring the containerized application based on the real-time data, further comprises:
acquiring terminal basic elements of the user terminal through the edge node, wherein the terminal basic elements comprise user identifiers and equipment identifiers of the user terminal;
searching in an abnormal terminal library by taking the terminal basic elements as keywords, and judging whether the user terminal belongs to the abnormal terminal library or not, wherein the abnormal terminal library is constructed based on a alliance chain;
if the user terminal belongs to an abnormal terminal library, judging that the user terminal is an abnormal terminal, terminating the connection between the edge node and the user terminal, and outputting an abnormal report.
3. The method for developing lightweight real-time applications according to claim 2, wherein after the step of searching in an abnormal terminal library using the terminal base element as a keyword and determining whether the user terminal belongs to an abnormal terminal based on the search result, further comprising:
if the user terminal does not belong to the abnormal terminal library, inquiring behavior data corresponding to the user terminal in a database by taking the terminal basic element as a keyword;
judging whether the user terminal has abnormal behaviors according to the behavior data;
if the user terminal has abnormal behaviors, determining the user terminal as abnormal equipment, and storing terminal basic elements corresponding to the abnormal equipment into the abnormal terminal library;
and if the user terminal does not have abnormal behaviors, executing the steps of acquiring the real-time data output by the user terminal after the mirror image application is used by the edge node and monitoring the containerized application based on the real-time data.
4. The lightweight real-time application development method according to claim 1, wherein the step of collecting, by the edge node, real-time data output by the user terminal after using the mirror application, comprises:
writing a data acquisition script based on a data transmission protocol compatible with the edge node and the user terminal;
and executing the data acquisition script in the edge node to obtain real-time data output by the user terminal.
5. A lightweight real-time application development device, the lightweight real-time application development device comprising:
the application construction module is used for containerizing the real-time application to obtain containerized application, and the real-time application is constructed according to the acquired user demand data;
the application distribution module is used for distributing the mirror image application contained in the containerized application to an edge node, and the edge node is connected with a user terminal;
the application monitoring module is used for acquiring real-time data output by the user terminal after the mirror image application is used through the edge node and monitoring the containerized application based on the real-time data;
the application development module is used for judging whether to develop the containerized application in real time based on the monitoring result;
the step of containerizing the real-time application to obtain the containerized application comprises the following steps:
acquiring user demand data, and determining an objective function based on the user demand data, wherein the objective function is stored in a preset function library;
calling the objective function to construct a real-time application, and containerizing the real-time application in a manner of packaging the real-time application into a portable container to obtain a containerized application;
the step of distributing the mirror application contained in the containerized application to an edge node includes:
acquiring node information of an edge node, and determining an optimal application distribution mode corresponding to the edge node based on the node information, wherein the node information comprises an identifier, operating system information, network configuration, node state and log information, and the optimal application distribution mode comprises a cloud distribution mode, a local network distribution mode and a storage medium distribution mode;
distributing mirror image applications contained in the containerized applications to the edge nodes according to the optimal application distribution mode;
the step of judging whether to develop the containerized application in real time based on the monitoring result comprises the following steps:
judging whether the containerized application has a developable project or not based on a monitoring result;
if the development project exists, constructing a DAG task according to the priority and the dependency relationship corresponding to the development project, wherein the arrangement mode of the DAG task is pipeline arrangement;
and developing the containerized application in real time according to the DAG task.
6. A lightweight real-time application development device, the device comprising: a memory, a processor, and a lightweight real-time application development program stored on the memory and executable on the processor, the lightweight real-time application development program configured to implement the steps of the lightweight real-time application development method of any one of claims 1 to 4.
7. A storage medium having stored thereon a lightweight real-time application development program which, when executed by a processor, implements the steps of the lightweight real-time application development method of any one of claims 1 to 4.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202410028227.0A CN117539439B (en) | 2024-01-09 | 2024-01-09 | Lightweight real-time application development method, device, equipment and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202410028227.0A CN117539439B (en) | 2024-01-09 | 2024-01-09 | Lightweight real-time application development method, device, equipment and storage medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN117539439A CN117539439A (en) | 2024-02-09 |
| CN117539439B true CN117539439B (en) | 2024-04-09 |
Family
ID=89794183
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202410028227.0A Active CN117539439B (en) | 2024-01-09 | 2024-01-09 | Lightweight real-time application development method, device, equipment and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN117539439B (en) |
Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111813561A (en) * | 2020-08-13 | 2020-10-23 | 中国人民解放军国防科技大学 | An Open and Universal Intelligent Satellite Software Architecture |
| CN115686830A (en) * | 2022-10-11 | 2023-02-03 | 华东计算技术研究所（中国电子科技集团公司第三十二研究所） | Method and system for flexibly scheduling edge computing resources |
| CN115705195A (en) * | 2021-08-09 | 2023-02-17 | 普天信息技术有限公司 | Edge computing platform and application method thereof |
| CN116661944A (en) * | 2023-05-15 | 2023-08-29 | 桂林电子科技大学 | Enterprise pollution discharge monitoring system and method based on combination of cloud primary edge calculation and AI |
| CN117009981A (en) * | 2023-08-28 | 2023-11-07 | 浪潮云信息技术股份公司 | Implementation method of edge intelligent software platform based on container operating system |
| CN117132890A (en) * | 2023-08-23 | 2023-11-28 | 中国地质大学（武汉） | Remote sensing image target detection method and system based on Kubernetes edge computing cluster |
Family Cites Families (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN108415795B (en) * | 2018-02-12 | 2019-04-05 | 人和未来生物科技（长沙）有限公司 | A kind of container Dockerfile, container mirror image rapid generation and system |
| CN111324360B (en) * | 2020-01-09 | 2022-04-01 | 华中科技大学 | Container mirror image construction method and system for edge calculation |
-
2024
- 2024-01-09 CN CN202410028227.0A patent/CN117539439B/en active Active
Patent Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111813561A (en) * | 2020-08-13 | 2020-10-23 | 中国人民解放军国防科技大学 | An Open and Universal Intelligent Satellite Software Architecture |
| CN115705195A (en) * | 2021-08-09 | 2023-02-17 | 普天信息技术有限公司 | Edge computing platform and application method thereof |
| CN115686830A (en) * | 2022-10-11 | 2023-02-03 | 华东计算技术研究所（中国电子科技集团公司第三十二研究所） | Method and system for flexibly scheduling edge computing resources |
| CN116661944A (en) * | 2023-05-15 | 2023-08-29 | 桂林电子科技大学 | Enterprise pollution discharge monitoring system and method based on combination of cloud primary edge calculation and AI |
| CN117132890A (en) * | 2023-08-23 | 2023-11-28 | 中国地质大学（武汉） | Remote sensing image target detection method and system based on Kubernetes edge computing cluster |
| CN117009981A (en) * | 2023-08-28 | 2023-11-07 | 浪潮云信息技术股份公司 | Implementation method of edge intelligent software platform based on container operating system |
Also Published As
| Publication number | Publication date |
|---|---|
| CN117539439A (en) | 2024-02-09 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US11876817B2 (en) | Modeling queue-based message-oriented middleware relationships in a security system | |
| US10747592B2 (en) | Router management by an event stream processing cluster manager | |
| US10210036B2 (en) | Time series metric data modeling and prediction | |
| US20180046567A1 (en) | Quantization of data streams of instrumented software | |
| CN112583898B (en) | Business process arrangement method, device and readable medium | |
| US11818152B2 (en) | Modeling topic-based message-oriented middleware within a security system | |
| JP2004303248A (en) | Architecture and system for location awareness | |
| Kotenko et al. | Aggregation of elastic stack instruments for collecting, storing and processing of security information and events | |
| US20220222266A1 (en) | Monitoring and alerting platform for extract, transform, and load jobs | |
| US20140201762A1 (en) | Event handling system and method | |
| CN112506683A (en) | Data processing method, related device, equipment and storage medium | |
| US11294740B2 (en) | Event to serverless function workflow instance mapping mechanism | |
| US20230344840A1 (en) | Method, apparatus, system, and non-transitory computer readable medium for identifying and prioritizing network security events | |
| CN110781180A (en) | Data screening method and data screening device | |
| CN111130882A (en) | Monitoring system and method of network equipment | |
| CN117539439B (en) | Lightweight real-time application development method, device, equipment and storage medium | |
| US20240013109A1 (en) | Method and system for automated system onboarding | |
| CN116488932A (en) | Interface security monitoring method, system, equipment and medium | |
| CN113760693B (en) | Method and device for local debugging of microservice system | |
| WO2023034444A1 (en) | Generating user-specific polygraphs for network activity | |
| Noorani | On the detection of malware on virtual assistants based on behavioral anomalies | |
| CN115378792B (en) | Alarm processing method, device and storage medium | |
| CN119383098B (en) | Modular social media data collection method and device | |
| CN115277477B (en) | Flow detection method and device based on simple object access protocol | |
| US11481248B2 (en) | Completing an SMI task across multiple SMI events |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |