CN113760487A - Service processing method and device - Google Patents
Service processing method and device Download PDFInfo
- Publication number
- CN113760487A CN113760487A CN202010778822.8A CN202010778822A CN113760487A CN 113760487 A CN113760487 A CN 113760487A CN 202010778822 A CN202010778822 A CN 202010778822A CN 113760487 A CN113760487 A CN 113760487A
- Authority
- CN
- China
- Prior art keywords
- service
- processing
- configuration flow
- calling
- data request
- 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.)
- Granted
Links
- 238000003672 processing method Methods 0.000 title abstract description 13
- 238000012545 processing Methods 0.000 claims abstract description 87
- 238000000034 method Methods 0.000 claims abstract description 78
- 230000008569 process Effects 0.000 claims abstract description 34
- 238000004590 computer program Methods 0.000 claims description 8
- 238000011423 initialization method Methods 0.000 claims description 4
- 230000008878 coupling Effects 0.000 abstract description 4
- 238000010168 coupling process Methods 0.000 abstract description 4
- 238000005859 coupling reaction Methods 0.000 abstract description 4
- 238000010586 diagram Methods 0.000 description 14
- 238000004891 communication Methods 0.000 description 7
- 230000006870 function Effects 0.000 description 6
- 230000003287 optical effect Effects 0.000 description 4
- 230000004048 modification Effects 0.000 description 3
- 238000012986 modification Methods 0.000 description 3
- 230000008901 benefit Effects 0.000 description 2
- 238000004364 calculation method Methods 0.000 description 2
- 238000013461 design Methods 0.000 description 2
- 230000000694 effects Effects 0.000 description 2
- 239000000835 fiber Substances 0.000 description 2
- 238000007710 freezing Methods 0.000 description 2
- 230000000644 propagated effect Effects 0.000 description 2
- 239000004065 semiconductor Substances 0.000 description 2
- 238000012795 verification Methods 0.000 description 2
- 238000010276 construction Methods 0.000 description 1
- 238000005538 encapsulation Methods 0.000 description 1
- 238000005516 engineering process Methods 0.000 description 1
- 230000006872 improvement Effects 0.000 description 1
- 239000004973 liquid crystal related substance Substances 0.000 description 1
- 239000013307 optical fiber Substances 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
- 238000012546 transfer Methods 0.000 description 1
Images
Classifications
-
- 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/46—Multiprogramming arrangements
- G06F9/48—Program initiating; Program switching, e.g. by interrupt
- G06F9/4806—Task transfer initiation or dispatching
- G06F9/4843—Task transfer initiation or dispatching by program, e.g. task dispatcher, supervisor, operating system
- G06F9/4881—Scheduling strategies for dispatcher, e.g. round robin, multi-level priority queues
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/90—Details of database functions independent of the retrieved data types
- G06F16/95—Retrieval from the web
- G06F16/953—Querying, e.g. by the use of web search engines
-
- 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/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/547—Remote procedure calls [RPC]; Web services
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Software Systems (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Databases & Information Systems (AREA)
- Data Mining & Analysis (AREA)
- Stored Programmes (AREA)
Abstract
The invention discloses a service processing method and a service processing device, and relates to the technical field of computers. One specific implementation mode of the method comprises the steps of receiving a service data request and acquiring a corresponding process code; calling a data stream processing engine through an external unified calling interface, and further obtaining a corresponding actuator according to the process code; processing the service data request according to the configuration flow of the actuator; wherein the configuration flow is set to a chain of responsibility mode. Therefore, the implementation mode of the invention can solve the problems of high complexity and high code coupling degree of the service processing of the existing software product.
Description
Technical Field
The present invention relates to the field of computer technologies, and in particular, to a method and an apparatus for processing a service.
Background
Currently, more and more software products are presented, such as WeChat apps in mobile phones, and websites accessed by computers. The design mode generally adopts a C/S architecture or a B/S architecture. Wherein, C represents a client, which refers to an application program installed in a device such as a mobile phone or a computer; b represents a browser, which refers to a unified application used for accessing the Internet in equipment such as a computer or a mobile phone; and S denotes service provisioning. The software product roughly comprises 3 parts: a service requester, a service provider, and a network signal connecting the two. When the software product is used, a user clicks an application program in equipment such as a mobile phone or a computer, the program sends out a message, the message is transmitted to a server through a network signal, the server returns a signal after processing, and the signal is displayed on a screen in a certain format for the user to check.
In the process of implementing the invention, the inventor finds that at least the following problems exist in the prior art:
each independent system is provided with a corresponding background service system which can be used for connecting service requests of a front-end client or a browser. Any operation of the user may correspond to a complex processing procedure of the background service, and the complexity of the service causes a long processing procedure of the background service, the processing procedure is complex, the code coupling degree is high, and it is difficult to add a new service.
Disclosure of Invention
In view of this, embodiments of the present invention provide a service processing method and apparatus, which can solve the problems of high complexity and high code coupling degree in service processing of existing software products.
In order to achieve the above object, according to an aspect of the embodiments of the present invention, a service processing method is provided, including receiving a service data request, and obtaining a corresponding flow code; calling a data stream processing engine through an external unified calling interface, and further obtaining a corresponding actuator according to the process code; processing the service data request according to the configuration flow of the actuator; wherein the configuration flow is set to a chain of responsibility mode.
Optionally, processing the service data request according to the configuration flow of the executor includes:
executing the service data request according to chain nodes on a configuration flow responsibility chain mode;
judging whether the execution is successful or not when one chain node is executed, if so, judging whether the next chain node exists or not according to the linked list, if so, continuing to execute the next chain node, otherwise, returning to the data stream processing engine, and generating a successful execution result;
if not, judging whether the last chain node exists according to the linked list, and if so, executing a rollback method of the last chain node; and if not, returning to the data stream processing engine, and generating an execution failure result.
Optionally, the determining whether the execution is successful or not every time one chain node is executed includes:
and each chain node executes the DoHandler event, and then judges whether the execution is successful.
Optionally, the method further comprises: the linked list is a bi-directional linked list.
Optionally, the invoking of the data stream processing engine through an external unified invoking interface includes:
and calling the data stream processing engine through a calling interface provided by the ResourceHandlerExecutor class.
Optionally, according to the configuration flow of the executor, before processing the service data request, the method includes:
and setting a configuration flow for each flow code through an AbstractResourceHandlerConfiguration configuration class.
Optionally, processing the service data request according to the configuration flow of the executor includes:
initializing a configuration flow according to a flow code by calling a build initialization method of a side issue type through a ResourceHandlerExecutor service;
and calling an execHandler method of the side issue class through the ResourceHandlerExecutor service, and executing a corresponding configuration flow.
In addition, the invention also provides a service processing device, which comprises an acquisition module, a processing module and a processing module, wherein the acquisition module is used for receiving the service data request and acquiring the corresponding process code; calling a data stream processing engine through an external unified calling interface, and further obtaining a corresponding actuator according to the process code; the processing module is used for processing the service data request according to the configuration flow of the actuator; wherein the configuration flow is set to a chain of responsibility mode.
One embodiment of the above invention has the following advantages or benefits: the invention carries out flow configuration aiming at each service, and each chain node has the operations of entering condition, forward execution and reverse execution. The service is convenient to be off-line and added, and the technical effect like hot plug is realized without modifying logic. That is, the invention can continuously access new service application scenes, and can be conveniently and flexibly expanded. And, the business process can be added or deleted in a hot-plug mode. Meanwhile, each service chain node has an event processor and an object consistency rollback method.
Further effects of the above-mentioned non-conventional alternatives will be described below in connection with the embodiments.
Drawings
The drawings are included to provide a better understanding of the invention and are not to be construed as unduly limiting the invention. Wherein:
fig. 1 is a schematic diagram of a main flow of a service processing method according to a first embodiment of the present invention;
FIG. 2 is a schematic diagram of core processing classes according to an embodiment of the invention;
fig. 3 is an example of a flow configuration of a business process method according to an embodiment of the present invention;
FIG. 4 is an example of a chain node configuration according to an embodiment of the present invention;
FIG. 5 is a data flow diagram of a business processing method according to an embodiment of the invention;
FIG. 6 is a schematic diagram of the main modules of a traffic processing apparatus according to an embodiment of the present invention;
FIG. 7 is an exemplary system architecture diagram in which embodiments of the present invention may be employed;
fig. 8 is a schematic structural diagram of a computer system suitable for implementing a terminal device or a server according to an embodiment of the present invention.
Detailed Description
Exemplary embodiments of the present invention are described below with reference to the accompanying drawings, in which various details of embodiments of the invention are included to assist understanding, and which are to be considered as merely exemplary. Accordingly, those of ordinary skill in the art will recognize that various changes and modifications of the embodiments described herein can be made without departing from the scope and spirit of the invention. Also, descriptions of well-known functions and constructions are omitted in the following description for clarity and conciseness.
Fig. 1 is a schematic diagram of a main flow of a service processing method according to a first embodiment of the present invention, and as shown in fig. 1, the service processing method includes:
step S101, receiving a service data request and acquiring a corresponding process code.
In the embodiment, a corresponding service processing flow is uniquely defined by a flow code, that is, one service processing flow corresponds to one flow code, and a service data request corresponds to a corresponding service processing flow.
And step S102, calling a data stream processing engine through an external unified calling interface, and further obtaining a corresponding actuator according to the process code.
In some embodiments, as shown in fig. 2, a schematic diagram of a core processing class according to an embodiment of the present invention is shown. And calling the data stream processing engine through a calling interface provided by the ResourceHandlerExecutor class.
Preferably, an interface may be set for each chaining node, and the resourceundler abstract service processing node interface (i.e., chaining node interface) is implemented by an abstract resourceundler abstract class, so that each service flow includes multiple implementation examples of the abstract resourceundler. For example: freezeMoney, freezeGoods fund-freezing, goods-freezing two example implementation classes, inherit the abstract ResourceHandler abstract class.
Further, in the validRequest method in the abstract resource Handler abstract class, a default value indicates that the current node is executed, and if a certain condition needs to be met, the current node needs to be executed, and the method needs to be rewritten. That is, a call condition can be set for each chain node by the validRequest method in the AbstractResourceHandler abstract class. In addition, the failCallBack method in the abstract resource Handler abstract class is used for realizing the rollback of the current chain node by default true.
Preferably, for each chain node, this is implemented by the minimum event handling unit ResourceHandler class. The method needs to be realized for the specific implementation class through the doHandle method of the minimum event processing unit resource Handler class, and the subtasks of the current node can be processed. The handle method through the minimum event handling unit resource handler class is the execution chain (process) scheduling method. And determining whether the current node needs to perform verification or not through a validRequest method of the minimum event processing unit ResourceHandler class. The current node rollback is performed by the failcall back method of the minimum event handling unit ResourceHandler class.
It should be noted that, according to the configuration flow of the executor, before the service data request is processed, a configuration flow may be set for each flow code through an abstract resource handler configuration class. Each business process is configured independently, such as ordering process and transfer process.
As a specific example, as shown in fig. 3 and 4, a specific executor is configured, which includes two business processes, i.e., "a general replenishment execution process" and "an emergency replenishment execution process", respectively. Taking "general replenishment" as an example, configuration is shown, a service node is configured in a general replenishment process, a flowCode is defined to be 20423999 by a flowType method, and a process name is set by a handlerconfigurame method to be "general replenishment". Configuring a chain node of a general replenishment service through a handler method, wherein the chain node comprises pre-check, participation, positioned verification acquisition, configuration information acquisition, safety inventory acquisition, maximum inventory acquisition and the like, replenishment target storage area calculation, replenishment inventory acquisition according to the configuration information, replenishment calculation execution according to configuration, positioning result encapsulation processing, racking recommendation and inventory pre-occupation.
It should be noted that, adding or deleting a flow of a certain service only needs to add or delete a corresponding executor and a configuration flow.
Step S103, processing the service data request according to the configuration flow of the actuator; wherein the configuration flow is set to a chain of responsibility mode.
In the embodiment, the configuration flow is set to be in a responsibility chain mode, so that the nodes on the responsibility chain ensure the independence of the sub-services, that is, each node executes the corresponding sub-service. Wherein the responsibility chain mode means that a plurality of objects are connected to form a chain by each object's reference to its next home.
In some embodiments, the processing the service data request according to the configuration flow of the executor, specifically, the implementation process includes:
executing the service data request according to chain nodes on a configuration flow responsibility chain mode;
judging whether the execution is successful or not when one chain node is executed, if so, judging whether the next chain node exists or not according to the linked list, if so, continuing to execute the next chain node, otherwise, returning to the data stream processing engine, and generating a successful execution result; if not, judging whether the last chain node exists according to the linked list, and if so, executing a rollback method of the last chain node; and if not, returning to the data stream processing engine, and generating an execution failure result.
Preferably, each chain node executes the doHandler event, and then determines whether the execution is successful.
In addition, it should be noted that each node in the flow is organized in a linked list form to form a bi-directional linked list with a head and a tail.
It can be seen that each chain node is an atomic event, including forward submission of doHandler event processing, and rollback processing of the failCallBack method.
As another embodiment, the processing the service data request according to the configuration flow of the executor includes:
and initializing the configuration flow according to the flow code by calling the build initialization method of the side issue class through the ResourceHandlerExecutor service. And calling an execHandler method of the side issue class through the ResourceHandlerExecutor service, and executing a corresponding configuration flow.
As another embodiment of the present invention, after receiving a service data request and acquiring a corresponding flow code, as shown in fig. 5, a data stream processing engine is called through an external unified call interface, and then an exenchandler method corresponding to an executor entry ResourceHandlerExecutor starts to be executed according to a configuration flow. And processing the sub-services of the current chain node by using a specific doHandle service processing method, judging whether the execution is successful, judging whether a next chain node exists according to a linked list if the execution is successful, continuing to execute the next chain node if the execution is successful, and returning to a data stream processing engine if the execution is not successful to generate an execution success result. If not, judging whether the last chain node exists according to the linked list, and if so, executing a rollback method of the last chain node; and if not, returning to the data stream processing engine, and generating an execution failure result.
Fig. 6 is a schematic diagram of main modules of a service processing apparatus according to an embodiment of the present invention, and as shown in fig. 6, the service processing apparatus 600 includes an obtaining module 601 and a processing module 602. The obtaining module 601 receives a service data request, and obtains a corresponding process code; calling a data stream processing engine through an external unified calling interface, and further obtaining a corresponding actuator according to the process code; the processing module 602 processes the service data request according to the configuration flow of the actuator; wherein the configuration flow is set to a chain of responsibility mode.
In some embodiments, the processing module 602 processes the service data request according to the configuration flow of the executor, including:
executing the service data request according to chain nodes on a configuration flow responsibility chain mode;
judging whether the execution is successful or not when one chain node is executed, if so, judging whether the next chain node exists or not according to the linked list, if so, continuing to execute the next chain node, otherwise, returning to the data stream processing engine, and generating a successful execution result;
if not, judging whether the last chain node exists according to the linked list, and if so, executing a rollback method of the last chain node; and if not, returning to the data stream processing engine, and generating an execution failure result.
In some embodiments, the determining whether the execution is successful or not by the processing module 602 after each execution completes one chain node includes:
and each chain node executes the DoHandler event, and then judges whether the execution is successful.
In some embodiments, the linked list is a doubly linked list.
In some embodiments, the obtaining module 601 calls the data stream processing engine through an external unified call interface, including:
and calling the data stream processing engine through a calling interface provided by the ResourceHandlerExecutor class.
In some embodiments, before the processing module 602 processes the service data request according to the configuration flow of the executor, the processing module includes:
and setting a configuration flow for each flow code through an AbstractResourceHandlerConfiguration configuration class.
In some embodiments, the processing module 602 processes the service data request according to the configuration flow of the executor, including:
initializing a configuration flow according to a flow code by calling a build initialization method of a side issue type through a ResourceHandlerExecutor service;
and calling an execHandler method of the side issue class through the ResourceHandlerExecutor service, and executing a corresponding configuration flow.
It should be noted that, the service processing method and the service processing apparatus of the present invention have corresponding relation in the specific implementation content, and therefore, the repeated content is not described again.
Fig. 7 shows an exemplary system architecture 700 to which a service processing method or a service processing apparatus according to an embodiment of the present invention can be applied.
As shown in fig. 7, the system architecture 700 may include terminal devices 701, 702, 703, a network 704, and a server 705. The network 704 serves to provide a medium for communication links between the terminal devices 701, 702, 703 and the server 705. Network 704 may include various connection types, such as wired, wireless communication links, or fiber optic cables, to name a few.
A user may use the terminal devices 701, 702, 703 to interact with a server 705 over a network 704, to receive or send messages or the like. The terminal devices 701, 702, 703 may have installed thereon various communication client applications, such as a shopping-like application, a web browser application, a search-like application, an instant messaging tool, a mailbox client, social platform software, etc. (by way of example only).
The terminal devices 701, 702, 703 may be various electronic devices having a business process screen and supporting web browsing, including but not limited to smart phones, tablet computers, laptop portable computers, desktop computers, and the like.
The server 705 may be a server providing various services, such as a background management server (for example only) providing support for shopping websites browsed by users using the terminal devices 701, 702, 703. The backend management server may analyze and perform other processing on the received data such as the product information query request, and feed back a processing result (for example, target push information, product information — just an example) to the terminal device.
It should be noted that the service processing method provided by the embodiment of the present invention is generally executed by the server 705, and accordingly, the computing device is generally disposed in the server 705.
It should be understood that the number of terminal devices, networks, and servers in fig. 7 is merely illustrative. There may be any number of terminal devices, networks, and servers, as desired for implementation.
Referring now to FIG. 8, shown is a block diagram of a computer system 800 suitable for use with a terminal device implementing an embodiment of the present invention. The terminal device shown in fig. 8 is only an example, and should not bring any limitation to the functions and the scope of use of the embodiments of the present invention.
As shown in fig. 8, the computer system 800 includes a Central Processing Unit (CPU)801 that can perform various appropriate actions and processes in accordance with a program stored in a Read Only Memory (ROM)802 or a program loaded from a storage section 708 into a Random Access Memory (RAM) 803. In the RAM803, various programs and data necessary for the operation of the computer system 800 are also stored. The CPU801, ROM802, and RAM803 are connected to each other via a bus 804. An input/output (I/O) interface 805 is also connected to bus 804.
The following components are connected to the I/O interface 805: an input portion 806 including a keyboard, a mouse, and the like; an output section 807 including components such as a Cathode Ray Tube (CRT), a liquid crystal service processor (LCD), and a speaker; a storage portion 808 including a hard disk and the like; and a communication section 809 including a network interface card such as a LAN card, a modem, or the like. The communication section 809 performs communication processing via a network such as the internet. A drive 810 is also connected to the I/O interface 805 as necessary. A removable medium 811 such as a magnetic disk, an optical disk, a magneto-optical disk, a semiconductor memory, or the like is mounted on the drive 810 as necessary, so that a computer program read out therefrom is mounted on the storage section 808 as necessary.
In particular, according to the embodiments of the present disclosure, the processes described above with reference to the flowcharts may be implemented as computer software programs. For example, embodiments of the present disclosure include a computer program product comprising a computer program embodied on a computer readable medium, the computer program comprising program code for performing the method illustrated in the flow chart. In such an embodiment, the computer program can be downloaded and installed from a network through the communication section 809 and/or installed from the removable medium 811. The computer program executes the above-described functions defined in the system of the present invention when executed by the Central Processing Unit (CPU) 801.
It should be noted that the computer readable medium shown in the present invention can be a computer readable signal medium or a computer readable storage medium or any combination of the two. A computer readable storage medium may be, for example, but not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or any combination of the foregoing. More specific examples of the computer readable storage medium may include, but are not limited to: an electrical connection having one or more wires, a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In the present invention, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device. In the present invention, however, a computer readable signal medium may include a propagated data signal with computer readable program code embodied therein, for example, in baseband or as part of a carrier wave. Such a propagated data signal may take many forms, including, but not limited to, electro-magnetic, optical, or any suitable combination thereof. A computer readable signal medium may also be any computer readable medium that is not a computer readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, apparatus, or device. Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to: wireless, wire, fiber optic cable, RF, etc., or any suitable combination of the foregoing.
The flowchart and block diagrams in the figures illustrate the architecture, functionality, and operation of possible implementations of systems, methods and computer program products according to various embodiments of the present invention. In this regard, each block in the flowchart or block diagrams may represent a module, segment, or portion of code, which comprises one or more executable instructions for implementing the specified logical function(s). It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or the blocks may sometimes be executed in the reverse order, depending upon the functionality involved. It will also be noted that each block of the block diagrams or flowchart illustration, and combinations of blocks in the block diagrams or flowchart illustration, can be implemented by special purpose hardware-based systems which perform the specified functions or acts, or combinations of special purpose hardware and computer instructions.
The modules described in the embodiments of the present invention may be implemented by software or hardware. The described modules may also be provided in a processor, which may be described as: a processor includes an acquisition module and a processing module. Wherein the names of the modules do not in some cases constitute a limitation of the module itself.
As another aspect, the present invention also provides a computer-readable medium that may be contained in the apparatus described in the above embodiments; or may be separate and not incorporated into the device. The computer readable medium carries one or more programs which, when executed by a device, cause the device to receive a service data request and obtain a corresponding flow code; calling a data stream processing engine through an external unified calling interface, and further obtaining a corresponding actuator according to the process code; processing the service data request according to the configuration flow of the actuator; wherein the configuration flow is set to a chain of responsibility mode.
According to the technical scheme of the embodiment of the invention, the problems of high complexity and high code coupling degree of service processing of the conventional software product can be solved.
The above-described embodiments should not be construed as limiting the scope of the invention. Those skilled in the art will appreciate that various modifications, combinations, sub-combinations, and substitutions can occur, depending on design requirements and other factors. Any modification, equivalent replacement, and improvement made within the spirit and principle of the present invention should be included in the protection scope of the present invention.
Claims (10)
1. A method for processing a service, comprising:
receiving a service data request and acquiring a corresponding process code;
calling a data stream processing engine through an external unified calling interface, and further obtaining a corresponding actuator according to the process code;
processing the service data request according to the configuration flow of the actuator; wherein the configuration flow is set to a chain of responsibility mode.
2. The method of claim 1, wherein processing the service data request according to the configuration flow of the executor comprises:
executing the service data request according to chain nodes on a configuration flow responsibility chain mode;
judging whether the execution is successful or not when one chain node is executed, if so, judging whether the next chain node exists or not according to the linked list, if so, continuing to execute the next chain node, otherwise, returning to the data stream processing engine, and generating a successful execution result;
if not, judging whether the last chain node exists according to the linked list, and if so, executing a rollback method of the last chain node; and if not, returning to the data stream processing engine, and generating an execution failure result.
3. The method of claim 2, wherein determining whether execution is successful each time execution completes one chain node comprises:
and each chain node executes the DoHandler event, and then judges whether the execution is successful.
4. The method of claim 2, further comprising:
the linked list is a bi-directional linked list.
5. The method of claim 1, wherein the calling the data stream processing engine through an external unified calling interface comprises:
and calling the data stream processing engine through a calling interface provided by the ResourceHandlerExecutor class.
6. The method of claim 1, wherein processing the service data request according to the configuration flow of the executor comprises:
and setting a configuration flow for each flow code through an AbstractResourceHandlerConfiguration configuration class.
7. The method according to any of claims 1-6, wherein processing the service data request according to the configuration flow of the executor comprises:
initializing a configuration flow according to a flow code by calling a build initialization method of a side issue type through a ResourceHandlerExecutor service;
and calling an execHandler method of the side issue class through the ResourceHandlerExecutor service, and executing a corresponding configuration flow.
8. A traffic processing apparatus, comprising:
the acquisition module is used for receiving the service data request and acquiring the corresponding process code; calling a data stream processing engine through an external unified calling interface, and further obtaining a corresponding actuator according to the process code;
the processing module is used for processing the service data request according to the configuration flow of the actuator; wherein the configuration flow is set to a chain of responsibility mode.
9. An electronic device, comprising:
one or more processors;
a storage device for storing one or more programs,
when executed by the one or more processors, cause the one or more processors to implement the method of any one of claims 1-7.
10. A computer-readable medium, on which a computer program is stored, which, when being executed by a processor, carries out the method according to any one of claims 1-7.
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202010778822.8A CN113760487B (en) | 2020-08-05 | 2020-08-05 | Service processing method and device |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202010778822.8A CN113760487B (en) | 2020-08-05 | 2020-08-05 | Service processing method and device |
Publications (2)
Publication Number | Publication Date |
---|---|
CN113760487A true CN113760487A (en) | 2021-12-07 |
CN113760487B CN113760487B (en) | 2024-04-12 |
Family
ID=78785658
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN202010778822.8A Active CN113760487B (en) | 2020-08-05 | 2020-08-05 | Service processing method and device |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN113760487B (en) |
Cited By (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN114567667A (en) * | 2022-03-04 | 2022-05-31 | 深圳前海环融联易信息科技服务有限公司 | Service processing assembly system based on responsibility chain design mode |
Citations (11)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US20100069035A1 (en) * | 2008-03-14 | 2010-03-18 | Johnson William J | Systema and method for location based exchanges of data facilitating distributed location applications |
US20120095734A1 (en) * | 2010-10-15 | 2012-04-19 | International Business Machines Corporation | Optimizing business process management models |
US20140165039A1 (en) * | 2012-11-07 | 2014-06-12 | Infosys Limited | Methods for detecting plagiarism in software code implementing a design pattern |
US20150088866A1 (en) * | 2013-09-20 | 2015-03-26 | Oracle International Corporation | Accessing application services from forms |
CN108346028A (en) * | 2017-01-24 | 2018-07-31 | 阿里巴巴集团控股有限公司 | A kind of business approval processing method, apparatus and system |
CN209657363U (en) * | 2019-03-29 | 2019-11-19 | 国网陕西省电力公司信息通信公司 | An attendance management system |
WO2020037896A1 (en) * | 2018-08-21 | 2020-02-27 | 平安科技(深圳)有限公司 | Facial feature value extraction method and device, computer apparatus, and storage medium |
CN110990076A (en) * | 2019-11-20 | 2020-04-10 | 杭州安恒信息技术股份有限公司 | Hot plug component chain calling method based on responsibility chain mode |
CN111190901A (en) * | 2019-12-12 | 2020-05-22 | 平安医疗健康管理股份有限公司 | Business data storage method and device, computer equipment and storage medium |
CN111222367A (en) * | 2018-11-26 | 2020-06-02 | 上海耕岩智能科技有限公司 | Fingerprint identification method and device, storage medium and terminal |
CN111427701A (en) * | 2020-03-09 | 2020-07-17 | 中国建设银行股份有限公司 | Workflow engine system and business processing method |
-
2020
- 2020-08-05 CN CN202010778822.8A patent/CN113760487B/en active Active
Patent Citations (11)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US20100069035A1 (en) * | 2008-03-14 | 2010-03-18 | Johnson William J | Systema and method for location based exchanges of data facilitating distributed location applications |
US20120095734A1 (en) * | 2010-10-15 | 2012-04-19 | International Business Machines Corporation | Optimizing business process management models |
US20140165039A1 (en) * | 2012-11-07 | 2014-06-12 | Infosys Limited | Methods for detecting plagiarism in software code implementing a design pattern |
US20150088866A1 (en) * | 2013-09-20 | 2015-03-26 | Oracle International Corporation | Accessing application services from forms |
CN108346028A (en) * | 2017-01-24 | 2018-07-31 | 阿里巴巴集团控股有限公司 | A kind of business approval processing method, apparatus and system |
WO2020037896A1 (en) * | 2018-08-21 | 2020-02-27 | 平安科技(深圳)有限公司 | Facial feature value extraction method and device, computer apparatus, and storage medium |
CN111222367A (en) * | 2018-11-26 | 2020-06-02 | 上海耕岩智能科技有限公司 | Fingerprint identification method and device, storage medium and terminal |
CN209657363U (en) * | 2019-03-29 | 2019-11-19 | 国网陕西省电力公司信息通信公司 | An attendance management system |
CN110990076A (en) * | 2019-11-20 | 2020-04-10 | 杭州安恒信息技术股份有限公司 | Hot plug component chain calling method based on responsibility chain mode |
CN111190901A (en) * | 2019-12-12 | 2020-05-22 | 平安医疗健康管理股份有限公司 | Business data storage method and device, computer equipment and storage medium |
CN111427701A (en) * | 2020-03-09 | 2020-07-17 | 中国建设银行股份有限公司 | Workflow engine system and business processing method |
Cited By (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN114567667A (en) * | 2022-03-04 | 2022-05-31 | 深圳前海环融联易信息科技服务有限公司 | Service processing assembly system based on responsibility chain design mode |
CN114567667B (en) * | 2022-03-04 | 2024-03-15 | 深圳前海环融联易信息科技服务有限公司 | A business processing component system based on the chain of responsibility design pattern |
Also Published As
Publication number | Publication date |
---|---|
CN113760487B (en) | 2024-04-12 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN112612467B (en) | A method and device for processing a micro front-end architecture based on Qiankun | |
CN111277639A (en) | Method and device for maintaining data consistency | |
CN111427701A (en) | Workflow engine system and business processing method | |
CN113672357A (en) | Task scheduling method, device and system | |
CN111090423A (en) | Webhook framework system and method for realizing active calling and event triggering | |
CN111478781B (en) | Message broadcasting method and device | |
CN110019158A (en) | A kind of method and apparatus of monitoring data quality | |
CN112398669A (en) | Hadoop deployment method and device | |
CN112905273A (en) | Service calling method and device | |
CN113779122B (en) | Method and device for exporting data | |
CN112084042A (en) | Message processing method and device | |
CN113760487B (en) | Service processing method and device | |
CN113127561B (en) | Method and device for generating service single number, electronic equipment and storage medium | |
CN113703933A (en) | Task processing method and device | |
CN113765983A (en) | Site service deployment method and device | |
CN113760561A (en) | Data processing method and device | |
CN111382953A (en) | Dynamic process generation method and device | |
CN110909269B (en) | Log reporting method and device | |
CN113110898A (en) | Transaction task execution method and device | |
CN113064678A (en) | Cache configuration method and device | |
CN113448652A (en) | Request processing method and device | |
CN113766437B (en) | Short message sending method and device | |
CN113778703B (en) | An event monitoring method, related device and event monitoring system | |
CN112311833A (en) | Data updating method and device | |
CN112732417B (en) | Method and device for processing application request |
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 |