JAVAMAil收取邮件为什么不能判断是否是新邮件
代码如下。。。我收取到的邮件判断的都是false,没有一个true的。这代码收取邮件会出现乱码。。。不知道怎么解决。。。希望能帮帮忙。。。
package com;import java.io.*; import java.text.*; import java.util.*; import javax.mail.*; import javax.mail.internet.*; import javax.servlet.http.HttpServletRequest;import com.gdschina.ccu.util.UIDGenerator; /** * 有一封邮件就需要建立一个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.getAddress(); if (from == null) from = ""; String personal = address.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.getAddress(); if (email == null) email = ""; else { email = MimeUtility.decodeText(email); } String personal = address.getPersonal(); if (personal == null) personal = ""; else { personal = MimeUtility.decodeText(personal); } String compositeto = personal + "<" + email + ">"; mailaddr += "," + compositeto; } mailaddr = mailaddr.substring(0); } } else { throw new Exception("Error emailaddr type!"); } return mailaddr; } /** * 获得有中文字的参数, 转成 UTF-8 encoding, default 为 "" . ** @param request * @param name * 参数名. * @return */public static String setDecodeText( String name) {String tmp = "";try {tmp = new String( name.getBytes("ISO-8859-1"), "UTF-8");} catch (UnsupportedEncodingException e) {}return tmp;} /** * 获得邮件主题 */ public String getSubject() throws MessagingException { String subject = ""; try { subject = mimeMessage.getSubject(); String header = ((MimeMessage)mimeMessage).getHeader("SUBJECT"); if ((header.toLowerCase().indexOf("=?"))>0) { subject = new String((subject.getBytes("iso-8859-1")),"gb2312"); } 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); } /** * 获取收件时间 * @return * @throws Exception */ public String getReceivedDate() throws Exception{ Date receivedDate = mimeMessage.getReceivedDate(); SimpleDateFormat format = new SimpleDateFormat(dateformat); return format.format(receivedDate); } /** * 获得邮件正文内容 */ 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 == 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("gbk") != -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:\\tmp"; } else { separator = "/"; storedir = "/tmp"; }// fileName = UIDGenerator.getUID(); File storefile = new File(MimeUtility.decodeText(storedir) + MimeUtility.decodeText(separator) + MimeUtility.decodeText(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", "pop.163.com", 110, null, "[用户名]", "[密码]"); 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; Date sendDate = null; Date today = null; Date date = new Date(); Date day = new Date(); SimpleDateFormat format = new SimpleDateFormat("yyyy/MM/dd"); try{ for (int i = 0; i < message.length; i++) { pmm = new ReciveOneMail((MimeMessage) message); pmm.setDateFormat("yyyy/MM/dd"); String send_date = pmm.getSentDate(); sendDate = format.parse(send_date); today = format.parse(format.format(day)); today.compareTo(sendDate); today.after(sendDate); System.out.println("Message " + i + " 是新邮件: " + pmm.isNew()); //是否是新邮件 System.out.println("第"+i+"封"); System.out.println("======================"); System.out.println("Message " + i + " 主题: " + setDecodeText(pmm.getSubject())); //获取主题 System.out.println("Message " + i + " 发送日期: "+ pmm.getSentDate());//获取邮件发送日期 System.out.println("Message " + i + " 是否需要回复: "+ pmm.getReplySign());// System.out.println("Message " + i + " 是否新邮件: " + pmm.isNew()); //是否是新邮件 System.out.println("Message " + i + "是否包含附件: "+ pmm.isContainAttach((Part) message)); //是否包含附件 System.out.println("Message " + i + " 发件人和地: " + pmm.getFrom()); //获取发件人和地址 System.out.println("Message " + i + " 收件人: "+ pmm.getMailAddress("to")); //收件人 System.out.println("Message " + i + " 抄送人: "+ pmm.getMailAddress("cc")); //抄送人 System.out.println("Message " + i + " 密抄送人: "+ pmm.getMailAddress("bcc")); //密抄送人// pmm.setDateFormat("yy年MM月dd日 HH:mm"); System.out.println("Message " + i + " 收件时间 "+ pmm.getSentDate()); System.out.println("Message " + i + " 邮件的ID: "+ pmm.getMessageId()); //获取邮件的ID // 获得邮件内容=============== // pmm.getMailContent((Part) message); System.out.println("Message " + i + " 邮件内容: \r\n" + pmm.getBodyText()); System.out.println("附件的路径"+pmm.getAttachPath()); pmm.setAttachPath("D:\\tmp\\"); pmm.saveAttachMent((Part) message); today.after(sendDate); folder.close(true); store.close(); } }catch(Exception e){ e.printStackTrace(); } } }
页:
[1]