用javamail接收邮件

    技术2022-05-12  29

    package test;

    /***************************************************** *  * @author wuzhenzhong *  * @since May 7, 2009  * *****************************************************/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"; //默认的日前显示格式        /**     * 初使化reciveOneMail时初使化MimeMessage对象     */    public ReciveOneMail(MimeMessage mimeMessage) {            this.mimeMessage = 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);//得到mail                        }                        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 e)         {         e.printStackTrace();        }            return subject;        }           /**        * 获得邮件发送日期        */       public String getSentDate() throws Exception {            Date sentdate = mimeMessage.getSentDate();            SimpleDateFormat format = new SimpleDateFormat(dateformat);           if(sentdate!=null)        {         return format.format(sentdate);            }        else        {         return null;        }    }           /**        * 获得邮件正文内容        */       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("已查看的邮件");                    break;                }            }            return isnew;        }           /**        * 判断此邮件是否包含附件        */       public boolean isContainAttach(Part part) throws Exception {            boolean attachflag = false;            @SuppressWarnings("unused")  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 = "d://workweb";           } else {               separator = "/";               storedir = "/workweb";           }           File storefile = new File(storedir + separator + fileName);           System.out.println("storefile's path: " + storefile.toString());           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.139.com");           props.put("mail.smtp.auth", "true");           Session session = Session.getDefaultInstance(props, null);           URLName urln = new URLName("pop3", "pop3.139.com", 110, null,                   "fengl", "fengy");           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 + " to: "+ pmm.getMailAddress("to"));               pmm.setDateFormat("yy年MM月dd日 HH:mm");               System.out.println("Message " + i + " senddate: "+ pmm.getSentDate());                // 获得邮件内容              pmm.getMailContent((Part) message[i]);               System.out.println("Message " + i + " bodycontent: /r/n"                       + pmm.getBodyText());               pmm.setAttachPath("c://");                pmm.saveAttachMent((Part) message[i]);                System.out.println("======================");        }        }    }  

     


    最新回复(0)