Spring中的Quartz任务没有启动

Question

我正在使用Spring的SchedulerFactoryBean动态调度作业。 这是我的Spring配置：

@Configuration
public class SpringConfigBean {
    @Bean
    public DataSource dataSource() throws NamingException{
        InitialContext ctx = new InitialContext();
        DataSource source = (DataSource) ctx.lookup(dataSourceName);
        return source;
    }

    @Bean
    public SchedulerFactoryBean schedulerFactoryBean() throws NamingException {
        SchedulerFactoryBean schedulerFactoryBean = null;
        try {
            schedulerFactoryBean = new SchedulerFactoryBean();
            schedulerFactoryBean.setDataSource(dataSource());
            schedulerFactoryBean.setQuartzProperties(com.orca.integration.plugins.vs.broadpeak.admin.utils.Configuration.getQuartzProperties());
            schedulerFactoryBean.setAutoStartup(false);
        } catch (SchedulingException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return schedulerFactoryBean;
    }

}

Here is my job:

@Component
public class MyJob extends QuartzJobBean {

    @Override
    public void executeInternal(JobExecutionContext context) throws JobExecutionException {
        System.out.println("Start job...");
}
}

这是我动态调度任务的位置：

@Component
public class MyManager {
    @Autowired
    private SchedulerFactoryBean schedulerFactoryBean;

    public void myMethod(String text, Calendar startDate) {
        logger.debug("BroadpeakDistributionManager.startRecordingChannel(); Parameters: recording channel ID=" + recordingChannel.getExternalId());

//      StartRecordJob.scheduleMe(text, startDate, "Start");

        JobDetailBean jobDetailBean = new JobDetailBean();
        jobDetailBean.setJobClass(MyJob.class);
        jobDetailBean.setName("name");
        jobDetailBean.afterPropertiesSet();

        SimpleTriggerBean simpleTriggerBean = new SimpleTriggerBean();
        simpleTriggerBean.setJobDetail(jobDetailBean);
        simpleTriggerBean.setName("Name");
        simpleTriggerBean.setStartTime(startDate.getTime());
        try {
            simpleTriggerBean.afterPropertiesSet();
        } catch (ParseException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        schedulerFactoryBean.setTriggers(new Trigger[] {simpleTriggerBean});
        schedulerFactoryBean.start();
    }
}

工作还未开始。 我做错了什么？

- Nel

Answer 1

我没有使用Spring进行编程配置的经验。因此，我编写了这个XML Spring应用程序上下文配置，并将其与Quartz集成。

看一下：

<!-- You can inject other sping beans here -->
<bean id="myJob" class="your.package.here.MyJob "/>

<!-- Define your target method -->
<bean id="jobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
  <property name="targetObject" ref="myJob" />
  <property name="targetMethod" value="executeInternal" />
</bean>

<!-- trigger using unix expression -->
<bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="jobDetail" />
    <!-- run every morning at 6 AM -->
    <property name="cronExpression" value="0 0 6 * * ?" />
</bean>

- humungs

Answer 2

你不是忘了加上 @EnableScheduling 注解吗？

像这样：

@Configuration
@EnableScheduling
public class SpringConfigBean {
...
}

- user1669739

---

当直接使用SchedulerFactoryBean时，@EnableScheduling注释是不必要的。 - cuttcards