1.一种任务处理方法,其特征在于,所述任务处理方法包括:
响应于多个任务执行请求,对所述多个任务执行请求进行分组,得到多个任务执行请求组;
根据每个任务执行请求组的组标识确定项目处理队列,并将每个任务执行请求组中的任务执行请求分配给对应的项目处理队列,其中,不同的项目处理队列在物理层相互隔离;
调用执行节点组执行多个所述项目处理队列中的任务执行请求;
监控所述执行节点组中每个执行节点的执行情况,当任意一个执行节点的执行情况为异常时,通过所述执行节点组在多个候选备用节点中选举一个副执行节点;
根据所述副执行节点更新所述执行节点组,并调用更新后的执行节点组执行多个所述项目处理队列中的任务执行请求;
所述对所述多个任务执行请求进行分组,得到多个任务执行请求组,包括:解析每个任务执行请求的报文头,得到所述报文头携带的地址信息;在预设的地址权限数据库中,查询与所述地址信息匹配的权限信息;根据所述权限信息对所述多个任务执行请求进行分组,得到多个任务执行请求组;
所述监控所述执行节点组中每个执行节点的执行情况,包括:按照预设时间间隔获取所述执行节点的工作状态信息;根据所述工作状态信息确定所述执行节点的健康程度;当所述健康程度低于预设的健康程度阈值时,确定所述执行节点执行的执行情况为异常;
所述通过所述执行节点组在多个候选备用节点中选举一个副执行节点包括:在多个备用节点中确定当前处于空闲状态的多个空闲备用节点;确定每个空闲备用节点的处理任务量;计算所述执行情况为异常的执行节点对应的项目处理队列中的剩余任务量;根据所述剩余任务量及每个空闲备用节点的处理任务量筛选出多个候选备用节点;通过所述执行节点组中剩余的执行节点对每个候选备用节点进行投票;根据每个候选备用节点的投票结果筛选出副执行节点;其中,所述计算所述执行情况为异常的执行节点对应的项目处理队列中的剩余任务量包括:确定所述执行情况为异常的执行节点对应的项目处理队列中的剩余任务执行请求;获取所述剩余任务执行请求对应的剩余文档数据;对所述剩余文档数据进行切分得到多个文档子数据,提取每个文档子数据的文档子向量,并根据多个所述文档子向量生成文档矩阵;采用预先训练的处理量预测模型基于所述文档矩阵预测出所述执行情况为异常的执行节点对应的项目处理队列中的剩余任务量。
2.根据权利要求1所述的任务处理方法,其特征在于,所述将每个任务执行请求组中的任务执行请求分配给对应的项目处理队列包括:获取每个任务执行请求组中每个任务执行请求对应的执行时间;
计算所述执行时间与当前时间的时间差;
根据所述时间差将每个任务执行请求写入对应的项目处理队列。
3.根据权利要求1所述的任务处理方法,其特征在于,所述监控所述执行节点组中每个执行节点的执行情况包括:当所述健康程度等于或高于所述预设的健康程度阈值时,确定所述执行节点执行的执行情况为正常。
4.根据权利要求1至3中任意一项所述的任务处理方法,其特征在于,所述方法还包括:按照预设的时间间隔确定所述更新后的执行节点组的剩余任务执行请求量;
计算所述剩余任务执行请求量的完成时间;
当所述完成时间晚于预设时间时,在所述更新后的执行节点组中增加执行节点;
当所述完成时间早于所述预设时间时,减少所述更新后的执行节点组中的执行节点。
5.一种任务处理装置,其特征在于,包括:
请求处理模块,用于响应于多个任务执行请求,对所述多个任务执行请求进行分组,得到多个任务执行请求组;
请求分配模块,用于根据每个任务执行请求组的组标识确定项目处理队列,并将每个任务执行请求组中的任务执行请求分配给对应的项目处理队列,其中,不同的项目处理队列在物理层相互隔离;
请求执行模块,用于调用执行节点组执行多个所述项目处理队列中的任务执行请求;
节点监控模块,用于监控所述执行节点组中每个执行节点的执行情况,当任意一个执行节点的执行情况为异常时,通过所述执行节点组在多个候选备用节点中选举一个副执行节点;
节点替换模块,用于根据所述副执行节点更新所述执行节点组,并调用更新后的执行节点组执行多个所述项目处理队列中的任务执行请求;
所述对所述多个任务执行请求进行分组,得到多个任务执行请求组,包括:解析每个任务执行请求的报文头,得到所述报文头携带的地址信息;在预设的地址权限数据库中,查询与所述地址信息匹配的权限信息;根据所述权限信息对所述多个任务执行请求进行分组,得到多个任务执行请求组;
所述监控所述执行节点组中每个执行节点的执行情况,包括:按照预设时间间隔获取所述执行节点的工作状态信息;根据所述工作状态信息确定所述执行节点的健康程度;当所述健康程度低于预设的健康程度阈值时,确定所述执行节点执行的执行情况为异常;
所述通过所述执行节点组在多个候选备用节点中选举一个副执行节点包括:在多个备用节点中确定当前处于空闲状态的多个空闲备用节点;确定每个空闲备用节点的处理任务量;计算所述执行情况为异常的执行节点对应的项目处理队列中的剩余任务量;根据所述剩余任务量及每个空闲备用节点的处理任务量筛选出多个候选备用节点;通过所述执行节点组中剩余的执行节点对每个候选备用节点进行投票;根据每个候选备用节点的投票结果筛选出副执行节点;其中,所述计算所述执行情况为异常的执行节点对应的项目处理队列中的剩余任务量包括:确定所述执行情况为异常的执行节点对应的项目处理队列中的剩余任务执行请求;获取所述剩余任务执行请求对应的剩余文档数据;对所述剩余文档数据进行切分得到多个文档子数据,提取每个文档子数据的文档子向量,并根据多个所述文档子向量生成文档矩阵;采用预先训练的处理量预测模型基于所述文档矩阵预测出所述执行情况为异常的执行节点对应的项目处理队列中的剩余任务量。
6.一种计算机设备,其特征在于,所述计算机设备包括存储器和处理器;
所述存储器,用于存储计算机程序;
所述处理器,用于执行所述计算机程序时实现如权利要求1至4中任一项所述的任务处理方法。
7.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质存储有计算机程序,所述计算机程序被处理器执行时实现如权利要求1至4中任一项所述的任务处理方法。