java mail(收邮件)

wander312

转载:
http://xiangzhengyan.iteye.com/blog/85961

package email;   import java.io.*;      import java.text.*;      import java.util.*;      import javax.mail.*;      import javax.mail.internet.*;           /**      * 有一封邮件就需要建立一个ReciveMail对象      */    public class ReciveOneMail {         private MimeMessage mimeMessage = null;         private String saveAttachPath = ""; //附件下载后的存放目录         private StringBuffer bodytext = new StringBuffer();//存放邮件内容         private String dateformat = "yy-MM-dd HH:mm"; //默认的日前显示格式             public ReciveOneMail(MimeMessage mimeMessage) {             this.mimeMessage = mimeMessage;         }             public void setMimeMessage(MimeMessage mimeMessage) {             this.mimeMessage = mimeMessage;         }             /**         * 获得发件人的地址和姓名         */        public String getFrom() throws Exception {             InternetAddress address[] = (InternetAddress[]) mimeMessage.getFrom();             String from = address[0].getAddress();             if (from == null)                 from = "";             String personal = address[0].getPersonal();             if (personal == null)                 personal = "";             String fromaddr = personal + "<" + from + ">";             return fromaddr;         }             /**         * 获得邮件的收件人，抄送，和密送的地址和姓名，根据所传递的参数的不同 "to"----收件人 "cc"---抄送人地址 "bcc"---密送人地址         */        public String getMailAddress(String type) throws Exception {             String mailaddr = "";             String addtype = type.toUpperCase();             InternetAddress[] address = null;             if (addtype.equals("TO") || addtype.equals("CC")|| addtype.equals("BCC")) {                 if (addtype.equals("TO")) {                     address = (InternetAddress[]) mimeMessage.getRecipients(Message.RecipientType.TO);                 } else if (addtype.equals("CC")) {                     address = (InternetAddress[]) mimeMessage.getRecipients(Message.RecipientType.CC);                 } else {                     address = (InternetAddress[]) mimeMessage.getRecipients(Message.RecipientType.BCC);                 }                 if (address != null) {                     for (int i = 0; i < address.length; i++) {                         String email = address[i].getAddress();                         if (email == null)                             email = "";                         else {                             email = MimeUtility.decodeText(email);                         }                         String personal = address[i].getPersonal();                         if (personal == null)                             personal = "";                         else {                             personal = MimeUtility.decodeText(personal);                         }                         String compositeto = personal + "<" + email + ">";                         mailaddr += "," + compositeto;                     }                     mailaddr = mailaddr.substring(1);                 }             } else {                 throw new Exception("Error emailaddr type!");             }             return mailaddr;         }             /**         * 获得邮件主题         */        public String getSubject() throws MessagingException {             String subject = "";             try {                 subject = MimeUtility.decodeText(mimeMessage.getSubject());                 if (subject == null)                     subject = "";             } catch (Exception exce) {}             return subject;         }             /**         * 获得邮件发送日期         */        public String getSentDate() throws Exception {             Date sentdate = mimeMessage.getSentDate();             SimpleDateFormat format = new SimpleDateFormat(dateformat);             return format.format(sentdate);         }           /**        * 获得邮件正文内容        */       public String getBodyText() {            return bodytext.toString();        }           /**        * 解析邮件，把得到的邮件内容保存到一个StringBuffer对象中，解析邮件 主要是根据MimeType类型的不同执行不同的操作，一步一步的解析        */       public void getMailContent(Part part) throws Exception {            String contenttype = part.getContentType();            int nameindex = contenttype.indexOf("name");            boolean conname = false;            if (nameindex != -1)                conname = true;            System.out.println("CONTENTTYPE: " + contenttype);            if (part.isMimeType("text/plain") && !conname) {                bodytext.append((String) part.getContent());            } else if (part.isMimeType("text/html") && !conname) {                bodytext.append((String) part.getContent());            } else if (part.isMimeType("multipart/*")) {                Multipart multipart = (Multipart) part.getContent();                int counts = multipart.getCount();                for (int i = 0; i < counts; i++) {                    getMailContent(multipart.getBodyPart(i));                }            } else if (part.isMimeType("message/rfc822")) {                getMailContent((Part) part.getContent());            } else {}        }           /**         * 判断此邮件是否需要回执，如果需要回执返回"true",否则返回"false"        */        public boolean getReplySign() throws MessagingException {            boolean replysign = false;            String needreply[] = mimeMessage                    .getHeader("Disposition-Notification-To");            if (needreply != null) {                replysign = true;            }            return replysign;        }           /**        * 获得此邮件的Message-ID        */       public String getMessageId() throws MessagingException {            return mimeMessage.getMessageID();        }           /**        * 【判断此邮件是否已读，如果未读返回返回false,反之返回true】        */       public boolean isNew() throws MessagingException {            boolean isnew = false;            Flags flags = ((Message) mimeMessage).getFlags();            Flags.Flag[] flag = flags.getSystemFlags();            System.out.println("flags's length: " + flag.length);            for (int i = 0; i < flag.length; i++) {                if (flag[i] == Flags.Flag.SEEN) {                    isnew = true;                    System.out.println("seen Message.......");                    break;                }            }            return isnew;        }           /**        * 判断此邮件是否包含附件        */       public boolean isContainAttach(Part part) throws Exception {            boolean attachflag = false;            String contentType = part.getContentType();            if (part.isMimeType("multipart/*")) {                Multipart mp = (Multipart) part.getContent();                for (int i = 0; i < mp.getCount(); i++) {                    BodyPart mpart = mp.getBodyPart(i);                    String disposition = mpart.getDisposition();                    if ((disposition != null)                            && ((disposition.equals(Part.ATTACHMENT)) || (disposition                                    .equals(Part.INLINE))))                        attachflag = true;                    else if (mpart.isMimeType("multipart/*")) {                        attachflag = isContainAttach((Part) mpart);                    } else {                        String contype = mpart.getContentType();                        if (contype.toLowerCase().indexOf("application") != -1)                            attachflag = true;                        if (contype.toLowerCase().indexOf("name") != -1)                            attachflag = true;                    }                }            } else if (part.isMimeType("message/rfc822")) {                attachflag = isContainAttach((Part) part.getContent());            }            return attachflag;        }           /**         * 【保存附件】         */        public void saveAttachMent(Part part) throws Exception {            String fileName = "";            if (part.isMimeType("multipart/*")) {                Multipart mp = (Multipart) part.getContent();                for (int i = 0; i < mp.getCount(); i++) {                    BodyPart mpart = mp.getBodyPart(i);                    String disposition = mpart.getDisposition();                    if ((disposition != null)                            && ((disposition.equals(Part.ATTACHMENT)) || (disposition                                    .equals(Part.INLINE)))) {                        fileName = mpart.getFileName();                        if (fileName.toLowerCase().indexOf("gb2312") != -1) {                            fileName = MimeUtility.decodeText(fileName);                        }                        saveFile(fileName, mpart.getInputStream());                    } else if (mpart.isMimeType("multipart/*")) {                        saveAttachMent(mpart);                    } else {                        fileName = mpart.getFileName();                        if ((fileName != null)                                && (fileName.toLowerCase().indexOf("GB2312") != -1)) {                            fileName = MimeUtility.decodeText(fileName);                            saveFile(fileName, mpart.getInputStream());                        }                    }                }            } else if (part.isMimeType("message/rfc822")) {                saveAttachMent((Part) part.getContent());            }        }           /**         * 【设置附件存放路径】         */           public void setAttachPath(String attachpath) {            this.saveAttachPath = attachpath;        }           /**        * 【设置日期显示格式】        */       public void setDateFormat(String format) throws Exception {            this.dateformat = format;        }           /**        * 【获得附件存放路径】        */       public String getAttachPath() {            return saveAttachPath;        }           /**        * 【真正的保存附件到指定目录里】        */       private void saveFile(String fileName, InputStream in) throws Exception {            String osName = System.getProperty("os.name");            String storedir = getAttachPath();            String separator = "";            if (osName == null)                osName = "";            if (osName.toLowerCase().indexOf("win") != -1) {                separator = "\\";               if (storedir == null || storedir.equals(""))                   storedir = "c:\\tmp";           } else {               separator = "/";               storedir = "/tmp";           }           File storefile = new File(storedir + separator + fileName);           System.out.println("storefile's path: " + storefile.toString());           // for(int i=0;storefile.exists();i++){           // storefile = new File(storedir+separator+fileName+i);           // }           BufferedOutputStream bos = null;           BufferedInputStream bis = null;           try {               bos = new BufferedOutputStream(new FileOutputStream(storefile));               bis = new BufferedInputStream(in);               int c;               while ((c = bis.read()) != -1) {                   bos.write(c);                   bos.flush();               }           } catch (Exception exception) {               exception.printStackTrace();               throw new Exception("文件保存失败!");           } finally {               bos.close();               bis.close();           }       }         /**        * PraseMimeMessage类测试        */       public static void main(String args[]) throws Exception {           Properties props = System.getProperties();           props.put("mail.smtp.host", "smtp.163.com");           props.put("mail.smtp.auth", "true");           Session session = Session.getDefaultInstance(props, null);           URLName urln = new URLName("pop3", "pop3.163.com", 110, null,                   "xiangzhengyan", "pass");           Store store = session.getStore(urln);           store.connect();           Folder folder = store.getFolder("INBOX");           folder.open(Folder.READ_ONLY);           Message message[] = folder.getMessages();           System.out.println("Messages's length: " + message.length);           ReciveOneMail pmm = null;           for (int i = 0; i < message.length; i++) {               System.out.println("======================");               pmm = new ReciveOneMail((MimeMessage) message[i]);               System.out.println("Message " + i + " subject: " + pmm.getSubject());               System.out.println("Message " + i + " sentdate: "+ pmm.getSentDate());               System.out.println("Message " + i + " replysign: "+ pmm.getReplySign());               System.out.println("Message " + i + " hasRead: " + pmm.isNew());               System.out.println("Message " + i + "  containAttachment: "+ pmm.isContainAttach((Part) message[i]));               System.out.println("Message " + i + " form: " + pmm.getFrom());               System.out.println("Message " + i + " to: "+ pmm.getMailAddress("to"));               System.out.println("Message " + i + " cc: "+ pmm.getMailAddress("cc"));               System.out.println("Message " + i + " bcc: "+ pmm.getMailAddress("bcc"));               pmm.setDateFormat("yy年MM月dd日 HH:mm");               System.out.println("Message " + i + " sentdate: "+ pmm.getSentDate());               System.out.println("Message " + i + " Message-ID: "+ pmm.getMessageId());               // 获得邮件内容===============               pmm.getMailContent((Part) message[i]);               System.out.println("Message " + i + " bodycontent: \r\n"                       + pmm.getBodyText());               pmm.setAttachPath("c:\\");                pmm.saveAttachMent((Part) message[i]);            }        }    }