Tag: job scheduling

使用Quartz-scheduler在Jobs中的自定义对象参数

我正在测试Quartz来安排工作。 但是,该作业包含3个不可序列化的参数。 我在下面创建了一个示例应用程序,指示我如何实现该function。 有谁知道如何使用Quartz将自定义对象用作参数? 下面是调度工作的触发器,我已经评论了给我问题的区域。 public class Trigger { public void run() throws Exception { SchedulerFactory sf = new StdSchedulerFactory(); Scheduler sched = sf.getScheduler(); Date startTime = DateBuilder.nextGivenSecondDate(null, 15); JobDetail job = newJob(SimpleJob.class) .withIdentity(“job6”, “group1”) .build(); SimpleTrigger trigger = newTrigger() .withIdentity(“trigger6”, “group1”) .startAt(startTime) .withSchedule(simpleSchedule() .withIntervalInSeconds(60) .repeatForever()) .build(); Date ft = sched.scheduleJob(job, trigger); TestObject testObject = […]

Spring + Quartz重新安排或更新触发器?

我使用的是Spring 3.2和Quartz 2.2 。 我的target Class和method , public class Producer { public void executeListener() { System.out.println(” Test Method . “); } } 在我的spring applicationContext.xml , <!– –> 上面的代码正常工作, executeListener()连续执行,间隔为5 seconds ,启动延迟为10 sec 。 我试过在spring controller中更新触发器, @Controller public class SpringController { @Autowired org.springframework.scheduling.quartz.SchedulerFactoryBean myScheduler; @Autowired org.springframework.scheduling.quartz.SimpleTriggerFactoryBean oldTrigger; @RequestMapping(value=”/reSheduleTrigger.html”,method=RequestMethod.POST) public @ResponseBody String reSheduleTrigger(@RequestParam(value=”triggerInSec”) String triggerInSec ){ System.out.println(“—————– […]

在集群环境中使用Quartz

我希望在我的应用程序中使用quartz调度程序,因为我有一个集群环境,并且希望保证每小时只运行一个我的作业实例。 我的问题是……我是否必须使用JDBC作业存储或作业数据的某种“外部”存储来保证我的集群中只有一个实例在任何给定的时间运行该作业,或者对Quartz来说是否有更多魔力我知道吗?

Quartz Scheduler:在每个集群节点上触发一些作业,每个集群只触发一些作业

我在集群环境中使用Quartz Scheduler作为Spring bean。 我有一些使用@NotConcurrent注释的作业,它们每个集群运行一次(即仅在一个节点中,仅在一个线程中)。 现在我需要在集群的每个节点上运行一个作业。 我删除了@NotConcurrent注释,但它只在一台机器上的每个线程上运行。 它不会在其他节点上被触发。 我应该用什么来诠释这份工作? 示例:Job1 NotConcurrent annotated安排在午夜=>它每隔午夜只在一台机器上触发。 Job2注释安排在午夜=>它每隔午夜在每台机器上启动。 谢谢。

分布式作业调度,管理和报告

我最近玩过Hadoop ,并对MapReduce作业的调度,管理和报告印象深刻。 它似乎使新工作的分配和执行非常无缝,使开发人员能够专注于他们的工作实施。 我想知道Java域中是否存在任何不容易表示为MapReduce问题的作业的分布式执行? 例如: 需要任务协调和同步的工作。 例如,它们可能涉及顺序执行任务,但同时执行某些任务是可行的: .– B –. .–A –| |–. | ‘– C –‘ | Start –| |– Done | | ‘–D ————-‘ 您希望分发但不提供任何输出以减少的CPU密集型任务 – 例如,图像转换/resize。 那么是否有一个提供这种分布式计算环境的Java框架/平台? 或者这种事情是否可以使用Hadoop接受/可实现 – 如果有的话,这些工作的模式/指南是什么?

如何检查Quartz cron作业是否正在运行?

如何检查计划的Quartz cron作业是否正在运行? 有任何API可以进行检查吗?