`

scheduler 的使用

阅读更多
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>
分享到:
评论

相关推荐

    STK Scheduler使用向导

    ### STK Scheduler 使用向导详解 #### 一、引言 本教程旨在引导您熟悉 **STK (System Tool Kit)/Scheduler** 的基本功能与特性。通过本教程的学习,您将能够启动 STK/Scheduler 模块,指定规划周期,定义各种任务...

    DolphinScheduler+海豚

    因此,确保DolphinScheduler使用的Hive Jar包版本与Hadoop集群中Hive的版本一致是非常重要的。 #### 二、错误日志解析 根据题目提供的部分日志内容,“/opt/apache-dolphinscheduler-3.1.7/api-server/logs/...

    dolphinscheduler配置

    DolphinScheduler是一款强大的分布式工作流调度系统,用于大数据处理任务的编排和管理。在这个配置过程中,我们将探讨如何将Dolphinscheduler与Hadoop、Spark、Hive、DataX、Python和Scala集成,以实现高效的数据...

    mysql event scheduler 使用笔记

    NULL 博文链接:https://chembo.iteye.com/blog/896941

    简单易用的java定时器scheduler,有完整配置说明

    在Java中,我们可以使用多种方式实现定时任务,如Java的`java.util.Timer`类、`java.util.concurrent.ScheduledExecutorService`,以及第三方库如Quartz Scheduler和Spring Framework的`@Scheduled`注解。...

    quartz scheduler 入门教程

    Quartz Scheduler 是一种功能丰富、开源的任务调度程序库,可以在任何 Java 程序中使用。它可以用来创建简单或者复杂的执行次数可以达成千上万的任务。任务可以是任何 Java 可以做的事情。 什么是 Quartz Scheduler...

    k8s部署dolphinscheduler3.1.2 踩坑记录

    k8s部署dolphinscheduler 踩坑记录3.1.2,全流程

    Spring TaskScheduler使用实例解析

    Spring TaskScheduler使用实例解析 Spring TaskScheduler是Spring框架中的一种计划任务管理组件,提供对计划任务的支持,允许开发者通过注解来定义计划任务。下面我们来详细解释Spring TaskScheduler的使用实例。 ...

    DolphinScheduler.docx

    9. **ZooKeeper**:作为集群管理和容错的基础,DolphinScheduler使用ZooKeeper实现节点发现、事件监听和分布式锁。 10. **Task Queue**:任务队列是协调MasterServer和WorkerServer之间通信的关键,用于任务分配和...

    centos apache-dolphinscheduler-3.2.1-bin.tar安装包

    将下载的 `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使用,让大家在实战中掌握DolphinScheduler。

    MySQL 进阶之大数据分布式任务调度系统:DolphinScheduler任务调度系统 v3.1.8

    DolphinScheduler使用DAG(Directed Acyclic Graph)来编排任务流程,这意味着任务之间可以有复杂的依赖关系,同时保证不会出现循环依赖。这种方式使得任务的编排和管理变得直观和灵活,您可以轻松地定义任务之间的...

    【Android 进程保活】应用进程拉活 ( JobScheduler 拉活 ).zip

    【Android 进程保活】应用进程拉活 ( JobScheduler 拉活 | JobScheduler 使用流程 | JobService 服务 | 不同版本兼容 | 源码资源 ) https://hanshuliang.blog.csdn.net/article/details/115584240 博客源码快照

    Spring @Scheduler使用cron表达式时的执行问题详解

    在Spring框架中,`@Scheduler`注解是用于创建定时任务的一个强大工具,它结合了`CronTrigger`,使得我们可以使用cron表达式来定义任务的执行周期。cron表达式是一种广泛使用的定时语法,用于定义任务在特定日期和...

    dhtmlxscheduler

    你需要配置Controller来处理HTTP请求,与数据库交互,并返回JSON格式的数据供scheduler使用。 7. **Spring Security**:确保用户只有在正确认证和授权后才能访问和修改日程数据。 8. **版本控制**:使用Git或其他...

    apache-dolphinscheduler-3.1.4-src.tar.gz

    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....

    dolphinscheduler安装包和mysql的jdbc连接jar包

    4. 初始化数据库:使用DolphinScheduler提供的SQL脚本对数据库进行初始化,创建必要的表和索引。 5. 启动DolphinScheduler:运行启动脚本,如`bin/start-dolphinscheduler.sh`,启动DolphinScheduler服务器。 6. ...

    dolphinscheduler3.18源码包+Helm v3.12.3二进制安装包

    Helm是Kubernetes的包管理工具,它使用Charts来打包和部署应用。在Kubernetes环境中,Helm的作用主要体现在以下几个方面: 1. **Charts**:Charts是Helm的打包格式,它包含了Kubernetes的资源定义(如Deployment、...

Global site tag (gtag.js) - Google Analytics