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);
		}
		// 作业的详细信息 指定为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()即可