定時執行任務後自動發送郵件
?
----------------------------1: 時間管理,到點自動開始------------------------
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.util.Calendar;
import java.util.Date;
import java.util.Enumeration;
import java.util.Properties;
import java.util.Timer;
public class TimerManager {
?private static final long PERIOD_DAY = 24 * 60 * 60 * 1000;
?private static final String CONFIG_FILE_PATH = "C:\\task.ini";
?
/*
?
task.ini 格式必須是
?
key=value
?
*/
?public TimerManager() {
??try{
?
??Calendar calendar = Calendar.getInstance();
??// 設置每日執行的時間
??calendar.set(Calendar.HOUR_OF_DAY, Integer.parseInt(getConfig("DAYENDHOUR")));
??calendar.set(Calendar.MINUTE, Integer.parseInt(getConfig("DAYENDMINUTE")));
??Date date = calendar.getTime();
??/**
?? * 如果更新系統的時間在設置時間之前，
?? * 則此任務會自動執行一次，數據會有問題！?
?? * 所以這裏要加一天，就是說在明天的這個時候再執行
?? */
??if (date.before(new Date())) {
???date = this.addDay(date, 1);
??}
??Timer timer = new Timer();
??//調用我們已經寫好的任務
??ScheduleDataTimerTask task = new ScheduleDataTimerTask();
??timer.schedule(task, date, PERIOD_DAY);
??}catch( Exception e){
???e.printStackTrace();
??}
?}
?public Date addDay(Date date, int num) {
??Calendar startDT = Calendar.getInstance();
??startDT.setTime(date);
??startDT.add(Calendar.DAY_OF_MONTH, num);
??return startDT.getTime();
?}
?
?public static void readFileForDayend() throws Exception {
???File file = new File(CONFIG_FILE_PATH);
???Properties properties = new Properties();
???try {
????FileInputStream fi = new FileInputStream(CONFIG_FILE_PATH);
????properties.load(fi);
????Enumeration emu = properties.keys();
????while (emu.hasMoreElements()) {
?????String theKey = (String) emu.nextElement();
?????String theValue = properties.getProperty(theKey);
?????System.setProperty(theKey, theValue);
????}
????try {
?????fi.close();
?????fi = null;
????} catch (Exception E) {
????}
???} catch (FileNotFoundException e) {
????throw new Exception(" file not found. "
??????+ file.getAbsolutePath());
???}
??}
??
?public static String getConfig(String parameterName) throws Exception
??{
???String propValue = System.getProperty(parameterName);
??
???File file = new File(CONFIG_FILE_PATH);
???if (!file.isFile())
???{
????throw new Exception(" file not found." + file.getAbsolutePath());
???}
??
???if (propValue == null)
???{
????readFileForDayend();
????propValue = System.getProperty(parameterName);
???}
???if (propValue == null)
???{
????throw new Exception("Parameter '" + parameterName + "' not found");
???}else{
????return propValue;
???}
??}
}
-----------------------------------2: 監聽類,??----------------------------------------
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
public class ScheduleActionListener implements ServletContextListener {?
public void contextInitialized(ServletContextEvent envt) {
?TimerManager time = new TimerManager();?
}
public void contextDestroyed(ServletContextEvent envt) {}?
?}
?
web.xml需要配置:
?
?<listener>
??<listener-class>
???????????????? ScheduleActionListener
??</listener-class>
?</listener>
?
-----------------------------------3: 要執行的任務---------------------------------------
import java.util.TimerTask;
public class ScheduleDataTimerTask extends TimerTask {
?
?public void run() {
??System.out.println("---------------------自動執行開始---------------------");
}
?
-----------------------------------4: 發送郵件類--------------------------------------------
import java.util.Date;
import java.util.StringTokenizer;
import javax.mail.Address;
import javax.mail.BodyPart;
import javax.mail.Message;
import javax.mail.MessagingException;
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 SimpleMailSender {
?// 發送帶抄送的郵件
?public static boolean sendMailtoMultiCC(MailSenderInfo mailInfo){
??MyAuthenticator authenticator = null;
??if (mailInfo.isValidate()) {
???authenticator = new MyAuthenticator(mailInfo.getUserName(),
?????mailInfo.getPassword());
??}
??Session sendMailSession = Session.getInstance(mailInfo
????.getProperties(), authenticator);
??try {
???Message mailMessage = new MimeMessage(sendMailSession);
???????????
???Address from = new InternetAddress(mailInfo.getFromAddress());
???mailMessage.setFrom(from);
?????????
???Address to = new InternetAddress(mailInfo.getToAddress());
???? mailMessage.setRecipient(Message.RecipientType.TO, to);
??? if(!"".equals(mailInfo.getToAddressCCs()) && null!=mailInfo.getToAddressCCs()){
???
???//JDK1.3沒有split函數，無奈只能用StringTokenizer
???? StringTokenizer st = new StringTokenizer(mailInfo.getToAddressCCs(),",");
??? if (st.countTokens()!=0){
????? Address[] ccAdresses = new InternetAddress[st.countTokens()];
????? int i =0;
?????? while(st.hasMoreTokens()){
?????? ccAdresses[i] = new InternetAddress(st.nextToken());
?????? i++;
????? }
????? mailMessage.setRecipients(Message.RecipientType.CC, ccAdresses);
???? }
??? }
???????????
???mailMessage.setSubject(mailInfo.getSubject());
???mailMessage.setSentDate(new Date());
???????????
???Multipart mainPart = new MimeMultipart();
???BodyPart html = new MimeBodyPart();
???html.setContent(mailInfo.getContent(), "text/html; charset=utf-8");
???mainPart.addBodyPart(html);
???mailMessage.setContent(mainPart);
??????????
???Transport.send(mailMessage);
???return true;
??} catch (MessagingException ex) {
???ex.printStackTrace();
??}
??return false;
?}
?
?public boolean sendMail(
???boolean isFromConfig,? //是否從配置文件讀, true: 是, false: 否
???String serverHost,
???String serverPort,
???boolean isValidate,??? //是否需要驗證, true: 是, false: 否
???String userName,
???String passWord,
???String fromAddress,
???String toAddress,
???String toAddressCCS,? // 抄送的郵箱地址
???String subJect,
???String content
???) {
????
???boolean flag=false;?
??MailSenderInfo mailInfo = new MailSenderInfo();
??// 從配置文件讀
??try{
???if(isFromConfig){
????mailInfo.setMailServerHost(ReadConfig.getConfig("SERVERHOST"));
????mailInfo.setMailServerPort(ReadConfig.getConfig("SERVERPORT"));
????mailInfo.setValidate(ReadConfig.getConfig("ISVALIDATE").trim().toUpperCase().equals("TRUE"));
????mailInfo.setUserName(ReadConfig.getConfig("USERNAME"));
????mailInfo.setPassword(ReadConfig.getConfig("PASSWORD"));
????mailInfo.setFromAddress(ReadConfig.getConfig("FROMADDRESS"));
????mailInfo.setToAddress(ReadConfig.getConfig("TOADDRESS"));
????mailInfo.setToAddressCCs(ReadConfig.getConfig("TOADDRESSCCS"));
????
???// 手動設置
???}else{
????mailInfo.setMailServerHost(serverHost);
????mailInfo.setMailServerPort(serverPort);
????mailInfo.setValidate(isValidate);
????mailInfo.setUserName(userName);
????mailInfo.setPassword(passWord);
????mailInfo.setFromAddress(fromAddress);
????mailInfo.setToAddress(toAddress);
????mailInfo.setToAddressCCs(toAddressCCS);
???}
??}catch(Exception e){
???e.printStackTrace();
???flag=false;
??}
??//郵件主題和內容經常變動, 所以允許自己手動填寫
??mailInfo.setSubject(subJect);
??mailInfo.setContent(content);
???if(SimpleMailSender.sendMailtoMultiCC(mailInfo)){
????flag=true;
??}
??return flag;
?}
}
?
-----------------------------------------5: 郵箱驗證------------------------------------
import javax.mail.*;??
????
public class MyAuthenticator extends Authenticator{??
??? String userName=null;??
??? String password=null;??
???????
??? public MyAuthenticator(){??
??? }??
??? public MyAuthenticator(String username, String password) {???
??????? this.userName = username;???
??????? this.password = password;???
??? }???
??? protected PasswordAuthentication getPasswordAuthentication(){??
??????? return new PasswordAuthentication(userName, password);??
??? }??
}
----------------------------------------6: 郵箱基本信息---------------------------------------
?
import java.util.Properties;
public class MailSenderInfo {
?private String mailServerHost;
?private String mailServerPort;
?private String fromAddress;
?private String toAddress;
?private String toAddressCCs;
?private String userName;
?private String password;
?private boolean validate;
?private String subject;
?private String content;
?private String[] attachFileNames;
?public Properties getProperties() {
??Properties p = new Properties();
??p.put("mail.smtp.host", this.mailServerHost);
??p.put("mail.smtp.port", this.mailServerPort);
??p.put("mail.smtp.auth", validate ? "true" : "false");
??return p;
?}
?public String getToAddressCCs() {
??return toAddressCCs;
?}
?public void setToAddressCCs(String toAddressCCs) {
??this.toAddressCCs = toAddressCCs;
?}
?
?public String getMailServerHost() {
??return mailServerHost;
?}
?public void setMailServerHost(String mailServerHost) {
??this.mailServerHost = mailServerHost;
?}
?public String getMailServerPort() {
??return mailServerPort;
?}
?public void setMailServerPort(String mailServerPort) {
??this.mailServerPort = mailServerPort;
?}
?public boolean isValidate() {
??return validate;
?}
?public void setValidate(boolean validate) {
??this.validate = validate;
?}
?public String[] getAttachFileNames() {
??return attachFileNames;
?}
?public void setAttachFileNames(String[] fileNames) {
??this.attachFileNames = fileNames;
?}
?public String getFromAddress() {
??return fromAddress;
?}
?public void setFromAddress(String fromAddress) {
??this.fromAddress = fromAddress;
?}
?public String getPassword() {
??return password;
?}
?public void setPassword(String password) {
??this.password = password;
?}
?public String getToAddress() {
??return toAddress;
?}
?public void setToAddress(String toAddress) {
??this.toAddress = toAddress;
?}
?public String getUserName() {
??return userName;
?}
?public void setUserName(String userName) {
??this.userName = userName;
?}
?public String getSubject() {
??return subject;
?}
?public void setSubject(String subject) {
??this.subject = subject;
?}
?public String getContent() {
??return content;
?}
?public void setContent(String textContent) {
??this.content = textContent;
?}
}
