用Java Socket实现SMTP邮件发送

什么是SMTP？

  SMTP（Simple Mail Transfer Protocol）即简单邮件传输协议，它是一种提供可靠且有效电子邮件传输的协议。SMTP是建模在FTP文件传输服务上的一种邮件服务，主要用于传输系统之间的邮件信息并提供来信有关的通知。



协议结构

  SMTP命令是发送于SMTP主机之间的ASCII信息，下面列举了5个常用SMTP指令

HELO <服务商><域名><换行> 与SMTP服务器握手
MAIL <服务商> FROM:<发件人地址><换行> 传送发件人的邮箱地址
RCPT <服务商> TO:<收件人地址><换行>  传送收件人的邮箱地址
DATA <换行> 发送邮件数据，以新行.结束（包括信头与信体）
QUIT <换行> 与SMTP服务器断开连接



信头与信体

  在DATA指令所传送的数据中，信头和信体以一个空行分隔，下面列举了部分常用信头

From: 发件人地址
To: 收件人地址
Subject: 邮件主题
Date: 发信时间
MIME-Version: MIME版本
Content-Type: 内容类型
Content-Transfer-Encoding: 编码方式
X-Priority: 优先级
X-Mailer: 代理发信的客户端



通过Socket发送SMTP邮件

1.Base64

  Base64内容传送编码被设计用来把任意序列的8位字节描述为一种不易被人直接识别的形式，它要求把每三个8位的字节转换为四个6位的字节，然后在6位字节的高位补两个0，最后组成四个8位的字节。在发送电子邮件时，服务器认证的用户名和密码需要用Base64编码，附件也需要用Base64编码。这种加密方式并非绝对安全，只能做到让人不能直接看出原本内容而已。

一个用Java实现的Base64的加/解密类
Java代码 复制代码 收藏代码
  1. package org.gameeden.security;   
  2.   
  3. import java.io.ByteArrayOutputStream;   
  4.   
  5. /**  
  6.  * Base64编码/解码器。  
  7.  * @author Sol  
  8.  */  
  9. public class Base64   
  10. {   
  11.     private final static char[] BASE64_ENCODING_TABLE;   
  12.     private final static byte[] BASE64_DECODING_TABLE;   
  13.   
  14.     static    
  15.     {   
  16.         BASE64_ENCODING_TABLE="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/".toCharArray();   
  17.         BASE64_DECODING_TABLE=new byte[]   
  18.         {   
  19.             -1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,   
  20.             -1,-1,-1,-1,-1,-1,-1,-1,-1,-1,-1,62,-1,-1,-1,63,52,53,54,55,56,57,58,59,60,61,-1,-1,-1,-1,-1,-1,   
  21.             -1, 0, 1, 2, 3, 4, 5, 6, 7, 8, 9,10,11,12,13,14,15,16,17,18,19,20,21,22,23,24,25,-1,-1,-1,-1,-1,   
  22.             -1,26,27,28,29,30,31,32,33,34,35,36,37,38,39,40,41,42,43,44,45,46,47,48,49,50,51,-1,-1,-1,-1,-1  
  23.         };   
  24.     }   
  25.        
  26.     private Base64()   
  27.     {    
  28.     }   
  29.        
  30.     /**  
  31.      * 将数据进行Base64编码。  
  32.      * @param data 数据  
  33.      * @param offset 数据中的初始偏移量  
  34.      * @param length 写入的字节数  
  35.      * @return 编码后的字符串  
  36.      */  
  37.     public final static String encode(byte[] data,int offset,int length)   
  38.     {   
  39.         if(data==null)   
  40.         {   
  41.             return null;   
  42.         }   
  43.            
  44.         StringBuffer buffer=new StringBuffer();   
  45.         int[] temp=new int[3];   
  46.         int end=offset+length;   
  47.            
  48.         while(offset<end)   
  49.         {               
  50.             temp[0]=data[offset++]&255;   
  51.                
  52.             if(offset==data.length)   
  53.             {   
  54.                 buffer.append(BASE64_ENCODING_TABLE[(temp[0]>>>2)&63]);   
  55.                 buffer.append(BASE64_ENCODING_TABLE[(temp[0]<<4)&63]);   
  56.                 buffer.append('=');   
  57.                 buffer.append('=');   
  58.                    
  59.                 break;   
  60.             }   
  61.                
  62.             temp[1]=data[offset++]&255;   
  63.                
  64.             if(offset==data.length)   
  65.             {   
  66.                 buffer.append(BASE64_ENCODING_TABLE[(temp[0]>>>2)&63]);   
  67.                 buffer.append(BASE64_ENCODING_TABLE[((temp[0]<<4)|(temp[1]>>>4))&63]);   
  68.                 buffer.append(BASE64_ENCODING_TABLE[(temp[1]<<2)&63]);   
  69.                 buffer.append('=');   
  70.                    
  71.                 break;   
  72.             }   
  73.                
  74.             temp[2]=data[offset++]&255;   
  75.                
  76.             buffer.append(BASE64_ENCODING_TABLE[(temp[0]>>>2)&63]);   
  77.             buffer.append(BASE64_ENCODING_TABLE[((temp[0]<<4)|(temp[1]>>>4))&63]);   
  78.             buffer.append(BASE64_ENCODING_TABLE[((temp[1]<<2)|(temp[2]>>>6))&63]);   
  79.             buffer.append(BASE64_ENCODING_TABLE[temp[2]&63]);   
  80.         }   
  81.            
  82.         return buffer.toString();   
  83.     }   
  84.        
  85.     /**  
  86.      * 将数据进行Base64编码。  
  87.      * @param data 数据  
  88.      * @return 编码后的字符串  
  89.      */  
  90.     public final static String encode(byte[] data)   
  91.     {   
  92.         return encode(data,0,data.length);   
  93.     }   
  94.   
  95.     /**  
  96.      * 将字符串进行Base64编码。  
  97.      * @param str 字符串  
  98.      * @return 编码后的字符串  
  99.      */  
  100.     public final static String encode(String str)   
  101.     {   
  102.         return encode(str.getBytes());   
  103.     }   
  104.        
  105.     /**  
  106.      * 对使用Base64编码的字符串进行解码。  
  107.      * @param str 经过编码的字符串  
  108.      * @return 解码后的数据  
  109.      */  
  110.     public final static byte[] decode(String str)   
  111.     {   
  112.         if(str==null)   
  113.         {   
  114.             return null;   
  115.         }   
  116.   
  117.         ByteArrayOutputStream buffer=new ByteArrayOutputStream();   
  118.         byte[] data=str.getBytes();   
  119.         int[] temp=new int[4];   
  120.         int index=0;   
  121.            
  122.         while(index<data.length)   
  123.         {   
  124.             do  
  125.             {   
  126.                 temp[0]=BASE64_DECODING_TABLE[data[index++]];   
  127.             }while(index<data.length&&temp[0]==-1);   
  128.                
  129.             if(temp[0]==-1)   
  130.             {   
  131.                 break;   
  132.             }   
  133.   
  134.             do  
  135.             {   
  136.                 temp[1]=BASE64_DECODING_TABLE[data[index++]];   
  137.             }while(index<data.length&&temp[1]==-1);   
  138.                
  139.             if(temp[1]==-1)   
  140.             {   
  141.                 break;   
  142.             }   
  143.                
  144.             buffer.write(((temp[0]<<2)&255)|((temp[1]>>>4)&255));   
  145.   
  146.             do  
  147.             {   
  148.                 temp[2]=data[index++];   
  149.                    
  150.                 if(temp[2]==61)   
  151.                 {   
  152.                     return buffer.toByteArray();   
  153.                 }   
  154.                    
  155.                 temp[2]=BASE64_DECODING_TABLE[temp[2]];   
  156.             }while(index<data.length&&temp[2]==-1);   
  157.                
  158.             if(temp[2]==-1)   
  159.             {   
  160.                 break;   
  161.             }   
  162.                
  163.             buffer.write(((temp[1]<<4)&255)|((temp[2]>>>2)&255));   
  164.   
  165.             do  
  166.             {   
  167.                 temp[3]=data[index++];   
  168.                    
  169.                 if(temp[3]==61)   
  170.                 {   
  171.                     return buffer.toByteArray();   
  172.                 }   
  173.                    
  174.                 temp[3]=BASE64_DECODING_TABLE[temp[3]];   
  175.             }while(index<data.length&&temp[3]==-1);   
  176.                
  177.             if(temp[3]==-1)   
  178.             {   
  179.                 break;   
  180.             }   
  181.                
  182.             buffer.write(((temp[2]<<6)&255)|temp[3]);   
  183.         }   
  184.            
  185.         return buffer.toByteArray();   
  186.     }   
  187. }  




2.MIME类型

  MIME意为多目Internet邮件扩展，它设计的最初目的是为了在发送电子邮件时附加多媒体数据，让邮件客户程序能根据其类型进行处理。每个MIME类型由两部分组成，前面是数据的大类别，后面为具体的种类。例如：image/bmp、image/jpeg、audio/mpeg

