Java程式Mail、EDM(電子型錄)寄送

這個範例主要的概念是抓取網路上EDM的html內容，讀取外部的寄送email清單文字檔，依續一個個email寄送出EDM內容，寄送的每一封信件都使用thread來獨立完成，而且寄送中間都有固定的間隔時間。

JavaMail是Java用來處理Mail事件的一個Framework，提供寄信SMTP、收信POP3等常用到的Mail Protocol，主要由sun(目前為oracle)來維護，是一個官方的套件，可由此下載。

發送Mail的主體程式Thread

Mail發送的內容為html，所以需要使用Multipart來承載內容，如果是純文字則可直接使用Message的setContent來加入信件內容。

package com.izero.mail.thread;

import java.util.*;

import javax.mail.*;

import javax.mail.internet.*;

public class Sender extends java.lang.Thread {
    private String content;
    // log
    private org.apache.log4j.Logger log;
    // 郵件標題
    private String subject;
    // 寄件對向
    private String to;
    // 設定檔
    private Properties p;

    // 建構
    public Sender(String to, String subject, String content, Properties p) {
        super();
        this.content = content;
        this.to = to;
        log = org.apache.log4j.Logger.getLogger(this.getClass());
        this.p = p;
        this.subject = subject;
    }

    // thread run
    public void run() {
        try {

            // 設定傳送基本資訊
            // 取得mail host名稱
            String host = p.getProperty("host");
            // 取得寄信者mail
            String from = p.getProperty("from");

            // 取得寄信者帳號
            String user = p.getProperty("user");
            // 取得寄信者帳號密碼
            String pwd = p.getProperty("pwd");

            Properties props = System.getProperties();

            // 設定SMTP server

            props.put("mail.smtp.host", host);
            // 是否需要認證
            props.put("mail.smtp.auth", "true");

            // 依據Properties建立一個Session

            Session mailSession = Session.getInstance(props, null);

            // 從Session建立一個Message
            MimeMessage message = new MimeMessage(mailSession);

            // 設定mail From
            message.setFrom(new InternetAddress(from, p.getProperty("fromName",
                    "utf-8")));
            // 設定mail To
            message.addRecipient(Message.RecipientType.TO, new InternetAddress(
                    to));
            // 設定標題
            message.setSubject(this.subject);

            // 設定寄件日期
            message.setSentDate(new Date());
            // 建立郵件本文內容
            Multipart multipart = new MimeMultipart();

            // 郵件內容
            BodyPart contentPart = new MimeBodyPart();
            // 給BodyPart對像設置內容和格式/編碼方式
            contentPart.setContent(content, "text/html;charset=utf8");

            // 加入郵件內容到mutipart裡
            multipart.addBodyPart(contentPart);

            // 將multipart加到mail的message裡
            message.setContent(multipart);
            // 產生mail message
            message.saveChanges();

            Transport transport = mailSession.getTransport("smtp");
            // 傳送
            transport.connect(host, user, pwd);
            transport.sendMessage(message, message.getAllRecipients());
            transport.close();
            log.info(to + ",寄送完成");

        } catch (Exception e) {

            log.info(this.to + "-" + e.getMessage());
            e.printStackTrace();

        }

    }
}

取得網頁內容程式WebModule

請參考java HttpURLConnection來實作get及post動作

package com.izero.http;

import java.net.*;
import java.io.*;

public class WebModule {
    private org.apache.log4j.Logger logger;
    private StringBuffer buff;

    public WebModule() {
        logger = org.apache.log4j.Logger.getLogger(this.getClass());
        buff = new StringBuffer();
    }

    public boolean doPost(String sURL, String data, String cookie,
            String referer, String charset) {

        boolean doSuccess = true;
        java.io.BufferedWriter wr = null;
        try {

            URL url = new URL(sURL);
            HttpURLConnection URLConn = (HttpURLConnection) url
                    .openConnection();

            URLConn.setDoOutput(true);
            URLConn.setDoInput(true);
            ((HttpURLConnection) URLConn).setRequestMethod("POST");
            URLConn.setUseCaches(false);
            URLConn.setAllowUserInteraction(true);
            HttpURLConnection.setFollowRedirects(true);
            URLConn.setInstanceFollowRedirects(true);

            URLConn.setRequestProperty(
                    "User-agent",
                    "Mozilla/5.0 (Windows; U; Windows NT 6.0; zh-TW; rv:1.9.1.2) "
                            + "Gecko/20090729 Firefox/3.5.2 GTB5 (.NET CLR 3.5.30729)");
            URLConn.setRequestProperty("Accept",
                    "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8");
            URLConn.setRequestProperty("Accept-Language",
                    "zh-tw,en-us;q=0.7,en;q=0.3");
            URLConn.setRequestProperty("Accept-Charse",
                    "Big5,utf-8;q=0.7,*;q=0.7");
            if (cookie != null)
                URLConn.setRequestProperty("Cookie", cookie);
            if (referer != null)
                URLConn.setRequestProperty("Referer", referer);

            URLConn.setRequestProperty("Content-Type",
                    "application/x-www-form-urlencoded");
            URLConn.setRequestProperty("Content-Length",
                    String.valueOf(data.getBytes().length));

            java.io.DataOutputStream dos = new java.io.DataOutputStream(
                    URLConn.getOutputStream());
            dos.writeBytes(data);

            java.io.BufferedReader rd = new java.io.BufferedReader(
                    new java.io.InputStreamReader(URLConn.getInputStream(),
                            charset));
            String line;
            while ((line = rd.readLine()) != null) {
                buff.append(line);
            }

            rd.close();
        } catch (java.io.IOException e) {
            doSuccess = false;
            logger.info(e);

        } finally {
            if (wr != null) {
                try {
                    wr.close();
                } catch (java.io.IOException ex) {
                    logger.info(ex);
                }
                wr = null;
            }
        }

        return doSuccess;
    }

