POP3協議/IMAP協議解析郵件(解析最新郵件實現方式)
阿新 • • 發佈：2021-01-08
技術標籤：技術分享
POP3協議解析郵件:
package com.bxtdata.ips.util; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import javax.mail.*; import javax.mail.internet.InternetAddress; import javax.mail.internet.MimeMessage; import javax.mail.internet.MimeMultipart; import javax.mail.internet.MimeUtility; import java.io.*; import java.text.SimpleDateFormat; import java.util.Date; import java.util.Properties; /** * 使用POP3協議解析郵件幫助類 * @author pengjian * @date 2020-12-15 14:10 */ @Slf4j public class POP3ParsingEmailUtil { public static void main(String[] args) throws Exception{ resceive("你的郵箱", "密碼(如果是qq郵箱,則填對應授權密碼,如果是企業郵箱,則是郵箱密碼,企業郵箱預設授權)"); } /** * 獲取郵箱資訊 * * @param emailAdress 需要解析的郵箱地址 * @param password 郵箱的授權密碼 * @throws Exception */ public static void resceive(String emailAdress, String password) throws Exception { String port = "110"; // 埠號 String servicePath = "pop.qq.com"; // 伺服器地址(此處對應qq郵箱,郵箱對應埠號和路徑看下方對應圖) // 準備連線伺服器的會話資訊 Properties props = new Properties(); props.setProperty("mail.store.protocol", "pop3"); // 使用pop3協議 props.setProperty("mail.pop3.port", port); // 埠 props.setProperty("mail.pop3.host", servicePath); // pop3伺服器 // 建立Session例項物件 Session session = Session.getInstance(props); Store store = session.getStore("pop3"); store.connect(emailAdress, password); //第三方登入授權密碼而並非普通的登入密碼 // 獲得收件箱 Folder folder = store.getFolder("INBOX"); /* Folder.READ_ONLY：只讀許可權 * Folder.READ_WRITE：可讀可寫（可以修改郵件的狀態） */ folder.open(Folder.READ_WRITE); //開啟收件箱,讀寫 // // 由於POP3協議無法獲知郵件的狀態,所以getUnreadMessageCount得到的是收件箱的郵件總數 // System.out.println("未讀郵件數: " + folder.getUnreadMessageCount()); // // // 由於POP3協議無法獲知郵件的狀態,所以下面得到的結果始終都是為0 // System.out.println("刪除郵件數: " + folder.getDeletedMessageCount()); // System.out.println("新郵件: " + folder.getNewMessageCount()); // 獲得收件箱中的郵件總數 log.warn("郵件總數: {}", folder.getMessageCount()); // 得到收件箱中的所有郵件,並解析 Message[] messages = folder.getMessages(); //解析郵件 parseMessage(messages); //得到收件箱中的所有郵件並且刪除郵件 // deleteMessage(messages); //釋放資源 folder.close(true); store.close(); } /** * 解析郵件 * * @param messages 要解析的郵件列表 */ public static void parseMessage(Message... messages) throws MessagingException, IOException { if (messages == null || messages.length < 1) throw new MessagingException("未找到要解析的郵件!"); // 解析所有郵件 for (int i = 0, count = messages.length; i < count; i++) { MimeMessage msg = (MimeMessage) messages[i]; log.info("------------------解析第" + msg.getMessageNumber() + "封郵件-------------------- "); log.warn("主題: {}", getSubject(msg)); log.warn("發件人: {}", getFrom(msg)); log.warn("收件人：{}", getReceiveAddress(msg, null)); log.warn("傳送時間：{}", getSentDate(msg, null)); boolean isContainerAttachment = isContainAttachment(msg); log.warn("是否包含附件：{}", isContainerAttachment); if (isContainerAttachment) { saveAttachment(msg, "D:\\TestEmailPlace\\" + msg.getSubject() + "_" + i + "_"); //儲存附件 } StringBuffer content = new StringBuffer(30); //解析郵件正文 getMailTextContent(msg, content); log.warn("郵件正文：{}", content); log.info("------------------第" + msg.getMessageNumber() + "封郵件解析結束-------------------- "); } } /** * 刪除郵件 * * @param messages 要刪除郵件列表 */ public static void deleteMessage(Message... messages) throws MessagingException, IOException { if (messages == null || messages.length < 1) throw new MessagingException("未找到要解析的郵件!"); // 解析所有郵件 for (int i = 0, count = messages.length; i < count; i++) { /** * 郵件刪除 */ Message message = messages[i]; String subject = message.getSubject(); // set the DELETE flag to true message.setFlag(Flags.Flag.DELETED, true); System.out.println("Marked DELETE for message: " + subject); } } /** * 獲得郵件主題 * * @param msg 郵件內容 * @return 解碼後的郵件主題 */ public static String getSubject(MimeMessage msg) throws UnsupportedEncodingException, MessagingException { return MimeUtility.decodeText(msg.getSubject()); } /** * 獲得郵件發件人 * * @param msg 郵件內容 * @return 姓名 <Email地址> * @throws MessagingException * @throws UnsupportedEncodingException */ public static String getFrom(MimeMessage msg) throws MessagingException, UnsupportedEncodingException { String from = ""; Address[] froms = msg.getFrom(); if (froms.length < 1) throw new MessagingException("沒有發件人!"); InternetAddress address = (InternetAddress) froms[0]; String person = address.getPersonal(); if (person != null) { person = MimeUtility.decodeText(person) + " "; } else { person = ""; } from = person + "<" + address.getAddress() + ">"; return from; } /** * 根據收件人型別，獲取郵件收件人、抄送和密送地址。如果收件人型別為空，則獲得所有的收件人 * <p>Message.RecipientType.TO 收件人</p> * <p>Message.RecipientType.CC 抄送</p> * <p>Message.RecipientType.BCC 密送</p> * * @param msg 郵件內容 * @param type 收件人型別 * @return 收件人1 <郵件地址1>, 收件人2 <郵件地址2>, ... * @throws MessagingException */ public static String getReceiveAddress(MimeMessage msg, Message.RecipientType type) throws MessagingException { StringBuffer receiveAddress = new StringBuffer(); Address[] addresss = null; if (type == null) { addresss = msg.getAllRecipients(); } else { addresss = msg.getRecipients(type); } if (addresss == null || addresss.length < 1) throw new MessagingException("沒有收件人!"); for (Address address : addresss) { InternetAddress internetAddress = (InternetAddress) address; receiveAddress.append(internetAddress.toUnicodeString()).append(","); } receiveAddress.deleteCharAt(receiveAddress.length() - 1); //刪除最後一個逗號 return receiveAddress.toString(); } /** * 獲得郵件傳送時間 * * @param msg 郵件內容 * @return yyyy年mm月dd日 星期X HH:mm * @throws MessagingException */ public static String getSentDate(MimeMessage msg, String pattern) throws MessagingException { Date receivedDate = msg.getSentDate(); if (receivedDate == null) return ""; if (pattern == null || "".equals(pattern)) pattern = "yyyy年MM月dd日 E HH:mm "; return new SimpleDateFormat(pattern).format(receivedDate); } /** * 判斷郵件中是否包含附件 * * @param part 郵件內容 * @return 郵件中存在附件返回true，不存在返回false * @throws MessagingException * @throws IOException */ public static boolean isContainAttachment(Part part) throws MessagingException, IOException { boolean flag = false; if (part.isMimeType("multipart/*")) { MimeMultipart multipart = (MimeMultipart) part.getContent(); int partCount = multipart.getCount(); for (int i = 0; i < partCount; i++) { BodyPart bodyPart = multipart.getBodyPart(i); String disp = bodyPart.getDisposition(); if (disp != null && (disp.equalsIgnoreCase(Part.ATTACHMENT) || disp.equalsIgnoreCase(Part.INLINE))) { flag = true; } else if (bodyPart.isMimeType("multipart/*")) { flag = isContainAttachment(bodyPart); } else { String contentType = bodyPart.getContentType(); if (contentType.indexOf("application") != -1) { flag = true; } if (contentType.indexOf("name") != -1) { flag = true; } } if (flag) break; } } else if (part.isMimeType("message/rfc822")) { flag = isContainAttachment((Part) part.getContent()); } return flag; } /** * 判斷郵件是否已讀 * * @param msg 郵件內容 * @return 如果郵件已讀返回true, 否則返回false * @throws MessagingException */ public static boolean isSeen(MimeMessage msg) throws MessagingException { return msg.getFlags().contains(Flags.Flag.SEEN); } /** * 判斷郵件是否需要閱讀回執 * * @param msg 郵件內容 * @return 需要回執返回true, 否則返回false * @throws MessagingException */ public static boolean isReplySign(MimeMessage msg) throws MessagingException { boolean replySign = false; String[] headers = msg.getHeader("Disposition-Notification-To"); if (headers != null) replySign = true; return replySign; } /** * 獲得郵件的優先順序 * * @param msg 郵件內容 * @return 1(High):緊急 3:普通(Normal) 5:低(Low) * @throws MessagingException */ public static String getPriority(MimeMessage msg) throws MessagingException { String priority = "普通"; String[] headers = msg.getHeader("X-Priority"); if (headers != null) { String headerPriority = headers[0]; if (headerPriority.indexOf("1") != -1 || headerPriority.indexOf("High") != -1) priority = "緊急"; else if (headerPriority.indexOf("5") != -1 || headerPriority.indexOf("Low") != -1) priority = "低"; else priority = "普通"; } return priority; } /** * 獲得郵件文字內容 * * @param part 郵件體 * @param content 儲存郵件文字內容的字串 * @throws MessagingException * @throws IOException */ public static void getMailTextContent(Part part, StringBuffer content) throws MessagingException, IOException { //如果是文字型別的附件，通過getContent方法可以取到文字內容，但這不是我們需要的結果，所以在這裡要做判斷 boolean isContainTextAttach = part.getContentType().indexOf("name") > 0; if (part.isMimeType("text/*") && !isContainTextAttach) { content.append(part.getContent().toString()); } else if (part.isMimeType("message/rfc822")) { getMailTextContent((Part) part.getContent(), content); } else if (part.isMimeType("multipart/*")) { Multipart multipart = (Multipart) part.getContent(); int partCount = multipart.getCount(); for (int i = 0; i < partCount; i++) { BodyPart bodyPart = multipart.getBodyPart(i); getMailTextContent(bodyPart, content); } } } /** * 儲存附件 * * @param part 郵件中多個組合體中的其中一個組合體 * @param destDir 附件儲存目錄 * @throws UnsupportedEncodingException * @throws MessagingException * @throws FileNotFoundException * @throws IOException */ public static void saveAttachment(Part part, String destDir) throws MessagingException, IOException { if (part.isMimeType("multipart/*")) { Multipart multipart = (Multipart) part.getContent(); //複雜體郵件 //複雜體郵件包含多個郵件體 int partCount = multipart.getCount(); for (int i = 0; i < partCount; i++) { //獲得複雜體郵件中其中一個郵件體 BodyPart bodyPart = multipart.getBodyPart(i); //某一個郵件體也有可能是由多個郵件體組成的複雜體 String disp = bodyPart.getDisposition(); if (disp != null && (disp.equalsIgnoreCase(Part.ATTACHMENT) || disp.equalsIgnoreCase(Part.INLINE))) { InputStream is = bodyPart.getInputStream(); saveFile(is, destDir, decodeText(bodyPart.getFileName())); } else if (bodyPart.isMimeType("multipart/*")) { saveAttachment(bodyPart, destDir); } else { String contentType = bodyPart.getContentType(); if (contentType.indexOf("name") != -1 || contentType.indexOf("application") != -1) { saveFile(bodyPart.getInputStream(), destDir, decodeText(bodyPart.getFileName())); } } } } else if (part.isMimeType("message/rfc822")) { saveAttachment((Part) part.getContent(), destDir); }else if (part.isMimeType("text/*") && part.isMimeType("image/*")){ saveAttachment((Part) part.getContent(), destDir); } } /** * 讀取輸入流中的資料儲存至指定目錄 * * @param is 輸入流 * @param fileName 檔名 * @param destDir 檔案儲存目錄 * @throws FileNotFoundException * @throws IOException */ private static void saveFile(InputStream is, String destDir, String fileName) throws FileNotFoundException, IOException { BufferedInputStream bis = new BufferedInputStream(is); BufferedOutputStream bos = new BufferedOutputStream( new FileOutputStream(new File(destDir + fileName))); int len = -1; while ((len = bis.read()) != -1) { bos.write(len); bos.flush(); } bos.close(); bis.close(); } /** * 文字解碼 * * @param encodeText 解碼MimeUtility.encodeText(String text)方法編碼後的文字 * @return 解碼後的文字 * @throws UnsupportedEncodingException */ public static String decodeText(String encodeText) throws UnsupportedEncodingException { if (encodeText == null || "".equals(encodeText)) { return ""; } else { return MimeUtility.decodeText(encodeText); } } }
IMAP協議和POP3協議程式碼基本一致,差別在於IMAP協議可以獲取郵件的狀態資訊以及埠號和路徑:
//獲得收件箱 IMAPFolder folder = (IMAPFolder) store.getFolder("INBOX"); folder.open(Folder.READ_WRITE); log.warn("郵件總數: {}", folder.getMessageCount()); log.info("未讀郵件數: {}", folder.getUnreadMessageCount()); //獲取最新郵件(此種方式不支援人工干預) Message[] messages = folder.getMessages(folder.getMessageCount() - folder.getUnreadMessageCount() +1,folder.getMessageCount());
拓展：獲取最新郵件的另一種方式,儲存郵件的UID,不能是MessageID,儲存MessageID會增加響應時間
package com.bxtdata.ips.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.bxtdata.ips.entity.EmailReply; import com.bxtdata.ips.mapper.EmailReplyMapper; import com.bxtdata.ips.service.EmailReplyService; import com.sun.mail.pop3.POP3Folder; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import javax.mail.*; import javax.mail.internet.InternetAddress; import javax.mail.internet.MimeMessage; import javax.mail.internet.MimeMultipart; import javax.mail.internet.MimeUtility; import java.io.*; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Properties; /** * @author pengjian * @date 2020-12-07 17:35 */ @Service @Slf4j public class EmailReplyServiceImpl extends ServiceImpl<EmailReplyMapper, EmailReply> implements EmailReplyService { @Autowired private EmailReplyService emailReplyService; /** * 獲取郵箱資訊 * * @param emailAdress 需要解析的郵箱地址 * @param password 郵箱的授權密碼 * @throws Exception */ @Override public List<EmailReply> resceive(String emailAdress, String password) throws Exception { String port = "110"; // 埠號 String servicePath = "pop.exmail.qq.com"; // 伺服器地址 // 準備連線伺服器的會話資訊 Properties props = new Properties(); props.setProperty("mail.store.protocol", "pop3"); // 使用pop3協議 props.setProperty("mail.pop3.port", port); // 埠 props.setProperty("mail.pop3.host", servicePath); // pop3伺服器 // 建立Session例項物件 Session session = Session.getInstance(props); Store store = session.getStore("pop3"); store.connect(emailAdress, password); //第三方登入授權密碼而並非普通的登入密碼 // 獲得收件箱 Folder folder = store.getFolder("INBOX"); /* Folder.READ_ONLY：只讀許可權 * Folder.READ_WRITE：可讀可寫（可以修改郵件的狀態） */ folder.open(Folder.READ_WRITE); //開啟收件箱,讀寫 // 獲得收件箱中的郵件總數 log.warn("郵件總數: {}", folder.getMessageCount()); // 得到收件箱中的所有郵件,並解析 Message[] messages = folder.getMessages(); //解析郵件 List<EmailReply> emailReplyList = parseMessage(folder, messages); //釋放資源 if (folder != null) { folder.close(true); } if (folder != null) { store.close(); } return emailReplyList; } /** * 解析郵件 * * @param messages 要解析的郵件列表 */ public List<EmailReply> parseMessage(Folder folder,Message... messages) throws MessagingException, IOException { if (messages == null || messages.length < 1){ List<EmailReply> list = new ArrayList<>(); return list; }else { // 解析所有郵件 List<EmailReply> emailReplyList = new ArrayList<>(); for (int i = 0, count = messages.length; i < count; i++) { EmailReply emailReply = new EmailReply(); MimeMessage msg = (MimeMessage) messages[i]; //此判斷為篩選符合需求的郵件，可根據自己需求自定義條件 if (isNumber(msg.getSubject().substring(msg.getSubject().lastIndexOf("_") + 1))) { POP3Folder inbox = (POP3Folder) folder; String uid = inbox.getUID(msg); //查詢uid是否已存資料庫 QueryWrapper<EmailReply> queryWrapper = new QueryWrapper<>(); queryWrapper.eq("u_id",uid); EmailReply check = emailReplyService.getOne(queryWrapper); if (check == null || check.equals("")){ log.info("------------------解析第" + msg.getMessageNumber() + "封郵件-------------------- "); emailReply.setUId(uid); log.warn("主題: {}", getSubject(msg)); emailReply.setSubject(getSubject(msg)); //擷取商品id String dataId = msg.getSubject().substring(msg.getSubject().lastIndexOf("_") + 1); emailReply.setDataId(Integer.valueOf(dataId)); log.warn("發件人: {}", getFrom(msg)); emailReply.setSendPeople(getFrom(msg)); log.warn("收件人：{}", getReceiveAddress(msg, null)); emailReply.setRecivePeople(getReceiveAddress(msg,null)); log.warn("傳送時間：{}", getSentDate(msg, null)); emailReply.setSentDate(getSentDate(msg,null)); // boolean isContainerAttachment = isContainAttachment(msg); // log.warn("是否包含附件：{}", isContainerAttachment); // if (isContainerAttachment) { // saveAttachment(msg, "D:\\TestEmailPlace" + msg.getSubject() + "_" + i + "_"); //儲存附件 // } StringBuffer content = new StringBuffer(30); //解析郵件正文 getMailTextContent(msg, content); log.warn("郵件正文：{}", content); emailReply.setContent(content.toString()); emailReply.setCreateTime(new Date()); emailReplyList.add(emailReply); log.info("------------------第" + msg.getMessageNumber() + "封郵件解析結束-------------------- "); } } } return emailReplyList; } } /** * 刪除郵件 * * @param messages 要刪除郵件列表 */ public static void deleteMessage(Message... messages) throws MessagingException, IOException { if (messages == null || messages.length < 1){ throw new MessagingException("未找到要解析的郵件!"); } // 解析所有郵件 for (int i = 0, count = messages.length; i < count; i++) { /** * 郵件刪除 */ Message message = messages[i]; String subject = message.getSubject(); // set the DELETE flag to true message.setFlag(Flags.Flag.DELETED, true); System.out.println("Marked DELETE for message: " + subject); } } /** * 獲得郵件主題 * * @param msg 郵件內容 * @return 解碼後的郵件主題 */ public static String getSubject(MimeMessage msg) throws UnsupportedEncodingException, MessagingException { return MimeUtility.decodeText(msg.getSubject()); } /** * 獲得郵件發件人 * * @param msg 郵件內容 * @return 姓名 <Email地址> * @throws MessagingException * @throws UnsupportedEncodingException */ public static String getFrom(MimeMessage msg) throws MessagingException, UnsupportedEncodingException { String from = ""; Address[] froms = msg.getFrom(); if (froms.length < 1){ throw new MessagingException("沒有發件人!"); } InternetAddress address = (InternetAddress) froms[0]; String person = address.getPersonal(); if (person != null) { person = MimeUtility.decodeText(person) + " "; } else { person = ""; } from = person + "<" + address.getAddress() + ">"; return from; } /** * 根據收件人型別，獲取郵件收件人、抄送和密送地址。如果收件人型別為空，則獲得所有的收件人 * <p>Message.RecipientType.TO 收件人</p> * <p>Message.RecipientType.CC 抄送</p> * <p>Message.RecipientType.BCC 密送</p> * * @param msg 郵件內容 * @param type 收件人型別 * @return 收件人1 <郵件地址1>, 收件人2 <郵件地址2>, ... * @throws MessagingException */ public static String getReceiveAddress(MimeMessage msg, Message.RecipientType type) throws MessagingException { StringBuffer receiveAddress = new StringBuffer(); Address[] addresss = null; if (type == null) { addresss = msg.getAllRecipients(); } else { addresss = msg.getRecipients(type); } if (addresss == null || addresss.length < 1){ throw new MessagingException("沒有收件人!"); } for (Address address : addresss) { InternetAddress internetAddress = (InternetAddress) address; receiveAddress.append(internetAddress.toUnicodeString()).append(","); } receiveAddress.deleteCharAt(receiveAddress.length() - 1); //刪除最後一個逗號 return receiveAddress.toString(); } /** * 獲得郵件傳送時間 * * @param msg 郵件內容 * @return yyyy年mm月dd日 星期X HH:mm * @throws MessagingException */ public static String getSentDate(MimeMessage msg, String pattern) throws MessagingException { Date receivedDate = msg.getSentDate(); if (receivedDate == null){ return ""; } if (pattern == null || "".equals(pattern)){ pattern = "yyyy年MM月dd日 E HH:mm "; } return new SimpleDateFormat(pattern).format(receivedDate); } /** * 判斷郵件中是否包含附件 * * @param part 郵件內容 * @return 郵件中存在附件返回true，不存在返回false * @throws MessagingException * @throws IOException */ public static boolean isContainAttachment(Part part) throws MessagingException, IOException { boolean flag = false; if (part.isMimeType("multipart/*")) { MimeMultipart multipart = (MimeMultipart) part.getContent(); int partCount = multipart.getCount(); for (int i = 0; i < partCount; i++) { BodyPart bodyPart = multipart.getBodyPart(i); String disp = bodyPart.getDisposition(); if (disp != null && (disp.equalsIgnoreCase(Part.ATTACHMENT) || disp.equalsIgnoreCase(Part.INLINE))) { flag = true; } else if (bodyPart.isMimeType("multipart/*")) { flag = isContainAttachment(bodyPart); } else { String contentType = bodyPart.getContentType(); if (contentType.indexOf("application") != -1) { flag = true; } if (contentType.indexOf("name") != -1) { flag = true; } } if (flag) { break; } } } else if (part.isMimeType("message/rfc822")) { flag = isContainAttachment((Part) part.getContent()); } return flag; } /** * 判斷郵件是否已讀 * * @param msg 郵件內容 * @return 如果郵件已讀返回true, 否則返回false * @throws MessagingException */ public static boolean isSeen(MimeMessage msg) throws MessagingException { return msg.getFlags().contains(Flags.Flag.SEEN); } /** * 判斷郵件是否需要閱讀回執 * * @param msg 郵件內容 * @return 需要回執返回true, 否則返回false * @throws MessagingException */ public static boolean isReplySign(MimeMessage msg) throws MessagingException { boolean replySign = false; String[] headers = msg.getHeader("Disposition-Notification-To"); if (headers != null){ replySign = true; } return replySign; } /** * 獲得郵件的優先順序 * * @param msg 郵件內容 * @return 1(High):緊急 3:普通(Normal) 5:低(Low) * @throws MessagingException */ public static String getPriority(MimeMessage msg) throws MessagingException { String priority = "普通"; String[] headers = msg.getHeader("X-Priority"); if (headers != null) { String headerPriority = headers[0]; if (headerPriority.indexOf("1") != -1 || headerPriority.indexOf("High") != -1){ priority = "緊急"; } else if (headerPriority.indexOf("5") != -1 || headerPriority.indexOf("Low") != -1){ priority = "低"; } else{ priority = "普通"; } } return priority; } /** * 獲得郵件文字內容 * * @param part 郵件體 * @param content 儲存郵件文字內容的字串 * @throws MessagingException * @throws IOException */ public static void getMailTextContent(Part part, StringBuffer content) throws MessagingException, IOException { //如果是文字型別的附件，通過getContent方法可以取到文字內容，但這不是我們需要的結果，所以在這裡要做判斷 boolean isContainTextAttach = part.getContentType().indexOf("name") > 0; if (part.isMimeType("text/*") && !isContainTextAttach) { content.append(part.getContent().toString()); } else if (part.isMimeType("message/rfc822")) { getMailTextContent((Part) part.getContent(), content); } else if (part.isMimeType("multipart/*")) { Multipart multipart = (Multipart) part.getContent(); int partCount = multipart.getCount(); for (int i = 0; i < partCount; i++) { BodyPart bodyPart = multipart.getBodyPart(i); getMailTextContent(bodyPart, content); } } } /** * 儲存附件 * * @param part 郵件中多個組合體中的其中一個組合體 * @param destDir 附件儲存目錄 * @throws UnsupportedEncodingException * @throws MessagingException * @throws FileNotFoundException * @throws IOException */ public static void saveAttachment(Part part, String destDir) throws MessagingException, IOException { if (part.isMimeType("multipart/*")) { Multipart multipart = (Multipart) part.getContent(); //複雜體郵件 //複雜體郵件包含多個郵件體 int partCount = multipart.getCount(); for (int i = 0; i < partCount; i++) { //獲得複雜體郵件中其中一個郵件體 BodyPart bodyPart = multipart.getBodyPart(i); //某一個郵件體也有可能是由多個郵件體組成的複雜體 String disp = bodyPart.getDisposition(); if (disp != null && (disp.equalsIgnoreCase(Part.ATTACHMENT) || disp.equalsIgnoreCase(Part.INLINE))) { InputStream is = bodyPart.getInputStream(); saveFile(is, destDir, decodeText(bodyPart.getFileName())); } else if (bodyPart.isMimeType("multipart/*")) { saveAttachment(bodyPart, destDir); } else { String contentType = bodyPart.getContentType(); if (contentType.indexOf("name") != -1 || contentType.indexOf("application") != -1) { saveFile(bodyPart.getInputStream(), destDir, decodeText(bodyPart.getFileName())); } } } } else if (part.isMimeType("message/rfc822")) { saveAttachment((Part) part.getContent(), destDir); }else if (part.isMimeType("text/*") && part.isMimeType("image/*")){ saveAttachment((Part) part.getContent(), destDir); } } /** * 讀取輸入流中的資料儲存至指定目錄 * * @param is 輸入流 * @param fileName 檔名 * @param destDir 檔案儲存目錄 * @throws FileNotFoundException * @throws IOException */ private static void saveFile(InputStream is, String destDir, String fileName) throws FileNotFoundException, IOException { BufferedInputStream bis = new BufferedInputStream(is); BufferedOutputStream bos = new BufferedOutputStream( new FileOutputStream(new File(destDir + fileName))); int len = -1; while ((len = bis.read()) != -1) { bos.write(len); bos.flush(); } bos.close(); bis.close(); } /** * 文字解碼 * * @param encodeText 解碼MimeUtility.encodeText(String text)方法編碼後的文字 * @return 解碼後的文字 * @throws UnsupportedEncodingException */ public static String decodeText(String encodeText) throws UnsupportedEncodingException { if (encodeText == null || "".equals(encodeText)) { return ""; } else { return MimeUtility.decodeText(encodeText); } } /** * 判斷字串是否可轉為整數 * @param str * @return */ public static boolean isNumber(String str){ return str.matches("^[-+]?(([0-9]+)([.]([0-9]+))?|([.]([0-9]+))?)$"); } }
常用郵箱的POP3 / SMTP地址及對應的埠
常用郵箱對應詳情：
https://blog.csdn.net/weixin_34216107/article/details/89050316
參考連結：https://blog.csdn.net/xyang81/article/details/7675160