Spring+quartz实现定时发送邮件功能实例

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xsi:schemaLocation="http://www.springframework.org/schema/beans      http://www.springframework.org/schema/beans/spring-beans-3.1.xsd      http://www.springframework.org/schema/aop        http://www.springframework.org/schema/aop/spring-aop-3.1.xsd        http://www.springframework.org/schema/tx        http://www.springframework.org/schema/tx/spring-tx-3.1.xsd "><bean id="testQuartz" class="com.zhuyun.net.AttachmentEmailUtil"></bean>  <!-- bean触发方法配置 --> <bean name="quartzBean"  class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">  <!-- bean名字 -->  <property name="targetObject" ref="testQuartz" /><!--目标对象-->  <!-- bean方法 -->  <property name="targetMethod"><!--目标方法-->   <value>sendEmail</value>  </property>  <property name="concurrent"><!--配置为false不允许任务并发执行-->   <value>false</value>  </property> </bean>    <!-- bean触发时间配置,指定具体的时间执行 -->   <bean id="quartzTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">    <!-- 触发bean配置 -->    <property name="jobDetail" ref="quartzBean" />    <!-- 触发时间配置 -->    <property name="cronExpression">     <value>0 0 10 1 * ?</value>    </property>   </bean>   <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean" lazy-init="default" autowire="default"> <property name="triggers">  <list>   <ref local="quartzTrigger" />  </list> </property> <property name="autoStartup" value="true" /></bean></beans>

package com.zhuyun.net;import java.io.BufferedWriter;import java.io.File;import java.io.FileNotFoundException;import java.io.FileOutputStream;import java.io.FileWriter;import java.io.IOException;import java.io.ObjectInputStream;import java.io.ObjectOutputStream;import java.io.OutputStream;import java.io.OutputStreamWriter;import java.io.Writer;import java.sql.SQLException;import java.text.SimpleDateFormat;import java.util.ArrayList;import java.util.Calendar;import java.util.Date;import java.util.List;import java.util.Properties;import javax.activation.DataHandler;import javax.activation.DataSource;import javax.activation.FileDataSource;import javax.mail.BodyPart;import javax.mail.Message;import javax.mail.Multipart;import javax.mail.Session;import javax.mail.Transport;import javax.mail.internet.InternetAddress;import javax.mail.internet.MimeBodyPart;import javax.mail.internet.MimeMessage;import javax.mail.internet.MimeMultipart;public class AttachmentEmailUtil { private String host = ""; // smtp服务器 private String from = ""; // 发件人地址 private String to = ""; // 收件人地址 private String affix = ""; // 附件地址 private String affixName = ""; // 附件名称 private String user = ""; // 用户名 private String pwd = ""; // 密码 private String subject = ""; // 邮件标题 public void setAddress(String from, String to, String subject) {  this.from = from;  this.to = to;  this.subject = subject; } public void setAffix(String affix, String affixName) {  this.affix = affix;  this.affixName = affixName; } public void send(String host, String user, String pwd) {  this.host = host;  this.user = user;  this.pwd = pwd;  Properties props = new Properties();  // 设置发送邮件的邮件服务器的属性（这里使用网易的smtp服务器）  props.put("mail.smtp.host", host);  // 需要经过授权，也就是有户名和密码的校验，这样才能通过验证  props.put("mail.smtp.auth", "true");  props.put("mail.smtp.port", 465);  props.put("mail.smtp.ssl.enable", true);  // 用刚刚设置好的props对象构建一个session  Session session = Session.getDefaultInstance(props);  // 有了这句便可以在发送邮件的过程中在console处显示过程信息，供调试使  // 用（你可以在控制台（console)上看到发送邮件的过程）  session.setDebug(true);  // 用session为参数定义消息对象  MimeMessage message = new MimeMessage(session);  try {   // 加载发件人地址   message.setFrom(new InternetAddress(from));   // 加载收件人地址   message.addRecipient(Message.RecipientType.TO, new InternetAddress(     to));   // 加载标题   message.setSubject(subject);   // 向multipart对象中添加邮件的各个部分内容，包括文本内容和附件   Multipart multipart = new MimeMultipart();   // 设置邮件的文本内容   BodyPart contentPart = new MimeBodyPart();   contentPart.setText("第二种方法···");   multipart.addBodyPart(contentPart);   // 添加附件   BodyPart messageBodyPart = new MimeBodyPart();   DataSource source = new FileDataSource(affix);   // 添加附件的内容   messageBodyPart.setDataHandler(new DataHandler(source));   // 添加附件的标题   // 这里很重要，通过下面的Base64编码的转换可以保证你的中文附件标题名在发送时不会变成乱码   sun.misc.BASE64Encoder enc = new sun.misc.BASE64Encoder();   messageBodyPart.setFileName("=?GBK?B?"     + enc.encode(affixName.getBytes()) + "?=");   multipart.addBodyPart(messageBodyPart);   // 将multipart对象放到message中   message.setContent(multipart);   // 保存邮件   message.saveChanges();   // 发送邮件   Transport transport = session.getTransport("smtp");   // 连接服务器的邮箱   transport.connect(host, user, pwd);   // 把邮件发送出去   transport.sendMessage(message, message.getAllRecipients());   transport.close();  } catch (Exception e) {   e.printStackTrace();  } } public void sendEmail() {  File file = new File("/root/EmailFile/content.csv");  if (!file.exists()) {   try {    file.createNewFile();   } catch (IOException e) {    // TODO Auto-generated catch block    e.printStackTrace();   }  }  String pushInfoContent = "成功了";  FileWriter writer = null;  try {   // 打开一个写文件器，构造函数中的第二个参数true表示以追加形式写文件   writer = new FileWriter(file, true);   writer.write(pushInfoContent + "/r/n");  } catch (IOException e) {   e.printStackTrace();  } finally {   try {    if (writer != null) {     writer.close();    }   } catch (IOException e) {    e.printStackTrace();   }  }  AttachmentEmailUtil cn = new AttachmentEmailUtil();  // 设置发件人地址、收件人地址和邮件标题  cn.setAddress("发件人地址", "收件人地址", "一个带附件的JavaMail邮件(标题)");  // 设置要发送附件的位置和标题  cn.setAffix("附件的位置", "附件的文件名");  // 设置smtp服务器以及邮箱的帐号和密码  cn.send("smtp.qq.com", "帐号", "密码");  if (file.exists()) {   file.delete();  } }}