    public boolean doGet(String sURL, String cookie, String referer,
            String charset) {
        boolean doSuccess = true;
        BufferedReader in = null;
        try {
            URL url = new URL(sURL);
            HttpURLConnection URLConn = (HttpURLConnection) url
                    .openConnection();
            URLConn.setRequestProperty(
                    "User-agent",
                    "Mozilla/5.0 (Windows; U; Windows NT 6.0; zh-TW; rv:1.9.1.2) "
                            + "Gecko/20090729 Firefox/3.5.2 GTB5 (.NET CLR 3.5.30729)");
            URLConn.setRequestProperty("Accept",
                    "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8");
            URLConn.setRequestProperty("Accept-Language",
                    "zh-tw,en-us;q=0.7,en;q=0.3");
            URLConn.setRequestProperty("Accept-Charse",
                    "Big5,utf-8;q=0.7,*;q=0.7");

            if (cookie != null)
                URLConn.setRequestProperty("Cookie", cookie);
            if (referer != null)
                URLConn.setRequestProperty("Referer", referer);
            URLConn.setDoInput(true);
            URLConn.setDoOutput(true);
            URLConn.connect();
            URLConn.getOutputStream().flush();
            in = new BufferedReader(new InputStreamReader(
                    URLConn.getInputStream(), charset));

            String line;
            while ((line = in.readLine()) != null) {
                buff.append(line);
            }

        } catch (IOException e) {
            doSuccess = false;
            logger.info(e);
            e.printStackTrace();
        } finally {
            if (in != null) {
                try {
                    in.close();
                } catch (java.io.IOException ex) {
                    logger.info(ex);
                }
                in = null;

            }
        }

        return doSuccess;
    }

    public String getContent() {
        return buff.toString();
    }
}

設定檔內容

host=你的mail主機
from=你的mail
auth=true
user=你的帳號
pwd=你的密碼
sleep=5000
fromName=寄信者顯示名稱
edmList=d:/mail/list.txt
edmUrl=edm的網址
edmSubject=郵件標題

主程式

也是個thread，讀取外部email清單，取得edm的html內容，配製寄送的thread。

mail清單列表需要是一個文字檔，每一個mail一行。

package com.izero.mail;

import java.util.Properties;

public class Main extends java.lang.Thread {
    private org.apache.log4j.Logger log;
    private java.util.ArrayList<String> toList;

    private Properties p;
    private String content;
    private String subject;

    public Main() throws java.io.IOException {
        super();

        log = org.apache.log4j.Logger.getLogger(this.getClass());
        java.io.FileReader fis = null;
        java.io.BufferedReader bis = null;
        toList = new java.util.ArrayList<String>();

        try {
            // 從外部取得設定檔資料
            p = new Properties();
            log.info(this.getClass().getResource("/mail.properties").getPath());
            java.io.FileReader fr = new java.io.FileReader(this.getClass()
                    .getResource("/mail.properties").getPath());
            java.io.BufferedReader br = new java.io.BufferedReader(fr);
            String str;
            while ((str = br.readLine()) != null) {
                String[] tmp = str.split("=");
                p.setProperty(tmp[0], tmp[1]);
            }
            br.close();
            fr.close();

            // 名單
            fis = new java.io.FileReader(p.getProperty("edmList"));
            bis = new java.io.BufferedReader(fis);

            while ((str = bis.readLine()) != null) {
                toList.add(str.trim());
            }
            fis.close();
            bis.close();
            fis = null;
            bis = null;

            // 取得網頁內容
            com.izero.http.WebModule web = new com.izero.http.WebModule();
            if (web.doGet(p.getProperty("edmUrl"), null, null, "utf-8")) {
                content = web.getContent();
            } else {
                throw new java.io.IOException("取得網頁資料錯誤!");
            }

            // 郵件標題
            this.subject = p.getProperty("edmSubject");

        } catch (java.io.IOException e) {
            log.info(e.getMessage());

            throw e;
        } finally {
            try {
                if (bis != null)
                    bis.close();

                if (fis != null)
                    fis.close();
                bis = null;
                fis = null;
            } catch (java.io.IOException ex) {

            }
        }

    }

    public void run() {

        java.io.FileWriter fw = null;

        try {

            for (int i = 0; i < toList.size(); i++) {

                // 啟動thread開始寄信
                com.izero.mail.thread.Sender sender = new com.izero.mail.thread.Sender(
                        toList.get(i), subject, content, p);
                sender.start();
                // 暫停數秒後再開始寄信
                Thread.sleep(Integer.parseInt(p.getProperty("sleep")));

                if (fw != null) {
                    fw.flush();
                    fw.write(toList.get(i) + "\r\n");
                }

            }

        } catch (Exception e) {
            log.info(e.getMessage());
            e.printStackTrace();
        } finally {
            if (fw != null) {
                try {
                    fw.flush();
                    fw.close();
                } catch (Exception e) {
                }

            }
        }

    }

    public static void main(String args[]) throws java.io.IOException {
        Main m = new Main();
        m.start();
    }
}

log4j的設定檔

log4j.rootLogger=INFO,R, stdout
#log4j.logger.system = debug,R


log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d %p    %c- %m%n

log4j.appender.R=org.apache.log4j.DailyRollingFileAppender
log4j.appender.R.Append=true
log4j.appender.R.File.DatePattern='.'yyyy-MM-dd
log4j.appender.R.File=mail.log


#log4j.appender.R.MaxFileSize=100KB
#log4j.appender.R.MaxBackupIndex=5

log4j.appender.R.layout=org.apache.log4j.PatternLayout
log4j.appender.R.layout.ConversionPattern=%d %p    %c- %m%n