项目中需要在某个动作执行完成8分钟后发送邮件,每隔10秒发送一封,下面给出简单实现:
1.定义邮件发送工具类:
import java.util.Properties; import org.springframework.mail.MailException; import org.springframework.mail.SimpleMailMessage; import org.springframework.mail.javamail.JavaMailSenderImpl; import com.czh.MailConfig; /** * 邮件发送 * */ public class MailSender extends JavaMailSenderImpl { private static MailSender mailSender; private MailSender() { //这里是读取properties文件中的邮件配置信息 this.setHost(MailConfig.getInstance().getValue("sendmail.sendserver")); this .setUsername(MailConfig.getInstance().getValue( "sendmail.username")); this .setPassword(MailConfig.getInstance().getValue( "sendmail.password")); this.setPort(25); Properties properties = new Properties(); properties.put("mail.smtp.auth", "true"); properties.put("mail.smtp.timeout", "50000"); this.setJavaMailProperties(properties); } public static synchronized MailSender getInstance() { if (mailSender == null) { mailSender = new MailSender(); } return mailSender; } public boolean sendMail(String[] receiver, String subject, String text) { SimpleMailMessage mail = new SimpleMailMessage(); mail.setFrom(MailConfig.getInstance().getValue("sendmail.username")); mail.setTo(receiver); mail.setSubject(subject); mail.setText(text); try { this.send(mail); } catch (MailException e) { e.printStackTrace(); return false; } return true; } }
2:定义执行发送邮件的定时任务:
import java.util.List; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import com.czh.MailSender; /** * 发送邮件 * @author czh * */ public class SendMailJob implements Job { public void execute(JobExecutionContext context) throws JobExecutionException { List receiver = (List) context.getJobDetail().getJobDataMap().get( "receiver"); if (!receiver.isEmpty()) { //这些值都是定时器启动类穿过类的 String subject = (String) context.getJobDetail().getJobDataMap() .get("subject"); String text = (String) context.getJobDetail().getJobDataMap().get( "text"); MailSender.getInstance().sendMail( new String[] { receiver.remove(0).toString() }, subject, text); System.out.println("转发邮件" + receiver.remove(0).toString()); } } }
3.定义定时器启动类
import java.util.Date; import java.util.List; import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.SimpleTrigger; import org.quartz.impl.StdSchedulerFactory; /** * 发送邮件任务 * @author czh * */ public class SendMailTask { /** * 发送邮件 保存成功8分钟后转发,每隔10秒钟转发一封 * * @param id * 唯一标示符 * @param receiver * 收件人 * @param subject * 主题 * @param text * 内容 * @throws Exception */ public static void sendMail(String id, List<String> receiver, String subject, String text) throws Exception { Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); String jobName = "sendMailJob_"; String groupName = "DEFAULT"; // 删除作业 if (scheduler.getJobDetail(jobName, groupName) != null) { scheduler.deleteJob(jobName, groupName); } // 作业的详细信息 指定为SendMailJob JobDetail jobDetail = new JobDetail(jobName + id, groupName, SendMailJob.class); // 传参数 在第2步中已写如何获取 jobDetail.getJobDataMap().put("id", id); jobDetail.getJobDataMap().put("receiver", receiver); jobDetail.getJobDataMap().put("subject", subject); jobDetail.getJobDataMap().put("text", text); // 创建简单触发器 SimpleTrigger simpleTrigger = new SimpleTrigger("simpleTrigger_" + id, null); simpleTrigger.setRepeatCount(receiver.size());// 调用次数 simpleTrigger.setRepeatInterval(10000);// 每10秒钟调用一次 // 8分钟后开始执行 long startTime = System.currentTimeMillis() + 480000L; // long startTime = System.currentTimeMillis() + 5000L; simpleTrigger.setStartTime(new Date(startTime)); // 注册作业 scheduler.scheduleJob(jobDetail, simpleTrigger); if (!scheduler.isShutdown()) { scheduler.start(); } } }
这样,哪里需要转发邮件,只要调用SendMailTask.sendMail()即可