本发明涉及信息处理,尤其涉及一种异步任务触发的去重方法、装置、电子设备及存储介质。
背景技术:
1、随着互联网行业的快速发展,大型的网络服务系统常常会面临高并发请求,因此通常对消息进行异步处理,可以增加技术上的时间。然而,有时候会偶尔发生重复调用的情况,例如任务多次下发,导致大数据在高并发下出现不一致的情况。
技术实现思路
1、本发明提供一种异步任务触发的去重方法、装置、电子设备及存储介质,用以保证大数据在高并发下的一致性。
2、第一方面,本发明提供一种异步任务触发的去重方法,包括:
3、响应用户针对目标任务的下发请求消息,对所述下发请求消息进行校验;所述下发请求消息携带所述目标任务和唯一消息标识;
4、在所述下发请求消息校验通过后,将所述下发请求消息传递到消息队列;
5、实时监听所述消息队列;所述监听与所述校验为异步操作;
6、在监听到所述下发请求消息时,对所述下发请求消息进行消费;在消费的过程中获取运行资源并将所述目标任务下发到客户端,以使所述客户端将所述目标任务转发至所述运行资源进行处理。
7、根据本发明提供的一种异步任务触发的去重方法,所述响应用户针对目标任务的下发请求消息,对所述下发请求消息进行校验,包括:
8、检测所述下发请求消息是否传输到应用接口服务;
9、在所述下发请求消息传输到所述应用接口服务的情况下,响应所述下发请求消息,调用所述应用接口服务对所述下发请求消息进行校验。
10、根据本发明提供的一种异步任务触发的去重方法,所述调用所述应用接口服务对所述下发请求消息进行校验,包括:
11、调用所述应用接口服务,对所述下发请求消息中的请求头、时间、所述目标任务的内容以及所述目标任务是否已处理的状态进行校验;其中,所述目标任务的内容可以包括用户操作和唯一用户标识。
12、根据本发明提供的一种异步任务触发的去重方法,所述在监听到所述下发请求消息时,对所述下发请求消息进行消费,包括:
13、在监听到所述下发请求消息、且未对所述下发请求消息进行消费时,确定所述下发请求消息的状态为可见状态。
14、根据本发明提供的一种异步任务触发的去重方法,所述在监听到所述下发请求消息时,对所述下发请求消息进行消费,包括:
15、在监听到所述下发请求消息、且正在对所述下发请求消息进行消费时,确定所述下发请求消息的状态为不可见状态。
16、根据本发明提供的一种异步任务触发的去重方法,所述在监听到所述下发请求消息时,对所述下发请求消息进行消费,包括:
17、在监听到所述下发请求消息、且对所述下发请求消息消费完成时,从所述消息队列中删除所述下发请求消息。
18、根据本发明提供的一种异步任务触发的去重方法,所述运行资源包括空闲的服务器资源。
19、第二方面,本发明还提供一种异步任务触发的去重装置,包括:
20、校验模块,用于响应用户针对目标任务的下发请求消息,对所述下发请求消息进行校验;所述下发请求消息携带所述目标任务和唯一消息标识;
21、传递模块,用于在所述下发请求消息校验通过后,将所述下发请求消息传递到消息队列;
22、监听模块,用于实时监听所述消息队列;所述监听与所述校验为异步操作;
23、消费模块,用于在监听到所述下发请求消息时,对所述下发请求消息进行消费;在消费的过程中获取运行资源并将所述目标任务下发到客户端,以使所述客户端将所述目标任务转发至所述运行资源进行处理。
24、第三方面,本发明还提供一种电子设备,包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,所述处理器执行所述程序时实现如上述第一方面任一种所述的异步任务触发的去重方法。
25、第四方面,本发明还提供一种非暂态计算机可读存储介质,其上存储有计算机程序,该计算机程序被处理器执行时实现如上述第一方面任一种所述的异步任务触发的去重方法。
26、第五方面,本发明还提供一种计算机程序产品,包括计算机程序,所述计算机程序被处理器执行时实现如上述第一方面任一种所述的异步任务触发的去重方法。
27、本发明提供的异步任务触发的去重方法、装置、电子设备及存储介质,首先,响应用户针对目标任务的下发请求消息,对下发请求消息进行校验;下发请求消息携带目标任务和唯一消息标识;可以保证只触发一次目标任务的下发操作;而后,在下发请求消息校验通过后,将下发请求消息传递到消息队列;接着,实时监听消息队列;监听与校验为异步操作;最后,在监听到下发请求消息时,对下发请求消息进行消费;在消费的过程中获取运行资源并将目标任务下发到客户端,以使客户端将目标任务转发至运行资源进行处理。本发明可以保证大数据在高并发下的一致性。
28、本发明的其他特征和优点将在随后的说明书中阐述,并且,部分地从说明书中变得显而易见,或者通过实施本发明而了解。本发明的目的和其他优点在说明书以及附图中所特别指出的结构来实现和获得。
29、为使本发明的上述目的、特征和优点能更明显易懂,下文特举较佳实施例,并配合所附附图,作详细说明如下。
1.一种异步任务触发的去重方法,其特征在于,包括:
2.根据权利要求1所述的异步任务触发的去重方法,其特征在于,所述响应用户针对目标任务的下发请求消息,对所述下发请求消息进行校验,包括:
3.根据权利要求2所述的异步任务触发的去重方法,其特征在于,所述调用所述应用接口服务对所述下发请求消息进行校验,包括:
4.根据权利要求1所述的异步任务触发的去重方法,其特征在于,所述在监听到所述下发请求消息时,对所述下发请求消息进行消费,包括:
5.根据权利要求1所述的异步任务触发的去重方法,其特征在于,所述在监听到所述下发请求消息时,对所述下发请求消息进行消费,包括:
6.根据权利要求1所述的异步任务触发的去重方法,其特征在于,所述在监听到所述下发请求消息时,对所述下发请求消息进行消费,包括:
7.根据权利要求1所述的异步任务触发的去重方法,其特征在于,所述运行资源包括空闲的服务器资源。
8.一种异步任务触发的去重装置,其特征在于,包括:
9.一种电子设备,包括存储器、处理器及存储在所述存储器上并可在所述处理器上运行的计算机程序,其特征在于,所述处理器执行所述程序时实现如权利要求1至7任一项所述的异步任务触发的去重方法。
10.一种非暂态计算机可读存储介质,其上存储有计算机程序,其特征在于,所述计算机程序被处理器执行时实现如权利要求1至7任一项所述的异步任务触发的去重方法。