任务处理方法、装置、计算机设备及存储介质与流程

allin2025-02-18  64


本发明实施例涉及任务处理,尤其涉及一种任务处理方法、装置、计算机设备及存储介质。


背景技术:

1、随着车辆网业务的发展,每个微服务系统会产生大量的业务数据,一些订单、支付等业务的流转都会使用延迟或定时任务来进行触达。实际在业务中的操作一般会使用到一些传统的框架来进行数据库表进行扫描或者直接使用一些常见的延迟队列。但是这样的设计存在以下问题:

2、一、任务扫描的服务会和业务代码耦合在一起,不具有通用性和复用性。

3、二、任务扫描的表和业务的数据库表重合,这样会影响正常业务,出现性能问题。

4、三、灵活性差传统定时任务执行时间通常是固定的,无法根据实际情况进行动态调整。

5、四、对于一些执行时间较晚的任务直接放入队列,会导致消息队列存储一些长期不需要消费的数据,导致队列阻塞。

6、因此,如何优化延迟执行的任务处理的过程,以提高延迟任务处理的效率成为现在亟待解决的问题。


技术实现思路

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、监听模块,用于通过任务服务对每个业务系统产生的延迟执行的业务数据进行监听;

30、存储模块,用于当监听到的所述业务数据不是当前时间周期内执行的数据时,将所述业务数据对应的任务存储至所述业务系统对应的任务调度表;

31、获取模块,用于从所述任务调度表中获取当前时间周期需要执行的目标任务;

32、发送模块,用于将所述目标任务通过消息总线发送至所述目标任务对应的目标业务系统,以使所述目标业务系统对所述目标任务进行处理。

33、第三方面,本发明实施例提供了一种计算机设备,包括:处理器和存储器,所述处理器用于执行所述存储器中存储的任务处理程序,以实现上述第一方面中任一项所述的任务处理方法。

34、第四方面,本发明实施例提供了一种存储介质,所述存储介质存储有一个或者多个程序,所述一个或者多个程序可被一个或者多个处理器执行,以实现上述第一方面中任一项所述的任务处理方法。

35、本发明实施例提供的任务处理方案,通过任务服务对每个业务系统产生的延迟执行的业务数据进行监听;当监听到的所述业务数据不是当前时间周期内执行的数据时,将所述业务数据对应的任务存储至所述业务系统对应的任务调度表;从所述任务调度表中获取当前时间周期需要执行的目标任务;将所述目标任务通过消息总线发送至所述目标任务对应的目标业务系统,以使所述目标业务系统对所述目标任务进行处理。由此,可以实现将延迟任务的数据存储至任务调度表,任务服务从任务调度表中按照执行时间获取当前周期要处理的任务,提高了针对延迟执行的任务调度处理的合理性,从而提高任务处理效率,避免出现性能问题。



技术特征:

1.一种任务处理方法,其特征在于,包括:

2.根据权利要求1所述的方法,其特征在于,所述通过任务服务对每个业务系统产生的延迟执行的业务数据进行监听,包括:

3.根据权利要求1所述的方法,其特征在于,所述当监听到的所述业务数据不是当前时间周期内执行的数据时,将所述业务数据对应的任务存储至所述业务系统对应的任务调度表,包括:

4.根据权利要求1所述的方法,其特征在于,所述从所述任务调度表中获取当前时间周期需要执行的目标任务,包括:

5.根据权利要求1所述的方法,其特征在于,所述将所述目标任务通过消息总线发送至所述目标任务对应的目标业务系统,包括:

6.根据权利要求5所述的方法,其特征在于,所述方法还包括:

7.根据权利要求1所述的方法,其特征在于,所述方法还包括:

8.一种任务处理装置,其特征在于,包括:

9.一种计算机设备,其特征在于,包括:处理器和存储器,所述处理器用于执行所述存储器中存储的任务处理程序,以实现权利要求1~7中任一项所述的任务处理方法。

10.一种存储介质,其特征在于,所述存储介质存储有一个或者多个程序,所述一个或者多个程序可被一个或者多个处理器执行,以实现权利要求1~7中任一项所述的任务处理方法。


技术总结
本发明实施例涉及一种任务处理方法、装置、计算机设备及存储介质,所述方法包括:通过任务服务对每个业务系统产生的延迟执行的业务数据进行监听;当监听到的业务数据不是当前时间周期内执行的数据时,将业务数据对应的任务存储至业务系统对应的任务调度表;从任务调度表中获取当前时间周期需要执行的目标任务;将目标任务通过消息总线发送至目标任务对应的目标业务系统,以使目标业务系统对目标任务进行处理。由此,可以实现将延迟任务的数据存储至任务调度表,任务服务从任务调度表中按照执行时间获取当前周期要处理的任务,提高了针对延迟执行的任务调度处理的合理性,从而提高任务处理效率,避免出现性能问题。

技术研发人员:唐平,陈仕强
受保护的技术使用者:重庆赛力斯凤凰智创科技有限公司
技术研发日:
技术公布日:2024/10/31
转载请注明原文地址: https://www.8miu.com/read-18722.html

最新回复(0)