Spring Batch 电子邮件监听器

Question

我想将 Spring Batch 配置为在作业开始时发送电子邮件，并在作业完成或失败时发送电子邮件。我通过搜索看到了一些示例，例如codecentric 上的链接，但我没有在我的项目中使用 XML 注释。我有一个看起来像这样的听众，但不确定我可能需要什么其他作品。任何输入将不胜感激public class SendMailListener implements JobExecutionListener {    final static Logger LOGGER = LoggerFactory.getLogger(SendMailListener.class);    @Autowired    private JobExplorer explorer;    @Autowired    private StepExecution stepExecution;    @Override    public void afterJob(JobExecution jobExecution) {        if (jobExecution.getStatus() == BatchStatus.COMPLETED) {            LOGGER.info("The job has been completed with the following parameters: " + jobExecution.getJobParameters());        }        //send email here    }    @Override    public void beforeJob(JobExecution jobExecution) {        // TODO Auto-generated method stub    }    //send email here}编辑：我有与听众一起定义的工作：@Bean(name = "mccINSTANCETESTjob")    public Job mccOrz004job(JobBuilderFactory jobFactory, //            @Qualifier("instanceTestSetupStep") Step orz004SetupStep, //            @Qualifier("callM204Step") Step callM204Step, //            @Autowired SingleInstanceListener listener, @Autowired SendMailListener mailListener) { //        return jobFactory.get("mccINSTANCETESTjob") //                .incrementer(new RunIdIncrementer()) //                .listener(mailListener) //                .start(orz004SetupStep) //                .next(callM204Step) //                .build();    }

Answer 1

您需要定义一个类型的 bean JavaMailSender（例如在您共享的链接中），例如：

@Bean

public JavaMailSender javaMailSender() {

    JavaMailSenderImpl javaMailSender = new JavaMailSenderImpl();

    // set properties on javaMailSender (user, password, etc)

    return javaMailSender;

}

然后，您可以SendMailListener像使用作业资源管理器一样将其注入您的系统中。注入后，可以使用邮件发件人发送电子邮件，这是一个示例：

public class SendMailListener implements JobExecutionListener {

    final static Logger LOGGER = LoggerFactory.getLogger(SendMailListener.class);

    @Autowired // field injection is not recommended, use constructor injection instead

    private JobExplorer explorer;

    @Autowired // field injection is not recommended, use constructor injection instead

    private JavaMailSender javaMailSender;

    @Autowired

    private StepExecution stepExecution;

    @Override

    public void afterJob(JobExecution jobExecution) {

        if (jobExecution.getStatus() == BatchStatus.COMPLETED) {

            LOGGER.info("The job has been completed with the following parameters: " + jobExecution.getJobParameters());

        }

        //send email here

        MimeMessage message = javaMailSender.createMimeMessage();

        // set message properties (sender, receiver, content)

        javaMailSender.send(message);

    }

    @Override

    public void beforeJob(JobExecution jobExecution) {

        // TODO Auto-generated method stub

        //send email here

        MimeMessage message = javaMailSender.createMimeMessage();

        // set message properties (sender, receiver, content)

        javaMailSender.send(message);

    }

}

Answer 2

因此，对于 XML 表示法的解决方法，您可以使用类似的作业配置。

@Bean

public Job demoJob(){

return jobs.get("demoJob")

        .incrementer(new RunIdIncrementer())

        .listener(new JobResultListener())

        .start(demostep())

        .build();

}

你可以在这里找到合适的文章：https ://howtodoinjava.com/spring-batch/spring-batch-event-listeners/