一个用于获取各种后缀名所对应MIME类型的工具类（MIME类型列表本来是存储在XML文件中的，此类的作用是读取XML中的数据，由于本文并不打算介绍XML解析，所以直接将数据写到了代码里）
Java代码 复制代码 收藏代码
  1. package org.gameeden.mail;   
  2.   
  3. import java.util.Hashtable;   
  4.   
  5. /**  
  6.  * 用于获得MIME类型的工具类。  
  7.  * @author Sol  
  8.  * @since 1.5  
  9.  */  
  10. public final class MimeTypeFactory   
  11. {   
  12.     private final static Hashtable<String,String> mimeTypes;   
  13.        
  14.     static  
  15.     {   
  16.         mimeTypes=new Hashtable<String,String>();   
  17.            
  18.         mimeTypes.put("*","application/octet-stream");   
  19.         mimeTypes.put("323","text/h323");   
  20.         mimeTypes.put("acx","application/internet-property-stream");   
  21.         mimeTypes.put("ai","application/postscript");   
  22.         mimeTypes.put("aif","audio/x-aiff");   
  23.         mimeTypes.put("aifc","audio/x-aiff");   
  24.         mimeTypes.put("aiff","audio/x-aiff");   
  25.         mimeTypes.put("asf","video/x-ms-asf");   
  26.         mimeTypes.put("asr","video/x-ms-asf");   
  27.         mimeTypes.put("asx","video/x-ms-asf");   
  28.         mimeTypes.put("au","audio/basic");   
  29.         mimeTypes.put("avi","video/x-msvideo");   
  30.         mimeTypes.put("axs","application/olescript");   
  31.         mimeTypes.put("bas","text/plain");   
  32.         mimeTypes.put("bcpio","application/x-bcpio");   
  33.         mimeTypes.put("bin","application/octet-stream");   
  34.         mimeTypes.put("bmp","image/bmp");   
  35.         mimeTypes.put("c","text/plain");   
  36.         mimeTypes.put("cat","application/vnd.ms-pkiseccat");   
  37.         mimeTypes.put("cdf","application/x-cdf");   
  38.         mimeTypes.put("cer","application/x-x509-ca-cert");   
  39.         mimeTypes.put("class","application/octet-stream");   
  40.         mimeTypes.put("clp","application/x-msclip");   
  41.         mimeTypes.put("cmx","image/x-cmx");   
  42.         mimeTypes.put("cod","image/cis-cod");   
  43.         mimeTypes.put("cpio","application/x-cpio");   
  44.         mimeTypes.put("crd","application/x-mscardfile");   
  45.         mimeTypes.put("crl","application/pkix-crl");   
  46.         mimeTypes.put("crt","application/x-x509-ca-cert");   
  47.         mimeTypes.put("csh","application/x-csh");   
  48.         mimeTypes.put("css","text/css");   
  49.         mimeTypes.put("dcr","application/x-director");   
  50.         mimeTypes.put("der","application/x-x509-ca-cert");   
  51.         mimeTypes.put("dir","application/x-director");   
  52.         mimeTypes.put("dll","application/x-msdownload");   
  53.         mimeTypes.put("dms","application/octet-stream");   
  54.         mimeTypes.put("doc","application/msword");   
  55.         mimeTypes.put("dot","application/msword");   
  56.         mimeTypes.put("dvi","application/x-dvi");   
  57.         mimeTypes.put("dxr","application/x-director");   
  58.         mimeTypes.put("eps","application/postscript");   
  59.         mimeTypes.put("etx","text/x-setext");   
  60.         mimeTypes.put("evy","application/envoy");   
  61.         mimeTypes.put("exe","application/octet-stream");   
  62.         mimeTypes.put("fif","application/fractals");   
  63.         mimeTypes.put("flr","x-world/x-vrml");   
  64.         mimeTypes.put("gif","image/gif");   
  65.         mimeTypes.put("gtar","application/x-gtar");   
  66.         mimeTypes.put("gz","application/x-gzip");   
  67.         mimeTypes.put("h","text/plain");   
  68.         mimeTypes.put("hdf","application/x-hdf");   
  69.         mimeTypes.put("hlp","application/winhlp");   
  70.         mimeTypes.put("hqx","application/mac-binhex40");   
  71.         mimeTypes.put("hta","application/hta");   
  72.         mimeTypes.put("htc","text/x-component");   
  73.         mimeTypes.put("htm","text/html");   
  74.         mimeTypes.put("html","text/html");   
  75.         mimeTypes.put("htt","text/webviewhtml");   
  76.         mimeTypes.put("ico","image/x-icon");   
  77.         mimeTypes.put("ief","image/ief");   
  78.         mimeTypes.put("iii","application/x-iphone");   
  79.         mimeTypes.put("ins","application/x-internet-signup");   
  80.         mimeTypes.put("isp","application/x-internet-signup");   
  81.         mimeTypes.put("jfif","image/pipeg");   
  82.         mimeTypes.put("jpe","image/jpeg");   
  83.         mimeTypes.put("jpeg","image/jpeg");   
  84.         mimeTypes.put("jpg","image/jpeg");   
  85.         mimeTypes.put("js","application/x-javascript");   
  86.         mimeTypes.put("latex","application/x-latex");   
  87.         mimeTypes.put("lha","application/octet-stream");   
  88.         mimeTypes.put("lsf","video/x-la-asf");   
  89.         mimeTypes.put("lsx","video/x-la-asf");   
  90.         mimeTypes.put("lzh","application/octet-stream");   
  91.         mimeTypes.put("m13","application/x-msmediaview");   
  92.         mimeTypes.put("m14","application/x-msmediaview");   
  93.         mimeTypes.put("m3u","audio/x-mpegurl");   
  94.         mimeTypes.put("man","application/x-troff-man");   
  95.         mimeTypes.put("mdb","application/x-msaccess");   
  96.         mimeTypes.put("me","application/x-troff-me");   
  97.         mimeTypes.put("mht","message/rfc822");   
  98.         mimeTypes.put("mhtml","message/rfc822");   
  99.         mimeTypes.put("mid","audio/mid");   
  100.         mimeTypes.put("mny","application/x-msmoney");   
  101.         mimeTypes.put("mov","video/quicktime");   
  102.         mimeTypes.put("movie","video/x-sgi-movie");   
  103.         mimeTypes.put("mp2","video/mpeg");   
  104.         mimeTypes.put("mp3","audio/mpeg");   
  105.         mimeTypes.put("mpa","video/mpeg");   
  106.         mimeTypes.put("mpe","video/mpeg");   
  107.         mimeTypes.put("mpeg","video/mpeg");   
  108.         mimeTypes.put("mpg","video/mpeg");   
  109.         mimeTypes.put("mpp","application/vnd.ms-project");   
  110.         mimeTypes.put("mpv2","video/mpeg");   
  111.         mimeTypes.put("ms","application/x-troff-ms");   
  112.         mimeTypes.put("mvb","application/x-msmediaview");   
  113.         mimeTypes.put("nws","message/rfc822");   
  114.         mimeTypes.put("oda","application/oda");   
  115.         mimeTypes.put("p10","application/pkcs10");   
  116.         mimeTypes.put("p12","application/x-pkcs12");   
  117.         mimeTypes.put("p7b","application/x-pkcs7-certificates");   
  118.         mimeTypes.put("p7c","application/x-pkcs7-mime");   
  119.         mimeTypes.put("p7m","application/x-pkcs7-mime");   
  120.         mimeTypes.put("p7r","application/x-pkcs7-certreqresp");   
  121.         mimeTypes.put("p7s","application/x-pkcs7-signature");   
  122.         mimeTypes.put("pbm","image/x-portable-bitmap");   
  123.         mimeTypes.put("pdf","application/pdf");   
  124.         mimeTypes.put("pfx","application/x-pkcs12");   
  125.         mimeTypes.put("pgm","image/x-portable-graymap");   
  126.         mimeTypes.put("pko","application/ynd.ms-pkipko");   
  127.         mimeTypes.put("pma","application/x-perfmon");   
  128.         mimeTypes.put("pmc","application/x-perfmon");   
  129.         mimeTypes.put("pml","application/x-perfmon");   
  130.         mimeTypes.put("pmr","application/x-perfmon");   
  131.         mimeTypes.put("pmw","application/x-perfmon");   
  132.         mimeTypes.put("pnm","image/x-portable-anymap");   
  133.         mimeTypes.put("pot,","application/vnd.ms-powerpoint");   
  134.         mimeTypes.put("ppm","image/x-portable-pixmap");   
  135.         mimeTypes.put("pps","application/vnd.ms-powerpoint");   
  136.         mimeTypes.put("ppt","application/vnd.ms-powerpoint");   
  137.         mimeTypes.put("prf","application/pics-rules");   
  138.         mimeTypes.put("ps","application/postscript");   
  139.         mimeTypes.put("pub","application/x-mspublisher");   
  140.         mimeTypes.put("qt","video/quicktime");   
  141.         mimeTypes.put("ra","audio/x-pn-realaudio");   
  142.         mimeTypes.put("ram","audio/x-pn-realaudio");   
  143.         mimeTypes.put("ras","image/x-cmu-raster");   
  144.         mimeTypes.put("rgb","image/x-rgb");   
  145.         mimeTypes.put("rmi","audio/mid");   
  146.         mimeTypes.put("roff","application/x-troff");   
  147.         mimeTypes.put("rtf","application/rtf");   
  148.         mimeTypes.put("rtx","text/richtext");   
  149.         mimeTypes.put("scd","application/x-msschedule");   
  150.         mimeTypes.put("sct","text/scriptlet");   
  151.         mimeTypes.put("setpay","application/set-payment-initiation");   
  152.         mimeTypes.put("setreg","application/set-registration-initiation");   
  153.         mimeTypes.put("sh","application/x-sh");   
  154.         mimeTypes.put("shar","application/x-shar");   
  155.         mimeTypes.put("sit","application/x-stuffit");   
  156.         mimeTypes.put("snd","audio/basic");   
  157.         mimeTypes.put("spc","application/x-pkcs7-certificates");   
  158.         mimeTypes.put("spl","application/futuresplash");   
  159.         mimeTypes.put("src","application/x-wais-source");   
  160.         mimeTypes.put("sst","application/vnd.ms-pkicertstore");   
  161.         mimeTypes.put("stl","application/vnd.ms-pkistl");   
  162.         mimeTypes.put("stm","text/html");   
  163.         mimeTypes.put("sv4cpio","application/x-sv4cpio");   
  164.         mimeTypes.put("sv4crc","application/x-sv4crc");   
  165.         mimeTypes.put("t","application/x-troff");   
  166.         mimeTypes.put("tar","application/x-tar");   
  167.         mimeTypes.put("tcl","application/x-tcl");   
  168.         mimeTypes.put("tex","application/x-tex");   
  169.         mimeTypes.put("texi","application/x-texinfo");   
  170.         mimeTypes.put("texinfo","application/x-texinfo");   
  171.         mimeTypes.put("tgz","application/x-compressed");   
  172.         mimeTypes.put("tif","image/tiff");   
  173.         mimeTypes.put("tiff","image/tiff");   
  174.         mimeTypes.put("tr","application/x-troff");   
  175.         mimeTypes.put("trm","application/x-msterminal");   
  176.         mimeTypes.put("tsv","text/tab-separated-values");   
  177.         mimeTypes.put("txt","text/plain");   
  178.         mimeTypes.put("uls","text/iuls");   
  179.         mimeTypes.put("ustar","application/x-ustar");   
  180.         mimeTypes.put("vcf","text/x-vcard");   
  181.         mimeTypes.put("vrml","x-world/x-vrml");   
  182.         mimeTypes.put("wav","audio/x-wav");   
  183.         mimeTypes.put("wcm","application/vnd.ms-works");   
  184.         mimeTypes.put("wdb","application/vnd.ms-works");   
  185.         mimeTypes.put("wks","application/vnd.ms-works");   
  186.         mimeTypes.put("wmf","application/x-msmetafile");   
  187.         mimeTypes.put("wps","application/vnd.ms-works");   
  188.         mimeTypes.put("wri","application/x-mswrite");   
  189.         mimeTypes.put("wrl","x-world/x-vrml");   
  190.         mimeTypes.put("wrz","x-world/x-vrml");   
  191.         mimeTypes.put("xaf","x-world/x-vrml");   
  192.         mimeTypes.put("xbm","image/x-xbitmap");   
  193.         mimeTypes.put("xla","application/vnd.ms-excel");   
  194.         mimeTypes.put("xlc","application/vnd.ms-excel");   
  195.         mimeTypes.put("xlm","application/vnd.ms-excel");   
  196.         mimeTypes.put("xls","application/vnd.ms-excel");   
  197.         mimeTypes.put("xlt","application/vnd.ms-excel");   
  198.         mimeTypes.put("xlw","application/vnd.ms-excel");   
  199.         mimeTypes.put("xof","x-world/x-vrml");   
  200.         mimeTypes.put("xpm","image/x-xpixmap");   
  201.         mimeTypes.put("xwd","image/x-xwindowdump");   
  202.         mimeTypes.put("z","application/x-compress");   
  203.         mimeTypes.put("zip","application/zip");   
  204.     }   
  205.        
  206.     private MimeTypeFactory()   
  207.     {   
  208.     }   
  209.        
  210.     /**  
  211.      * 设置MIME类型。  
  212.      * @param postfix 文件后缀名  
  213.      * @param mimeType MIME类型  
  214.      * @return 以前的MIME类型  
  215.      */  
  216.     public static String setMimeType(String postfix,String mimeType)   
  217.     {   
  218.         Object result=mimeTypes.put(postfix.toLowerCase(),mimeType);   
  219.                
  220.         return result==null?(String)getMimeType("*"):(String)result;   
  221.     }   
  222.        
  223.     /**  
  224.      * 获得MIME类型。  
  225.      * @param postfix 文件后缀名  
  226.      * @return MIME类型  
  227.      */  
  228.     public static String getMimeType(String postfix)   
  229.     {   
  230.         Object result=mimeTypes.get(postfix.toLowerCase());   
  231.            
  232.         return result==null?(String)getMimeType("*"):(String)result;   
  233.     }   
  234. }  




