使用“ crontab语法”进行EJB调度任务

Question

我试图找出解决以下问题的可能性。

a）我想拥有一个使用“ crontab语法”来计划任务的数据库表，其结构将如下所示：

    | -Id- | --- Crontab语法--- || ---------任务---------- |
    | 1 | 30 * * * * * | MyClass.TaskA（args []）|
    | 2 | 0 1 * * 1-5 * | MyClass.TaskB（args []）|
    | | | |

上表将随时由外部应用程序进行修改。添加或删除的任务应立即影响调度程序。

b）调度程序本身应驻留在Java应用程序服务器上。它应该与数据库表中活动的计划任务不断进行同步。每当发生调度事件时，都应触发/调用以“任务”中的值为参数的EJB。

我不是在寻找上述问题的答案。但是，可以将哪些框架用于crontab解析以及应该以哪种方式部署代表调度程序的EJB进行一些输入。

提前致谢。

Answer 1

请参阅EJB 3.1 @ScheduleAPI。我们为该规范选择的API比cron更接近Quartz语法-两者之间的微小差异。

这是一个注释示例：

package org.superbiz.corn;

import javax.ejb.Lock;
import javax.ejb.LockType;
import javax.ejb.Schedule;
import javax.ejb.Schedules;
import javax.ejb.Singleton;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * This is where we schedule all of Farmer Brown's corn jobs
 */
@Singleton
@Lock(LockType.READ) // allows timers to execute in parallel
public class FarmerBrown {

    private final AtomicInteger checks = new AtomicInteger();

    @Schedules({
            @Schedule(month = "5", dayOfMonth = "20-Last", minute = "0", hour = "8"),
            @Schedule(month = "6", dayOfMonth = "1-10", minute = "0", hour = "8")
    })
    private void plantTheCorn() {
        // Dig out the planter!!!
    }

    @Schedules({
            @Schedule(month = "9", dayOfMonth = "20-Last", minute = "0", hour = "8"),
            @Schedule(month = "10", dayOfMonth = "1-10", minute = "0", hour = "8")
    })
    private void harvestTheCorn() {
        // Dig out the combine!!!
    }

    @Schedule(second = "*", minute = "*", hour = "*")
    private void checkOnTheDaughters() {
        checks.incrementAndGet();
    }

    public int getChecks() {
        return checks.get();
    }
}

完整的源代码在这里

您可以通过ScheduleExpression类以编程方式执行相同的操作，该类只是上述批注的可构造版本。如果计划是在代码中完成的，则上面的示例如下所示：

package org.superbiz.corn;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import javax.ejb.Lock;
import javax.ejb.LockType;
import javax.ejb.ScheduleExpression;
import javax.ejb.Singleton;
import javax.ejb.Startup;
import javax.ejb.Timeout;
import javax.ejb.Timer;
import javax.ejb.TimerConfig;
import javax.ejb.TimerService;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * This is where we schedule all of Farmer Brown's corn jobs
 *
 * @version $Revision$ $Date$
 */
@Singleton
@Lock(LockType.READ) // allows timers to execute in parallel
@Startup
public class FarmerBrown {

    private final AtomicInteger checks = new AtomicInteger();

    @Resource
    private TimerService timerService;

    @PostConstruct
    private void construct() {
        final TimerConfig plantTheCorn = new TimerConfig("plantTheCorn", false);
        timerService.createCalendarTimer(new ScheduleExpression().month(5).dayOfMonth("20-Last").minute(0).hour(8), plantTheCorn);
        timerService.createCalendarTimer(new ScheduleExpression().month(6).dayOfMonth("1-10").minute(0).hour(8), plantTheCorn);

        final TimerConfig harvestTheCorn = new TimerConfig("harvestTheCorn", false);
        timerService.createCalendarTimer(new ScheduleExpression().month(9).dayOfMonth("20-Last").minute(0).hour(8), harvestTheCorn);
        timerService.createCalendarTimer(new ScheduleExpression().month(10).dayOfMonth("1-10").minute(0).hour(8), harvestTheCorn);

        final TimerConfig checkOnTheDaughters = new TimerConfig("checkOnTheDaughters", false);
        timerService.createCalendarTimer(new ScheduleExpression().second("*").minute("*").hour("*"), checkOnTheDaughters);
    }

    @Timeout
    public void timeout(Timer timer) {
        if ("plantTheCorn".equals(timer.getInfo())) {
            plantTheCorn();
        } else if ("harvestTheCorn".equals(timer.getInfo())) {
            harvestTheCorn();
        } else if ("checkOnTheDaughters".equals(timer.getInfo())) {
            checkOnTheDaughters();
        }
    }

    private void plantTheCorn() {
        // Dig out the planter!!!
    }

    private void harvestTheCorn() {
        // Dig out the combine!!!
    }

    private void checkOnTheDaughters() {
        checks.incrementAndGet();
    }

    public int getChecks() {
        return checks.get();
    }
}

此示例的来源在这里

附带说明，两个示例都可以在纯IDE中运行，并且具有使用Embeddable
EJBContainer
API的测试用例，这也是EJB 3.1中的新增功能。

@Schedule vs ScheduleExpression

• @时间表
  • 静态配置
  • 可能有许多调度方法
  • 无法传递参数
  • 无法取消

以上都是在部署描述符中完成的，因此仅限于可以预先配置的内容。动态性更高的版本使用TimerService的以下签名：

TimerService.createCalendarTimer（javax.ejb.ScheduleExpression，javax.ejb.TimerConfig）

• ScheduleExpression
  • 动态创建
  • 恰好一个@Timeout支持所有ScheduleExpression
  • 超时方法必须javax.ejb.Timer作为参数
  • 可以传递参数
  • 调用方将参数包装在TimerConfig.setInfo（Serializable）对象中
  • @Timeout方法通过Timer.getInfo（）访问它们
  • 可以被调用者或@Timeout方法取消

还要注意，这里有一个拦截器@AroundTimeout注释，其功能与拦截器相同，@AroundInvoke并允许拦截器参与bean的计时器功能。