分布式定时任务调度框架实践

Posted 2022-01-27 vivo互联网技术

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了分布式定时任务调度框架实践相关的知识，希望对你有一定的参考价值。

OfflineTaskExecutorFacade offlineTaskExecutorFacade; ReturnT<String> Exception XxlJobLogger.log( offlineTaskExecutorFacade.executeOfflineTask(); (Exception e) XxlJobLogger.log(, e); FAIL; XxlJobLogger.log( SUCCESS; ReturnT<String> Exception ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo(); XxlJobLogger.log( (i = (i == shardingVO.getIndex()) XxlJobLogger.log( XxlJobLogger.log( SUCCESS; = = OfflineTaskExecutorFacade offlineTaskExecutorFacade;

SpringApplication.run(XxlJobExecutorApplication.class, args); ZookeeperRegistryCenter regCenter(String serverList, String namespace) new ZookeeperRegistryCenter(new ZookeeperConfiguration(serverList, namespace)); DataSourceProperties url; username; password; DataSource getDataSource() DruidDataSource dataSource = DruidDataSource(); dataSource.setUrl(url); dataSource.setUsername(username); dataSource.setPassword(password); dataSource; DataSource dataSource; JobEventConfiguration JobEventRdbConfiguration(dataSource); ElasticSimpleJob value() cron() jobName() int shardingTotalCount() shardingItemParameters() jobParameter() ElasticJobAutoConfiguration serverList; ApplicationContext applicationContext; DataSource dataSource; initElasticJob() ZookeeperRegistryCenter regCenter = ZookeeperRegistryCenter(ZookeeperConfiguration(serverList, regCenter.init(); Map< (Map.Entry< SimpleJob simpleJob = entry.getValue(); ElasticSimpleJob elasticSimpleJobAnnotation = simpleJob.getClass().getAnnotation(ElasticSimpleJob.class); cron = StringUtils.defaultIfBlank(elasticSimpleJobAnnotation.cron(), elasticSimpleJobAnnotation.value()); SimpleJobConfiguration simpleJobConfiguration = SimpleJobConfiguration(JobCoreConfiguration.newBuilder(simpleJob.getClass().getName(), cron, elasticSimpleJobAnnotation.shardingTotalCount()).shardingItemParameters(elasticSimpleJobAnnotation.shardingItemParameters()).build(), simpleJob.getClass().getCanonicalName()); LiteJobConfiguration liteJobConfiguration = LiteJobConfiguration.newBuilder(simpleJobConfiguration).overwrite( JobEventRdbConfiguration jobEventRdbConfiguration = JobEventRdbConfiguration(dataSource); SpringJobScheduler jobScheduler = SpringJobScheduler(simpleJob, regCenter, liteJobConfiguration, jobEventRdbConfiguration); jobScheduler.init(); cron = jobName = shardingTotalCount = jobParameter = shardingItemParameters = Logger logger = LoggerFactory.getLogger(OfflineTaskJob.class); OfflineTaskExecutorFacade offlineTaskExecutorFacade; offlineTaskExecutorFacade.executeOfflineTask(); logger.info(String.format(+ + , Thread.currentThread().getId(), shardingContext.getShardingTotalCount(), shardingContext.getShardingItem(), shardingContext.getShardingParameter(), shardingContext.getJobName(), shardingContext.getJobParameter() ));