`
ShellyLi
  • 浏览: 114600 次
  • 性别: Icon_minigender_2
  • 来自: 山东
社区版块
存档分类
最新评论

javamail接收邮件的bean,可以正确的解析中文(转)(三)

阅读更多
//接上一文章

/**
      * 从folder中提取所有的messages
      *
      * @throws MessagingException
      */
     public void getAllMessages() throws MessagingException {
         //从邮件文件夹获取邮件信息
         Message[] messages = folder.getMessages();
         setMessages(messages);
         setRecordFailure();//初始化出错数组
         //         setMessageCount();
     }

     /**
      * 获得messageNums数组指定的message
      *
      * @param messageNums
      * @throws MessagingException
      */
     public void getMessages(int[] messageNums) throws MessagingException {
         Message[] messages = folder.getMessages(messageNums);
         setMessages(messages);
         setRecordFailure();//初始化出错数组
         //         setMessageCount();
     }

     /**
      * 获得start和end之间的message
      *
      * @param start
      * @param end
      * @throws MessagingException
      */
     public void getMessages(int start, int end) throws MessagingException {
         Message[] messages = folder.getMessages(start, end);
         setMessages(messages);
         setRecordFailure();//初始化出错数组
         //         setMessageCount();
     }

     /**
      * 关闭连接
      */
     public void closeConnection() {
         try {
             messages = null;
             message = null;
             if (folder.isOpen())
                 folder.close(true);
             store.close();
             System.out.println("close");
         } catch (Exception e) {
             System.out.println("关闭和邮件服务器之间连接时出错!");
             e.printStackTrace();
         }
     }

     /**
      * 获得当前邮件的基本方法 Pop3Bean内部应该调用这个方法 以便在调用函数中加入重试机制
      *
      * @throws MessagingException
      * @throws MessagingException
      * 
      */
     public void getMail() throws Throwable {//抛出异常,用以重掷
         try {
             saveMessageAs(message);
             parseMessage(message);
         } catch (IOException e) {
             // TODO Auto-generated catch block
             System.err.println("保存邮件出错,检查保存路径");
             throw new IOException("保存邮件出错,检查保存路径");
         } catch (MessagingException e) {
             // TODO Auto-generated catch block
             System.err.println("邮件转换出错");
             throw new MessagingException("邮件转换出错");
         } catch (Exception e) {
             System.err.println("未知错误");
             otherError = true;
             e.printStackTrace();
             throw new Exception("未知错误");
         }
     }

     /**
      * 获得指定的邮件
      *
      * @param index
      */
     public void getMail(int index) {
         mailDownErrorCounter = 0; //邮件下载出错计数器置零
         try {//获取邮件下载之前的错误
             setMessage(messages[index]);//设置当前message
             System.out.println("正在获取第" + index + "封邮件. . .");
             getMail();//获取当前message
             System.out.println("成功获取第" + index + "封邮件");
         } catch (Throwable e) {//获得重掷异常
             recordFailure[index] = true;
             mailDownErrorCounter++;
             System.err.println("下载第" + index + "封邮件时出错");
             retry();
         }
     }

     /**
      * 获取messages中的所有邮件
      */
     public void getAllMail() {
         int mailArrayLength; //将要下载的邮件的数量。若是重试时,则为还未下载的邮件数量

         mailArrayLength = getMessageCount();

         System.out.println("一共有邮件" + mailArrayLength + "封");

         mailDownErrorCounter = 0; //邮件下载出错计数器置零
         mailCounter = 0;
         for (int index = 0; index < mailArrayLength; index++) {
             try {
                 setMessage(messages[index]);//设置当前message
                 System.out.println("正在获取第" + index + "封邮件. . .");
                 getMail();//获取当前message
                 System.out.println("成功获取第" + index + "封邮件");
                 mailCounter++;
             } catch (Throwable e) {
                 otherError = false;
                 recordFailure[index] = true;
                 mailDownErrorCounter++;
                 System.err.println("下载第" + index + "封邮件时出错");
             }
         }
         System.out.println("成功下载" + mailCounter + "封邮件");
         mailCounter = 0;
         if (mailDownErrorCounter != 0)
             retry();
     }

     /**
      * 保存邮件源文件
      */

     public void saveMessageAs(Message message) {
         String oriFileName;
         String fileExtend;

         try {
             oriFileName = getInfoBetweenBrackets(getMessageId(message)
                     .toString());
             //设置文件后缀名。若是附件则设法取得其文件后缀名作为将要保存文件的后缀名,若是正文部分则用.htm做后缀名
             String emlName = oriFileName;
             String fileNameWidthExtension = getEmlPath() + oriFileName
                     + getExtension();
             File storeFile = new File(fileNameWidthExtension);
             for (int i = 0; storeFile.exists(); i++) {
                 emlName = oriFileName + i;
                 fileNameWidthExtension = getEmlPath() + emlName
                         + getExtension();
                 storeFile = new File(fileNameWidthExtension);
             }
             setEmlName(emlName);
             System.out.println("storefile's path: " + fileNameWidthExtension);
             ByteArrayOutputStream baos = new ByteArrayOutputStream();
             message.writeTo(baos);
             StringReader in = new StringReader(baos.toString());
             saveFile(fileNameWidthExtension, in);
         } catch (MessagingException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         } catch (Exception e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         }
     }

     /*
      * 解析邮件
      */
     public void parseMessage(Message message) throws IOException,
             MessagingException {
         Object content = message.getContent();
         if (content instanceof Multipart) {
             handleMultipart((Multipart) content);
         } else {
             handlePart(message);
         }
     }

   /*
      * 解析Multipart
      */
     public void handleMultipart(Multipart multipart) throws MessagingException,
             IOException {
         for (int i = 0, n = multipart.getCount(); i < n; i++) {
             handlePart(multipart.getBodyPart(i));
         }
     }

     /*
      * 解析指定part,从中提取文件
      */
     public void handlePart(Part part) throws MessagingException, IOException {
         String disposition = part.getDisposition(); // Find attachment
         String contentType = part.getContentType();
         String str;
         InputStreamReader sbis = new InputStreamReader(part.getInputStream());
         if (disposition == null) { // When just body
             System.out.println("Null: " + contentType);
             // Check if plain
             if ((contentType.length() >= 9)
                     && (contentType.toLowerCase().substring(0, 9)
                             .equals("text/plai"))) {

                 System.out.println(getAttachPath() + getEmlName() + ".txt");
                 saveFile(getAttachPath() + getEmlName() + ".txt", sbis);
             } else if ((contentType.length() >= // Check if html
                     && (contentType.toLowerCase().substring(0,
                             .equals("text/htm"))) {
                 saveFile(getAttachPath() + getEmlName() + ".html", sbis);
             } else if ((contentType.length() >= 9) // Check if html
                     && (contentType.toLowerCase().substring(0, 9)
                             .equals("image/gif"))) {
                 saveFile(getAttachPath() + getEmlName() + ".gif", sbis);
             } else if ((contentType.length() >= 10)
                     && contentType.toLowerCase().substring(0, 10).equals(
                             "multipart/")) { // Check if multipart
                 System.out.println("multipart body: " + contentType);
                 Multipart mp = (Multipart) (part.getContent());
                 handleMultipart(mp);
             } else { // Unknown type
                 System.out.println("Other body: " + contentType);
                 saveFile(getAttachPath() + getEmlName() + ".txt", sbis);
             }
         } else if (disposition.equalsIgnoreCase(Part.ATTACHMENT)) {
             System.out.println("Attachment: " + part.getFileName() + " : "
                     + contentType);
             //outToFile.println("Attachment: " + part.getFileName() + " : "
             //         + contentType);
             saveFile(getAttachPath() + part.getFileName(), sbis);
         } else if (disposition.equalsIgnoreCase(Part.INLINE)) {
             System.out.println("Inline: " + part.getFileName() + " : "
                     + contentType);
             //outToFile.println("Inline: " + part.getFileName() + " : "
             //         + contentType);
             saveFile(getAttachPath() + part.getFileName(), sbis);
         } else { // Should never happen
             System.out.println("Other: " + disposition);
             //             outToFile.println("Other: " + disposition);
         }
     }

     public void saveFile(String fileName, Reader input) throws IOException {
         if (fileName == null) {
             fileName = File.createTempFile(getAttachPath() + "xx", ".out")
                     .getName();
         }
         // Do no overwrite existing file
         File file = new File(fileName);
         int lastDot = fileName.lastIndexOf(".");
         String extension = fileName.substring(lastDot);
         String fullFileName = fileName;
         fileName = fileName.substring(0, lastDot);
         for (int i = 0; file.exists(); i++) {
             file = new File(fileName + i + extension);
         }
         FileWriter fos = new FileWriter(file);
         BufferedWriter bos = new BufferedWriter(fos);
         BufferedReader bis = new BufferedReader(input);
         int aByte;
         while ((aByte = bis.read()) != -1) {
             bos.write(aByte);
         }
         bos.flush();
         bos.close();
         bis.close();
     }

     public void readEmlFile(String fileName) throws MessagingException {
         try {
             //TODO readEmlFile
             InputStream fis = new FileInputStream(fileName);
             Object emlObj = (Object)fis;
             Session mailSession = Session.getDefaultInstance(System.getProperties(), null);
             MimeMessage msg = new MimeMessage(mailSession,fis);
             message = msg;
           
         } catch (FileNotFoundException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         }
     }

     private String getInfoBetweenBrackets(String str) throws Exception {
         int i, j; //用于标识字符串中的"<"和">"的位置
         if (str == null) {
             str = "error";
             return str;
         }
         i = str.lastIndexOf("<");
         j = str.lastIndexOf(">");
         if (i != -1 && j != -1)
             str = str.substring(i + 1, j);
         return str;
     } //当有邮件无法下载时进行重试
     private void retry() {
         mailCounter = 0;
         while (retryTimeCounter < totalRetryTimes && mailDownErrorCounter != 0) {
             if (!store.isConnected() || !folder.isOpen()) {
                 System.err.println("与服务器连接断开,请重新连接");
                 closeConnection();
                 return;
             }

             System.out.println("第" + (retryTimeCounter + 1) + "次重试");

             mailDownErrorCounter = 0; //邮件下载出错计数器置零

             for (int index = 0; index < getMessageCount(); index++) {
                 if (recordFailure[index]) {
                     try {
                         setMessage(messages[index]);//设置当前message
                         System.out.println("正在获取第" + index + "封邮件. . .");
                         getMail();//获取当前message
                         System.out.println("成功获取第" + index + "封邮件");
                         mailCounter++;
                         recordFailure[index] = false;
                     } catch (Throwable e) {
                         otherError = false;
                         recordFailure[index] = true;
                         mailDownErrorCounter++;
                         System.err.println("重新下载第" + index + "封邮件时出错");
                     }
                 }
             }
             retryTimeCounter++;
         }
         System.out.println("成功下载" + mailCounter + "封邮件");
         mailCounter = 0; //将邮件计数置零
         mailDownErrorCounter = 0;//下载错误数量归零
     }
}

  
分享到:
评论

相关推荐

    Java发邮件:通过Bean封装.rar

    一旦邮件Bean填充完毕,就可以使用JavaMail API的`Transport`类发送邮件。首先,需要创建一个`Session`对象,配置SMTP服务器的相关信息,如用户名、密码、端口等。然后,利用`Session`创建`MimeMessage`实例,设置...

    javamail.jar

    JavaMail是Java编程环境中用于处理电子邮件的一套API,它提供了创建、发送和接收邮件的功能。在Java应用程序中,我们通常会用到两个关键的库文件:`activation.jar`和`mail.jar`。这两个JAR文件在Spring框架集成邮件...

    java 发送邮件 spring发送邮件Mail

    `java邮件系统`和`java邮件收发`则涉及到更广泛的邮件处理概念,包括不仅限于发送,还可能包括接收和解析邮件。 综上所述,Java结合Spring框架发送邮件是一个实用且功能强大的解决方案,通过合理的配置和编程,可以...

    java中email邮件发送接受和处理excel文件(xls)实例

    综上所述,Java通过JavaMail API和Apache POI库可以实现电子邮件的发送、接收以及Excel文件的处理。在Spring框架中,这些功能可以更加方便地集成和管理,提高开发效率。通过编写相应的逻辑,你可以创建一个自动化...

    Java邮件开发源代码.rar

    通过研究和理解这个Java邮件开发源代码,开发者不仅可以学习到如何使用JavaMail API发送和接收邮件,还能掌握SSM框架的实践应用,这对于进行企业级的课程设计或毕业设计项目非常有帮助。同时,这也是提升Java Web...

    java-emailutil-csvutil.docx

    JavaMail 是一个用于发送和接收电子邮件的开源库,在Java编程中广泛使用。在这个场景中,我们看到一个简单的Java应用,它结合了JavaMail和CSV文件处理来实现批量发送电子邮件的功能。下面将详细解释相关的知识点: ...

    java邮件开发源码jar包笔记

    6. **邮件地址处理**:JavaMail API中的`InternetAddress`类用于处理电子邮件地址,包括解析、验证和格式化。 7. **SSL/TLS加密**:为了保证邮件传输的安全性,通常会使用SSL或TLS协议。JavaMail API支持这些安全...

    java发送邮件jar包

    它提供了与邮件服务器交互的接口,包括创建、发送和接收邮件。此库支持SMTP、POP3、IMAP等协议,并且可以处理MIME格式的邮件,包括附件、HTML内容等。 最后,`spring-context-support-5.0.1.RELEASE.jar`是Spring上...

    JAVA编程百例(照着例子更容易!)

    实例48 使用JAVAMAIL接收邮件 实例49 获取URL文本 实例5 哈希表和枚举器 实例50 一个简单的WEB服务器 实例51 数据报通讯:聊天吧 实例52 使用ODBC连接数据库 实例53 加载JDBC驱动 实例54 使用语句预处理 实例55 可...

    运用JSPservletJavaBean 技术完成的电子邮件

    **JSP、Servlet和JavaBean是Java Web开发中的三大核心技术,它们在构建Web应用程序,特别是像电子邮件这样的交互式系统中发挥着关键作用。** **JSP(JavaServer Pages)** 是一种动态网页技术,允许开发者将Java...

    JBoss+Ejb

    2. **mail.jar**:JavaMail API的实现,允许应用程序发送和接收电子邮件,可能在EJB中用于发送通知或确认信息。 3. **activation.jar**:JavaBeans Activation Framework的实现,是JavaMail的依赖,提供了处理MIME...

    struts聊天室 邮件系统 后台管理的struts版本

    “邮件系统”可能涉及到SMTP协议,用于发送邮件,以及POP3/IMAP协议,用于接收邮件。开发者需要熟悉JavaMail API来实现这些功能,同时,还需要处理用户认证、邮件存储和检索等复杂问题。 “后台管理”部分通常包括...

    j2eeAPI 中文版

    有三种类型的EJB:会话bean(Session Beans)处理客户端请求,实体bean(Entity Beans)代表持久化的业务对象,消息驱动bean(Message-Driven Beans)用于处理消息队列。 5. **Java Messaging Service (JMS)**:JMS...

    J2EE中文版指南

    8. **JavaMail API**:JavaMail API提供了在Java应用程序中发送和接收电子邮件的能力。 9. **Java API for XML Processing (JAXP)**:JAXP允许Java程序处理XML数据,包括解析、转换和样式表处理。 10. **Java API ...

    j2ee api 免费下载

    8. **JavaMail API**:JavaMail API允许开发者在Java应用中发送和接收电子邮件。 9. **Java API for XML Processing (JAXP)**:JAXP用于处理XML文档,包括解析、验证和转换XML数据。 10. **Java API for XML Web ...

    javaweb项目中常用的jar包详解.pdf

    使用 JavaMail,可以在 Java 应用程序中实现电子邮件的发送和接收。 2. Antlr-2.7.6.jar:这是一个 ant 编译的包,在工程中不需要添加,可以删除。ANTLR 是一个工具,用于生成解析器、词法分析器和语法分析器。它...

    j2ee5.0API(包括中文版)

    7. **JavaMail API**:用于发送和接收电子邮件,常用于实现企业级的通知系统。 8. **Java API for XML Processing (JAXP)** 和 **Java API for XML Binding (JAXB)**:这两个API支持XML的解析和转换,以及XML与Java...

    J2EE 的 13 种核心技术

    JavaMail是J2EE中用于发送和接收电子邮件的API。它支持多种邮件协议,包括SMTP、POP3和IMAP,使得J2EE应用程序可以轻松地集成电子邮件功能。 #### JAF:应用程序框架 Java应用程序框架(JAF)是J2EE中用于构建桌面...

    j2ee api

    EJB是J2EE中的核心组件,分为三种类型:会话Bean(Session Beans)、实体Bean(Entity Beans)和消息驱动Bean(Message-Driven Beans)。会话Bean处理客户端请求,实体Bean代表持久化数据,而消息驱动Bean则用于处理...

    Java 高 级 编 程

    通过JavaMail,开发者可以轻松实现SMTP(简单邮件传输协议)、POP3(邮局协议)和IMAP(因特网消息访问协议)等功能,创建复杂的邮件系统,如自动回复、邮件列表和邮件过滤器。 5. **Web服务编程**:Web服务允许...

Global site tag (gtag.js) - Google Analytics