java检验用户邮箱是否真实有效（去邮箱服务器上检验）

package org.kilfen.mail; import java.net.InetSocketAddress; import java.net.Socket; import java.util.Scanner; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; import javax.net.ssl.SSLSocketFactory; import org.apache.commons.lang.math.NumberUtils; public class MailUtils { private final static String timeOut = "60000"; /** * @param user * @param pass * @param pop3Addr * @param pop3Port * @param smtpAddr * @param smtpPort * @return 0:有效,-1:无效,1:pop3有效smtp无效 */ public int checkEMailValid(final String emailAddr, final String pass, final String pop3Addr, final String pop3Port, final String smtpAddr, final String smtpPort, final boolean pop3Ssl, final boolean smtpSsl){ long curTime = System.currentTimeMillis(); int code = -1; Pop3ServerCheck pop3CheckServer = new Pop3ServerCheck(pop3Addr, NumberUtils.toInt(pop3Port), timeOut, pop3Ssl); FutureTask<Boolean> pop3ServerTask = new FutureTask<Boolean>(pop3CheckServer); new Thread(pop3ServerTask).start(); Pop3Check pop3EmailCheck = new Pop3Check(emailAddr, pass, pop3Addr, pop3Port, timeOut, pop3Ssl); FutureTask<Boolean> pop3EmailTask = new FutureTask<Boolean>(pop3EmailCheck); new Thread(pop3EmailTask).start(); SmtpCheck smtpCheck = new SmtpCheck(smtpAddr, smtpPort, timeOut, smtpSsl); FutureTask<Boolean> smtpTask = new FutureTask<Boolean>(smtpCheck); new Thread(smtpTask).start(); try{ if(pop3ServerTask.get()){ if(pop3EmailTask.get()){ if(smtpTask.get()){ code = 0; }else{ code = 1; } }else{ smtpTask.cancel(true); } }else{ code = 2; pop3EmailTask.cancel(true); smtpTask.cancel(true); } }catch(ExecutionException ee){ ee.printStackTrace(); }catch(InterruptedException ie){ ie.printStackTrace(); }catch(Exception e){ e.printStackTrace(); } System.out.println("check email is used:"+(System.currentTimeMillis()-curTime)); return code; } public static boolean checkSmtpServer(final String smtpAddr, final int port, final boolean ssl) { boolean result = false; System.out.println("checkSmtpServer smtpAddr-->" + smtpAddr + " port-->" + port + " ssl-->" + ssl); long curTime = System.currentTimeMillis(); Socket socket = null; try { //安全连接 if(ssl){ socket = SSLSocketFactory.getDefault().createSocket(); }else{ socket = new Socket(); } socket.connect(new InetSocketAddress(smtpAddr, port), 60000); Scanner scanner = new Scanner(socket.getInputStream()); String line = scanner.nextLine(); if (line != null) { if (line.startsWith("220")){ result = true; } } } catch (Exception e) { e.printStackTrace(); }finally{ try { socket.close(); } catch (Exception ex) { ex.printStackTrace(); } } System.out.println("checkSmtpServer is used time:" + (System.currentTimeMillis() - curTime) + " result is --->" + result); return result; } public static void main(String[] args) { boolean pop3Ssl = false; boolean smtpSsl = false; String user = "zhulingyanc@163.com"; String pass = "49660020"; String pop3Addr = "pop.163.com"; String pop3Port = "110"; String smtpAddr = "smtp.163.com"; String smtpPort = "25"; System.out.println(new MailUtils().checkEMailValid(user, pass, pop3Addr, pop3Port, smtpAddr, smtpPort, pop3Ssl, smtpSsl)); } }