一种任务处理方法和装置与流程
未命名
07-29
阅读:106
评论:0
1.本公开的实施例涉及数据处理技术领域,具体地,涉及适用于一种任务处理方法和装置。
背景技术:
2.定时任务管理系统能够对多个定时任务进行有效管理。定时任务为按照一定的时间周期运行的短任务,其使用场景为在某个固定时间点,为所有运行中的节点做时间同步。
3.相关技术中,定时任务管理系统可通过分布式定时任务框架搭建得出,分布式定时任务框架可包括:xxl-job/elastic-job/lts/schedulerx/saturn等,在需要进行定时任务配置时,可基于quartz进行拓展,自研分布式定时任务框架,实现定时任务管理。
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.在数据库中配置列表字段信息,所述列表字段信息包括:cron表达式、任务标识、任务描述、任务状态以及任务类型;
29.基于所述列表字段信息,建立所述目标任务列表,所述目标任务列表中存储的每一任务工程包括所述cron表达式、所述任务标识、所述任务描述、所述任务状态以及所述任务类型。
30.在一种可选的方式中,所述建立任务配置框架,包括:
31.调用框架导入组件;
32.基于所述框架导入组件,导入springboot依赖,得到所述任务配置框架。
33.在一种可选的方式中,还包括:
34.配置异常捕获机制,所述异常捕获机制用于记录配置过程中的异常信息;
35.在基于所述异常捕获机制获取到所述异常信息时,告警并显示所述异常信息。
36.第二方面,提供了一种任务处理装置,包括:
37.第一建立模块,用于建立任务配置框架,所述任务配置框架用于进行任务工程的管理配置;
38.第二建立模块,用于建立目标任务列表,所述目标任务列表用于存放进行所述管理配置后的多个所述任务工程;
39.第一配置模块,用于基于所述任务配置框架配置所述目标任务列表;
40.第二配置模块,用于配置任务管理接口,并基于所述任务管理接口访问所述目标任务列表,以对所述目标任务列表中的所述任务工程进行处理。
41.在一种可选的方式中,第一配置模块,包括:建立单元和配置单元;
42.建立单元,用于基于所述任务配置框架建立任务线程池,所述任务线程池作为定时任务调度线程池,用于配置线程池大小、线程名称、任务销毁机制以及任务等待时长;
43.配置单元,用于读取所述目标任务列表,基于所述任务工程的任务状态,在所述任务线程池中配置所述目标任务列表中的多个所述任务工程。
44.在一种可选的方式中,配置单元,具体用于:
45.在所述任务工程的任务状态为开启时,调用第一任务处理接口;
46.基于所述第一任务处理接口,将所述任务工程添加至所述任务线程池中。
47.在一种可选的方式中,还包括:读取模块和处理模块;
48.读取模块,用于读取所述目标任务列表;
49.处理模块,用于基于所述任务工程的任务状态,处理所述任务工程。
50.在一种可选的方式中,读取模块,具体用于:
51.在所述任务工程的任务状态为关闭时,调用第二任务处理接口;
52.基于所述第二任务处理接口,关闭所述任务工程在所述目标任务列表中的刷新周期。
53.在一种可选的方式中,还包括:获取模块、第三建立模块和第三配置模块;
54.获取模块,用于获取业务处理场景;
55.第三建立模块,用于基于所述业务处理场景,建立所述目标任务列表对应的任务存储介质,所述任务存储介质包括:关系型数据库或非关系型数据库;
56.第三配置模块,用于基于第三任务处理接口,在所述任务存储介质中配置所述目标任务列表中多个所述任务工程的业务执行逻辑,以基于所述业务执行逻辑运行相应的所述任务工程。
57.在一种可选的方式中,第二建立模块,具体用于:
58.在数据库中配置列表字段信息,所述列表字段信息包括:cron表达式、任务标识、任务描述、任务状态以及任务类型;
59.基于所述列表字段信息,建立所述目标任务列表,所述目标任务列表中存储的每一任务工程包括所述cron表达式、所述任务标识、所述任务描述、所述任务状态以及所述任务类型。
60.在一种可选的方式中,第一建立模块,具体用于:
61.调用框架导入组件;
62.基于所述框架导入组件,导入springboot依赖,得到所述任务配置框架。
63.在一种可选的方式中,还包括:第四配置模块;
64.第四配置模块,用于配置异常捕获机制,所述异常捕获机制用于记录配置过程中的异常信息;
65.处理模块,还用于在基于所述异常捕获机制获取到所述异常信息时,告警并显示所述异常信息。
66.第三方面,提供了一种计算机设备,包括存储器和处理器,存储器中存储有计算机程序,处理器执行计算机程序时实现如以上任意一个实施例中任务处理方法的步骤。
67.第四方面,提供了一种计算机可读存储介质,计算机可读存储介质上存储有计算机程序,计算机程序被处理器执行时实现如以上任意一个实施例中任务处理方法的步骤。
68.本技术实施例中提供的任务处理方法,通过建立任务配置框架,对多个任务工程进行管理配置,并通过建立目标任务列表,存储进行管理配置后的多个任务工程,根据任务配置框架配置目标任务列表,如此,整个配置过程无需重新部署任务环境,只需在原有环境基础上增加配置项实现任务有效配置,高效且节省配置资源。另外,通过配置任务管理接口,便于通过任务管理接口访问目标任务列表中的任务工程,方便任务及时访问处理。
69.上述说明仅是本技术实施例技术方案的概述,为了能够更清楚了解本技术实施例的技术手段,而可依照说明书的内容予以实施,并且为了让本技术实施例的上述和其它目的、特征和优点能够更明显易懂,以下特举本技术的具体实施方式。
附图说明
70.为了更清楚地说明本公开的实施例的技术方案,下面将对实施例的附图进行简要说明,应当知道,以下描述的附图仅仅涉及本公开的一些实施例,而非对本公开的限制,其中:
71.图1为本实施例中提供的一种任务处理方法的流程示意图。
72.图2为本实施例中提供的一种任务配置的原理示意图;
73.图3为本实施例中提供的一种任务处理装置的结构示意图。
74.图4为本实施例中提供的一种计算机设备的结构示意图。
具体实施方式
75.为了使本公开的实施例的目的、技术方案和优点更加清楚,下面将结合附图,对本公开的实施例的技术方案进行清楚、完整的描述。显然,所描述的实施例是本公开的一部分实施例,而不是全部的实施例。基于所描述的本公开的实施例,本领域技术人员在无需创造性劳动的前提下所获得的所有其它实施例,也都属于本公开保护的范围。
76.除非另外定义,否则在此使用的所有术语(包括技术和科学术语)具有与本公开主题所属领域的技术人员所通常理解的相同含义。进一步将理解的是,诸如在通常使用的词典中定义的那些的术语应解释为具有与说明书上下文和相关技术中它们的含义一致的含义,并且将不以理想化或过于正式的形式来解释,除非在此另外明确定义。如在此所使用的,将两个或更多部分“连接”或“耦接”到一起的陈述应指这些部分直接结合到一起或通过一个或多个中间部件结合。
77.在本文中提及“实施例”意味着,结合实施例描述的特定特征、结构或特性可以包含在本技术的至少一个实施例中。在说明书中的各个位置出现该短语“实施例”并不一定均是指相同的实施例,也不是与其它实施例互斥的独立的或备选的实施例。本领域技术人员显式地和隐式地理解的是,本文所描述的实施例可以与其它实施例相结合。
78.本文中术语“和/或”,仅仅是一种描述关联对象的关联关系,表示可以存在三种关系,例如,a和/或b,可以表示:存在a,同时存在a和b,存在b这三种情况。另外,本文中字符“/”,一般表示前后关联对象是一种“或”的关系。诸如“第一”和“第二”的术语仅用于将一个部件(或部件的一部分)与另一个部件(或部件的另一部分)区分开。
79.在本技术的描述中,除非另有说明,“多个”的含义是指两个以上(包括两个),同理,“多组”指的是两组以上(包括两组)。
80.为了使本技术领域的人员更好地理解本技术方案,下面将结合附图,对本技术实施例中的技术方案进行清楚、完整地描述。
81.图1为实施例提供的一种任务处理方法的流程示意图,任务处理方法可以如下包括。
82.s110、建立任务配置框架。
83.其中,任务配置框架可用于进行一个或多个任务工程的管理配置。也就是,可在任务配置框架之上,对一个任务工程或者多个任务工程进行某些管理信息的配置。
84.任务配置框架可为springboot框架,能够通过特定配置进行任务项目的配置,其中,配置时不需要开发人员定义样板化的配置,便于实现项目的快速开发。
85.此外,springboot还可以创建独立的spring应用程序,通过maven创建可执行的jar、war。内嵌tomcat或jetty等servlet容器。自动配置spring容器,如自动注入、自动扫描等。无代码生成,不需要xml配置。同时,可提供自动配置的“starter”项目对象模型(projectobjectmodel,poms)以简化maven配置。其中,poms可通过一小段描述信息来管理任务项目的构建、报告和文档的软件项目管理工具。
86.一些实施例中,建立任务配置框架,可包括:调用框架导入组件;基于框架导入组件,导入springboot依赖,得到任务配置框架。
87.其中,框架导入组件可为一个第三方插件/工具,如maven,可通过maven导入springboot依赖,以快速有效的建立任务配置框架。
88.maven可看作一个跨平台的项目管理工具,主要服务基于如java的项目构建、项目信息管理和依赖管理。
89.s120、建立目标任务列表。
90.其中,可在数据库中建立目标任务列表,建立在数据库中的目标任务列表能够用于存放进行管理配置后的多个任务工程。目标任务列表中可包括但不限于自定义多个有效字段。
91.一些实施例中,建立目标任务列表,可包括:在数据库中配置列表字段信息,列表字段信息包括:cron表达式、任务标识、任务描述、任务状态以及任务类型;基于列表字段信息,建立目标任务列表,目标任务列表中存储的每一任务工程包括cron表达式、任务标识、任务描述、任务状态以及任务类型。
92.其中,cron表达式、任务标识、任务描述、任务状态以及任务类型为目标任务列表中自定义的有效字段。
93.cron表达式为一个字符串,字符串以5或6个空格隔开,分为6或7个域,每一个域代表一个含义。cron表达式如:{秒数}{分钟}{小时}{日期}{月份}{星期}{年份},其中,{年份}可为空。
94.举例而言,cron有如下两种语法格式:
[0095]“secondsminuteshoursdayofmonthmonthdayofweekyear”[0096]
或“secondsminuteshoursdayofmonthmonthdayofweek”。
[0097]
每一个域可出现的字符如下:
[0098]“seconds”可出现",-*/"四个字符,有效范围为0-59的整数。“minutes”可出现",-*/"四个字符,有效范围为0-59的整数。“hours”可出现",-*/"四个字符,有效范围为0-23的整数。“dayofmonth”可出现",-*/?lwc"八个字符,有效范围为0-31的整数。“month”可出现",-*/"四个字符,有效范围为1-12的整数或jan-dec。“dayofweek”可出现",-*/?lc#"四个字符,有效范围为1-7的整数或sun-sat两个范围,1表示星期天,2表示星期一,依次类推。“year”可出现",-*/"四个字符,有效范围为1970-2099年。
[0099]
从而,通过在数据库中配置列表字段信息,列表字段信息可包括:cron表达式、任务标识、任务描述、任务状态以及任务类型,并基于列表字段信息,建立目标任务列表,其中,目标任务列表中存储的每一任务工程包括cron表达式、任务标识、任务描述、任务状态以及任务类型,建立出符合任务需求的目标任务列表。
[0100]
s130、基于任务配置框架配置目标任务列表。
[0101]
其中,可在导入springboot依赖之后,对目标任务列表中的多个任务工程进行有效配置。
[0102]
s140、配置任务管理接口,并基于任务管理接口访问目标任务列表。
[0103]
其中,基于任务管理接口访问目标任务列表,能够实现对目标任务列表中的任务工程进行处理。
[0104]
任务管理接口可为设备前端页面中的一个可触控接口,用来对多个任务工程进行实际操作,实际操作可包括但不限于是增、删、查、改以及匹配正确的cron表达式。
[0105]
本实施例中,能够通过建立任务配置框架,对多个任务工程进行管理配置,并通过建立目标任务列表,存储进行管理配置后的多个任务工程,根据任务配置框架配置目标任务列表,如此,整个配置过程无需重新部署任务环境,只需在原有环境基础上增加配置项实现任务有效配置,高效且节省配置资源。另外,通过配置任务管理接口,便于通过任务管理接口访问目标任务列表中的任务工程,方便任务及时访问处理。
[0106]
一些实施例中,基于任务配置框架配置目标任务列表,可包括:
[0107]
基于任务配置框架建立任务线程池,任务线程池作为定时任务调度线程池,用于配置线程池大小、线程名称、任务销毁机制以及任务等待时长;读取目标任务列表,基于任务工程的任务状态,在任务线程池中配置目标任务列表中的多个任务工程。
[0108]
其中,可新建一个bean-threadpooltaskscheduler,用于创建任务线程池,作为定时任务调度线程池。
[0109]
任务销毁机制可包括:任务工程的开启、销毁条件等。任务等待时长可包括:任务读取等待时长、任务刷新时长等。
[0110]
从而,通过建立任务线程池,读取目标任务列表,基于任务工程的任务状态,在任务线程池中配置目标任务列表中的多个任务工程,便于对目标任务列表中的多个任务工程进行有效配置。
[0111]
其中,基于任务工程的任务状态,在任务线程池中配置目标任务列表中的多个任务工程,包括:在任务工程的任务状态为开启时,调用第一任务处理接口;基于第一任务处理接口,将任务工程添加至任务线程池中。
[0112]
可通过重写configuretasks方法,读取目标任务列表,查询出目标任务列表中任务状态为开启的任务工程,并通过第一任务处理接口添加至任务线程池,以基于任务工程的不同任务状态,合理进行任务配置。
[0113]
如图2所示,基于任务管理同步目标任务列表,定时进行刷新,并通过scheduledtaskregistrar接口实现多任务添加。
[0114]
上述实施例的基础上,本实施例方法还可以包括:读取目标任务列表;基于任务工程的任务状态,处理任务工程。
[0115]
在基于任务配置框架建立任务线程池之后,可基于任务工程的任务状态,处理任务工程,便于实现不同形式任务配置。
[0116]
任务线程池作为定时任务调度线程池,用于配置线程池大小、线程名称、任务销毁机制以及任务等待时长。
[0117]
其中,基于任务工程的任务状态,处理任务工程,包括:在任务工程的任务状态为关闭时,调用第二任务处理接口;基于第二任务处理接口,关闭任务工程在目标任务列表中
的刷新周期。从而,在确定出一个任务工程的任务状态为关闭时,能够快速通过第二任务处理接口对其刷新周期进行关闭,节省资源。
[0118]
上述实施例的基础上,本实施例方法还可以包括:
[0119]
获取业务处理场景;基于业务处理场景,建立目标任务列表对应的任务存储介质,任务存储介质包括:关系型数据库或非关系型数据库;基于第三任务处理接口,在任务存储介质中配置目标任务列表中多个任务工程的业务执行逻辑,以基于业务执行逻辑运行相应的任务工程。
[0120]
其中,可根据不同业务处理场景,创建对应任务类,需实现runnable接口,重写run方法,便于设置任务执行的业务逻辑。
[0121]
上述实施例的基础上,本实施例方法还可以包括:配置异常捕获机制,异常捕获机制用于记录配置过程中的异常信息;在基于异常捕获机制获取到异常信息时,告警并显示异常信息。
[0122]
其中,异常捕获机制可用来告警及提示一些配置过程中的异常情况,便于配置人员及时发生并更正,避免配置出错且不知,有效提升配置效率。
[0123]
另外,在任务执行过程中,也可通过异常捕获机制进行任务执行的异常信息监测,在监测到任务执行异常时,可及时进行告警并显示,便于有效发现任务执行问题并核正。
[0124]
图3为本实施例提供的一种任务处理装置的结构示意图,其中,任务处理装置可包括:第一建立模块310、第二建立模块320、第一配置模块330和第二配置模块340。
[0125]
第一建立模块310,用于建立任务配置框架,所述任务配置框架用于进行任务工程的管理配置。
[0126]
第二建立模块320,用于建立目标任务列表,所述目标任务列表用于存放进行所述管理配置后的多个所述任务工程。
[0127]
第一配置模块330,用于基于所述任务配置框架配置所述目标任务列表。
[0128]
第二配置模块340,用于配置任务管理接口,并基于所述任务管理接口访问所述目标任务列表,以对所述目标任务列表中的所述任务工程进行处理。
[0129]
在一些实施例中,可选的,第一配置模块330,包括:建立单元和配置单元。
[0130]
建立单元,用于基于所述任务配置框架建立任务线程池,所述任务线程池作为定时任务调度线程池,用于配置线程池大小、线程名称、任务销毁机制以及任务等待时长。
[0131]
配置单元,用于读取所述目标任务列表,基于所述任务工程的任务状态,在所述任务线程池中配置所述目标任务列表中的多个所述任务工程。
[0132]
在一些实施例中,可选的,配置单元,具体用于:
[0133]
在所述任务工程的任务状态为开启时,调用第一任务处理接口;基于所述第一任务处理接口,将所述任务工程添加至所述任务线程池中。
[0134]
在一些实施例中,可选的,还包括:读取模块和处理模块。
[0135]
读取模块,用于读取所述目标任务列表。
[0136]
处理模块,用于基于所述任务工程的任务状态,处理所述任务工程。
[0137]
在一些实施例中,可选的,读取模块,具体用于:
[0138]
在所述任务工程的任务状态为关闭时,调用第二任务处理接口;基于所述第二任务处理接口,关闭所述任务工程在所述目标任务列表中的刷新周期。
[0139]
在一些实施例中,可选的,还包括:获取模块、第三建立模块和第三配置模块。
[0140]
获取模块,用于获取业务处理场景。
[0141]
第三建立模块,用于基于所述业务处理场景,建立所述目标任务列表对应的任务存储介质,所述任务存储介质包括:关系型数据库或非关系型数据库。
[0142]
第三配置模块,用于基于第三任务处理接口,在所述任务存储介质中配置所述目标任务列表中多个所述任务工程的业务执行逻辑,以基于所述业务执行逻辑运行相应的所述任务工程。
[0143]
在一些实施例中,可选的,第二建立模块320,具体用于:
[0144]
在数据库中配置列表字段信息,所述列表字段信息包括:cron表达式、任务标识、任务描述、任务状态以及任务类型;基于所述列表字段信息,建立所述目标任务列表,所述目标任务列表中存储的每一任务工程包括所述cron表达式、所述任务标识、所述任务描述、所述任务状态以及所述任务类型。
[0145]
在一些实施例中,可选的,第一建立模块310,具体用于:
[0146]
调用框架导入组件;基于所述框架导入组件,导入springboot依赖,得到所述任务配置框架。
[0147]
在一些实施例中,可选的,还包括:第四配置模块;
[0148]
第四配置模块,用于配置异常捕获机制,所述异常捕获机制用于记录配置过程中的异常信息。
[0149]
处理模块,还用于在基于所述异常捕获机制获取到所述异常信息时,告警并显示所述异常信息。
[0150]
本发明实施例所提供的任务处理装置,通过建立任务配置框架,对多个任务工程进行管理配置,并通过建立目标任务列表,存储进行管理配置后的多个任务工程,根据任务配置框架配置目标任务列表,如此,整个配置过程无需重新部署任务环境,只需在原有环境基础上增加配置项实现任务有效配置,高效且节省配置资源。另外,通过配置任务管理接口,便于通过任务管理接口访问目标任务列表中的任务工程,方便任务及时访问处理。
[0151]
本技术实施例还提供了一种计算机设备。具体请参阅图4,图4为本实施例计算机设备基本结构框图。
[0152]
计算机设备包括通过系统总线相互通信连接存储器410和处理器420。需要指出的是,图中仅示出了具有组件410-420的计算机设备,但是应理解的是,并不要求实施所有示出的组件,可以替代的实施更多或者更少的组件。其中,本技术领域技术人员可以理解,这里的计算机设备是一种能够按照事先设定或存储的指令,自动进行数值计算和/或信息处理的设备,其硬件包括但不限于微处理器、专用集成电路(application specific integrated circuit,asic)、可编程门阵列(field-programmable gate array,fpga)、数字处理器(digital signal processor,dsp)、嵌入式设备等。
[0153]
计算机设备可以是桌上型计算机、笔记本、掌上电脑及云端服务器等计算设备。计算机设备可以与用户通过键盘、鼠标、遥控器、触摸板或声控设备等方式进行人机交互。
[0154]
存储器410至少包括一种类型的可读存储介质,可读存储介质包括非易失性存储器(non-volatile memory)或易失性存储器,例如,闪存(flash memory)、硬盘、多媒体卡、卡型存储器(例如,sd或dx存储器等)、随机访问存储器(random access memory,ram)、只读
存储器(read-only memory,rom)、可擦写可编程只读存储器(erasable programmable read-only memory,eprom)、电可擦写可编程只读存储器(electrically erasable programmable read-only memory,eeprom)、可编程只读存储器(programmable read-only memory,prom)、磁性存储器、磁盘、光盘等,ram可以包括静态ram或动态ram。在一些实施例中,存储器410可以是计算机设备的内部存储单元,例如,该计算机设备的硬盘或内存。在另一些实施例中,存储器410也可以是计算机设备的外部存储设备,例如该计算机设备上配备的插接式硬盘、智能存储卡(smart media card,smc)、安全数字(secure digital,sd)卡或闪存卡(flash card)等。当然,存储器410还可以既包括计算机设备的内部存储单元也包括其外部存储设备。本实施例中,存储器410通常用于存储安装于计算机设备的操作系统和各类应用软件,例如上述方法的程序代码等。此外,存储器410还可以用于暂时地存储已经输出或者将要输出的各类数据。
[0155]
处理器420通常用于执行计算机设备的总体操作。本实施例中,存储器410用于存储程序代码或指令,程序代码包括计算机操作指令,处理器420用于执行存储器410存储的程序代码或指令或者处理数据,例如运行上述方法的程序代码。
[0156]
本文中,总线可以是工业标准体系结构(industry standard architecture,isa)总线、外设部件互连标准(peripheral component interconnect,pci)总线或扩展工业标准结构(extended industry standard architecture,eisa)总线等。该总线系统可以分为地址总线、数据总线、控制总线等。为便于表示,图中仅用一条粗线表示,但并不表示仅有一根总线或一种类型的总线。
[0157]
本技术的另一实施例还提供一种计算机可读介质,计算机可读介质可以是计算机可读信号介质或者计算机可读介质。计算机中的处理器读取存储在计算机可读介质中的计算机可读程序代码,使得处理器能够执行在上述方法中每个步骤、或各步骤的组合中规定的功能动作;生成实施在框图的每一块、或各块的组合中规定的功能动作的装置。
[0158]
计算机可读介质包含但不限于电子、磁性、光学、电磁、红外的存储器或半导体系统、设备或者装置,或者前述的任意适当组合,存储器用于存储程序代码或指令,程序代码包括计算机操作指令,处理器用于执行存储器存储的上述方法的程序代码或指令。
[0159]
存储器和处理器的定义,可以参考前述计算机设备实施例的描述,在此不再赘述。
[0160]
在本技术所提供的几个实施例中,应该理解到,所揭露的系统、装置和方法,可以通过其它的方式实现。例如,以上所描述的装置实施例仅仅是示意性的,例如,模块或单元的划分,仅仅为一种逻辑功能划分,实际实现时可以有另外的划分方式,例如多个单元或组件可以结合或者可以集成到另一个系统,或一些特征可以忽略,或不执行。另一点,所显示或讨论的相互之间的耦合或直接耦合或通信连接可以是通过一些接口,装置或单元的间接耦合或通信连接,可以是电性,机械或其它的形式。
[0161]
在本技术各个实施例中的各功能单元或模块可以集成在一个处理单元中,也可以是各个单元单独物理存在,也可以两个或两个以上单元集成在一个单元中。上述集成的单元既可以采用硬件的形式实现,也可以采用软件功能单元的形式实现。
[0162]
集成的单元如果以软件功能单元的形式实现并作为独立的产品销售或使用时,可以存储在一个计算机可读取存储介质中。基于这样的理解,本技术的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的全部或部分可以以软件产品的形式体现
出来,该计算机软件产品存储在一个存储介质中,包括若干指令用以使得一台计算机设备(可以是个人计算机,服务器,或者网络设备等)或处理器(processor)执行本技术各个实施例方法的全部或部分步骤。而前述的存储介质包括:u盘、移动硬盘、只读存储器(read-onlymemory,rom)、随机存取存储器(random access memory,ram)、磁碟或者光盘等各种可以存储程序代码的介质。
[0163]
在权利要求中,不应将位于括号之间的任何参考符号构造成对权利要求的限制。本技术描述的“包含”不排除存在未列在权利要求中的元件或步骤。位于元件之前的单词“一”或“一个”不排除存在多个这样的元件。本技术可以借助于包括有若干不同元件的硬件以及借助于适当编程的计算机来实现。在列举了装置若干的单元权利要求中,这些装置中的若干个单元可以是通过同一个硬件项来具体体现。第一、第二、以及第三等的使用不表示任何顺序,可将这些单词解释为名称。上述实施例中的步骤,除有特殊说明外,不应理解为对执行顺序的限定。
[0164]
以上实施例仅用以说明本技术的技术方案,而非对其限制;尽管参照前述实施例对本技术进行了详细的说明,本领域的普通技术人员应当理解:其依然可以对前述各实施例所记载的技术方案进行修改,或者对其中部分技术特征进行等同替换;而这些修改或者替换,并不使相应技术方案的本质脱离本技术各实施例技术方案的精神和范围。
技术特征:
1.一种任务处理方法,其特征在于,包括:建立任务配置框架,所述任务配置框架用于进行任务工程的管理配置;建立目标任务列表,所述目标任务列表用于存放进行所述管理配置后的多个所述任务工程;基于所述任务配置框架配置所述目标任务列表;配置任务管理接口,并基于所述任务管理接口访问所述目标任务列表,以对所述目标任务列表中的所述任务工程进行处理。2.根据权利要求1所述的方法,其特征在于,所述基于所述任务配置框架配置所述目标任务列表,包括:基于所述任务配置框架建立任务线程池,所述任务线程池作为定时任务调度线程池,用于配置线程池大小、线程名称、任务销毁机制以及任务等待时长;读取所述目标任务列表,基于所述任务工程的任务状态,在所述任务线程池中配置所述目标任务列表中的多个所述任务工程。3.根据权利要求2所述的方法,其特征在于,所述基于所述任务工程的任务状态,在所述任务线程池中配置所述目标任务列表中的多个所述任务工程,包括:在所述任务工程的任务状态为开启时,调用第一任务处理接口;基于所述第一任务处理接口,将所述任务工程添加至所述任务线程池中。4.根据权利要求2所述的方法,其特征在于,还包括:读取所述目标任务列表;基于所述任务工程的任务状态,处理所述任务工程。5.根据权利要求4所述的方法,其特征在于,所述基于所述任务工程的任务状态,处理所述任务工程,包括:在所述任务工程的任务状态为关闭时,调用第二任务处理接口;基于所述第二任务处理接口,关闭所述任务工程在所述目标任务列表中的刷新周期。6.根据权利要求2所述的方法,其特征在于,还包括:获取业务处理场景;基于所述业务处理场景,建立所述目标任务列表对应的任务存储介质,所述任务存储介质包括:关系型数据库或非关系型数据库;基于第三任务处理接口,在所述任务存储介质中配置所述目标任务列表中多个所述任务工程的业务执行逻辑,以基于所述业务执行逻辑运行相应的所述任务工程。7.根据权利要求1所述的方法,其特征在于,所述建立目标任务列表,包括:在数据库中配置列表字段信息,所述列表字段信息包括:cron表达式、任务标识、任务描述、任务状态以及任务类型;基于所述列表字段信息,建立所述目标任务列表,所述目标任务列表中存储的每一任务工程包括所述cron表达式、所述任务标识、所述任务描述、所述任务状态以及所述任务类型。8.根据权利要求1所述的方法,其特征在于,所述建立任务配置框架,包括:调用框架导入组件;基于所述框架导入组件,导入springboot依赖,得到所述任务配置框架。
9.根据权利要求1所述的方法,其特征在于,还包括:配置异常捕获机制,所述异常捕获机制用于记录配置过程中的异常信息;在基于所述异常捕获机制获取到所述异常信息时,告警并显示所述异常信息。10.一种任务处理装置,其特征在于,包括:第一建立模块,用于建立任务配置框架,所述任务配置框架用于进行任务工程的管理配置;第二建立模块,用于建立目标任务列表,所述目标任务列表用于存放进行所述管理配置后的多个所述任务工程;第一配置模块,用于基于所述任务配置框架配置所述目标任务列表;第二配置模块,用于配置任务管理接口,并基于所述任务管理接口访问所述目标任务列表,以对所述目标任务列表中的所述任务工程进行处理。
技术总结
本申请实施例提供一种任务处理方法和装置,其中,该方法包括:建立任务配置框架,任务配置框架用于进行任务工程的管理配置;建立目标任务列表,目标任务列表用于存放进行管理配置后的多个任务工程;基于任务配置框架配置目标任务列表;配置任务管理接口,并基于任务管理接口访问目标任务列表,以对目标任务列表中的任务工程进行处理。本实施例整个配置过程无需重新部署任务环境,只需在原有环境基础上增加配置项实现任务有效配置,高效且节省配置资源,便于实现任务及时访问处理。便于实现任务及时访问处理。便于实现任务及时访问处理。
技术研发人员:王锦胤 贺浪 刘国强
受保护的技术使用者:紫金诚征信有限公司
技术研发日:2023.03.08
技术公布日:2023/7/26
版权声明
本文仅代表作者观点,不代表航家之家立场。
本文系作者授权航家号发表,未经原创作者书面授权,任何单位或个人不得引用、复制、转载、摘编、链接或以其他任何方式复制发表。任何单位或个人在获得书面授权使用航空之家内容时,须注明作者及来源 “航空之家”。如非法使用航空之家的部分或全部内容的,航空之家将依法追究其法律责任。(航空之家官方QQ:2926969996)
航空之家 https://www.aerohome.com.cn/
飞机超市 https://mall.aerohome.com.cn/
航空资讯 https://news.aerohome.com.cn/
