[go: up one dir, main page]

CN107908494A - 异常事件的处理方法、装置、电子设备及存储介质 - Google Patents

异常事件的处理方法、装置、电子设备及存储介质 Download PDF

Info

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
Application number
CN201711104702.4A
Other languages
English (en)
Other versions
CN107908494B (zh
Inventor
龙飞
刘伟奇
彭宪峰
李妍
张卉
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Taikang Insurance Group Co Ltd
Original Assignee
Taikang Insurance Group Co Ltd
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 Taikang Insurance Group Co Ltd filed Critical Taikang Insurance Group Co Ltd
Priority to CN201711104702.4A priority Critical patent/CN107908494B/zh
Publication of CN107908494A publication Critical patent/CN107908494A/zh
Application granted granted Critical
Publication of CN107908494B publication Critical patent/CN107908494B/zh
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Classifications

    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR 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; CALCULATING OR 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; CALCULATING OR 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; CALCULATING OR 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; CALCULATING OR 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; CALCULATING OR 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

异常事件的处理方法、装置、电子设备及存储介质
技术领域
本发明的实施例涉及数据处理技术领域，具体而言，涉及一种异常事件的处理方法、异常事件的处理装置、电子设备以及计算机可读存储介质。
背景技术
随着计算机技术的发展，业务系统变得越来越复杂，业务系统在长时间运行时，不能保证不出现任何问题例如网络闪断问题，一旦出现问题就会导致异常发生，更为严重的还会丢失数据。
在目前的技术方案中，当出现异常情况时，一般是通过重试的方式来解决问题，但是这种重试方式需要维护人员根据业务的不同手动触发重试操作。因此目前的技术方案不仅需要投入大量的人力物力，而且人工操作会耗费大量的时间，大大地降低了异常事件的处理效率。
需要说明的是，在上述背景技术部分公开的信息仅用于加强对本发明背景的理解，因此可以包括不构成对本领域普通技术人员已知的现有技术的信息。
发明内容
本发明实施例的目的在于提供一种异常事件的处理方法、异常事件的处理装置、电子设备以及计算机可读存储介质，进而至少在一定程度上解决目前异常事件处理效率低、需要花费大量人力物力成本的问题。
根据本发明实施例的第一方面，提供了一种异常事件的处理方法，包括：在业务的执行过程中，检测是否出现异常事件；若检测到出现所述异常事件，则在目标数据库中存储与所述异常事件对应的异常消息；读取所述目标数据库中存储的异常消息，并根据读取的异常消息对相应的业务进行重试处理；在重试成功时从所述目标数据库中删除读取的异常消息。
在本发明的一些实施例中，基于前述方案，在根据读取的异常消息对相应的业务进行重试处理之后，还包括：在重试失败时，累加读取的异常消息对应的重试次数；其中，读取所述目标数据库中存储的异常消息，包括：读取所述目标数据库中对应的重试次数小于预定次数的异常消息。
在本发明的一些实施例中，基于前述方案，读取所述目标数据库中存储的异常消息，包括：按照预定周期，定时读取所述目标数据库中存储的异常消息。
在本发明的一些实施例中，基于前述方案，在目标数据库中存储与所述异常事件对应的异常消息之前，还包括：对所述异常事件进行解析，以获取所述异常事件对应的异常消息。
在本发明的一些实施例中，基于前述方案，在业务的执行过程中，检测是否出现异常事件，包括：在同一事务中依次调用多个对象时，若对任一对象调用失败，则对已发生的调用过程进行回滚处理；若检测到对已发生的调用过程回滚失败，则确定检测到回滚业务出现异常事件。
在本发明的一些实施例中，基于前述方案，在目标数据库中存储与所述异常事件对应的异常消息，包括：在所述目标数据库中存储对已发生的调用过程回滚失败的消息。
在本发明的一些实施例中，基于前述方案，对已发生的调用过程进行回滚处理，包括：根据所述事务的标识，获取对应的回调路径；基于所述回调路径调用回调方法，并根据所述回调方法对已发生的调用过程进行回滚处理。
在本发明的一些实施例中，基于前述方案，在调用所述多个对象中的每个对象时，均记录所述事务的标识和对应的回调路径。
在本发明的一些实施例中，基于前述方案，在记录所述事务的标识和对应的回调路径之后，还包括：若检测到对所述已发生的调用过程回滚成功，则删除调用所述任一对象时记录的所述事务的标识和对应的回调路径。
在本发明的一些实施例中，基于前述方案，在记录所述事务的标识和对应的回调路径之后，还包括：若对所述多个对象均调用成功，则删除记录的与所述事务的标识相关的所有信息。
在本发明的一些实施例中，基于前述方案，还包括：若对任一对象调用成功，则根据调用顺序继续调用所述多个对象中的下一个对象，直至所述多个对象全部调用完成。
在本发明的一些实施例中，基于前述方案，所述多个目标对象为分布式系统中的节点。
根据本发明实施例的第二方面，提供了一种异常事件的处理装置，包括：异常检测单元，用于在业务的执行过程中，检测是否出现异常事件；异常存储单元，用于若检测到出现所述异常事件，则在目标数据库中存储与所述异常事件对应的异常消息；重试单元，用于读取所述目标数据库中存储的异常消息，并根据读取的异常消息对相应的业务进行重试处理；删除单元，用于在重试成功时从所述目标数据库中删除读取的异常消息。
根据本发明实施例的第三方面，提供了一种电子设备，包括：处理器；以及存储器，所述存储器上存储有计算机可读指令，所述计算机可读指令被所述处理器执行时实现如上述第一方面所述的异常事件的处理方法。
根据本发明实施例的第四方面，提供了一种计算机可读存储介质，其上存储有计算机程序，所述计算机程序被处理器执行时实现如上述第一方面所述的异常事件的处理方法。
在本发明的一些实施例所提供的技术方案中，在检测到异常事件时，在目标数据库中存储与异常事件对应的异常消息；根据读取的目标数据库中的异常消息对相应的业务进行重试处理，在重试成功时删除异常消息。一方面，当检测到异常事件时，在目标数据库中存储与异常事件对应的异常消息，能够保证异常消息不会丢失；另一方面，根据读取的目标数据库中的异常消息对相应的业务进行重试处理，在重试成功时删除异常消息，使得能够自动地对发生异常的业务进行重试，不需要人为干预，大大地节省了人力和物力的投入；再一方面，由于检测、存储异常消息的过程与读取异常消息进行处理的过程是异步进行的，因此能够提高异常事件的处理效率。
应当理解的是，以上的一般描述和后文的细节描述仅是示例性和解释性的，并不能限制本发明。
附图说明
此处的附图被并入说明书中并构成本说明书的一部分，示出了符合本发明的实施例，并与说明书一起用于解释本发明的原理。显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。在附图中：
图1示出了根据本发明的第一个实施例的异常事件的处理方法的流程示意图；
图2示出了根据本发明的示例性实施例的异常事件处理系统的示意框图；
图3示出了根据本发明的第二个实施例的异常事件的处理方法的流程示意图；
图4示出了根据本发明的示例性实施例的对多个对象进行调用的过程示意图；
图5示出了根据本发明的第三个示例性实施例的异常事件的处理方法的流程示意图；
图6示出了根据本发明的一示例性实施例的异常事件的处理装置的示意框图；
图7示出了适于用来实现本发明实施例的电子设备的计算机系统的结构示意图。
具体实施方式
现在将参考附图更全面地描述示例实施例。然而，示例实施例能够以多种形式实施，且不应被理解为限于在此阐述的实施例；相反，提供这些实施例使得本发明将全面和完整，并将示例实施例的构思全面地传达给本领域的技术人员。在图中相同的附图标记表示相同或类似的部分，因而将省略对它们的重复描述。
此外，所描述的特征、结构或特性可以以任何合适的方式结合在一个或更多实施例中。在下面的描述中，提供许多具体细节从而给出对本发明的实施例的充分理解。然而，本领域技术人员将意识到，可以实践本发明的技术方案而没有特定细节中的一个或更多，或者可以采用其它的方法、组元、装置、步骤等。在其它情况下，不详细示出或描述公知方法、装置、实现或者操作以避免模糊本发明的各方面。
附图中所示的方框图仅仅是功能实体，不一定必须与物理上独立的实体相对应。即，可以采用软件形式来实现这些功能实体，或在一个或多个硬件模块或集成电路中实现这些功能实体，或在不同网络和/或处理器装置和/或微控制器装置中实现这些功能实体。
附图中所示的流程图仅是示例性说明，不是必须包括所有的内容和操作/步骤，也不是必须按所描述的顺序执行。例如，有的操作/步骤还可以分解，而有的操作/步骤可以合并或部分合并，因此实际执行的顺序有可能根据实际情况改变。
图1示出了根据本发明的第一个实施例的异常事件的处理方法的流程示意图。
参照图1所示，该异常事件的处理方法可以包括以下步骤：
步骤S110，在业务的执行过程中，检测是否出现异常事件；
步骤S120，若检测到出现所述异常事件，则在目标数据库中存储与所述异常事件对应的异常消息；
步骤S130，读取所述目标数据库中存储的异常消息，并根据读取的异常消息对相应的业务进行重试处理；
步骤S140，在重试成功时从所述目标数据库中删除读取的异常消息。
在图1所示的异常事件的处理方法，一方面，当检测到异常事件时，在目标数据库中存储与异常事件对应的异常消息，能够保证异常消息不会丢失；另一方面，根据读取目标数据库中存储的异常消息对与异常消息对应的业务进行重试处理，在重试成功时删除异常消息，使得能够自动地对异常的业务进行重试，不需要人为干预，大大地节省了人力和物力的投入；再一方，由于检测、存储异常消息的过程与读取异常消息进行处理的过程是异步进行的，因此能够提高异常事件的处理效率。
下面，将结合附图对本示例实施例中的异常事件的处理方法进行详细的描述。
参照图1所示，在步骤S110中，在业务的执行过程中，检测是否出现异常事件。
可选地，图1所示的异常事件的处理方法可以是由图2所示的根据本发明的示例性实施例的异常事件处理系统来执行的。参照图2所示，该异常事件处理系统可以包括：异常事件发布器210、异常消息处理引擎220、定时任务触发器230、异常业务重试引擎240以及数据库250。
在本示例实施例中，在执行业务的过程中发生异常时，可以通过异常事件发布器210向异常消息处理引擎220发布异常事件，异常事件中可以包含异常事件发生时间、异常事件对应的消息体(如消息发送业务中的消息本身)、发生异常的错误消息、异常事件对应的目标队列(如消息发送业务中的发送的消息所在的队列)等内容。
需要说明的是，在本示例实施例中，异常事件可以为消息发送失败、业务回滚失败等，但是本发明的示例实施例中的异常事件不限于此，例如还可以为消息接收失败、消息读取失败、网络闪断等异常事件，这同样在本发明的保护范围内。
接下来，参照图1所示，在步骤S120中，若检测到出现所述异常事件，则在目标数据库中存储与所述异常事件对应的异常消息。
继续参照图2所示，在本示例实施例中，异常消息处理引擎220可以将异常事件的内容进行解析，将对应的异常消息存入数据库250中的异常消息重试表中。进一步地，还可以在异常消息重试表中记录数据库250中的存储异常消息对应的重试次数。在下表1中示出了本示例实施例中的异常消息重试表的结构。
表1
接下来，在步骤S130中，读取所述目标数据库中存储的异常消息，并根据读取的异常消息对相应的业务进行重试处理。
继续参照图2所示，在本示例实施例中，定时任务触发器230可以按照配置的定时规则定时触发异常业务重试引擎240从数据库250中查询异常消息重试表中记录的异常消息，以触发异常消息重试引擎240执行异常消息重试任务。
进一步地，在本示例实施例中，在异常消息重试引擎240接到定时任务触发器230的触发指令时，会抽取重试次数小于预定次数例如3次(具体数值在此处仅为示例)的异常消息，进而对与抽取出的异常消息对应的业务进行重试。在对与异常消息对应的业务重试成功后，将该条异常消息从异常消息重试表中删除；在重试失败时，将该异常消息的重试次数加1。如果一条异常消息对应的业务重试3次还没有成功，则与该条异常消息对应的业务可能出现了不可自动恢复的问题，需要人工介入进行处理。
此外，在本示例实施例中，对于消息发送业务，在业务重试时有可能会多次向接收端发送消息。因此为了避免接收端重复处理相同的消息，还可以在消息接收端创建一个消息表，以记录处理过的消息，避免消息接收端重复处理相同的消息，保证消息发送端与消息接收端的消息的幂等性。
继续参照图1所示，在步骤S140中，在重试成功时从所述目标数据库中删除读取的异常消息。
在本示例实施例中，为了避免在业务重试成功后再次读取异常消息进行重试，可以在重试成功时从目标数据库中的异常消息重试表中删除记录的异常消息。
上述实施例中的异常事件的处理方法能够自动地对异常的业务进行重试，不需要人为干预，大大地节省了人力和物力的投入，并且由于检测、存储异常消息的过程与读取异常消息进行处理的过程是异步进行的，因此能够提高异常事件的处理效率。
图3示出了根据本发明的第二个实施例的异常事件的处理方法的流程示意图。
参照图3所示，在步骤S310中，定时任务触发器触发定时任务。具体地，图2中所示的定时任务触发器230可以按照配置的定时规则定时触发异常消息重试引擎240来执行重试任务。需要说明的是，图3所示的各个步骤中，除了步骤S310，其它步骤的执行主体可以是图2中所示的异常消息重试引擎240。
在步骤S320中，读取异常消息重试表中存储的异常消息。异常消息重试表中的该异常消息可以包括对应业务的重试次数。
在步骤S330中，判断与异常消息对应的业务是否重试了预定次数，例如3次；若在步骤S330中判定已经重试了预定次数，则结束流程，若在步骤S330中判定未重试到预定次数，则执行步骤S340。
在步骤S340中，执行与异常消息对应的业务的重试操作。
进一步地，在步骤S350中，可以判断步骤S340中的重试操作是否成功，在步骤S350中判断重试成功时，执行步骤S360；在步骤S350中判定重试未成功时，执行步骤S370。
在步骤S360中，删除异常消息重试表中中存储的该条异常消息。
在步骤S370中将异常消息的重试次数加1。
由于该示例实施例中的异常事件的处理方法的具体细节与上述第一个实施例中的异常事件的处理方法的具体细节类似，在此将不再赘述。同样地，图3所示的异常事件的处理方法同样能够自动地对异常的业务进行重试，并且也能够提高异常事件的处理效率。
图4示出了根据本发明的示例性实施例的另一异常事件处理系统的示意图。
参照图4所示，在同一事务中，服务D需要依次调用对象A、对象B以及对象C。为了保证这种在一个事务中需要对多个对象进行调用时的数据一致性，在服务D对对象A、对象B、对象C中任一对象调用失败的情况下，需要对已发生的调用过程进行回滚，比如调用对象B失败时，需要对调用对象A和对象B的过程进行回滚。一旦回滚失败，则会在整个系统中产生消息不一致的问题，这样会造成系统中存在一些错误的数据。因此，可以通过中间表例如本地消息表存储异常消息，根据所存储的异常消息通过上述示例实施例中的异常事件的处理方法对回滚失败的业务进行重试，直到重试成功后将异常消息删除，从而保证整个系统的消息一致性。
需要说明的是，在本示例实施例中，多个对象可以为同一个系统中的多个业务逻辑(如业务对象)，也可以为分布式系统中的多个节点(如分布式系统中的服务器节点)，这两种情况都在本发明的保护范围内。以下对图4所示的处理过程进行详细说明：
参照图4所示，在本示例实施例中，服务D在同一事务中依次调用对象A、对象B以及对象C时，需要调用本地消息表记录相关的信息，以保证消息的一致性，可选地，本地消息表至少可以包含以下内容：(1)事务号；(2)回调服务地址(即回调路径，用于进行数据回滚)；(3)本次回滚是否异常。下表2示出了本发明的一个示例实施例中的本地消息表message_log的各个字段的信息：
字段名称 字段类型 备注
id varchar(64) 唯一标识
transaction_id int(4) 事务号
callback_url varchar 回调服务地址
status int(4) 回滚是否异常
表2
在图4所示的实施例中，当服务D在调用对象A之前，需要在本地消息表中记录事务号T和对对象A服务进行回滚的回调服务地址(即回调路径)。如果对对象A调用失败，则根据该回调服务地址进行数据回滚；如果服务D对对象A调用成功，则继续调用对象B。
当服务D在调用对象B之前，同样需要在本地消息表中记录事务号T、回调服务地址。如果对对象B的调用失败，则需要对已经发生的调用过程进行回滚。
回滚的具体方法是：根据事务号T从本地消息表中查询之前记录的回调服务地址，根据回调服务地址调用相应的回调方法对已发生的调用过程进行回滚。若检测到回滚失败，则保留记录的事务号T及回调服务地址，并在本地消息表中存储对已发生的调用过程回滚失败的消息，例如可以在表2中所示的本地消息表的字段名称为status(状态)的字段下存储与回滚异常对应的异常消息。
进一步地，为了处理回滚失败的这种异常事件，可以采用类似于图1中所示的异常事件的处理方法，具体地，可以定时地从本地消息表中读取所述异常消息，根据读取的异常消息获取与该异常消息对应的同一事务下的回调服务地址，根据所述回调服务地址重新对已发生的调用过程进行回滚。可选地，还可以在本地消息表中记录回滚失败的次数，以在回滚失败的次数达到预定次数时，由人工介入处理。
在对已发生的调用过程回滚成功时，删除在本地消息表中记录的事务号、回调服务地址以及回滚异常的异常消息。
如果服务D对对象B调用成功，则继续调用对象C。
服务D对对象C的调用的处理过程与对对象B的调用的处理过程基本类似。需要注意的是，由于对象C是最后一个调用的对象，因此在对对象C调用成功时，可以删除与事务T相关的所有信息即在本地消息表中记录的与事务T有关的所有信息。
图5具体示出了图4中所示的调用过程的处理流程。参照图5所示，在同一事务下，服务D需要依次调用对象A、对象B和对象C。以下对各个步骤进行详细阐述：
在步骤S502中，服务D在本地消息表中记录事务号T、消息流水号(消息流水号为可选，并非一定要有消息流水号)以及对象A的回调函数地址。
在步骤S504中，调用对象A。
在步骤S506中，判断服务D对对象A的调用是否成功，若在步骤S506中判定调用对象A成功，则执行步骤S510；若在步骤S506中判定调用对象A失败，则执行步骤S508。
在步骤S508中，进行数据回滚处理。在回滚处理时，可以根据事务号T获取在调用对象A之前记录的回调函数地址，基于该回调函数地址调用回调方法进行回滚处理。
在步骤S510中，在本地消息表中记录事务号T、消息流水号以及回调函数地址。
在步骤S512中，调用对象B。
接下来，在步骤S514中判断对对象B的调用是否成功；若在步骤S514中判定调用对象B成功，则执行步骤S524；若调用对象B失败，则执行步骤S516。
在步骤S516中，根据事物号T查询记录的回调服务地址，根据回调服务地址调用回调方法对已发生的调用过程进行回滚。
进一步地，在步骤S518中，判断回调是否成功；若在步骤S518中判定回调成功，则执行步骤S520；若判定回调失败，则可以在本地消息表中记录回调失败的异常消息，然后执行步骤S522。
在步骤S520中，删除在步骤S510中记录的事务号T、消息流水号以及回调地址。
在步骤S522中，等待定时任务重试。即定时任务定时读取本地消息表中记录的信息，并对已发生的调用过程重新进行回滚，直到回调成功后删除在本地消息表中记录的事务号T、消息流水号、回调地址以及回滚是否异常等记录。当然，也可以在重试预定次数依然回滚失败后，由人工介入处理。
在步骤S524中，在本地消息表中记录事物号T、消息流水号以及回调函数地址。
在步骤S526中，调用对象C。
接下来，在步骤S528中判断对对象C的调用是否成功；若在步骤S528中判定对对象C的调用成功，则执行步骤S530；若调用对象C失败，则执行步骤S516。
在步骤S530中，根据事务号T删除与该事务号T相关的所有记录。
图4和图5所示实施例的技术方案中，通过在调用任一对象失败时，对一发生的调用过程进行回滚，当回滚失败时，记录异常消息并进行重试，使得能够保证整个系统的数据的一致性。同时，自动重试机制的使用也使得无需人为干预，节省了人力和物力的投入，并且也能够提高回滚处理的效率。
此外，在本发明的实施例中，还提供了一种异常事件的处理装置。参照图6所示，该异常事件的处理装置600可以包括：异常检测单元610、异常存储单元620、重试单元630以及删除单元640。
其中，异常检测单元610用于在业务的执行过程中，检测是否出现异常事件；异常存储单元620用于若检测到出现所述异常事件，则在目标数据库中存储与所述异常事件对应的异常消息；重试单元630用于读取所述目标数据库中存储的异常消息，并根据读取的异常消息对相应的业务进行重试处理；删除单元640用于在重试成功时从所述目标数据库中删除读取的异常消息。
在本发明的一些实施例中，基于前述方案，异常事件的处理装置600还包括：第一记录单元，用于在重试失败时，累加读取的异常消息对应的重试次数。
其中，重试单元630配置为：读取所述目标数据库中对应的重试次数小于预定次数的异常消息。
在本发明的一些实施例中，基于前述方案，重试单元630被配置成：按照预定周期，定时读取所述目标数据库中存储的异常消息。
在本发明的一些实施例中，基于前述方案，异常事件的处理装置600还包括：解析单元，用于对所述异常事件进行解析，以获取所述异常事件对应的异常消息。
在本发明的一些实施例中，基于前述方案，异常检测单元610包括：回滚单元，用于在同一事务中依次调用多个对象时，若对任一对象调用失败，则对已发生的调用过程进行回滚处理；确定单元，用于若检测到对已发生的调用过程回滚失败，则确定检测到回滚业务出现异常事件。
在本发明的一些实施例中，基于前述方案，异常存储单元620被配置成：在所述目标数据库中存储对已发生的调用过程回滚失败的消息。
在本发明的一些实施例中，基于前述方案，回滚单元被配置成：根据所述事务的标识，获取对应的回调路径；基于所述回调路径调用回调方法，并根据所述回调方法对已发生的调用过程进行回滚处理。
在本发明的一些实施例中，基于前述方案，异常事件的处理装置600还包括：第二记录单元，用于在调用所述多个对象中的每个对象时，均记录所述事务的标识和对应的回调路径。
在本发明的一些实施例中，基于前述方案，第二记录单元配置为：在对所述已发生的调用过程回滚成功时，删除调用所述任一对象时记录的所述事务的标识和对应的回调路径。
在本发明的一些实施例中，基于前述方案，第二记录单元配置为：在对所述多个对象均调用成功时，删除记录的与所述事务的标识相关的所有信息。
在本发明的一些实施例中，基于前述方案，异常事件的处理装置600还包括：调用单元，用于在对任一对象调用成功时，根据调用顺序继续调用所述多个对象中的下一个对象，直至所述多个对象全部调用完成。
由于本发明的示例实施例的异常事件的处理装置600的各个功能模块与上述异常事件的处理方法的示例实施例的步骤对应，因此在此不再赘述。
在本发明的示例性实施例中，还提供了一种能够实现上述方法的电子设备。
下面参考图7，其示出了适于用来实现本发明实施例的电子设备的计算机系统700的结构示意图。图7示出的电子设备的计算机系统700仅是一个示例，不应对本发明实施例的功能和使用范围带来任何限制。
如图7所示，计算机系统700包括中央处理单元(CPU)701，其可以根据存储在只读存储器(ROM)702中的程序或者从存储部分708加载到随机访问存储器(RAM)703中的程序而执行各种适当的动作和处理。在RAM 703中，还存储有系统操作所需的各种程序和数据。CPU701、ROM 702以及RAM 703通过总线704彼此相连。输入/输出(I/O)接口705也连接至总线704。
以下部件连接至I/O接口705：包括键盘、鼠标等的输入部分706；包括诸如阴极射线管(CRT)、液晶显示器(LCD)等以及扬声器等的输出部分707；包括硬盘等的存储部分708；以及包括诸如LAN卡、调制解调器等的网络接口卡的通信部分709。通信部分709经由诸如因特网的网络执行通信处理。驱动器710也根据需要连接至I/O接口705。可拆卸介质711，诸如磁盘、光盘、磁光盘、半导体存储器等等，根据需要安装在驱动器710上，以便于从其上读出的计算机程序根据需要被安装入存储部分708。
特别地，根据本发明的实施例，上文参考流程图描述的过程可以被实现为计算机软件程序。例如，本发明的实施例包括一种计算机程序产品，其包括承载在计算机可读介质上的计算机程序，该计算机程序包含用于执行流程图所示的方法的程序代码。在这样的实施例中，该计算机程序可以通过通信部分709从网络上被下载和安装，和/或从可拆卸介质711被安装。在该计算机程序被中央处理单元(CPU)701执行时，执行本申请的系统中限定的上述功能。
需要说明的是，本发明所示的计算机可读介质可以是计算机可读信号介质或者计算机可读存储介质或者是上述两者的任意组合。计算机可读存储介质例如可以是——但不限于——电、磁、光、电磁、红外线、或半导体的系统、装置或器件，或者任意以上的组合。计算机可读存储介质的更具体的例子可以包括但不限于：具有一个或多个导线的电连接、便携式计算机磁盘、硬盘、随机访问存储器(RAM)、只读存储器(ROM)、可擦式可编程只读存储器(EPROM或闪存)、光纤、便携式紧凑磁盘只读存储器(CD-ROM)、光存储器件、磁存储器件、或者上述的任意合适的组合。在本发明中，计算机可读存储介质可以是任何包含或存储程序的有形介质，该程序可以被指令执行系统、装置或者器件使用或者与其结合使用。而在本发明中，计算机可读的信号介质可以包括在基带中或者作为载波一部分传播的数据信号，其中承载了计算机可读的程序代码。这种传播的数据信号可以采用多种形式，包括但不限于电磁信号、光信号或上述的任意合适的组合。计算机可读的信号介质还可以是计算机可读存储介质以外的任何计算机可读介质，该计算机可读介质可以发送、传播或者传输用于由指令执行系统、装置或者器件使用或者与其结合使用的程序。计算机可读介质上包含的程序代码可以用任何适当的介质传输，包括但不限于：无线、电线、光缆、RF等等，或者上述的任意合适的组合。
附图中的流程图和框图，图示了按照本发明各种实施例的系统、方法和计算机程序产品的可能实现的体系架构、功能和操作。在这点上，流程图或框图中的每个方框可以代表一个模块、程序段、或代码的一部分，上述模块、程序段、或代码的一部分包含一个或多个用于实现规定的逻辑功能的可执行指令。也应当注意，在有些作为替换的实现中，方框中所标注的功能也可以以不同于附图中所标注的顺序发生。例如，两个接连地表示的方框实际上可以基本并行地执行，它们有时也可以按相反的顺序执行，这依所涉及的功能而定。也要注意的是，框图或流程图中的每个方框、以及框图或流程图中的方框的组合，可以用执行规定的功能或操作的专用的基于硬件的系统来实现，或者可以用专用硬件与计算机指令的组合来实现。
描述于本发明实施例中所涉及到的单元可以通过软件的方式实现，也可以通过硬件的方式来实现，所描述的单元也可以设置在处理器中。其中，这些单元的名称在某种情况下并不构成对该单元本身的限定。
作为另一方面，本申请还提供了一种计算机可读介质，该计算机可读介质可以是上述实施例中描述的电子设备中所包含的；也可以是单独存在，而未装配入该电子设备中。上述计算机可读介质承载有一个或者多个程序，当上述一个或者多个程序被一个该电子设备执行时，使得该电子设备实现如上述实施例中所述的异常事件的处理方法。
例如，所述电子设备可以实现如图1中所示的：步骤S110，在业务的执行过程中，检测是否出现异常事件；步骤S120，若检测到出现所述异常事件，则在目标数据库中存储与所述异常事件对应的异常消息；步骤S130，读取所述目标数据库中存储的异常消息，并根据读取的异常消息对相应的业务进行重试处理；步骤S140，在重试成功时从所述目标数据库中删除读取的异常消息。
应当注意，尽管在上文详细描述中提及了用于动作执行的设备或装置的若干模块或者单元，但是这种划分并非强制性的。实际上，根据本发明的实施方式，上文描述的两个或更多模块或者单元的特征和功能可以在一个模块或者单元中具体化。反之，上文描述的一个模块或者单元的特征和功能可以进一步划分为由多个模块或者单元来具体化。
通过以上的实施方式的描述，本领域的技术人员易于理解，这里描述的示例实施方式可以通过软件实现，也可以通过软件结合必要的硬件的方式来实现。因此，根据本发明实施方式的技术方案可以以软件产品的形式体现出来，该软件产品可以存储在一个非易失性存储介质(可以是CD-ROM，U盘，移动硬盘等)中或网络上，包括若干指令以使得一台计算设备(可以是个人计算机、服务器、触控终端、或者网络设备等)执行根据本发明实施方式的方法。
本领域技术人员在考虑说明书及实践这里公开的发明后，将容易想到本发明的其它实施方案。本申请旨在涵盖本发明的任何变型、用途或者适应性变化，这些变型、用途或者适应性变化遵循本发明的一般性原理并包括本发明未公开的本技术领域中的公知常识或惯用技术手段。说明书和实施例仅被视为示例性的，本发明的真正范围和精神由下面的权利要求指出。
应当理解的是，本发明并不局限于上面已经描述并在附图中示出的精确结构，并且可以在不脱离其范围进行各种修改和改变。本发明的范围仅由所附的权利要求来限制。

Claims (15)

1.一种异常事件的处理方法，其特征在于，包括：
在业务的执行过程中，检测是否出现异常事件；
若检测到出现所述异常事件，则在目标数据库中存储与所述异常事件对应的异常消息；
读取所述目标数据库中存储的异常消息，并根据读取的异常消息对相应的业务进行重试处理；
在重试成功时，从所述目标数据库中删除读取的异常消息。
2.根据权利要求1所述的异常事件的处理方法，其特征在于，在根据读取的异常消息对相应的业务进行重试处理之后，还包括：在重试失败时，累加读取的异常消息对应的重试次数；
其中，读取所述目标数据库中存储的异常消息，包括：读取所述目标数据库中对应的重试次数小于预定次数的异常消息。
3.根据权利要求1所述的异常事件的处理方法，其特征在于，读取所述目标数据库中存储的异常消息，包括：
按照预定周期，定时读取所述目标数据库中存储的异常消息。
4.根据权利要求1所述的异常事件的处理方法，其特征在于，在目标数据库中存储与所述异常事件对应的异常消息之前，还包括：
对所述异常事件进行解析，以获取所述异常事件对应的异常消息。
5.根据权利要求1至4中任一项所述的异常事件的处理方法，其特征在于，在业务的执行过程中，检测是否出现异常事件，包括：
在同一事务中依次调用多个对象时，若对任一对象调用失败，则对已发生的调用过程进行回滚处理；
若检测到对已发生的调用过程回滚失败，则确定检测到回滚业务出现异常事件。
6.根据权利要求5所述的异常事件的处理方法，其特征在于，在目标数据库中存储与所述异常事件对应的异常消息，包括：
在所述目标数据库中存储对已发生的调用过程回滚失败的消息。
7.根据权利要求5所述的异常事件的处理方法，其特征在于，对已发生的调用过程进行回滚处理，包括：
根据所述事务的标识，获取对应的回调路径；
基于所述回调路径调用回调方法，并根据所述回调方法对已发生的调用过程进行回滚处理。
8.根据权利要求7所述的异常事件的处理方法，其特征在于，在调用所述多个对象中的每个对象时，均记录所述事务的标识和对应的回调路径。
9.根据权利要求8所述的异常事件的处理方法，其特征在于，在记录所述事务的标识和对应的回调路径之后，还包括：
若检测到对所述已发生的调用过程回滚成功，则删除调用所述任一对象时记录的所述事务的标识和对应的回调路径。
10.根据权利要求8所述的异常事件的处理方法，其特征在于，在记录所述事务的标识和对应的回调路径之后，还包括：
若对所述多个对象均调用成功，则删除记录的与所述事务的标识相关的所有信息。
11.根据权利要求5所述的异常事件的处理方法，其特征在于，还包括：
若对任一对象调用成功，则根据调用顺序继续调用所述多个对象中的下一个对象，直至所述多个对象全部调用完成。
12.根据权利要求5所述的异常事件的处理方法，其特征在于，所述多个目标对象为分布式系统中的节点。
13.一种异常事件的处理装置，其特征在于，包括：
异常检测单元，用于在业务的执行过程中，检测是否出现异常事件；
异常存储单元，用于若检测到出现所述异常事件，则在目标数据库中存储与所述异常事件对应的异常消息；
重试单元，用于读取所述目标数据库中存储的异常消息，并根据读取的异常消息对相应的业务进行重试处理；
删除单元，用于在重试成功时从所述目标数据库中删除读取的异常消息。
14.一种电子设备，其特征在于，包括：
处理器；以及
存储器，所述存储器上存储有计算机可读指令，所述计算机可读指令被所述处理器执行时实现如权利要求1至12中任一项所述的异常事件的处理方法。
15.一种计算机可读存储介质，其上存储有计算机程序，所述计算机程序被处理器执行时实现如权利要求1至12中任一项所述的异常事件的处理方法。
CN201711104702.4A 2017-11-10 2017-11-10 异常事件的处理方法、装置、电子设备及存储介质 Active CN107908494B (zh)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN201711104702.4A CN107908494B (zh) 2017-11-10 2017-11-10 异常事件的处理方法、装置、电子设备及存储介质

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201711104702.4A CN107908494B (zh) 2017-11-10 2017-11-10 异常事件的处理方法、装置、电子设备及存储介质

Publications (2)

Publication Number Publication Date
CN107908494A true CN107908494A (zh) 2018-04-13
CN107908494B CN107908494B (zh) 2021-05-07

Family

ID=61844752

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201711104702.4A Active CN107908494B (zh) 2017-11-10 2017-11-10 异常事件的处理方法、装置、电子设备及存储介质

Country Status (1)

Country Link
CN (1) CN107908494B (zh)

Cited By (32)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN108647141A (zh) * 2018-04-26 2018-10-12 腾讯科技（深圳）有限公司 自动测试方法、装置、计算机可读介质及电子设备
CN108874587A (zh) * 2018-06-06 2018-11-23 亚信科技（中国）有限公司 一种事务的最终一致性保障方法及系统
CN108959374A (zh) * 2018-05-24 2018-12-07 北京三快在线科技有限公司 数据存储方法、装置及电子设备
CN109002363A (zh) * 2018-06-21 2018-12-14 郑州云海信息技术有限公司 一种事件处理方法、装置、设备及可读存储介质
CN109032819A (zh) * 2018-07-27 2018-12-18 郑州云海信息技术有限公司 一种系统间消息事件的同步方法、装置、设备及存储介质
CN109309848A (zh) * 2018-09-29 2019-02-05 武汉斗鱼网络科技有限公司 基于重试机制的弹幕分发方法、装置、设备及存储介质
CN109324925A (zh) * 2018-08-29 2019-02-12 北京仁科互动网络技术有限公司 分布式框架的事务处理方法及装置
CN109408581A (zh) * 2018-11-13 2019-03-01 杭州数梦工场科技有限公司 一种数据交换方法、装置、设备及存储介质
CN109614257A (zh) * 2018-10-23 2019-04-12 平安科技（深圳）有限公司 程序异常的处理方法、装置、计算机存储介质及电子设备
CN109982170A (zh) * 2019-03-04 2019-07-05 烽火通信科技股份有限公司 一种光网络设备的基于link的保护方法及系统
CN110413384A (zh) * 2019-06-25 2019-11-05 腾讯科技（深圳）有限公司 延时任务处理方法及装置、存储介质、电子设备
CN110458582A (zh) * 2019-01-29 2019-11-15 深圳市智税链科技有限公司 基于区块链系统的业务处理方法、装置、介质及电子设备
CN110471746A (zh) * 2019-08-22 2019-11-19 中国工商银行股份有限公司 一种分布式事务回调方法、装置及系统
CN110689394A (zh) * 2018-07-06 2020-01-14 北京嘀嘀无限科技发展有限公司 业务补单的处理方法及装置
CN110782358A (zh) * 2019-10-23 2020-02-11 泰康保险集团股份有限公司 数据处理方法及装置、存储介质、电子设备
CN110955532A (zh) * 2018-09-27 2020-04-03 北京国双科技有限公司 消息处理方法、装置及计算机设备
CN111078442A (zh) * 2018-10-22 2020-04-28 千寻位置网络有限公司 容错重试方法及装置、终端
CN111090658A (zh) * 2019-11-08 2020-05-01 网联清算有限公司 异常事务处理方法、系统及其设备
CN111274090A (zh) * 2020-01-16 2020-06-12 泰康保险集团股份有限公司 作业处理方法、装置、介质及电子设备
CN111510349A (zh) * 2020-04-09 2020-08-07 上海东普信息科技有限公司 业务异常检测和告警方法、装置、设备及存储介质
CN111782431A (zh) * 2020-06-22 2020-10-16 深圳乐信软件技术有限公司 一种异常的处理方法、装置、终端及存储介质
CN112306819A (zh) * 2020-11-24 2021-02-02 微医云(杭州)控股有限公司 异常事件的回放方法、装置、电子设备以及存储介质
CN112364079A (zh) * 2020-11-12 2021-02-12 北京思特奇信息技术股份有限公司 一种多业务交互异常处理方法、系统和电子设备
CN112732413A (zh) * 2019-10-28 2021-04-30 腾讯科技（深圳）有限公司 异常处理方法、装置、计算机设备和计算机可读存储介质
CN112751743A (zh) * 2019-10-30 2021-05-04 北京车和家信息技术有限公司 消息发送异常的处理方法、消息发送装置和电子设备
CN113645260A (zh) * 2020-04-27 2021-11-12 北京三快在线科技有限公司 业务重试方法、装置、存储介质及电子设备
CN113783666A (zh) * 2020-11-27 2021-12-10 北京京东振世信息技术有限公司 一种处理业务的方法和装置
CN113794744A (zh) * 2021-01-29 2021-12-14 北京京东拓先科技有限公司 消息的处理方法及相关设备
CN113886497A (zh) * 2021-10-09 2022-01-04 北京房江湖科技有限公司 一种双向实时数据监控方法和装置
CN114328013A (zh) * 2021-12-14 2022-04-12 上海万物新生环保科技集团有限公司 一种用于业务处理异常时重试的方法与设备
CN114595074A (zh) * 2020-12-04 2022-06-07 中盈优创资讯科技有限公司 一种基于分布式调度的编排中事务失败回滚方法及装置
WO2022199229A1 (zh) * 2021-03-25 2022-09-29 北京金山云网络技术有限公司 悬挂事务巡检方法和装置、电子设备和存储介质

Citations (8)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101593135A (zh) * 2008-05-29 2009-12-02 国际商业机器公司 在分布式集成环境中集中处理业务流程故障的装置和方法
CN101615269A (zh) * 2009-08-11 2009-12-30 用友软件股份有限公司 一种工作流管理系统中的回退方法和装置
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 (zh) * 2016-01-04 2016-06-22 北京百度网讯科技有限公司 多线程任务处理方法和装置
CN105824842A (zh) * 2015-01-07 2016-08-03 阿里巴巴集团控股有限公司 分布式事务处理方法及其系统
CN106325978A (zh) * 2015-06-19 2017-01-11 阿里巴巴集团控股有限公司 分布式事务的处理方法及装置
CN106502769A (zh) * 2016-09-30 2017-03-15 华为技术有限公司 分布式事务处理方法、装置及系统

Patent Citations (8)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101593135A (zh) * 2008-05-29 2009-12-02 国际商业机器公司 在分布式集成环境中集中处理业务流程故障的装置和方法
CN101615269A (zh) * 2009-08-11 2009-12-30 用友软件股份有限公司 一种工作流管理系统中的回退方法和装置
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 (zh) * 2015-01-07 2016-08-03 阿里巴巴集团控股有限公司 分布式事务处理方法及其系统
CN106325978A (zh) * 2015-06-19 2017-01-11 阿里巴巴集团控股有限公司 分布式事务的处理方法及装置
CN105700937A (zh) * 2016-01-04 2016-06-22 北京百度网讯科技有限公司 多线程任务处理方法和装置
CN106502769A (zh) * 2016-09-30 2017-03-15 华为技术有限公司 分布式事务处理方法、装置及系统

Non-Patent Citations (1)

* Cited by examiner, † Cited by third party
Title
钱素娟: "《容器管理事务(CMT)EJB中事务会话的设计》", 《中共郑州市委党校学报》 *

Cited By (44)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN108647141A (zh) * 2018-04-26 2018-10-12 腾讯科技（深圳）有限公司 自动测试方法、装置、计算机可读介质及电子设备
CN108959374A (zh) * 2018-05-24 2018-12-07 北京三快在线科技有限公司 数据存储方法、装置及电子设备
CN108874587A (zh) * 2018-06-06 2018-11-23 亚信科技（中国）有限公司 一种事务的最终一致性保障方法及系统
CN108874587B (zh) * 2018-06-06 2022-01-14 亚信科技（中国）有限公司 一种事务的最终一致性保障方法及系统
CN109002363A (zh) * 2018-06-21 2018-12-14 郑州云海信息技术有限公司 一种事件处理方法、装置、设备及可读存储介质
CN110689394A (zh) * 2018-07-06 2020-01-14 北京嘀嘀无限科技发展有限公司 业务补单的处理方法及装置
CN110689394B (zh) * 2018-07-06 2022-04-12 北京嘀嘀无限科技发展有限公司 业务补单的处理方法及装置
CN109032819A (zh) * 2018-07-27 2018-12-18 郑州云海信息技术有限公司 一种系统间消息事件的同步方法、装置、设备及存储介质
CN109032819B (zh) * 2018-07-27 2021-10-29 郑州云海信息技术有限公司 一种系统间消息事件的同步方法、装置、设备及存储介质
CN109324925A (zh) * 2018-08-29 2019-02-12 北京仁科互动网络技术有限公司 分布式框架的事务处理方法及装置
CN110955532A (zh) * 2018-09-27 2020-04-03 北京国双科技有限公司 消息处理方法、装置及计算机设备
CN109309848B (zh) * 2018-09-29 2021-02-02 武汉斗鱼网络科技有限公司 基于重试机制的弹幕分发方法、装置、设备及存储介质
CN109309848A (zh) * 2018-09-29 2019-02-05 武汉斗鱼网络科技有限公司 基于重试机制的弹幕分发方法、装置、设备及存储介质
CN111078442A (zh) * 2018-10-22 2020-04-28 千寻位置网络有限公司 容错重试方法及装置、终端
CN109614257A (zh) * 2018-10-23 2019-04-12 平安科技（深圳）有限公司 程序异常的处理方法、装置、计算机存储介质及电子设备
CN109408581A (zh) * 2018-11-13 2019-03-01 杭州数梦工场科技有限公司 一种数据交换方法、装置、设备及存储介质
CN110458582B (zh) * 2019-01-29 2023-12-12 深圳市智税链科技有限公司 基于区块链系统的业务处理方法、装置、介质及电子设备
CN110458582A (zh) * 2019-01-29 2019-11-15 深圳市智税链科技有限公司 基于区块链系统的业务处理方法、装置、介质及电子设备
CN109982170B (zh) * 2019-03-04 2021-10-19 烽火通信科技股份有限公司 一种光网络设备的基于link的保护方法及系统
CN109982170A (zh) * 2019-03-04 2019-07-05 烽火通信科技股份有限公司 一种光网络设备的基于link的保护方法及系统
CN110413384A (zh) * 2019-06-25 2019-11-05 腾讯科技（深圳）有限公司 延时任务处理方法及装置、存储介质、电子设备
CN110413384B (zh) * 2019-06-25 2024-03-01 腾讯科技（深圳）有限公司 延时任务处理方法及装置、存储介质、电子设备
CN110471746A (zh) * 2019-08-22 2019-11-19 中国工商银行股份有限公司 一种分布式事务回调方法、装置及系统
CN110782358A (zh) * 2019-10-23 2020-02-11 泰康保险集团股份有限公司 数据处理方法及装置、存储介质、电子设备
CN112732413A (zh) * 2019-10-28 2021-04-30 腾讯科技（深圳）有限公司 异常处理方法、装置、计算机设备和计算机可读存储介质
CN112732413B (zh) * 2019-10-28 2023-09-29 腾讯科技（深圳）有限公司 异常处理方法、装置、计算机设备和计算机可读存储介质
CN112751743A (zh) * 2019-10-30 2021-05-04 北京车和家信息技术有限公司 消息发送异常的处理方法、消息发送装置和电子设备
CN112751743B (zh) * 2019-10-30 2023-04-28 北京车和家信息技术有限公司 消息发送异常的处理方法、消息发送装置和电子设备
CN111090658B (zh) * 2019-11-08 2021-03-02 网联清算有限公司 异常事务处理方法、系统及其设备
CN111090658A (zh) * 2019-11-08 2020-05-01 网联清算有限公司 异常事务处理方法、系统及其设备
CN111274090A (zh) * 2020-01-16 2020-06-12 泰康保险集团股份有限公司 作业处理方法、装置、介质及电子设备
CN111510349A (zh) * 2020-04-09 2020-08-07 上海东普信息科技有限公司 业务异常检测和告警方法、装置、设备及存储介质
CN113645260A (zh) * 2020-04-27 2021-11-12 北京三快在线科技有限公司 业务重试方法、装置、存储介质及电子设备
CN111782431A (zh) * 2020-06-22 2020-10-16 深圳乐信软件技术有限公司 一种异常的处理方法、装置、终端及存储介质
CN111782431B (zh) * 2020-06-22 2025-03-11 深圳乐信软件技术有限公司 一种异常的处理方法、装置、终端及存储介质
CN112364079A (zh) * 2020-11-12 2021-02-12 北京思特奇信息技术股份有限公司 一种多业务交互异常处理方法、系统和电子设备
CN112306819B (zh) * 2020-11-24 2022-07-12 微医云(杭州)控股有限公司 异常事件的回放方法、装置、电子设备以及存储介质
CN112306819A (zh) * 2020-11-24 2021-02-02 微医云(杭州)控股有限公司 异常事件的回放方法、装置、电子设备以及存储介质
CN113783666A (zh) * 2020-11-27 2021-12-10 北京京东振世信息技术有限公司 一种处理业务的方法和装置
CN114595074A (zh) * 2020-12-04 2022-06-07 中盈优创资讯科技有限公司 一种基于分布式调度的编排中事务失败回滚方法及装置
CN113794744A (zh) * 2021-01-29 2021-12-14 北京京东拓先科技有限公司 消息的处理方法及相关设备
WO2022199229A1 (zh) * 2021-03-25 2022-09-29 北京金山云网络技术有限公司 悬挂事务巡检方法和装置、电子设备和存储介质
CN113886497A (zh) * 2021-10-09 2022-01-04 北京房江湖科技有限公司 一种双向实时数据监控方法和装置
CN114328013A (zh) * 2021-12-14 2022-04-12 上海万物新生环保科技集团有限公司 一种用于业务处理异常时重试的方法与设备

Also Published As

Publication number Publication date
CN107908494B (zh) 2021-05-07

Similar Documents

Publication Publication Date Title
CN107908494A (zh) 异常事件的处理方法、装置、电子设备及存储介质
CN114048217B (zh) 增量数据的同步方法和装置、电子设备和存储介质
CN109034993B (zh) 对账方法、设备、系统及计算机可读存储介质
CN110516971B (zh) 异常检测的方法、装置、介质和计算设备
CN110222039B (zh) 数据存储及垃圾数据清理方法、装置、设备及存储介质
CN111752793A (zh) 系统异常的监控方法、装置、计算机设备及存储介质
CN105138691B (zh) 分析用户业务量的方法和系统
CN110188103A (zh) 数据对账方法、装置、设备和存储介质
WO2019024910A1 (zh) 存储资源回收方法、装置及系统
WO2012171349A1 (zh) 一种分布式自增计数的实现方法、装置及系统
CN112416708B (zh) 异步调用链路监控方法及系统
CN111177165A (zh) 数据一致性检测的方法、装置及设备
CN110727563B (zh) 预设客户的云服务报警方法及装置
CN114637611A (zh) 基于消息队列的信息处理方法、装置及计算机设备
CN113448754A (zh) 对账方法、装置和电子设备
CN114579416B (zh) 一种指标确定方法、装置、服务器和介质
CN116048846A (zh) 数据传输方法、装置、设备和存储介质
CN113625971B (zh) 数据存储方法、装置、设备以及计算机存储介质
CN112383448A (zh) 监控数据处理方法及装置
CN117407205A (zh) 异常处理方法、装置、存储介质及电子设备
CN114710394B (zh) 告警同步方法、装置、电子设备及可读存储介质
CN108121514B (zh) 元信息更新方法、装置、计算设备及计算机存储介质
CN110909062A (zh) 数据处理方法、装置、电子设备及可读存储介质
CN114217932B (zh) 第三方对接异常处理方法及系统
CN102929657A (zh) 一种内存数据共享方法、装置和系统

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