一种定时任务进程与队列服务进程管理系统及方法

摘要

本申请公开了一种定时任务进程与队列服务进程管理系统及方法，该系统包括：数据中心，用于通过可视化的配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息；第一类配置信息中包括定时拉起配置信息；调度模块，用于基于预设定时器定时加载数据中心的第一类配置信息，并直接加载第二类配置信息，根据第一类配置信息和第二类配置信息确定对应的待执行任务；执行器，用于接收并执行调度模块下发的待执行任务。本申请中用户可以通过可视化的配置界面对定时任务进程以及队列服务进程进行配置，方便对各进程进行直观的配置管理；为定时任务进程设置定时拉起配置信息，能够解决数据库连接无法释放的问题，避免了系统资源的浪费。

权利要求

1.一种定时任务进程与队列服务进程管理系统，其特征在于，包括：数据中心，用于通过可视化的配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息；所述第一类配置信息中包括定时拉起配置信息；

调度模块，用于基于预设定时器的设置定时加载所述数据中心的所述第一类配置信息，并直接加载所述第二类配置信息，通过对所述第一类配置信息和所述第二类配置信息进行验证，确定对应的待执行任务；

执行器，用于接收并执行所述调度模块下发的所述待执行任务；

其中，所述调度模块，包括：

第一加载单元，用于基于预设定时器的设置定时加载所述数据中心的所述第一类配置信息，并判断所述第一类配置信息对应的定时任务是否允许执行，如果是，则将当前定时任务确定为所述待执行任务；

第二加载单元，用于加载所述数据中心的第二类配置信息，利用预设验证规则筛选满足执行条件的队列任务确定为所述待执行任务；

相应的，所述执行器，包括：

定时任务执行单元，用于对定时任务对应的第一类待执行任务进行执行，在执行完成后输出执行结果并退出执行进程；

队列任务执行单元，用于对队列服务对应的第二类待执行任务进行执行，并利用消息处理引擎Kafka自动关闭阻塞进程。

2.根据权利要求1所述的定时任务进程与队列服务进程管理系统，其特征在于，所述数据中心，包括：

配置单元，用于通过可视化的所述配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息；

管理单元，用于当启动定时任务的主进程或队列服务的主进程之后，导入所述第一类配置信息或所述第二类配置信息，并通过可视化的管理界面对所述第一类配置信息或所述第二类配置信息进行显示。

3.根据权利要求2所述的定时任务进程与队列服务进程管理系统，其特征在于，所述第一类配置信息，包括：任务名称、任务命令、任务状态、任务执行环境、定时拉起配置信息、任务级别、任务拥有者信息中任一项或任几项的组合；所述第二类配置信息，包括：服务名称、服务命令、服务状态、服务执行环境、服务级别、服务拥有者信息中任一项或任几项的组合。

4.根据权利要求2所述的定时任务进程与队列服务进程管理系统，其特征在于，所述管理单元，还用于：

通过所述管理界面显示针对所述第一类配置信息的附加参数配置子界面，以便通过所述附加参数配置子界面接收用户终端设置的附加参数；

其中，所述附加参数包括任务节点、任务超时时间、任务失败重试次数、任务失败重试时间间隔、任务通知开启/关闭配置信息中任一项或任几项的组合。

5.根据权利要求2所述的定时任务进程与队列服务进程管理系统，其特征在于，所述管理单元，还用于：

通过所述管理界面对所述定时任务对应的任务日志进行显示，所述任务日志中包括任务执行开始时间、任务执行结束时间、任务执行时长、任务开始时对应的初始内存大小、任务结束时对应的目标内存大小以及执行结果中任一项或任几项的组合；

通过所述管理界面对任务执行时长统计表进行显示，所述任务执行时长统计表中包括定时任务中所涉及的针对数据表的更新操作记录。

6.一种定时任务进程与队列服务进程管理方法，其特征在于，包括：通过数据中心可视化的配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息；所述第一类配置信息中包括定时拉起配置信息；