3.SMTP邮件发送实例

日志管理器
Java代码 复制代码 收藏代码
  1. package org.gameeden.util;   
  2.   
  3. /**  
  4.  * 日志管理器。  
  5.  * @author Sol  
  6.  */  
  7. public interface LogManager   
  8. {   
  9.     /**  
  10.      * 输出。  
  11.      * @param info 信息  
  12.      */  
  13.     public void output(String info);   
  14. }  




用Socket实现的SMTP邮件发送类
Java代码 复制代码 收藏代码
  1. package org.gameeden.mail;   
  2.   
  3. import java.io.File;   
  4. import java.io.FileNotFoundException;   
  5. import java.io.IOException;   
  6. import java.io.InputStream;   
  7. import java.io.OutputStream;   
  8. import java.io.RandomAccessFile;   
  9. import java.net.Socket;   
  10. import java.net.SocketTimeoutException;   
  11. import java.nio.charset.Charset;   
  12. import java.text.SimpleDateFormat;   
  13. import java.util.ArrayList;   
  14. import java.util.Date;   
  15. import java.util.Hashtable;   
  16. import java.util.Locale;   
  17. import java.util.regex.Pattern;   
  18. import javax.naming.NamingEnumeration;   
  19. import javax.naming.NamingException;   
  20. import javax.naming.directory.InitialDirContext;   
  21.   
  22. import org.gameeden.security.Base64;   
  23. import org.gameeden.util.LogManager;   
  24.   
  25. /**  
  26.  * SMTP邮件发送系统。  
  27.  *   
  28.  *   
  29.  * 发件人和收件人的正确格式如下:  
  30.  *   
  31.  * 例1: "Sol"<sol@gameeden.org>  
  32.  * 例2: Sol<sol@gameeden.org>  
  33.  * 例3: <sol@gameeden.org>  
  34.  * 例4: sol@gameeden.org  
  35.  *   
  36.  * @author Sol  
  37.  * @since 1.5  
  38.  */  
  39. public final class SmtpMailSender   
  40. {   
  41.     /**  
  42.      * 发送成功的常量。  
  43.      */  
  44.     public final static boolean SUCCESSFUL=true;   
  45.        
  46.     /**  
  47.      * 发送失败的常量。  
  48.      */  
  49.     public final static boolean FAILED=false;   
  50.        
  51.     private final static int PORT=25;//服务器端口(SMTP服务器和邮件接收服务器的端口均为25)   
  52.     private final static int RETRY=3;//当连接SMTP服务器失败后尝试重新连接的次数(仅用于发送ESMTP邮件)   
  53.     private final static int INTERVAL=1000;//当连接SMTP服务器失败后重新连接的时间间隔(仅用于发送ESMTP邮件)   
  54.     private final static int TIMEOUT=10000;//网络连接的超时时间   
  55.        
  56.     private final static String BOUNDARY;//MIME分格符   
  57.     private final static String CHARSET;//虚拟机的默认编码   
  58.     private final static Pattern PATTERN;//用于效验邮箱地址的正确性   
  59.        
  60.     private static InitialDirContext dirContext;//用于查询DNS记录   
  61.        
  62.     private final ArrayList<LogManager> logManager;//日志管理器   
  63.        
  64.     private boolean isEsmtp;//发送类型   
  65.        
  66.     private String smtp;//SMTP服务器地址(仅用于发送ESMTP邮件)   
  67.     private String user;//用户名(仅用于发送ESMTP邮件)   
  68.     private String password;//密码(仅用于发送ESMTP邮件)   
  69.     private String sender;//发件人名字   
  70.     private String senderAddress;//发件人的E-Mail地址   
  71.        
  72.     static  
  73.     {   
  74.         BOUNDARY="Boundary-=_hMbeqwnGNoWeLsRMeKTIPeofyStu";   
  75.         CHARSET=Charset.defaultCharset().displayName();   
  76.         PATTERN=Pattern.compile(".+@[^.@]+(\\.[^.@]+)+$");//此处放弃了传统匹配方式，这是为了兼容非英文域名的电子邮箱   
  77.            
  78.         Hashtable<String,String> hashtable=new Hashtable<String,String>();   
  79.         hashtable.put("java.naming.factory.initial","com.sun.jndi.dns.DnsContextFactory");   
  80.            
  81.         try  
  82.         {   
  83.             dirContext=new InitialDirContext(hashtable);   
  84.         }   
  85.         catch(NamingException e)   
  86.         {   
  87.         }   
  88.     }   
  89.        
  90.     private SmtpMailSender(String from)   
  91.     {   
  92.         if(from==null)   
  93.         {   
  94.             throw new IllegalArgumentException("参数from不能为null。");   
  95.         }   
  96.            
  97.         int leftSign=(from=from.trim()).charAt(from.length()-1)=='>'?from.lastIndexOf('<'):-1;   
  98.            
  99.         senderAddress=leftSign>-1?from.substring(leftSign+1,from.length()-1).trim():from;   
  100.            
  101.         if(!PATTERN.matcher(senderAddress).find())   
  102.         {   
  103.             throw new IllegalArgumentException("参数from不正确。");   
  104.         }   
  105.            
  106.         sender=leftSign>-1?from.substring(0,leftSign).trim():null;   
  107.         logManager=new ArrayList<LogManager>();   
  108.         isEsmtp=false;   
  109.            
  110.         if(sender!=null)   
  111.         {   
  112.             if(sender.length()==0)   
  113.             {   
  114.                 sender=null;   
  115.             }   
  116.             else if(sender.charAt(0)=='"'&&sender.charAt(sender.length()-1)=='"')   
  117.             {   
  118.                 sender=sender.substring(1,sender.length()-1).trim();   
  119.             }   
  120.         }   
  121.     }   
  122.        
  123.     private SmtpMailSender(String address,String from,String user,String password)   
  124.     {   
  125.         this(from);   
  126.            
  127.         isEsmtp=true;   
  128.         this.smtp=address;   
  129.         this.user=Base64.encode(user.getBytes());   
  130.         this.password=Base64.encode(password.getBytes());   
  131.     }   
  132.   
  133.     /**  
  134.      * 创建SMTP邮件发送系统实例。  
  135.      * @param from 发件人  
  136.      * @return SMTP邮件发送系统的实例  
  137.      * @throws IllegalArgumentException 如果参数from为null或格式不正确  
  138.      */  
  139.     public static SmtpMailSender createSmtpMailSender(String from) throws IllegalArgumentException   
  140.     {   
  141.         return new SmtpMailSender(from);   
  142.     }   
  143.        
  144.     /**  
  145.      * 创建ESMTP邮件发送系统实例。  
  146.      * @param smtp SMTP服务器地址  
  147.      * @param from 发件人  
  148.      * @param user 用户名  
  149.      * @param password 密码  
  150.      * @return SMTP邮件发送系统的实例  
  151.      * @throws IllegalArgumentException 如果参数from为null或格式不正确  
  152.      */  
  153.     public static SmtpMailSender createESmtpMailSender(String smtp,String from,String user,String password) throws IllegalArgumentException   
  154.     {   
  155.         return new SmtpMailSender(smtp,from,user,password);   
  156.     }   
  157.        
  158.     /**  
  159.      * 发送邮件。  
  160.      * @param to 收件人  
  161.      * @param subject 主题  
  162.      * @param content 正文  
  163.      * @param attachments 附件  
  164.      * @param isHtml 使用网页形式发送  
  165.      * @param isUrgent 紧急邮件  
  166.      * @return 是否发送成功  
  167.      * @throws IllegalArgumentException 如果参数to为null或格式不正确  
  168.      */  
  169.     public boolean sendMail(String to,String subject,String content,File[] attachments,boolean isHtml,boolean isUrgent) throws IllegalArgumentException   
  170.     {   
  171.         if(to==null)   
  172.         {   
  173.             throw new IllegalArgumentException("参数to不能为null。");   
  174.         }   
  175.            
  176.         int leftSign=(to=to.trim()).charAt(to.length()-1)=='>'?to.lastIndexOf('<'):-1;   
  177.            
  178.         String addresseeAddress=leftSign>-1?to.substring(leftSign+1,to.length()-1).trim():to;//收件人的E-Mail地址   
  179.   
  180.         if(!PATTERN.matcher(addresseeAddress).find())   
  181.         {   
  182.             throw new IllegalArgumentException("参数to不正确。");   
  183.         }   
  184.            
  185.         String addressee=leftSign>-1?to.substring(0,leftSign).trim():null;//收件人名字   
  186.         boolean needBoundary=attachments!=null&&attachments.length>0;   
  187.            
  188.         Socket socket=null;   
  189.         InputStream in=null;   
  190.         OutputStream out=null;   
  191.         byte[] data;   
  192.   
  193.         try  
  194.         {      
  195.             if(addressee!=null)   
  196.             {   
  197.                 if(addressee.length()==0)   
  198.                 {   
  199.                     addressee=null;   
  200.                 }   
  201.                 else if(addressee.charAt(0)=='"'&&addressee.charAt(addressee.length()-1)=='"')   
  202.                 {   
  203.                     addressee=addressee.substring(1,addressee.length()-1).trim();   
  204.                 }   
  205.             }   
  206.                
  207.             if(isEsmtp)   
  208.             {   
  209.                 for(int k=1;;k++)   
  210.                 {   
  211.                     try  
  212.                     {   
  213.                         log("连接: 主机:\""+smtp+"\" 端口:\""+PORT+"\"");   
  214.                         socket=new Socket(smtp,PORT);   
  215.                         break;   
  216.                     }   
  217.                     catch(IOException e)   
  218.                     {   
  219.                         log("错误: 连接失败"+k+"次");   
  220.   
  221.                         if(k==RETRY)   
  222.                         {   
  223.                             return FAILED;   
  224.                         }   
  225.                            
  226.                         try  
  227.                         {   
  228.                             Thread.sleep(INTERVAL);   
  229.                         }   
  230.                         catch(InterruptedException ie)   
  231.                         {   
  232.                         }   
  233.                     }   
  234.                 }   
  235.   
  236.                 in=socket.getInputStream();   
  237.                 out=socket.getOutputStream();   
  238.                    
  239.                 if(response(in)!=220)   
  240.                 {   
  241.                     return FAILED;   
  242.                 }   
  243.             }   
  244.             else  
  245.             {   
  246.                 log("状态: 创建邮件接收服务器列表");   
  247.                 String[] address=parseDomain(parseUrl(addresseeAddress));   
  248.                    
  249.                 if(address==null)   
  250.                 {   
  251.                     return FAILED;   
  252.                 }   
  253.                    
  254.                 for(int k=0;k<address.length;k++)   
  255.                 {   
  256.                     try  
  257.                     {   
  258.                         log("连接: 主机:\""+address[k]+"\" 端口:\""+PORT+"\"");   
  259.   
  260.                         socket=new Socket(address[k],PORT);   
  261.        
  262.                         in=socket.getInputStream();   
  263.                         out=socket.getOutputStream();   
  264.                            
  265.                         if(response(in)!=220)   
  266.                         {   
  267.                             return FAILED;   
  268.                         }   
  269.                            
  270.                         break;   
  271.                     }   
  272.                     catch(IOException e)   
  273.                     {   
  274.                         log("错误: 连接失败");   
  275.                     }   
  276.                 }   
  277.             }   
  278.   
  279.             if(in==null||out==null)   
  280.             {   
  281.                 return FAILED;   
  282.             }   
  283.                
  284.             socket.setSoTimeout(TIMEOUT);   
  285.                
  286.             sendString("HELO "+parseUrl(senderAddress),out);   
  287.             sendNewline(out);   
  288.                
  289.             if(response(in)!=250)   
  290.             {   
  291.                 return FAILED;   
  292.             }   
  293.   
  294.             if(isEsmtp)   
  295.             {   
  296.                 sendString("AUTH LOGIN",out);   
  297.                 sendNewline(out);   
  298.                    
  299.                 if(response(in)!=334)   
  300.                 {   
  301.                     return FAILED;   
  302.                 }   
  303.                    
  304.                 sendString(user,out);   
  305.                 sendNewline(out);   
  306.                    
  307.                 if(response(in)!=334)   
  308.                 {   
  309.                     return FAILED;   
  310.                 }   
  311.                    
  312.                 sendString(password,out);   
  313.                 sendNewline(out);   
  314.                    
  315.                 if(response(in)!=235)   
  316.                 {   
  317.                     return FAILED;   
  318.                 }   
  319.             }   
  320.                
  321.             sendString("MAIL FROM: <"+senderAddress+">",out);   
  322.             sendNewline(out);   
  323.   
  324.             if(response(in)!=250)   
  325.             {   
  326.                 return FAILED;   
  327.             }   
  328.                
  329.             sendString("RCPT TO: <"+addresseeAddress+">",out);   
  330.             sendNewline(out);   
  331.                
  332.             if(response(in)!=250)   
  333.             {   
  334.                 return FAILED;   
  335.             }   
  336.   
  337.             sendString("DATA",out);   
  338.             sendNewline(out);   
  339.   
  340.             if(response(in)!=354)   
  341.             {   
  342.                 return FAILED;   
  343.             }   
  344.   
  345.             sendString("From: "+(sender==null?senderAddress:getBase64String(sender)+" <"+senderAddress+">"),out);   
  346.             sendNewline(out);   
  347.             sendString("To: "+(addressee==null?addresseeAddress:getBase64String(addressee)+" <"+addresseeAddress+">"),out);   
  348.             sendNewline(out);   
  349.             sendString("Subject: "+getBase64String(subject),out);   
  350.             sendNewline(out);   
  351.             sendString("Date: "+new SimpleDateFormat("EEE, d MMM yyyy HH:mm:ss Z (z)",Locale.US).format(new Date()),out);   
  352.             sendNewline(out);   
  353.             sendString("MIME-Version: 1.0",out);   
  354.             sendNewline(out);   
  355.                
  356.             if(needBoundary)   
  357.             {   
  358.                 sendString("Content-Type: multipart/mixed; BOUNDARY=\""+BOUNDARY+"\"",out);   
  359.                 sendNewline(out);   
  360.             }   
  361.             else  
  362.             {   
  363.                 if(isHtml)   
  364.                 {   
  365.                     sendString("Content-Type: text/html; charset=\""+CHARSET+"\"",out);   
  366.                     sendNewline(out);   
  367.                 }   
  368.                 else  
  369.                 {   
  370.                     sendString("Content-Type: text/plain; charset=\""+CHARSET+"\"",out);   
  371.                     sendNewline(out);   
  372.                 }   
  373.             }   
  374.                
  375.             sendString("Content-Transfer-Encoding: base64",out);   
  376.             sendNewline(out);   
  377.   
  378.             if(isUrgent)   
  379.             {   
  380.                 sendString("X-Priority: 1",out);   
  381.                 sendNewline(out);   
  382.             }   
  383.             else  
  384.             {   
  385.                 sendString("X-Priority: 3",out);   
  386.                 sendNewline(out);   
  387.             }   
  388.                
  389.             sendString("X-Mailer: BlackFox Mail[Copyright(C) 2007 Sol]",out);   
  390.             sendNewline(out);   
  391.                
  392.             log("发送: ");   
  393.             sendNewline(out);   
  394.   
  395.             if(needBoundary)   
  396.             {   
  397.                 sendString("--"+BOUNDARY,out);   
  398.                 sendNewline(out);   
  399.                    
  400.                 if(isHtml)   
  401.                 {   
  402.                     sendString("Content-Type: text/html; charset=\""+CHARSET+"\"",out);   
  403.                     sendNewline(out);   
  404.                 }   
  405.                 else  
  406.                 {   
  407.                     sendString("Content-Type: text/plain; charset=\""+CHARSET+"\"",out);   
  408.                     sendNewline(out);   
  409.                 }   
  410.                    
  411.                 sendString("Content-Transfer-Encoding: base64",out);   
  412.                 sendNewline(out);   
  413.                    
  414.                 log("发送: ");   
  415.                 sendNewline(out);   
  416.             }   
  417.                
  418.             data=(content!=null?content:"").getBytes();   
  419.                
  420.             for(int k=0;k<data.length;k+=54)   
  421.             {   
  422.                 sendString(Base64.encode(data,k,Math.min(data.length-k,54)),out);   
  423.                 sendNewline(out);   
  424.             }   
  425.   
  426.             if(needBoundary)   
  427.             {   
  428.                 RandomAccessFile attachment=null;   
  429.                 int fileIndex=0;   
  430.                 String fileName;   
  431.                 int k;   
  432.                 data=new byte[54];   
  433.                    
  434.                 try  
  435.                 {   
  436.                     for(;fileIndex<attachments.length;fileIndex++)   
  437.                     {   
  438.                         fileName=attachments[fileIndex].getName();   
  439.                         attachment=new RandomAccessFile(attachments[fileIndex],"r");   
  440.   
  441.                         sendString("--"+BOUNDARY,out);   
  442.                         sendNewline(out);   
  443.                         sendString("Content-Type: "+MimeTypeFactory.getMimeType(fileName.indexOf(".")==-1?"*":fileName.substring(fileName.lastIndexOf(".")+1))+"; name=\""+(fileName=getBase64String(fileName))+"\"",out);   
  444.                         sendNewline(out);   
  445.                         sendString("Content-Transfer-Encoding: base64",out);   
  446.                         sendNewline(out);   
  447.                         sendString("Content-Disposition: attachment; filename=\""+fileName+"\"",out);   
  448.                         sendNewline(out);   
  449.                            
  450.                         log("发送: ");   
  451.                         sendNewline(out);   
  452.                            
  453.                         do  
  454.                         {   
  455.                             k=attachment.read(data,0,54);   
  456.                                
  457.                             if(k==-1)   
  458.                             {   
  459.                                 break;   
  460.                             }   
  461.                                
  462.                             sendString(Base64.encode(data,0,k),out);   
  463.                             sendNewline(out);   
  464.                         }while(k==54);   
  465.                     }   
  466.                 }   
  467.                 catch(FileNotFoundException e)   
  468.                 {   
  469.                     log("错误: 附件\""+attachments[fileIndex].getAbsolutePath()+"\"不存在");   
  470.                     return FAILED;   
  471.                 }   
  472.                 catch(IOException e)   
  473.                 {   
  474.                     log("错误: 无法读取附件\""+attachments[fileIndex].getAbsolutePath()+"\"");   
  475.                     return FAILED;   
  476.                 }   
  477.                 finally  
  478.                 {   
  479.                     if(attachment!=null)   
  480.                     {   
  481.                         try  
  482.                         {   
  483.                             attachment.close();   
  484.                         }   
  485.                         catch(IOException e)   
  486.                         {   
  487.                         }   
  488.                     }   
  489.                 }   
  490.                    
  491.                 sendString("--"+BOUNDARY+"--",out);   
  492.                 sendNewline(out);   
  493.             }   
  494.                
  495.             sendString(".",out);   
  496.             sendNewline(out);   
  497.   
  498.             if(response(in)!=250)   
  499.             {   
  500.                 return FAILED;   
  501.             }   
  502.   
  503.             sendString("QUIT",out);   
  504.             sendNewline(out);   
  505.   
  506.             if(response(in)!=221)   
  507.             {   
  508.                 return FAILED;   
  509.             }   
  510.                
  511.             return SUCCESSFUL;   
  512.         }   
  513.         catch(SocketTimeoutException e)   
  514.         {   
  515.             log("错误: 连接超时");   
  516.             return FAILED;   
  517.         }   
  518.         catch(IOException e)   
  519.         {   
  520.             log("错误: 连接出错");   
  521.             return FAILED;   
  522.         }   
  523.         catch(Exception e)   
  524.         {   
  525.             log("错误: "+e.toString());   
  526.             return FAILED;   
  527.         }   
  528.         finally  
  529.         {   
  530.             if(in!=null)   
  531.             {   
  532.                 try  
  533.                 {   
  534.                     in.close();   
  535.                 }   
  536.                 catch(IOException e)   
  537.                 {   
  538.                 }   
  539.             }   
  540.                
  541.             if(out!=null)   
  542.             {   
  543.                 try  
  544.                 {   
  545.                     out.close();   
  546.                 }   
  547.                 catch(IOException e)   
  548.                 {   
  549.                 }   
  550.             }   
  551.   
  552.             if(socket!=null)   
  553.             {   
  554.                 try  
  555.                 {   
  556.                     socket.close();   
  557.                 }   
  558.                 catch(IOException e)   
  559.                 {   
  560.                 }   
  561.             }   
  562.         }   
  563.     }   
  564.        
  565.     /**  
  566.      * 给多个发件人发送邮件。  
  567.      * @param to 收件人  
  568.      * @param subject 主题  
  569.      * @param content 正文  
  570.      * @param attachments 附件  
  571.      * @param isHtml 使用网页形式发送  
  572.      * @param isUrgent 紧急邮件  
  573.      * @return 任务状况  
  574.      * @throws IllegalArgumentException 如果参数to为null或格式不正确  
  575.      */  
  576.     public boolean[] sendMail(String[] to,String subject,String content,File[] attachments,boolean isHtml,boolean isUrgent) throws IllegalArgumentException   
  577.     {   
  578.         boolean[] task=new boolean[to.length];   
  579.            
  580.         for(int k=0;k<task.length;k++)   
  581.         {   
  582.             task[k]=sendMail(to[k],subject,content,attachments,isHtml,isUrgent);   
  583.         }   
  584.            
  585.         return task;   
  586.     }   
  587.   
  588.     /**  
  589.      * 发送纯文本邮件。  
  590.      * @param to 收件人  
  591.      * @param subject 主题  
  592.      * @param content 正文  
  593.      * @return 是否发送成功  
  594.      * @throws IllegalArgumentException 如果参数to为null或格式不正确  
  595.      */  
  596.     public boolean sendTextMail(String to,String subject,String content) throws IllegalArgumentException   
  597.     {   
  598.         return sendMail(to,subject,content,null,false,false);   
  599.     }   
  600.        
  601.     /**  
  602.      * 发送HTML邮件。  
  603.      * @param to 收件人  
  604.      * @param subject 主题  
  605.      * @param content 正文  
  606.      * @return 是否发送成功  
  607.      * @throws IllegalArgumentException 如果参数to为null或格式不正确  
  608.      */  
  609.     public boolean sendHtmlMail(String to,String subject,String content) throws IllegalArgumentException   
  610.     {   
  611.         return sendMail(to,subject,content,null,true,false);   
  612.     }   
  613.        
  614.     /**  
  615.      * 给多个发件人发送纯文本邮件。  
  616.      * @param to 收件人  
  617.      * @param subject 主题  
  618.      * @param content 正文  
  619.      * @return 任务状况  
  620.      * @throws IllegalArgumentException 如果参数to为null或格式不正确  
  621.      */  
  622.     public boolean[] sendTextMail(String[] to,String subject,String content) throws IllegalArgumentException   
  623.     {   
  624.         return sendMail(to,subject,content,null,false,false);   
  625.     }   
  626.        
  627.     /**  
  628.      * 给多个发件人发送HTML邮件。  
  629.      * @param to 收件人  
  630.      * @param subject 主题  
  631.      * @param content 正文  
  632.      * @return 任务状况  
  633.      * @throws IllegalArgumentException 如果参数to为null或格式不正确  
  634.      */  
  635.     public boolean[] sendHtmlMail(String[] to,String subject,String content) throws IllegalArgumentException   
  636.     {   
  637.         return sendMail(to,subject,content,null,true,false);   
  638.     }   
  639.        
  640.     /**  
  641.      * 发送带附件的纯文本邮件。  
  642.      * @param to 收件人  
  643.      * @param subject 主题  
  644.      * @param content 正文  
  645.      * @param attachments 附件  
  646.      * @return 是否发送成功  
  647.      * @throws IllegalArgumentException 如果参数to为null或格式不正确  
  648.      */  
  649.     public boolean sendTextMail(String to,String subject,String content,File[] attachments) throws IllegalArgumentException   
  650.     {   
  651.         return sendMail(to,subject,content,attachments,false,false);   
  652.     }   
  653.        
  654.     /**  
  655.      * 发送带附件的HTML邮件。  
  656.      * @param to 收件人  
  657.      * @param subject 主题  
  658.      * @param content 正文  
  659.      * @param attachments 附件  
  660.      * @return 是否发送成功  
  661.      * @throws IllegalArgumentException 如果参数to为null或格式不正确  
  662.      */  
  663.     public boolean sendHtmlMail(String to,String subject,String content,File[] attachments) throws IllegalArgumentException   
  664.     {   
  665.         return sendMail(to,subject,content,attachments,true,false);   
  666.     }   
  667.        
  668.     /**  
  669.      * 给多个发件人发送带附件的纯文本邮件。  
  670.      * @param to 收件人  
  671.      * @param subject 主题  
  672.      * @param content 正文  
  673.      * @param attachments 附件  
  674.      * @return 任务状况  
  675.      * @throws IllegalArgumentException 如果参数to为null或格式不正确  
  676.      */  
  677.     public boolean[] sendTextMail(String[] to,String subject,String content,File[] attachments) throws IllegalArgumentException   
  678.     {   
  679.         return sendMail(to,subject,content,attachments,false,false);   
  680.     }   
  681.        
  682.     /**  
  683.      * 给多个发件人发送带附件的HTML邮件。  
  684.      * @param to 收件人  
  685.      * @param subject 主题  
  686.      * @param content 正文  
  687.      * @param attachments 附件  
  688.      * @return 任务状况  
  689.      * @throws IllegalArgumentException 如果参数to为null或格式不正确  
  690.      */  
  691.     public boolean[] sendHtmlMail(String[] to,String subject,String content,File[] attachments) throws IllegalArgumentException   
  692.     {   
  693.         return sendMail(to,subject,content,attachments,true,false);   
  694.     }   
  695.   
  696.     /**  
  697.      * 添加一个日志管理器。  
  698.      * @param manager 日志管理器  
  699.      */  
  700.     public void addLogManager(LogManager manager)   
  701.     {   
  702.         logManager.add(manager);   
  703.     }   
  704.        
  705.     /**  
  706.      * 移除日志管理器。  
  707.      * @param manager 要移除的日志管理器  
  708.      */  
  709.     public void removeLogManager(LogManager manager)   
  710.     {   
  711.         logManager.remove(manager);   
  712.     }   
  713.        
  714.     /**  
  715.      * 通过分析收件人邮箱域名的DNS记录获取邮件接收服务器地址。  
  716.      * @param url 收件人邮箱域名  
  717.      * @return 主机地址列表  
  718.      */  
  719.     private String[] parseDomain(String url)   
  720.     {   
  721.         try  
  722.         {   
  723.             NamingEnumeration records=dirContext.getAttributes(url,new String[]{"mx"}).getAll();   
  724.                
  725.             String[] address;   
  726.             String[] tmpMx;   
  727.             MX[] tmpMxArray;   
  728.             MX tmp;   
  729.   
  730.             if(records.hasMore())   
  731.             {   
  732.                 url=records.next().toString();   
  733.                 url=url.substring(url.indexOf(": ")+2);   
  734.                 address=url.split(",");   
  735.                 tmpMxArray=new MX[address.length];   
  736.   
  737.                 for(int k=0;k<address.length;k++)   
  738.                 {   
  739.                     tmpMx=address[k].trim().split(" ");   
  740.                     tmpMxArray[k]=new MX(Integer.parseInt(tmpMx[0]),tmpMx[1]);   
  741.                 }   
  742.                    
  743.                 for(int n=1;n<tmpMxArray.length;n++)   
  744.                 {   
  745.                     for(int m=n;m>0;m--)   
  746.                     {   
  747.                         if(tmpMxArray[m-1].pri>tmpMxArray[m].pri)   
  748.                         {   
  749.                             tmp=tmpMxArray[m-1];   
  750.                             tmpMxArray[m-1]=tmpMxArray[m];   
  751.                             tmpMxArray[m]=tmp;   
  752.                         }   
  753.                     }   
  754.                 }   
  755.                    
  756.                 for(int k=0;k<tmpMxArray.length;k++)   
  757.                 {   
  758.                     address[k]=tmpMxArray[k].address;   
  759.                 }   
  760.                    
  761.                 return address;   
  762.             }//分析mx记录   
  763.   
  764.             records=dirContext.getAttributes(url,new String[]{"a"}).getAll();   
  765.   
  766.             if(records.hasMore())   
  767.             {   
  768.                 url=records.next().toString();   
  769.                 url=url.substring(url.indexOf(": ")+2).replace(" ","");   
  770.                 address=url.split(",");   
  771.                    
  772.                 return address;   
  773.             }//分析a记录   
  774.                
  775.             return new String[]{url};   
  776.         }   
  777.         catch(NamingException e)   
  778.         {   
  779.             log("错误: 域名\""+url+"\"无法解析");   
  780.             return null;   
  781.         }   
  782.     }   
  783.        
  784.     /**  
  785.      * 获得响应码。  
  786.      * @param in 输入流  
  787.      * @return 响应码  
  788.      * @throws IOException 如果发生 I/O 错误。  
  789.      */  
  790.     private int response(InputStream in) throws IOException   
  791.     {   
  792.         byte[] buffer=new byte[1024];   
  793.         int k=in.read(buffer);   
  794.            
  795.         if(k==-1)   
  796.         {   
  797.             return -1;   
  798.         }   
  799.            
  800.         String response=new String(buffer,0,k).trim();   
  801.         log("响应: "+response);   
  802.         return Integer.parseInt(response.substring(0,3));   
  803.     }   
  804.        
  805.     /**  
  806.      * 输出字符串。  
  807.      * @param str 字符串  
  808.      * @param out 输出流  
  809.      * @throws IOException 如果发生 I/O 错误。  
  810.      */  
  811.     private void sendString(String str,OutputStream out) throws IOException   
  812.     {   
  813.         log("发送: "+str);   
  814.   
  815.         if(str==null)   
  816.         {   
  817.             str="";   
  818.         }   
  819.            
  820.         out.write(str.getBytes());   
  821.         out.flush();   
  822.     }   
  823.        
  824.     /**  
  825.      * 写日志。  
  826.      * @param info 信息  
  827.      */  
  828.     private void log(String info)   
  829.     {   
  830.         for(int n=0,m=logManager.size();n<m;n++)   
  831.         {   
  832.             logManager.get(n).output(info);   
  833.         }   
  834.     }   
  835.   
  836.     /**  
  837.      * 输出一个换行符。  
  838.      * @param out 输出流  
  839.      * @throws IOException 如果发生 I/O 错误。  
  840.      */  
  841.     private static void sendNewline(OutputStream out) throws IOException   
  842.     {   
  843.         out.write('\r');   
  844.         out.write('\n');   
  845.         out.flush();   
  846.     }   
  847.        
  848.     /**  
  849.      * 获得字符串的Base64加密形式。  
  850.      * @param str 字符串  
  851.      * @return 加密后的字符串  
  852.      */  
  853.     private static String getBase64String(String str)   
  854.     {   
  855.         if(str==null||str.length()==0)   
  856.         {   
  857.             return "";   
  858.         }   
  859.            
  860.         StringBuffer tmpStr=new StringBuffer();   
  861.         byte[] bytes=str.getBytes();   
  862.            
  863.         for(int k=0;k<bytes.length;)   
  864.         {   
  865.             if(k!=0)   
  866.             {   
  867.                 tmpStr.append(' ');   
  868.             }   
  869.                
  870.             tmpStr.append("=?");   
  871.             tmpStr.append(CHARSET);   
  872.             tmpStr.append("?B?");   
  873.             tmpStr.append(Base64.encode(bytes,k,Math.min(bytes.length-k,30)));   
  874.             tmpStr.append("?=");   
  875.                
  876.             k+=30;   
  877.                
  878.             if(k<bytes.length)   
  879.             {   
  880.                 tmpStr.append('\r');   
  881.                 tmpStr.append('\n');   
  882.             }   
  883.         }   
  884.   
  885.         return tmpStr.toString();   
  886.     }   
  887.        
  888.     /**  
  889.      * 分析邮箱域名。  
  890.      * @param address E-Mail地址  
  891.      * @return 邮箱域名  
  892.      */  
  893.     private static String parseUrl(String address)   
  894.     {   
  895.         return address.substring(address.lastIndexOf('@')+1);   
  896.     }   
  897.        
  898.     /**  
  899.      * MX记录。  
  900.      */  
  901.     private class MX   
  902.     {   
  903.         final int pri;   
  904.         final String address;   
  905.            
  906.         MX(int pri,String host)   
  907.         {   
  908.             this.pri=pri;   
  909.             this.address=host;   
  910.         }   
  911.     }   
  912. }  




