使用spring batch config如何发送邮件以及如何在job中配置

Question

我需要使用 spring batch configs 发送邮件。在具有邮件状态的邮件中（成功或失败）现在能够从 csv 读取数据并写入数据库。写入数据库后我需要发送邮件。 请任何人给我建议 这是我的 java config 文件作业配置

return jobs.get("insertIntoDbFromCsvJob")
            .start(readRegistrations())
                .build();
    }

这里是 readRegistrations() 步骤，是从 csv 读取数据并写入数据库。 现在，如果该步骤成功或失败，我需要发送邮件。

Answer 1

您可以使用 spring 电子邮件支持和工作侦听器。

    @Bean
    public JavaMailSender javaMailSender() {
        JavaMailSenderImpl javaMailSenderImpl = new JavaMailSenderImpl();
        javaMailSenderImpl.setHost("localhost");
        javaMailSenderImpl.setUsername("");
        javaMailSenderImpl.setPassword("");
        javaMailSenderImpl.setProtocol("smtp");
        javaMailSenderImpl.setPort(25);
        return javaMailSenderImpl;
    }

    @Bean
    public SimpleMailMessage templateMessage() {
        SimpleMailMessage mailMessage = new SimpleMailMessage();
        mailMessage.setTo("to@gmail.com");
        mailMessage.setSubject("Job Status");
        mailMessage.setFrom("test@test.com");
        return mailMessage;
    }

实现一个监听器

@Component
public class JobCompletionNotificationListener extends
        JobExecutionListenerSupport {

    private static final Logger log = LoggerFactory
            .getLogger(JobCompletionNotificationListener.class);

    @Autowired
    private JavaMailSender javaMailSender;

    @Autowired
    private SimpleMailMessage templateMessage;

    @Override
    public void afterJob(JobExecution jobExecution) {
        if (jobExecution.getStatus() == BatchStatus.COMPLETED) {
            log.info("!!! JOB FINISHED! Time to verify the results");
            SimpleMailMessage mailMessage = new SimpleMailMessage(
                    templateMessage);
            mailMessage.setText("Job Success");
            javaMailSender.send(mailMessage);
        }
    }
}

工作配置

@Autowired
private JobCompletionNotificationListener listener;

@Bean
public Job importUserJob(JobBuilderFactory jobs, Step s1,
        JobExecutionListener listener) {
    return jobs.get("importUserJob").incrementer(new RunIdIncrementer())
            .listener(listener).flow(s1).end().build();
}