[go: up one dir, main page]

WO2021057252A1 - Service processing flow configuration method and apparatus, and service request processing method and apparatus - Google Patents

Service processing flow configuration method and apparatus, and service request processing method and apparatus Download PDF

Info

Publication number
WO2021057252A1
WO2021057252A1 PCT/CN2020/105959 CN2020105959W WO2021057252A1 WO 2021057252 A1 WO2021057252 A1 WO 2021057252A1 CN 2020105959 W CN2020105959 W CN 2020105959W WO 2021057252 A1 WO2021057252 A1 WO 2021057252A1
Authority
WO
WIPO (PCT)
Prior art keywords
processing flow
business
module
execution
processing
Prior art date
Application number
PCT/CN2020/105959
Other languages
French (fr)
Chinese (zh)
Inventor
肖梁军
王康龙
秦刚
司孝波
钱津津
Original Assignee
苏宁云计算有限公司
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by 苏宁云计算有限公司 filed Critical 苏宁云计算有限公司
Priority to CA3155732A priority Critical patent/CA3155732A1/en
Publication of WO2021057252A1 publication Critical patent/WO2021057252A1/en

Links

Images

Classifications

    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00Arrangements for program control, e.g. control units
    • G06F9/06Arrangements 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/44Arrangements for executing specific programs
    • G06F9/445Program loading or initiating
    • G06F9/44505Configuring for program initiating, e.g. using registry, configuration files
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F8/00Arrangements for software engineering
    • G06F8/60Software deployment

Definitions

  • the present invention relates to the field of computer technology, in particular to a method for configuring a business processing flow, a method and a device for processing a business request.
  • the real-time business logic adjustment can adopt the gray-scale publishing scheme, but the use of gray-scale publishing will cause the system service performance to decline during the publishing period, and at the same time, the system publishing window is limited, the operation process is more complicated, and risks are easily introduced.
  • Java's hot-loading technology the way to directly modify the bytecode in the jvm is difficult to monitor and is not suitable for the deployment of the core system in the production environment.
  • the hot deployment of Java is not suitable for frequent deployment and is relatively time-consuming and modified at the same time. It's just a small part of the overall business. When a small amount of business changes, hot deployment will reload the entire application, which is costly.
  • real-time business logic adjustments can also adopt a logic switch scheme to retain the new and old version data processing logic in the product, and route to the old version data processing logic through the switch control, or route to the new version data processing logic, but the solution needs to be shut down and released , And it is inconvenient to perform version rollback operations.
  • the present invention provides a business processing flow configuration method, business request processing method and device, which can improve system stability and reduce system risks without system publishing.
  • the present invention provides a business processing flow configuration method, the method includes:
  • the new business processing flow includes a plurality of processing modules with an execution sequence, and each of the plurality of processing modules includes at least one execution logic between execution units. ;
  • the configuration according to the received configuration information to generate a new business processing flow includes:
  • Receive module configuration information determine corresponding at least one execution unit in the execution unit warehouse according to the module configuration information, configure at least one execution logic between the execution units, and generate a processing module for storage in the processing module warehouse ;
  • Receive business processing flow configuration information determine corresponding multiple processing modules in the processing module warehouse according to the business processing flow configuration information, and configure the execution order among multiple processing modules to generate the new Business processing flow.
  • the configuration according to the received configuration information to generate a new business processing flow includes:
  • the execution sequence between the changed processing module and the processing module that does not need to be changed is configured to generate the new business processing flow.
  • the at least one execution unit includes the LUA script in the redis server.
  • a method for processing a service request includes:
  • the business processing flow corresponding to the business identifier in the business request is determined, wherein the business processing flow includes a plurality of processing modules having an execution sequence, and each of the plurality of processing modules includes at least one Execution logic between execution units;
  • each of the processing modules According to the execution sequence of each of the processing modules and the execution logic between at least one execution unit in each of the processing modules, call a corresponding execution unit from the execution unit warehouse to process the business request;
  • an apparatus for configuring a business processing flow includes:
  • the configuration module is configured to perform configuration according to the received configuration information to generate a new business processing flow.
  • the new business processing flow includes a plurality of processing modules having an execution sequence, and each of the plurality of processing modules includes at least one execution unit Execution logic between;
  • a judging module used for judging whether the service identifier of the target service corresponds to the old version of the service processing flow when receiving the activation request for the target service to activate the new service processing flow;
  • the corresponding module is used to change the service identifier from the business processing flow corresponding to the old version to the new business processing flow when the judgment result of the judgment module is yes, otherwise, directly change
  • the service identifier corresponds to the new service processing flow, so as to activate the new service processing flow.
  • configuration module is specifically used for:
  • Receive module configuration information determine corresponding at least one execution unit in the execution unit warehouse according to the module configuration information, configure at least one execution logic between the execution units, and generate a processing module for storage in the processing module warehouse ;
  • Receive business processing flow configuration information determine corresponding multiple processing modules in the processing module warehouse according to the business processing flow configuration information, and configure the execution order among multiple processing modules to generate the new Business processing flow.
  • configuration module is specifically used for:
  • a service request processing device including:
  • the determining module is used to determine the business processing flow corresponding to the business identifier in the business request when the business request is received, wherein the business processing flow includes a plurality of processing modules having an execution sequence, and a plurality of the processing modules The modules respectively include execution logic between at least one execution unit;
  • An obtaining module configured to obtain multiple processing modules in the business processing flow and the execution sequence of each of the processing modules
  • the processing module is configured to call the corresponding execution unit from the execution unit warehouse to process the business request according to the execution sequence of each of the processing modules and the execution logic between at least one execution unit in each of the processing modules;
  • the return module is used to return the processing result of the service request.
  • the present invention provides a computer device, including:
  • One or more processors are One or more processors;
  • Storage device for storing one or more programs
  • the one or more processors When the one or more programs are executed by the one or more processors, the one or more processors implement the steps of any one of the methods described in the first aspect.
  • the present invention provides a computer device, including:
  • One or more processors are One or more processors;
  • Storage device for storing one or more programs
  • the one or more processors When the one or more programs are executed by the one or more processors, the one or more processors implement the steps of any one of the methods described in the second aspect.
  • the present invention provides a computer-readable storage medium on which a computer program is stored, and when the program is executed by a processor, the steps of any one of the methods described in the first aspect are implemented.
  • the present invention provides a computer-readable storage medium on which a computer program is stored, and when the program is executed by a processor, it implements the steps of any one of the methods described in the second aspect.
  • the present invention provides a business processing flow configuration method, business request processing method and device, which generate a new business processing flow by receiving configuration information for configuration, and when receiving a request for a target business to activate a new business processing flow, if The business identification of the target business already corresponds to the business processing flow of the old version, then the business identification is changed from the business processing flow corresponding to the old version to the new business processing flow, which can be implemented quickly Switching of data processing logic.
  • This switching method is easy to operate, can improve system stability and reduce system risks. It completes the smooth switching of data processing logic without the user's perception, which brings users a better experience. At the same time, it can quickly switch back after problems are found to reduce problems. Scope of influence.
  • FIG. 1 shows a schematic flow chart of a method for configuring a business processing flow provided by an embodiment of the present invention
  • FIG. 2 shows a schematic flowchart of an implementation manner of step 101 in FIG. 1;
  • FIG. 3 shows a schematic flowchart of another implementation manner of step 101 in FIG. 1;
  • Figure 4 shows a schematic flow chart of an old version of a business processing process provided by an embodiment of the present invention.
  • Fig. 5 shows a schematic flow chart of a new service processing process provided by an embodiment of the present invention.
  • FIG. 6 shows a structural block diagram of an apparatus for configuring a business processing flow provided by an embodiment of the present invention
  • Fig. 7 shows a structural block diagram of a service request processing apparatus provided by an embodiment of the present invention.
  • the system release window is limited, business changes are frequent and unpredictable, the difference between the new and the old processing logic is generally small, the correlation is strong, and the implementation is more urgent.
  • the gray-scale release and batch verification are used to realize the logic switching of data processing between the new and old versions, this method requires multiple verifications, multiple releases, and a long switching cycle.
  • the reserved logic switch is used to control the change of the data processing logic, but the range of options available is small, it usually needs to be re-developed and released at the end.
  • the embodiment of the present invention provides a business processing flow configuration method, which generates a new business processing flow by receiving configuration information for configuration, and when receiving a request for the target business to activate the new business processing flow, if the target business
  • the service identifier of has already corresponded to the business processing flow of the old version, then the service identification is changed from the business processing flow corresponding to the old version to the new business processing flow, so that data processing can be realized quickly Logical switching.
  • This switching method is easy to operate, can improve system stability and reduce system risks. It completes the smooth switching of data processing logic without the user's perception, which brings users a better experience. At the same time, it can quickly switch back after problems are found to reduce problems. Scope of influence.
  • the embodiment of the present invention provides a method for configuring a business processing flow.
  • the method may be executed by a configuration server. As shown in FIG. 1, the method may include the following steps:
  • Step 101 Perform configuration according to the received configuration information to generate a new business processing flow.
  • the new business processing flow includes multiple processing modules with an execution sequence, and the multiple processing modules respectively include execution logic between at least one execution unit.
  • the execution unit can be divided into two types: the basic execution unit and the extended execution unit; the basic execution unit includes a JAVA script for processing basic function logic; the extended execution unit includes a LUA script for processing the extended function logic, and the LUA script is pre-stored On the redis server.
  • the process may include:
  • the configuration server receives the module configuration information input by the user on the pre-generated visual configuration interface, uses the execution unit indicated by the module configuration information and the execution logic between the execution units to create or modify the corresponding processing module; receives the user input on the visual configuration interface The configuration information of the business processing flow, using the processing modules indicated by the module configuration information and the execution sequence between the processing modules, create or modify the corresponding business processing flow.
  • the new business processing flow is saved in the pre-built business processing flow library.
  • the configuration information of the business processing flow may be:
  • ModelGroup01 ModelCheck01, ModelDo01, ModelExec01;
  • the processing module includes execution logic between at least one execution unit. If an extended execution unit is used in the processing module, an input parameter (redisDocKey of the lua script) needs to be passed in.
  • the respective configuration information of the verification module, the judgment module, and the execution module may be:
  • ModelCheck01 unitCheck: ⁇ redisDocKey ⁇
  • ModelDo01 unitStart,If(And(unitA,Or(unitB,unitC)),unitE,uintF),unitEnd;
  • ModelExec01 unitExec
  • the symbol ",” is used as a separator for different logic and execution units in the same processing module.
  • the extended execution unit can be used to process special requests, for example, to modify fields such as date and sales rules in the request according to special rules.
  • the configuration information of the extended execution unit can be:
  • a new business processing flow is generated. Since the business processing flow includes multiple processing modules with an execution sequence, the multiple processing modules respectively include at least one execution unit.
  • Logic which can correspond the processing process of a business request to the processing process of a business processing flow. Each stage of the request processing corresponds to each processing module of the business processing flow, and the operation performed in each processing stage corresponds to each processing module in each processing module. Execution unit. In this way, the management of system business processing is transformed into the management of three levels of business processing flow, processing module and execution unit.
  • Step 102 When receiving a request to activate a new business processing flow for the target service, determine whether the business identification of the target business corresponds to the business processing flow of the old version, if yes, proceed to step 103; otherwise, proceed to step 104.
  • the business identifier is inquired in the business processing flow database whether there is a corresponding business processing flow, and if it exists, it is determined that the corresponding business processing flow is an old version of the business processing flow.
  • Step 103 Change the business identifier from the business processing flow corresponding to the old version to the new business processing flow.
  • the correspondence between the business identifier and the old version of the business processing flow is changed to: the correspondence between the business identification and the new business processing flow, and the changed correspondence is saved.
  • the business request can be controlled and the new business processing flow can be used for business processing.
  • Step 104 Directly correspond the service identifier to the new business processing flow, so as to activate the new business processing flow.
  • the method further includes:
  • the business identification is changed from corresponding to the new business processing flow to the business processing flow corresponding to the old version.
  • the embodiment of the present invention provides a business processing flow configuration method, which generates a new business processing flow by receiving configuration information for configuration, and when receiving a request for the target business to activate the new business processing flow, if the business identifier of the target business is If the business processing flow corresponds to the old version, the business identification is changed from the business processing flow corresponding to the old version to the new business processing flow, so that the data processing logic can be switched quickly.
  • This switching method is easy to operate, can improve system stability and reduce system risks, and complete the smooth switching of data processing logic without the user's perception, bringing a better experience to the user. At the same time, it can quickly switch back after the problem is found to reduce the problem. Scope of influence.
  • step 101 performs configuration according to the received configuration information
  • the implementation process of generating a new business processing flow may include:
  • Receive module configuration information determine corresponding at least one execution unit in the execution unit warehouse according to the module configuration information, configure the execution logic between the at least one execution unit, and generate a processing module for storage in the processing module warehouse.
  • the configuration server receives the module configuration information input by the user on the pre-generated visual configuration interface, and after receiving the module configuration information, it parses the configuration information to determine the execution unit identifier indicated by the module configuration information and between the execution units.
  • the execution logic of the execution unit is to verify whether the execution unit corresponding to the execution unit identifier is valid. If it is valid, construct the corresponding processing module according to the execution logic between the execution units, and use the key-value pair (Key-Value) of the constructed processing module If the execution unit is invalid, an alarm message will be sent out.
  • the created processing module is actually an instance of a specific module abstract class.
  • the module creation process is similar to the code compilation process.
  • the configuration information is parsed first, and the execution logic between the execution units is encapsulated to generate a similar binary tree. Tree.
  • the processing module is called, it is essentially executed from the root node of the structure tree to the leaf nodes according to the processing results of each node.
  • the execution logic can be: a combination of one or more of And, Or, If, and Not.
  • the configuration server receives the business processing flow configuration information input by the user on the pre-generated visual configuration interface, and after receiving the business processing flow configuration information, it performs grammatical analysis on the business processing flow configuration information to determine what the business processing flow configuration information indicates The processing module identification and the execution order between the processing modules, check whether the processing module corresponding to the processing module identification is valid, if it is valid, construct the corresponding business processing flow according to the execution order between the processing modules, and construct the obtained business
  • the processing flow is stored in the business processing flow library, and if it is invalid, an alarm message will be sent out.
  • the existing execution unit when a new business processing requirement needs to be supported, can be used to configure the processing module required by the business processing flow, and then the existing processing module can be used for configuration to obtain the business processing flow. In this way, the configuration of the processing logic can be dynamically completed, thereby reducing the frequency of version development.
  • step 101 performs configuration according to the received configuration information, and the implementation process of generating a new business processing flow may include:
  • Step 301 Receive change information for the business processing flow of the old version, where the change information is used to indicate to change the execution order of the processing modules in the business processing flow of the old version, the execution unit in the processing module and the execution between the execution units At least one of the logic.
  • Step 302 Under the condition that the business processing flow of the old version is retained, corresponding changes are made in the business processing flow of the old version according to the change information to generate a new business processing flow.
  • the process may include:
  • changing the execution unit in the processing module that needs to be changed may include at least one of the following operations:
  • a new business processing flow can be obtained by constructing a business processing flow of an old version, thereby realizing configuration management of the business processing flow, improving the reuse rate of the existing business processing flow, and further improving the new version
  • the development efficiency of the business processing process saves the time and cost of business implementation.
  • #Module group name module 1 name, module 2 name, module 3 name
  • buess4B2C modelA, ModelB, ModelC;
  • buess4B2C_New modelA, ModelB_New, ModelC.
  • an embodiment of the present invention also provides a business request processing method. As shown in FIG. 5, the method includes:
  • Step 501 When a service request is received, the service processing flow corresponding to the service identifier in the service request is determined.
  • the service processing flow includes a plurality of processing modules having an execution sequence, and the plurality of processing modules respectively include at least one of the execution units. Execution logic between.
  • step 101 For the configuration process of the business processing flow, reference may be made to step 101 to step 104 in the foregoing embodiment, which will not be repeated here.
  • Step 502 Obtain multiple processing modules in the new business processing flow and the execution order of each processing module.
  • Step 503 According to the execution sequence of each processing module and the execution logic between at least one execution unit in each processing module, call the corresponding execution unit from the execution unit warehouse to process the business request.
  • Step 504 Return the processing result of the service request.
  • the corresponding business processing flow is executed according to the business identifier in the business request, thereby realizing the processing of the business request, and at the same time, completing the smooth switching of the data processing logic without the user's perception, bringing the user a better experience .
  • an embodiment of the present invention also provides a device for configuring a business processing flow. As shown in FIG. 6, the device includes:
  • the configuration module 61 is configured to perform configuration according to the received configuration information to generate a new business processing flow.
  • the new business processing flow includes multiple processing modules with an execution sequence, and the multiple processing modules respectively include at least one execution unit Execution logic
  • the judging module 62 is used for judging whether the service identifier of the target service corresponds to the old version of the service processing process when receiving the activation request for the target service to activate the new service processing flow;
  • the corresponding module 63 is used to change the business identification from the business processing flow corresponding to the old version to the new business processing flow when the judgment result of the judging module is yes, otherwise, the business identification and the new business processing are directly changed Corresponding processes to enable new business processing processes.
  • module 63 is specifically used for:
  • the business identification is changed from corresponding to the new business processing flow to the business processing flow corresponding to the old version.
  • configuration module 61 is specifically used for:
  • Receiving module configuration information determining corresponding at least one execution unit in the execution unit warehouse according to the module configuration information, and configuring the execution logic between the at least one execution unit to generate a processing module for storage in the processing module warehouse;
  • Receive business processing flow configuration information determine corresponding multiple processing modules in the processing module warehouse according to the business processing flow configuration information, and configure the execution sequence among multiple processing modules to generate a new business processing flow.
  • configuration module 61 is specifically used for:
  • the configuration module 61 is specifically used to:
  • the at least one execution unit includes the LUA script in the redis server.
  • the business processing flow configuration device provided by the embodiment of the present invention belongs to the same inventive concept as the business processing flow configuration method provided in the first embodiment of the present invention. It can execute the business processing flow configuration method provided by any embodiment of the present invention, and has the ability to execute services.
  • the corresponding functional modules and beneficial effects of the processing flow configuration method are not described in detail in the embodiment of the present invention, please refer to the service processing flow configuration method provided in the embodiment of the present invention, which is not repeated here.
  • an embodiment of the present invention also provides a service request processing device. As shown in FIG. 7, the device includes:
  • the determining module 71 is used to determine the business processing flow corresponding to the business identifier in the business request when the business request is received.
  • the new business processing flow includes multiple processing modules with execution order, and the multiple processing modules respectively include Execution logic between at least one execution unit;
  • the obtaining module 72 is used to obtain multiple processing modules in the new business processing flow and the execution sequence of each processing module;
  • the processing module 73 is configured to call the corresponding execution unit from the execution unit warehouse to process the business request according to the execution sequence of each processing module and the execution logic between at least one execution unit in each processing module;
  • the return module 74 is used to return the processing result of the service request.
  • the service request processing device provided in the embodiment of the present invention belongs to the same inventive concept as the service request processing method provided in the first embodiment of the present invention, can execute the service request processing method provided in any embodiment of the present invention, and is capable of executing a service request processing method Corresponding functional modules and beneficial effects.
  • the service request processing method provided in the embodiment of the present invention which will not be repeated here.
  • another embodiment of the present invention also provides a computer device, including:
  • One or more processors are One or more processors;
  • the program stored in the memory When the program stored in the memory is executed by one or more processors, the program causes the processor to execute the steps of the business processing flow configuration method described in the first embodiment.
  • another embodiment of the present invention also provides a computer device, including:
  • One or more processors are One or more processors;
  • the program stored in the memory When the program stored in the memory is executed by one or more processors, the program causes the processor to execute the steps of the service request processing method described in the second embodiment.
  • another embodiment of the present invention also provides a computer-readable storage medium.
  • the computer-readable storage medium stores a program.
  • the processor executes the service processing described in the first embodiment. The steps of the process configuration method.
  • another embodiment of the present invention also provides a computer-readable storage medium.
  • the computer-readable storage medium stores a program.
  • the processor executes the service request as described in the first embodiment. Processing method steps.
  • the embodiments in the embodiments of the present invention may be provided as methods, devices, or computer program products. Therefore, the embodiments of the present invention may adopt the form of a complete hardware embodiment, a complete software embodiment, or an embodiment combining software and hardware. Moreover, the embodiments of the present invention may adopt the form of computer program products implemented on one or more computer-usable storage media (including but not limited to disk storage, CD-ROM, optical storage, etc.) containing computer-usable program codes. .
  • computer-usable storage media including but not limited to disk storage, CD-ROM, optical storage, etc.
  • These computer program instructions can be provided to the processor of a general-purpose computer, a special-purpose computer, an embedded processor, or other programmable data processing equipment to generate a machine, so that the instructions executed by the processor of the computer or other programmable data processing equipment are generated It is a device that realizes the functions specified in one process or multiple processes in the flowchart and/or one block or multiple blocks in the block diagram.
  • These computer program instructions can also be stored in a computer-readable memory that can guide a computer or other programmable data processing equipment to work in a specific manner, so that the instructions stored in the computer-readable memory produce an article of manufacture including the instruction device.
  • the device implements the functions specified in one process or multiple processes in the flowchart and/or one block or multiple blocks in the block diagram.
  • These computer program instructions can also be loaded on a computer or other programmable data processing equipment, so that a series of operation steps are executed on the computer or other programmable equipment to produce computer-implemented processing, so as to execute on the computer or other programmable equipment. Instructions provide steps for implementing functions specified in a liuc process or multiple processes in the flowchart and/or a block or multiple blocks in the block diagram.

