Ein EJB-planen von tasks mit "crontab-syntax"

Finden Sie in der EJB 3.1 @Schedule API. Die API wir wählten für die Skillung ein wenig näher zu Quarz-syntax als cron -- winzigen Abweichungen zwischen den beiden.

Hier ist eine Anmerkung Beispiel:

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();
    }
}

Vollständige Quelle für diese hier

Können Sie das gleiche tun programmgesteuert über die ScheduleExpression Klasse, welche nur eine constructable version der oben genannten Anmerkung. Hier ist, was das obige Beispiel Aussehen würde, wenn der Zeitplan war getan-code:

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();
    }
}

Den Quellcode für dieses Beispiel ist hier

Seite beachten Sie, beide Beispiele sind ausführbar in einem einfachen IDE-und test-Fällen, die Verwendung des Einbettbaren EJBContainer API auch neu in EJB 3.1.

@Schedule vs ScheduleExpression

• @Schedule
  • Statisch konfiguriert
  • Viele planen Methoden sind möglich
  • Nicht möglich, Argumente
  • Können nicht storniert werden

Oben alles geschieht im deployment-descriptor und beschränkt sich daher nur auf Dinge, die konfiguriert werden können, im Voraus. Die dynamischere version verwendet, die nach der Unterzeichnung des TimerService:

TimerService.createCalendarTimer(javax.ejb.ScheduleExpression, javax.ejb.TimerConfig)

• ScheduleExpression
  • Dynamisch erstellt
  • Genau ein @ - Timeout unterstützt alle ScheduleExpression
  • Die timeout-Methode muss javax.ejb.Timer als parameter
  • Argumente übergeben werden können
    • Der Anrufer wraps Argumente in einer TimerConfig.setInfo(Serializable) Objekt
    • Das @ - Timeout-Methode greift auf Sie über Timer.getInfo()
  • Kann aufgehoben werden, indem der Anrufer oder das @ - Timeout-Methode

Beachten Sie auch, dass es ein interceptor @AroundTimeout Anmerkung, dass die Funktionen identisch zu @AroundInvoke und ermöglicht Abfangjäger zur Teilnahme an der bean timer-Funktionalität.

InformationsquelleAutor David Blevins

Werfen Sie einen Blick auf Quarz. Wenn Sie Frühjahr gibt es sehr gute Unterstützung gibt. Eine gepflegte, zuverlässige gut funktionierende Sache.

InformationsquelleAutor lexicore