测试类
Java代码 复制代码 收藏代码
  1. import java.io.File;   
  2.   
  3. import org.gameeden.mail.SmtpMailSender;   
  4. import org.gameeden.util.LogManager;   
  5.   
  6. /**  
  7.  * 测试类。  
  8.  */  
  9. public class TestSmtpMail   
  10. {   
  11.     public static void main(String[] args)   
  12.     {   
  13.         SmtpMailSender sms=SmtpMailSender.createSmtpMailSender("\"Black Fox\"<blackfox@gameeden.org>");   
  14.     //    SmtpMailSender sms=SmtpMailSender.createESmtpMailSender("smtp.163.com","\"Object\"<java.lang.object@163.com>","java.lang.object","******");   
  15.            
  16.         sms.addLogManager(new LogPrinter());//添加日志管理器   
  17.            
  18.         if(sms.sendTextMail("\"Sol\"<114412367@qq.com>","STMP邮件测试","这是一封测试邮件。",new File[]{new File("java.gif")})==SmtpMailSender.SUCCESSFUL)   
  19.         {   
  20.             System.out.println("邮件发送成功。");   
  21.         }   
  22.         else  
  23.         {   
  24.             System.out.println("邮件发送失败。");   
  25.         }   
  26.     }   
  27. }   
  28.   
  29. /**  
  30.  * 一个简单的日志管理器。  
  31.  */  
  32. class LogPrinter implements LogManager   
  33. {   
  34.     public void output(String info)   
  35.     {   
  36.         System.out.println(info);//将日志打印到控制台   
  37.     }   
  38. }  