基于预设定时器的设置，利用调度模块定时加载所述数据中心的所述第一类配置信息，并直接加载所述第二类配置信息，通过对所述第一类配置信息和所述第二类配置信息进行验证，确定对应的待执行任务；

将所述待执行任务下发至执行器，以便所述执行器执行所述待执行任务；

其中，所述调度模块包括第一加载单元和第二加载单元；

相应的，所述基于预设定时器的设置，利用调度模块定时加载所述数据中心的所述第一类配置信息，并直接加载所述第二类配置信息，通过对所述第一类配置信息和所述第二类配置信息进行验证，确定对应的待执行任务，包括：基于预设定时器的设置利用所述第一加载单元定时加载所述数据中心的所述第一类配置信息，并判断所述第一类配置信息对应的定时任务是否允许执行，如果是，则将当前定时任务确定为所述待执行任务；

利用所述第二加载单元加载所述数据中心的第二类配置信息，并利用预设验证规则筛选满足执行条件的队列任务确定为所述待执行任务；

相应的，所述执行器包括定时任务执行单元和队列任务执行单元，所述将所述待执行任务下发至执行器，以便所述执行器执行所述待执行任务，包括：利用所述定时任务执行单元对定时任务对应的第一类待执行任务进行执行，在执行完成后输出执行结果并退出执行进程；

利用所述队列任务执行单元对队列服务对应的第二类待执行任务进行执行，并利用消息处理引擎Kafka自动关闭阻塞进程。

7.根据权利要求6所述的定时任务进程与队列服务进程管理方法，其特征在于，所述通过数据中心可视化的配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息，包括：

通过数据中心可视化的所述配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息；

当启动定时任务的主进程或队列服务的主进程之后，导入所述第一类配置信息或所述第二类配置信息，并通过数据中心可视化的管理界面对所述第一类配置信息或所述第二类配置信息进行显示。

8.根据权利要求7所述的定时任务进程与队列服务进程管理方法，其特征在于，还包括：

通过所述管理界面对所述定时任务对应的任务日志进行显示，所述任务日志中包括任务执行开始时间、任务执行结束时间、任务执行时长、任务开始时对应的初始内存大小、任务结束时对应的目标内存大小以及执行结果中任一项或任几项的组合；

通过所述管理界面对任务执行时长统计表进行显示，所述任务执行时长统计表中包括定时任务中所涉及的针对数据表的更新操作记录。

说明书

一种定时任务进程与队列服务进程管理系统及方法

技术领域

[0001] 本申请涉及进程管理技术领域，更具体地说，涉及一种定时任务进程与队列服务进程管理系统及方法。

背景技术

[0002] 在企业的一个业务项目中，通常包括各个系统的多个定时任务和多个队列服务。其中，队列工作服务一般使用常驻进程，无法释放一定时间内不使用的数据库连接，导致占
用了系统资源。而针对定时任务进程和队列服务进程的配置也通常采用后台脚本实现，不
便于用户进行管理。

[0003] 因此，如何解决上述问题是本领域技术人员需要重点关注的。

发明内容

[0004] 本申请的目的在于提供一种定时任务进程与队列服务进程管理系统及方法，便于对各进程进行直观的配置管理，同时解决了数据库连接无法释放的问题，避免系统资源的
浪费。

[0005] 为实现上述目的，本申请提供了一种定时任务进程与队列服务进程管理系统，包括：

[0006] 数据中心，用于通过可视化的配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息；所述第一类配置信息中包括定时拉起配置信息；

[0007] 调度模块，用于基于预设定时器的设置定时加载所述数据中心的所述第一类配置信息，并直接加载所述第二类配置信息，通过对所述第一类配置信息和所述第二类配置信
息进行验证，确定对应的待执行任务；

[0008] 执行器，用于接收并执行所述调度模块下发的所述待执行任务。

[0009] 可选的，所述数据中心，包括：

[0010] 配置单元，用于通过可视化的所述配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息；

[0011] 管理单元，用于当启动定时任务的主进程或队列服务的主进程之后，导入所述第一类配置信息或所述第二类配置信息，并通过可视化的管理界面对所述第一类配置信息或
所述第二类配置信息进行显示。

