Введите bean ссылку в задание кварца в Spring?

Ответ 1

Просто завершите решение, предоставленное jelies, а также пару других вещей, чтобы упростить интеграцию Spring + Quartz: http://codrspace.com/Khovansa/spring-quartz-with-a-database/

Ответ 2

Вы можете использовать этот SpringBeanJobFactory для автоматического автоустройства объектов кварца с помощью spring:

import org.quartz.spi.TriggerFiredBundle;
import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.scheduling.quartz.SpringBeanJobFactory;

public final class AutowiringSpringBeanJobFactory extends SpringBeanJobFactory implements
    ApplicationContextAware {

    private transient AutowireCapableBeanFactory beanFactory;

    @Override
    public void setApplicationContext(final ApplicationContext context) {
        beanFactory = context.getAutowireCapableBeanFactory();
    }

    @Override
    protected Object createJobInstance(final TriggerFiredBundle bundle) throws Exception {
        final Object job = super.createJobInstance(bundle);
        beanFactory.autowireBean(job);
        return job;
    }
}

Затем присоедините его к вашему SchedulerBean (в данном случае с Java-config):

@Bean
public SchedulerFactoryBean quartzScheduler() {
    SchedulerFactoryBean quartzScheduler = new SchedulerFactoryBean();

    ...

    AutowiringSpringBeanJobFactory jobFactory = new AutowiringSpringBeanJobFactory();
    jobFactory.setApplicationContext(applicationContext);
    quartzScheduler.setJobFactory(jobFactory);

    ...

    return quartzScheduler;
}

Работайте со мной, используя spring -3.2.1 и quartz-2.1.6.

Посмотрите полный gist здесь.

Я нашел решение в этом сообщении в блоге

Ответ 3

Я просто положил SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); в первую строку моего метода Job.execute(JobExecutionContext context).

Ответ 4

Такая же проблема была решена в LINK:

Я мог бы найти другой вариант из сообщения на форуме Spring, который вы можете передать ссылку на контекст приложения Spring через SchedulerFactoryBean. Как показано ниже:

<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<propertyy name="triggers">
    <list>
        <ref bean="simpleTrigger"/>
            </list>
    </property>
    <property name="applicationContextSchedulerContextKey">
        <value>applicationContext</value>
</property>

Затем, используя нижеприведенный код в своем классе заданий, вы можете получить applicationContext и получить все bean, которое вы хотите.

appCtx = (ApplicationContext)context.getScheduler().getContext().get("applicationContextSchedulerContextKey");

Надеюсь, это поможет. Вы можете получить дополнительную информацию от Mark Mclaren'sBlog

Ответ 5

Вы правы в своем предположении о Spring против Quartz, создающем экземпляр класса. Тем не менее, Spring предоставляет некоторые классы, которые позволяют выполнить некоторую примитивную инъекцию зависимостей в Quartz. Просмотрите SchedulerFactoryBean.setJobFactory() вместе с SpringBeanJobFactory. По сути, с помощью SpringBeanJobFactory вы включаете инъекцию зависимостей во все свойства Job, но только для значений, которые находятся в контексте планировщика Quartz или карта данных задания. Я не знаю, что все стили DI, которые он поддерживает (конструктор, аннотация, сеттер...), но я знаю, что он поддерживает инъекцию установщика.

Ответ 6

для всех, кто попытается это сделать в будущем.

org.springframework.scheduling.quartz.JobDetailBean поставляет карту объектов, и эти объекты могут быть spring beans.

определить smth like

<bean name="myJobDetail" class="org.springframework.scheduling.quartz.JobDetailBean">
    <property name="jobClass"
        value="my.cool.class.myCoolJob" />
    <property name="jobDataAsMap">
        <map>
            <entry key="myBean" value-ref="myBean" />
        </map>
    </property>
</bean>

а затем внутри

public void executeInternal(JobExecutionContext context)

вызов myBean = (myBean) context.getMergedJobDataMap().get("myBean"); и вы все поставили. Я знаю, он выглядит уродливым, но в качестве обходного пути он работает

