使用 Quartz 在 spring 中未触发 Quartz 作业

Quatz job not getting triigered in spring with Quartz

下面是我与 Spring 的 quatz 集成,但它不工作,即作业没有被触发。我可以看到石英在少数 MS 中检查 MySQL 数据库,这意味着与 MYSQL 的连接很好并且记录也被插入到表中但是下面提到的 Sysout class 没有出现在控制台中.请告知根本原因是什么 -

来自 Spring 配置 XML

<bean id="myTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
        <property name="corePoolSize" value="5" />
        <property name="maxPoolSize" value="50" />
        <property name="WaitForTasksToCompleteOnShutdown" value="true" />
    </bean>

    <bean id="exampleBusinessObjectJobTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
        <property name="jobDetail">
            <bean name="exampleBusinessObjectJob" class="org.springframework.scheduling.quartz.JobDetailBean">
                <property name="name" value="exampleBusinessObjectJob"/>
                <property name="jobClass" value="com.aexp.mars.job.ExampleJob"/>
            </bean>
        </property>
        <property name="cronExpression" value="0 */1 * * * ?"/>
    </bean>

    <bean id="exampleBusinessObjectJob" class="com.aexp.mars.job.ExampleJob">
    </bean>

    <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">

        <property name="applicationContextSchedulerContextKey" value="applicationContext"/>

        <property name="autoStartup" value="true"/>

        <property name="triggers">
            <list>
                <ref bean="exampleBusinessObjectJobTrigger" />
            </list>        
        </property>
        <property name="quartzProperties">
            <props>
                <prop key="org.quartz.scheduler.instanceName">MARS_SCHEDULER</prop>
                <prop key="org.quartz.scheduler.instanceId">AUTO</prop>
                <prop key="org.quartz.scheduler.instanceId">10000</prop>
                <prop key="org.quartz.scheduler.instanceId">600000</prop>
                <prop key="org.quartz.threadPool.class">org.quartz.simpl.SimpleThreadPool</prop>
                <prop key="org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread">true</prop>
                <prop key="org.quartz.threadPool.threadCount">3</prop>
                <prop key="org.quartz.threadPool.threadPriority">5</prop>
                <prop key="org.quartz.jobStore.misfireThreshold">60000</prop>
                <prop key="org.quartz.jobStore.class">org.quartz.impl.jdbcjobstore.JobStoreTX</prop>
                <prop key="org.quartz.jobStore.driverDelegateClass">org.quartz.impl.jdbcjobstore.StdJDBCDelegate</prop>
                <prop key="org.quartz.jobStore.useProperties">false</prop>
                <prop key="org.quartz.jobStore.dataSource">marsDS</prop>
                <prop key="org.quartz.jobStore.tablePrefix">QRTZ_</prop>
                <prop key="org.quartz.jobStore.isClustered">true</prop>
                <prop key="org.quartz.jobStore.clusterCheckinInterval">15000</prop>
                <prop key="org.quartz.jobStore.maxMisfiresToHandleAtATime">20</prop>
                <prop key="org.quartz.dataSource.marsDS.driver">com.mysql.jdbc.Driver</prop>
                <prop key="org.quartz.dataSource.marsDS.URL">{server_url}</prop>
                <prop key="org.quartz.dataSource.marsDS.user">{user_name}</prop>
                <prop key="org.quartz.dataSource.marsDS.password">{password}</prop>
                <prop key="org.quartz.dataSource.marsDS.maxConnections">10</prop>
                <prop key="org.quartz.dataSource.marsDS.validationQuery">select 1</prop>
                <prop key="org.quartz.plugin.shutdownHook.class">org.quartz.plugins.management.ShutdownHookPlugin</prop>
                <prop key="org.quartz.plugin.shutdownHook.cleanShutdown">false</prop>
            </props>
        </property>
        <property name="taskExecutor" ref="myTaskExecutor" />
        <property name="jobFactory">
            <bean class="com.aexp.mars.job.MarsSpringBeanJobFactory"/>
        </property>
    </bean>

**Java class - **

public class ExampleJob   {

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


    protected void executeInternal(JobExecutionContext ctx) throws JobExecutionException {
          System.out.println("Job is running");
          LOG.info("Job ran");
    }

    public void execute(JobExecutionContext ctx) throws JobExecutionException {
          System.out.println("Job#1 is running");
          LOG.info("Job ran");
    }

}

了解场景。我每 1 分钟将 cron 表达式的值更改为 运行,但它仍然设置为我以前的值(即凌晨 3 点)。我在下面添加 属性 然后新的 cron 表达式开始工作..

<property name="overwriteExistingJobs" value="true"/>