[0012] 可选的，所述第一类配置信息，包括：任务名称、任务命令、任务状态、任务执行环境、定时拉起配置信息、任务级别、任务拥有者信息中任一项或任几项的组合；所述第二类
配置信息，包括：服务名称、服务命令、服务状态、服务执行环境、服务级别、服务拥有者信息
中任一项或任几项的组合。

[0013] 可选的，所述管理单元，还用于：

[0014] 通过所述管理界面显示针对所述第一类配置信息的附加参数配置子界面，以便通过所述附加参数配置子界面接收用户终端设置的附加参数；

[0015] 其中，所述附加参数包括任务节点、任务超时时间、任务失败重试次数、任务失败重试时间间隔、任务通知开启/关闭配置信息中任一项或任几项的组合。

[0016] 可选的，所述管理单元，还用于：

[0017] 通过所述管理界面对所述定时任务对应的任务日志进行显示，所述任务日志中包括任务执行开始时间、任务执行结束时间、任务执行时长、任务开始时对应的初始内存大
小、任务结束时对应的目标内存大小以及执行结果中任一项或任几项的组合；

[0018] 通过所述管理界面对任务执行时长统计表进行显示，所述任务执行时长统计表中包括定时任务中所涉及的针对数据表的更新操作记录。

[0019] 可选的，所述调度模块，包括：

[0020] 第一加载单元，用于基于预设定时器的设置定时加载所述数据中心的所述第一类配置信息，并判断所述第一类配置信息对应的定时任务是否允许执行，如果是，则将当前定
时任务确定为所述待执行任务；

[0021] 第二加载单元，用于加载所述数据中心的第二类配置信息，利用预设验证规则筛选满足执行条件的队列任务确定为所述待执行任务。

[0022] 可选的，所述执行器，包括：

[0023] 定时任务执行单元，用于对定时任务对应的第一类待执行任务进行执行，在执行完成后输出执行结果并退出执行进程；

[0024] 队列任务执行单元，用于对队列服务对应的第二类待执行任务进行执行，并利用消息处理引擎Kafka自动关闭阻塞进程。

[0025] 为实现上述目的，本申请提供了一种定时任务进程与队列服务进程管理方法，包括：

[0026] 通过数据中心可视化的配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息；所述第一类配置信息中包括定时拉起配置信息；

[0027] 基于预设定时器的设置，利用调度模块定时加载所述数据中心的所述第一类配置信息，并直接加载所述第二类配置信息，通过对所述第一类配置信息和所述第二类配置信
息进行验证，确定对应的待执行任务；

[0028] 将所述待执行任务下发至执行器，以便所述执行器执行所述待执行任务。

[0029] 可选的，所述通过数据中心可视化的配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息，包括：

[0030] 通过数据中心可视化的所述配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息；

[0031] 当启动定时任务的主进程或队列服务的主进程之后，导入所述第一类配置信息或所述第二类配置信息，并通过数据中心可视化的管理界面对所述第一类配置信息或所述第
二类配置信息进行显示。

[0032] 可选的，还包括：

[0033] 通过所述管理界面对所述定时任务对应的任务日志进行显示，所述任务日志中包括任务执行开始时间、任务执行结束时间、任务执行时长、任务开始时对应的初始内存大
小、任务结束时对应的目标内存大小以及执行结果中任一项或任几项的组合；

[0034] 通过所述管理界面对任务执行时长统计表进行显示，所述任务执行时长统计表中包括定时任务中所涉及的针对数据表的更新操作记录。

[0035] 通过以上方案可知，本申请提供的一种定时任务进程与队列服务进程管理系统，包括：数据中心，用于通过可视化的配置界面接收定时任务进程的第一类配置信息和队列
服务进程的第二类配置信息；所述第一类配置信息中包括定时拉起配置信息；调度模块，用
于基于预设定时器的设置定时加载所述数据中心的所述第一类配置信息，并直接加载所述
第二类配置信息，通过对所述第一类配置信息和所述第二类配置信息进行验证，确定对应
的待执行任务；执行器，用于接收并执行所述调度模块下发的所述待执行任务。由上可知，
本申请中用户可以通过可视化的配置界面对定时任务进程以及队列服务进程进行配置，实
现更加方便直观地对各进程进行配置管理，提升了用户的使用体验；另外通过为定时任务
进程设置定时拉起配置信息，能够解决数据库连接无法释放的问题，避免了系统资源的浪
费。