Ответ 7

ApplicationContext springContext =

WebApplicationContextUtils.getWebApplicationContext(ContextLoaderListener .getCurrentWebApplicationContext().getServletContext());

Bean bean = (Bean) springContext.getBean("beanName");

bean.method();

Ответ 8

Спасибо, Риппон! Я, наконец, получил эту работу, после многих битв, и мое решение очень близко к тому, что вы предложили! Ключ должен был сделать мое собственное задание для расширения QuartzJobBean и использовать schedulerContextAsMap.

Я ушел, не указав свойство applicationContextSchedulerContextKey - он работал без него для меня.

В интересах других, вот окончательная конфигурация, которая сработала для меня:

    <bean id="quartzScheduler"  class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="configLocation" value="classpath:spring/quartz.properties"/>
        <property name="jobFactory">
            <bean  class="org.springframework.scheduling.quartz.SpringBeanJobFactory" />
        </property>
        <property name="schedulerContextAsMap">
            <map>
                <entry key="mailService" value-ref="mailService" />
            </map>
        </property>
</bean>
<bean id="jobTriggerFactory"
      class="org.springframework.beans.factory.config.ObjectFactoryCreatingFactoryBean">
    <property name="targetBeanName">
        <idref local="jobTrigger" />
    </property>
</bean>
<bean id="jobTrigger"   class="org.springframework.scheduling.quartz.SimpleTriggerBean"
    scope="prototype">
      <property name="group" value="myJobs" />
      <property name="description" value="myDescription" />
      <property name="repeatCount" value="0" />
</bean>

<bean id="jobDetailFactory"
      class="org.springframework.beans.factory.config.ObjectFactoryCreatingFactoryBean">
    <property name="targetBeanName">
        <idref local="jobDetail" />
    </property>
</bean>

<bean id="jobDetail" class="org.springframework.scheduling.quartz.JobDetailBean"
scope="prototype">
<property name="jobClass" value="com.cambridgedata.notifications.EMailJob" />
<property name="volatility" value="false" />
<property name="durability" value="false" />
<property name="requestsRecovery" value="true" />
</bean> 
<bean id="notificationScheduler"   class="com.cambridgedata.notifications.NotificationScheduler">
    <constructor-arg ref="quartzScheduler" />
    <constructor-arg ref="jobDetailFactory" />
    <constructor-arg ref="jobTriggerFactory" />
</bean>

