logo
搜索
我的图书馆

发文章

发文工具

其他工具

留言交流
搜索
分享

黑马 JavaMail加深总结pop3协议收邮件

 Babylly 2011-11-26
  1. package com.skycn.pop3;  
  2.   
  3. import java.io.File;  
  4. import java.util.Properties;  
  5. /*** 
  6.  * 收邮件基本信息 
  7.  * @author tianzhw 
  8.  * 
  9.  */  
  10. public class MailReceiverInfo {  
  11.     //邮件服务器IP和端口和协议   
  12.     private String mailServerHost;  
  13.     private String mailServerPost;  
  14.     private String protpcal = "pop3";  
  15.     //登录邮件服务器的用户名和密码   
  16.     private String userName;  
  17.     private String passWord;  
  18.     //保存邮件的路径   
  19.     private String attchmentDir = "";  
  20.     private String emailDir = "";  
  21.     private String emailFileSuffix = ".eml";  
  22.     //是否要确认身份   
  23.     private boolean vaildate = true;  
  24.     //获得邮件的属性初始化   
  25.     public Properties getProperties() {  
  26.         Properties properties = new Properties();  
  27.         properties.put("mail.pop3.host", mailServerHost);  
  28.         properties.put("mail.pop3.port", mailServerPost);  
  29.         properties.put("mail.pop3.auth", vaildate ? "true" : "false");  
  30.         return properties;  
  31.     }  
  32.   
  33.     public String getMailServerHost() {  
  34.         return mailServerHost;  
  35.     }  
  36.   
  37.     public void setMailServerHost(String mailServerHost) {  
  38.         this.mailServerHost = mailServerHost;  
  39.     }  
  40.   
  41.     public String getMailServerPost() {  
  42.         return mailServerPost;  
  43.     }  
  44.   
  45.     public void setMailServerPost(String mailServerPost) {  
  46.         this.mailServerPost = mailServerPost;  
  47.     }  
  48.   
  49.     public String getProtpcal() {  
  50.         return protpcal;  
  51.     }  
  52.   
  53.     public void setProtpcal(String protpcal) {  
  54.         this.protpcal = protpcal;  
  55.     }  
  56.   
  57.     public String getUserName() {  
  58.         return userName;  
  59.     }  
  60.   
  61.     public void setUserName(String userName) {  
  62.         this.userName = userName;  
  63.     }  
  64.   
  65.     public String getPassWord() {  
  66.         return passWord;  
  67.     }  
  68.   
  69.     public void setPassWord(String passWord) {  
  70.         this.passWord = passWord;  
  71.     }  
  72.   
  73.     public String getAttchmentDir() {  
  74.         return attchmentDir;  
  75.     }  
  76.   
  77.     public void setAttchmentDir(String attchmentDir) {  
  78.         if (!attchmentDir.endsWith(File.separator)) {  
  79.             attchmentDir = attchmentDir + File.separator;  
  80.         }  
  81.         this.attchmentDir = attchmentDir;  
  82.     }  
  83.   
  84.     public String getEmailDir() {  
  85.         return emailDir;  
  86.     }  
  87.   
  88.     public void setEmailDir(String emailDir) {  
  89.         if (!emailDir.endsWith(File.separator)) {  
  90.             emailDir = emailDir + File.separator;  
  91.         }  
  92.         this.emailDir = emailDir;  
  93.     }  
  94.   
  95.     public String getEmailFileSuffix() {  
  96.         return emailFileSuffix;  
  97.     }  
  98.   
  99.     public void setEmailFileSuffix(String emailFileSuffix) {  
  100.         if (!emailFileSuffix.endsWith(File.separator)) {  
  101.             emailFileSuffix = emailFileSuffix + File.separator;  
  102.         }  
  103.         this.emailFileSuffix = emailFileSuffix;  
  104.     }  
  105.   
  106.     public boolean isVaildate() {  
  107.         return vaildate;  
  108.     }  
  109.   
  110.     public void setVaildate(boolean vaildate) {  
  111.         this.vaildate = vaildate;  
  112.     }  
  113.   
  114. }  

