Java與郵件系統交互之使用Socket驗證郵箱是否存在

　　最近遇到一個需求：需要驗證用戶填寫的郵箱地址是否真實存在，是否可達。和普通的正則表達式不同，他要求嘗試鏈接目標郵箱服務器並請求校驗目標郵箱是否存在。

先來了解

---

 

　　DNS之MX記錄

　　對於DNS不了解的，請移步百度搜索。

　　DNS中除了A記錄(域名-IP映射)之外，還有MX記錄(郵件交換記錄)，CNAME記錄(別名，咱不管)。

　　MX記錄就是為了在發送郵件時使用友好域名規則，比如我們發送到QQ郵箱[e-mail]。我們填寫地址是到“qq.com”，但實際上可能服務器地址千奇百怪/而且許有多個。在設置DNS時可以順帶設置MX記錄。

　　說白了，“qq.com”只是域名，做HTTP請求響應地址，你郵件能發到Tomcat上嗎？那我們發到“qq.com”上面的郵件哪里去了，我們把自己想象成一個郵件服務器，你的用戶讓你給[e-mail]發一封信，你如何操作？找mx記錄是必要的。

　　SMTP之純Socket訪問

　　對於SMTP不了解或Java Socket不了解的，請移步百度搜索。

　　郵件協議是匿名協議，我們通過SMTP協議可以讓郵件服務器來驗證目標地址是否真實存在。

代碼實現

---

 

　　由以上介紹可知：通過DNS中MX記錄可以找到郵件服務器地址，通過SMTP協議可以讓郵件服務器驗證目標郵箱地址的真實性。

　　那么我們就來進行編碼實現。

　　首先需要查詢DNS，這個需要用到一個Java查詢DNS的組件dnsjava(下載)，自己寫太麻煩。

// 查找mx記錄
            Record[] mxRecords = new Lookup(host, Type.MX).run();
            if(ArrayUtils.isEmpty(mxRecords)) return false;
            // 郵件服務器地址
            String mxHost = ((MXRecord)mxRecords[0]).getTarget().toString();
            if(mxRecords.length > 1) { // 優先級排序
                List<Record> arrRecords = new ArrayList<Record>();
                Collections.addAll(arrRecords, mxRecords);
                Collections.sort(arrRecords, new Comparator<Record>() {
                    
                    public int compare(Record o1, Record o2) {
                        return new CompareToBuilder().append(((MXRecord)o1).getPriority(), ((MXRecord)o2).getPriority()).toComparison();
                    }
                    
                });
                mxHost = ((MXRecord)arrRecords.get(0)).getTarget().toString();
            }

　　(上面代碼中的生僻類型就是來自dnsjava，我使用apache-commons組件來判斷空值和構建排序，return false是在查詢失敗時。)

　　接下來通過優先級排序(mx記錄有這個屬性)取第一個郵件服務器地址來鏈接。

　　這里的主要代碼是通過SMTP發送RCPT TO指令來指定郵件接收方，如果這個地址存在則服務器返回成功狀態，如果沒有的話則返回錯誤指令。

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.List;

import org.apache.commons.lang.ArrayUtils;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.builder.CompareToBuilder;
import org.xbill.DNS.Lookup;
import org.xbill.DNS.MXRecord;
import org.xbill.DNS.Record;
import org.xbill.DNS.TextParseException;
import org.xbill.DNS.Type;


public class MailValid {

    public static void main(String[] args) {
        System.out.println(new MailValid().valid("[e-mail]", "jootmir.org"));
    }
    
