1.MailUtil
public class MailUtil {
@Value("${mail.mark}")
private String id;
public static String mark;
@PostConstruct
public void init(){
mark = this.id;
}
/**
* 发送邮件
* @param fromMailSMTPHost 邮件服务器
* @param smtpPort 端口
* @param fromMailAddress 发件地址
* @param fromMailPwd 发件授权码
* @param toEmailAddress 收件地址
* @param emailContent 内容
* @param emailTitle 标题
* @param msgId 指定标识ID
* @return
*/
public static boolean sendEmail(String fromMailSMTPHost,String smtpPort,String fromMailAddress,
String fromMailPwd, String toEmailAddress, String emailContent, String emailTitle,
String msgId) {
Session session = setSession(fromMailSMTPHost,smtpPort);
try {
Message message = setMail(session,fromMailAddress,toEmailAddress, emailTitle, emailContent,msgId);
Transport transport = session.getTransport();
transport.connect(fromMailAddress, fromMailPwd);
transport.sendMessage(message, message.getAllRecipients());
transport.close();
} catch (Exception e) {
log.error("toEmailAddress = " + toEmailAddress + ", emailContent = " + emailContent + ", emailTitle = " + emailTitle + ", error = " + e.getMessage());
return false;
}
return true;
}
private static Properties setProperties(String fromMailSMTPHost,String smtpPort) {
Properties properties = new Properties();
properties.setProperty("mail.transport.protocol", "smtp");
properties.setProperty("mail.smtp.host", fromMailSMTPHost);
properties.setProperty("mail.smtp.auth", "true");
properties.setProperty("mail.smtp.port", smtpPort);
properties.setProperty("mail.smtp.socketFactory.class", "javax.net.ssl.SSLSocketFactory");
properties.setProperty("mail.smtp.socketFactory.fallback", "false");
properties.setProperty("mail.smtp.socketFactory.port", smtpPort);
properties.setProperty("mail.smtp.ssl.enable", "true");
properties.setProperty("mail.debug", "true");
return properties;
}
private static Message setMail(Session session,String fromMailAddress, String toEmailAdress, String emailTitle,
String emailContent,String messageId) throws Exception {
MimeMessage message = new MimeMessage(session);
message.setFrom(new InternetAddress(fromMailAddress, fromMailAddress, "UTF-8"));
message.setRecipient(Message.RecipientType.TO, new InternetAddress(toEmailAdress, toEmailAdress, "UTF-8"));
message.setSubject(emailTitle);
message.setContent(emailContent, "text/html;charset=utf-8");
message.setSentDate(new Date());
message.addHeader(mark,messageId);
message.saveChanges();
return message;
}
private static Session setSession(String fromMailSMTPHost,String smtpPort) {
Properties properties = setProperties(fromMailSMTPHost,smtpPort);
Session session = Session.getInstance(properties);
session.setDebug(true);
return session;
}
public static void main(String[] args) {
String fromMailAddress = "XX@qq.com";
String fromMailPwd = "XXXX";
String fromMailSMTPHost = "smtp.qq.com";
String smtpPort = "465";
String toEmailAddress = "XXXX@sina.com";
String emailContent = "testContent1227";
String emailTitle = "testTitle1227";
UUID uuid = UUID.randomUUID();
MailUtil.sendEmail(fromMailSMTPHost, smtpPort, fromMailAddress, fromMailPwd, toEmailAddress,
emailContent,
emailTitle, DateUtils.getTime()+"-"+uuid);
}
}
2.EmailBounceScanService
public class EmailBounceScanService {
private static final String multipart = "multipart/*";
private final static String subjectKeyword = "来自qq.com的退信";
private final static String subjectKeyword163 = "系统退信";
private Integer timeOffset = 1;
private Properties buildInboxProperties(String popHost) {
Properties properties = new Properties();
// properties.setProperty("mail.store.protocol", "pop3");
// properties.setProperty("mail.pop3.host", popHost);
// properties.setProperty("mail.pop3.auth", "true");
// properties.setProperty("mail.pop3.default-encoding", "UTF-8");
properties.setProperty("mail.store.protocol", "imap");
properties.setProperty("mail.imap.host", popHost);
properties.setProperty("mail.imap.auth", "true");
properties.setProperty("mail.imap.port", "993");
properties.setProperty("mail.imap.socketFactory.class", "javax.net.ssl.SSLSocketFactory");
properties.setProperty("mail.imap.socketFactory.fallback", "false");
properties.setProperty("mail.imap.socketFactory.port", "993");
properties.setProperty("mail.imap.ssl.enable", "true");
properties.setProperty("mail.imap.default-encoding", "UTF-8");
properties.setProperty("mail.debug", "true");
return properties;
}
/**
* 查找退回邮件
* @param popHost
* @param username
* @param password
*/
public void searchEmail163(String popHost,String username,String password) {
//这部分就是解决异常的关键所在，设置IAMP ID信息
HashMap IAM = new HashMap();
//带上IMAP ID信息，由key和value组成，例如name，version，vendor，support-email等。
// 这个value的值随便写就行
IAM.put("name","myname");
IAM.put("version","1.0.0");
IAM.put("vendor","myclient");
IAM.put("support-email","testmail@test.com");
Session session = Session.getInstance(this.buildInboxProperties(popHost));
IMAPStore store = null;
Folder receiveFolder = null;
try {
// 使用imap会话机制，连接服务器
int total = 0;
store = (IMAPStore) session.getStore("imap");
store.connect(username, password);
store.id(IAM);
receiveFolder = store.getFolder("inbox");
receiveFolder.open(Folder.READ_ONLY);
int messageCount = receiveFolder.getMessageCount();
List<Message> list = new ArrayList<>();
if (messageCount > 0) {
Date now = Calendar.getInstance().getTime();
Date timeOffsetAgo = DateUtils.getStartDate(DateUtils.getLastDay(timeOffset));
SearchTerm comparisonTermGe = new ReceivedDateTerm(ComparisonTerm.GE, timeOffsetAgo);
SearchTerm comparisonTermLe = new ReceivedDateTerm(ComparisonTerm.LE, now);
SearchTerm searchDate = new AndTerm(comparisonTermLe,comparisonTermGe);
SearchTerm searchFrom = new FromStringTerm("PostMaster");
SearchTerm search = new AndTerm(searchDate,searchFrom);
// Message[] messages = receiveFolder.search(search);
Message[] messages = receiveFolder.getMessages();
if (messages.length == 0) {
log.info("No bounce email was found.");
return;
}
for (Message message : messages) {
String subject = message.getSubject();
if(subjectKeyword163.equalsIgnoreCase(subject)){
list.add(message);
}
}
this.messageHandler(list);
}
} catch (MessagingException e) {
log.error("Exception in searchInboxEmail {}", e.getMessage());
e.printStackTrace();
} finally {
try {
if (receiveFolder != null) {
receiveFolder.close(true);
}
if (store != null) {
store.close();
}
} catch (MessagingException e) {
log.error("Exception in searchInboxEmail {}", e.getMessage());
e.printStackTrace();
}
}
}
/**
* 获取指定标识
* @param part
* @return
* @throws Exception
*/
public static HashMap<String, String> getMessageId163(Part part) throws Exception {
HashMap<String, String> map = new HashMap<>();
if (!part.isMimeType(multipart)) {
return map;
}
Multipart multipart = (Multipart) part.getContent();
for (int i = 0; i < multipart.getCount(); i++) {
BodyPart bodyPart = multipart.getBodyPart(i);
if (part.isMimeType("message/rfc822")) {
return getMessageId((Part) part.getContent());
}
InputStream inputStream = bodyPart.getInputStream();
try (BufferedReader br = new BufferedReader(new InputStreamReader(inputStream))) {
String strLine;
String text = "";
while ((strLine = br.readLine()) != null) {
if (strLine.startsWith(MailUtil.mark)) {
String[] split = strLine.split(MailUtil.mark+":");
if(split.length > 1 && StringUtils.isNotEmpty(split[1].trim())){
map.put("id", split[1].trim());
}
}
String fromBase64 = Base64Utils.getFromBase64(strLine,"gb2312");
if(fromBase64.contains("退信原因：")) {
text = "\t"+fromBase64;
}
}
if(StringUtils.isNotEmpty(text)){
text = deleteAllHTMLTag(text);
text = text.replaceAll("\t", "");
}
if(StringUtils.isNotEmpty(text)){
map.put("text",text);
}
}
}
return map;
}
/**
* 查找退回邮件
* @param popHost
* @param username
* @param password
*/
public void searchInboxEmail(String popHost,String username,String password) {
Session session = Session.getInstance(this.buildInboxProperties(popHost));
Store store = null;
Folder receiveFolder = null;
try {
store = session.getStore("imap");
store.connect(username, password);
receiveFolder = store.getFolder("inbox");
receiveFolder.open(Folder.READ_ONLY);
int messageCount = receiveFolder.getMessageCount();
List<Message> list = new ArrayList<>();
if (messageCount > 0) {
Date now = Calendar.getInstance().getTime();
Date timeOffsetAgo = DateUtils.getStartDate(DateUtils.getLastDay(timeOffset));
SearchTerm comparisonTermGe = new ReceivedDateTerm(ComparisonTerm.GE, timeOffsetAgo);
SearchTerm comparisonTermLe = new ReceivedDateTerm(ComparisonTerm.LE, now);
SearchTerm searchDate = new AndTerm(comparisonTermLe,comparisonTermGe);
SearchTerm searchFrom = new FromStringTerm("PostMaster");
SearchTerm search = new AndTerm(searchDate,searchFrom);
Message[] messages = receiveFolder.search(search);
if (messages.length == 0) {
log.info("No bounce email was found.");
return;
}
for (Message message : messages) {
String subject = message.getSubject();
if(subjectKeyword.equalsIgnoreCase(subject)){
list.add(message);
}
}
this.messageHandler(list);
}
} catch (MessagingException e) {
log.error("Exception in searchInboxEmail {}", e.getMessage());
e.printStackTrace();
} finally {
try {
if (receiveFolder != null) {
receiveFolder.close(true);
}
if (store != null) {
store.close();
}
} catch (MessagingException e) {
log.error("Exception in searchInboxEmail {}", e.getMessage());
e.printStackTrace();
}
}
}
/**
* 处理标识的邮件
* @param messageList
*/
@Transactional
public void messageHandler(List<Message> messageList) {
// messageList.stream().filter(MailUtil::isContainAttachment).forEach((message -> {
messageList.stream().forEach((message -> {
String messageId = null;
String reason = null;
try {
HashMap<String, String> mail = this.getMessageId(message);
messageId = mail.get("id");
reason = mail.get("text");
} catch (Exception e) {
log.error("getMessageId:", e.getMessage());
}
if (StringUtils.isEmpty(messageId)) return;
//todo 数据处理
}));
}
/**
* 处理中文编码问题
* @param text
* @return
* @throws UnsupportedEncodingException
*/
private String decodeText(String text) throws UnsupportedEncodingException {
if (text == null) {
return null;
}
if (text.startsWith("=?GB") || text.startsWith("=?gb"))
text = MimeUtility.decodeText(text);
else
text = new String(text.getBytes("ISO8859_1"));
return text;
}
/**
* 获取指定标识
* @param part
* @return
* @throws Exception
*/
public static HashMap<String, String> getMessageId(Part part) throws Exception {
HashMap<String, String> map = new HashMap<>();
if (!part.isMimeType(multipart)) {
return map;
}
Multipart multipart = (Multipart) part.getContent();
for (int i = 0; i < multipart.getCount(); i++) {
BodyPart bodyPart = multipart.getBodyPart(i);
if (part.isMimeType("message/rfc822")) {
return getMessageId((Part) part.getContent());
}
InputStream inputStream = bodyPart.getInputStream();
try (BufferedReader br = new BufferedReader(new InputStreamReader(inputStream))) {
String strLine;
boolean flag = false;
String text = "";
while ((strLine = br.readLine()) != null) {
if (strLine.startsWith(MailUtil.mark)) {
String[] split = strLine.split(MailUtil.mark+":");
if(split.length > 1 && StringUtils.isNotEmpty(split[1].trim())){
map.put("id", split[1].trim());
}
}
if(flag){
text = "\t"+strLine;
}
if(strLine.contains("退信原因")) {
flag = true;
}
if(text.contains("</td>")){
flag = false;
}
}
if(StringUtils.isNotEmpty(text)){
text = deleteAllHTMLTag(text);
text = text.replaceAll("\t", "");
}
if(StringUtils.isNotEmpty(text)){
map.put("text",text);
}
}
}
return map;
}
/**
* 删除所有的HTML标签
*
* @param source 需要进行除HTML的文本
* @return
*/
public static String deleteAllHTMLTag(String source) {
if(source == null) {
return "";
}
String s = source;
/** 删除普通标签 */
s = s.replaceAll("<(S*?)[^>]*>.*?|<.*? />", "");
/** 删除转义字符 */
s = s.replaceAll("&.{2,6}?;", "");
return s;
}
/**
* 是否存在附件
* @param part
* @return
*/
public static boolean isContainAttachment(Part part) {
boolean attachFlag = false;
try {
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 = isContainAttachment((Part) mpart);
} else {
String contype = mpart.getContentType();
if (contype.toLowerCase().contains("application"))
attachFlag = true;
if (contype.toLowerCase().contains("name"))
attachFlag = true;
}
}
} else if (part.isMimeType("message/rfc822")) {
attachFlag = isContainAttachment((Part) part.getContent());
}
} catch (MessagingException | IOException e) {
e.printStackTrace();
}
return attachFlag;
}
}