view plaincopy to clipboardprint?
  1. package com.skycn.pop3;  
  2.   
  3. import java.io.BufferedReader;  
  4. import java.io.BufferedWriter;  
  5. import java.io.ByteArrayOutputStream;  
  6. import java.io.File;  
  7. import java.io.FileWriter;  
  8. import java.io.IOException;  
  9. import java.io.InputStreamReader;  
  10. import java.io.Reader;  
  11. import java.io.StringReader;  
  12. import java.io.UnsupportedEncodingException;  
  13.   
  14. import javax.mail.BodyPart;  
  15. import javax.mail.Flags;  
  16. import javax.mail.Folder;  
  17. import javax.mail.Message;  
  18. import javax.mail.MessagingException;  
  19. import javax.mail.Multipart;  
  20. import javax.mail.NoSuchProviderException;  
  21. import javax.mail.Part;  
  22. import javax.mail.Session;  
  23. import javax.mail.Store;  
  24. import javax.mail.internet.InternetAddress;  
  25. import javax.mail.internet.MimeMessage;  
  26. import javax.mail.internet.MimeUtility;  
  27. import javax.xml.crypto.Data;  
  28.   
  29. import com.skycn.helper.MyAuthenticator;  
  30.   
  31. /******************************************************************************* 
  32.  * 邮件接收器，目前支持pop3协议 能够接受文本，html和带有福建的邮件 
  33.  *  
  34.  * @author tianzhw 
  35.  */  
  36. @SuppressWarnings("unused")  
  37. public class MailReceiver {  
  38.   
  39.     private MailReceiverInfo receiverInfo;// 邮件的参数配置   
  40.     private Store store;// 以邮件服务器连接后得到的邮箱   
  41.     private Folder folder;// 收件箱   
  42.     private Message[] messages;// 收件箱中的邮件消息   
  43.     private Message currentMessage;// 正在处理的邮件消息   
  44.     private String currentEmailFileName;  
  45.   
  46.     public MailReceiver(MailReceiverInfo receiverInfo) {  
  47.         this.receiverInfo = receiverInfo;  
  48.     }  
  49.   
  50.     /*************************************************************************** 
  51.      * 收邮件 
  52.      */  
  53.     public void receiveAllMail() throws Exception {  
  54.         if (this.receiverInfo == null) {  
  55.             throw new Exception("必须提供收邮件的参数");  
  56.         }  
  57.         // 打开连接   
  58.         if (this.connectToServer()) {  
  59.             // 打开收件箱   
  60.             if (this.openInBoxFolder()) {  
  61.                 // 收件箱里面的邮件信息输出   
  62.                 this.getAllMail();  
  63.                 this.closeConnection();  
  64.             } else {  
  65.                 throw new Exception("打开连接失败");  
  66.             }  
  67.         } else {  
  68.             throw new Exception("打开连接失败");  
  69.         }  
  70.   
  71.     }  
  72.   
  73.     /*************************************************************************** 
  74.      * 登录服务器，登录服务器，通过Session对象创建store对象。同时讲session对象中认证名和密码，协议描述，等信息通知服务器。 
  75.      */  
  76.     @SuppressWarnings("unused")  
  77.     private boolean connectToServer() {  
  78.         // 判断是否需要身份认证   
  79.         MyAuthenticator authenticator = null;  
  80.         if (this.receiverInfo.isVaildate()) {  
  81.             // 如果需要身份认证，则创建一个密码验证器   
  82.             authenticator = new MyAuthenticator(  
  83.                     this.receiverInfo.getUserName(), this.receiverInfo  
  84.                             .getPassWord());  
  85.         }  
  86.         // 创建一个session   
  87.         Session mailSession = Session.getInstance(this.receiverInfo  
  88.                 .getProperties());  
  89.         try {  
  90.             // 创建store，建立连接,通过Session对象是可以创建一个store对象的。   
  91.             this.store = mailSession.getStore(this.receiverInfo.getProtpcal());  
  92.         } catch (NoSuchProviderException e) {  
  93.             System.out.println("链接服务器失败");  
  94.             return false;  
  95.         }  
  96.         System.out.println("connecting");  
  97.         try {  
  98.             this.store.connect();  
  99.         } catch (MessagingException e) {  
  100.             // TODO Auto-generated catch block   
  101.             System.out.println("链接服务器失败");  
  102.             return false;  
  103.         }  
  104.         return true;  
  105.     }  
  106.   
  107.     /*************************************************************************** 
  108.      * 打开收件箱 
  109.      * stroe是一个邮箱的整体，如果连接上以后，我们有很多抽屉，Inbox是国际默认的收件箱（抽屉的）标示。但是也有不是这样的，这取决于什么邮件服务器 
  110.      */  
  111.     private boolean openInBoxFolder() {  
  112.         try {  
  113.             this.folder = this.store.getFolder("inbox");  
  114.             folder.open(Folder.READ_ONLY);  
  115.             return true;  
  116.         } catch (MessagingException e) {  
  117.             // TODO Auto-generated catch block   
  118.             e.printStackTrace();  
  119.         }  
  120.         return false;  
  121.     }  
  122.   
  123.     /*************************************************************************** 
  124.      * 关闭链接 
  125.      *  
  126.      * @return 
  127.      */  
  128.     private boolean closeConnection() {  
  129.         try {  
  130.             if (this.folder.isOpen()) {  
  131.                 this.folder.close(true);  
  132.             }  
  133.             this.store.close();  
  134.             System.out.println("关闭链接成功 ");  
  135.             return true;  
  136.         } catch (MessagingException e) {  
  137.             // TODO Auto-generated catch block   
  138.             e.printStackTrace();  
  139.         }  
  140.         return false;  
  141.     }  
  142.   
  143.     private void getAllMail() throws Exception {  
  144.         // 文件夹下获取邮件信息   
  145.         this.messages = this.folder.getMessages();  
  146.         System.out.println("总邮件数目：" + messages.length);  
  147.         System.out.println("新邮件数目：" + this.getNewMessageCount());  
  148.         System.out.println("未读邮件数目：" + this.getUnreadMessageConunt());  
  149.         // 将要下载的邮件数量   
  150.         int mailArrayLength = this.getMessageCount();  
  151.         System.out.println("一共有邮件" + mailArrayLength + "封");  
  152.         int errorCounter = 0;  
  153.         int successCounter = 0;  
  154.         for (int index = 0; index < mailArrayLength; index++) {  
  155.             this.currentMessage = messages[index];  
  156.             System.out.println("正在获取第" + index + "封邮件~~~~~~~~~~~~~~");  
  157.             this.showMailBasicInfo();  
  158.         }  
  159.   
  160.     }  
  161.   
  162.     private void showMailBasicInfo() throws Exception {  
  163.         // TODO Auto-generated method stub   
  164.         showMailBasicInfo(this.currentMessage);  
  165.     }  
  166.   
  167.     /*************************************************************************** 
  168.      * 显示邮件的基本信息 
  169.      *  
  170.      * @param message 
  171.      * @throws Exception 
  172.      */  
  173.     private void showMailBasicInfo(Message message) throws Exception {  
  174.         // TODO Auto-generated method stub   
  175.         System.out.println("~~~~~~~~~~~邮件ID：" + this.getMessageId()  
  176.                 + "~~~~~~~~~~~~~~~~~~~~~~~ ");  
  177.         System.out.println("From：" + this.getFrom());  
  178.         System.out.println("To：" + this.getToAddress());  
  179.         System.out.println("CC：" + this.getCCAddress());  
  180.         System.out.println("BCC：" + this.getBCCAddress());  
  181.         System.out.println("Subject：" + this.getSubject());  
  182.         System.out.println("发送时间：" + this.getSentDate());  
  183.         System.out.println("是新邮件？：" + this.isNew());  
  184.         System.out.println("是否回执：" + this.getReplySign());  
  185.         System.out.println("包涵附件：" + this.isContainAttch());  
  186.         System.out  
  187.                 .println("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~");  
  188.     }  
  189.   
  190.     private boolean isContainAttch() throws Exception {  
  191.         // TODO Auto-generated method stub   
  192.         return isContainAttch(this.currentMessage);  
  193.     }  
  194.   
  195.     /*************************************************************************** 
  196.      * 判断邮件是否是包含附件 
  197.      *  
  198.      * @param part 
  199.      * @return 
  200.      * @throws Exception 
  201.      */  
  202.     private boolean isContainAttch(Part part) throws Exception {  
  203.         boolean attachflag = false;  
  204.         if (part.isMimeType("multipart/*")) {  
  205.             // 如果邮件体包含多部分   
  206.             Multipart mp = (Multipart) part.getContent();  
  207.   
  208.             for (int i = 0; i < mp.getCount(); i++) {  
  209.                 BodyPart bodyPart = mp.getBodyPart(i);  
  210.                 String disposition = bodyPart.getDisposition();  
  211.                 if ((disposition != null)  
  212.                         && ((disposition.equals(Part.ATTACHMENT) || (disposition  
  213.                                 .equals(Part.INLINE))))) {  
  214.                     attachflag = true;  
  215.                 } else if (bodyPart.isMimeType("Multipart/*")) {  
  216.                     attachflag = isContainAttch((Part) bodyPart);  
  217.                 } else {  
  218.                     String contype = bodyPart.getContentType();  
  219.                     if (contype.toLowerCase().indexOf("applcation") != -1) {  
  220.                         attachflag = true;  
  221.                     }  
  222.                     if (contype.toLowerCase().indexOf("name") != -1) {  
  223.                         attachflag = true;  
  224.                     }  
  225.                 }  
  226.             }  
  227.         } else if (part.isMimeType("message/rfc822")) {  
  228.             attachflag = isContainAttch((Part) part.getContent());  
  229.         }  
  230.         return attachflag;  
  231.     }  
  232.   
  233.     private String getMessageId() throws Exception {  
  234.         // TODO Auto-generated method stub   
  235.         return getMessageId(this.currentMessage);  
  236.     }  
  237.   
  238.     /***************************************************************************  
  239.      * 获得Message - Id  
  240.      *   
  241.      * @param mimeMessage  
  242.      * @return  
  243.      * @throws Exception  
  244.      */  
  245.     private String getMessageId(Message mimeMessage) throws Exception {  
  246.         MimeMessage message = (MimeMessage) mimeMessage;  
  247.         return message.getMessageID();  
  248.     }  
  249.   
  250.     private boolean getReplySign() throws Exception {  
  251.         // TODO Auto-generated method stub   
  252.         return getReplySign(this.currentMessage);  
  253.     }  
  254.   
  255.     /*************************************************************************** 
  256.      * 判断邮件是否需要回执。 
  257.      *  
  258.      * @param mimeMessage 
  259.      * @return 
  260.      * @throws Exception 
  261.      */  
  262.     private boolean getReplySign(Message mimeMessage) throws Exception {  
  263.         // TODO Auto-generated method stub   
  264.         boolean replaysign = false;  
  265.         String[] needreply = (String[]) mimeMessage  
  266.                 .getHeader("Disposition-Notification-To");  
  267.         if (needreply != null) {  
  268.             replaysign = true;  
  269.         }  
  270.         return replaysign;  
  271.     }  
  272.   
  273.     private boolean isNew() throws Exception {  
  274.         // TODO Auto-generated method stub   
  275.         return isNew(this.currentMessage);  
  276.     }  
  277.   
  278.     /*************************************************************************** 
  279.      * 获得邮件是否是已经读过了 
  280.      *  
  281.      * @param mimeMessage 
  282.      * @return 
  283.      * @throws Exception 
  284.      */  
  285.     private boolean isNew(Message mimeMessage) throws Exception {  
  286.         // TODO Auto-generated method stub   
  287.         boolean isnew = false;  
  288.         Flags flags = mimeMessage.getFlags();  
  289.         Flags.Flag[] flag = flags.getSystemFlags();  
  290.         for (int i = 0; i < flag.length; i++) {  
  291.             if (flag[i] == Flags.Flag.SEEN) {  
  292.                 isnew = true;  
  293.                 break;  
  294.             }  
  295.         }  
  296.         return false;  
  297.     }  
  298.   
  299.     private Data getSentDate() throws Exception {  
  300.         // TODO Auto-generated method stub   
  301.         return getSetDate(this.currentMessage);  
  302.     }  
  303.   
  304.     /** 
  305.      * 获得邮件的发送日期 
  306.      *  
  307.      * @param mimeMessage 
  308.      * @return 
  309.      * @throws Exception 
  310.      */  
  311.     private Data getSetDate(Message mimeMessage) throws Exception {  
  312.         // TODO Auto-generated method stub   
  313.         return (Data) mimeMessage.getSentDate();  
  314.     }  
  315.   
  316.     /** 
  317.      * 获得邮件的发送主题 
  318.      *  
  319.      * @return 
  320.      * @throws Exception 
  321.      */  
  322.     private String getSubject() throws Exception {  
  323.         return getSubject(this.currentMessage);  
  324.     }  
  325.   
  326.     private String getSubject(Message mimeMessage) throws Exception {  
  327.         // TODO Auto-generated method stub   
  328.         String subject = "";  
  329.         try {  
  330.             subject = MimeUtility.decodeText(mimeMessage.getSubject());  
  331.             if (subject == null) {  
  332.                 subject = "";  
  333.             }  
  334.         } catch (Exception e) {  
  335.         }  
  336.         return subject;  
  337.     }  
  338.   
  339.     /*************************************************************************** 
  340.      * 获得发件人的地址和姓名 
  341.      *  
  342.      * @return 
  343.      * @throws Exception 
  344.      */  
  345.     private String getFrom() throws Exception {  
  346.         return getFrom(this.currentMessage);  
  347.     }  
  348.   
  349.     /*************************************************************************** 
  350.      * 获得发件人的地址和姓名 
  351.      *  
  352.      * @return 
  353.      * @throws Exception 
  354.      */  
  355.     private String getFrom(Message mimeMessage) throws Exception {  
  356.         InternetAddress[] address = (InternetAddress[]) mimeMessage.getFrom();  
  357.         // 获得发件人的邮件地址   
  358.         String from = address[0].getAddress();  
  359.         if (from == null) {  
  360.             from = "";  
  361.         }  
  362.         // 获得发件人的描述   
  363.         String personal = address[0].getPersonal();  
  364.         if (personal == null) {  
  365.             personal = "";  
  366.         }  
  367.         String fromaddr = personal + "<" + from + ">";  
  368.         return fromaddr;  
  369.     }  
  370.   
  371.     /** 
  372.      * 根据传递的参数的不同，获得邮件收件人、抄送、密送的地址和姓名 to---收件人 cc----抄送人 bcc----密送人 
  373.      *  
  374.      * @return 
  375.      * @throws Exception 
  376.      */  
  377.     private String getBCCAddress() throws Exception {  
  378.         // TODO Auto-generated method stub   
  379.         return getMailAddress("BCC", this.currentMessage);  
  380.     }  
  381.   
  382.     private String getCCAddress() throws Exception {  
  383.         // TODO Auto-generated method stub   
  384.         return getMailAddress("CC", this.currentMessage);  
  385.     }  
  386.   
  387.     private String getToAddress() throws Exception {  
  388.         // TODO Auto-generated method stub   
  389.         return getMailAddress("TO", this.currentMessage);  
  390.     }  
  391.   
  392.     /*************************************************************************** 
  393.      * 获得邮件地址 
  394.      *  
  395.      * @param type 
  396.      *            类型 如 收件人 抄送人 密送人 
  397.      * @param mimeMessage 
  398.      *            邮件消息 
  399.      * @return 
  400.      * @throws Exception 
  401.      */  
  402.     private String getMailAddress(String type, Message mimeMessage)  
  403.             throws Exception {  
  404.         String mailaddr = "";  
  405.         String addtype = type.toUpperCase();  
  406.         InternetAddress[] address = null;  
  407.         if (addtype.equals("TO") || addtype.equals("CC")  
  408.                 || addtype.equals("BCC")) {  
  409.             if (addtype.equals("TO")) {  
  410.                 address = (InternetAddress[]) mimeMessage  
  411.                         .getRecipients(Message.RecipientType.TO);  
  412.             }  
  413.             if (addtype.equals("CC")) {  
  414.                 address = (InternetAddress[]) mimeMessage  
  415.                         .getRecipients(Message.RecipientType.CC);  
  416.             }  
  417.             if (addtype.equals("BCC")) {  
  418.                 address = (InternetAddress[]) mimeMessage  
  419.                         .getRecipients(Message.RecipientType.BCC);  
  420.             }  
  421.             if (address != null) {  
  422.                 for (int i = 0; i < address.length; i++) {  
  423.                     // 先获取邮件地址   
  424.                     String email = address[i].getAddress();  
  425.                     if (email == null) {  
  426.                         email = "";  
  427.                     } else {  
  428.                         email = MimeUtility.decodeText(email);  
  429.                     }  
  430.                     // 再取得个人描述信息   
  431.                     String personal = address[i].getPersonal();  
  432.                     if (personal == null) {  
  433.                         personal = "";  
  434.                     } else {  
  435.                         personal = MimeUtility.decodeText(personal);  
  436.                     }  
  437.                     // 讲个人描述信息与邮件地址连接起来   
  438.                     String compostiteto = personal + "<" + email + ">";  
  439.                     // 多个地址用，号分隔   
  440.                     mailaddr += "," + compostiteto;  
  441.                 }  
  442.                 mailaddr = mailaddr.substring(1);  
  443.             }  
  444.         } else {  
  445.             throw new Exception("错误的地址类型");  
  446.         }  
  447.         return mailaddr;  
  448.     }  
  449.   
  450.     /*************************************************************************** 
  451.      * 获得messages中Message的个数 
  452.      *  
  453.      * @return 
  454.      */  
  455.     private int getMessageCount() {  
  456.         // TODO Auto-generated method stub   
  457.         return this.messages.length;  
  458.     }  
  459.   
  460.     /** 
  461.      * 获得邮件里面未读的邮件个数 
  462.      *  
  463.      * @return 
  464.      * @throws MessagingException 
  465.      */  
  466.     private int getUnreadMessageConunt() throws MessagingException {  
  467.         // TODO Auto-generated method stub   
  468.         return this.folder.getUnreadMessageCount();  
  469.     }  
  470.   
  471.     /** 
  472.      * 获得邮件里面新邮件的个数 
  473.      *  
  474.      * @return 
  475.      * @throws MessagingException 
  476.      */  
  477.     private int getNewMessageCount() throws MessagingException {  
  478.         // TODO Auto-generated method stub   
  479.         return this.folder.getNewMessageCount();  
  480.     }  
  481.   
  482.     /*************************************************************************** 
  483.      * 获得当前邮件 
  484.      *  
  485.      * @throws MessagingException 
  486.      * @throws IOException 
  487.      */  
  488.     private void getMail() throws Exception {  
  489.         this.saveMessageAsFile(this.currentMessage);  
  490.         this.parseMessage(this.currentMessage);  
  491.     }  
  492.   
  493.     /*************************************************************************** 
  494.      * 解析邮件 
  495.      *  
  496.      * @param currentMessage2 
  497.      * @throws MessagingException 
  498.      * @throws IOException 
  499.      */  
  500.     private void parseMessage(Message message) throws IOException,  
  501.             MessagingException {  
  502.         Object content = message.getContent();  
  503.         if (content instanceof Multipart) {  
  504.             handleMultipart((Multipart) content);  
  505.         } else {  
  506.             handlePart(message);  
  507.         }  
  508.   
  509.     }  
  510.   
  511.     /*************************************************************************** 
  512.      * 解析Multipart 
  513.      *  
  514.      * @param content 
  515.      * @throws MessagingException 
  516.      * @throws IOException 
  517.      */  
  518.     private void handleMultipart(Multipart multipart)  
  519.             throws MessagingException, IOException {  
  520.         for (int i = 0, n = multipart.getCount(); i < n; i++) {  
  521.             handlePart(multipart.getBodyPart(i));  
  522.         }  
  523.   
  524.     }  
  525.   
  526.     /*************************************************************************** 
  527.      *  
  528.      * @param bodyPart 
  529.      * @throws MessagingException 
  530.      * @throws IOException 
  531.      */  
  532.     private void handlePart(Part part) throws MessagingException, IOException {  
  533.         String dispostion = part.getDisposition();  
  534.         String contentType = part.getContentType();  
  535.         String fileNameWidthExtension = "";  
  536.         // 获得邮件的内容输入流   
  537.         InputStreamReader sbis = new InputStreamReader(part.getInputStream());  
  538.         // 在没有附件的情况   
  539.         if (dispostion == null) {  
  540.             if ((contentType.length() >= 10)  
  541.                     && (contentType.toLowerCase().substring(0, 10)  
  542.                             .equals("text/plain"))) {  
  543.                 fileNameWidthExtension = this.receiverInfo.getAttchmentDir()  
  544.                         + this.currentEmailFileName + ".txt";  
  545.             } else if ((contentType.length() >= 9)  
  546.                     && (contentType.toLowerCase().substring(0, 9)  
  547.                             .equals("text/html"))) {  
  548.                 fileNameWidthExtension = this.receiverInfo.getAttchmentDir()  
  549.                         + this.currentEmailFileName + ".html";  
  550.             } else if ((contentType.length() >= 9)  
  551.                     && (contentType.toLowerCase().substring(0, 9)  
  552.                             .equals("text/gif"))) {  
  553.                 fileNameWidthExtension = this.receiverInfo.getAttchmentDir()  
  554.                         + this.currentEmailFileName + ".gif";  
  555.             } else if ((contentType.length() >= 9)  
  556.                     && (contentType.toLowerCase().substring(0, 9)  
  557.                             .equals("multipart/*"))) {  
  558.                 handleMultipart((Multipart) part.getContent());  
  559.             } else {  
  560.                 fileNameWidthExtension = this.receiverInfo.getAttchmentDir()  
  561.                         + this.currentEmailFileName + ".txt";  
  562.             }  
  563.             System.out.println("保存邮件内容到：" + fileNameWidthExtension);  
  564.             saveFile(fileNameWidthExtension, sbis);  
  565.             return;  
  566.         }  
  567.         // 各种有附件的情况   
  568.         String name = "";  
  569.         if (dispostion.equalsIgnoreCase(Part.ATTACHMENT)) {  
  570.             name = getFileName(part);  
  571.             fileNameWidthExtension = this.receiverInfo.getAttchmentDir() + name;  
  572.         } else if (dispostion.equalsIgnoreCase(Part.INLINE)) {  
  573.             name = getFileName(part);  
  574.             fileNameWidthExtension = this.receiverInfo.getAttchmentDir() + name;  
  575.         } else {  
  576.   
  577.         }  
  578.   
  579.         // 储存各类附件   
  580.         if (!fileNameWidthExtension.equals("")) {  
  581.             System.out.println("保存邮件附件到：" + fileNameWidthExtension);  
  582.             saveFile(fileNameWidthExtension, sbis);  
  583.         }  
  584.   
  585.     }  
  586.   
  587.     private String getFileName(Part part) throws UnsupportedEncodingException,  
  588.             MessagingException {  
  589.         String fileName = part.getFileName();  
  590.         fileName = MimeUtility.decodeText(fileName);  
  591.         String name = fileName;  
  592.         if (fileName != null) {  
  593.             int index = fileName.lastIndexOf("/");  
  594.             if (index != -1) {  
  595.                 name = fileName.substring(index + 1);  
  596.             }  
  597.         }  
  598.         return name;  
  599.     }  
  600.   
  601.     /***************************************************************************  
  602.      * 保存邮件源文件  
  603.      *   
  604.      * @param currentMessage2  
  605.      */  
  606.     private void saveMessageAsFile(Message message) {  
  607.         try {  
  608.             // 将邮件ID中尖括号中的部分作为邮件的文件名   
  609.             String oriFileName = getInfoBetweenBrackets(this.getMessageId(  
  610.                     message).toString());  
  611.             // 设置文件后缀名，如是附件则设法取得其文件后缀名作为将要保存文件的后缀名。如是正文不封则用。html作为后缀名   
  612.             String emlName = oriFileName;  
  613.             String fileNameWidthExtension = this.receiverInfo.getEmailDir()  
  614.                     + oriFileName + this.receiverInfo.getEmailFileSuffix();  
  615.             File storeFile = new File(fileNameWidthExtension);  
  616.             for (int i = 0; storeFile.exists(); i++) {  
  617.                 emlName = oriFileName + i;  
  618.                 fileNameWidthExtension = this.receiverInfo.getEmailDir()  
  619.                         + emlName + this.receiverInfo.getEmailFileSuffix();  
  620.                 storeFile = new File(fileNameWidthExtension);  
  621.             }  
  622.             this.currentEmailFileName = emlName;  
  623.             System.out.println("邮件消息的存储路径:" + fileNameWidthExtension);  
  624.             // 将邮件消息的内容写入ByteArrayOutputStram流中   
  625.             ByteArrayOutputStream baos = new ByteArrayOutputStream();  
  626.             message.writeTo(baos);  
  627.             StringReader in = new StringReader(baos.toString());  
  628.             saveFile(fileNameWidthExtension, in);  
  629.   
  630.         } catch (Exception e) {  
  631.             // TODO Auto-generated catch block   
  632.             e.printStackTrace();  
  633.         }  
  634.   
  635.     }  
  636.   
  637.     /** 
  638.      * 保存文件内容 
  639.      *  
  640.      * @param fileName 
  641.      * @param in 
  642.      * @throws IOException 
  643.      */  
  644.     private void saveFile(String fileName, Reader in) throws IOException {  
  645.         // 为了防止文件名重名，在重名的文件后面添加上数字   
  646.         File file = new File(fileName);  
  647.         // 先取得文件名的后缀   
  648.         int lastDot = fileName.lastIndexOf(".");  
  649.         String extension = fileName.substring(lastDot);  
  650.         fileName = fileName.substring(0, lastDot);  
  651.         for (int i = 0; file.exists(); i++) {  
  652.             file = new File(fileName + i + extension);  
  653.         }  
  654.         // 从输入流中读取数据，写入文件的输入流   
  655.         FileWriter fos = new FileWriter(file);  
  656.         BufferedWriter bos = new BufferedWriter(fos);  
  657.         BufferedReader bis = new BufferedReader(in);  
  658.         int aByte;  
  659.         while ((aByte = bis.read()) != -1) {  
  660.             bos.write(aByte);  
  661.         }  
  662.         bos.flush();  
  663.         bos.close();  
  664.         bis.close();  
  665.     }  
  666.   
  667.     /** 
  668.      * 获得尖括号之间的字符串 如 tianzhw <tianzhw@vip.qq.com> ----- tianzhw@vip.qq.cpm 
  669.      *  
  670.      * @param string 
  671.      * @return 
  672.      */  
  673.     private String getInfoBetweenBrackets(String str) {  
  674.         int i, j;  
  675.         if (str == null) {  
  676.             str = "error";  
  677.             return str;  
  678.         }  
  679.         i = str.lastIndexOf("<");  
  680.         j = str.lastIndexOf(">");  
  681.         if (i != 1 && j != -1) {  
  682.             str = str.substring(i + 1, j);  
  683.         }  
  684.         return str;  
  685.     }  
  686.   
  687.     public static void main(String[] args) throws Exception {  
  688.         MailReceiverInfo info = new MailReceiverInfo();  
  689.         info.setMailServerHost("pop.163.com");  
  690.         info.setMailServerPost("110");  
  691.         info.setVaildate(true);  
  692.         info.setUserName("*************");  
  693.         info.setPassWord("*************");  
  694.         info.setAttchmentDir("F:/mails");  
  695.         info.setEmailDir("F:/mails");  
  696.           
  697.         MailReceiver receiver = new MailReceiver(info);  
  698.           
  699.         receiver.receiveAllMail();  
  700.     }  
  701. }  

    本站是提供个人知识管理的网络存储空间，所有内容均由用户发布，不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息，谨防诈骗。如发现有害或侵权内容，请点击一键举报。
    转藏 分享 献花（0）

    来自： Babylly > 《java文章》

    举报/认领

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多