测试日志

状态: 创建邮件接收服务器列表
连接: 主机:"mx0.qq.com." 端口:"25"
响应: 220 mx7.qq.com ESMTP QQ Mail Server
发送: HELO gameeden.org
响应: 250 mx7.qq.com
发送: MAIL FROM: <blackfox@gameeden.org>
响应: 250 Ok
发送: RCPT TO: <114412367@qq.com>
响应: 250 Ok
发送: DATA
响应: 354 End data with .
发送: From: =?GBK?B?QmxhY2sgRm94?= <blackfox@gameeden.org>
发送: To: =?GBK?B?U29s?= <114412367@qq.com>
发送: Subject: =?GBK?B?U1RNUNPKvP6y4srU?=
发送: Date: Thu, 25 Oct 2007 10:42:13 +0800 (CST)
发送: MIME-Version: 1.0
发送: Content-Type: multipart/mixed; BOUNDARY="Boundary-=_hMbeqwnGNoWeLsRMeKTIPeofyStu"
发送: Content-Transfer-Encoding: base64
发送: X-Priority: 3
发送: X-Mailer: BlackFox Mail[Copyright(C) 2007 Sol]
发送:
发送: --Boundary-=_hMbeqwnGNoWeLsRMeKTIPeofyStu
发送: Content-Type: text/plain; charset="GBK"
发送: Content-Transfer-Encoding: base64
发送:
发送: 1eLKx9K7t+Ky4srU08q8/qGj
发送: --Boundary-=_hMbeqwnGNoWeLsRMeKTIPeofyStu
发送: Content-Type: image/gif; name="=?GBK?B?amF2YS5naWY=?="
发送: Content-Transfer-Encoding: base64
发送: Content-Disposition: attachment; filename="=?GBK?B?amF2YS5naWY=?="
发送:
发送: R0lGODlhOQA9AEQAACH/C05FVFNDQVBFMi4wAwEAAAAh+QQAyAAAACwAAAAAOQA9AKT///+Z
发送: mcz/zMzu7u5mZpn/mZm7u7vMzMzd3d3/mczMZpnMZmbMM2aZZpkzM5nMmcz/zP+IiIj/ZpnM
发送: MzNmM5nMzP+qqqrMADPMmZmZZmYAAAAAAAAAAAAAAAAAAAAAAAAF/yAgjmRpnmiqrmzrvnAs
发送: z3Rtk0JRCMPtiwKJQgABQBISwa9WkPRMuSVroOMBhiqBUnoSLCZbwI6V4JoKjAUJUgCEUW+z
发送: pKAoSYDF1CBv3imeIlQiBYAne2ZuO20kCVuLKXFLdXUlj5Qpj1JjlyOLAmVWUJmSiSZlYj0J
发送: fCRqbpE0n64lA1utdCYLWwyvMwmpq7KxBRc8jwutCqM2i40lVrkLaAIMWNFAYFKnsYw9DLsD
发送: F62yAwrEXJaVYhMiC3U5nkPiS49jnQITRblU9G1JZkT2RiigBmBBoza0APgriEjQCAHJEjCY
发送: MFFBMgADdi1UiEhMl11eBrTaVW9QoSVRnP8xAMCAXA+DEO6kQ1RyRBKDQ7woPAmgGc1RIies
发送: u9eDE4kCwFAm01LgGEWMKwecOqGMi5YtEC5YbDXVRMKOJ6hBYFCFlxGwJxTkukPFJ9oWEhEY
发送: wECLh68TFQLoRcBFroEDgA0w4NtIy6ASevUScOCAgAEbAwzsHTEAAQYMD/4meJRyQIAGBCgQ
发送: AM3YQQAaARwfMPAXMAIErXgYyHBALgYLklMTCCDZc+jUp2UEeBCAgt4IBJKPTvy5gW7RAQZE
发送: CC4iNQACCA5Q4NniAPDafy3gZm3AgvPhu0RUOEBigAP2BAAgwD6jwgDvAfimDNQqI4/siT1Q
发送: 3WmeVVfDasQtxxv/YAdkYAAC0yiB3wN8jRAfANFhRF0NuWVWYQKn3JVCfgB4Z6ANedHnDAoD
发送: FELiAA2IEEGFNvAWwHSsMRgYcYmxN0IFfMHYIgE+3jCAcgdU9lptCLToZGWrFelZZSr60JsB
发送: uzHHXGtNmsCXXtyhdsADD4Q5AgLEPUbCjUVKYUBjjWmpZZKU5UajGQEkCZpyop2n1555vnUm
发送: aMbduBtriSmnZkee6WXAE1gmpyWgvN3ppqTcyYVcaZLq1aZXn7qwGwIb9lWqC8HllmdtLbL4
发送: 5BOAVJZbrC2Q+l10gPFoaAMRTDddA3su5gAFw0r6YAkVLMqCAcgJq5xyfjKnHKcETJdZMayr
发送: /UVDZJ2SqWUEwGap5bPiHvuDd1lymV22umr5l5k/QMlaZn81Ca+g+Oar774jhAAAIfkEABQA
发送: AAAsAAAAADkAKwCk////mZnMzMzM7u7u/8zMZmaZ3d3du7u7/5mZzJnM/8z/zDNmmWaZMzOZ
发送: ZjOZiIiIzGZmzMz//5nMzGaZmWZmzJmZ/2aZqqqqAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA
发送: Bf8gII5kaZ5oqq5s675wLM90bd94rsfE7gOS364nzBGLtyPSplzOms6YYhCtQasuKnam3cIG
发送: Xa/rKi4pw+XmdKQom98jMnagJrXdoiY4jueTgnl9IncjCCMShHhHBIYiEIKBIghEBI+QjQAL
发送: IwtyWwhtCI0QmH0KmgOaABOkfZwAEEEIE5CShgYLBqgrEQG9Bj4GBwcCAhQCBhBEFim9vQUN
发送: DQUHNgMHviMDFcTGAgBXAwEMBQ4F4tANATQB0gLCxMcJAAqGA+0HwcQJzgUB1uDj69LJCKDP
发送: Qa8HBRKWC9csAMJx/AY8EChiHYACBgQ4QONCQMBjw9olOHBBX7NjIyJbdMPWoFsBAAYwzohQ
发送: 75oJVgAGZGwWD0CvnAIpyhC5jkGvkO9+jfBIUKmIlz6pgMNhjeC9gb88VrzBS2aWMAF+DWAg
发送: 4oHTGv0c9kNK7IDJXitFRBDLAEyBuCZCAAAh+QQAFAAAACwAAAAAOQArAKT///+Zmczu7u7/
发送: zMzMzMz/mZlmZpnd3d27u7vMM2b/mczMZmbMZpn/zP/MmczMMzP/ZpkzM5mZZplmM5nMzP/M
发送: ADOIiIgAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAF/yAgjmRpnmiqrmzrvnAsz4BQMMsC
发送: KXR/NouEoiEaFBaMgc83qFQS0BxjaCsQl7LFoCHodgcKRhJQUGJh15SCBz67RYKr+Y29Cuhn
发送: gXmOp9lEBX0+CmYMgj0JIwuHMzeAgYwmYAWUhGYCD3cNiZEkCg8LBWuUEDhBiwAJfJEDCXco
发送: rQMMD4adIwOrJVoCCWUQr7YKwCWyAw+QZMORlCdTDzwkuYzKIhUPuVy2KQWuJ4TaJwUV1CLd
发送: 4J5QKL3n0aoQJrzI7Km48gCt9ueOuJ7X8yQL7vADZO6fiHf3zEBAZXAEJD0AFHBqOALaPQBp
发送: KIpooESAgwPkSlAIQPIAnQMIEMAQWPlRwIGMJ0iSNBAhggEEPgQgKDnCJQGVP1MICCDBwAQD
发送: RWtGCEAjwM2fQAmATAjgwEqpQB3MNBBg51CjTpnKCKB1AkkLBtJyJSpz69EAAiyIFeEUgAGr
发送: E0KuIBAW68qUKdsGkDqCAgESAiIcNlD17gwKAvgGMNnCp0wHdJkOpdvjp1akJKOupCxC8kcS
发送: jAHArTG3x06yCEi/mAyAL2cfIx276EKCtgAJIizIbrpTbsqrf7XKPFzY5O8uBpifCAEAIfkE
发送: ABQAAAAsAAAAADkAKwCk////mZnM/8zM/5mZ7u7uzMzMzDNm/5nMZmaZzGZm3d3dzGaZu7u7
发送: /2aZ/8z/zJnMmWaZMzOZzDMzzMz/ZjOZiIiIqqqqzAAzzJmZAAAAAAAAAAAAAAAAAAAAAAAA
发送: AAAABf8gII5kaZKHYBJn675wrMZ0bQPHre/lwP+6AQtIhDWGxaQpoYQJBgmDNBFNLA5IErN5
发送: OkgHs9KTmhsJGtwSwZAIOw6DuCB7SJTb6dHaJxJIGwdwUAthAE9+eSMGfIYSKlkiKSULjGkO
发送: WyJtCxILJ3MkBgIOiZIjcZ0ujANohU2lfYAuDqgABiwCha08uD1QugADZQe0ZX1Ko2qGugaK
发送: SJW8RZ+Qhj1lArQElWBKBw7LJGsjCUgNhcxNc9sAa5jAfAKYAhJaleiU1FojhH0XM2u0iZ5A
发送: wsSMwIJQAGZJKJbIzKRIcRDCW9TwRKVsmSTwOciwIigSbxxIGWIAjccTCS7/brrn7qRFgAn7
发送: qavn0oUVYEOQ1XwBzwfMnS/K5TAJNEYnUUSLvniXVGmLMg8wKJhmYkKAqwrSKGDAoEABCwUU
发送: KPhp4upVBBEiIGBAhAADrHoeeC0AoYALAgEgIKCAQG/aCAF+BFhbgOtcBQ9EEGig4HDXAg/O
发送: IgjwFu/ewYF3BIhM4WoFBKD7XoVgdvDeyQQqZBYxGACCxhSoxiiAOexjBpEtWCgddsQEu3oi
发送: 2EUAQMFrHhMI0A6QFUW5FY3NJgZwdV3m1TsKRxZN2evj5iKWPwDvmjULvEnebmZAvgZzALRZ
发送: F7F6vAaBLO8JQBBRoT0PygGoZthc2vFGwgRZ6XcfBQLAnRACACH5BAAUAAAALAAAAAA5ACsA
发送: pP/////MzJmZzO7u7v+ZmczMzMwzZmZmmf+ZzN3d3cxmmbu7u8xmZv/M/8wzM8yZzJlmmf9m
发送: mTMzmWYzmcwAM8zM/5lmZoiIiMyZmaqqqgAAAAAAAAAAAAAAAAAAAAAAAAX/ICCOZGmeQBAg
发送: Kuq+MBwwjsEoBIEHce+XAYOBdwoQfkgYwkF8NZNQEcEw6A2qUZ/R4KBQbIRG7JlFzRyEwIAq
发送: MiqwKET5RUCPAhFT2nWcn6ZwKWRtgyIMfiYIBiQNK4UpYiU5iCWLAFNeaI8pJWuUjDk1X0Sb
发送: DZGGcp9tNUF9bU4jBIeqhocBCiWnf1KWtAgMPGEmjw24gLQib5d5JoEkDAgKvci4AAPAJ7oi
发送: ijfIJNUACDppziRBV94kzIIpOGZs6SSunEVDiuXpqSIN5QFM/lVmPFGgj5K2ALrWDPAnxt+T
发送: IN7IiMNCQM4QERe/bSrTwpwCYLZm3TIxK2LBbwCw/yGIMGhdRGWSAOACOGheOm3hLgG4iPNk
发送: PCApJolwhvCnCxXTOsayafSVS3bmIuCLxwMB0XJTqQ7wubGpiAcDHiQIpMZEBQFoE9BKsGBB
发送: gbcFMFx5suYJWrQHJEg4sGDOgAVpRwxga+Fthkj+XA0QAOHAhAON9UoQkEUA3wJt4SZIwASj
发送: WwwG3BZ4gPeAAMCLHVumDEUA6QloLxyY/RgtBAiMZzs2PeACaxGWARxIUGBC1hcFVhdgO7rw
发送: ggwW0EZfPqJCARIDJFw/ACDB8CgVBiQXoPYSFnDgBo93DZzyYuBlMJOGfPcthrcJ9I0XS4I7
发送: AAFVvOcHYK4tUJ5O9LhAHikAycE3x1nf+YDOCAsOAIEIFxxYxmkC+JYZXPLdJcB11all4RUH
发送: kHhCCAA7
发送: --Boundary-=_hMbeqwnGNoWeLsRMeKTIPeofyStu--
发送: .
响应: 250 Ok: queued as
发送: QUIT
响应: 221 Bye
邮件发送成功。

posted on 2012-01-22 11:52 脉凌网络 阅读(2997) 评论(2)  编辑  收藏

评论

# re: 用Java Socket实现SMTP邮件发送 2012-01-23 23:11 tb  回复  更多评论   

不错的例子啊

# re: 用Java Socket实现SMTP邮件发送 2012-05-08 22:51 weipt  回复  更多评论   

能用到ANDROID下吗

只有注册用户登录后才能发表评论。
网站导航: