数据处理方法、装置、设备及存储介质

摘要

本申请涉及数据处理领域，具体公开了一种数据处理方法、装置、设备及存储介质，应用于交易系统，所述方法包括：基于用户发起的交易请求生成业务请求和待消费消息，所述待消费消息包括延迟消费时间；将所述业务请求发送至对应的业务系统，使所述业务系统响应于所述业务请求产生响应结果，所述响应结果包括交易状态；将所述待消费消息写入至消息队列；当经过所述延迟消费时间后，消费所述待消费消息以对所述交易状态进行查询，并将所述交易状态同步至与所述业务系统对应的交易系统中。以简化保证数据一致性的操作过程。

权利要求

1.一种数据处理方法，其特征在于，应用于交易系统，所述方法包括：基于用户发起的交易请求生成业务请求和待消费消息，所述待消费消息包括延迟消费时间；

将所述业务请求发送至对应的业务系统，使所述业务系统响应于所述业务请求产生响应结果，所述响应结果包括交易状态；

将所述待消费消息写入至消息队列；

当经过所述延迟消费时间后，消费所述待消费消息以对所述交易状态进行查询，并将所述交易状态同步至与所述业务系统对应的交易系统中。

2.根据权利要求1所述的数据处理方法，其特征在于，所述方法还包括：生成与所述待消费消息对应的识别码，并将所述识别码写入至消息队列；

所述当经过所述延迟消费时间后，消费所述待消费消息以对所述交易状态进行查询，包括：当经过所述延迟消费时间后，对所述待消费消息对应的识别码进行验证；

若所述识别码验证成功，则消费所述待消费消息以对所述交易状态进行查询。

3.根据权利要求1所述的数据处理方法，其特征在于，所述对所述交易状态进行查询，包括：若查询到所述交易状态是完成状态，则所述待消费消息被正常消费；

若查询到所述交易状态不是完成状态，则修改所述待消费消息的延迟消费时间，得到修改后的待消费消息，并将所述修改后的待消费消息放回所述消息队列。

4.根据权利要求3所述的数据处理方法，其特征在于，所述修改所述待消费消息的延迟消费时间，包括：获取所述待消费消息的放回次数，并根据所述放回次数修改按照预设规则所述待消费消息的延迟消费时间。

5.根据权利要求4所述的数据处理方法，其特征在于，所述预设规则为所述放回次数与修改的所述待消费消息的延迟消费时间成正比例关系。

6.根据权利要求3所述的数据处理方法，其特征在于，所述修改所述待消费消息的延迟消费时间，包括：获取所述业务系统的业务暂停时段，以根据所述业务暂停时段调整所述待消费消息的延迟消费时间。

7.根据权利要求1所述的数据处理方法，其特征在于，在所述对所述交易状态进行查询之后，还包括：若查询到与所述业务请求对应的至少两个所述业务系统的交易状态相冲突，则生成冲正消费消息；

将所述冲正消费消息写入消息队列，以消费所述冲正消费消息对所述交易状态为完成的业务系统进行冲正。

8.一种数据处理装置，其特征在于，应用于交易系统，所述装置包括：消息生成模块，用于基于用户发起的交易请求生成业务请求和待消费消息，所述待消费消息包括延迟消费时间；

请求发送模块，用于将所述业务请求发送至对应的业务系统，使所述业务系统响应于所述业务请求产生响应结果，所述响应结果包括交易状态；

消息写入模块，用于将所述待消费消息写入至消息队列；

状态查询模块，用于当经过所述延迟消费时间后，消费所述待消费消息以对所述交易状态进行查询，并将所述交易状态同步至与所述业务系统对应的交易系统中。

9.一种计算机设备，其特征在于，所述计算机设备包括存储器和处理器；

所述存储器用于存储计算机程序；

所述处理器，用于执行所述计算机程序并在执行所述计算机程序时实现如权利要求1至7中任一项所述的数据处理方法。

10.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质存储有计算机程序，所述计算机程序被处理器执行时使所述处理器实现如权利要求1至7中任一项所述的数据处理方法。

说明书

数据处理方法、装置、设备及存储介质

技术领域

[0001] 本申请涉及数据处理领域，尤其涉及一种数据处理方法、装置、设备及存储介质。

背景技术

[0002] 在组合式交易系统中，由于一个交易服务往往需要调用多个系统，因此在进行交易服务的数据处理时，需要保证多个系统中的数据一致性，以保证交易服务的正确性。但是现有的处理组合式交易系统中数据一致性的方案是通过定时器的方式，定时读取调用方的交易状态，但当调用的系统数量较多时，定时器的定时任务较多，不方便维护，数据处理较为繁琐，并且轮询的时间间隔无法动态配置，灵活性不足。

[0003] 因此，如何简化保证数据一致性的操作过程成为亟待解决的问题。

发明内容

[0004] 本申请提供了一种数据处理方法、装置、设备及存储介质，以简化保证数据一致性的操作过程。

[0005] 第一方面，本申请提供了一种数据处理方法，应用于交易系统，所述方法包括：

[0006] 基于用户发起的交易请求生成业务请求和待消费消息，所述待消费消息包括延迟消费时间；

[0007] 将所述业务请求发送至对应的业务系统，使所述业务系统响应于所述业务请求产生响应结果，所述响应结果包括交易状态；

[0008] 将所述待消费消息写入至消息队列；

[0009] 当经过所述延迟消费时间后，消费所述待消费消息以对所述交易状态进行查询，并将所述交易状态同步至与所述业务系统对应的交易系统中。

[0010] 第二方面，本申请还提供了一种数据处理装置，应用于交易系统，所述装置包括：

[0011] 消息生成模块，用于基于用户发起的交易请求生成业务请求和待消费消息，所述待消费消息包括延迟消费时间；

[0012] 请求发送模块，用于将所述业务请求发送至对应的业务系统，使所述业务系统响应于所述业务请求产生响应结果，所述响应结果包括交易状态；

[0013] 消息写入模块，用于将所述待消费消息写入至消息队列；

[0014] 状态查询模块，用于当经过所述延迟消费时间后，消费所述待消费消息以对所述交易状态进行查询，并将所述交易状态同步至与所述业务系统对应的交易系统中。

[0015] 第三方面，本申请还提供了一种计算机设备，所述计算机设备包括存储器和处理器；所述存储器用于存储计算机程序；所述处理器，用于执行所述计算机程序并在执行所述计算机程序时实现如上述的数据处理方法。

[0016] 第四方面，本申请还提供了一种计算机可读存储介质，所述计算机可读存储介质存储有计算机程序，所述计算机程序被处理器执行时使所述处理器实现如上述的数据处理方法。

[0017] 本申请公开了一种数据处理方法、装置、设备及存储介质，在生成业务请求的同时生成待消费消息，并设置待消费消息的延迟消费时间，将业务请求发送给业务系统，业务系统即会响应于所述业务请求产生响应结果，所述响应结果包括交易状态；将待消费消息写入消息队列并记录写入时间，当写入时间等于延迟消费时间时，消费待消费消息从而对交易状态进行查询，并将查询到的交易状态同步至与所述业务系统对应的交易系统中。通过加入消息队列，使得交易系统和业务系统解耦，交易系统只负责与业务系统进行业务交易，执行业务交易的流程，通过消息队列对业务系统的交易状态进行查询，来保证交易系统和业务系统对于交易状态的数据一致性。简化在保证交易系统和业务系统对于交易状态的数据一致性的操作过程。同时，待消费消息的延迟消费时间可以根据实际情况进行调整，使用灵活，且可以避免频繁查询导致的系统性能损耗。

附图说明

[0018] 为了更清楚地说明本申请实施例技术方案，下面将对实施例描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图是本申请的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。

[0019] 图1是本申请实施例提供的数据处理方法的步骤示意流程图；

[0020] 图2是本申请实施例提供的对所述交易状态进行查询的步骤示意流程图；

[0021] 图3为本申请实施例提供的一种数据处理装置的示意性框图；

[0022] 图4为本申请一实施例提供的一种计算机设备的结构示意性框图。

具体实施方式

[0023] 下面将结合本申请实施例中的附图，对本申请实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例是本申请一部分实施例，而不是全部的实施例。基于本申请中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本申请保护的范围。

[0024] 附图中所示的流程图仅是示例说明，不是必须包括所有的内容和操作/步骤，也不是必须按所描述的顺序执行。例如，有的操作/步骤还可以分解、组合或部分合并，因此实际执行的顺序有可能根据实际情况改变。

[0025] 应当理解，在此本申请说明书中所使用的术语仅仅是出于描述特定实施例的目的而并不意在限制本申请。如在本申请说明书和所附权利要求书中所使用的那样，除非上下文清楚地指明其它情况，否则单数形式的“一”、“一个”及“该”意在包括复数形式。

[0026] 还应当理解，在本申请说明书和所附权利要求书中使用的术语“和/或”是指相关联列出的项中的一个或多个的任何组合以及所有可能组合，并且包括这些组合。

[0027] 本申请的实施例提供了一种数据处理方法、装置、计算机设备及存储介质。数据处理方法可应用于交易系统，用于对业务系统的业务处理状态进行查询，从而保证交易系统和业务系统之间的数据一致性，进而简化数据一致性的操作过程。

[0028] 下面结合附图，对本申请的一些实施方式作详细说明。在不冲突的情况下，下述的实施例及实施例中的特征可以相互组合。

[0029] 请参阅图1，图1是本申请实施例提供的一种数据处理方法的示意流程图。该数据处理方法通过增加消息队列，交易系统在产生业务请求的同时也产生待消费消息，并将产生的业务请求发送至业务系统，将产生的待消费消息发送至消息队列，从而使消息队列在对待消费消息进行消费后对业务系统的业务处理状态进行查询，从而保证交易系统和业务系统之间的数据一致性。

[0030] 为了便于描述，本申请中以交易系统为银行系统为例进行详细说明。前端的交易系统可能连接有多个后端的业务系统，每个业务系统分别处理不同的业务，以为用户提供不同的交易需求。例如，业务系统可以包括存款业务系统、贷款业务系统、理财业务系统等等。

[0031] 如图1所示，该数据处理方法，具体包括：步骤S101至步骤S104。

[0032] S101、基于用户发起的交易请求生成业务请求和待消费消息。

[0033] 具体地，当用户向交易系统发起交易请求时，交易系统会根据用户发起的交易请求生成对应的业务请求和待消费消息。其中，所述待消费消息包括延迟消费时间，延迟消费时间可以由开发人员自由设置。例如可以为1分钟。

[0034] 例如，若用户发起一笔贷款申请，则交易系统分别生成存款业务请求和贷款业务请求，以便于存款业务系统和贷款业务系统根据对应的业务请求进行交易处理。同时，交易系统生成一条待消费消息，并且设置该待消费消息的延迟消费时间为一分钟。

[0035] S102、将所述业务请求发送至对应的业务系统，使所述业务系统响应于所述业务请求产生响应结果。

[0036] 具体地，前端的交易系统将生成的业务请求发送至对应的业务系统，使对应的所述业务系统对所述业务请求进行响应，也即使业务系统根据该业务请求进行响应的业务交易，并生成响应结果。其中，响应结果包括交易状态。在具体实施过程中，交易状态具体可以包括交易成功、交易失败、交易处理中和交易异常等至少四种状态。

[0037] S103、将所述待消费消息写入至消息队列。

[0038] 具体地，交易系统将生成的待消费消息写入至消息队列，以便于消息队列将待消费消息进行消费。

[0039] 需要说明的是，步骤S102和步骤S103之间可以不存在先后关系，也即，步骤S102和步骤S103可以是同时发生的。在交易系统与业务系统发送业务请求的同时，将待消费消息写入消息队列。

[0040] 交易系统在接收到用户的一笔交易请求后，即会生成业务请求和待消费消息，业务请求发送至业务系统进行正常的业务流程，而对于交易的查询则通过向消息队列中写入待消费消息，由消息队列对待消费消息进行释放消费来进行查询。通过加入消息队列，使交易系统与业务系统解耦，交易系统可以专注于与业务系统的正常业务交易，交易的查询则映射为消息队列中的消息，提高了在保证数据一致性时的便捷度。

[0041] 并且，在新增业务系统时，交易系统即可将交易的查询消息写入消息队列即可，提高保证数据一致性时的操作统一程度。

[0042] S104、当经过所述延迟消费时间后，消费所述待消费消息以对所述交易状态进行查询，并将所述交易状态同步至与所述业务系统对应的交易系统中。

[0043] 具体地，由于待消费消息中包括了延迟消费时间，因此，消息队列在经过延迟消费时间后，即可将该待消费消息进行释放消费，从而对业务系统的交易状态进行查询。

[0044] 在具体实施过程中，消息队列可以在接收到待消费消息后，根据该待消费消息的延迟消费时间开始倒计时，当倒计时结束后，释放该待消费消息，以对业务系统的交易状态进行查询。

[0045] 待消费消息被消息队列释放消费后，即可查询到对应的业务系统的交易状态，然后将查询到的交易状态同步至与所述业务系统对应的交易系统中，从而保证交易系统与业务系统对于一笔业务交易的交易状态的数据一致性。

[0046] 在一些实施例中，所述数据处理方法还包括：生成与所述待消费消息对应的识别码，并将所述识别码写入至消息队列；所述当经过所述延迟消费时间后，消费所述待消费消息以对所述交易状态进行查询，包括：当经过所述延迟消费时间后，对所述待消费消息对应的识别码进行验证；若所述识别码验证成功，则消费所述待消费消息以对所述交易状态进行查询。

[0047] 具体地，应用系统在基于用户发起的交易请求生成业务请求和待消费消息时，同时还生成与待消费消息对应的识别码，该识别码为用于识别所述待消费消息的唯一识别码。然后将待消费消息和待消费消息对应的识别码共同写入至消息队列，在对待消费消息进行消费时，根据该识别码对待消费消息进行验证，若验证成功，则说明该待消费消息为第一次消费，则对待消费消息进行消费，以查询业务系统的交易状态。若验证失败，则说明该待消费消息已经被消费过，则不进行消费，以避免消息的重复消费。

[0048] 在一些实施例中，对所述交易状态进行查询，请参阅图2，具体包括步骤S1041和步骤S1042：

[0049] S1041、若查询到所述交易状态是完成状态，则所述待消费消息被正常消费。

[0050] 其中，交易状态包括交易完成、系统异常、网络异常、交易失败等多种状态，交易完成、交易失败等有确定交易结果的状态为完成状态。

[0051] 具体地，消息队列将待消费消息释放至交易系统后，交易系统即可根据该待消费消息对业务系统的交易状态进行查询，若查询到业务系统的交易状态为交易成功或交易失败，则说明此时该笔交易已经被正常处理，并且产生了确定的交易结果，因此该待消费消息被正常消费。

[0052] S1042、若查询到所述交易状态不是完成状态，则修改所述待消费消息的延迟消费时间，得到修改后的待消费消息，并将所述修改后的待消费消息放回所述消息队列。

[0053] 具体地，若查询到业务系统的交易状态不是完成状态，则说明此时该笔交易还未完成，因此，可以对所述待消费消息的延迟消费时间进行修改，并将修改延迟消费时间后的待消费消息重新放回消息队列中，待经过修改后的延迟消费时间后对所述待消费消息再次进行消费。

[0054] 消费队列在经过修改后的延迟消费时间后将所述待消费消息释放至交易系统，由交易系统再次进行消费，若查询到业务系统的交易状态仍不是完成状态，则继续修改该待消费消息的延迟消费时间，并放回所述消息队列中，直至查询到业务系统的交易状态为完成状态后，该待消费消息被正常消费。

[0055] 例如，当待消费消息的延迟消费时间为一分钟时，在交易系统将该待消费消息发送至消息队列后，经过一分钟后，交易系统消费到该待消费消息，查询业务系统的交易状态，当查询到交易系统的交易状态不是完成状态时，则交易系统修改该待消费消息的延迟消费时间为一小时，并将修改后的待消费消息重新放回消息队列中，在经过一小时后重新消费该待消费消息，直至查询到业务系统的交易状态为完成状态后，该待消费消息才被正常消费。

[0056] 在一些实施例中，所述修改所述待消费消息的延迟消费时间，包括：获取所述业务系统的业务暂停时段，以根据所述业务暂停时段调整所述待消费消息的延迟消费时间。

[0057] 具体地，以银行系统为例，业务暂停时段具体是指日切时段，当业务系统存在日切时段时，获取业务系统的日切时段，从而根据该日切时段调整待消费消息的延迟消费时间，使该待消费消息在日切时段外进行消费。

[0058] 例如，以业务系统为理财系统为例，在下午三点至四点之间进行日切，则可以调整待消费消息的延迟消费时间，使待消费消息在下午四点之后再进行消费。

[0059] 根据业务系统实际处理交易的时间来修改待消费消息的延迟消费时间，使得消息队列在释放待消费消息进行查询的时间间隔更为灵活，避免频繁无用查询导致的系统性能损耗。

[0060] 在一些实施例中，所述修改所述待消费消息的延迟消费时间，包括：获取所述待消费消息的放回次数，并根据所述放回次数修改按照预设规则所述待消费消息的延迟消费时间。

[0061] 具体地，当待消费消息未被正常消费时，交易系统获取待消费消息的放回次数，并且根据所述待消费消息的放回次数和预设规则修改待消费消息的延迟消费时间。

[0062] 在具体实施过程中，所述预设规则可以是所述放回次数与修改的所述待消费消息的延迟消费时间呈正比例关系。在具体实施过程中，可以随着待消费消息的放回次数的增加，逐渐增加待消费消息的延迟消费时间。例如，若待消费消息被放入消息队列时，设置的延迟消费时间为一分钟，则在待消费消息被第一次放回消息队列时，设置的延迟消费时间可以为30分钟。

[0063] 将待消费消息的放回次数与待消费消息的延迟消费时间相关联，可以有效的避免频繁查询导致的系统性能损耗。

[0064] 在一些实施例中，在所述对所述交易状态进行查询之后，还包括：若查询到与所述业务请求对应的至少两个所述业务系统的交易状态相冲突，则生成冲正消费消息；将所述冲正消费消息写入消息队列，以消费所述冲正消费消息对所述交易状态为完成的业务系统进行冲正。

[0065] 具体地，以银行系统为例，关联的业务系统是指存在账务调整的业务系统，交易状态相冲突是指一个业务系统查询到的交易状态为成功，另一业务系统查询到的交易状态为失败。

[0066] 如果查询到与业务请求对应的至少两个业务系统的交易状态相冲突，则会生成冲正消费消息，并将生成的所述冲正消费消息写入消息队列，由消息队列对所述冲正消费消息进行释放消费，从而对交易状态为完成的业务系统进行冲正，控制交易状态为完成的业务系统取消该笔交易。

[0067] 例如，当用户发起一笔贷款申请时，交易系统会分别向存款业务系统和贷款业务系统分别发送业务请求，若查询到存款业务系统的交易状态为成功，也即成功记账，而查询到贷款业务系统的交易状态为失败时，交易系统会生成一个冲正消费消息，并将冲正消费消息写入消息队列，由消息队列控制所述冲正消费消息进行释放和消费，以控制存款业务系统取消所述业务交易，确保账务交易的平账。

[0068] 上述实施例提供的数据处理方法，在生成业务请求的同时生成待消费消息，并设置待消费消息的延迟消费时间，将业务请求发送给业务系统，业务系统即会响应于所述业务请求产生响应结果，所述响应结果包括交易状态；将待消费消息写入消息队列，当经过所述延迟消费时间后，消费待消费消息从而对交易状态进行查询，并将查询到的交易状态同步至与所述业务系统对应的交易系统中。通过加入消息队列，使得交易系统和业务系统解耦，交易系统只负责与业务系统进行业务交易，执行业务交易的流程，通过消息队列对业务系统的交易状态进行查询，来保证交易系统和业务系统对于交易状态的数据一致性。简化在保证交易系统和业务系统对于交易状态的数据一致性的操作过程。同时，待消费消息的延迟消费时间可以根据实际情况进行调整，使用灵活，且可以避免频繁查询导致的系统性能损耗。

[0069] 请参阅图3，图3是本申请的实施例还提供一种数据处理装置的示意性框图，该数据处理装置用于执行前述的数据处理方法。其中，该数据处理装置可以配置于服务器或终端中。

[0070] 其中，服务器可以为独立的服务器，也可以为服务器集群。该终端可以是手机、平板电脑、笔记本电脑、台式电脑、个人数字助理和穿戴式设备等电子设备。

[0071] 如图3所示，数据处理装置200包括：消息生成模块201、请求发送模块202、消息写入模块203和状态查询模块204。

[0072] 消息生成模块201，用于基于用户发起的交易请求生成业务请求和待消费消息，所述待消费消息包括延迟消费时间。

[0073] 请求发送模块202，用于将所述业务请求发送至对应的业务系统，使所述业务系统响应于所述业务请求产生响应结果，所述响应结果包括交易状态。

[0074] 消息写入模块203，用于将所述待消费消息写入至消息队列.

[0075] 状态查询模块204，用于当经过所述延迟消费时间后，消费所述待消费消息以对所述交易状态进行查询，并将所述交易状态同步至与所述业务系统对应的交易系统中。

[0076] 其中，状态查询模块204包括消息消费子模块2041和时间修改子模块2042。

[0077] 具体地，消息消费子模块2041，用于若查询到所述交易状态是完成状态，则所述待消费消息被正常消费。

[0078] 时间修改子模块2042，用于若查询到所述交易状态不是完成状态，则修改所述待消费消息的延迟消费时间，得到修改后的待消费消息，并将所述修改后的待消费消息放回所述消息队列。

[0079] 需要说明的是，所属领域的技术人员可以清楚地了解到，为了描述的方便和简洁，上述描述的数据处理装置和各模块的具体工作过程，可以参考前述数据处理方法实施例中的对应过程，在此不再赘述。

[0080] 上述的数据处理装置可以实现为一种计算机程序的形式，该计算机程序可以在如图4所示的计算机设备上运行。

[0081] 请参阅图4，图4是本申请实施例提供的一种计算机设备的结构示意性框图。该计算机设备可以是服务器或终端。

[0082] 参阅图4，该计算机设备包括通过系统总线连接的处理器、存储器和网络接口，其中，存储器可以包括非易失性存储介质和内存储器。

[0083] 非易失性存储介质可存储操作系统和计算机程序。该计算机程序包括程序指令，该程序指令被执行时，可使得处理器执行任意一种数据处理方法。

[0084] 处理器用于提供计算和控制能力，支撑整个计算机设备的运行。

[0085] 内存储器为非易失性存储介质中的计算机程序的运行提供环境，该计算机程序被处理器执行时，可使得处理器执行任意一种数据处理方法。

[0086] 该网络接口用于进行网络通信，如发送分配的任务等。本领域技术人员可以理解，图4中示出的结构，仅仅是与本申请方案相关的部分结构的框图，并不构成对本申请方案所应用于其上的计算机设备的限定，具体的计算机设备可以包括比图中所示更多或更少的部件，或者组合某些部件，或者具有不同的部件布置。

[0087] 应当理解的是，处理器可以是中央处理单元(Central Processing Unit，CPU)，该处理器还可以是其他通用处理器、数字信号处理器(Digital Signal Processor，DSP)、专用集成电路(Application Specific Integrated Circuit，ASIC)、现场可编程门阵列(Field-Programmable Gate Array，FPGA)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件等。其中，通用处理器可以是微处理器或者该处理器也可以是任何常规的处理器等。

[0088] 其中，在一个实施例中，所述处理器用于运行存储在存储器中的计算机程序，以实现如下步骤：

[0089] 基于用户发起的交易请求生成业务请求和待消费消息，所述待消费消息包括延迟消费时间；

[0090] 将所述业务请求发送至对应的业务系统，使所述业务系统响应于所述业务请求产生响应结果，所述响应结果包括交易状态；

[0091] 将所述待消费消息写入至消息队列；

[0092] 当经过所述延迟消费时间后，消费所述待消费消息以对所述交易状态进行查询，并将所述交易状态同步至与所述业务系统对应的交易系统中。

[0093] 在一个实施例中，所述处理器还用于实现：

[0094] 生成与所述待消费消息对应的识别码，并将所述识别码写入至消息队列；

[0095] 所述当经过所述延迟消费时间后，消费所述待消费消息以对所述交易状态进行查询，包括：

[0096] 当经过所述延迟消费时间后，对所述待消费消息对应的识别码进行验证；

[0097] 若所述识别码验证成功，则消费所述待消费消息以对所述交易状态进行查询。

[0098] 在一个实施例中，所述处理器在实现所述对所述交易状态进行查询时，用于实现：

[0099] 若查询到所述交易状态是完成状态，则所述待消费消息被正常消费；

[0100] 若查询到所述交易状态不是完成状态，则修改所述待消费消息的延迟消费时间，得到修改后的待消费消息，并将所述修改后的待消费消息放回所述消息队列。

[0101] 在一个实施例中，所述处理器在实现所述修改所述待消费消息的延迟消费时间时，用于实现：

[0102] 获取所述待消费消息的放回次数，并根据所述放回次数修改按照预设规则所述待消费消息的延迟消费时间。

[0103] 在一个实施例中，所述预设规则为所述放回次数与修改的所述待消费消息的延迟消费时间成正比例关系。

[0104] 在一个实施例中，所述处理器在实现所述修改所述待消费消息的延迟消费时间时，用于实现：

[0105] 获取所述业务系统的业务暂停时段，以根据所述业务暂停时段调整所述待消费消息的延迟消费时间。

[0106] 在一个实施例中，所述处理器在实现所述对所述交易状态进行查询之后，还用于实现：

[0107] 若查询到与所述业务请求对应的至少两个所述业务系统的交易状态相冲突，则生成冲正消费消息；

[0108] 将所述冲正消费消息写入消息队列，以消费所述冲正消费消息对所述交易状态为完成的业务系统进行冲正。

[0109] 本申请的实施例中还提供一种计算机可读存储介质，所述计算机可读存储介质存储有计算机程序，所述计算机程序中包括程序指令，所述处理器执行所述程序指令，实现本申请实施例提供的任一项数据处理方法。

[0110] 其中，所述计算机可读存储介质可以是前述实施例所述的计算机设备的内部存储单元，例如所述计算机设备的硬盘或内存。所述计算机可读存储介质也可以是所述计算机设备的外部存储设备，例如所述计算机设备上配备的插接式硬盘，智能存储卡(Smart Media Card，SMC)，安全数字(Secure Digital，SD)卡，闪存卡(Flash Card)等。

[0111] 以上所述，仅为本申请的具体实施方式，但本申请的保护范围并不局限于此，任何熟悉本技术领域的技术人员在本申请揭露的技术范围内，可轻易想到各种等效的修改或替换，这些修改或替换都应涵盖在本申请的保护范围之内。因此，本申请的保护范围应以权利要求的保护范围为准。