调度作业新增两种执行模式:广播分片和任务分片
为了提升执行作业的效率,增加调度作业广播分片和任务分片处理功能
补丁号:COSMIC.V4.0.004_0729
特性效果展示
广播分片流程
任务分片流程
分片实现
填写调度作业,选择执行程序的时候,插件会根据类全名去调用微服务接口,判断当前任务类是否存在于当前应用id的微服务jar中,规范任务类的实现
广播分片
如果是广播分片任务类,任务类需要实现kd.bos.schedule.executor.BroadcastTask接口。 广播分片参数的获取方式:
int index = broadcastVO.getIndex(); //当前执行器下标
int total = broadcastVO.getTotal(); //总执行器数量
任务分片
如果是任务分片任务类,任务类需要实现kd.bos.schedule.executor.ShardingTask接口。 任务分片参数的获取方式:
String name = shardingParam.getName(); //分片参数名
String value = shardingParam.getValue(); //分片参数值
页面效果
1、广播分片配置
调度作业页面->执行策略->执行模式->广播分片,广播分片页面配置示例如下。
可在调度计划-调度作业分录-查看日志,查看广播分片执行记录
2、任务分片配置
调度作业页面->执行策略->执行模式->任务分片,任务分片页面配置示例如下。
任务分片的分片参数是必填项,分发任务时是根据分片参数来发起分片调度任务的,有几个分片参数就分发几个任务
任务分片的目的是尽可能多的使用可利用执行服务器,所以分片参数最好不要超过执行服务器台数,因为分片数大于执行服务器台数,如下图执行服务器只有2台,分片参数有4个,每台机器会接收2个任务。当然如果后期会加服务器是可以这么配置的。
调度作业新增两种执行模式:广播分片和任务分片
本文2024-09-23 00:23:20发表“云苍穹知识”栏目。
本文链接:https://wenku.my7c.com/article/kingdee-cangqiong-139148.html