Landscapes

  • Engineering & Computer Science (AREA)
  • Software Systems (AREA)
  • Theoretical Computer Science (AREA)
  • General Engineering & Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • General Physics & Mathematics (AREA)
  • Stored Programmes (AREA)

Abstract

A service processing flow configuration method and apparatus, and a service request processing method and apparatus, relating to the technical field of computers. The configuration method comprises: performing configuration according to received configuration information to generate a new service processing flow, the new service processing flow comprising multiple processing modules having an execution sequence, and the multiple processing modules each comprising execution logic between at least one execution unit; upon receiving a request for enabling the new service processing flow for a target service, determining whether the service identifier of the target service corresponds to the service processing flow of the old version; and if yes, changing the service identifier from the service processing flow corresponding to the old version to the new service processing flow, or otherwise, directly making the service identifier correspond to the new service processing flow, to enable the new service processing flow. This solution can improve system stability and reduce system risks without loading the system.

Description

一种业务处理流程配置方法、业务请求处理方法及装置Business processing flow configuration method, business request processing method and device 技术领域Technical field
本发明涉及计算机技术领域,尤其涉及一种业务处理流程配置方法、业务请求处理方法及装置。The present invention relates to the field of computer technology, in particular to a method for configuring a business processing flow, a method and a device for processing a business request.
背景技术Background technique
随着互联网业务的急速扩张,互联网业务的更新迭代越来越快,业务处理流程的部署时间要求越来越短。为了更快地实施新的数据处理逻辑,需要通过实时业务逻辑调整的方式来实现不停服务的业务处理切换。With the rapid expansion of Internet services, the update iterations of Internet services are getting faster and faster, and the deployment time requirements for business processing procedures are getting shorter and shorter. In order to implement new data processing logic faster, real-time business logic adjustments need to be used to implement non-stop service business processing switching.
现有的技术中,实时业务逻辑调整可以采用灰度发布方案,但采用灰度发布会导致发布期间系统的服务性能下降,同时系统发布窗口有限,操作过程也较复杂,容易引入风险。Java的热加载技术,直接修改jvm中字节码的方式是难以监控,并不适用于生产环境的核心系统部署,并且,Java的热部署不适合频繁的部署并且比较耗时,同时修改的业务只是整体业务中的一小部分。在业务进行少量变更时,采用热部署会重新加载整个应用,代价较大。此外,实时业务逻辑调整还可以采用逻辑开关方案,在产品中保留新老版本数据处理逻辑,通过开关控制路由到旧版本数据处理逻辑,还是路由到新版本数据处理逻辑,但是该方案需要停机发布,且不方便进行版本回退操作。In the existing technology, the real-time business logic adjustment can adopt the gray-scale publishing scheme, but the use of gray-scale publishing will cause the system service performance to decline during the publishing period, and at the same time, the system publishing window is limited, the operation process is more complicated, and risks are easily introduced. Java's hot-loading technology, the way to directly modify the bytecode in the jvm is difficult to monitor and is not suitable for the deployment of the core system in the production environment. Moreover, the hot deployment of Java is not suitable for frequent deployment and is relatively time-consuming and modified at the same time. It's just a small part of the overall business. When a small amount of business changes, hot deployment will reload the entire application, which is costly. In addition, real-time business logic adjustments can also adopt a logic switch scheme to retain the new and old version data processing logic in the product, and route to the old version data processing logic through the switch control, or route to the new version data processing logic, but the solution needs to be shut down and released , And it is inconvenient to perform version rollback operations.
发明内容Summary of the invention
为了解决上述背景技术中提到的技术问题,本发明提供了一种业务处理流程配置方法、业务请求处理方法及装置,在不进行系统发布的情况下,能够提高系统稳定性并降低系统风险。In order to solve the technical problems mentioned in the above background art, the present invention provides a business processing flow configuration method, business request processing method and device, which can improve system stability and reduce system risks without system publishing.
本发明实施例提供的具体技术方案如下:The specific technical solutions provided by the embodiments of the present invention are as follows:
第一方面,本发明提供了一种业务处理流程配置方法,所述方法包括:In the first aspect, the present invention provides a business processing flow configuration method, the method includes:
根据接收到的配置信息进行配置,生成新的业务处理流程,所述新的业务处理流程包括具有执行顺序的多个处理模块,多个所述处理模块分别包括至少一个执行单元之间的执行逻辑;Configure according to the received configuration information to generate a new business processing flow. The new business processing flow includes a plurality of processing modules with an execution sequence, and each of the plurality of processing modules includes at least one execution logic between execution units. ;
在接收到对目标业务进行启用所述新的业务处理流程的请求时,判断所述目标业务的业务标识是否对应于旧版本的业务处理流程;When receiving a request to enable the new business processing flow for the target business, determine whether the business identification of the target business corresponds to the business processing flow of the old version;
若是,则将所述业务标识由对应于所述旧版本的业务处理流程变更为对应于所述新的业务处理流程,否则,则直接将所述业务标识与所述新的业务处理流程进行对应,以启用所述新的业务处理流程。If yes, then change the service identification from the business processing flow corresponding to the old version to corresponding to the new business processing flow; otherwise, directly correspond the business identification to the new business processing flow To enable the new business processing flow.
进一步地,所述根据接收到的配置信息进行配置,生成新的业务处理流程,包括:Further, the configuration according to the received configuration information to generate a new business processing flow includes:
接收模块配置信息,根据所述模块配置信息,在执行单元仓库中确定对应的至少一个执行单元,并配置至少一个所述执行单元之间的执行逻辑,生成处理模块,以存储至处理模块仓库中;Receive module configuration information, determine corresponding at least one execution unit in the execution unit warehouse according to the module configuration information, configure at least one execution logic between the execution units, and generate a processing module for storage in the processing module warehouse ;
接收业务处理流程配置信息,根据所述业务处理流程配置信息,在所述处理模块仓库中确定对应的多个处理模块,并配置多个所述处理模块之间的执行顺序,生成所述新的业务处理流程。Receive business processing flow configuration information, determine corresponding multiple processing modules in the processing module warehouse according to the business processing flow configuration information, and configure the execution order among multiple processing modules to generate the new Business processing flow.
进一步地,所述根据接收到的配置信息进行配置,生成新的业务处理流程,包括:Further, the configuration according to the received configuration information to generate a new business processing flow includes:
接收针对所述旧版本的业务处理流程的变更信息,其中,所述变更信息用于指示变更所述旧版本的业务处理流程中的处理模块的执行顺序、处理模块中的执行单元和执行单元之间的执行逻辑中的至少一个;Receive change information for the business processing flow of the old version, where the change information is used to instruct to change the execution sequence of the processing modules in the business processing flow of the old version, the execution unit in the processing module, and the execution unit At least one of the execution logic between;
在保留所述旧版本的业务处理流程的情况下,根据所述变更信息,在所述旧版本的业务处理流程中进行对应的变更,以生成所述新的业务处理流程。In the case that the business processing flow of the old version is retained, corresponding changes are made in the business processing flow of the old version according to the change information to generate the new business processing flow.
进一步地,所述变更信息用于指示变更处理模块中的执行单元时,所述在保 留所述旧版本的业务处理流程的情况下,根据所述变更信息,在所述旧版本的业务处理流程中进行对应的变更,以生成所述新的业务处理流程,包括:Further, when the change information is used to indicate the execution unit in the change processing module, when the business processing flow of the old version is retained, according to the change information, the business processing flow of the old version is Corresponding changes are made to generate the new business processing flow, including:
在保留所述新的业务处理流程的情况下,根据所述变更信息,从所述旧版本的业务处理流程中抽取需要变更的处理模块和不需要变更的处理模块;In the case of retaining the new business processing flow, extract processing modules that need to be changed and processing modules that do not need to be changed from the business processing flow of the old version according to the change information;
对所述需要变更的处理模块中的执行单元进行变更,得到变更后的处理模块;Change the execution unit in the processing module that needs to be changed to obtain the changed processing module;
配置所述变更后的处理模块和所述不需要变更的处理模块之间的执行顺序,生成所述新的业务处理流程。The execution sequence between the changed processing module and the processing module that does not need to be changed is configured to generate the new business processing flow.
进一步地,所述至少一个执行单元中包括redis服务器中的LUA脚本。Further, the at least one execution unit includes the LUA script in the redis server.
第二方面,提供了一种业务请求处理方法,所述方法包括:In a second aspect, a method for processing a service request is provided, and the method includes:
在接收到业务请求时,确定所述业务请求中的业务标识所对应的业务处理流程,其中,所述业务处理流程包括具有执行顺序的多个处理模块,多个所述处理模块分别包括至少一个执行单元之间的执行逻辑;When a business request is received, the business processing flow corresponding to the business identifier in the business request is determined, wherein the business processing flow includes a plurality of processing modules having an execution sequence, and each of the plurality of processing modules includes at least one Execution logic between execution units;
获取所述业务处理流程中的多个处理模块以及各所述处理模块的执行顺序;Acquiring multiple processing modules in the business processing flow and the execution order of each of the processing modules;
按照各所述处理模块的执行顺序和各所述处理模块中的至少一个执行单元之间的执行逻辑,从执行单元仓库中调用对应的执行单元对所述业务请求进行处理;According to the execution sequence of each of the processing modules and the execution logic between at least one execution unit in each of the processing modules, call a corresponding execution unit from the execution unit warehouse to process the business request;
返回所述业务请求的处理结果。Return the processing result of the service request.
第三方面,提供了一种业务处理流程配置装置,所述装置包括:In a third aspect, an apparatus for configuring a business processing flow is provided, and the apparatus includes:
配置模块,用于根据接收到的配置信息进行配置,生成新的业务处理流程,所述新的业务处理流程包括具有执行顺序的多个处理模块,多个所述处理模块分别包括至少一个执行单元之间的执行逻辑;The configuration module is configured to perform configuration according to the received configuration information to generate a new business processing flow. The new business processing flow includes a plurality of processing modules having an execution sequence, and each of the plurality of processing modules includes at least one execution unit Execution logic between;
判断模块,用于在接收到对目标业务进行启用所述新的业务处理流程的启用请求时,判断所述目标业务的业务标识是否对应于旧版本的业务处理流程;A judging module, used for judging whether the service identifier of the target service corresponds to the old version of the service processing flow when receiving the activation request for the target service to activate the new service processing flow;
对应模块,用于在所述判断模块的判断结果为是时,将所述业务标识由对应于所述旧版本的业务处理流程变更为对应于所述新的业务处理流程,否则,则直 接将所述业务标识与所述新的业务处理流程进行对应,以启用所述新的业务处理流程。The corresponding module is used to change the service identifier from the business processing flow corresponding to the old version to the new business processing flow when the judgment result of the judgment module is yes, otherwise, directly change The service identifier corresponds to the new service processing flow, so as to activate the new service processing flow.
进一步地,所述配置模块具体用于:Further, the configuration module is specifically used for:
接收模块配置信息,根据所述模块配置信息,在执行单元仓库中确定对应的至少一个执行单元,并配置至少一个所述执行单元之间的执行逻辑,生成处理模块,以存储至处理模块仓库中;Receive module configuration information, determine corresponding at least one execution unit in the execution unit warehouse according to the module configuration information, configure at least one execution logic between the execution units, and generate a processing module for storage in the processing module warehouse ;
接收业务处理流程配置信息,根据所述业务处理流程配置信息,在所述处理模块仓库中确定对应的多个处理模块,并配置多个所述处理模块之间的执行顺序,生成所述新的业务处理流程。Receive business processing flow configuration information, determine corresponding multiple processing modules in the processing module warehouse according to the business processing flow configuration information, and configure the execution order among multiple processing modules to generate the new Business processing flow.
进一步地,所述配置模块具体用于:Further, the configuration module is specifically used for:
接收针对所述旧版本的业务处理流程的变更信息,其中,所述变更信息用于指示变更所述旧版本的业务处理流程中的处理模块的执行顺序、处理模块中的执行单元和执行单元之间的执行逻辑中的至少一个;Receive change information for the business processing flow of the old version, where the change information is used to instruct to change the execution sequence of the processing modules in the business processing flow of the old version, the execution unit in the processing module, and the execution unit At least one of the execution logic between;
在保留所述旧版本的业务处理流程的情况下,根据所述变更信息,在所述旧版本的业务处理流程中进行对应的变更,以生成所述新的业务处理流程。In the case that the business processing flow of the old version is retained, corresponding changes are made in the business processing flow of the old version according to the change information to generate the new business processing flow.
第四方面,提供了一种业务请求处理装置,所述装置包括:In a fourth aspect, a service request processing device is provided, the device including:
确定模块,用于在接收到业务请求时,确定所述业务请求中的业务标识所对应的业务处理流程,其中,所述业务处理流程包括具有执行顺序的多个处理模块,多个所述处理模块分别包括至少一个执行单元之间的执行逻辑;The determining module is used to determine the business processing flow corresponding to the business identifier in the business request when the business request is received, wherein the business processing flow includes a plurality of processing modules having an execution sequence, and a plurality of the processing modules The modules respectively include execution logic between at least one execution unit;
获取模块,用于获取所述业务处理流程中的多个处理模块以及各所述处理模块的执行顺序;An obtaining module, configured to obtain multiple processing modules in the business processing flow and the execution sequence of each of the processing modules;
处理模块,用于按照各所述处理模块的执行顺序和各所述处理模块中的至少一个执行单元之间的执行逻辑,从执行单元仓库中调用对应的执行单元对所述业务请求进行处理;The processing module is configured to call the corresponding execution unit from the execution unit warehouse to process the business request according to the execution sequence of each of the processing modules and the execution logic between at least one execution unit in each of the processing modules;
返回模块,用于返回所述业务请求的处理结果。The return module is used to return the processing result of the service request.
第五方面,本发明提供了一种计算机设备,包括:In a fifth aspect, the present invention provides a computer device, including:
一个或多个处理器;One or more processors;
存储装置,用于存储一个或多个程序;Storage device for storing one or more programs;
当所述一个或多个程序被所述一个或多个处理器执行,使得所述一个或多个处理器实现如第一方面任意一种所述的方法的步骤。When the one or more programs are executed by the one or more processors, the one or more processors implement the steps of any one of the methods described in the first aspect.
第六方面,本发明提供了一种计算机设备,包括:In a sixth aspect, the present invention provides a computer device, including:
一个或多个处理器;One or more processors;
存储装置,用于存储一个或多个程序;Storage device for storing one or more programs;
当所述一个或多个程序被所述一个或多个处理器执行,使得所述一个或多个处理器实现如第二方面任意一种所述的方法的步骤。When the one or more programs are executed by the one or more processors, the one or more processors implement the steps of any one of the methods described in the second aspect.
第七方面,本发明提供了一种计算机可读存储介质,其上存储有计算机程序,所述程序被处理器执行时实现如第一方面任意一种所述的方法的步骤。In a seventh aspect, the present invention provides a computer-readable storage medium on which a computer program is stored, and when the program is executed by a processor, the steps of any one of the methods described in the first aspect are implemented.
第八方面,本发明提供了一种计算机可读存储介质,其上存储有计算机程序,所述程序被处理器执行时实现如第二方面任意一种所述的方法的步骤。In an eighth aspect, the present invention provides a computer-readable storage medium on which a computer program is stored, and when the program is executed by a processor, it implements the steps of any one of the methods described in the second aspect.
本发明提供一种业务处理流程配置方法、业务请求处理方法及装置,通过接收配置信息进行配置生成新的业务处理流程,并在接收到对目标业务进行启用新的业务处理流程的请求时,若目标业务的业务标识已经对应于旧版本的业务处理流程,则将所述业务标识由对应于所述旧版本的业务处理流程变更为对应于所述新的业务处理流程,由此可以快速地实现数据处理逻辑的切换。这种切换方法操作方便,能够提高系统稳定性和降低系统风险,在用户无感知的情况完成数据处理逻辑平滑切换,带给用户较好的体验,同时发现问题后可以快速回切,减小问题影响的范围。The present invention provides a business processing flow configuration method, business request processing method and device, which generate a new business processing flow by receiving configuration information for configuration, and when receiving a request for a target business to activate a new business processing flow, if The business identification of the target business already corresponds to the business processing flow of the old version, then the business identification is changed from the business processing flow corresponding to the old version to the new business processing flow, which can be implemented quickly Switching of data processing logic. This switching method is easy to operate, can improve system stability and reduce system risks. It completes the smooth switching of data processing logic without the user's perception, which brings users a better experience. At the same time, it can quickly switch back after problems are found to reduce problems. Scope of influence.
附图说明Description of the drawings
为了更清楚地说明本发明实施例中的技术方案,下面将对实施例描述中所需要使用的附图作简单地介绍,显而易见地,下面描述中的附图仅仅是本发明的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还 可以根据这些附图获得其他的附图。In order to explain the technical solutions in the embodiments of the present invention more clearly, the following will briefly introduce the drawings needed in the description of the embodiments. Obviously, the drawings in the following description are only some embodiments of the present invention. For those of ordinary skill in the art, other drawings can be obtained from these drawings without creative work.
图1示出了本发明实施例提供的一种业务处理流程配置方法的流程示意图;FIG. 1 shows a schematic flow chart of a method for configuring a business processing flow provided by an embodiment of the present invention;
图2示出了图1中的步骤101的一种实施方式的流程示意图;FIG. 2 shows a schematic flowchart of an implementation manner of step 101 in FIG. 1;
图3示出了图1中的步骤101的另一种实施方式的流程示意图;FIG. 3 shows a schematic flowchart of another implementation manner of step 101 in FIG. 1;
图4示出了本发明实施例提供的旧版本的业务处理流程的流程示意图。Figure 4 shows a schematic flow chart of an old version of a business processing process provided by an embodiment of the present invention.
图5示出了本发明实施例提供的新的业务处理流程的流程示意图。Fig. 5 shows a schematic flow chart of a new service processing process provided by an embodiment of the present invention.
图6示出了本发明实施例提供的一种业务处理流程配置装置的结构框图;FIG. 6 shows a structural block diagram of an apparatus for configuring a business processing flow provided by an embodiment of the present invention;
图7示出了本发明实施例提供的一种业务请求处理装置的结构框图。Fig. 7 shows a structural block diagram of a service request processing apparatus provided by an embodiment of the present invention.
具体实施方式detailed description
为使本发明的目的、技术方案和优点更加清楚,下面将结合本发明实施例中的附图,对本发明实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅是本发明一部分实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例,都属于本发明保护的范围。In order to make the objectives, technical solutions and advantages of the present invention clearer, the following will clearly and completely describe the technical solutions in the embodiments of the present invention with reference to the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments are only A part of the embodiments of the present invention, but not all the embodiments. Based on the embodiments of the present invention, all other embodiments obtained by those of ordinary skill in the art without creative work shall fall within the protection scope of the present invention.
应当理解,在本发明的描述中,除非上下文明确要求,否则整个说明书和权利要求书中的“包括”、“包含”等类似词语应当解释为包含的含义而不是排他或穷举的含义;也就是说,是“包括但不限于”的含义。It should be understood that, in the description of the present invention, unless the context clearly requires otherwise, similar words such as "including" and "including" in the entire specification and claims should be interpreted as inclusive rather than exclusive or exhaustive meanings; also In other words, it means "including but not limited to".
还应当理解,术语“第一”、“第二”等仅用于描述目的,而不能理解为指示或暗示相对重要性。此外,在本发明的描述中,除非另有说明,“多个”的含义是两个或两个以上。It should also be understood that the terms "first", "second", etc. are only used for descriptive purposes, and cannot be understood as indicating or implying relative importance. In addition, in the description of the present invention, unless otherwise specified, "plurality" means two or more.
目前,互联网产品运维场景中,系统发布窗口有限,业务变更频繁且不可预知,新旧处理逻辑间差别一般较小,关联性强,同时实施较为紧急。若通过灰度发布,分批验证方式来实现进行新旧版本数据处理逻辑切换,这种方式要经过多次验证,多次发布,切换周期长。若通过预留的逻辑开关,控制数据处理逻辑的变更,但是可供选择的范围较小,通常最后还是需要重新开发和发布。为此,本 发明实施例提供一种业务处理流程配置方法,通过接收配置信息进行配置生成新的业务处理流程,并在接收到对目标业务进行启用新的业务处理流程的请求时,若目标业务的业务标识已经对应于旧版本的业务处理流程,则将所述业务标识由对应于所述旧版本的业务处理流程变更为对应于所述新的业务处理流程,由此可以快速地实现数据处理逻辑的切换。这种切换方法操作方便,能够提高系统稳定性和降低系统风险,在用户无感知的情况完成数据处理逻辑平滑切换,带给用户较好的体验,同时发现问题后可以快速回切,减小问题影响的范围。At present, in the Internet product operation and maintenance scenario, the system release window is limited, business changes are frequent and unpredictable, the difference between the new and the old processing logic is generally small, the correlation is strong, and the implementation is more urgent. If the gray-scale release and batch verification are used to realize the logic switching of data processing between the new and old versions, this method requires multiple verifications, multiple releases, and a long switching cycle. If the reserved logic switch is used to control the change of the data processing logic, but the range of options available is small, it usually needs to be re-developed and released at the end. To this end, the embodiment of the present invention provides a business processing flow configuration method, which generates a new business processing flow by receiving configuration information for configuration, and when receiving a request for the target business to activate the new business processing flow, if the target business The service identifier of has already corresponded to the business processing flow of the old version, then the service identification is changed from the business processing flow corresponding to the old version to the new business processing flow, so that data processing can be realized quickly Logical switching. This switching method is easy to operate, can improve system stability and reduce system risks. It completes the smooth switching of data processing logic without the user's perception, which brings users a better experience. At the same time, it can quickly switch back after problems are found to reduce problems. Scope of influence.
实施例一Example one
本发明实施例提供了一种业务处理流程配置方法,该方法可以由配置服务器作为执行主体,如图1所示,该方法可以包括步骤:The embodiment of the present invention provides a method for configuring a business processing flow. The method may be executed by a configuration server. As shown in FIG. 1, the method may include the following steps:
步骤101,根据接收到的配置信息进行配置,生成新的业务处理流程,新的业务处理流程包括具有执行顺序的多个处理模块,多个处理模块分别包括至少一个执行单元之间的执行逻辑。Step 101: Perform configuration according to the received configuration information to generate a new business processing flow. The new business processing flow includes multiple processing modules with an execution sequence, and the multiple processing modules respectively include execution logic between at least one execution unit.
其中,执行单元可以分为两种:基本执行单元和扩展执行单元;基本执行单元包括用于处理基本功能逻辑的JAVA脚本;扩展执行单元包括用于处理扩展功能逻辑的LUA脚本,LUA脚本预先存储在redis服务器上。Among them, the execution unit can be divided into two types: the basic execution unit and the extended execution unit; the basic execution unit includes a JAVA script for processing basic function logic; the extended execution unit includes a LUA script for processing the extended function logic, and the LUA script is pre-stored On the redis server.
具体地,该过程可以包括:Specifically, the process may include:
配置服务器接收用户在预先生成的可视化配置界面输入的模块配置信息,使用模块配置信息所指示的执行单元以及执行单元之间的执行逻辑,新建或修改对应的处理模块;接收用户在可视化配置界面输入的业务处理流程配置信息,使用模块配置信息所指示的处理模块以及处理模块之间的执行顺序,新建或修改对应的业务处理流程。The configuration server receives the module configuration information input by the user on the pre-generated visual configuration interface, uses the execution unit indicated by the module configuration information and the execution logic between the execution units to create or modify the corresponding processing module; receives the user input on the visual configuration interface The configuration information of the business processing flow, using the processing modules indicated by the module configuration information and the execution sequence between the processing modules, create or modify the corresponding business processing flow.
其中,在生成新的业务处理流程之后,对新的业务处理流程进行保存至预先构建的业务处理流程库中。Among them, after the new business processing flow is generated, the new business processing flow is saved in the pre-built business processing flow library.
示例性地,假如配置得到的业务处理流程包括顺序执行的校验模块、判断模块和执行模块,那么业务处理流程的配置信息可以为:Exemplarily, if the configured business processing flow includes a check module, a judgment module, and an execution module that are executed sequentially, then the configuration information of the business processing flow may be:
#业务处理流程名称=模块1名称,模块2名称,模块3名称#Business processing process name = module 1 name, module 2 name, module 3 name
ModelGroup01=ModelCheck01,ModelDo01,ModelExec01;ModelGroup01=ModelCheck01, ModelDo01, ModelExec01;
处理模块包括至少一个执行单元之间的执行逻辑,假如处理模块中使用到扩展执行单元,则需要传入入参(lua脚本的redisDocKey)。The processing module includes execution logic between at least one execution unit. If an extended execution unit is used in the processing module, an input parameter (redisDocKey of the lua script) needs to be passed in.
示例性地,校验模块、判断模块和执行模块各自的配置信息可以为:Exemplarily, the respective configuration information of the verification module, the judgment module, and the execution module may be:
#模块名称=校验模块;判断模块;执行模块#Module name=Check module; Judgment module; Execution module
ModelCheck01=unitCheck:{{{redisDocKey}}};ModelCheck01=unitCheck:{{{redisDocKey}}};
ModelDo01=unitStart,If(And(unitA,Or(unitB,unitC)),unitE,uintF),unitEnd;ModelDo01=unitStart,If(And(unitA,Or(unitB,unitC)),unitE,uintF),unitEnd;
ModelExec01=unitExec;ModelExec01=unitExec;
其中,使用符号“,”作为同一个处理模块中不同逻辑和执行单元的分割符。Among them, the symbol "," is used as a separator for different logic and execution units in the same processing module.
符号“:{{{}}}”括号中的内容可以作为扩展执行单元的附加入参进行传入。The content in the brackets of the symbol ":{{{}}}" can be passed in as additional input parameters of the extended execution unit.
示例性地,扩展执行单元可以用于针对特殊的请求处理,例如,按照特殊规则修改请求中的日期,销售规则等字段。Exemplarily, the extended execution unit can be used to process special requests, for example, to modify fields such as date and sales rules in the request according to special rules.
扩展执行单元的配置信息可以为:The configuration information of the extended execution unit can be:
#扩展模块名称=预留扩展模块入口:{{{lua脚本执行编码}}}#Expansion module name = reserved expansion module entrance: {{{lua script execution code}}}
ExRedis01=ExRedis01=
exModelType01:{{{bf9d491a7a79537005f97e2d62d6a979d9c26531exModelType01:{{{bf9d491a7a79537005f97e2d62d6a979d9c26531
}}}}}}
ExRedis01=ExRedis01=
exModelType02:{{{bf9d491a7a79537005f97e2d62d6a979d9c26531exModelType02:{{{bf9d491a7a79537005f97e2d62d6a979d9c26531
}}}。}}}.
本实施例中,通过根据接收到的配置信息进行配置,生成新的业务处理流程,由于业务处理流程包括具有执行顺序的多个处理模块,多个处理模块分别包括至少一个执行单元之间的执行逻辑,由此可以将一个业务请求的处理过程对应一个业务处理流程的处理过程,请求处理的各阶段对应业务处理流程的各个处理模块,每个处理阶段执行的操作对应每个处理模块中的各个执行单元。从而实现将对系统业务处理的管理转换为对业务处理流程、处理模块和执行单元这三 个层级的管理。In this embodiment, by configuring according to the received configuration information, a new business processing flow is generated. Since the business processing flow includes multiple processing modules with an execution sequence, the multiple processing modules respectively include at least one execution unit. Logic, which can correspond the processing process of a business request to the processing process of a business processing flow. Each stage of the request processing corresponds to each processing module of the business processing flow, and the operation performed in each processing stage corresponds to each processing module in each processing module. Execution unit. In this way, the management of system business processing is transformed into the management of three levels of business processing flow, processing module and execution unit.
步骤102,在接收到对目标业务进行启用新的业务处理流程的请求时,判断目标业务的业务标识是否对应于旧版本的业务处理流程,若是,则执行步骤103,否则,则执行步骤104。Step 102: When receiving a request to activate a new business processing flow for the target service, determine whether the business identification of the target business corresponds to the business processing flow of the old version, if yes, proceed to step 103; otherwise, proceed to step 104.
具体地,对业务标识在业务处理流程库中进行查询是否存在对应的业务处理流程,若存在,则确定对应的业务处理流程为旧版本的业务处理流程。Specifically, the business identifier is inquired in the business processing flow database whether there is a corresponding business processing flow, and if it exists, it is determined that the corresponding business processing flow is an old version of the business processing flow.
步骤103,将业务标识由对应于旧版本的业务处理流程变更为对应于新的业务处理流程。Step 103: Change the business identifier from the business processing flow corresponding to the old version to the new business processing flow.
具体地,将业务标识与旧版本的业务处理流程之间的对应关系变更为:业务标识与新的业务处理流程之间的对应关系,并保存变更后的对应关系。Specifically, the correspondence between the business identifier and the old version of the business processing flow is changed to: the correspondence between the business identification and the new business processing flow, and the changed correspondence is saved.
假如业务标识“B2C+1”与旧版本的业务处理流程“ModelGroup01”之间的对应关系配置为:If the corresponding relationship between the business identifier "B2C+1" and the old version of the business processing flow "ModelGroup01" is configured as:
“B2C+1,ModelGroup01”。"B2C+1, ModelGroup01".
那么,在变更对应关系后,业务标识“B2C+1”与新的业务处理流程“ModelGroup01_NEW”之间的对应关系配置为:Then, after changing the corresponding relationship, the corresponding relationship between the business identifier "B2C+1" and the new business processing flow "ModelGroup01_NEW" is configured as:
“B2C+1,ModelGroup01_NEW”。"B2C+1, ModelGroup01_NEW".
本实施例中,通过将业务标识由对应于旧版本的业务处理流程变更为对应于新的业务处理流程,可以对业务请求进行控制使用新的业务处理流程进行业务处理。In this embodiment, by changing the business identifier from the business processing flow corresponding to the old version to the new business processing flow, the business request can be controlled and the new business processing flow can be used for business processing.
步骤104,直接将业务标识与新的业务处理流程进行对应,以启用新的业务处理流程。Step 104: Directly correspond the service identifier to the new business processing flow, so as to activate the new business processing flow.
具体地,添加业务标识与业务处理流程之间的对应关系并进行保存。Specifically, the corresponding relationship between the business identifier and the business processing flow is added and saved.
此外,为了对业务处理流程进行风险控制,在步骤103之后,方法还包括:In addition, in order to perform risk control on the business processing flow, after step 103, the method further includes:
在接收到对目标业务进行启用旧版本的业务处理流程的请求时,将业务标识由对应于新的业务处理流程变更为对应于旧版本的业务处理流程。When receiving a request for enabling the old version of the business processing flow for the target business, the business identification is changed from corresponding to the new business processing flow to the business processing flow corresponding to the old version.
本发明实施例提供一种业务处理流程配置方法,通过接收配置信息进行配 置生成新的业务处理流程,并在接收到对目标业务进行启用新的业务处理流程的请求时,若目标业务的业务标识已经对应于旧版本的业务处理流程,则将业务标识由对应于旧版本的业务处理流程变更为对应于新的业务处理流程,由此可以快速地实现数据处理逻辑的切换。这种切换方法操作方便,能够提高系统稳定性和降低系统风险,在用户无感知的情况完成数据处理逻辑平滑切换,带给用户较好的体验,同时发现问题后可以快速回切,减小问题影响的范围。The embodiment of the present invention provides a business processing flow configuration method, which generates a new business processing flow by receiving configuration information for configuration, and when receiving a request for the target business to activate the new business processing flow, if the business identifier of the target business is If the business processing flow corresponds to the old version, the business identification is changed from the business processing flow corresponding to the old version to the new business processing flow, so that the data processing logic can be switched quickly. This switching method is easy to operate, can improve system stability and reduce system risks, and complete the smooth switching of data processing logic without the user's perception, bringing a better experience to the user. At the same time, it can quickly switch back after the problem is found to reduce the problem. Scope of influence.
在一个实施方式中,如图2所示,步骤101根据接收到的配置信息进行配置,生成新的业务处理流程的实现过程可以包括:In one embodiment, as shown in FIG. 2, step 101 performs configuration according to the received configuration information, and the implementation process of generating a new business processing flow may include:
201,接收模块配置信息,根据模块配置信息,在执行单元仓库中确定对应的至少一个执行单元,并配置至少一个执行单元之间的执行逻辑,生成处理模块,以存储至处理模块仓库中。201. Receive module configuration information, determine corresponding at least one execution unit in the execution unit warehouse according to the module configuration information, configure the execution logic between the at least one execution unit, and generate a processing module for storage in the processing module warehouse.
具体地,配置服务器接收用户在预先生成的可视化配置界面输入的模块配置信息,在接收到模块配置信息后,对配置信息进行语法解析,确定模块配置信息所指示的执行单元标识以及执行单元之间的执行逻辑,校验执行单元标识对应的执行单元是否有效,如果有效,则根据执行单元之间的执行逻辑,构建对应的处理模块,将构建得到的处理模块以键值对(Key-Value)的方式存储到模块仓库中,如果执行单元无效,则发出告警信息。Specifically, the configuration server receives the module configuration information input by the user on the pre-generated visual configuration interface, and after receiving the module configuration information, it parses the configuration information to determine the execution unit identifier indicated by the module configuration information and between the execution units. The execution logic of the execution unit is to verify whether the execution unit corresponding to the execution unit identifier is valid. If it is valid, construct the corresponding processing module according to the execution logic between the execution units, and use the key-value pair (Key-Value) of the constructed processing module If the execution unit is invalid, an alarm message will be sent out.
具体来说,创建的处理模块实际是一个特定模块抽象类的实例,模块创建过程类似代码编译过程,先对配置信息进行语法解析,将执行单元之间的执行逻辑进行封装,进而生成一个类似二叉树的结构树。在调用该处理模块时,实质上是从该结构树的根节点开始按照每个节点处理的结果执行到叶子节点。Specifically, the created processing module is actually an instance of a specific module abstract class. The module creation process is similar to the code compilation process. The configuration information is parsed first, and the execution logic between the execution units is encapsulated to generate a similar binary tree. Tree. When the processing module is called, it is essentially executed from the root node of the structure tree to the leaf nodes according to the processing results of each node.
其中,执行逻辑可以为:And、Or、If、Not中的一个或多个的组合。Among them, the execution logic can be: a combination of one or more of And, Or, If, and Not.
202,接收业务处理流程配置信息,根据业务处理流程配置信息,在处理模块仓库中确定对应的多个处理模块,并配置多个处理模块之间的执行顺序,生成新的业务处理流程。202. Receive business processing flow configuration information, determine corresponding multiple processing modules in the processing module warehouse according to the business processing flow configuration information, and configure the execution sequence among the multiple processing modules to generate a new business processing flow.
具体地,配置服务器接收用户在预先生成的可视化配置界面输入的业务处 理流程配置信息,在接收到业务处理流程配置信息后,对业务处理流程配置信息进行语法解析,确定业务处理流程配置信息所指示的处理模块标识以及处理模块之间的执行顺序,校验处理模块标识对应的处理模块是否有效,如果有效,则根据处理模块之间的执行顺序,构建对应的业务处理流程,将构建得到的业务处理流程存储到业务处理流程库中,如果无效,则发出告警信息。Specifically, the configuration server receives the business processing flow configuration information input by the user on the pre-generated visual configuration interface, and after receiving the business processing flow configuration information, it performs grammatical analysis on the business processing flow configuration information to determine what the business processing flow configuration information indicates The processing module identification and the execution order between the processing modules, check whether the processing module corresponding to the processing module identification is valid, if it is valid, construct the corresponding business processing flow according to the execution order between the processing modules, and construct the obtained business The processing flow is stored in the business processing flow library, and if it is invalid, an alarm message will be sent out.
本发明实施例中,当需要支持新的业务处理需求时,可以先使用已有的执行单元进行配置业务处理流程所需的处理模块,然后再使用已有的处理模块进行配置,得到业务处理流程,如此,可以动态地完成处理逻辑的配置,从而降低版本开发频率。In the embodiment of the present invention, when a new business processing requirement needs to be supported, the existing execution unit can be used to configure the processing module required by the business processing flow, and then the existing processing module can be used for configuration to obtain the business processing flow. In this way, the configuration of the processing logic can be dynamically completed, thereby reducing the frequency of version development.
在另一个实施方式中,如图3所示,步骤101根据接收到的配置信息进行配置,生成新的业务处理流程的实现过程可以包括:In another embodiment, as shown in FIG. 3, step 101 performs configuration according to the received configuration information, and the implementation process of generating a new business processing flow may include:
步骤301,接收针对旧版本的业务处理流程的变更信息,其中,变更信息用于指示变更旧版本的业务处理流程中的处理模块的执行顺序、处理模块中的执行单元和执行单元之间的执行逻辑中的至少一个。Step 301: Receive change information for the business processing flow of the old version, where the change information is used to indicate to change the execution order of the processing modules in the business processing flow of the old version, the execution unit in the processing module and the execution between the execution units At least one of the logic.
步骤302,在保留旧版本的业务处理流程的情况下,根据变更信息,在旧版本的业务处理流程中进行对应的变更,以生成新的业务处理流程。Step 302: Under the condition that the business processing flow of the old version is retained, corresponding changes are made in the business processing flow of the old version according to the change information to generate a new business processing flow.
具体地,变更信息用于指示变更处理模块中的执行单元时,该过程可以包括:Specifically, when the change information is used to indicate the execution unit in the change processing module, the process may include:
在保留新的业务处理流程的情况下,根据变更信息,从旧版本的业务处理流程中抽取需要变更的处理模块和不需要变更的处理模块;对需要变更的处理模块中的执行单元进行变更,得到变更后的处理模块;配置变更后的处理模块和不需要变更的处理模块之间的执行顺序,生成新的业务处理流程。In the case of retaining the new business processing flow, according to the change information, extract the processing modules that need to be changed and the processing modules that do not need to be changed from the old version of the business processing flow; change the execution units in the processing modules that need to be changed, Obtain the changed processing module; configure the execution sequence between the changed processing module and the processing module that does not need to be changed, and generate a new business processing flow.
其中,对需要变更的处理模块中的执行单元进行变更可以包括如下操作中至少一种:Wherein, changing the execution unit in the processing module that needs to be changed may include at least one of the following operations:
对该处理模块进行删除变更信息对应的执行单元;Delete the execution unit corresponding to the change information on the processing module;
使用已有的执行单元对处理模块中的执行单元进行替换;Use the existing execution unit to replace the execution unit in the processing module;
使用已有的执行单元增加到处理模块中。Use existing execution units to add to the processing module.
本发明实施例中,可以通过使用旧版本的业务处理流程构建得到新的业务处理流程,实现对业务处理流程的配置管理,提高了已有的业务处理流程的复用率,进一步提高了新版本的业务处理流程的开发效率,节约了业务实施时间成本。In the embodiment of the present invention, a new business processing flow can be obtained by constructing a business processing flow of an old version, thereby realizing configuration management of the business processing flow, improving the reuse rate of the existing business processing flow, and further improving the new version The development efficiency of the business processing process saves the time and cost of business implementation.
下面结合图4a至图4b,对本发明实施例提供的方法作进一步描述。The method provided by the embodiment of the present invention will be further described below in conjunction with FIG. 4a to FIG. 4b.
假如旧版本的业务处理流程buess4B2C如图4a所示,若新的业务处理流程需要添加一个unitB2的处理过程,实现在使用unitA1处理后,unitB1和unitB2两者中只需要处理成功一个,就可以进行后续的处理。If the old version of the business processing flow buess4B2C is shown in Figure 4a, if the new business processing flow needs to add a unitB2 processing process, after the unitA1 is used for processing, only one of the unitB1 and unitB2 needs to be processed successfully, and it can be processed Subsequent processing.
使用上述的变更方法进行处理,先将从旧版本的业务处理流程中抽取需要变更的处理模块ModelB和不需要变更的处理模块ModelA、ModelC,其中,ModelB=“unitB1,unitB3”,将已有的unitB2增加到需要变更的处理模块ModelB中,生成ModelB_New,ModelB_New=“Or(unitB1,unitB2),unitB3”;配置变更后的处理模块和不需要变更的处理模块之间的执行顺序,生成新的业务处理流程buess4B2C_New,保存至旧版本业务处理流程所在的业务处理流程库中,其中,保存结果如下:Use the above-mentioned change method to process, first extract the processing module ModelB that needs to be changed and the processing modules ModelA and ModelC that do not need to be changed from the business processing flow of the old version, where ModelB="unitB1,unitB3", replace the existing UnitB2 is added to the processing module ModelB that needs to be changed, and ModelB_New is generated, ModelB_New="Or(unitB1,unitB2),unitB3"; the execution sequence between the processing module after the configuration change and the processing module that does not need to be changed, and a new business is generated The processing flow buys4B2C_New is saved to the business processing flow library where the old version of the business processing flow is located, and the saving results are as follows:
#模块组名称=模块1名称,模块2名称,模块3名称#Module group name = module 1 name, module 2 name, module 3 name
buess4B2C=modelA,ModelB,ModelC;buess4B2C=modelA, ModelB, ModelC;
buess4B2C_New=modelA,ModelB_New,ModelC。buess4B2C_New=modelA, ModelB_New, ModelC.
实施例二Example two
基于上述实施例一中的业务处理流程配置方法所配置得到的业务处理流程,本发明实施例还提供了一种业务请求处理方法,参照图5所示,该方法包括:Based on the business processing flow configured by the business processing flow configuration method in the first embodiment, an embodiment of the present invention also provides a business request processing method. As shown in FIG. 5, the method includes:
步骤501,在接收到业务请求时,确定业务请求中的业务标识所对应的业务处理流程,其中,业务处理流程包括具有执行顺序的多个处理模块,多个处理模块分别包括至少一个执行单元之间的执行逻辑。Step 501: When a service request is received, the service processing flow corresponding to the service identifier in the service request is determined. The service processing flow includes a plurality of processing modules having an execution sequence, and the plurality of processing modules respectively include at least one of the execution units. Execution logic between.
其中,业务处理流程的配置过程可以参照上述实施例中的步骤101至步骤104,此处不再赘述。For the configuration process of the business processing flow, reference may be made to step 101 to step 104 in the foregoing embodiment, which will not be repeated here.
步骤502,获取新的业务处理流程中的多个处理模块以及各处理模块的执行 顺序。Step 502: Obtain multiple processing modules in the new business processing flow and the execution order of each processing module.
步骤503,按照各处理模块的执行顺序和各处理模块中的至少一个执行单元之间的执行逻辑,从执行单元仓库中调用对应的执行单元对业务请求进行处理。Step 503: According to the execution sequence of each processing module and the execution logic between at least one execution unit in each processing module, call the corresponding execution unit from the execution unit warehouse to process the business request.
步骤504,返回业务请求的处理结果。Step 504: Return the processing result of the service request.
本发明实施例中,通过根据业务请求中的业务标识执行对应的业务处理流程,从而实现对业务请求的处理,同时在用户无感知的情况完成数据处理逻辑平滑切换,带给用户较好的体验。In the embodiment of the present invention, the corresponding business processing flow is executed according to the business identifier in the business request, thereby realizing the processing of the business request, and at the same time, completing the smooth switching of the data processing logic without the user's perception, bringing the user a better experience .
实施例三Example three
作为对上述实施例一提供的一种业务处理流程配置方法的实现,本发明实施例还提供一种业务处理流程配置装置,如图6所示,装置包括:As an implementation of the method for configuring a business processing flow provided in the first embodiment, an embodiment of the present invention also provides a device for configuring a business processing flow. As shown in FIG. 6, the device includes:
配置模块61,用于根据接收到的配置信息进行配置,生成新的业务处理流程,新的业务处理流程包括具有执行顺序的多个处理模块,多个处理模块分别包括至少一个执行单元之间的执行逻辑;The configuration module 61 is configured to perform configuration according to the received configuration information to generate a new business processing flow. The new business processing flow includes multiple processing modules with an execution sequence, and the multiple processing modules respectively include at least one execution unit Execution logic
判断模块62,用于在接收到对目标业务进行启用新的业务处理流程的启用请求时,判断目标业务的业务标识是否对应于旧版本的业务处理流程;The judging module 62 is used for judging whether the service identifier of the target service corresponds to the old version of the service processing process when receiving the activation request for the target service to activate the new service processing flow;
对应模块63,用于在判断模块的判断结果为是时,将业务标识由对应于旧版本的业务处理流程变更为对应于新的业务处理流程,否则,则直接将业务标识与新的业务处理流程进行对应,以启用新的业务处理流程。The corresponding module 63 is used to change the business identification from the business processing flow corresponding to the old version to the new business processing flow when the judgment result of the judging module is yes, otherwise, the business identification and the new business processing are directly changed Corresponding processes to enable new business processing processes.
进一步地,对应模块63具体还用于:Further, the corresponding module 63 is specifically used for:
在接收到对目标业务进行启用旧版本的业务处理流程的请求时,将业务标识由对应于新的业务处理流程变更为对应于旧版本的业务处理流程。When receiving a request for enabling the old version of the business processing flow for the target business, the business identification is changed from corresponding to the new business processing flow to the business processing flow corresponding to the old version.
进一步地,配置模块61具体用于:Further, the configuration module 61 is specifically used for:
接收模块配置信息,根据模块配置信息,在执行单元仓库中确定对应的至少一个执行单元,并配置至少一个执行单元之间的执行逻辑,生成处理模块,以存储至处理模块仓库中;Receiving module configuration information, determining corresponding at least one execution unit in the execution unit warehouse according to the module configuration information, and configuring the execution logic between the at least one execution unit to generate a processing module for storage in the processing module warehouse;
接收业务处理流程配置信息,根据业务处理流程配置信息,在处理模块仓库 中确定对应的多个处理模块,并配置多个处理模块之间的执行顺序,生成新的业务处理流程。Receive business processing flow configuration information, determine corresponding multiple processing modules in the processing module warehouse according to the business processing flow configuration information, and configure the execution sequence among multiple processing modules to generate a new business processing flow.
进一步地,配置模块61具体用于:Further, the configuration module 61 is specifically used for:
接收针对旧版本的业务处理流程的变更信息,其中,变更信息用于指示变更旧版本的业务处理流程中的处理模块的执行顺序、处理模块中的执行单元和执行单元之间的执行逻辑中的至少一个;Receive change information for the business processing flow of the old version, where the change information is used to indicate to change the execution sequence of the processing modules in the business processing flow of the old version, the execution units in the processing modules and the execution logic between the execution units at least one;
在保留旧版本的业务处理流程的情况下,根据变更信息,在旧版本的业务处理流程中进行对应的变更,以生成新的业务处理流程。In the case of retaining the business processing flow of the old version, corresponding changes are made in the business processing flow of the old version according to the change information to generate a new business processing flow.
进一步地,变更信息用于指示变更处理模块中的执行单元时,配置模块61具体用于:Further, when the change information is used to indicate the execution unit in the change processing module, the configuration module 61 is specifically used to:
在保留新的业务处理流程的情况下,根据变更信息,从旧版本的业务处理流程中抽取需要变更的处理模块和不需要变更的处理模块;In the case of retaining the new business processing flow, according to the change information, extract the processing modules that need to be changed and the processing modules that do not need to be changed from the old version of the business processing flow;
对需要变更的处理模块中的执行单元进行变更,得到变更后的处理模块;Change the execution unit in the processing module that needs to be changed to obtain the changed processing module;
配置变更后的处理模块和不需要变更的处理模块之间的执行顺序,生成新的业务处理流程。Configure the execution sequence between the processing module after the change and the processing module that does not need to be changed to generate a new business processing flow.
进一步地,至少一个执行单元中包括redis服务器中的LUA脚本。Further, the at least one execution unit includes the LUA script in the redis server.
本发明实施例提供的业务处理流程配置装置,与本发明实施例一所提供的业务处理流程配置方法属于同一发明构思,可执行本发明任意实施例所提供的业务处理流程配置方法,具备执行业务处理流程配置方法相应的功能模块和有益效果。未在本发明实施例中详尽描述的技术细节,可参见本发明实施例提供的业务处理流程配置方法,此处不再加以赘述。The business processing flow configuration device provided by the embodiment of the present invention belongs to the same inventive concept as the business processing flow configuration method provided in the first embodiment of the present invention. It can execute the business processing flow configuration method provided by any embodiment of the present invention, and has the ability to execute services. The corresponding functional modules and beneficial effects of the processing flow configuration method. For technical details that are not described in detail in the embodiment of the present invention, please refer to the service processing flow configuration method provided in the embodiment of the present invention, which is not repeated here.
实施例四Example four
作为对上述实施例二提供的一种业务请求处理方法的实现,本发明实施例还提供一种业务请求处理装置,如图7所示,装置包括:As an implementation of the service request processing method provided in the second embodiment, an embodiment of the present invention also provides a service request processing device. As shown in FIG. 7, the device includes:
确定模块71,用于在接收到业务请求时,确定业务请求中的业务标识所对应的业务处理流程,其中,新的业务处理流程包括具有执行顺序的多个处理模块, 多个处理模块分别包括至少一个执行单元之间的执行逻辑;The determining module 71 is used to determine the business processing flow corresponding to the business identifier in the business request when the business request is received. The new business processing flow includes multiple processing modules with execution order, and the multiple processing modules respectively include Execution logic between at least one execution unit;
获取模块72,用于获取新的业务处理流程中的多个处理模块以及各处理模块的执行顺序;The obtaining module 72 is used to obtain multiple processing modules in the new business processing flow and the execution sequence of each processing module;
处理模块73,用于按照各处理模块的执行顺序和各处理模块中的至少一个执行单元之间的执行逻辑,从执行单元仓库中调用对应的执行单元对业务请求进行处理;The processing module 73 is configured to call the corresponding execution unit from the execution unit warehouse to process the business request according to the execution sequence of each processing module and the execution logic between at least one execution unit in each processing module;
返回模块74,用于返回业务请求的处理结果。The return module 74 is used to return the processing result of the service request.
本发明实施例提供的业务请求处理装置,与本发明实施例一所提供的业务请求处理方法属于同一发明构思,可执行本发明任意实施例所提供的业务请求处理方法,具备执行业务请求处理方法相应的功能模块和有益效果。未在本发明实施例中详尽描述的技术细节,可参见本发明实施例提供的业务请求处理方法,此处不再加以赘述。The service request processing device provided in the embodiment of the present invention belongs to the same inventive concept as the service request processing method provided in the first embodiment of the present invention, can execute the service request processing method provided in any embodiment of the present invention, and is capable of executing a service request processing method Corresponding functional modules and beneficial effects. For technical details that are not described in detail in the embodiment of the present invention, please refer to the service request processing method provided in the embodiment of the present invention, which will not be repeated here.
此外,本发明另一实施例还提供了一种计算机设备,包括:In addition, another embodiment of the present invention also provides a computer device, including:
一个或者多个处理器;One or more processors;
存储器;Memory
存储在存储器中的程序,当被一个或者多个处理器执行时,程序使处理器执行如上述实施例一所述的业务处理流程配置方法的步骤。When the program stored in the memory is executed by one or more processors, the program causes the processor to execute the steps of the business processing flow configuration method described in the first embodiment.
此外,本发明另一实施例还提供了一种计算机设备,包括:In addition, another embodiment of the present invention also provides a computer device, including:
一个或者多个处理器;One or more processors;
存储器;Memory
存储在存储器中的程序,当被一个或者多个处理器执行时,程序使处理器执行如上述实施例二所述的业务请求处理方法的步骤。When the program stored in the memory is executed by one or more processors, the program causes the processor to execute the steps of the service request processing method described in the second embodiment.
此外,本发明另一实施例还提供了一种计算机可读存储介质,计算机可读存储介质存储有程序,当程序被处理器执行时,使得处理器执行如上述实施例一所述的业务处理流程配置方法的步骤。In addition, another embodiment of the present invention also provides a computer-readable storage medium. The computer-readable storage medium stores a program. When the program is executed by a processor, the processor executes the service processing described in the first embodiment. The steps of the process configuration method.
此外,本发明另一实施例还提供了一种计算机可读存储介质,计算机可读存 储介质存储有程序,当程序被处理器执行时,使得处理器执行如上述实施例一所述的业务请求处理方法的步骤。In addition, another embodiment of the present invention also provides a computer-readable storage medium. The computer-readable storage medium stores a program. When the program is executed by a processor, the processor executes the service request as described in the first embodiment. Processing method steps.
本领域内的技术人员应明白,本发明实施例中的实施例可提供为方法、装置、或计算机程序产品。因此,本发明实施例中可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且,本发明实施例中可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。Those skilled in the art should understand that the embodiments in the embodiments of the present invention may be provided as methods, devices, or computer program products. Therefore, the embodiments of the present invention may adopt the form of a complete hardware embodiment, a complete software embodiment, or an embodiment combining software and hardware. Moreover, the embodiments of the present invention may adopt the form of computer program products implemented on one or more computer-usable storage media (including but not limited to disk storage, CD-ROM, optical storage, etc.) containing computer-usable program codes. .
本发明实施例中是参照根据本发明实施例中实施例的方法、装置(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器,使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。The embodiments of the present invention are described with reference to the flowcharts and/or block diagrams of the methods, devices (systems), and computer program products according to the embodiments of the present invention. It should be understood that each process and/or block in the flowchart and/or block diagram, and the combination of processes and/or blocks in the flowchart and/or block diagram can be implemented by computer program instructions. These computer program instructions can be provided to the processor of a general-purpose computer, a special-purpose computer, an embedded processor, or other programmable data processing equipment to generate a machine, so that the instructions executed by the processor of the computer or other programmable data processing equipment are generated It is a device that realizes the functions specified in one process or multiple processes in the flowchart and/or one block or multiple blocks in the block diagram.
这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中,使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品,该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。These computer program instructions can also be stored in a computer-readable memory that can guide a computer or other programmable data processing equipment to work in a specific manner, so that the instructions stored in the computer-readable memory produce an article of manufacture including the instruction device. The device implements the functions specified in one process or multiple processes in the flowchart and/or one block or multiple blocks in the block diagram.
这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上,使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理,从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个liuc流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。These computer program instructions can also be loaded on a computer or other programmable data processing equipment, so that a series of operation steps are executed on the computer or other programmable equipment to produce computer-implemented processing, so as to execute on the computer or other programmable equipment. Instructions provide steps for implementing functions specified in a liuc process or multiple processes in the flowchart and/or a block or multiple blocks in the block diagram.
尽管已描述了本发明实施例中的优选实施例,但本领域内的技术人员一旦得知了基本创造性概念,则可对这些实施例作出另外的变更和修改。所以,所附权利要求意欲解释为包括优选实施例以及落入本发明实施例中范围的所有变更和修改。Although the preferred embodiments of the embodiments of the present invention have been described, those skilled in the art can make additional changes and modifications to these embodiments once they learn the basic creative concept. Therefore, the appended claims are intended to be interpreted as including the preferred embodiments and all changes and modifications falling within the scope of the embodiments of the present invention.
显然,本领域的技术人员可以对本发明进行各种改动和变型而不脱离本发明的精神和范围。这样,倘若本发明的这些修改和变型属于本发明权利要求及其等同技术的范围之内,则本发明也意图包含这些改动和变型在内。Obviously, those skilled in the art can make various changes and modifications to the present invention without departing from the spirit and scope of the present invention. In this way, if these modifications and variations of the present invention fall within the scope of the claims of the present invention and their equivalent technologies, the present invention is also intended to include these modifications and variations.

Claims (10)

  1. 一种业务处理流程配置方法,其特征在于,所述方法包括:A business processing flow configuration method, characterized in that the method includes:
    根据接收到的配置信息进行配置,生成新的业务处理流程,所述新的业务处理流程包括具有执行顺序的多个处理模块,多个所述处理模块分别包括至少一个执行单元之间的执行逻辑;Configure according to the received configuration information to generate a new business processing flow. The new business processing flow includes a plurality of processing modules with an execution sequence, and each of the plurality of processing modules includes at least one execution logic between execution units. ;
    在接收到对目标业务进行启用所述新的业务处理流程的请求时,判断所述目标业务的业务标识是否对应于旧版本的业务处理流程;When receiving a request to enable the new business processing flow for the target business, determine whether the business identification of the target business corresponds to the business processing flow of the old version;
    若是,则将所述业务标识由对应于所述旧版本的业务处理流程变更为对应于所述新的业务处理流程,否则,则直接将所述业务标识与所述新的业务处理流程进行对应,以启用所述新的业务处理流程。If yes, then change the service identification from the business processing flow corresponding to the old version to corresponding to the new business processing flow; otherwise, directly correspond the business identification to the new business processing flow To enable the new business processing flow.
  2. 根据权利要求1所述的方法,其特征在于,所述根据接收到的配置信息进行配置,生成新的业务处理流程,包括:The method according to claim 1, wherein the configuration according to the received configuration information to generate a new service processing flow comprises:
    接收模块配置信息,根据所述模块配置信息,在执行单元仓库中确定对应的至少一个执行单元,并配置至少一个所述执行单元之间的执行逻辑,生成处理模块,以存储至处理模块仓库中;Receive module configuration information, determine corresponding at least one execution unit in the execution unit warehouse according to the module configuration information, configure at least one execution logic between the execution units, and generate a processing module for storage in the processing module warehouse ;
    接收业务处理流程配置信息,根据所述业务处理流程配置信息,在所述处理模块仓库中确定对应的多个处理模块,并配置多个所述处理模块之间的执行顺序,生成所述新的业务处理流程。Receive business processing flow configuration information, determine corresponding multiple processing modules in the processing module warehouse according to the business processing flow configuration information, and configure the execution order among multiple processing modules to generate the new Business processing flow.
  3. 根据权利要求1所述的方法,其特征在于,所述根据接收到的配置信息进行配置,生成新的业务处理流程,包括:The method according to claim 1, wherein the configuration according to the received configuration information to generate a new service processing flow comprises:
    接收针对所述旧版本的业务处理流程的变更信息,其中,所述变更信息用于指示变更所述旧版本的业务处理流程中的处理模块的执行顺序、处理模块中的执行单元和执行单元之间的执行逻辑中的至少一个;Receive change information for the business processing flow of the old version, where the change information is used to instruct to change the execution sequence of the processing modules in the business processing flow of the old version, the execution unit in the processing module, and the execution unit At least one of the execution logic between;
    在保留所述旧版本的业务处理流程的情况下,根据所述变更信息,在所述旧版本的业务处理流程中进行对应的变更,以生成所述新的业务处理流程。In the case that the business processing flow of the old version is retained, corresponding changes are made in the business processing flow of the old version according to the change information to generate the new business processing flow.
  4. 根据权利要求3所述的方法,其特征在于,所述变更信息用于指示变更处理模块中的执行单元时,所述在保留所述旧版本的业务处理流程的情况下,根据所述变更信息,在所述旧版本的业务处理流程中进行对应的变更,以生成所述新的业务处理流程,包括:The method according to claim 3, wherein when the change information is used to indicate the change of the execution unit in the processing module, the business processing flow of the old version is retained according to the change information , Making corresponding changes in the business processing flow of the old version to generate the new business processing flow, including:
    在保留所述新的业务处理流程的情况下,根据所述变更信息,从所述旧版本的业务处理流程中抽取需要变更的处理模块和不需要变更的处理模块;In the case of retaining the new business processing flow, extract processing modules that need to be changed and processing modules that do not need to be changed from the business processing flow of the old version according to the change information;
    对所述需要变更的处理模块中的执行单元进行变更,得到变更后的处理模块;Change the execution unit in the processing module that needs to be changed to obtain the changed processing module;
    配置所述变更后的处理模块和所述不需要变更的处理模块之间的执行顺序,生成所述新的业务处理流程。The execution sequence between the changed processing module and the processing module that does not need to be changed is configured to generate the new business processing flow.
  5. 根据权利要求1至4任一所述的方法,其特征在于,所述至少一个执行单元中包括redis服务器中的LUA脚本。The method according to any one of claims 1 to 4, wherein the at least one execution unit includes a LUA script in a redis server.
  6. 一种业务请求处理方法,其特征在于,所述方法包括:A service request processing method, characterized in that the method includes:
    在接收到业务请求时,确定所述业务请求中的业务标识所对应的业务处理流程,其中,所述业务处理流程包括具有执行顺序的多个处理模块,多个所述处理模块分别包括至少一个执行单元之间的执行逻辑;When a business request is received, the business processing flow corresponding to the business identifier in the business request is determined, wherein the business processing flow includes a plurality of processing modules having an execution sequence, and each of the plurality of processing modules includes at least one Execution logic between execution units;
    获取所述业务处理流程中的多个处理模块以及各所述处理模块的执行顺序;Acquiring multiple processing modules in the business processing flow and the execution order of each of the processing modules;
    按照各所述处理模块的执行顺序和各所述处理模块中的至少一个执行单元之间的执行逻辑,从执行单元仓库中调用对应的执行单元对所述业务请求进行处理;According to the execution sequence of each of the processing modules and the execution logic between at least one execution unit in each of the processing modules, call a corresponding execution unit from the execution unit warehouse to process the business request;
    返回所述业务请求的处理结果。Return the processing result of the service request.
  7. 一种业务处理流程配置装置,其特征在于,所述装置包括:A business processing flow configuration device, characterized in that the device includes:
    配置模块,用于根据接收到的配置信息进行配置,生成新的业务处理流程,所述新的业务处理流程包括具有执行顺序的多个处理模块,多个所述处理模块分别包括至少一个执行单元之间的执行逻辑;The configuration module is configured to perform configuration according to the received configuration information to generate a new business processing flow. The new business processing flow includes a plurality of processing modules having an execution sequence, and each of the plurality of processing modules includes at least one execution unit Execution logic between;
    判断模块,用于在接收到对目标业务进行启用所述新的业务处理流程的启 用请求时,判断所述目标业务的业务标识是否对应于旧版本的业务处理流程;The judging module is used for judging whether the service identifier of the target service corresponds to the old version of the service processing flow when receiving the activation request for the target service to activate the new service processing flow;
    对应模块,用于在所述判断模块的判断结果为是时,将所述业务标识由对应于所述旧版本的业务处理流程变更为对应于所述新的业务处理流程,否则,则直接将所述业务标识与所述新的业务处理流程进行对应,以启用所述新的业务处理流程。The corresponding module is used to change the service identifier from the business processing flow corresponding to the old version to the new business processing flow when the judgment result of the judgment module is yes, otherwise, directly change The service identifier corresponds to the new service processing flow, so as to activate the new service processing flow.
  8. 根据权利要求7所述的装置,其特征在于,所述配置模块具体用于:The device according to claim 7, wherein the configuration module is specifically configured to:
    接收模块配置信息,根据所述模块配置信息,在执行单元仓库中确定对应的至少一个执行单元,并配置至少一个所述执行单元之间的执行逻辑,生成处理模块,以存储至处理模块仓库中;Receive module configuration information, determine corresponding at least one execution unit in the execution unit warehouse according to the module configuration information, configure at least one execution logic between the execution units, and generate a processing module for storage in the processing module warehouse ;
    接收业务处理流程配置信息,根据所述业务处理流程配置信息,在所述处理模块仓库中确定对应的多个处理模块,并配置多个所述处理模块之间的执行顺序,生成所述新的业务处理流程。Receive business processing flow configuration information, determine corresponding multiple processing modules in the processing module warehouse according to the business processing flow configuration information, and configure the execution order among multiple processing modules to generate the new Business processing flow.
  9. 根据权利要求7所述的装置,其特征在于,所述配置模块具体用于:The device according to claim 7, wherein the configuration module is specifically configured to:
    接收针对所述旧版本的业务处理流程的变更信息,其中,所述变更信息用于指示变更所述旧版本的业务处理流程中的处理模块的执行顺序、处理模块中的执行单元和执行单元之间的执行逻辑中的至少一个;Receive change information for the business processing flow of the old version, where the change information is used to instruct to change the execution sequence of the processing modules in the business processing flow of the old version, the execution unit in the processing module, and the execution unit At least one of the execution logic between;
    在保留所述旧版本的业务处理流程的情况下,根据所述变更信息,在所述旧版本的业务处理流程中进行对应的变更,以生成所述新的业务处理流程。In the case that the business processing flow of the old version is retained, corresponding changes are made in the business processing flow of the old version according to the change information to generate the new business processing flow.
  10. 一种业务请求处理装置,其特征在于,所述装置包括:A service request processing device, characterized in that the device includes:
    确定模块,用于在接收到业务请求时,确定所述业务请求中的业务标识所对应的业务处理流程,其中,所述业务处理流程包括具有执行顺序的多个处理模块,多个所述处理模块分别包括至少一个执行单元之间的执行逻辑;The determining module is used to determine the business processing flow corresponding to the business identifier in the business request when the business request is received, wherein the business processing flow includes a plurality of processing modules having an execution sequence, and a plurality of the processing modules The modules respectively include execution logic between at least one execution unit;
    获取模块,用于获取所述业务处理流程中的多个处理模块以及各所述处理模块的执行顺序;An obtaining module, configured to obtain multiple processing modules in the business processing flow and the execution sequence of each of the processing modules;
    处理模块,用于按照各所述处理模块的执行顺序和各所述处理模块中的至少一个执行单元之间的执行逻辑,从执行单元仓库中调用对应的执行单元对所 述业务请求进行处理;The processing module is configured to call the corresponding execution unit from the execution unit warehouse to process the business request according to the execution sequence of each of the processing modules and the execution logic between at least one execution unit in each of the processing modules;
    返回模块,用于返回所述业务请求的处理结果。The return module is used to return the processing result of the service request.
PCT/CN2020/105959 2019-09-24 2020-07-30 Service processing flow configuration method and apparatus, and service request processing method and apparatus WO2021057252A1 (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CA3155732A CA3155732A1 (en) 2019-09-24 2020-07-30 Business process configuring method, business request processing method, and devices

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
CN201910905745.5 2019-09-24
CN201910905745.5A CN110764839A (en) 2019-09-24 2019-09-24 Business processing flow configuration method, business request processing method and device

Publications (1)

Publication Number Publication Date
WO2021057252A1 true WO2021057252A1 (en) 2021-04-01

Family

ID=69330354

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/CN2020/105959 WO2021057252A1 (en) 2019-09-24 2020-07-30 Service processing flow configuration method and apparatus, and service request processing method and apparatus

Country Status (3)

Country Link
CN (1) CN110764839A (en)
CA (1) CA3155732A1 (en)
WO (1) WO2021057252A1 (en)

Cited By (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN113157271A (en) * 2021-05-13 2021-07-23 中国建设银行股份有限公司 Service processing method and device
CN113159737A (en) * 2021-05-27 2021-07-23 中国平安人寿保险股份有限公司 RPA service processing method, RPA management platform, device and medium
CN113434119A (en) * 2021-06-24 2021-09-24 江苏创源电子有限公司 Business processing method and device based on process control
CN113780778A (en) * 2021-08-30 2021-12-10 北京沃东天骏信息技术有限公司 An information processing method and device, and a storage medium
CN114237615A (en) * 2021-12-15 2022-03-25 平安科技(深圳)有限公司 Packing method based on decision tree model and related equipment

Families Citing this family (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN110764839A (en) * 2019-09-24 2020-02-07 苏宁云计算有限公司 Business processing flow configuration method, business request processing method and device
CN111273962B (en) * 2020-02-14 2022-02-18 腾讯科技(深圳)有限公司 Configuration management method, device, computer readable storage medium and computer equipment
CN113760386A (en) * 2021-01-29 2021-12-07 北京京东拓先科技有限公司 An access control system, access control method and storage medium
CN114462859A (en) * 2022-02-10 2022-05-10 中国工商银行股份有限公司 Workflow processing method and device, computer equipment and storage medium

Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20150046902A1 (en) * 2013-08-09 2015-02-12 Oracle International Corporation Execution semantics for sub-processes in bpel
CN104866951A (en) * 2015-04-27 2015-08-26 广州杰赛科技股份有限公司 Service information updating method in service process, and system thereof
CN108304455A (en) * 2017-12-20 2018-07-20 阿里巴巴集团控股有限公司 A kind of method, apparatus and equipment of processing business request
CN109636317A (en) * 2018-11-23 2019-04-16 山东中创软件工程股份有限公司 Service control method, device, system and storage medium
CN110764839A (en) * 2019-09-24 2020-02-07 苏宁云计算有限公司 Business processing flow configuration method, business request processing method and device

Family Cites Families (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101132401A (en) * 2006-08-25 2008-02-27 华为技术有限公司 Business interactive processing method and system
CN108228252B (en) * 2017-12-26 2021-04-30 创新先进技术有限公司 Method, device and equipment for service processing and service flow configuration

Patent Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20150046902A1 (en) * 2013-08-09 2015-02-12 Oracle International Corporation Execution semantics for sub-processes in bpel
CN104866951A (en) * 2015-04-27 2015-08-26 广州杰赛科技股份有限公司 Service information updating method in service process, and system thereof
CN108304455A (en) * 2017-12-20 2018-07-20 阿里巴巴集团控股有限公司 A kind of method, apparatus and equipment of processing business request
CN109636317A (en) * 2018-11-23 2019-04-16 山东中创软件工程股份有限公司 Service control method, device, system and storage medium
CN110764839A (en) * 2019-09-24 2020-02-07 苏宁云计算有限公司 Business processing flow configuration method, business request processing method and device

Cited By (7)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN113157271A (en) * 2021-05-13 2021-07-23 中国建设银行股份有限公司 Service processing method and device
CN113159737A (en) * 2021-05-27 2021-07-23 中国平安人寿保险股份有限公司 RPA service processing method, RPA management platform, device and medium
CN113159737B (en) * 2021-05-27 2022-11-01 中国平安人寿保险股份有限公司 RPA service processing method, RPA management platform, device and medium
CN113434119A (en) * 2021-06-24 2021-09-24 江苏创源电子有限公司 Business processing method and device based on process control
CN113434119B (en) * 2021-06-24 2024-04-26 江苏创源电子有限公司 Service processing method and device based on flow control
CN113780778A (en) * 2021-08-30 2021-12-10 北京沃东天骏信息技术有限公司 An information processing method and device, and a storage medium
CN114237615A (en) * 2021-12-15 2022-03-25 平安科技(深圳)有限公司 Packing method based on decision tree model and related equipment

Also Published As

Publication number Publication date
CA3155732A1 (en) 2021-04-01
CN110764839A (en) 2020-02-07

Similar Documents

Publication Publication Date Title
WO2021057252A1 (en) Service processing flow configuration method and apparatus, and service request processing method and apparatus
US8589909B2 (en) Techniques for reducing down time in updating applications with metadata
US20150193229A1 (en) Efficient propagation of software based on snapshot technologies enabling more efficient informal software builds
CN108319656A (en) Realize the method, apparatus and calculate node and system that gray scale is issued
US10248537B2 (en) Translation bug prediction classifier
US20100306750A1 (en) Parallel program generation method
CN110096263A (en) Web front end code automatic generation method and device
CN110597888B (en) Virtual resource acquisition method and device based on block chain, medium and equipment
CN113961584A (en) Method and device for analyzing field blood relationship, electronic equipment and storage medium
CN110147273A (en) A kind of task executing method and device
CN115309387A (en) Method for generating API (application program interface) based on dynamic SQL (structured query language) configuration
CN111240772A (en) Data processing method and device based on block chain and storage medium
CN113495723B (en) Method, device and storage medium for calling functional component
CN108268266A (en) A kind of upgrade method and device
CN113721948A (en) Database upgrading method, system and storage medium
CN110119283B (en) Application update processing method, device and system and application update system
CN113778564B (en) Method, equipment and storage medium for efficiently executing EVM intelligent contract
US9059992B2 (en) Distributed mobile enterprise application platform
CN112445607A (en) Method and device for executing method function by application program
CN114356379A (en) Backup-based service upgrade method, device, device and storage medium
WO2022105494A1 (en) Automatic data backfilling method and apparatus, electronic device, and computer storage medium
US10657476B2 (en) Just in time compilation (JIT) for business process execution
EP4196874A1 (en) Representing asynchronous state machine in intermediate code
CN112367205A (en) Processing method and scheduling system for HTTP scheduling request
CN111782641A (en) Data error repairing method and system

Legal Events

Date Code Title Description
121 Ep: the epo has been informed by wipo that ep was designated in this application

Ref document number: 20867243

Country of ref document: EP

Kind code of ref document: A1

ENP Entry into the national phase

Ref document number: 3155732

Country of ref document: CA

NENP Non-entry into the national phase

Ref country code: DE

122 Ep: pct application non-entry in european phase

Ref document number: 20867243

Country of ref document: EP

Kind code of ref document: A1

122 Ep: pct application non-entry in european phase

Ref document number: 20867243

Country of ref document: EP

Kind code of ref document: A1