Spring定时器_代码设置
上一篇介绍了如何通过配置文件定义定时器，这里再分享一下如何通过代码定义。
项目中需要在某个动作执行完成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);}// 作业的详细信息 指定为SendMailJobJobDetail 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()即可