[0036] 本申请还公开了一种定时任务进程与队列服务进程管理系统方法，同样能实现上述技术效果。

[0037] 应当理解的是，以上的一般描述和后文的细节描述仅是示例性的，并不能限制本申请。

附图说明

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

[0039] 图1为本申请实施例公开的一种定时任务进程与队列服务进程管理系统的结构图；

[0040] 图2为本申请实施例公开的一种定时任务进程与队列服务进程管理方法的流程图。

具体实施方式

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

[0042] 在相关技术中，队列工作服务一般使用常驻进程，无法释放一定时间内不使用的数据库连接，导致占用了系统资源。而针对定时任务进程和队列服务进程的配置也通常采
用后台脚本实现，不便于用户进行管理。

[0043] 因此，本申请实施例公开了一种定时任务进程与队列服务进程管理系统，便于对各进程进行直观的配置管理，同时解决了数据库连接无法释放的问题，避免系统资源的浪
费。

[0044] 参见图1所示，本申请实施例公开的一种定时任务进程与队列服务进程管理系统，具体包括：

[0045] 数据中心10，用于通过可视化的配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息；所述第一类配置信息中包括定时拉起配置信息；

[0046] 本申请实施例中，数据中心10具体用于接收用户的配置信息。具体地，数据中心10可以提供可视化的配置界面，用户可以基于可视化的配置界面下发为定时任务进程设置的
第一类配置信息以及为队列服务进程设置的第二类配置信息。在具体实施中，可视化的配
置界面可以按照预先设定的格式显示定时任务进程与队列服务进程所需配置的各类基本
参数名称，并显示对应的输入框或可选项，用户可以通过手动输入或选择已有参数的方式
下发配置信息。其中，上述定时任务进程的第一类配置信息中可以具体包括定时拉起配置
信息，该配置信息用于将定时任务进程设置为定时拉起的进程，从而及时释放对应的数据
库连接。

[0047] 需要指出的是，上述第一类配置信息可以包括但不限于：任务名称、任务命令、任务状态、任务执行环境、定时拉起配置信息、任务级别、任务拥有者信息；上述第二类配置信
息可以包括但不限于：服务名称、服务命令、服务状态、服务执行环境、服务级别、服务拥有
者信息。

[0048] 作为一种可行的实施方式，本申请实施例中的数据中心10可以包括配置单元，用于通过可视化的所述配置界面接收定时任务进程的第一类配置信息和队列服务进程的第
二类配置信息；管理单元，用于当启动定时任务的主进程或队列服务的主进程之后，导入所
述第一类配置信息或所述第二类配置信息，并通过可视化的管理界面对所述第一类配置信
息或所述第二类配置信息进行显示。

[0049] 也即，配置中心用于实现对定时任务进程和队列服务进程的配置，主要涉及定时任务进程和队列服务进程的部分主要执行配置参数。而管理中心可以具备其单独的图形界
面，即可视化的管理界面。在每次启动对应系统定时任务或队列服务的主进程后，将配置中
心的数据新增或更新到管理中心的定时任务或队列服务对应的配置数据中。

[0050] 调度模块20，用于基于预设定时器的设置定时加载所述数据中心的所述第一类配置信息，并直接加载所述第二类配置信息，通过对所述第一类配置信息和所述第二类配置
信息进行验证，确定对应的待执行任务；

[0051] 本申请实施例中，调度模块20可以基于预设定时器的设置，定时地加载数据中心的第一类配置信息，针对第二类配置信息可以直接进行加载。后续可基于第一类配置信息
和第二类配置信息确定出对应的待执行任务。

