Java与邮件系统交互之使用Socket验证邮箱是否存在

  最近遇到一个需求:需要验证用户填写的邮箱地址是否真实存在,是否可达。和普通的正则表达式不同,他要求尝试链接目标邮箱服务器并请求校验目标邮箱是否存在。

先来了解


 

  DNS之MX记录

  对于DNS不了解的,请移步百度搜索。

  DNS中除了A记录(域名-IP映射)之外,还有MX记录(邮件交换记录),CNAME记录(别名,咱不管)。

  MX记录就是为了在发送邮件时使用友好域名规则,比如我们发送到QQ邮箱[email protected]。我们填写地址是到“qq.com”,但实际上可能服务器地址千奇百怪/而且许有多个。在设置DNS时可以顺带设置MX记录。

  说白了,“qq.com”只是域名,做HTTP请求响应地址,你邮件能发到Tomcat上吗?那我们发到“qq.com”上面的邮件哪里去了,我们把自己想象成一个邮件服务器,你的用户让你给[email protected]发一封信,你如何操作?找mx记录是必要的。

  SMTP之纯Socket访问

  对于SMTP不了解或Java Socket不了解的,请移步百度搜索。

  邮件协议是匿名协议,我们通过SMTP协议可以让邮件服务器来验证目标地址是否真实存在。

代码实现


 

  由以上介绍可知:通过DNS中MX记录可以找到邮件服务器地址,通过SMTP协议可以让邮件服务器验证目标邮箱地址的真实性。

  那么我们就来进行编码实现。

  首先需要查询DNS,这个需要用到一个Java查询DNS的组件dnsjava(下载),自己写太麻烦。

技术分享
 1 // 查找mx记录
 2             Record[] mxRecords = new Lookup(host, Type.MX).run();
 3             if(ArrayUtils.isEmpty(mxRecords)) return false;
 4             // 邮件服务器地址
 5             String mxHost = ((MXRecord)mxRecords[0]).getTarget().toString();
 6             if(mxRecords.length > 1) { // 优先级排序
 7                 List<Record> arrRecords = new ArrayList<Record>();
 8                 Collections.addAll(arrRecords, mxRecords);
 9                 Collections.sort(arrRecords, new Comparator<Record>() {
10                     
11                     public int compare(Record o1, Record o2) {
12                         return new CompareToBuilder().append(((MXRecord)o1).getPriority(), ((MXRecord)o2).getPriority()).toComparison();
13                     }
14                     
15                 });
16                 mxHost = ((MXRecord)arrRecords.get(0)).getTarget().toString();
17             }
mx

  (上面代码中的生僻类型就是来自dnsjava,我使用apache-commons组件来判断空值和构建排序,return false是在查询失败时。)

  接下来通过优先级排序(mx记录有这个属性)取第一个邮件服务器地址来链接。

  这里的主要代码是通过SMTP发送RCPT TO指令来指定邮件接收方,如果这个地址存在则服务器返回成功状态,如果没有的话则返回错误指令。

