iis怎么做网站,互联网行业发展,网站开发微信,品牌建设全过程一、xxl-job的作用 1. 解决集群任务的重复执行问题。 2. cron表达式定义灵活。 3. 定时任务失败了#xff0c;重试和统计。 4. 任务量大#xff0c;分片执行。
二、xxl-job路由策略 1. FIRST#xff08;第一个#xff09;#xff1a;固定选择第一个机器。 2. LAST#x…一、xxl-job的作用 1. 解决集群任务的重复执行问题。 2. cron表达式定义灵活。 3. 定时任务失败了重试和统计。 4. 任务量大分片执行。
二、xxl-job路由策略 1. FIRST第一个固定选择第一个机器。 2. LAST最后一个固定选择最后一个机器。 3. ROUND轮询。 4. RANDOM随机随机选择在线的机器。 5. CONSISTENT_HASH一致性HASH每个任务按照Hash算法固定选择某一台机器且所有任务均匀散列在不同机器上。 6. LEAST_FREQUENTLY_USED最不经常使用使用频率最低的机器优先被选举。 7. LEAST_RECENTLY_USED最近最久未使用最久未使用的机器优先被选举。 8. FAILOVER故障转移按照顺序依次进行心跳检测第一个心跳检测成功的机器选定为目标执行器并发起调度。 9. BUSYOVER忙碌转移按照顺序依次进行空闲检测第一个空闲检测成功的机器选定为目标执行器并发起调度。 10. SHARDING_BROADCAST(分片广播)广播触发对应集群中所有机器执行一次任务同时系统自动传递分片参数可根据分片参数开发分片任务。
三、xxl-job执行失败 故障转移失败重试查看日志分析---- 邮件告警。
四、处理大量并发任务 执行器集群部署时任务路由策略选择分片广播情况下一次任务调度将会广播触发对应集群中所有执行器执行一次任务。 分片参数1. index当前分片序号(从0开始)执行器集群列表中当前执行器的序号。 2. total总分片数执行器集群的总机器数量。 具体代码如下
XxlJob(shadingSample)public void shardingJobHandler() throws Exception {// 分片参数int shardIndex XxlJobHelper.getShardIndex();int shardTotal XxlJobHelper.getShardTotal();XxlJobHelper.log(分片参数当前分片序号 {}, 总分片数 {}, shardIndex, shardTotal);// 业务逻辑ListInteger list getList();for (Integer integer : list) {if (integer % shardTotal shardIndex) {System.out.println(第 shardIndex 分片执行执行数据为 integer);}}}
五、面试题
面试官xxl-job路由策略有哪些
候选人xxl-job提供了很多的路由策略我们平时用的较多就是轮询、故障转移、分片广播…
面试官xxl-job任务执行失败怎么解决
候选人有这么几个操作
第一路由策略选择故障转移优先使用健康的实例来执行任务。
第二如果还有失败的我们在创建任务时可以设置重试次数。
第三如果还有失败的就可以查看日志或者配置邮件告警来通知相关负责人解决。
面试官如果有大数据量的任务同时都需要执行怎么解决
候选人我们会让部署多个实例共同去执行这些批量的任务其中任务的路由策略是分片广播
在任务执行的代码中可以获取分片总数和当前分片按照取模的方式分摊到各个实例执行就可以。