Обратите внимание, что "mailService" bean является моей собственной службой bean, управляемой Spring. Мне удалось получить доступ к ней в моем задании следующим образом:

    public void executeInternal(JobExecutionContext context)
    throws JobExecutionException {

    logger.info("EMailJob started ...");
    ....
    SchedulerContext schedulerContext = null;
    try {
        schedulerContext = context.getScheduler().getContext();
    } catch (SchedulerException e1) {
        e1.printStackTrace();
    }
    MailService mailService = (MailService)schedulerContext.get("mailService");
    ....

И эта конфигурация также позволила мне выполнять динамические задания планировщика, используя заводы для получения триггеров и рабочих заданий и программно задавая им необходимые параметры:

    public NotificationScheduler(final Scheduler scheduler,
        final ObjectFactory<JobDetail> jobDetailFactory,
        final ObjectFactory<SimpleTrigger> jobTriggerFactory) {
    this.scheduler = scheduler;
    this.jobDetailFactory = jobDetailFactory;
    this.jobTriggerFactory = jobTriggerFactory;
           ...
        // create a trigger
        SimpleTrigger trigger = jobTriggerFactory.getObject();
        trigger.setRepeatInterval(0L);
    trigger.setStartTime(new Date());

    // create job details
    JobDetail emailJob = jobDetailFactory.getObject();

    emailJob.setName("new name");
    emailJob.setGroup("immediateEmailsGroup");
            ...

Спасибо всем, кто помог,

Марина

Ответ 9

Вот как выглядит код с помощью @Component:

Основной класс, который расписывает задание:

public class NotificationScheduler {

private SchedulerFactory sf;
private Scheduler scheduler;

@PostConstruct
public void initNotificationScheduler() {
    try {
    sf = new StdSchedulerFactory("spring/quartz.properties");
    scheduler = sf.getScheduler();
    scheduler.start();
            // test out sending a notification at startup, prepare some parameters...
    this.scheduleImmediateNotificationJob(messageParameters, recipients);
        try {
            // wait 20 seconds to show jobs
            logger.info("sleeping...");
            Thread.sleep(40L * 1000L); 
            logger.info("finished sleeping");
           // executing...
        } catch (Exception ignore) {
        }

      } catch (SchedulerException e) {
    e.printStackTrace();
    throw new RuntimeException("NotificationScheduler failed to retrieve a Scheduler instance: ", e);
    }
}


public void scheduleImmediateNotificationJob(){
  try {
    JobKey jobKey = new JobKey("key");
    Date fireTime = DateBuilder.futureDate(delayInSeconds, IntervalUnit.SECOND);
    JobDetail emailJob = JobBuilder.newJob(EMailJob.class)
    .withIdentity(jobKey.toString(), "immediateEmailsGroup")
        .build();

    TriggerKey triggerKey = new TriggerKey("triggerKey");
    SimpleTrigger trigger = (SimpleTrigger) TriggerBuilder.newTrigger() 
        .withIdentity(triggerKey.toString(), "immediateEmailsGroup")
        .startAt(fireTime)
        .build();

    // schedule the job to run
    Date scheduleTime1 = scheduler.scheduleJob(emailJob, trigger);
  } catch (SchedulerException e) {
    logger.error("error scheduling job: " + e.getMessage(), e);
    e.printStackTrace();
      }
}

@PreDestroy
public void cleanup(){
    sf = null;
    try {
        scheduler.shutdown();
    } catch (SchedulerException e) {
        e.printStackTrace();
    }
}

EmailJob - это то же самое, что и в моей первой публикации, за исключением аннотации @Component:

@Component
public class EMailJob implements Job { 
  @Autowired
  private JavaMailSenderImpl mailSenderImpl;
... }

И файл конфигурации Spring имеет:

...
<context:property-placeholder location="classpath:spring/*.properties" />
<context:spring-configured/>
<context:component-scan base-package="com.mybasepackage">
  <context:exclude-filter expression="org.springframework.stereotype.Controller"
        type="annotation" />
</context:component-scan>
<bean id="mailSenderImpl" class="org.springframework.mail.javamail.JavaMailSenderImpl">
    <property name="host" value="${mail.host}"/>
    <property name="port" value="${mail.port}"/>
    ...
</bean>
<bean id="notificationScheduler" class="com.mybasepackage.notifications.NotificationScheduler">
</bean>

Спасибо за помощь!

Марина

Ответ 10

Простым решением является установка spring bean в Карте данных заданий, а затем извлечение bean в класс задания, например

// the class sets the configures the MyJob class 
    SchedulerFactory sf = new StdSchedulerFactory();
    Scheduler sched = sf.getScheduler();
    Date startTime = DateBuilder.nextGivenSecondDate(null, 15);
    JobDetail job = newJob(MyJob.class).withIdentity("job1", "group1").build();
    job.getJobDataMap().put("processDataDAO", processDataDAO);

`

 // this is MyJob Class
    ProcessDataDAO processDataDAO = (ProcessDataDAO) jec.getMergedJobDataMap().get("processDataDAO");

Ответ 11

Решение от Hary fooobar.com/questions/73431/... работает очень хорошо. Это проще, не нужно так много специальных фасоли фабрик и поддерживает несколько триггеров и заданий. Просто добавим, что задание Quartz можно сделать универсальным, а конкретные задания выполняются как обычные весенние бобы.

public interface BeanJob {
  void executeBeanJob();
}

public class GenericJob implements Job {

  @Override
  public void execute(JobExecutionContext context) throws JobExecutionException {
    JobDataMap dataMap = context.getMergedJobDataMap();
    ((BeanJob)dataMap.get("beanJob")).executeBeanJob();    
  }

}

@Component
public class RealJob implements BeanJob {
  private SomeService service;

  @Autowired
  public RealJob(SomeService service) {
    this.service = service;
  }

  @Override
  public void executeBeanJob() {
      //do do job with service
  }

}

Ответ 12

Простым способом сделать это будет просто комментировать задания Quartz с аннотацией @Component, а затем Spring сделает для вас всю магию DI, так как теперь она распознается как Spring bean, Я должен был сделать что-то подобное для аспекта AspectJ - это не был Spring bean, пока я не аннотировал его с помощью стереотипа Spring @Component.

Ответ 13

Это довольно старый пост, который по-прежнему полезен. Все решения, которые предлагают эти два, имеют мало условий, которые не соответствуют всем:

• SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); Это предполагает или требует, чтобы это был проект на основе весны
• AutowiringSpringBeanJobFactory упомянутый в предыдущем ответе, очень полезен, но ответ специфичен для тех, кто не использует чистый ванильный кварц api, а скорее Spring wrapper для кварца, чтобы сделать то же самое.

Если вы хотите остаться с чистой реализацией Quartz для планирования (кварц с возможностями Autowiring с Spring), я смог сделать это следующим образом:

Я старался сделать это кварцевым способом, насколько это возможно, и, таким образом, маленький взлом оказывается полезным.

 public final class AutowiringSpringBeanJobFactory extends SpringBeanJobFactory{

    private AutowireCapableBeanFactory beanFactory;

    public AutowiringSpringBeanJobFactory(final ApplicationContext applicationContext){
        beanFactory = applicationContext.getAutowireCapableBeanFactory();
    }

    @Override
    protected Object createJobInstance(final TriggerFiredBundle bundle) throws Exception {
        final Object job = super.createJobInstance(bundle);
        beanFactory.autowireBean(job);
        beanFactory.initializeBean(job, job.getClass().getName());
        return job;
    }
}


@Configuration
public class SchedulerConfig {   
    @Autowired private ApplicationContext applicationContext;

    @Bean
    public AutowiringSpringBeanJobFactory getAutowiringSpringBeanJobFactory(){
        return new AutowiringSpringBeanJobFactory(applicationContext);
    }
}


private void initializeAndStartScheduler(final Properties quartzProperties)
            throws SchedulerException {
        //schedulerFactory.initialize(quartzProperties);
        Scheduler quartzScheduler = schedulerFactory.getScheduler();

        //Below one is the key here. Use the spring autowire capable job factory and inject here
        quartzScheduler.setJobFactory(autowiringSpringBeanJobFactory);
        quartzScheduler.start();
    }

quartzScheduler.setJobFactory(autowiringSpringBeanJobFactory); дает нам экземпляр с автоподготовкой. Поскольку AutowiringSpringBeanJobFactory неявно реализует JobFactory, мы теперь включили автоматическое решение. Надеюсь это поможет!

Ответ 14

Убедитесь, что ваш

AutowiringSpringBeanJobFactory extends SpringBeanJobFactory 

зависимость вытягивается из

    "org.springframework:spring-context-support:4..."

и НЕ от

    "org.springframework:spring-support:2..."

Он хотел, чтобы я использовал

@Override
public Job newJob(TriggerFiredBundle bundle, Scheduler scheduler)

вместо

@Override
protected Object createJobInstance(final TriggerFiredBundle bundle)

так что не удалось выполнить аудит рабочего экземпляра.

Ответ 15

Когда вы уже используете реальный AspectJ в своем проекте, вы можете аннотировать класс задания bean с помощью @Configurable. Тогда Spring будет вводиться в этот класс, даже если он построен через new

Ответ 16

Я столкнулся с аналогичной проблемой и вышел из нее следующим образом:

<!-- Quartz Job -->
<bean name="JobA" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <!-- <constructor-arg ref="dao.DAOFramework" /> -->
     <property name="jobDataAsMap">
    <map>
        <entry key="daoBean" value-ref="dao.DAOFramework" />
    </map>
</property>
    <property name="jobClass" value="com.stratasync.jobs.JobA" />
    <property name="durability" value="true"/>
</bean>

В вышеприведенном коде я вставляю dao.DAOFramework bean в JobA bean и внутри метода ExecuteInternal вы можете ввести bean как:

  daoFramework = (DAOFramework)context.getMergedJobDataMap().get("daoBean");

Надеюсь, это поможет! Спасибо.

Ответ 17

Решение выше отлично, но в моем случае инъекция не работала. Мне нужно было использовать autowireBeanProperties, возможно, из-за настройки моего контекста:

import org.quartz.spi.TriggerFiredBundle;
import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.scheduling.quartz.SpringBeanJobFactory;

public final class AutowiringSpringBeanJobFactory extends SpringBeanJobFactory implements
ApplicationContextAware {

    private transient AutowireCapableBeanFactory beanFactory;

    @Override
    public void setApplicationContext(final ApplicationContext context) {
        beanFactory = context.getAutowireCapableBeanFactory();
    }

    @Override
    protected Object createJobInstance(final TriggerFiredBundle bundle) throws Exception {
        final Object job = super.createJobInstance(bundle);
        //beanFactory.autowireBean(job);
        beanFactory.autowireBeanProperties(job, AutowireCapableBeanFactory.AUTOWIRE_BY_TYPE, true);
        return job;
    }
}

Ответ 18

Это правильный ответ fooobar.com/questions/73431/.... и будет работать для большинства людей. Но если ваш web.xml не знает обо всех файлах applicationContext.xml, кварцевое задание не сможет вызвать эти компоненты. Мне пришлось сделать дополнительный слой, чтобы добавить дополнительные файлы приложенияContext

public class MYSpringBeanJobFactory extends SpringBeanJobFactory
        implements ApplicationContextAware {

    private transient AutowireCapableBeanFactory beanFactory;

    @Override
    public void setApplicationContext(final ApplicationContext context) {

        try {
                PathMatchingResourcePatternResolver pmrl = new PathMatchingResourcePatternResolver(context.getClassLoader());
                Resource[] resources = new Resource[0];
                GenericApplicationContext createdContext = null ;
                    resources = pmrl.getResources(
                            "classpath*:my-abc-integration-applicationContext.xml"
                    );

                    for (Resource r : resources) {
                        createdContext = new GenericApplicationContext(context);
                        XmlBeanDefinitionReader reader = new XmlBeanDefinitionReader(createdContext);
                        int i = reader.loadBeanDefinitions(r);
                    }

            createdContext.refresh();//important else you will get exceptions.
            beanFactory = createdContext.getAutowireCapableBeanFactory();

        } catch (IOException e) {
            e.printStackTrace();
        }



    }

    @Override
    protected Object createJobInstance(final TriggerFiredBundle bundle)
            throws Exception {
        final Object job = super.createJobInstance(bundle);
        beanFactory.autowireBean(job);
        return job;
    }
}

Вы можете добавить любое количество файлов контекста, о которых вы должны знать ваш кварц.

Ответ 19

Все эти решения выше не работают для меня с Spring 5 и Hibernate 5 и Quartz 2.2.3, когда я хочу назвать транзакционные методы!

Поэтому я реализовал это решение, которое автоматически запускает планировщик и запускает задания. Я нашел много кода в dzone. Поскольку мне не нужно динамически создавать триггеры и задания, я хотел бы, чтобы статические триггеры были предварительно определены с помощью Spring Configuration и только задания, которые должны отображаться как компоненты Spring.

Моя основная конфигурация выглядит так:

@Configuration
public class QuartzConfiguration {

  @Autowired
  ApplicationContext applicationContext;

  @Bean
  public SchedulerFactoryBean scheduler(@Autowired JobFactory jobFactory) throws IOException {
    SchedulerFactoryBean sfb = new SchedulerFactoryBean();

    sfb.setOverwriteExistingJobs(true);
    sfb.setAutoStartup(true);
    sfb.setJobFactory(jobFactory);

    Trigger[] triggers = new Trigger[] {
        cronTriggerTest().getObject()
    };
    sfb.setTriggers(triggers);
    return sfb;
  }

  @Bean
  public JobFactory cronJobFactory() {
    AutowiringSpringBeanJobFactory jobFactory = new AutowiringSpringBeanJobFactory();
    jobFactory.setApplicationContext(applicationContext);
    return jobFactory;
  }

  @Bean 
  public CronTriggerFactoryBean cronTriggerTest() {
    CronTriggerFactoryBean tfb = new CronTriggerFactoryBean();
    tfb.setCronExpression("0 * * ? * * *");

    JobDetail jobDetail = JobBuilder.newJob(CronTest.class)
                            .withIdentity("Testjob")
                            .build()
                            ;

    tfb.setJobDetail(jobDetail);
    return tfb;
  }

}

Как вы можете видеть, у вас есть планировщик и простой триггер, который определяется с помощью выражения cron. Вы можете, очевидно, выбрать любое графическое выражение, которое вам нравится. Затем вам понадобится AutowiringSpringBeanJobFactory, который будет выглядеть следующим образом:

public final class AutowiringSpringBeanJobFactory extends SpringBeanJobFactory implements ApplicationContextAware {

  @Autowired
  private ApplicationContext applicationContext;

  private SchedulerContext schedulerContext;

  @Override
  public void setApplicationContext(final ApplicationContext context) {
    this.applicationContext = context;
  }


  @Override
  protected Object createJobInstance(final TriggerFiredBundle bundle) throws Exception {
    Job job = applicationContext.getBean(bundle.getJobDetail().getJobClass());
    BeanWrapper bw = PropertyAccessorFactory.forBeanPropertyAccess(job);

    MutablePropertyValues pvs = new MutablePropertyValues();
    pvs.addPropertyValues(bundle.getJobDetail().getJobDataMap());
    pvs.addPropertyValues(bundle.getTrigger().getJobDataMap());

    if (this.schedulerContext != null)
    {
        pvs.addPropertyValues(this.schedulerContext);
    }
    bw.setPropertyValues(pvs, true);

    return job;
  }  

  public void setSchedulerContext(SchedulerContext schedulerContext) {
    this.schedulerContext = schedulerContext;
    super.setSchedulerContext(schedulerContext);
  }

}

Здесь вы связываете свой обычный контекст приложения и свою работу вместе. Это важный разрыв, потому что обычно Quartz запускает рабочие потоки, которые не имеют никакого отношения к вашему контексту приложения. Вот почему вы не можете выполнять транзакционные mehtods. Последнее, чего не хватает, - это работа. Это может выглядеть так

@Component
public class CronTest implements Job {

  @Autowired
  private MyService s;

  public CronTest() {
  }

  @Override
  public void execute(JobExecutionContext context) throws JobExecutionException {
    s.execute();
  }

}

Это не идеальное решение, потому что вы получаете дополнительный класс только для вызова своего метода обслуживания. Но тем не менее он работает.

Ответ 20

Jdbc JobStore

Если вы используете jdbc jobstore, Quartz использует другой загрузчик классов. Это предотвращает все обходные пути для автоматического подключения, так как объекты из пружины не будут совместимы на стороне кварца, потому что они возникли из загрузчика другого класса.

Чтобы это исправить, загрузчик классов по умолчанию должен быть установлен в файле свойств кварца следующим образом:

org.quartz.scheduler.classLoadHelper.class=org.quartz.simpl.ThreadContextClassLoadHelper

Как ссылка: https://github.com/quartz-scheduler/quartz/issues/221

Ответ 21

Просто продлите свою работу от QuartzJobBean

public class MyJob extends QuartzJobBean {

    @Autowired
    private SomeBean someBean;

    @Override
    protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        System.out.println("Some bean is " + someBean.toString());
    }

}