java Mail邮件接收工具类

public class ReciveMail { 
 private MimeMessage msg = null; 
  private String saveAttchPath = ""; 
  private StringBuffer bodytext = new StringBuffer(); 
  private String dateformate = "yy-MM-dd HH:mm"; 
  
  public ReciveMail(MimeMessage msg){ 
    this.msg = msg; 
    } 
  public void setMsg(MimeMessage msg) { 
    this.msg = msg; 
  } 
  
  /** 
   * 获取发送邮件者信息 
   * @return 
   * @throws MessagingException 
   */ 
  public String getFrom() throws MessagingException{ 
    InternetAddress[] address = (InternetAddress[]) msg.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"-->密送地址 
   * @param type 
   * @return 
   * @throws MessagingException 
   * @throws UnsupportedEncodingException 
   */ 
  public String getMailAddress(String type) throws MessagingException, UnsupportedEncodingException{ 
    String mailaddr = ""; 
    String addrType = type.toUpperCase(); 
    InternetAddress[] address = null; 
    
    if(addrType.equals("TO")||addrType.equals("CC")||addrType.equals("BCC")){ 
      if(addrType.equals("TO")){ 
        address = (InternetAddress[]) msg.getRecipients(Message.RecipientType.TO); 
      } 
      if(addrType.equals("CC")){ 
        address = (InternetAddress[]) msg.getRecipients(Message.RecipientType.CC); 
      } 
      if(addrType.equals("BCC")){ 
        address = (InternetAddress[]) msg.getRecipients(Message.RecipientType.BCC); 
      }    
      if(address != null){ 
        for(int i=0;i<address.length;i++){ 
          String mail = address[i].getAddress(); 
          if(mail == null){ 
            mail = ""; 
          }else{ 
            mail = MimeUtility.decodeText(mail); 
          } 
          String personal = address[i].getPersonal(); 
          if(personal == null){ 
            personal = ""; 
          }else{ 
            personal = MimeUtility.decodeText(personal); 
          } 
          String compositeto = personal +"<"+mail+">"; 
          mailaddr += ","+compositeto; 
        } 
        mailaddr = mailaddr.substring(1); 
      } 
    }else{ 
      throw new RuntimeException("Error email Type!"); 
    } 
    return mailaddr; 
  } 
  
  /** 
   * 获取邮件主题 
   * @return 
   * @throws UnsupportedEncodingException 
   * @throws MessagingException 
   */ 
  public String getSubject() throws UnsupportedEncodingException, MessagingException{ 
    String subject = ""; 
    subject = MimeUtility.decodeText(msg.getSubject()); 
    if(subject == null){ 
      subject = ""; 
    } 
    return subject; 
  } 
  
  /** 
   * 获取邮件发送日期 
   * @return 
   * @throws MessagingException 
   */ 
  public String getSendDate() throws MessagingException{ 
    Date sendDate = msg.getSentDate(); 
    SimpleDateFormat smd = new SimpleDateFormat(dateformate); 
    return smd.format(sendDate); 
  } 
  
  /** 
   * 获取邮件正文内容 
   * @return 
   */ 
  public String getBodyText(){ 
    return bodytext.toString(); 
  } 
  
  /** 
   * 解析邮件，将得到的邮件内容保存到一个stringBuffer对象中， 
   * 解析邮件 主要根据MimeType的不同执行不同的操作，一步一步的解析 
   * @param part 
   * @throws MessagingException 
   * @throws IOException 
   */ 
  public void getMailContent(Part part) throws MessagingException, IOException{ 
    
    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 count = multipart.getCount(); 
      for(int i=0;i<count;i++){ 
        getMailContent(multipart.getBodyPart(i)); 
      } 
    }else if(part.isMimeType("message/rfc822")){ 
      getMailContent((Part) part.getContent()); 
    } 
    
  } 
  
  /** 
   * 判断邮件是否需要回执，如需回执返回true，否则返回false 
   * @return 
   * @throws MessagingException 
   */ 
  public boolean getReplySign() throws MessagingException{ 
    boolean replySign = false; 
    String needreply[] = msg.getHeader("Disposition-Notification-TO"); 
    if(needreply != null){ 
      replySign = true; 
    } 
    return replySign; 
  } 
  
  /** 
   * 获取此邮件的message-id 
   * @return 
   * @throws MessagingException 
   */ 
  public String getMessageId() throws MessagingException{ 
    return msg.getMessageID(); 
  } 
  
  /** 
   * 判断此邮件是否已读，如果未读则返回false，已读返回true 
   * @return 
   * @throws MessagingException 
   */ 
  public boolean isNew() throws MessagingException{ 
    boolean isnew = false; 
    Flags flags = ((Message)msg).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; 
  } 
  