    /**
     * 驗證郵箱是否存在
     * <br>
     * 由於要讀取IO，會造成線程阻塞
     * 
     * @param toMail
     *         要驗證的郵箱
     * @param domain
     *         發出驗證請求的域名(是當前站點的域名，可以任意指定)
     * @return
     *         郵箱是否可達
     */
    public boolean valid(String toMail, String domain) {
        if(StringUtils.isBlank(toMail) || StringUtils.isBlank(domain)) return false;
        if(!StringUtils.contains(toMail, '@')) return false;
        String host = toMail.substring(toMail.indexOf('@') + 1);
        if(host.equals(domain)) return false;
        Socket socket = new Socket();
        try {
            // 查找mx記錄
            Record[] mxRecords = new Lookup(host, Type.MX).run();
            if(ArrayUtils.isEmpty(mxRecords)) return false;
            // 郵件服務器地址
            String mxHost = ((MXRecord)mxRecords[0]).getTarget().toString();
            if(mxRecords.length > 1) { // 優先級排序
                List<Record> arrRecords = new ArrayList<Record>();
                Collections.addAll(arrRecords, mxRecords);
                Collections.sort(arrRecords, new Comparator<Record>() {
                    
                    public int compare(Record o1, Record o2) {
                        return new CompareToBuilder().append(((MXRecord)o1).getPriority(), ((MXRecord)o2).getPriority()).toComparison();
                    }
                    
                });
                mxHost = ((MXRecord)arrRecords.get(0)).getTarget().toString();
            }
            // 開始smtp
            socket.connect(new InetSocketAddress(mxHost, 25));
            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(new BufferedInputStream(socket.getInputStream())));
            BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            // 超時時間(毫秒)
            long timeout = 6000;
            // 睡眠時間片段(50毫秒)
            int sleepSect = 50;
            
            // 連接(服務器是否就緒)
            if(getResponseCode(timeout, sleepSect, bufferedReader) != 220) {
                return false;
            }
            
            // 握手
            bufferedWriter.write("HELO " + domain + "\r\n");
            bufferedWriter.flush();
            if(getResponseCode(timeout, sleepSect, bufferedReader) != 250) {
                return false;
            }
            // 身份
            bufferedWriter.write("MAIL FROM: <check@" + domain + ">\r\n");
            bufferedWriter.flush();
            if(getResponseCode(timeout, sleepSect, bufferedReader) != 250) {
                return false;
            }
            // 驗證
            bufferedWriter.write("RCPT TO: <" + toMail + ">\r\n");
            bufferedWriter.flush();
            if(getResponseCode(timeout, sleepSect, bufferedReader) != 250) {
                return false;
            }
            // 斷開
            bufferedWriter.write("QUIT\r\n");
            bufferedWriter.flush();
            return true;
        } catch (NumberFormatException e) {
        } catch (TextParseException e) {
        } catch (IOException e) {
        } catch (InterruptedException e) {
        } finally {
            try {
                socket.close();
            } catch (IOException e) {
            }
        }
        return false;
    }
    
    private int getResponseCode(long timeout, int sleepSect, BufferedReader bufferedReader) throws InterruptedException, NumberFormatException, IOException {
        int code = 0;
        for(long i = sleepSect; i < timeout; i += sleepSect) {
            Thread.sleep(sleepSect);
            if(bufferedReader.ready()) {
                String outline = bufferedReader.readLine();
                // FIXME 讀完……
                while(bufferedReader.ready())
                    /*System.out.println(*/bufferedReader.readLine()/*)*/;
                /*System.out.println(outline);*/
                code = Integer.parseInt(outline.substring(0, 3));
                break;
            }
        }
        return code;
    }
}

 

　　(解鎖和輸出123、124行數據可以讓你更加清晰SMTP協議)

　　對於企業郵箱，可能無法正常驗證，這個是因為服務器問題。另外，dnsjava查詢DNS是有緩存的。

　　現在工作越來越緊張，對於技術的理解也較以前深刻。現在寫出的代碼可能較為精簡(這意味着如果你是新手可能不容易理解)。

聯系我，一起交流

---

 

 歡迎您移步我們的交流群，無聊的時候大家一起打發時間：

 

 

或者通過QQ與我聯系：

 （最后編輯時間2015-04-29 10:27:44）