[0052] 在具体实施中，上述调度模块20可以具体包括：第一加载单元，用于基于预设定时器的设置定时加载所述数据中心的所述第一类配置信息，并判断所述第一类配置信息对应
的定时任务是否允许执行，如果是，则将当前定时任务确定为所述待执行任务；第二加载单
元，用于加载所述数据中心的第二类配置信息，利用预设验证规则筛选满足执行条件的队
列任务确定为所述待执行任务。

[0053] 也即，调度模块中，可包括定时任务对应的第一加载单元和队列服务对应的第二加载单元。其中，第一加载单元可具体依赖于Swoole的定时器Timer，一种毫秒精度的定时
器，底层基于epoll_wait和setitimer实现。其数据结构使用最小堆，可支持添加大量定时
器。而定时器的添加和删除，全部为内存操作，能够达到较高的性能。第一加载单元每秒加
载一次数据中心的第一类配置信息，并进行一轮验证操作，例如，验证定时任务是否允许运
行，任务执行的定时配置是否在当前一秒内可以运行。如果可以运行，将此定时任务传递到
一个通路内，另一个线程接收到通路的数据后即可将任务分发至执行器。

[0054] 上述第二加载单元，其不依赖于定时器的Timer机制，而是在工作进程启动时，直接加载数据中心的配置信息，通过验证规则将满足条件的任务直接分发到执行器去执行。

[0055] 执行器30，用于接收并执行所述调度模块下发的所述待执行任务。

[0056] 可以理解的是，当调度模块20将待执行任务分发至执行器30后，执行器30将展开任务的执行过程。

[0057] 需要说明的是，上述执行器30可以包括：定时任务执行单元，用于对定时任务对应的第一类待执行任务进行执行，在执行完成后输出执行结果并退出执行进程；队列任务执
行单元，用于对队列服务对应的第二类待执行任务进行执行，并利用消息处理引擎Kafka自
动关闭阻塞进程。

[0058] 作为一种可行的实施方式，本申请实施例可在定时任务执行单元中注入三个事件点：任务开始执行、任务执行成功、任务执行失败。通过三个事件点，能够方便收集对应事件
点的数据。在每次任务执行完成后，将结果传给父进程。在每次执行完一个定时任务后，即
退出该执行进程，同时释放了数据库的连接，减少了系统资源的消耗。

[0059] 针对上述队列任务执行单元，本申请实施例不再使用原有Redis的List数据结构，而是使用消息处理引擎Kafka。由于消息处理引擎Kafka的高可用性，能够解决队列消费的
单点问题。由于队列服务通常采用常驻进程，每次启动后进程就一直处于运行状态，每次对
数据库操作之后就会建立对应的数据库连接。本实施例中，基于Kafka的每次阻塞时间，可
设置在几个阻塞时间内没有收到数据时，底层将自动关闭对应的数据库连接，由此解决了
数据库连接无法释放的问题。

[0060] 通过以上方案可知，本申请提供的一种定时任务进程与队列服务进程管理系统，包括：数据中心，用于通过可视化的配置界面接收定时任务进程的第一类配置信息和队列
服务进程的第二类配置信息；所述第一类配置信息中包括定时拉起配置信息；调度模块，用
于基于预设定时器的设置定时加载所述数据中心的所述第一类配置信息，并直接加载所述
第二类配置信息，通过对所述第一类配置信息和所述第二类配置信息进行验证，确定对应
的待执行任务；执行器，用于接收并执行所述调度模块下发的所述待执行任务。由上可知，
本申请中用户可以通过可视化的配置界面对定时任务进程以及队列服务进程进行配置，实
现更加方便直观地对各进程进行配置管理，提升了用户的使用体验；另外通过为定时任务
进程设置定时拉起配置信息，能够解决数据库连接无法释放的问题，避免了系统资源的浪
费。

[0061] 在上述实施例的基础上，本申请实施例对上述数据中心10中的管理中心进行了进一步优化和说明。

[0062] 具体地，管理单元，还可以用于：通过可视化的管理界面显示针对第一类配置信息的附加参数配置子界面，以便通过附加参数配置子界面接收用户终端设置的附加参数；其
中，附加参数可以包括但不限于任务节点、任务超时时间、任务失败重试次数、任务失败重
试时间间隔、任务通知开启/关闭配置信息。

[0063] 也即，通过配置中心，可以对定时任务进程与队列服务进程的主要配置参数进行设置。而在管理中心，还可对定时任务进程增设一些额外的配置参数，作为主要配置参数的
补充。在具体实施中，可在可视化的管理界面显示附加参数配置子界面，例如可在管理界面
的局部位置显示附加参数配置子界面，用户可通过子界面配置补充的附加参数。

[0064] 在一种优选的实施方式中，管理单元还可以用于：通过管理界面对定时任务对应的任务日志进行显示，所述任务日志中可以包括但不限于任务执行开始时间、任务执行结
束时间、任务执行时长、任务开始时对应的初始内存大小、任务结束时对应的目标内存大小
以及执行结果；还可通过管理界面对任务执行时长统计表进行显示，所述任务执行时长统
计表中包括定时任务中所涉及的针对数据表的更新操作记录。

[0065] 可以理解的是，通过可视化的管理界面，用户可以查看和管理对应的定时任务，还可查看任务日志的记录。在管理界面中，还可以显示任务执行时长图表，用于显示定时任务
针对数据表的更新操作记录。通过图像化的方式，显示在某一段时间内运行的各个定时任
务命令，基于此功能，能够直观地看出哪些定时任务是一起运行的。另外，还包括了定时任
务涉及的针对数据表的更新操作记录，通过此功能，可以便于用户分析哪些定时任务的命
令可能会涉及到锁表，能够预先发现并进行防范或解决。

[0066] 在上述任一实施例的基础上，本申请实施例对上述调度模块20进行了进一步优化和说明。

[0067] 可以理解的是，调度模块20主要作为数据中心10和执行器30之间的桥梁。考虑到PHP自带的pcntl组件存在很多不足，如没有提供进程间通信的功能，不支持重定向标准输
入和输出，只提供了fork类型的原始接口，容易使用错误。本申请实施例中，使用Swoole的
Process模块替换了PHP自带的pcntl组件。相较于pcntl组件，Process模块提供了更加强大
的功能，可以方便的实现进程间通信，支持重定向标准输入和输出，同时提供了exec接口，
创建的进程可以执行其他程序，与原PHP父进程之间可以方便的进行通信。

[0068] 需要指出的是，项目中的每个系统都存在对应的主进程，如定时任务和队列服务都具备其对应的主进程，主进程具体用于管理其所在系统下的监控进程和工作进程。其中，
监控进程定时收集运行数据，并基于预先设定的报警规则对每次收集的运行结果数据进行
计算，若达到报警条件，则通过告警接口上报相应的数据。上述工作进程的具体实施过程可
参考前述实施例公开的第一加载单元和第二加载单元的工作流程，在此不再进行赘述。

[0069] 下面对本申请实施例提供的一种定时任务进程与队列服务进程管理方法进行介绍，下文描述的一种定时任务进程与队列服务进程管理方法与上文描述的一种定时任务进
程与队列服务进程管理系统可以相互参照。

[0070] 参见图2所示，本申请实施例提供的一种定时任务进程与队列服务进程管理方法包括：

[0071] S101：通过数据中心可视化的配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息；所述第一类配置信息中包括定时拉起配置信息；

[0072] S102：基于预设定时器的设置，利用调度模块定时加载所述数据中心的所述第一类配置信息，并直接加载所述第二类配置信息，通过对所述第一类配置信息和所述第二类
配置信息进行验证，确定对应的待执行任务；

[0073] S103：将所述待执行任务下发至执行器，以便所述执行器执行所述待执行任务。

[0074] 关于上述步骤S101至S103的具体实施过程可参考前述实施例公开的相应内容，在此不再进行赘述。

[0075] 在上述实施例的基础上，作为一种优选实施方式，所述通过数据中心可视化的配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息的过程可
以包括：

[0076] 通过数据中心可视化的所述配置界面接收定时任务进程的第一类配置信息和队列服务进程的第二类配置信息；

[0077] 当启动定时任务的主进程或队列服务的主进程之后，导入所述第一类配置信息或所述第二类配置信息，并通过数据中心可视化的管理界面对所述第一类配置信息或所述第
二类配置信息进行显示。

[0078] 在上述实施例的基础上，作为一种优选实施方式，所述第一类配置信息，包括：任务名称、任务命令、任务状态、任务执行环境、定时拉起配置信息、任务级别、任务拥有者信
息中任一项或任几项的组合；所述第二类配置信息，包括：服务名称、服务命令、服务状态、
服务执行环境、服务级别、服务拥有者信息中任一项或任几项的组合。

[0079] 在上述实施例的基础上，作为一种优选实施方式，本申请实施例提供的定时任务进程与队列服务进程管理方法还可以进一步包括：

[0080] 通过所述管理界面显示针对所述第一类配置信息的附加参数配置子界面，以便通过所述附加参数配置子界面接收用户终端设置的附加参数；

[0081] 其中，所述附加参数包括任务节点、任务超时时间、任务失败重试次数、任务失败重试时间间隔、任务通知开启/关闭配置信息中任一项或任几项的组合。

[0082] 在上述实施例的基础上，作为一种优选实施方式，本申请实施例提供的定时任务进程与队列服务进程管理方法还可以进一步包括：

[0083] 通过所述管理界面对所述定时任务对应的任务日志进行显示，所述任务日志中包括任务执行开始时间、任务执行结束时间、任务执行时长、任务开始时对应的初始内存大
小、任务结束时对应的目标内存大小以及执行结果中任一项或任几项的组合；

[0084] 通过所述管理界面对任务执行时长统计表进行显示，所述任务执行时长统计表中包括定时任务中所涉及的针对数据表的更新操作记录。

[0085] 在上述实施例的基础上，作为一种优选实施方式，本申请实施例提供的定时任务进程与队列服务进程管理方法还可以进一步包括：

[0086] 基于预设定时器的设置定时加载所述数据中心的所述第一类配置信息，并判断所述第一类配置信息对应的定时任务是否允许执行，如果是，则将当前定时任务确定为所述
待执行任务；

[0087] 加载所述数据中心的第二类配置信息，利用预设验证规则筛选满足执行条件的队列任务确定为所述待执行任务。

[0088] 在上述实施例的基础上，作为一种优选实施方式，所述将所述待执行任务下发至执行器之后，还包括：

[0089] 利用所述执行器对定时任务对应的第一类待执行任务进行执行，在执行完成后输出执行结果并退出执行进程；

[0090] 利用所述执行器对队列服务对应的第二类待执行任务进行执行，并利用消息处理引擎Kafka自动关闭阻塞进程。

[0091] 本申请中，用户可以通过可视化的配置界面对定时任务进程以及队列服务进程进行配置，实现更加方便直观地对各进程进行配置管理，提升了用户的使用体验；另外通过为
定时任务进程设置定时拉起配置信息，能够解决数据库连接无法释放的问题，避免了系统
资源的浪费。

[0092] 说明书中各个实施例采用递进的方式描述，每个实施例重点说明的都是与其他实施例的不同之处，各个实施例之间相同相似部分互相参见即可。对于实施例公开的系统而
言，由于其与实施例公开的方法相对应，所以描述的比较简单，相关之处参见方法部分说明
即可。应当指出，对于本技术领域的普通技术人员来说，在不脱离本申请原理的前提下，还
可以对本申请进行若干改进和修饰，这些改进和修饰也落入本申请权利要求的保护范围
内。

[0093] 还需要说明的是，在本说明书中，诸如第一和第二等之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来，而不一定要求或者暗示这些实体或操作
之间存在任何这种实际的关系或者顺序。而且，术语“包括”、“包含”或者其任何其他变体意
在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、物品或者设备不仅包括那
些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、物品或者
设备所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排
除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同要素。