`
- 浏览:
38872 次
- 性别:
- 来自:
上海
-
1:scheduler 自动调配任务的使用:
开发组件,SSH。 我这里用的是SSH,当然也可用其他的方法
2: 首先应该建立一个schedule 来管理我们使用的任务时间等
public class BidBoardFinalizeScheduler {
// Static Logger variable
private static final Logger logger = Logger
.getLogger(BidBoardFinalizeScheduler.class.getName());
public BidBoardFinalizeScheduler() throws BBSystemException,
BBSystemException {
scheduleFinalizeJob();
}
private void scheduleFinalizeJob() throws BBSystemException {
// fields declaration
SchedulerFactory schedulerFactory = null;
Scheduler scheduler = null;
JobDetail jobDetail = null;
SimpleTrigger simpleTrigger = null;
try {
schedulerFactory = new StdSchedulerFactory();
scheduler = schedulerFactory.getScheduler();
jobDetail = new JobDetail(BBCommonConstants.Finalize,
Scheduler.DEFAULT_GROUP, BidboradFinalizeJob.class);
simpleTrigger = new SimpleTrigger("myFinalizetrigger",
Scheduler.DEFAULT_GROUP, 5000, 90000); // 15minutes
try {
scheduler.scheduleJob(jobDetail, simpleTrigger);
} catch (SchedulerException e) {
logger.debug("Exception occured in invokeJob ");
throw BBUtil.getBBSystemException(e,
BBMessageConstants.ERROR_WHILE_SCHEDULING_JOB);
}
scheduler.start();
} catch (BBSystemException e) {
logger.error("scheduler could not be intialized");
throw BBUtil.getBBSystemException(BBMessageConstants.OBJECTS_NULL);
} catch (Exception exception) {
logger.debug("Error while Initializing Scheduler");
}
}
}
3: 我们应该接着写一个job类文件,在这个类里我们调用DAO 以及 SERVICE层,就是我们要执行的功能, 而且这个类我们必须要实现job类的一个接口,而且实现它的execute方法。
public class BidboradFinalizeJob implements StatefulJob {
public void execute(JobExecutionContext arg0) {
// variable declaration
CommonService commonService = null;
try {
commonService = getBidBoardServiceFactory().getCommonService();
commonService.bidBoardFinalize();
} catch (BBSystemException e) {
e.printStackTrace();
}
}
public static synchronized BidBoardServiceFactory getBidBoardServiceFactory()
throws BBSystemException {
BidBoardServiceFactory bbServiceFactory = null;
if (null == bbServiceFactory) {
bbServiceFactory = (BidBoardServiceFactory) SpringContextSupport
.getBean(BBCommonConstants.BIDBOARDSERVICE_FACTORY);
}
return bbServiceFactory;
}
}
4: 等配置完这些之后,我们只需要在bean.xml 的配置文件中,加入我们要实例化的这个即可
如何: <bean id="bidBoardFializeScheduler"
class="com.fritolay.bidboard.service.bidsheet.BidBoardFinalizeScheduler" singleton ="true">
</bean>
分享到:
Global site tag (gtag.js) - Google Analytics
相关推荐
### STK Scheduler 使用向导详解 #### 一、引言 本教程旨在引导您熟悉 **STK (System Tool Kit)/Scheduler** 的基本功能与特性。通过本教程的学习,您将能够启动 STK/Scheduler 模块,指定规划周期,定义各种任务...
因此,确保DolphinScheduler使用的Hive Jar包版本与Hadoop集群中Hive的版本一致是非常重要的。 #### 二、错误日志解析 根据题目提供的部分日志内容,“/opt/apache-dolphinscheduler-3.1.7/api-server/logs/...
DolphinScheduler是一款强大的分布式工作流调度系统,用于大数据处理任务的编排和管理。在这个配置过程中,我们将探讨如何将Dolphinscheduler与Hadoop、Spark、Hive、DataX、Python和Scala集成,以实现高效的数据...
NULL 博文链接:https://chembo.iteye.com/blog/896941
在Java中,我们可以使用多种方式实现定时任务,如Java的`java.util.Timer`类、`java.util.concurrent.ScheduledExecutorService`,以及第三方库如Quartz Scheduler和Spring Framework的`@Scheduled`注解。...
k8s部署dolphinscheduler 踩坑记录3.1.2,全流程
Quartz Scheduler 是一种功能丰富、开源的任务调度程序库,可以在任何 Java 程序中使用。它可以用来创建简单或者复杂的执行次数可以达成千上万的任务。任务可以是任何 Java 可以做的事情。 什么是 Quartz Scheduler...
Spring TaskScheduler使用实例解析 Spring TaskScheduler是Spring框架中的一种计划任务管理组件,提供对计划任务的支持,允许开发者通过注解来定义计划任务。下面我们来详细解释Spring TaskScheduler的使用实例。 ...
9. **ZooKeeper**:作为集群管理和容错的基础,DolphinScheduler使用ZooKeeper实现节点发现、事件监听和分布式锁。 10. **Task Queue**:任务队列是协调MasterServer和WorkerServer之间通信的关键,用于任务分配和...
将下载的 `apache-dolphinscheduler-3.2.1-bin.tar` 文件上传到 CentOS 服务器的任意目录,例如 `/home/user/`,然后使用 `tar -zxvf apache-dolphinscheduler-3.2.1-bin.tar` 解压。 3. **配置环境变量**: 在 `...
本课程会带大家深入DolphinScheduler框架源码,包括设计的思想和技术都会讲解,DolphinScheduler源码很多,会按照模块进行讲解,学习完课程后,不仅可以熟悉DolphinScheduler使用,而且可以掌握很多优秀的设计思想和...
基于DolphinScheduler构建大数据调度平台,课程会带大家构建DolphinScheduler大数据调度平台,实战讲解多种任务调度配置,会基于案例讲解DolphinScheduler使用,让大家在实战中掌握DolphinScheduler。
DolphinScheduler使用DAG(Directed Acyclic Graph)来编排任务流程,这意味着任务之间可以有复杂的依赖关系,同时保证不会出现循环依赖。这种方式使得任务的编排和管理变得直观和灵活,您可以轻松地定义任务之间的...
【Android 进程保活】应用进程拉活 ( JobScheduler 拉活 | JobScheduler 使用流程 | JobService 服务 | 不同版本兼容 | 源码资源 ) https://hanshuliang.blog.csdn.net/article/details/115584240 博客源码快照
在Spring框架中,`@Scheduler`注解是用于创建定时任务的一个强大工具,它结合了`CronTrigger`,使得我们可以使用cron表达式来定义任务的执行周期。cron表达式是一种广泛使用的定时语法,用于定义任务在特定日期和...
你需要配置Controller来处理HTTP请求,与数据库交互,并返回JSON格式的数据供scheduler使用。 7. **Spring Security**:确保用户只有在正确认证和授权后才能访问和修改日程数据。 8. **版本控制**:使用Git或其他...
apache-dolphinscheduler-3.1.4-src.tar.gzapache-dolphinscheduler-3.1.4-src.tar.gzapache-dolphinscheduler-3.1.4-src.tar.gzapache-dolphinscheduler-3.1.4-src.tar.gzapache-dolphinscheduler-3.1.4-src.tar....
4. 初始化数据库:使用DolphinScheduler提供的SQL脚本对数据库进行初始化,创建必要的表和索引。 5. 启动DolphinScheduler:运行启动脚本,如`bin/start-dolphinscheduler.sh`,启动DolphinScheduler服务器。 6. ...
dolphinscheduler 1.3.6 编译镜像,用于编译dolphinscheduler