  /** 
   * 判断是是否包含附件 
   * @param part 
   * @return 
   * @throws MessagingException 
   * @throws IOException 
   */ 
  public boolean isContainAttch(Part part) throws MessagingException, IOException{ 
    boolean flag = false; 
    
    //String contentType = part.getContentType(); 
    if(part.isMimeType("multipart/*")){ 
      Multipart multipart = (Multipart) part.getContent(); 
      int count = multipart.getCount(); 
      for(int i=0;i<count;i++){ 
        BodyPart bodypart = multipart.getBodyPart(i); 
        String dispostion = bodypart.getDisposition(); 
        if((dispostion != null)&&(dispostion.equals(Part.ATTACHMENT)||dispostion.equals(Part.INLINE))){ 
          flag = true; 
        }else if(bodypart.isMimeType("multipart/*")){ 
          flag = isContainAttch(bodypart); 
        }else{ 
          String conType = bodypart.getContentType(); 
          if(conType.toLowerCase().indexOf("appliaction")!=-1){ 
            flag = true; 
          } 
          if(conType.toLowerCase().indexOf("name")!=-1){ 
            flag = true; 
          } 
        } 
      } 
    }else if(part.isMimeType("message/rfc822")){ 
      flag = isContainAttch((Part) part.getContent()); 
    } 
    
    return flag; 
  } 
  
  /** 
   * 保存附件 
   * @param part 
   * @throws MessagingException 
   * @throws IOException 
   */ 
  public void saveAttchMent(Part part) throws MessagingException, IOException{ 
    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 dispostion = mpart.getDisposition(); 
        if((dispostion != null)&&(dispostion.equals(Part.ATTACHMENT)||dispostion.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/*")){ 
          saveAttchMent(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")){ 
      saveAttchMent((Part) part.getContent()); 
    } 
  } 
  /** 
   * 获得保存附件的地址 
   * @return 
   */ 
  public String getSaveAttchPath() { 
    return saveAttchPath; 
  } 
  /** 
   * 设置保存附件地址 
   * @param saveAttchPath 
   */ 
  public void setSaveAttchPath(String saveAttchPath) { 
    this.saveAttchPath = saveAttchPath; 
  } 
  /** 
   * 设置日期格式 
   * @param dateformate 
   */ 
  public void setDateformate(String dateformate) { 
    this.dateformate = dateformate; 
  } 
  /** 
   * 保存文件内容 
   * @param filename 
   * @param inputStream 
   * @throws IOException 
   */ 
  private void saveFile(String filename, InputStream inputStream) throws IOException { 
    String osname = System.getProperty("os.name"); 
    String storedir = getSaveAttchPath(); 
    String sepatror = ""; 
    if(osname == null){ 
      osname = ""; 
    } 
    
    if(osname.toLowerCase().indexOf("win")!=-1){ 
      sepatror = "//"; 
      if(storedir==null||"".equals(storedir)){ 
        storedir = "d://temp"; 
      } 
    }else{ 
      sepatror = "/"; 
      storedir = "/temp"; 
    } 
    
    File storefile = new File(storedir+sepatror+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(inputStream); 
      int c; 
      while((c= bis.read())!=-1){ 
        bos.write(c); 
        bos.flush(); 
      } 
    } catch (FileNotFoundException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
    } catch (IOException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
    }finally{ 
      bos.close(); 
      bis.close(); 
    } 
    
  } 
  
  public void recive(Part part,int i) throws MessagingException, IOException{ 
    System.out.println("------------------START-----------------------"); 
    System.out.println("Message"+i+" subject:" + getSubject()); 
    System.out.println("Message"+i+" from:" + getFrom()); 
    System.out.println("Message"+i+" isNew:" + isNew()); 
    boolean flag = isContainAttch(part); 
    System.out.println("Message"+i+" isContainAttch:" +flag); 
    System.out.println("Message"+i+" replySign:" + getReplySign()); 
    getMailContent(part); 
    System.out.println("Message"+i+" content:" + getBodyText()); 
    setSaveAttchPath("c://temp//"+i); 
    if(flag){ 
      saveAttchMent(part); 
    } 
    System.out.println("------------------END-----------------------"); 
  }

}

public static void main(String[] args) throws Exception { 
    // 连接pop3服务器的主机名、协议、用户名、密码 
    String pop3Server = "pop.163.com"; 
    String protocol = "pop3"; 
    String user = "username"; 
    String pwd = "password"; 
     
    // 创建一个有具体连接信息的Properties对象 
    Properties props = new Properties(); 
    props.setProperty("mail.store.protocol", protocol); 
    props.setProperty("mail.pop3.host", pop3Server); 
     
    // 使用Properties对象获得Session对象 
    Session session = Session.getInstance(props); 
    session.setDebug(true); 
     
    // 利用Session对象获得Store对象，并连接pop3服务器 
    Store store = session.getStore(); 
    store.connect(pop3Server, user, pwd); 
     
    // 获得邮箱内的邮件夹Folder对象，以"只读"打开 
    Folder folder = store.getFolder("inbox"); 
    folder.open(Folder.READ_ONLY); 
     
    // 获得邮件夹Folder内的所有邮件Message对象 
    Message [] messages = folder.getMessages();  
    ReciveMail rm = null; 
    for(int i=0;i< messages.size() ;i++){ 
      rm = new ReciveMail((MimeMessage) messages[i]); 
      rm.recive(messages[i],i);; 
    } 
     folder.close(false); 
    store.close(); 
}