CN107908494A - Abnormal event processing method, device, electronic equipment and storage medium - Google Patents
Abnormal event processing method, device, electronic equipment and storage medium Download PDFInfo
- Publication number
- CN107908494A CN107908494A CN201711104702.4A CN201711104702A CN107908494A CN 107908494 A CN107908494 A CN 107908494A CN 201711104702 A CN201711104702 A CN 201711104702A CN 107908494 A CN107908494 A CN 107908494A
- Authority
- CN
- China
- Prior art keywords
- anomalous event
- message
- abnormal
- target database
- processing method
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/07—Responding to the occurrence of a fault, e.g. fault tolerance
- G06F11/0703—Error or fault processing not based on redundancy, i.e. by taking additional measures to deal with the error or fault not making use of redundancy in operation, in hardware, or in data representation
- G06F11/0766—Error or fault reporting or storing
- G06F11/0775—Content or structure details of the error report, e.g. specific table structure, specific error fields
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/07—Responding to the occurrence of a fault, e.g. fault tolerance
- G06F11/0703—Error or fault processing not based on redundancy, i.e. by taking additional measures to deal with the error or fault not making use of redundancy in operation, in hardware, or in data representation
- G06F11/0751—Error or fault detection not based on redundancy
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/07—Responding to the occurrence of a fault, e.g. fault tolerance
- G06F11/0703—Error or fault processing not based on redundancy, i.e. by taking additional measures to deal with the error or fault not making use of redundancy in operation, in hardware, or in data representation
- G06F11/0766—Error or fault reporting or storing
- G06F11/0787—Storage of error reports, e.g. persistent data storage, storage using memory protection
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/07—Responding to the occurrence of a fault, e.g. fault tolerance
- G06F11/0703—Error or fault processing not based on redundancy, i.e. by taking additional measures to deal with the error or fault not making use of redundancy in operation, in hardware, or in data representation
- G06F11/0793—Remedial or corrective actions
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/07—Responding to the occurrence of a fault, e.g. fault tolerance
- G06F11/0703—Error or fault processing not based on redundancy, i.e. by taking additional measures to deal with the error or fault not making use of redundancy in operation, in hardware, or in data representation
- G06F11/0706—Error or fault processing not based on redundancy, i.e. by taking additional measures to deal with the error or fault not making use of redundancy in operation, in hardware, or in data representation the processing taking place on a specific hardware platform or in a specific software environment
- G06F11/0709—Error or fault processing not based on redundancy, i.e. by taking additional measures to deal with the error or fault not making use of redundancy in operation, in hardware, or in data representation the processing taking place on a specific hardware platform or in a specific software environment in a distributed system consisting of a plurality of standalone computer nodes, e.g. clusters, client-server systems
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2201/00—Indexing scheme relating to error detection, to error correction, and to monitoring
- G06F2201/80—Database-specific techniques
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Quality & Reliability (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
- Retry When Errors Occur (AREA)
Abstract
Description
技术领域technical field
本发明的实施例涉及数据处理技术领域,具体而言,涉及一种异常事件的处理方法、异常事件的处理装置、电子设备以及计算机可读存储介质。Embodiments of the present invention relate to the technical field of data processing, and in particular, relate to a method for processing an abnormal event, an apparatus for processing an abnormal event, electronic equipment, and a computer-readable storage medium.
背景技术Background technique
随着计算机技术的发展,业务系统变得越来越复杂,业务系统在长时间运行时,不能保证不出现任何问题例如网络闪断问题,一旦出现问题就会导致异常发生,更为严重的还会丢失数据。With the development of computer technology, the business system has become more and more complex. When the business system runs for a long time, there is no guarantee that there will be no problems such as network flashing. Data will be lost.
在目前的技术方案中,当出现异常情况时,一般是通过重试的方式来解决问题,但是这种重试方式需要维护人员根据业务的不同手动触发重试操作。因此目前的技术方案不仅需要投入大量的人力物力,而且人工操作会耗费大量的时间,大大地降低了异常事件的处理效率。In the current technical solution, when an abnormal situation occurs, the problem is generally solved by retrying. However, this retrying method requires maintenance personnel to manually trigger the retrying operation according to different services. Therefore, the current technical solution not only needs to invest a lot of manpower and material resources, but also consumes a lot of time for manual operation, which greatly reduces the processing efficiency of abnormal events.
需要说明的是,在上述背景技术部分公开的信息仅用于加强对本发明背景的理解,因此可以包括不构成对本领域普通技术人员已知的现有技术的信息。It should be noted that the information disclosed in the background section above is only used to enhance the understanding of the background of the present invention, and therefore may include information that does not constitute prior art known to those of ordinary skill in the art.
发明内容Contents of the invention
本发明实施例的目的在于提供一种异常事件的处理方法、异常事件的处理装置、电子设备以及计算机可读存储介质,进而至少在一定程度上解决目前异常事件处理效率低、需要花费大量人力物力成本的问题。The purpose of the embodiments of the present invention is to provide a method for processing abnormal events, a device for processing abnormal events, an electronic device, and a computer-readable storage medium, so as to solve the problem of low efficiency in processing abnormal events and the need for a large amount of manpower and material resources at least to a certain extent. The question of cost.
根据本发明实施例的第一方面,提供了一种异常事件的处理方法,包括:在业务的执行过程中,检测是否出现异常事件;若检测到出现所述异常事件,则在目标数据库中存储与所述异常事件对应的异常消息;读取所述目标数据库中存储的异常消息,并根据读取的异常消息对相应的业务进行重试处理;在重试成功时从所述目标数据库中删除读取的异常消息。According to the first aspect of an embodiment of the present invention, a method for processing an abnormal event is provided, including: during the execution of the business, detecting whether an abnormal event occurs; if the abnormal event is detected, storing the abnormal event in the target database An abnormal message corresponding to the abnormal event; read the abnormal message stored in the target database, and retry the corresponding business according to the read abnormal message; delete it from the target database when the retry is successful The exception message read.
在本发明的一些实施例中,基于前述方案,在根据读取的异常消息对相应的业务进行重试处理之后,还包括:在重试失败时,累加读取的异常消息对应的重试次数;其中,读取所述目标数据库中存储的异常消息,包括:读取所述目标数据库中对应的重试次数小于预定次数的异常消息。In some embodiments of the present invention, based on the foregoing solution, after retrying the corresponding business according to the read exception message, it further includes: when the retry fails, accumulating the number of retries corresponding to the read exception message ; Wherein, reading the abnormal message stored in the target database includes: reading the corresponding abnormal message in the target database whose number of retries is less than a predetermined number.
在本发明的一些实施例中,基于前述方案,读取所述目标数据库中存储的异常消息,包括:按照预定周期,定时读取所述目标数据库中存储的异常消息。In some embodiments of the present invention, based on the aforementioned solutions, reading the abnormal messages stored in the target database includes: regularly reading the abnormal messages stored in the target database according to a predetermined period.
在本发明的一些实施例中,基于前述方案,在目标数据库中存储与所述异常事件对应的异常消息之前,还包括:对所述异常事件进行解析,以获取所述异常事件对应的异常消息。In some embodiments of the present invention, based on the foregoing solution, before storing the abnormal message corresponding to the abnormal event in the target database, further includes: parsing the abnormal event to obtain the abnormal message corresponding to the abnormal event .
在本发明的一些实施例中,基于前述方案,在业务的执行过程中,检测是否出现异常事件,包括:在同一事务中依次调用多个对象时,若对任一对象调用失败,则对已发生的调用过程进行回滚处理;若检测到对已发生的调用过程回滚失败,则确定检测到回滚业务出现异常事件。In some embodiments of the present invention, based on the aforementioned solution, during the execution of the business, detecting whether an abnormal event occurs includes: when calling multiple objects in the same transaction, if the call to any object fails, the Rollback processing is performed on the call process that has occurred; if it is detected that the rollback of the call process that has occurred fails, it is determined that an abnormal event in the rollback business has been detected.
在本发明的一些实施例中,基于前述方案,在目标数据库中存储与所述异常事件对应的异常消息,包括:在所述目标数据库中存储对已发生的调用过程回滚失败的消息。In some embodiments of the present invention, based on the foregoing solution, storing the exception message corresponding to the abnormal event in the target database includes: storing in the target database a message of rollback failure of the call process that has occurred.
在本发明的一些实施例中,基于前述方案,对已发生的调用过程进行回滚处理,包括:根据所述事务的标识,获取对应的回调路径;基于所述回调路径调用回调方法,并根据所述回调方法对已发生的调用过程进行回滚处理。In some embodiments of the present invention, based on the aforementioned solutions, rolling back the call process that has occurred includes: obtaining the corresponding callback path according to the identifier of the transaction; calling the callback method based on the callback path, and according to The callback method rolls back the calling process that has occurred.
在本发明的一些实施例中,基于前述方案,在调用所述多个对象中的每个对象时,均记录所述事务的标识和对应的回调路径。In some embodiments of the present invention, based on the foregoing solution, when each of the multiple objects is called, the identifier of the transaction and the corresponding callback path are recorded.
在本发明的一些实施例中,基于前述方案,在记录所述事务的标识和对应的回调路径之后,还包括:若检测到对所述已发生的调用过程回滚成功,则删除调用所述任一对象时记录的所述事务的标识和对应的回调路径。In some embodiments of the present invention, based on the foregoing solution, after recording the transaction identifier and the corresponding callback path, it further includes: if it is detected that the rollback of the call process that has occurred is successfully rolled back, then delete the call process The identifier of the transaction recorded by any object and the corresponding callback path.
在本发明的一些实施例中,基于前述方案,在记录所述事务的标识和对应的回调路径之后,还包括:若对所述多个对象均调用成功,则删除记录的与所述事务的标识相关的所有信息。In some embodiments of the present invention, based on the aforementioned solution, after recording the identifier of the transaction and the corresponding callback path, it further includes: if all the calls to the multiple objects are successful, then delete the recorded connection with the transaction All information related to the identity.
在本发明的一些实施例中,基于前述方案,还包括:若对任一对象调用成功,则根据调用顺序继续调用所述多个对象中的下一个对象,直至所述多个对象全部调用完成。In some embodiments of the present invention, based on the foregoing solution, further comprising: if the call to any object is successful, continue to call the next object in the multiple objects according to the calling sequence until all the calls to the multiple objects are completed .
在本发明的一些实施例中,基于前述方案,所述多个目标对象为分布式系统中的节点。In some embodiments of the present invention, based on the foregoing solution, the multiple target objects are nodes in a distributed system.
根据本发明实施例的第二方面,提供了一种异常事件的处理装置,包括:异常检测单元,用于在业务的执行过程中,检测是否出现异常事件;异常存储单元,用于若检测到出现所述异常事件,则在目标数据库中存储与所述异常事件对应的异常消息;重试单元,用于读取所述目标数据库中存储的异常消息,并根据读取的异常消息对相应的业务进行重试处理;删除单元,用于在重试成功时从所述目标数据库中删除读取的异常消息。According to the second aspect of the embodiments of the present invention, there is provided a device for processing abnormal events, including: an abnormal detection unit, used to detect whether an abnormal event occurs during the execution of a business; an abnormal storage unit, used to detect When the abnormal event occurs, an abnormal message corresponding to the abnormal event is stored in the target database; a retry unit is configured to read the abnormal message stored in the target database, and perform corresponding processing according to the read abnormal message. The business performs retry processing; the deletion unit is configured to delete the read abnormal message from the target database when the retry succeeds.
根据本发明实施例的第三方面,提供了一种电子设备,包括:处理器;以及存储器,所述存储器上存储有计算机可读指令,所述计算机可读指令被所述处理器执行时实现如上述第一方面所述的异常事件的处理方法。According to a third aspect of the embodiments of the present invention, there is provided an electronic device, including: a processor; and a memory, where computer-readable instructions are stored in the memory, and the computer-readable instructions are implemented when executed by the processor. The method for handling the abnormal event as described in the first aspect above.
根据本发明实施例的第四方面,提供了一种计算机可读存储介质,其上存储有计算机程序,所述计算机程序被处理器执行时实现如上述第一方面所述的异常事件的处理方法。According to a fourth aspect of the embodiments of the present invention, there is provided a computer-readable storage medium, on which a computer program is stored, and when the computer program is executed by a processor, the method for processing an abnormal event as described in the above-mentioned first aspect is implemented. .
在本发明的一些实施例所提供的技术方案中,在检测到异常事件时,在目标数据库中存储与异常事件对应的异常消息;根据读取的目标数据库中的异常消息对相应的业务进行重试处理,在重试成功时删除异常消息。一方面,当检测到异常事件时,在目标数据库中存储与异常事件对应的异常消息,能够保证异常消息不会丢失;另一方面,根据读取的目标数据库中的异常消息对相应的业务进行重试处理,在重试成功时删除异常消息,使得能够自动地对发生异常的业务进行重试,不需要人为干预,大大地节省了人力和物力的投入;再一方面,由于检测、存储异常消息的过程与读取异常消息进行处理的过程是异步进行的,因此能够提高异常事件的处理效率。In the technical solution provided by some embodiments of the present invention, when an abnormal event is detected, the abnormal message corresponding to the abnormal event is stored in the target database; Retry processing, delete the exception message when the retry succeeds. On the one hand, when an abnormal event is detected, the abnormal message corresponding to the abnormal event is stored in the target database, which can ensure that the abnormal message will not be lost; on the other hand, the corresponding business is processed according to the abnormal message in the target database read Retry processing, delete the abnormal message when the retry is successful, so that the abnormal business can be automatically retried without human intervention, which greatly saves the investment of manpower and material resources; on the other hand, due to the abnormal detection and storage The message process and the process of reading and processing the exception message are asynchronous, so the processing efficiency of the exception event can be improved.
应当理解的是,以上的一般描述和后文的细节描述仅是示例性和解释性的,并不能限制本发明。It is to be understood that both the foregoing general description and the following detailed description are exemplary and explanatory only and are not restrictive of the invention.
附图说明Description of drawings
此处的附图被并入说明书中并构成本说明书的一部分,示出了符合本发明的实施例,并与说明书一起用于解释本发明的原理。显而易见地,下面描述中的附图仅仅是本发明的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他的附图。在附图中:The accompanying drawings, which are incorporated in and constitute a part of this specification, illustrate embodiments consistent with the invention and together with the description serve to explain the principles of the invention. Apparently, the drawings in the following description are only some embodiments of the present invention, and those skilled in the art can obtain other drawings according to these drawings without creative efforts. In the attached picture:
图1示出了根据本发明的第一个实施例的异常事件的处理方法的流程示意图;FIG. 1 shows a schematic flowchart of a method for processing an abnormal event according to a first embodiment of the present invention;
图2示出了根据本发明的示例性实施例的异常事件处理系统的示意框图;Fig. 2 shows a schematic block diagram of an abnormal event processing system according to an exemplary embodiment of the present invention;
图3示出了根据本发明的第二个实施例的异常事件的处理方法的流程示意图;FIG. 3 shows a schematic flowchart of a method for processing an abnormal event according to a second embodiment of the present invention;
图4示出了根据本发明的示例性实施例的对多个对象进行调用的过程示意图;Fig. 4 shows a schematic diagram of the process of calling multiple objects according to an exemplary embodiment of the present invention;
图5示出了根据本发明的第三个示例性实施例的异常事件的处理方法的流程示意图;FIG. 5 shows a schematic flowchart of a method for processing an abnormal event according to a third exemplary embodiment of the present invention;
图6示出了根据本发明的一示例性实施例的异常事件的处理装置的示意框图;Fig. 6 shows a schematic block diagram of an abnormal event processing device according to an exemplary embodiment of the present invention;
图7示出了适于用来实现本发明实施例的电子设备的计算机系统的结构示意图。FIG. 7 shows a schematic structural diagram of a computer system suitable for implementing the electronic device of the embodiment of the present invention.
具体实施方式Detailed ways
现在将参考附图更全面地描述示例实施例。然而,示例实施例能够以多种形式实施,且不应被理解为限于在此阐述的实施例;相反,提供这些实施例使得本发明将全面和完整,并将示例实施例的构思全面地传达给本领域的技术人员。在图中相同的附图标记表示相同或类似的部分,因而将省略对它们的重复描述。Example embodiments will now be described more fully with reference to the accompanying drawings. Example embodiments may, however, be embodied in many forms and should not be construed as limited to the embodiments set forth herein; rather, these embodiments are provided so that this disclosure will be thorough and complete, and will fully convey the concept of example embodiments to those skilled in the art. The same reference numerals denote the same or similar parts in the drawings, and thus their repeated descriptions will be omitted.
此外,所描述的特征、结构或特性可以以任何合适的方式结合在一个或更多实施例中。在下面的描述中,提供许多具体细节从而给出对本发明的实施例的充分理解。然而,本领域技术人员将意识到,可以实践本发明的技术方案而没有特定细节中的一个或更多,或者可以采用其它的方法、组元、装置、步骤等。在其它情况下,不详细示出或描述公知方法、装置、实现或者操作以避免模糊本发明的各方面。Furthermore, the described features, structures, or characteristics may be combined in any suitable manner in one or more embodiments. In the following description, numerous specific details are provided in order to give a thorough understanding of embodiments of the invention. However, those skilled in the art will appreciate that the technical solutions of the present invention may be practiced without one or more of the specific details, or other methods, components, means, steps, etc. may be employed. In other instances, well-known methods, apparatus, implementations, or operations have not been shown or described in detail to avoid obscuring aspects of the invention.
附图中所示的方框图仅仅是功能实体,不一定必须与物理上独立的实体相对应。即,可以采用软件形式来实现这些功能实体,或在一个或多个硬件模块或集成电路中实现这些功能实体,或在不同网络和/或处理器装置和/或微控制器装置中实现这些功能实体。The block diagrams shown in the drawings are merely functional entities and do not necessarily correspond to physically separate entities. That is, these functional entities may be implemented in software, or in one or more hardware modules or integrated circuits, or in different networks and/or processor devices and/or microcontroller devices entity.
附图中所示的流程图仅是示例性说明,不是必须包括所有的内容和操作/步骤,也不是必须按所描述的顺序执行。例如,有的操作/步骤还可以分解,而有的操作/步骤可以合并或部分合并,因此实际执行的顺序有可能根据实际情况改变。The flow charts shown in the drawings are only exemplary illustrations, and do not necessarily include all contents and operations/steps, nor must they be performed in the order described. For example, some operations/steps can be decomposed, and some operations/steps can be combined or partly combined, so the actual order of execution may be changed according to the actual situation.
图1示出了根据本发明的第一个实施例的异常事件的处理方法的流程示意图。Fig. 1 shows a schematic flowchart of a method for processing an abnormal event according to a first embodiment of the present invention.
参照图1所示,该异常事件的处理方法可以包括以下步骤:Referring to Fig. 1, the processing method of the abnormal event may include the following steps:
步骤S110,在业务的执行过程中,检测是否出现异常事件;Step S110, during the execution of the business, detect whether an abnormal event occurs;
步骤S120,若检测到出现所述异常事件,则在目标数据库中存储与所述异常事件对应的异常消息;Step S120, if the occurrence of the abnormal event is detected, storing an abnormal message corresponding to the abnormal event in the target database;
步骤S130,读取所述目标数据库中存储的异常消息,并根据读取的异常消息对相应的业务进行重试处理;Step S130, reading the abnormal message stored in the target database, and retrying the corresponding business according to the read abnormal message;
步骤S140,在重试成功时从所述目标数据库中删除读取的异常消息。Step S140, when the retry succeeds, delete the read exception message from the target database.
在图1所示的异常事件的处理方法,一方面,当检测到异常事件时,在目标数据库中存储与异常事件对应的异常消息,能够保证异常消息不会丢失;另一方面,根据读取目标数据库中存储的异常消息对与异常消息对应的业务进行重试处理,在重试成功时删除异常消息,使得能够自动地对异常的业务进行重试,不需要人为干预,大大地节省了人力和物力的投入;再一方,由于检测、存储异常消息的过程与读取异常消息进行处理的过程是异步进行的,因此能够提高异常事件的处理效率。In the processing method of the abnormal event shown in Figure 1, on the one hand, when the abnormal event is detected, the abnormal message corresponding to the abnormal event is stored in the target database, which can ensure that the abnormal message will not be lost; on the other hand, according to the read The exception messages stored in the target database retry the business corresponding to the exception message, and delete the exception message when the retry is successful, so that the abnormal business can be retried automatically without human intervention, which greatly saves manpower and material resources; on the other hand, since the process of detecting and storing abnormal messages and the process of reading abnormal messages for processing are asynchronous, it can improve the processing efficiency of abnormal events.
下面,将结合附图对本示例实施例中的异常事件的处理方法进行详细的描述。Next, the method for handling abnormal events in this exemplary embodiment will be described in detail with reference to the accompanying drawings.
参照图1所示,在步骤S110中,在业务的执行过程中,检测是否出现异常事件。Referring to FIG. 1 , in step S110 , during the execution of the service, it is detected whether an abnormal event occurs.
可选地,图1所示的异常事件的处理方法可以是由图2所示的根据本发明的示例性实施例的异常事件处理系统来执行的。参照图2所示,该异常事件处理系统可以包括:异常事件发布器210、异常消息处理引擎220、定时任务触发器230、异常业务重试引擎240以及数据库250。Optionally, the abnormal event processing method shown in FIG. 1 may be executed by the abnormal event processing system according to the exemplary embodiment of the present invention shown in FIG. 2 . Referring to FIG. 2 , the abnormal event processing system may include: an abnormal event publisher 210 , an abnormal message processing engine 220 , a scheduled task trigger 230 , an abnormal service retry engine 240 and a database 250 .
在本示例实施例中,在执行业务的过程中发生异常时,可以通过异常事件发布器210向异常消息处理引擎220发布异常事件,异常事件中可以包含异常事件发生时间、异常事件对应的消息体(如消息发送业务中的消息本身)、发生异常的错误消息、异常事件对应的目标队列(如消息发送业务中的发送的消息所在的队列)等内容。In this exemplary embodiment, when an exception occurs in the process of executing a business, an exception event may be issued to the exception message processing engine 220 through the exception event publisher 210, and the exception event may include the occurrence time of the exception event and the message body corresponding to the exception event (such as the message itself in the message sending service), the error message where the exception occurred, and the target queue corresponding to the abnormal event (such as the queue where the sent message in the message sending service is located) and so on.
需要说明的是,在本示例实施例中,异常事件可以为消息发送失败、业务回滚失败等,但是本发明的示例实施例中的异常事件不限于此,例如还可以为消息接收失败、消息读取失败、网络闪断等异常事件,这同样在本发明的保护范围内。It should be noted that, in this example embodiment, the abnormal event may be message sending failure, business rollback failure, etc., but the abnormal event in the example embodiment of the present invention is not limited to this, for example, it may also be message receiving failure, message Abnormal events such as reading failure and network flash disconnection are also within the protection scope of the present invention.
接下来,参照图1所示,在步骤S120中,若检测到出现所述异常事件,则在目标数据库中存储与所述异常事件对应的异常消息。Next, referring to FIG. 1 , in step S120, if the abnormal event is detected, an abnormal message corresponding to the abnormal event is stored in the target database.
继续参照图2所示,在本示例实施例中,异常消息处理引擎220可以将异常事件的内容进行解析,将对应的异常消息存入数据库250中的异常消息重试表中。进一步地,还可以在异常消息重试表中记录数据库250中的存储异常消息对应的重试次数。在下表1中示出了本示例实施例中的异常消息重试表的结构。Continuing to refer to FIG. 2 , in this exemplary embodiment, the exception message processing engine 220 may analyze the content of the exception event, and store the corresponding exception message in the exception message retry table in the database 250 . Further, the number of retries corresponding to the stored exception messages in the database 250 may also be recorded in the exception message retry table. The structure of the exception message retry table in this exemplary embodiment is shown in Table 1 below.
表1Table 1
接下来,在步骤S130中,读取所述目标数据库中存储的异常消息,并根据读取的异常消息对相应的业务进行重试处理。Next, in step S130, the abnormal message stored in the target database is read, and the corresponding service is retried according to the read abnormal message.
继续参照图2所示,在本示例实施例中,定时任务触发器230可以按照配置的定时规则定时触发异常业务重试引擎240从数据库250中查询异常消息重试表中记录的异常消息,以触发异常消息重试引擎240执行异常消息重试任务。Continuing to refer to Fig. 2, in this exemplary embodiment, the timed task trigger 230 can regularly trigger the abnormal service retry engine 240 according to the configured timing rule to query the abnormal message recorded in the abnormal message retry table from the database 250 to The exception message retry engine 240 is triggered to perform the exception message retry task.
进一步地,在本示例实施例中,在异常消息重试引擎240接到定时任务触发器230的触发指令时,会抽取重试次数小于预定次数例如3次(具体数值在此处仅为示例)的异常消息,进而对与抽取出的异常消息对应的业务进行重试。在对与异常消息对应的业务重试成功后,将该条异常消息从异常消息重试表中删除;在重试失败时,将该异常消息的重试次数加1。如果一条异常消息对应的业务重试3次还没有成功,则与该条异常消息对应的业务可能出现了不可自动恢复的问题,需要人工介入进行处理。Further, in this exemplary embodiment, when the exception message retry engine 240 receives the trigger instruction from the timing task trigger 230, it will extract the number of retries less than the predetermined number of times, for example, 3 times (the specific value is only an example here) exception message, and then retry the service corresponding to the extracted exception message. After the retry of the service corresponding to the exception message succeeds, the exception message is deleted from the exception message retry table; when the retry fails, the number of retries of the exception message is increased by 1. If the service corresponding to an exception message fails to succeed after three retries, the service corresponding to the exception message may have a problem that cannot be automatically recovered, and manual intervention is required for processing.
此外,在本示例实施例中,对于消息发送业务,在业务重试时有可能会多次向接收端发送消息。因此为了避免接收端重复处理相同的消息,还可以在消息接收端创建一个消息表,以记录处理过的消息,避免消息接收端重复处理相同的消息,保证消息发送端与消息接收端的消息的幂等性。In addition, in this example embodiment, for the message sending service, the message may be sent to the receiving end multiple times when the service is retried. Therefore, in order to avoid repeated processing of the same message at the receiving end, a message table can also be created at the message receiving end to record the processed messages, avoiding the repeated processing of the same message at the message receiving end, and ensuring the power of the message between the message sending end and the message receiving end equivalence.
继续参照图1所示,在步骤S140中,在重试成功时从所述目标数据库中删除读取的异常消息。Continuing to refer to FIG. 1 , in step S140, when the retry is successful, the read exception message is deleted from the target database.
在本示例实施例中,为了避免在业务重试成功后再次读取异常消息进行重试,可以在重试成功时从目标数据库中的异常消息重试表中删除记录的异常消息。In this exemplary embodiment, in order to avoid retrying by reading the exception message again after the service retry succeeds, the recorded exception message may be deleted from the exception message retry table in the target database when the retry succeeds.
上述实施例中的异常事件的处理方法能够自动地对异常的业务进行重试,不需要人为干预,大大地节省了人力和物力的投入,并且由于检测、存储异常消息的过程与读取异常消息进行处理的过程是异步进行的,因此能够提高异常事件的处理效率。The abnormal event processing method in the above embodiment can automatically retry the abnormal business without human intervention, which greatly saves the input of manpower and material resources, and because the process of detecting and storing abnormal messages is not the same as reading abnormal messages The process of processing is performed asynchronously, so the processing efficiency of abnormal events can be improved.
图3示出了根据本发明的第二个实施例的异常事件的处理方法的流程示意图。Fig. 3 shows a schematic flowchart of a method for processing an abnormal event according to a second embodiment of the present invention.
参照图3所示,在步骤S310中,定时任务触发器触发定时任务。具体地,图2中所示的定时任务触发器230可以按照配置的定时规则定时触发异常消息重试引擎240来执行重试任务。需要说明的是,图3所示的各个步骤中,除了步骤S310,其它步骤的执行主体可以是图2中所示的异常消息重试引擎240。Referring to FIG. 3, in step S310, a timed task trigger triggers a timed task. Specifically, the timing task trigger 230 shown in FIG. 2 can periodically trigger the exception message retry engine 240 to execute the retry task according to the configured timing rules. It should be noted that, among the various steps shown in FIG. 3 , except step S310 , other steps may be executed by the exception message retry engine 240 shown in FIG. 2 .
在步骤S320中,读取异常消息重试表中存储的异常消息。异常消息重试表中的该异常消息可以包括对应业务的重试次数。In step S320, the exception message stored in the exception message retry table is read. The exception message in the exception message retry table may include the number of retries of the corresponding service.
在步骤S330中,判断与异常消息对应的业务是否重试了预定次数,例如3次;若在步骤S330中判定已经重试了预定次数,则结束流程,若在步骤S330中判定未重试到预定次数,则执行步骤S340。In step S330, it is judged whether the service corresponding to the abnormal message has been retried a predetermined number of times, for example, 3 times; If the predetermined number of times is exceeded, step S340 is executed.
在步骤S340中,执行与异常消息对应的业务的重试操作。In step S340, the retry operation of the service corresponding to the abnormal message is performed.
进一步地,在步骤S350中,可以判断步骤S340中的重试操作是否成功,在步骤S350中判断重试成功时,执行步骤S360;在步骤S350中判定重试未成功时,执行步骤S370。Further, in step S350, it may be determined whether the retry operation in step S340 is successful, and if it is determined in step S350 that the retry operation is successful, step S360 is performed; when it is determined in step S350 that the retry operation is unsuccessful, step S370 is performed.
在步骤S360中,删除异常消息重试表中中存储的该条异常消息。In step S360, delete the exception message stored in the exception message retry table.
在步骤S370中将异常消息的重试次数加1。In step S370, add 1 to the number of retries of the exception message.
由于该示例实施例中的异常事件的处理方法的具体细节与上述第一个实施例中的异常事件的处理方法的具体细节类似,在此将不再赘述。同样地,图3所示的异常事件的处理方法同样能够自动地对异常的业务进行重试,并且也能够提高异常事件的处理效率。Since the specific details of the method for handling the abnormal event in this example embodiment are similar to those in the above-mentioned first embodiment, details will not be repeated here. Similarly, the method for handling abnormal events shown in FIG. 3 can also automatically retry abnormal services, and can also improve the processing efficiency of abnormal events.
图4示出了根据本发明的示例性实施例的另一异常事件处理系统的示意图。Fig. 4 shows a schematic diagram of another abnormal event processing system according to an exemplary embodiment of the present invention.
参照图4所示,在同一事务中,服务D需要依次调用对象A、对象B以及对象C。为了保证这种在一个事务中需要对多个对象进行调用时的数据一致性,在服务D对对象A、对象B、对象C中任一对象调用失败的情况下,需要对已发生的调用过程进行回滚,比如调用对象B失败时,需要对调用对象A和对象B的过程进行回滚。一旦回滚失败,则会在整个系统中产生消息不一致的问题,这样会造成系统中存在一些错误的数据。因此,可以通过中间表例如本地消息表存储异常消息,根据所存储的异常消息通过上述示例实施例中的异常事件的处理方法对回滚失败的业务进行重试,直到重试成功后将异常消息删除,从而保证整个系统的消息一致性。Referring to FIG. 4 , in the same transaction, service D needs to call object A, object B, and object C in sequence. In order to ensure the data consistency when multiple objects need to be called in one transaction, when service D fails to call any object in object A, object B, or object C, it is necessary to Perform rollback, for example, when calling object B fails, the process of calling object A and object B needs to be rolled back. Once the rollback fails, message inconsistency will occur throughout the system, which will cause some erroneous data in the system. Therefore, the exception message can be stored in an intermediate table such as a local message table, and the business that fails to be rolled back can be retried through the exception event processing method in the above example embodiment according to the stored exception message until the exception message is sent to the server after the retry succeeds. Deleted to ensure message consistency across the system.
需要说明的是,在本示例实施例中,多个对象可以为同一个系统中的多个业务逻辑(如业务对象),也可以为分布式系统中的多个节点(如分布式系统中的服务器节点),这两种情况都在本发明的保护范围内。以下对图4所示的处理过程进行详细说明:It should be noted that, in this example embodiment, multiple objects may be multiple business logics (such as business objects) in the same system, or multiple nodes in a distributed system (such as server node), both cases are within the protection scope of the present invention. The processing procedure shown in Figure 4 is described in detail below:
参照图4所示,在本示例实施例中,服务D在同一事务中依次调用对象A、对象B以及对象C时,需要调用本地消息表记录相关的信息,以保证消息的一致性,可选地,本地消息表至少可以包含以下内容:(1)事务号;(2)回调服务地址(即回调路径,用于进行数据回滚);(3)本次回滚是否异常。下表2示出了本发明的一个示例实施例中的本地消息表message_log的各个字段的信息:Referring to Figure 4, in this example embodiment, when service D calls object A, object B, and object C sequentially in the same transaction, it needs to call the local message table to record relevant information to ensure message consistency. Optional Specifically, the local message table can at least include the following contents: (1) transaction number; (2) callback service address (that is, the callback path, used for data rollback); (3) whether the rollback is abnormal. The following table 2 shows the information of each field of the local message table message_log in an example embodiment of the present invention:
表2Table 2
在图4所示的实施例中,当服务D在调用对象A之前,需要在本地消息表中记录事务号T和对对象A服务进行回滚的回调服务地址(即回调路径)。如果对对象A调用失败,则根据该回调服务地址进行数据回滚;如果服务D对对象A调用成功,则继续调用对象B。In the embodiment shown in FIG. 4 , before calling object A, service D needs to record the transaction number T and the callback service address (that is, the callback path) for rolling back the object A service in the local message table. If the call to object A fails, data rollback will be performed according to the callback service address; if service D succeeds in calling object A, continue to call object B.
当服务D在调用对象B之前,同样需要在本地消息表中记录事务号T、回调服务地址。如果对对象B的调用失败,则需要对已经发生的调用过程进行回滚。Before service D calls object B, it also needs to record transaction number T and callback service address in the local message table. If the call to object B fails, it is necessary to roll back the calling process that has already occurred.
回滚的具体方法是:根据事务号T从本地消息表中查询之前记录的回调服务地址,根据回调服务地址调用相应的回调方法对已发生的调用过程进行回滚。若检测到回滚失败,则保留记录的事务号T及回调服务地址,并在本地消息表中存储对已发生的调用过程回滚失败的消息,例如可以在表2中所示的本地消息表的字段名称为status(状态)的字段下存储与回滚异常对应的异常消息。The specific method of rollback is: query the previously recorded callback service address from the local message table according to the transaction number T, and call the corresponding callback method according to the callback service address to roll back the call process that has occurred. If the rollback failure is detected, the recorded transaction number T and the callback service address are kept, and the message of the rollback failure of the call process that has occurred is stored in the local message table, for example, the local message table shown in Table 2 The exception message corresponding to the rollback exception is stored under the field whose field name is status (status).
进一步地,为了处理回滚失败的这种异常事件,可以采用类似于图1中所示的异常事件的处理方法,具体地,可以定时地从本地消息表中读取所述异常消息,根据读取的异常消息获取与该异常消息对应的同一事务下的回调服务地址,根据所述回调服务地址重新对已发生的调用过程进行回滚。可选地,还可以在本地消息表中记录回滚失败的次数,以在回滚失败的次数达到预定次数时,由人工介入处理。Further, in order to handle the abnormal event of rollback failure, a processing method similar to the abnormal event shown in FIG. 1 can be adopted. Specifically, the abnormal message can be read from the local message table periodically, The retrieved exception message obtains the callback service address under the same transaction corresponding to the exception message, and rolls back the call process that has occurred according to the callback service address. Optionally, the number of rollback failures may also be recorded in the local message table, so that when the number of rollback failures reaches a predetermined number, manual intervention is performed.
在对已发生的调用过程回滚成功时,删除在本地消息表中记录的事务号、回调服务地址以及回滚异常的异常消息。When the rollback of the calling process that has occurred is successful, delete the transaction number, callback service address and exception message of the rollback exception recorded in the local message table.
如果服务D对对象B调用成功,则继续调用对象C。If service D calls object B successfully, it continues to call object C.
服务D对对象C的调用的处理过程与对对象B的调用的处理过程基本类似。需要注意的是,由于对象C是最后一个调用的对象,因此在对对象C调用成功时,可以删除与事务T相关的所有信息即在本地消息表中记录的与事务T有关的所有信息。The processing process of service D's call to object C is basically similar to the processing process of service D's call to object B. It should be noted that since object C is the last object to be called, when the call to object C is successful, all information related to transaction T can be deleted, that is, all information related to transaction T recorded in the local message table.
图5具体示出了图4中所示的调用过程的处理流程。参照图5所示,在同一事务下,服务D需要依次调用对象A、对象B和对象C。以下对各个步骤进行详细阐述:FIG. 5 specifically shows the processing flow of the calling process shown in FIG. 4 . Referring to FIG. 5 , under the same transaction, service D needs to call object A, object B, and object C in sequence. Each step is described in detail below:
在步骤S502中,服务D在本地消息表中记录事务号T、消息流水号(消息流水号为可选,并非一定要有消息流水号)以及对象A的回调函数地址。In step S502, the service D records the transaction number T, the message serial number (the message serial number is optional and not necessary) and the callback function address of the object A in the local message table.
在步骤S504中,调用对象A。In step S504, object A is called.
在步骤S506中,判断服务D对对象A的调用是否成功,若在步骤S506中判定调用对象A成功,则执行步骤S510;若在步骤S506中判定调用对象A失败,则执行步骤S508。In step S506, it is determined whether the invocation of object A by service D is successful, if it is determined in step S506 that invocation of object A is successful, then step S510 is executed; if in step S506 it is determined that invocation of object A fails, then step S508 is executed.
在步骤S508中,进行数据回滚处理。在回滚处理时,可以根据事务号T获取在调用对象A之前记录的回调函数地址,基于该回调函数地址调用回调方法进行回滚处理。In step S508, data rollback processing is performed. During the rollback process, the callback function address recorded before calling the object A can be obtained according to the transaction number T, and the callback method is called to perform the rollback process based on the callback function address.
在步骤S510中,在本地消息表中记录事务号T、消息流水号以及回调函数地址。In step S510, record the transaction number T, message serial number and callback function address in the local message table.
在步骤S512中,调用对象B。In step S512, object B is invoked.
接下来,在步骤S514中判断对对象B的调用是否成功;若在步骤S514中判定调用对象B成功,则执行步骤S524;若调用对象B失败,则执行步骤S516。Next, it is judged in step S514 whether the call to object B is successful; if it is judged in step S514 that the call to object B is successful, then step S524 is executed; if the call to object B fails, then step S516 is executed.
在步骤S516中,根据事物号T查询记录的回调服务地址,根据回调服务地址调用回调方法对已发生的调用过程进行回滚。In step S516, the recorded callback service address is queried according to the transaction number T, and the callback method is invoked according to the callback service address to roll back the calling process that has occurred.
进一步地,在步骤S518中,判断回调是否成功;若在步骤S518中判定回调成功,则执行步骤S520;若判定回调失败,则可以在本地消息表中记录回调失败的异常消息,然后执行步骤S522。Further, in step S518, it is judged whether the callback is successful; if it is judged in step S518 that the callback is successful, then step S520 is executed; if it is judged that the callback fails, the abnormal message of callback failure can be recorded in the local message table, and then step S522 is executed .
在步骤S520中,删除在步骤S510中记录的事务号T、消息流水号以及回调地址。In step S520, delete the transaction number T, message serial number and callback address recorded in step S510.
在步骤S522中,等待定时任务重试。即定时任务定时读取本地消息表中记录的信息,并对已发生的调用过程重新进行回滚,直到回调成功后删除在本地消息表中记录的事务号T、消息流水号、回调地址以及回滚是否异常等记录。当然,也可以在重试预定次数依然回滚失败后,由人工介入处理。In step S522, wait for the scheduled task to retry. That is, the scheduled task regularly reads the information recorded in the local message table, and rolls back the call process that has occurred until the callback succeeds, and then deletes the transaction number T, message serial number, callback address, and callback address recorded in the local message table. Record whether the roll is abnormal or not. Of course, it can also be handled by manual intervention after the predetermined number of retries still fail to roll back.
在步骤S524中,在本地消息表中记录事物号T、消息流水号以及回调函数地址。In step S524, record the transaction number T, message serial number and callback function address in the local message table.
在步骤S526中,调用对象C。In step S526, object C is invoked.
接下来,在步骤S528中判断对对象C的调用是否成功;若在步骤S528中判定对对象C的调用成功,则执行步骤S530;若调用对象C失败,则执行步骤S516。Next, in step S528, it is judged whether the call to object C is successful; if it is judged in step S528 that the call to object C is successful, then step S530 is executed; if the call to object C fails, then step S516 is executed.
在步骤S530中,根据事务号T删除与该事务号T相关的所有记录。In step S530, according to the transaction number T, all records related to the transaction number T are deleted.
图4和图5所示实施例的技术方案中,通过在调用任一对象失败时,对一发生的调用过程进行回滚,当回滚失败时,记录异常消息并进行重试,使得能够保证整个系统的数据的一致性。同时,自动重试机制的使用也使得无需人为干预,节省了人力和物力的投入,并且也能够提高回滚处理的效率。In the technical solution of the embodiment shown in Fig. 4 and Fig. 5, when calling any object fails, the call process that takes place is rolled back, and when the rollback fails, the exception message is recorded and retried, so that it can be guaranteed Data consistency across the system. At the same time, the use of the automatic retry mechanism also eliminates the need for human intervention, saves the input of manpower and material resources, and can also improve the efficiency of rollback processing.
此外,在本发明的实施例中,还提供了一种异常事件的处理装置。参照图6所示,该异常事件的处理装置600可以包括:异常检测单元610、异常存储单元620、重试单元630以及删除单元640。In addition, in the embodiment of the present invention, a device for processing abnormal events is also provided. Referring to FIG. 6 , the abnormal event processing apparatus 600 may include: an abnormality detection unit 610 , an abnormality storage unit 620 , a retry unit 630 and a deletion unit 640 .
其中,异常检测单元610用于在业务的执行过程中,检测是否出现异常事件;异常存储单元620用于若检测到出现所述异常事件,则在目标数据库中存储与所述异常事件对应的异常消息;重试单元630用于读取所述目标数据库中存储的异常消息,并根据读取的异常消息对相应的业务进行重试处理;删除单元640用于在重试成功时从所述目标数据库中删除读取的异常消息。Wherein, the abnormal detection unit 610 is used to detect whether an abnormal event occurs during the execution of the business; the abnormal storage unit 620 is used to store the abnormal event corresponding to the abnormal event in the target database if the abnormal event is detected. message; the retry unit 630 is used to read the exception message stored in the target database, and retry the corresponding business according to the read exception message; the delete unit 640 is used to remove the Delete the exception message read from the database.
在本发明的一些实施例中,基于前述方案,异常事件的处理装置600还包括:第一记录单元,用于在重试失败时,累加读取的异常消息对应的重试次数。In some embodiments of the present invention, based on the foregoing solution, the abnormal event processing apparatus 600 further includes: a first recording unit configured to accumulate the number of retries corresponding to the read abnormal message when the retry fails.
其中,重试单元630配置为:读取所述目标数据库中对应的重试次数小于预定次数的异常消息。Wherein, the retry unit 630 is configured to: read the abnormal message whose corresponding retry times are less than a predetermined number in the target database.
在本发明的一些实施例中,基于前述方案,重试单元630被配置成:按照预定周期,定时读取所述目标数据库中存储的异常消息。In some embodiments of the present invention, based on the foregoing solution, the retry unit 630 is configured to: regularly read the exception messages stored in the target database according to a predetermined period.
在本发明的一些实施例中,基于前述方案,异常事件的处理装置600还包括:解析单元,用于对所述异常事件进行解析,以获取所述异常事件对应的异常消息。In some embodiments of the present invention, based on the foregoing solution, the abnormal event processing apparatus 600 further includes: an analyzing unit configured to analyze the abnormal event, so as to obtain an abnormal message corresponding to the abnormal event.
在本发明的一些实施例中,基于前述方案,异常检测单元610包括:回滚单元,用于在同一事务中依次调用多个对象时,若对任一对象调用失败,则对已发生的调用过程进行回滚处理;确定单元,用于若检测到对已发生的调用过程回滚失败,则确定检测到回滚业务出现异常事件。In some embodiments of the present invention, based on the foregoing solution, the abnormality detection unit 610 includes: a rollback unit, configured to call multiple objects sequentially in the same transaction, if the call to any object fails, the call that has occurred The process performs rollback processing; the determination unit is used to determine that an abnormal event of the rollback business is detected if the rollback failure of the calling process that has occurred is detected.
在本发明的一些实施例中,基于前述方案,异常存储单元620被配置成:在所述目标数据库中存储对已发生的调用过程回滚失败的消息。In some embodiments of the present invention, based on the foregoing solution, the exception storage unit 620 is configured to: store a message of rollback failure of the call process that has occurred in the target database.
在本发明的一些实施例中,基于前述方案,回滚单元被配置成:根据所述事务的标识,获取对应的回调路径;基于所述回调路径调用回调方法,并根据所述回调方法对已发生的调用过程进行回滚处理。In some embodiments of the present invention, based on the foregoing solution, the rollback unit is configured to: acquire a corresponding callback path according to the transaction identifier; call a callback method based on the callback path, and The resulting call is rolled back.
在本发明的一些实施例中,基于前述方案,异常事件的处理装置600还包括:第二记录单元,用于在调用所述多个对象中的每个对象时,均记录所述事务的标识和对应的回调路径。In some embodiments of the present invention, based on the foregoing solution, the abnormal event processing apparatus 600 further includes: a second recording unit, configured to record the transaction identifier when calling each of the plurality of objects and the corresponding callback path.
在本发明的一些实施例中,基于前述方案,第二记录单元配置为:在对所述已发生的调用过程回滚成功时,删除调用所述任一对象时记录的所述事务的标识和对应的回调路径。In some embodiments of the present invention, based on the foregoing solution, the second recording unit is configured to: when the rollback of the call process that has occurred is successfully rolled back, delete the transaction identifier and The corresponding callback path.
在本发明的一些实施例中,基于前述方案,第二记录单元配置为:在对所述多个对象均调用成功时,删除记录的与所述事务的标识相关的所有信息。In some embodiments of the present invention, based on the foregoing solution, the second recording unit is configured to: delete all recorded information related to the transaction identifier when all the calls to the multiple objects are successful.
在本发明的一些实施例中,基于前述方案,异常事件的处理装置600还包括:调用单元,用于在对任一对象调用成功时,根据调用顺序继续调用所述多个对象中的下一个对象,直至所述多个对象全部调用完成。In some embodiments of the present invention, based on the foregoing solution, the abnormal event processing apparatus 600 further includes: a calling unit, configured to continue calling the next object in the plurality of objects according to the calling sequence when calling any object successfully objects until all the calls of the multiple objects are completed.
由于本发明的示例实施例的异常事件的处理装置600的各个功能模块与上述异常事件的处理方法的示例实施例的步骤对应,因此在此不再赘述。Since each functional module of the abnormal event processing apparatus 600 in the exemplary embodiment of the present invention corresponds to the steps in the above exemplary embodiment of the abnormal event processing method, details are not repeated here.
在本发明的示例性实施例中,还提供了一种能够实现上述方法的电子设备。In an exemplary embodiment of the present invention, an electronic device capable of implementing the above method is also provided.
下面参考图7,其示出了适于用来实现本发明实施例的电子设备的计算机系统700的结构示意图。图7示出的电子设备的计算机系统700仅是一个示例,不应对本发明实施例的功能和使用范围带来任何限制。Referring now to FIG. 7 , it shows a schematic structural diagram of a computer system 700 suitable for implementing an electronic device according to an embodiment of the present invention. The computer system 700 of the electronic device shown in FIG. 7 is only an example, and should not limit the functions and scope of use of the embodiments of the present invention.
如图7所示,计算机系统700包括中央处理单元(CPU)701,其可以根据存储在只读存储器(ROM)702中的程序或者从存储部分708加载到随机访问存储器(RAM)703中的程序而执行各种适当的动作和处理。在RAM 703中,还存储有系统操作所需的各种程序和数据。CPU701、ROM 702以及RAM 703通过总线704彼此相连。输入/输出(I/O)接口705也连接至总线704。As shown in FIG. 7 , a computer system 700 includes a central processing unit (CPU) 701 that can operate according to a program stored in a read-only memory (ROM) 702 or a program loaded from a storage section 708 into a random-access memory (RAM) 703 Instead, various appropriate actions and processes are performed. In the RAM 703, various programs and data necessary for system operation are also stored. The CPU 701 , ROM 702 , and RAM 703 are connected to each other via a bus 704 . An input/output (I/O) interface 705 is also connected to the bus 704 .
以下部件连接至I/O接口705:包括键盘、鼠标等的输入部分706;包括诸如阴极射线管(CRT)、液晶显示器(LCD)等以及扬声器等的输出部分707;包括硬盘等的存储部分708;以及包括诸如LAN卡、调制解调器等的网络接口卡的通信部分709。通信部分709经由诸如因特网的网络执行通信处理。驱动器710也根据需要连接至I/O接口705。可拆卸介质711,诸如磁盘、光盘、磁光盘、半导体存储器等等,根据需要安装在驱动器710上,以便于从其上读出的计算机程序根据需要被安装入存储部分708。The following components are connected to the I/O interface 705: an input section 706 including a keyboard, a mouse, etc.; an output section 707 including a cathode ray tube (CRT), a liquid crystal display (LCD), etc., and a speaker; a storage section 708 including a hard disk, etc. and a communication section 709 including a network interface card such as a LAN card, a modem, or the like. The communication section 709 performs communication processing via a network such as the Internet. A drive 710 is also connected to the I/O interface 705 as needed. A removable medium 711 such as a magnetic disk, optical disk, magneto-optical disk, semiconductor memory, etc. is mounted on the drive 710 as necessary so that a computer program read therefrom is installed into the storage section 708 as necessary.
特别地,根据本发明的实施例,上文参考流程图描述的过程可以被实现为计算机软件程序。例如,本发明的实施例包括一种计算机程序产品,其包括承载在计算机可读介质上的计算机程序,该计算机程序包含用于执行流程图所示的方法的程序代码。在这样的实施例中,该计算机程序可以通过通信部分709从网络上被下载和安装,和/或从可拆卸介质711被安装。在该计算机程序被中央处理单元(CPU)701执行时,执行本申请的系统中限定的上述功能。In particular, according to an embodiment of the present invention, the processes described above with reference to the flowcharts may be implemented as computer software programs. For example, the embodiments of the present invention include a computer program product, which includes a computer program carried on a computer-readable medium, where the computer program includes program codes for executing the methods shown in the flowcharts. In such an embodiment, the computer program may be downloaded and installed from a network via communication portion 709 and/or installed from removable media 711 . When this computer program is executed by a central processing unit (CPU) 701, the above-mentioned functions defined in the system of the present application are performed.
需要说明的是,本发明所示的计算机可读介质可以是计算机可读信号介质或者计算机可读存储介质或者是上述两者的任意组合。计算机可读存储介质例如可以是——但不限于——电、磁、光、电磁、红外线、或半导体的系统、装置或器件,或者任意以上的组合。计算机可读存储介质的更具体的例子可以包括但不限于:具有一个或多个导线的电连接、便携式计算机磁盘、硬盘、随机访问存储器(RAM)、只读存储器(ROM)、可擦式可编程只读存储器(EPROM或闪存)、光纤、便携式紧凑磁盘只读存储器(CD-ROM)、光存储器件、磁存储器件、或者上述的任意合适的组合。在本发明中,计算机可读存储介质可以是任何包含或存储程序的有形介质,该程序可以被指令执行系统、装置或者器件使用或者与其结合使用。而在本发明中,计算机可读的信号介质可以包括在基带中或者作为载波一部分传播的数据信号,其中承载了计算机可读的程序代码。这种传播的数据信号可以采用多种形式,包括但不限于电磁信号、光信号或上述的任意合适的组合。计算机可读的信号介质还可以是计算机可读存储介质以外的任何计算机可读介质,该计算机可读介质可以发送、传播或者传输用于由指令执行系统、装置或者器件使用或者与其结合使用的程序。计算机可读介质上包含的程序代码可以用任何适当的介质传输,包括但不限于:无线、电线、光缆、RF等等,或者上述的任意合适的组合。It should be noted that the computer-readable medium shown in the present invention may be a computer-readable signal medium or a computer-readable storage medium or any combination of the above two. A computer readable storage medium may be, for example, but not limited to, an electrical, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or any combination thereof. More specific examples of computer-readable storage media may include, but are not limited to, electrical connections with one or more wires, portable computer diskettes, hard disks, random access memory (RAM), read-only memory (ROM), erasable Programmable read-only memory (EPROM or flash memory), optical fiber, portable compact disk read-only memory (CD-ROM), optical storage device, magnetic storage device, or any suitable combination of the above. In the present invention, a computer-readable storage medium may be any tangible medium that contains or stores a program that can be used by or in conjunction with an instruction execution system, apparatus, or device. In the present invention, however, a computer-readable signal medium may include a data signal propagated in baseband or as part of a carrier wave, in which computer-readable program codes are carried. Such propagated data signals may take many forms, including but not limited to electromagnetic signals, optical signals, or any suitable combination of the foregoing. A computer-readable signal medium may also be any computer-readable medium other than a computer-readable storage medium, which can send, propagate, or transmit a program for use by or in conjunction with an instruction execution system, apparatus, or device. . Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to wireless, wireline, optical fiber cable, RF, etc., or any suitable combination of the foregoing.
附图中的流程图和框图,图示了按照本发明各种实施例的系统、方法和计算机程序产品的可能实现的体系架构、功能和操作。在这点上,流程图或框图中的每个方框可以代表一个模块、程序段、或代码的一部分,上述模块、程序段、或代码的一部分包含一个或多个用于实现规定的逻辑功能的可执行指令。也应当注意,在有些作为替换的实现中,方框中所标注的功能也可以以不同于附图中所标注的顺序发生。例如,两个接连地表示的方框实际上可以基本并行地执行,它们有时也可以按相反的顺序执行,这依所涉及的功能而定。也要注意的是,框图或流程图中的每个方框、以及框图或流程图中的方框的组合,可以用执行规定的功能或操作的专用的基于硬件的系统来实现,或者可以用专用硬件与计算机指令的组合来实现。The flowchart and block diagrams in the Figures illustrate the architecture, functionality, and operation of possible implementations of systems, methods and computer program products according to various embodiments of the present invention. In this regard, each block in a flowchart or block diagram may represent a module, program segment, or portion of code that includes one or more logical functions for implementing specified executable instructions. It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or they may sometimes be executed in the reverse order, depending upon the functionality involved. It should also be noted that each block in the block diagrams or flowchart illustrations, and combinations of blocks in the block diagrams or flowchart illustrations, can be implemented by a dedicated hardware-based system that performs the specified function or operation, or can be implemented by a A combination of dedicated hardware and computer instructions.
描述于本发明实施例中所涉及到的单元可以通过软件的方式实现,也可以通过硬件的方式来实现,所描述的单元也可以设置在处理器中。其中,这些单元的名称在某种情况下并不构成对该单元本身的限定。The units described in the embodiments of the present invention may be implemented by software or by hardware, and the described units may also be set in a processor. Wherein, the names of these units do not constitute a limitation of the unit itself under certain circumstances.
作为另一方面,本申请还提供了一种计算机可读介质,该计算机可读介质可以是上述实施例中描述的电子设备中所包含的;也可以是单独存在,而未装配入该电子设备中。上述计算机可读介质承载有一个或者多个程序,当上述一个或者多个程序被一个该电子设备执行时,使得该电子设备实现如上述实施例中所述的异常事件的处理方法。As another aspect, the present application also provides a computer-readable medium. The computer-readable medium may be included in the electronic device described in the above-mentioned embodiments; or it may exist independently without being assembled into the electronic device. middle. The above-mentioned computer-readable medium carries one or more programs, and when the above-mentioned one or more programs are executed by an electronic device, the electronic device is made to implement the method for processing abnormal events as described in the above-mentioned embodiments.
例如,所述电子设备可以实现如图1中所示的:步骤S110,在业务的执行过程中,检测是否出现异常事件;步骤S120,若检测到出现所述异常事件,则在目标数据库中存储与所述异常事件对应的异常消息;步骤S130,读取所述目标数据库中存储的异常消息,并根据读取的异常消息对相应的业务进行重试处理;步骤S140,在重试成功时从所述目标数据库中删除读取的异常消息。For example, the electronic device can implement as shown in Figure 1: step S110, during the execution of the service, detect whether an abnormal event occurs; step S120, if the abnormal event is detected, store the abnormal event in the target database The abnormal message corresponding to the abnormal event; step S130, read the abnormal message stored in the target database, and retry the corresponding business according to the read abnormal message; step S140, when the retry is successful, from The target database deletes the read exception message.
应当注意,尽管在上文详细描述中提及了用于动作执行的设备或装置的若干模块或者单元,但是这种划分并非强制性的。实际上,根据本发明的实施方式,上文描述的两个或更多模块或者单元的特征和功能可以在一个模块或者单元中具体化。反之,上文描述的一个模块或者单元的特征和功能可以进一步划分为由多个模块或者单元来具体化。It should be noted that although several modules or units of an apparatus or apparatus for action execution are mentioned in the above detailed description, such division is not mandatory. Actually, according to the embodiment of the present invention, the features and functions of two or more modules or units described above may be embodied in one module or unit. Conversely, the features and functions of one module or unit described above can be further divided to be embodied by a plurality of modules or units.
通过以上的实施方式的描述,本领域的技术人员易于理解,这里描述的示例实施方式可以通过软件实现,也可以通过软件结合必要的硬件的方式来实现。因此,根据本发明实施方式的技术方案可以以软件产品的形式体现出来,该软件产品可以存储在一个非易失性存储介质(可以是CD-ROM,U盘,移动硬盘等)中或网络上,包括若干指令以使得一台计算设备(可以是个人计算机、服务器、触控终端、或者网络设备等)执行根据本发明实施方式的方法。Through the description of the above implementations, those skilled in the art can easily understand that the example implementations described here can be implemented by software, or by combining software with necessary hardware. Therefore, the technical solution according to the embodiment of the present invention can be embodied in the form of a software product, and the software product can be stored in a non-volatile storage medium (which can be a CD-ROM, U disk, mobile hard disk, etc.) or on a network , including several instructions to make a computing device (which may be a personal computer, a server, a touch terminal, or a network device, etc.) execute the method according to the embodiment of the present invention.
本领域技术人员在考虑说明书及实践这里公开的发明后,将容易想到本发明的其它实施方案。本申请旨在涵盖本发明的任何变型、用途或者适应性变化,这些变型、用途或者适应性变化遵循本发明的一般性原理并包括本发明未公开的本技术领域中的公知常识或惯用技术手段。说明书和实施例仅被视为示例性的,本发明的真正范围和精神由下面的权利要求指出。Other embodiments of the invention will be readily apparent to those skilled in the art from consideration of the specification and practice of the invention disclosed herein. This application is intended to cover any modification, use or adaptation of the present invention, these modifications, uses or adaptations follow the general principles of the present invention and include common knowledge or conventional technical means in the technical field not disclosed in the present invention . The specification and examples are to be considered exemplary only, with a true scope and spirit of the invention being indicated by the following claims.
应当理解的是,本发明并不局限于上面已经描述并在附图中示出的精确结构,并且可以在不脱离其范围进行各种修改和改变。本发明的范围仅由所附的权利要求来限制。It should be understood that the present invention is not limited to the precise constructions which have been described above and shown in the accompanying drawings, and various modifications and changes may be made without departing from the scope thereof. The scope of the invention is limited only by the appended claims.
Claims (15)
- A kind of 1. processing method of anomalous event, it is characterised in that including:In the implementation procedure of business, detect whether anomalous event occur;There is the anomalous event if detecting, exception corresponding with the anomalous event is stored in target database and is disappeared Breath;The unexpected message stored in the target database is read, and weight carries out corresponding business according to the unexpected message of reading Examination is handled;When retrying successfully, the unexpected message of reading is deleted from the target database.
- 2. the processing method of anomalous event according to claim 1, it is characterised in that in the unexpected message pair according to reading Corresponding business is carried out after retrying processing, is further included:When retrying unsuccessfully, the cumulative unexpected message that reads is corresponding to be retried time Number;Wherein, the unexpected message stored in the target database is read, including:Read corresponding heavy in the target database Try the unexpected message that number is less than pre-determined number.
- 3. the processing method of anomalous event according to claim 1, it is characterised in that read in the target database and deposit The unexpected message of storage, including:According to predetermined period, the unexpected message stored in the target database is periodically read.
- 4. the processing method of anomalous event according to claim 1, it is characterised in that storage and institute in target database Before stating the corresponding unexpected message of anomalous event, further include:The anomalous event is parsed, to obtain the corresponding unexpected message of the anomalous event.
- 5. the processing method of anomalous event according to any one of claim 1 to 4, it is characterised in that in holding for business During row, detect whether anomalous event occur, including:When calling multiple objects successively in same affairs, if to any object malloc failure malloc, to the invoked procedure occurred Carry out rollback processing;Fail if detecting to the invoked procedure rollback occurred, it is determined that detect that anomalous event occurs in rollback business.
- 6. the processing method of anomalous event according to claim 5, it is characterised in that storage and institute in target database The corresponding unexpected message of anomalous event is stated, including:The invoked procedure rollback failure to having occurred is stored in the target database.
- 7. the processing method of anomalous event according to claim 5, it is characterised in that carried out to the invoked procedure occurred Rollback is handled, including:According to the mark of the affairs, corresponding readjustment path is obtained;Callback method is called based on the readjustment path, and rollback is carried out to the invoked procedure occurred according to the callback method Processing.
- 8. the processing method of anomalous event according to claim 7, it is characterised in that in the multiple object is called During each object, the mark of the affairs and corresponding readjustment path are recorded.
- 9. the processing method of anomalous event according to claim 8, it is characterised in that record the affairs mark and After corresponding readjustment path, further include:If detecting to the invoked procedure rollback success occurred, recorded when deleting the calling any object described The mark of affairs and corresponding readjustment path.
- 10. the processing method of anomalous event according to claim 8, it is characterised in that recording the mark of the affairs After corresponding readjustment path, further include:If calling success to the multiple object, deletion record with the relevant all information of the mark of the affairs.
- 11. the processing method of anomalous event according to claim 5, it is characterised in that further include:If being called to any object successfully, continue to call next object in the multiple object according to calling order, directly All call and complete to the multiple object.
- 12. the processing method of anomalous event according to claim 5, it is characterised in that the multiple destination object is point Node in cloth system.
- A kind of 13. processing unit of anomalous event, it is characterised in that including:Abnormality detecting unit, in the implementation procedure of business, detecting whether anomalous event occur;Abnormal memory cell, if there is the anomalous event for detecting, storage and the exception in target database The corresponding unexpected message of event;Unit is retried, for reading the unexpected message stored in the target database, and according to the unexpected message of reading to phase The business answered carries out retrying processing;Unit is deleted, for deleting the unexpected message of reading from the target database when retrying successfully.
- 14. a kind of electronic equipment, it is characterised in that including:Processor;AndMemory, is stored with computer-readable instruction on the memory, the computer-readable instruction is held by the processor The processing method of the anomalous event as any one of claim 1 to 12 is realized during row.
- 15. a kind of computer-readable recording medium, is stored thereon with computer program, the computer program is executed by processor The processing method of anomalous events of the Shi Shixian as any one of claim 1 to 12.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201711104702.4A CN107908494B (en) | 2017-11-10 | 2017-11-10 | Abnormal event processing method and device, electronic equipment and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201711104702.4A CN107908494B (en) | 2017-11-10 | 2017-11-10 | Abnormal event processing method and device, electronic equipment and storage medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN107908494A true CN107908494A (en) | 2018-04-13 |
| CN107908494B CN107908494B (en) | 2021-05-07 |
Family
ID=61844752
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201711104702.4A Active CN107908494B (en) | 2017-11-10 | 2017-11-10 | Abnormal event processing method and device, electronic equipment and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN107908494B (en) |
Cited By (32)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN108647141A (en) * | 2018-04-26 | 2018-10-12 | 腾讯科技(深圳)有限公司 | Automatic test approach, device, computer-readable medium and electronic equipment |
| CN108874587A (en) * | 2018-06-06 | 2018-11-23 | 亚信科技(中国)有限公司 | A kind of the final consistency support method and system of affairs |
| CN108959374A (en) * | 2018-05-24 | 2018-12-07 | 北京三快在线科技有限公司 | Date storage method, device and electronic equipment |
| CN109002363A (en) * | 2018-06-21 | 2018-12-14 | 郑州云海信息技术有限公司 | A kind of event-handling method, device, equipment and readable storage medium storing program for executing |
| CN109032819A (en) * | 2018-07-27 | 2018-12-18 | 郑州云海信息技术有限公司 | Synchronous method, device, equipment and the storage medium of message event between a kind of system |
| CN109309848A (en) * | 2018-09-29 | 2019-02-05 | 武汉斗鱼网络科技有限公司 | Barrage distribution method, device, equipment and storage medium based on retry mechanism |
| CN109324925A (en) * | 2018-08-29 | 2019-02-12 | 北京仁科互动网络技术有限公司 | The transaction methods and device of Distributed Architecture |
| CN109408581A (en) * | 2018-11-13 | 2019-03-01 | 杭州数梦工场科技有限公司 | A kind of method for interchanging data, device, equipment and storage medium |
| CN109614257A (en) * | 2018-10-23 | 2019-04-12 | 平安科技(深圳)有限公司 | Program exception processing method, device, computer storage medium and electronic device |
| CN109982170A (en) * | 2019-03-04 | 2019-07-05 | 烽火通信科技股份有限公司 | A kind of guard method and system based on link of optical network device |
| CN110413384A (en) * | 2019-06-25 | 2019-11-05 | 腾讯科技(深圳)有限公司 | Delay task processing method and device, storage medium, electronic equipment |
| CN110458582A (en) * | 2019-01-29 | 2019-11-15 | 深圳市智税链科技有限公司 | Business processing method, device, medium and electronic equipment based on block chain system |
| CN110471746A (en) * | 2019-08-22 | 2019-11-19 | 中国工商银行股份有限公司 | A kind of distributed transaction callback method, apparatus and system |
| CN110689394A (en) * | 2018-07-06 | 2020-01-14 | 北京嘀嘀无限科技发展有限公司 | Method and device for processing service supplementary notes |
| CN110782358A (en) * | 2019-10-23 | 2020-02-11 | 泰康保险集团股份有限公司 | Data processing method and device, storage medium and electronic equipment |
| CN110955532A (en) * | 2018-09-27 | 2020-04-03 | 北京国双科技有限公司 | Message processing method and device and computer equipment |
| CN111078442A (en) * | 2018-10-22 | 2020-04-28 | 千寻位置网络有限公司 | Fault-tolerant retry method and device and terminal |
| CN111090658A (en) * | 2019-11-08 | 2020-05-01 | 网联清算有限公司 | Abnormal transaction processing method, system and equipment |
| CN111274090A (en) * | 2020-01-16 | 2020-06-12 | 泰康保险集团股份有限公司 | Job processing method, job processing apparatus, job processing medium, and electronic device |
| CN111510349A (en) * | 2020-04-09 | 2020-08-07 | 上海东普信息科技有限公司 | Method, device, equipment and storage medium for service abnormity detection and alarm |
| CN111782431A (en) * | 2020-06-22 | 2020-10-16 | 深圳乐信软件技术有限公司 | An abnormal processing method, device, terminal and storage medium |
| CN112306819A (en) * | 2020-11-24 | 2021-02-02 | 微医云(杭州)控股有限公司 | Abnormal event playback method and device, electronic equipment and storage medium |
| CN112364079A (en) * | 2020-11-12 | 2021-02-12 | 北京思特奇信息技术股份有限公司 | Multi-service interaction exception handling method and system and electronic equipment |
| CN112732413A (en) * | 2019-10-28 | 2021-04-30 | 腾讯科技(深圳)有限公司 | Exception handling method and device, computer equipment and computer readable storage medium |
| CN112751743A (en) * | 2019-10-30 | 2021-05-04 | 北京车和家信息技术有限公司 | Message sending exception processing method, message sending device and electronic equipment |
| CN113645260A (en) * | 2020-04-27 | 2021-11-12 | 北京三快在线科技有限公司 | Service retry method, device, storage medium and electronic equipment |
| CN113783666A (en) * | 2020-11-27 | 2021-12-10 | 北京京东振世信息技术有限公司 | Method and device for processing service |
| CN113794744A (en) * | 2021-01-29 | 2021-12-14 | 北京京东拓先科技有限公司 | Message processing method and related equipment |
| CN113886497A (en) * | 2021-10-09 | 2022-01-04 | 北京房江湖科技有限公司 | Bidirectional real-time data monitoring method and device |
| CN114328013A (en) * | 2021-12-14 | 2022-04-12 | 上海万物新生环保科技集团有限公司 | A method and device for retrying when business processing is abnormal |
| CN114595074A (en) * | 2020-12-04 | 2022-06-07 | 中盈优创资讯科技有限公司 | A method and device for rollback of transaction failure in orchestration based on distributed scheduling |
| WO2022199229A1 (en) * | 2021-03-25 | 2022-09-29 | 北京金山云网络技术有限公司 | Suspended transaction inspection method and apparatus, electronic device and storage medium |
Citations (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101593135A (en) * | 2008-05-29 | 2009-12-02 | 国际商业机器公司 | In distributed integrated environment, focus on the apparatus and method of business process failure |
| CN101615269A (en) * | 2009-08-11 | 2009-12-30 | 用友软件股份有限公司 | Backing method in a kind of Workflow Management System and device |
| US8132043B2 (en) * | 2009-12-17 | 2012-03-06 | Symantec Corporation | Multistage system recovery framework |
| US8473783B2 (en) * | 2010-11-09 | 2013-06-25 | International Business Machines Corporation | Fault tolerance in distributed systems |
| CN105700937A (en) * | 2016-01-04 | 2016-06-22 | 北京百度网讯科技有限公司 | Multi-thread task processing method and device |
| CN105824842A (en) * | 2015-01-07 | 2016-08-03 | 阿里巴巴集团控股有限公司 | Distributed transaction processing method and system |
| CN106325978A (en) * | 2015-06-19 | 2017-01-11 | 阿里巴巴集团控股有限公司 | Distributed transaction processing method and apparatus |
| CN106502769A (en) * | 2016-09-30 | 2017-03-15 | 华为技术有限公司 | Distributed transaction processing method, apparatus and system |
-
2017
- 2017-11-10 CN CN201711104702.4A patent/CN107908494B/en active Active
Patent Citations (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101593135A (en) * | 2008-05-29 | 2009-12-02 | 国际商业机器公司 | In distributed integrated environment, focus on the apparatus and method of business process failure |
| CN101615269A (en) * | 2009-08-11 | 2009-12-30 | 用友软件股份有限公司 | Backing method in a kind of Workflow Management System and device |
| US8132043B2 (en) * | 2009-12-17 | 2012-03-06 | Symantec Corporation | Multistage system recovery framework |
| US8473783B2 (en) * | 2010-11-09 | 2013-06-25 | International Business Machines Corporation | Fault tolerance in distributed systems |
| CN105824842A (en) * | 2015-01-07 | 2016-08-03 | 阿里巴巴集团控股有限公司 | Distributed transaction processing method and system |
| CN106325978A (en) * | 2015-06-19 | 2017-01-11 | 阿里巴巴集团控股有限公司 | Distributed transaction processing method and apparatus |
| CN105700937A (en) * | 2016-01-04 | 2016-06-22 | 北京百度网讯科技有限公司 | Multi-thread task processing method and device |
| CN106502769A (en) * | 2016-09-30 | 2017-03-15 | 华为技术有限公司 | Distributed transaction processing method, apparatus and system |
Non-Patent Citations (1)
| Title |
|---|
| 钱素娟: "《容器管理事务(CMT)EJB中事务会话的设计》", 《中共郑州市委党校学报》 * |
Cited By (44)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN108647141A (en) * | 2018-04-26 | 2018-10-12 | 腾讯科技(深圳)有限公司 | Automatic test approach, device, computer-readable medium and electronic equipment |
| CN108959374A (en) * | 2018-05-24 | 2018-12-07 | 北京三快在线科技有限公司 | Date storage method, device and electronic equipment |
| CN108874587A (en) * | 2018-06-06 | 2018-11-23 | 亚信科技(中国)有限公司 | A kind of the final consistency support method and system of affairs |
| CN108874587B (en) * | 2018-06-06 | 2022-01-14 | 亚信科技(中国)有限公司 | Method and system for guaranteeing final consistency of affairs |
| CN109002363A (en) * | 2018-06-21 | 2018-12-14 | 郑州云海信息技术有限公司 | A kind of event-handling method, device, equipment and readable storage medium storing program for executing |
| CN110689394B (en) * | 2018-07-06 | 2022-04-12 | 北京嘀嘀无限科技发展有限公司 | Method and device for processing service supplementary notes |
| CN110689394A (en) * | 2018-07-06 | 2020-01-14 | 北京嘀嘀无限科技发展有限公司 | Method and device for processing service supplementary notes |
| CN109032819B (en) * | 2018-07-27 | 2021-10-29 | 郑州云海信息技术有限公司 | A method, device, device and storage medium for synchronizing message events between systems |
| CN109032819A (en) * | 2018-07-27 | 2018-12-18 | 郑州云海信息技术有限公司 | Synchronous method, device, equipment and the storage medium of message event between a kind of system |
| CN109324925A (en) * | 2018-08-29 | 2019-02-12 | 北京仁科互动网络技术有限公司 | The transaction methods and device of Distributed Architecture |
| CN110955532A (en) * | 2018-09-27 | 2020-04-03 | 北京国双科技有限公司 | Message processing method and device and computer equipment |
| CN109309848A (en) * | 2018-09-29 | 2019-02-05 | 武汉斗鱼网络科技有限公司 | Barrage distribution method, device, equipment and storage medium based on retry mechanism |
| CN109309848B (en) * | 2018-09-29 | 2021-02-02 | 武汉斗鱼网络科技有限公司 | Bullet screen distribution method, device, equipment and storage medium based on retry mechanism |
| CN111078442A (en) * | 2018-10-22 | 2020-04-28 | 千寻位置网络有限公司 | Fault-tolerant retry method and device and terminal |
| CN109614257A (en) * | 2018-10-23 | 2019-04-12 | 平安科技(深圳)有限公司 | Program exception processing method, device, computer storage medium and electronic device |
| CN109408581A (en) * | 2018-11-13 | 2019-03-01 | 杭州数梦工场科技有限公司 | A kind of method for interchanging data, device, equipment and storage medium |
| CN110458582A (en) * | 2019-01-29 | 2019-11-15 | 深圳市智税链科技有限公司 | Business processing method, device, medium and electronic equipment based on block chain system |
| CN110458582B (en) * | 2019-01-29 | 2023-12-12 | 深圳市智税链科技有限公司 | Business processing method, device, medium and electronic equipment based on block chain system |
| CN109982170B (en) * | 2019-03-04 | 2021-10-19 | 烽火通信科技股份有限公司 | Link-based protection method and system for optical network equipment |
| CN109982170A (en) * | 2019-03-04 | 2019-07-05 | 烽火通信科技股份有限公司 | A kind of guard method and system based on link of optical network device |
| CN110413384A (en) * | 2019-06-25 | 2019-11-05 | 腾讯科技(深圳)有限公司 | Delay task processing method and device, storage medium, electronic equipment |
| CN110413384B (en) * | 2019-06-25 | 2024-03-01 | 腾讯科技(深圳)有限公司 | Delay task processing method and device, storage medium and electronic equipment |
| CN110471746A (en) * | 2019-08-22 | 2019-11-19 | 中国工商银行股份有限公司 | A kind of distributed transaction callback method, apparatus and system |
| CN110782358A (en) * | 2019-10-23 | 2020-02-11 | 泰康保险集团股份有限公司 | Data processing method and device, storage medium and electronic equipment |
| CN112732413A (en) * | 2019-10-28 | 2021-04-30 | 腾讯科技(深圳)有限公司 | Exception handling method and device, computer equipment and computer readable storage medium |
| CN112732413B (en) * | 2019-10-28 | 2023-09-29 | 腾讯科技(深圳)有限公司 | Exception handling method, exception handling device, computer equipment and computer readable storage medium |
| CN112751743B (en) * | 2019-10-30 | 2023-04-28 | 北京车和家信息技术有限公司 | Message sending exception processing method, message sending device and electronic equipment |
| CN112751743A (en) * | 2019-10-30 | 2021-05-04 | 北京车和家信息技术有限公司 | Message sending exception processing method, message sending device and electronic equipment |
| CN111090658B (en) * | 2019-11-08 | 2021-03-02 | 网联清算有限公司 | Abnormal transaction processing method, system and equipment |
| CN111090658A (en) * | 2019-11-08 | 2020-05-01 | 网联清算有限公司 | Abnormal transaction processing method, system and equipment |
| CN111274090A (en) * | 2020-01-16 | 2020-06-12 | 泰康保险集团股份有限公司 | Job processing method, job processing apparatus, job processing medium, and electronic device |
| CN111510349A (en) * | 2020-04-09 | 2020-08-07 | 上海东普信息科技有限公司 | Method, device, equipment and storage medium for service abnormity detection and alarm |
| CN113645260A (en) * | 2020-04-27 | 2021-11-12 | 北京三快在线科技有限公司 | Service retry method, device, storage medium and electronic equipment |
| CN111782431B (en) * | 2020-06-22 | 2025-03-11 | 深圳乐信软件技术有限公司 | A method, device, terminal and storage medium for handling abnormalities |
| CN111782431A (en) * | 2020-06-22 | 2020-10-16 | 深圳乐信软件技术有限公司 | An abnormal processing method, device, terminal and storage medium |
| CN112364079A (en) * | 2020-11-12 | 2021-02-12 | 北京思特奇信息技术股份有限公司 | Multi-service interaction exception handling method and system and electronic equipment |
| CN112306819B (en) * | 2020-11-24 | 2022-07-12 | 微医云(杭州)控股有限公司 | Abnormal event playback method and device, electronic equipment and storage medium |
| CN112306819A (en) * | 2020-11-24 | 2021-02-02 | 微医云(杭州)控股有限公司 | Abnormal event playback method and device, electronic equipment and storage medium |
| CN113783666A (en) * | 2020-11-27 | 2021-12-10 | 北京京东振世信息技术有限公司 | Method and device for processing service |
| CN114595074A (en) * | 2020-12-04 | 2022-06-07 | 中盈优创资讯科技有限公司 | A method and device for rollback of transaction failure in orchestration based on distributed scheduling |
| CN113794744A (en) * | 2021-01-29 | 2021-12-14 | 北京京东拓先科技有限公司 | Message processing method and related equipment |
| WO2022199229A1 (en) * | 2021-03-25 | 2022-09-29 | 北京金山云网络技术有限公司 | Suspended transaction inspection method and apparatus, electronic device and storage medium |
| CN113886497A (en) * | 2021-10-09 | 2022-01-04 | 北京房江湖科技有限公司 | Bidirectional real-time data monitoring method and device |
| CN114328013A (en) * | 2021-12-14 | 2022-04-12 | 上海万物新生环保科技集团有限公司 | A method and device for retrying when business processing is abnormal |
Also Published As
| Publication number | Publication date |
|---|---|
| CN107908494B (en) | 2021-05-07 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN107908494A (en) | Abnormal event processing method, device, electronic equipment and storage medium | |
| CN114048217B (en) | Incremental data synchronization method and device, electronic device and storage medium | |
| CN109034993B (en) | Account checking method, account checking equipment, account checking system and computer readable storage medium | |
| CN110070359B (en) | Blockchain-based data verification system, method, computing device and storage medium | |
| CN110516971B (en) | Anomaly detection method, device, medium and computing equipment | |
| CN106815254B (en) | Data processing method and device | |
| CN110222039B (en) | Data storage and garbage data cleaning method, device, equipment and storage medium | |
| CN110188103A (en) | Data reconciliation method, device, equipment and storage medium | |
| CN105138691B (en) | Analyze the method and system of subscriber traffic | |
| WO2019024910A1 (en) | Storage resource recovery method, apparatus and system | |
| WO2012171349A1 (en) | Method, apparatus and system for implementing distributed auto-incrementing counting | |
| CN112416708B (en) | Asynchronous call link monitoring method and system | |
| CN110727563B (en) | Cloud service alarm method and device for preset customers | |
| CN113448754A (en) | Account checking method and device and electronic equipment | |
| CN114637611A (en) | Information processing method and device based on message queue and computer equipment | |
| CN114579416B (en) | Index determination method, device, server and medium | |
| CN113625971B (en) | Data storage method, device, equipment and computer storage medium | |
| CN110909062A (en) | Data processing method and device, electronic equipment and readable storage medium | |
| CN112383448A (en) | Monitoring data processing method and device | |
| CN117407205A (en) | Abnormality processing method, abnormality processing device, storage medium and electronic equipment | |
| CN114710394B (en) | Alarm synchronization method and device, electronic equipment and readable storage medium | |
| CN108121514B (en) | Meta-information updating method, apparatus, computing device and computer storage medium | |
| CN115098463A (en) | Business message processing method, device, equipment, medium and product | |
| CN102929657A (en) | Internal memory data sharing method, device and system | |
| CN115695587A (en) | Service data processing system, method, device and storage medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |