quartz2.3.0（十二）通過RMI協議向Scheduler調度器遠程添加job任務

此代碼示例通過RMI協議向Scheduler調度器遠程添加job任務。

代碼文件包括：job任務類（SimpleJob.java）、RMI服務端server類（RemoteServerExample.java）、RMI客戶端client類（RemoteClientExample.java）。

注意：job任務類與client客戶端在同一個應用里。

RMI服務端server類（RemoteServerExample.java）

先設置server端的定時配置quartz.properties

#============================================================================
# Configure Main Scheduler Properties  
#============================================================================
org.quartz.scheduler.instanceName: Sched1
org.quartz.scheduler.rmi.export: true         //重點
org.quartz.scheduler.rmi.registryHost: localhost     //重點
org.quartz.scheduler.rmi.registryPort: 1099          //重點
org.quartz.scheduler.rmi.createRegistry: true

#============================================================================
# Configure ThreadPool  
#============================================================================
org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount: 10
org.quartz.threadPool.threadPriority: 5

#============================================================================
# Configure JobStore  
#============================================================================
org.quartz.jobStore.misfireThreshold: 60000
org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore

RemoteServerExample.java 類代碼：

 

package org.quartz.examples.example12;

import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.SchedulerMetaData;
import org.quartz.impl.StdSchedulerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 這個示例將生成大量要運行的作業
 */
public class RemoteServerExample {
    Logger LOG = LoggerFactory.getLogger(RemoteServerExample.class);

    public void run() throws Exception {

        // 初始化一個調度工廠，並實例化一個調度類
        SchedulerFactory sf = new StdSchedulerFactory();
        Scheduler sched = sf.getScheduler();

        sched.start();

        try {
            Thread.sleep(300L * 1000L);
        } catch (Exception e) {
            //
        }

        sched.shutdown(true);
        LOG.info("------- Shutdown Complete -----------------");

        SchedulerMetaData metaData = sched.getMetaData();
        LOG.info("Executed " + metaData.getNumberOfJobsExecuted() + " jobs.");
        
    }

    public static void main(String[] args) throws Exception {

        RemoteServerExample example = new RemoteServerExample();
        example.run();
    }

}

 

 

job任務類（SimpleJob.java）

 

 

package org.quartz.examples.example12;

import java.util.Date;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;

/**
 * 一個愚蠢的作業實現，用於單元測試。
 */
public class SimpleJob implements Job {

    public static final String MESSAGE = "msg";

    private static Logger LOG = LoggerFactory.getLogger(SimpleJob.class);

    // 必須要有public修飾的無參構造函數
    public SimpleJob() {
    }

    // 任務執行方法
    public void execute(JobExecutionContext context) throws JobExecutionException {
        JobKey jobKey = context.getJobDetail().getKey();
        String message = (String) context.getJobDetail().getJobDataMap().get(MESSAGE);
        LOG.info("任務執行1。SimpleJob: " + jobKey + " executing at " + new Date());
        LOG.info("任務執行2。SimpleJob: msg: " + message);
    }

}

 

 

RMI客戶端client類（RemoteClientExample.java）

設置client端的定時配置quartz.properties

org.quartz.scheduler.instanceName: Sched1
org.quartz.scheduler.logger: schedLogger
org.quartz.scheduler.rmi.proxy: true        //重點
org.quartz.scheduler.rmi.registryHost: localhost       //重點
org.quartz.scheduler.rmi.registryPort: 1099            //重點

 

RemoteClientExample.java類代碼：

package org.quartz.examples.example12;

import static org.quartz.CronScheduleBuilder.cronSchedule;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.TriggerBuilder.newTrigger;

import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.Trigger;
import org.quartz.impl.StdSchedulerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 這個示例是一個客戶機程序，它將與調度程序進行遠程通信以調度作業。
 * 在本例中，我們將需要使用JDBC作業存儲。客戶機將遠程連接到JDBC作業存儲以調度作業。
 */
public class RemoteClientExample {
    static Logger LOG = LoggerFactory.getLogger(RemoteClientExample.class);

    public void run() throws Exception {
     // 初始化一個調度工廠，並實例化一個調度類
        SchedulerFactory sf = new StdSchedulerFactory();
        Scheduler sched = sf.getScheduler();

        // 定義一個job任務，遠程添加到調度器的任務  
        // group: default, job: remotelyAddedJob
        JobDetail job = newJob(SimpleJob.class)
            .withIdentity("remotelyAddedJob", "default")
            .build();
        
        JobDataMap map = job.getJobDataMap();
        map.put("msg", "Your remotely added job has executed!");
        
        Trigger trigger = newTrigger()
            .withIdentity("remotelyAddedTrigger", "default")
            .forJob(job.getKey())
            .withSchedule(cronSchedule("0/2 * * * * ?"))
            .build();
        sched.scheduleJob(job, trigger);

        LOG.info("Remote job scheduled.");
    }

    public static void main(String[] args) throws Exception {

        RemoteClientExample example = new RemoteClientExample();
        example.run();
        
    }

}