1 // 验证
2             bufferedWriter.write("RCPT TO: <" + toMail + ">\r\n");
3             bufferedWriter.flush();
4             if(getResponseCode(timeout, sleepSect, bufferedReader) != 250) {
5                 return false;
6             }

  (上面代码中toMail即要验证的邮件地址)

  下面是全部代码

  1 import java.io.BufferedInputStream;
  2 import java.io.BufferedReader;
  3 import java.io.BufferedWriter;
  4 import java.io.IOException;
  5 import java.io.InputStreamReader;
  6 import java.io.OutputStreamWriter;
  7 import java.net.InetSocketAddress;
  8 import java.net.Socket;
  9 import java.util.ArrayList;
 10 import java.util.Collections;
 11 import java.util.Comparator;
 12 import java.util.List;
 13 
 14 import org.apache.commons.lang.ArrayUtils;
 15 import org.apache.commons.lang.StringUtils;
 16 import org.apache.commons.lang.builder.CompareToBuilder;
 17 import org.xbill.DNS.Lookup;
 18 import org.xbill.DNS.MXRecord;
 19 import org.xbill.DNS.Record;
 20 import org.xbill.DNS.TextParseException;
 21 import org.xbill.DNS.Type;
 22 
 23 
 24 public class MailValid {
 25 
 26     public static void main(String[] args) {
 27         System.out.println(new MailValid().valid("[email protected]", "jootmir.org"));
 28     }
 29     
 30     /**
 31      * 验证邮箱是否存在
 32      * <br>
 33      * 由于要读取IO,会造成线程阻塞
 34      * 
 35      * @param toMail
 36      *         要验证的邮箱
 37      * @param domain
 38      *         发出验证请求的域名(是当前站点的域名,可以任意指定)
 39      * @return
 40      *         邮箱是否可达
 41      */
 42     public boolean valid(String toMail, String domain) {
 43         if(StringUtils.isBlank(toMail) || StringUtils.isBlank(domain)) return false;
 44         if(!StringUtils.contains(toMail, ‘@‘)) return false;
 45         String host = toMail.substring(toMail.indexOf(‘@‘) + 1);
 46         if(host.equals(domain)) return false;
 47         Socket socket = new Socket();
 48         try {
 49             // 查找mx记录
 50             Record[] mxRecords = new Lookup(host, Type.MX).run();
 51             if(ArrayUtils.isEmpty(mxRecords)) return false;
 52             // 邮件服务器地址
 53             String mxHost = ((MXRecord)mxRecords[0]).getTarget().toString();
 54             if(mxRecords.length > 1) { // 优先级排序
 55                 List<Record> arrRecords = new ArrayList<Record>();
 56                 Collections.addAll(arrRecords, mxRecords);
 57                 Collections.sort(arrRecords, new Comparator<Record>() {
 58                     
 59                     public int compare(Record o1, Record o2) {
 60                         return new CompareToBuilder().append(((MXRecord)o1).getPriority(), ((MXRecord)o2).getPriority()).toComparison();
 61                     }
 62                     
 63                 });
 64                 mxHost = ((MXRecord)arrRecords.get(0)).getTarget().toString();
 65             }
 66             // 开始smtp
 67             socket.connect(new InetSocketAddress(mxHost, 25));
 68             BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(new BufferedInputStream(socket.getInputStream())));
 69             BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
 70             // 超时时间(毫秒)
 71             long timeout = 6000;
 72             // 睡眠时间片段(50毫秒)
 73             int sleepSect = 50;
 74             
 75             // 握手
 76             bufferedWriter.write("HELO " + domain + "\r\n");
 77             bufferedWriter.flush();
 78             if(getResponseCode(timeout, sleepSect, bufferedReader) != 220) {
 79                 return false;
 80             }
 81             // 身份
 82             bufferedWriter.write("MAIL FROM: <check@" + domain + ">\r\n");
 83             bufferedWriter.flush();
 84             if(getResponseCode(timeout, sleepSect, bufferedReader) != 250) {
 85                 return false;
 86             }
 87             // 验证
 88             bufferedWriter.write("RCPT TO: <" + toMail + ">\r\n");
 89             bufferedWriter.flush();
 90             if(getResponseCode(timeout, sleepSect, bufferedReader) != 250) {
 91                 return false;
 92             }
 93             // 断开
 94             bufferedWriter.write("QUIT\r\n");
 95             bufferedWriter.flush();
 96             return true;
 97         } catch (NumberFormatException e) {
 98         } catch (TextParseException e) {
 99         } catch (IOException e) {
100         } catch (InterruptedException e) {
101         } finally {
102             try {
103                 socket.close();
104             } catch (IOException e) {
105             }
106         }
107         return false;
108     }
109     
110     private int getResponseCode(long timeout, int sleepSect, BufferedReader bufferedReader) throws InterruptedException, NumberFormatException, IOException {
111         int code = 0;
112         for(long i = sleepSect; i < timeout; i += sleepSect) {
113             Thread.sleep(sleepSect);
114             if(bufferedReader.ready()) {
115                 String outline = bufferedReader.readLine();
116                 // FIXME 读完……
117                 while(bufferedReader.ready())
118                     bufferedReader.readLine();
119                 //System.out.println(outline);
120                 code = Integer.parseInt(outline.substring(0, 3));
121                 break;
122             }
123         }
124         return code;
125     }
126 }

  (解锁119行代码和输出118行数据可以让你更加清晰SMTP协议)

  对于企业邮箱,可能无法正常验证,这个是因为服务器问题。另外,dnsjava查询DNS是有缓存的。

  现在工作越来越紧张,对于技术的理解也较以前深刻。现在写出的代码可能较为精简(这意味着如果你是新手可能不容易理解)。

联系我,一起交流


 

 欢迎您移步我们的交流群,无聊的时候大家一起打发时间:技术分享

 

 技术分享

或者通过QQ与我联系:技术分享

技术分享

 (最后编辑时间2015-04-28 22:03:03)

 

郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。