CN110930110B - Distributed flow monitoring method and device, storage medium and electronic equipment - Google Patents
Distributed flow monitoring method and device, storage medium and electronic equipment Download PDFInfo
- Publication number
- CN110930110B CN110930110B CN201911053940.6A CN201911053940A CN110930110B CN 110930110 B CN110930110 B CN 110930110B CN 201911053940 A CN201911053940 A CN 201911053940A CN 110930110 B CN110930110 B CN 110930110B
- Authority
- CN
- China
- Prior art keywords
- sub
- identification information
- determining
- target sub
- flow
- 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
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q10/00—Administration; Management
- G06Q10/10—Office automation; Time management
- G06Q10/103—Workflow collaboration or project management
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q10/00—Administration; Management
- G06Q10/10—Office automation; Time management
- G06Q10/105—Human resources
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q40/00—Finance; Insurance; Tax strategies; Processing of corporate or income taxes
- G06Q40/12—Accounting
- G06Q40/125—Finance or payroll
Landscapes
- Business, Economics & Management (AREA)
- Engineering & Computer Science (AREA)
- Strategic Management (AREA)
- Human Resources & Organizations (AREA)
- Entrepreneurship & Innovation (AREA)
- Accounting & Taxation (AREA)
- General Physics & Mathematics (AREA)
- Marketing (AREA)
- Finance (AREA)
- Economics (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Business, Economics & Management (AREA)
- Quality & Reliability (AREA)
- Tourism & Hospitality (AREA)
- Data Mining & Analysis (AREA)
- Operations Research (AREA)
- Development Economics (AREA)
- Technology Law (AREA)
- Debugging And Monitoring (AREA)
Abstract
The disclosure relates to a distributed process monitoring method, a distributed process monitoring device, a storage medium and an electronic device, wherein the method comprises the following steps: sending a plurality of detection requests to each sub-process system corresponding to a main process to be monitored, wherein the sub-process system is a system corresponding to a sub-process belonging to the main process, and each detection request is sent by adopting a protocol corresponding to each sub-process system; determining a target sub-process system in a running state according to a received response signal responding to the detection request; intercepting a business document of the target sub-flow system, wherein the business document of the target sub-flow system carries node identification information of a node for processing the business document; and determining the flow operation state in the target sub-flow system according to the business receipt. Therefore, the flow running state in the main flow circulation process can be comprehensively monitored, and meanwhile, the workload of manual modification can be greatly reduced, and the maintenance is facilitated.
Description
Technical Field
The present disclosure relates to the field of process processing, and in particular, to a distributed process monitoring method and apparatus, a storage medium, and an electronic device.
Background
With the continuous deepening of enterprise informatization, most of large enterprises have established perfect informatization systems. The existing enterprises generally adopt a distributed flow structure, that is, most of different flow systems in the enterprises are constructed by different manufacturers for historical reasons, so that the promotion of the whole flow of the system is generally realized through the flow series connection among the different flow systems. In the prior art, the following ways can be adopted to implement the process association between the various process systems:
one is that each sub-process system can be connected in series through the main process, but in the method, only the sub-process system is monitored, and the operation state inside the sub-process system cannot be monitored; the other method is to modify the process engine of each sub-process system, and report the execution information of the process engine of each sub-process system in a unified manner, so as to monitor the running state inside the sub-process system, but in this way, the process engines of all the sub-process systems need to be modified, the workload of manual modification is large, each sub-process system has a corresponding programming language, a corresponding protocol and the like, and the difficulty of modification and maintenance is too large.
Disclosure of Invention
The purpose of the disclosure is to provide a simple and comprehensively distributed process monitoring method, device, storage medium and electronic equipment.
In order to achieve the above object, according to a first aspect of the present disclosure, there is provided a distributed process monitoring method, including:
sending a plurality of detection requests to each sub-process system corresponding to a main process to be monitored, wherein the sub-process system is a system corresponding to a sub-process belonging to the main process, and each detection request is sent by adopting a protocol corresponding to each sub-process system;
determining a target sub-process system in a running state according to a received response signal responding to the detection request;
intercepting a business document of the target sub-flow system, wherein the business document of the target sub-flow system carries node identification information of a node for processing the business document;
and determining the flow operation state in the target sub-flow system according to the business receipt.
Optionally, the determining, according to the service document, a flow operation state in the target sub-flow system includes:
acquiring bill identification information of the business bill;
determining information in a first preset range of the bill identification information as process identification information, and determining a process corresponding to the process identification information as a sub-process in an operating state in the target sub-process system;
and determining the information in the second preset range of the bill identification information as the node identification information, and determining the node corresponding to the node identification information as the child node in the running state in the target sub-flow system.
Optionally, the determining, according to the service document, a flow operation state in the target sub-flow system includes:
acquiring bill identification information of the business bill and a comparison code corresponding to the target sub-process system, wherein the bill identification information and the comparison code are both represented by binary numbers, and the comparison code is used for indicating the position of the process identification information in the bill identification information;
according to the comparison code and the receipt identification information, determining flow identification information corresponding to the business receipt, and determining a flow corresponding to the flow identification information as a sub-flow in the target sub-flow system in an operating state;
and determining the residual information except the process identification information in the bill identification information as node identification information, and determining the node corresponding to the node identification information as a child node in the running state in the target sub-process system.
Optionally, the method for determining a target sub-process system in an operating state according to a received response signal in response to a probe request includes:
and determining a sub-process system corresponding to the port number and the protocol as the target sub-process system according to the port number of the port for receiving the response signal and the protocol corresponding to the detection request responded by the response signal.
Optionally, after the step of determining the target sub-process system in an operating state according to the received response signal responding to the probe request, the method further includes:
sending a detection request to the target sub-process system at intervals of a preset time interval by using a protocol corresponding to the target sub-process system;
and when the sub-process operation in the target sub-process system is determined to be finished, if a next sub-process system exists in the main process and the target sub-process system, sending a detection request to the next sub-process system by adopting a protocol corresponding to the next sub-process system.
According to a second aspect of the present disclosure, there is provided a distributed process monitoring apparatus, the apparatus comprising:
the system comprises a first sending module, a second sending module and a monitoring module, wherein the first sending module is used for sending a plurality of detection requests to each sub-process system corresponding to a main process to be monitored, the sub-process systems are systems corresponding to sub-processes belonging to the main process, and each detection request is sent by adopting a protocol corresponding to each sub-process system;
the first determination module is used for determining a target sub-process system in a running state according to a received response signal responding to the detection request;
the intercepting module is used for intercepting the business document of the target sub-flow system, wherein the business document of the target sub-flow system carries node identification information of a node for processing the business document;
and the second determining module is used for determining the process running state in the target sub-process system according to the business bill.
Optionally, the second determining module includes:
the first obtaining sub-module is used for obtaining the bill identification information of the business bill;
the first determining submodule is used for determining information in a first preset range of the bill identification information as process identification information, and determining a process corresponding to the process identification information as a sub-process in an operating state in the target sub-process system;
and the second determining submodule is used for determining the information in a second preset range of the receipt identification information as the node identification information, and determining the node corresponding to the node identification information as the child node in the running state in the target sub-flow system.
Optionally, the second determining module includes:
the second obtaining submodule is used for obtaining bill identification information of the business bill and a comparison code corresponding to the target sub-process system, wherein the bill identification information and the comparison code are both represented by binary numbers, and the comparison code is used for indicating the position of the process identification information in the bill identification information;
a third determining sub-module, configured to determine, according to the comparison code and the document identification information, flow identification information corresponding to the business document, and determine a flow corresponding to the flow identification information as a sub-flow in the target sub-flow system that is in an operating state;
and the fourth determining submodule is used for determining the residual information except the process identification information in the receipt identification information as node identification information, and determining the node corresponding to the node identification information as a child node in the running state in the target sub-process system.
Optionally, the probe requests of multiple sub-process systems corresponding to the same protocol are sent through different ports, and the first determining module is configured to:
and determining a sub-process system corresponding to the port number and the protocol as the target sub-process system according to the port number of the port for receiving the response signal and the protocol corresponding to the detection request responded by the response signal.
Optionally, the apparatus further comprises:
a second sending module, configured to send, at intervals of a preset time period, a probe request to the target sub-process system according to a protocol corresponding to the target sub-process system after the first determining module determines, according to the received response signal responding to the probe request, the target sub-process system in the running state;
and a third sending module, configured to, when it is determined that the sub-process operation in the target sub-process system is finished, send a probe request to a next sub-process system by using a protocol corresponding to the next sub-process system if the next sub-process system exists in the main process and the target sub-process system.
According to a third aspect of the present disclosure, there is provided a computer readable storage medium having stored thereon a computer program which, when executed by a processor, performs the steps of any of the methods of the first aspect described above.
According to a fourth aspect of the present disclosure, there is provided an electronic device comprising:
a memory having a computer program stored thereon;
a processor for executing the computer program in the memory to implement the steps of the method of any of the first aspects above.
In the above technical solution, the detection request is sent to each sub-process system corresponding to the main process, so that the sub-process currently in the running state in the main process can be determined according to the response signal. And then, by intercepting the business document of the sub-process system, the process running state in the sub-process system can be determined according to the business document. Therefore, according to the technical scheme, the feedback of the running state among all the distributed process systems can be realized without modifying the process engines of the sub-process systems, the sub-process systems can be monitored, and the running states of the internal sub-nodes in the sub-process systems can be monitored, so that the overall monitoring of the running state of the process in the main process flow circulation process is realized, and the safety and the reliability of the process flow circulation are ensured. Meanwhile, the distributed flow monitoring method can greatly reduce the workload of manual modification and is convenient for the overall modification and maintenance of the system.
Additional features and advantages of the disclosure will be set forth in the detailed description which follows.
Drawings
The accompanying drawings, which are included to provide a further understanding of the disclosure and are incorporated in and constitute a part of this specification, illustrate embodiments of the disclosure and together with the description serve to explain the disclosure without limiting the disclosure. In the drawings:
FIG. 1 is a schematic diagram of an example main flow, sub-flow and sub-node.
FIG. 2 is a flow chart of a distributed process monitoring method provided according to one embodiment of the present disclosure;
FIG. 3 is a block diagram of a distributed process monitoring apparatus provided in accordance with one embodiment of the present disclosure;
FIG. 4 is a block diagram illustrating an electronic device in accordance with an exemplary embodiment;
FIG. 5 is a block diagram illustrating an electronic device in accordance with an example embodiment.
Detailed Description
The following detailed description of specific embodiments of the present disclosure is provided in connection with the accompanying drawings. It should be understood that the detailed description and specific examples, while indicating the present disclosure, are given by way of illustration and explanation only, not limitation.
In the related art, a plurality of distributed process systems are required to be connected in series in an enterprise system to realize the overall process of the system. For example, as shown in fig. 1, the overall process (i.e., the main process) of the system is a research and development approval process, each node in the main process is a sub-process, and each sub-process may originate from a different process system, for example, a human resource sub-process belongs to a human resource management system, a financial sub-process belongs to a financial system, and a research and development management sub-process belongs to a research and development management system.
When the research and development approval process is monitored according to the manner in the related art, that is, the operation state of the current process is determined, if the first manner described in the background art is used, it can only be determined which sub-process is currently in the operation state, for example, it can be determined that the current process runs to the human resource sub-process, but the operation state of the human resource sub-process cannot be accurately monitored, for example, it cannot be determined that the current sub-process runs to the applicant node. If the second method described in the background art is used, the process engines of the human resource management system, the financial system, and the research and development management system need to be modified again, which is heavy in workload and difficult to maintain.
Based on this, the present disclosure provides a distributed process monitoring method, which does not need to modify the process engine of the process system, and can explicitly monitor the operation state inside the sub-process.
Fig. 2 is a flowchart of a distributed process monitoring method according to an embodiment of the present disclosure, where the method includes:
in S11, a plurality of probe requests are sent to each sub-process system corresponding to the main process to be monitored, where the sub-process system is a system corresponding to a sub-process belonging to the main process, and each probe request is sent by using a protocol corresponding to each sub-process system.
As shown in fig. 1, each sub-process system corresponding to the main process is a human resource management system, a financial system, and a research and development management system. The sub-process systems may be built by different vendors and the protocols used in building the systems are different. Illustratively, the human resource management system adopts a protocol a, the financial system adopts a protocol b, and the research and development management system adopts a protocol c. Therefore, when sending the probe request, the a, b, c protocols can be respectively adopted to send the probe request to the human resource management system, the a, b, c protocols can be respectively adopted to send the probe request to the financial system, and the mode of sending the probe request to other sub-process systems is similar, which is not described herein again.
In S12, the target sub-process system in the operating state is determined based on the received response signal in response to the probe request.
If the sub-process system is in the running state, when the sub-process system receives the probe request, the sub-process system may respond to the probe request sent by using the same protocol, that is, feed back the response signal, and may determine the sub-process system corresponding to the response signal according to the response information, thereby determining the target sub-process system in the running state.
In S13, a service document of a target sub-flow system is intercepted, where the service document of the target sub-flow system carries node identification information of a node that processes the service document.
In the flow process of the flow, each node in the flow can be hooked with a business document, and the business document can be a business document in a uniform format or an existing business document in the flow, which is not limited by the disclosure.
For example, in the main flow, node identification information of a node of each sub-flow in the main flow may be set, and the node identification information of the node may be sent to the sub-flow system where the node is located. Therefore, in the sub-process system, when a certain node of the sub-process is in an operating state (i.e., processing a business document), the node identification information of the node may be added to the document identification information of the business document. For example, node identification information may be added to the document identification information in a suffix manner, for example, the document identification information is "url Code 111012", where "Code 111012" is the node identification information.
In S14, the process running status in the target sub-process system is determined according to the business document.
The process running state in the target sub-process system may be to determine which node the current sub-process in the target sub-process system runs to, that is, to determine the node in the running state in the target sub-process system. The business document carries node identification information of a node for processing the business document, so that the node for processing the business document can be determined when the business document is intercepted, the node is the node which is in the current running state in the target sub-flow system, and the flow running state in the target sub-flow system can be determined.
In the above technical solution, the detection request is sent to each sub-process system corresponding to the main process, so that the sub-process currently in the running state in the main process can be determined according to the response signal. And then, by intercepting the business document of the sub-process system, the process running state in the sub-process system can be determined according to the business document. Therefore, according to the technical scheme, the feedback of the running state among all the distributed process systems can be realized without modifying the process engines of the sub-process systems, the sub-process systems can be monitored, and the running states of the internal sub-nodes in the sub-process systems can be monitored, so that the overall monitoring of the running state of the process in the main process flow circulation process is realized, and the safety and the reliability of the process flow circulation are ensured. Meanwhile, the distributed process monitoring method can greatly reduce the workload of manual modification and is convenient for the overall modification and maintenance of the system.
Optionally, in S14, an exemplary embodiment of determining the process running status in the target sub-process system according to the business document includes:
and acquiring bill identification information of the business bill, wherein the bill identification information can be the serial number or URL of the bill and the like.
Determining information in a first preset range of the bill identification information as process identification information, and determining a process corresponding to the process identification information as a sub-process in an operating state in the target sub-process system;
and determining the information in the second preset range of the bill identification information as the node identification information, and determining the node corresponding to the node identification information as the child node in the running state in the target sub-flow system. The first preset range and the second preset range are set during initialization of the main process.
For example, the document identification information may be a number of the service document, the process identification information may be a number of the process, and the node identification information may be a number of the node. In this embodiment, which bits in the number of the service document represent the number of the flow and which bits represent the number of the node may be preset. For example, the number of the business document is preset to be 16 bits, wherein the first 8 bits represent the number of the sub-process, and the last 8 bits represent the number of the sub-node. As an example, the number of the service document is 0100361111110111, 01003611 (the first 8 bits) can be determined as the number of the sub-flow, and 111110111 (the last 8 bits) can be determined as the number of the sub-node.
Therefore, after the number of the sub-process and the number of the sub-node are determined according to the document identification information, it can be determined that the node (such as the applicant node in fig. 1) with the number of 111110111 in the sub-process (such as the human resource sub-process in fig. 1) with the number of 01003611 in the target sub-process system is in the running state, so that the distributed process can be monitored comprehensively and accurately, and accurate data support can be provided for safe flow and error tracing of the process.
However, in different process systems, the number of sub-processes included in the process system and the number of sub-nodes in each sub-process may have a large difference, for example, the number of sub-processes in the process system M is large, the number of sub-nodes in each sub-process is small, the number of sub-processes in the process system N is small, and the number of sub-nodes in each sub-process is large. In this case, the number of the sub-process and the number of the sub-node corresponding to the number of the document may be insufficient.
Optionally, in S14, another exemplary embodiment of determining the process running status in the target sub-process system according to the business document includes:
and acquiring bill identification information of the business bill and a comparison code corresponding to the target sub-process system, wherein the bill identification information and the comparison code are both represented by binary numbers, and the comparison code is used for indicating the position of the process identification information in the bill identification information.
And the position of '1' in the comparison code is represented as the position of the process identification information in the bill identification information. For example, the comparison code M1 corresponding to the flow system M may be 1111111111000000, and the comparison code N1 corresponding to the flow system N may be 1111110000000000, that is, in the flow system M, the first 10 bits are flow identification information, and in the flow system N, the first 6 bits are flow identification information. Therefore, the number of bits of the flow identification information can be dynamically adjusted by setting the comparison code so as to adapt to the number of sub-flows and sub-nodes in the flow system.
And determining the flow identification information corresponding to the business document according to the comparison code and the document identification information, and determining the flow corresponding to the flow identification information as the sub-flow in the target sub-flow system in the running state.
And determining the residual information except the process identification information in the bill identification information as node identification information, and determining the node corresponding to the node identification information as a child node in the running state in the target sub-process system.
And the comparison code and the bill identification information can be subjected to AND operation to determine the process identification information corresponding to the business bill. For example, the result obtained by performing and operation on the "1" position of the comparison code in the document identification information is determined as the flow identification information, for example, the document identification information is 0100101111110111, and the comparison code M1 corresponding to the flow system M is 1111111111000000, then by performing and operation on the document identification information and the comparison code, as follows:
0100101111110111&1111111111000000->0100101111000000
if the result 0100101111 (i.e., the first 10 bits of the document identification information) obtained by performing the and operation with the "1" position of the comparison code is obtained, the flow identification information of the sub-flow in the running state of the flow system M is 0100101111, and the remaining information in the document identification information is 110111, i.e., the node identification information of the sub-node in the running state in the target sub-flow system is 110111.
The comparison code N1 corresponding to the process system N can be represented as "1111110000000000", and then:
0100101111110111&1111110000000000->0100100000000000
if the result obtained by performing the and operation with the "1" position of the comparison code is 010010 (i.e., the first 6 bits of the document identification information), the flow identification information of the sub-flow in the running state of the flow system N is 010010, and the remaining information in the document identification information is 1111110111, that is, the node identification information of the sub-node in the running state in the target sub-flow system is 1111110111.
Therefore, according to the technical scheme, the digit of the process identification information and the digit of the node identification information can be dynamically adjusted through the comparison code of the process system so as to adapt to the number of the sub-processes and the sub-nodes in the process system, on one hand, different management can be performed on the digit of the process identification information aiming at different process systems, on the other hand, the process identification information and the node identification information can be simply, conveniently and accurately determined, and therefore the efficiency and the accuracy of distributed process monitoring can be improved. In addition, the application range of the distributed flow monitoring method can be effectively widened.
Optionally, after the flow identification information and the node identification information are determined according to the service document, the determined identification information may be stored, for example, stored in a log file, so that a record of flow of the flow node may be generated in the process of main flow circulation, thereby facilitating flow state query and providing data support for backtracking of the flow node.
Alternatively, as described above, the respective sub-flow systems may correspond to different protocols. When the protocols corresponding to the sub-process systems are the same, the target sub-process system is determined only according to the protocol corresponding to the probe request fed back with the response signal, and the target sub-process system is difficult to be determined accurately. Accordingly, the present disclosure also provides the following embodiments. Specifically, the method for determining a target sub-process system in an operating state according to a received response signal responding to a probe request includes:
and determining a sub-process system corresponding to the port number and the protocol as the target sub-process system according to the port number of the port for receiving the response signal and the protocol corresponding to the detection request responded by the response signal.
Illustratively, the sub-process system S and the sub-process system T correspond to the same protocol, and if the human resource management system and the logistics management system correspond to the same protocol a, ports for sending the probe requests by the human resource management system and the logistics management system may be respectively set, illustratively, the probe requests for setting the human resource management system are sent through the port 8080, and the probe requests for setting the logistics management system are sent through the port 8081. Therefore, when the target sub-process system is determined according to the response signal, the sub-process system adopting the same protocol can be distinguished by receiving the port number of the response signal, for example, the response signal of the protocol a received through the port 8080 is the response signal of the human resource management system, so that the target sub-process system can be uniquely determined according to the protocol corresponding to the response signal and the port number of the port receiving the response signal, and the accuracy of the determined target sub-process system can be effectively ensured, so that the accuracy of distributed process monitoring is ensured.
Optionally, after the step of determining the target sub-process system in an operating state according to the received response signal responding to the probe request, the method further includes:
and sending a detection request to the target sub-process system at intervals of a preset time interval by using a protocol corresponding to the target sub-process system.
In an embodiment, after the target sub-process system is determined, that is, the target sub-process system currently in the operating state is determined, in the process of subsequently monitoring the process of the target sub-process system, it is only required to send a detection request to the target sub-process system at intervals of a preset time period and in a protocol corresponding to the target sub-process system to determine whether the target sub-process system is still in the operating state, so that the number of sent detection requests can be effectively reduced, the data transmission amount can be effectively reduced, and the data processing efficiency can be further improved. For example, the preset time period may be set according to an actual usage scenario, such as 1s, which is not limited by the present disclosure.
When the sub-process in the target sub-process system is determined to be finished, if a next sub-process system exists in the main process and the target sub-process system, sending a detection request to the next sub-process system by adopting a protocol corresponding to the next sub-process system, wherein the next sub-process system is a next-stage process system of the target sub-process system in the process flow sequence.
As an example, if a response signal fed back by the target sub-process system is not received within a period after the probe request is sent to the target sub-process system, it may be determined that the sub-process operation in the target sub-process system is finished. As another example, the response signal may carry start time identification information and end time identification information of a sub-process in the target sub-process system, and when the received response signal includes the end time identification information, it may be determined that the sub-process in the target sub-process system is finished.
After the sub-process operation in the target sub-process system is finished, if a next sub-process system exists in the main process and the target sub-process system, indicating that the current main process is not finished running yet, sending a detection request to the next sub-process system by using a protocol corresponding to the next sub-process system so as to monitor the process running state of the next sub-process system. If the next sub-process system does not exist in the main process and the target sub-process system, the main process may be run to the end node, and at this time, the operation corresponding to the node is executed.
In the above technical solution, when the target sub-process system is determined, the target sub-process system may send a probe request to monitor the process running state, so that on one hand, resource waste caused by sending too many useless probe requests may be avoided, and on the other hand, the target sub-process system may be monitored comprehensively. In addition, after the sub-process operation in the target sub-process system is finished, the next sub-process system of the target sub-process system in the main process can be monitored, so that the operation states of all sub-processes and sub-nodes in the main process can be monitored, the operation states of all nodes in the main process can be determined in real time, and the safety of process flow is further improved.
The present disclosure also provides a distributed process monitoring apparatus, as shown in fig. 3, the apparatus 10 includes:
a first sending module 100, configured to send a plurality of probe requests to each sub-process system corresponding to a main process to be monitored, where the sub-process system is a system corresponding to a sub-process belonging to the main process, and each probe request is sent by using a protocol corresponding to each sub-process system;
a first determining module 200, configured to determine, according to a received response signal in response to the probe request, a target sub-process system in an operating state;
the intercepting module 300 is configured to intercept a service document of the target sub-flow system, where the service document of the target sub-flow system carries node identification information of a node that processes the service document;
and a second determining module 400, configured to determine, according to the service document, a process running state in the target sub-process system.
Optionally, the second determining module includes:
the first obtaining sub-module is used for obtaining the bill identification information of the business bill;
the first determining submodule is used for determining information in a first preset range of the bill identification information as process identification information, and determining a process corresponding to the process identification information as a sub-process in an operating state in the target sub-process system;
and the second determining submodule is used for determining the information in a second preset range of the receipt identification information as the node identification information, and determining the node corresponding to the node identification information as the child node in the running state in the target sub-flow system.
Optionally, the second determining module includes:
the second obtaining submodule is used for obtaining bill identification information of the business bill and a comparison code corresponding to the target sub-process system, wherein the bill identification information and the comparison code are both represented by binary numbers, and the comparison code is used for indicating the position of the process identification information in the bill identification information;
a third determining sub-module, configured to determine, according to the comparison code and the document identification information, flow identification information corresponding to the business document, and determine a flow corresponding to the flow identification information as a sub-flow in the target sub-flow system that is in an operating state;
and the fourth determining submodule is used for determining the residual information except the process identification information in the receipt identification information as node identification information, and determining the node corresponding to the node identification information as a child node in the running state in the target sub-process system.
Optionally, the probe requests of multiple sub-process systems corresponding to the same protocol are sent through different ports, and the first determining module is configured to:
and determining a sub-process system corresponding to the port number and the protocol as the target sub-process system according to the port number of the port for receiving the response signal and the protocol corresponding to the detection request responded by the response signal.
Optionally, the apparatus further comprises:
a second sending module, configured to send, at intervals of a preset time period, a probe request to the target sub-process system according to a protocol corresponding to the target sub-process system after the first determining module determines, according to the received response signal responding to the probe request, the target sub-process system in the running state;
and a third sending module, configured to, when it is determined that the sub-process in the target sub-process system ends, send a probe request to a next sub-process system by using a protocol corresponding to the next sub-process system if the next sub-process system exists in the main process and the target sub-process system.
With regard to the apparatus in the above-described embodiment, the specific manner in which each module performs the operation has been described in detail in the embodiment related to the method, and will not be elaborated here.
Fig. 4 is a block diagram illustrating an electronic device 700 according to an example embodiment. As shown in fig. 4, the electronic device 700 may include: a processor 701 and a memory 702. The electronic device 700 may also include one or more of a multimedia component 703, an input/output (I/O) interface 704, and a communication component 705.
The processor 701 is configured to control the overall operation of the electronic device 700, so as to complete all or part of the steps in the distributed process monitoring method. The memory 702 is used to store various types of data to support operation at the electronic device 700, such as instructions for any application or method operating on the electronic device 700 and application-related data, such as contact data, transmitted and received messages, pictures, audio, video, and the like. The Memory 702 may be implemented by any type of volatile or non-volatile Memory device or combination thereof, such as Static Random Access Memory (SRAM), Electrically Erasable Programmable Read-Only Memory (EEPROM), Erasable Programmable Read-Only Memory (EPROM), Programmable Read-Only Memory (PROM), Read-Only Memory (ROM), magnetic Memory, flash Memory, magnetic disk, or optical disk. The multimedia components 703 may include screen and audio components. Wherein the screen may be, for example, a touch screen and the audio component is used for outputting and/or inputting audio signals. For example, the audio component may include a microphone for receiving external audio signals. The received audio signal may further be stored in the memory 702 or transmitted through the communication component 705. The audio assembly also includes at least one speaker for outputting audio signals. The I/O interface 704 provides an interface between the processor 701 and other interface modules, such as a keyboard, mouse, buttons, etc. These buttons may be virtual buttons or physical buttons. The communication component 705 is used for wired or wireless communication between the electronic device 700 and other devices. Wireless Communication, such as Wi-Fi, bluetooth, Near Field Communication (NFC), 2G, 3G, 4G, NB-IOT, eMTC, or other 5G, etc., or a combination of one or more of them, which is not limited herein. The corresponding communication component 705 may thus include: Wi-Fi module, Bluetooth module, NFC module, etc.
In an exemplary embodiment, the electronic Device 700 may be implemented by one or more Application Specific Integrated Circuits (ASICs), Digital Signal Processors (DSPs), Digital Signal Processing Devices (DSPDs), Programmable Logic Devices (PLDs), Field Programmable Gate Arrays (FPGAs), controllers, microcontrollers, microprocessors, or other electronic components for performing the distributed process monitoring method described above.
In another exemplary embodiment, a computer readable storage medium comprising program instructions which, when executed by a processor, implement the steps of the distributed flow monitoring method described above is also provided. For example, the computer readable storage medium may be the memory 702 described above that includes program instructions that are executable by the processor 701 of the electronic device 700 to perform the distributed process monitoring method described above.
Fig. 5 is a block diagram illustrating an electronic device 1900 according to an example embodiment. For example, the electronic device 1900 may be provided as a server. Referring to fig. 5, an electronic device 1900 includes a processor 1922, which may be one or more in number, and a memory 1932 for storing computer programs executable by the processor 1922. The computer program stored in memory 1932 may include one or more modules that each correspond to a set of instructions. Further, the processor 1922 may be configured to execute the computer program to perform the distributed flow monitoring method described above.
Additionally, electronic device 1900 may also include a power component 1926 and a communication component 1950, the power component 1926 may be configured to perform power management of the electronic device 1900, and the communication component 1950 may be configured to enable communication, e.g., wired or wireless communication, of the electronic device 1900. In addition, the electronic device 1900 may also include input/output (I/O) interfaces 1958. The electronic device 1900 may operate based on an operating system, such as Windows Server, Mac OS XTM, UnixTM, LinuxTM, etc., stored in memory 1932.
In another exemplary embodiment, a computer readable storage medium comprising program instructions which, when executed by a processor, implement the steps of the distributed flow monitoring method described above is also provided. For example, the computer readable storage medium may be the memory 1932 described above that includes program instructions that are executable by the processor 1922 of the electronic device 1900 to perform the distributed flow monitoring method described above.
In another exemplary embodiment, a computer program product is also provided, which comprises a computer program executable by a programmable apparatus, the computer program having code portions for performing the above-described distributed flow monitoring method when executed by the programmable apparatus.
The preferred embodiments of the present disclosure are described in detail with reference to the accompanying drawings, however, the present disclosure is not limited to the specific details of the above embodiments, and various simple modifications may be made to the technical solution of the present disclosure within the technical idea of the present disclosure, and these simple modifications all belong to the protection scope of the present disclosure.
It should be noted that the various features described in the above embodiments may be combined in any suitable manner without departing from the scope of the invention. In order to avoid unnecessary repetition, various possible combinations will not be separately described in this disclosure.
In addition, any combination of various embodiments of the present disclosure may be made, and the same should be considered as the disclosure of the present disclosure, as long as it does not depart from the spirit of the present disclosure.
Claims (10)
1. A distributed process monitoring method, the method comprising:
sending a plurality of detection requests to each sub-process system corresponding to a main process to be monitored, wherein the sub-process system is a system corresponding to a sub-process belonging to the main process, and each detection request is sent by adopting a protocol corresponding to each sub-process system;
determining a target sub-process system in a running state according to a received response signal responding to the detection request;
intercepting a business document of the target sub-flow system, wherein the business document of the target sub-flow system carries node identification information of a node for processing the business document;
and determining the flow operation state in the target sub-flow system according to the business receipt.
2. The method of claim 1, wherein the determining the process running status in the target sub-process system according to the business document comprises:
acquiring bill identification information of the business bill;
determining information in a first preset range of the bill identification information as process identification information, and determining a process corresponding to the process identification information as a sub-process in an operating state in the target sub-process system;
and determining the information in the second preset range of the bill identification information as the node identification information, and determining the node corresponding to the node identification information as the child node in the running state in the target sub-flow system.
3. The method of claim 1, wherein the determining the process running status in the target sub-process system according to the business document comprises:
acquiring bill identification information of the business bill and a comparison code corresponding to the target sub-process system, wherein the bill identification information and the comparison code are both represented by binary numbers, and the comparison code is used for indicating the position of the process identification information in the bill identification information;
according to the comparison code and the receipt identification information, determining flow identification information corresponding to the business receipt, and determining a flow corresponding to the flow identification information as a sub-flow in the target sub-flow system in an operating state;
and determining the residual information except the process identification information in the bill identification information as node identification information, and determining the node corresponding to the node identification information as a child node in the running state in the target sub-process system.
4. The method according to claim 1, wherein the probe requests of a plurality of sub-process systems corresponding to the same protocol are sent through different ports, and the determining the target sub-process system in the running state according to the received response signal responding to the probe request comprises:
and determining a sub-process system corresponding to the port number and the protocol as the target sub-process system according to the port number of the port for receiving the response signal and the protocol corresponding to the detection request responded by the response signal.
5. The method of claim 1, wherein after the step of determining the target sub-process system in an operational state based on the received response signal in response to the probe request, the method further comprises:
sending a detection request to the target sub-process system at intervals of a preset time interval by using a protocol corresponding to the target sub-process system;
and when the sub-process operation in the target sub-process system is determined to be finished, if a next sub-process system exists in the main process and the target sub-process system, sending a detection request to the next sub-process system by adopting a protocol corresponding to the next sub-process system.
6. A distributed process monitoring apparatus, the apparatus comprising:
the system comprises a first sending module, a second sending module and a monitoring module, wherein the first sending module is used for sending a plurality of detection requests to each sub-process system corresponding to a main process to be monitored, the sub-process systems are systems corresponding to sub-processes belonging to the main process, and each detection request is sent by adopting a protocol corresponding to each sub-process system;
the first determination module is used for determining a target sub-process system in a running state according to a received response signal responding to the detection request;
the intercepting module is used for intercepting the business document of the target sub-flow system, wherein the business document of the target sub-flow system carries node identification information of a node for processing the business document;
and the second determining module is used for determining the process running state in the target sub-process system according to the business bill.
7. The apparatus of claim 6, wherein the second determining module comprises:
the first obtaining sub-module is used for obtaining the bill identification information of the business bill;
the first determining submodule is used for determining information in a first preset range of the bill identification information as process identification information, and determining a process corresponding to the process identification information as a sub-process in an operating state in the target sub-process system;
and the second determining submodule is used for determining the information in a second preset range of the receipt identification information as the node identification information, and determining the node corresponding to the node identification information as the child node in the running state in the target sub-flow system.
8. The apparatus of claim 6, wherein the second determining module comprises:
the second obtaining submodule is used for obtaining bill identification information of the business bill and a comparison code corresponding to the target sub-process system, wherein the bill identification information and the comparison code are both represented by binary numbers, and the comparison code is used for indicating the position of the process identification information in the bill identification information;
a third determining sub-module, configured to determine, according to the comparison code and the document identification information, flow identification information corresponding to the business document, and determine a flow corresponding to the flow identification information as a sub-flow in the target sub-flow system that is in an operating state;
and the fourth determining submodule is used for determining the residual information except the process identification information in the receipt identification information as node identification information, and determining the node corresponding to the node identification information as a child node in the running state in the target sub-process system.
9. A computer-readable storage medium, on which a computer program is stored which, when being executed by a processor, carries out the steps of the method according to any one of claims 1 to 5.
10. An electronic device, comprising:
a memory having a computer program stored thereon;
a processor for executing the computer program in the memory to carry out the steps of the method of any one of claims 1 to 5.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201911053940.6A CN110930110B (en) | 2019-10-31 | 2019-10-31 | Distributed flow monitoring method and device, storage medium and electronic equipment |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201911053940.6A CN110930110B (en) | 2019-10-31 | 2019-10-31 | Distributed flow monitoring method and device, storage medium and electronic equipment |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN110930110A CN110930110A (en) | 2020-03-27 |
| CN110930110B true CN110930110B (en) | 2022-06-07 |
Family
ID=69850063
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201911053940.6A Active CN110930110B (en) | 2019-10-31 | 2019-10-31 | Distributed flow monitoring method and device, storage medium and electronic equipment |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN110930110B (en) |
Families Citing this family (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111626602B (en) * | 2020-05-25 | 2023-08-01 | 泰康保险集团股份有限公司 | Service processing method, service processing device, storage medium and electronic equipment |
| CN112148732B (en) * | 2020-08-24 | 2024-11-15 | 北京来也网络科技有限公司 | Smart grid electronic handover order monitoring method and device combining RPA and AI |
| CN113919728B (en) * | 2021-10-22 | 2025-06-27 | 长鑫存储技术有限公司 | Process management methods and equipment |
Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN105335821A (en) * | 2015-10-18 | 2016-02-17 | 广州赛意信息科技有限公司 | Fusion-based multiple-system process centralized processing method |
| CN106651301A (en) * | 2016-11-29 | 2017-05-10 | 东软集团股份有限公司 | Process monitoring method and apparatus |
| CN107958021A (en) * | 2017-10-27 | 2018-04-24 | 东软集团股份有限公司 | Processing method, device, storage medium and the equipment of operation flow data |
| CN110288255A (en) * | 2019-06-28 | 2019-09-27 | 深圳前海微众银行股份有限公司 | Process guarantee method and device for distributed transactions |
-
2019
- 2019-10-31 CN CN201911053940.6A patent/CN110930110B/en active Active
Patent Citations (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN105335821A (en) * | 2015-10-18 | 2016-02-17 | 广州赛意信息科技有限公司 | Fusion-based multiple-system process centralized processing method |
| CN106651301A (en) * | 2016-11-29 | 2017-05-10 | 东软集团股份有限公司 | Process monitoring method and apparatus |
| CN107958021A (en) * | 2017-10-27 | 2018-04-24 | 东软集团股份有限公司 | Processing method, device, storage medium and the equipment of operation flow data |
| CN110288255A (en) * | 2019-06-28 | 2019-09-27 | 深圳前海微众银行股份有限公司 | Process guarantee method and device for distributed transactions |
Also Published As
| Publication number | Publication date |
|---|---|
| CN110930110A (en) | 2020-03-27 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN114363042B (en) | Log analysis method, device, equipment and readable storage medium | |
| CN109218407B (en) | Code control method and terminal device based on log monitoring technology | |
| CN110930110B (en) | Distributed flow monitoring method and device, storage medium and electronic equipment | |
| US9929930B2 (en) | Reducing an amount of captured network traffic data to analyze | |
| CN107426022A (en) | Security incident monitoring method and device, electronic equipment, storage medium | |
| US10659289B2 (en) | System and method for event processing order guarantee | |
| CN110166562B (en) | Data synchronization method and device, storage medium and electronic equipment | |
| CN111679968A (en) | Detecting method, device, computer equipment and storage medium for abnormal interface call | |
| WO2019075845A1 (en) | Construction method and device for link call relationship, computer device and storage medium | |
| CN113220342A (en) | Centralized configuration method and device, electronic equipment and storage medium | |
| CN108804574B (en) | Alarm prompting method and device, computer readable storage medium and electronic equipment | |
| CN112579165B (en) | Batch operation execution method, device, readable medium and electronic device | |
| US10205767B2 (en) | Management system and method for a big data processing device | |
| CN110620695A (en) | Data processing method and related equipment | |
| CN114567678A (en) | Resource calling method and device of cloud security service and electronic equipment | |
| CN111080250B (en) | Flow backspacing compensation method and device, storage medium and electronic equipment | |
| US20240134326A1 (en) | Smart building data connector | |
| US20240135470A1 (en) | Smart building data connector | |
| CN115774739A (en) | Transaction data tracking method and device | |
| CN107577546B (en) | Information processing method and device and electronic equipment | |
| CN108288135B (en) | System compatibility method and device, computer readable storage medium and electronic equipment | |
| US12386986B1 (en) | Endpoint security synchronization | |
| CN113672910B (en) | Security event processing method and device | |
| KR102653510B1 (en) | Method and electronic device for providing a push noitification | |
| CN110599005B (en) | Process analysis method and device, computer readable storage medium and electronic device |
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 |