package com.ots.project.tool.email;
|
import lombok.extern.slf4j.Slf4j;
|
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;
|
@Slf4j
|
public class ParsingEmailUtil {
|
public static void main(String[] args) throws Exception {
|
resceive("2040239371@qq.com", "pznchtoldrmcdgif");
|
}
|
|
public static void resceive(String emailAdress, String password) throws Exception {
|
String port = "110";
|
String servicePath = "pop.qq.com";
|
|
Properties props = new Properties();
|
props.setProperty("mail.store.protocol", "pop3");
|
props.setProperty("mail.pop3.port", port);
|
props.setProperty("mail.pop3.host", servicePath);
|
|
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();
|
|
parseMessage(messages);
|
|
|
|
folder.close(true);
|
store.close();
|
}
|
|
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));
|
log.warn("是否已读：{}", isSeen(msg));
|
log.warn("邮件优先级：{}", getPriority(msg));
|
log.warn("是否需要回执：{}", isReplySign(msg));
|
log.warn("邮件大小：{}", msg.getSize() * 1024 + "kb");
|
boolean isContainerAttachment = isContainAttachment(msg);
|
log.warn("是否包含附件：{}", isContainerAttachment);
|
if (isContainerAttachment) {
|
|
}
|
StringBuffer content = new StringBuffer(30);
|
|
getMailTextContent(msg, content);
|
log.warn("邮件正文：{}", content);
|
String head = "收件人（";
|
int start = content.indexOf(head);
|
int end = content.indexOf("）", start);
|
String substring = content.substring(start + head.length(), end);
|
log.error("退信邮箱地址：{}", substring);
|
log.info("------------------第" + msg.getMessageNumber() + "封邮件解析结束-------------------- ");
|
System.out.println();
|
}
|
}
|
|
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();
|
|
message.setFlag(Flags.Flag.DELETED, true);
|
System.out.println("Marked DELETE for message: " + subject);
|
}
|
}
|
|
public static String getSubject(MimeMessage msg) throws UnsupportedEncodingException, MessagingException {
|
return MimeUtility.decodeText(msg.getSubject());
|
}
|
|
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;
|
}
|
|
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();
|
}
|
|
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);
|
}
|
|
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;
|
}
|
|
public static boolean isSeen(MimeMessage msg) throws MessagingException {
|
return msg.getFlags().contains(Flags.Flag.SEEN);
|
}
|
|
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;
|
}
|
|
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;
|
}
|
|
public static void getMailTextContent(Part part, StringBuffer content) throws MessagingException, IOException {
|
|
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);
|
}
|
}
|
}
|
|
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);
|
}
|
}
|
|
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();
|
}
|
|
public static String decodeText(String encodeText) throws UnsupportedEncodingException {
|
if (encodeText == null || "".equals(encodeText)) {
|
return "";
|
} else {
|
return MimeUtility.decodeText(encodeText);
|
}
|
}
|
}
|
