package com.skysz.app.km.audit.utils;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Properties;
import javax.mail.BodyPart;
import javax.mail.Flags;
import javax.mail.Folder;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Multipart;
import javax.mail.Part;
import javax.mail.Session;
import javax.mail.Store;
import javax.mail.URLName;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import javax.mail.internet.MimeUtility;
import org.apache.log4j.Logger;
import com.skysz.framework.exception.ExceptionUtils;
import com.skysz.framework.file.FileUtils;
import com.skysz.framework.utils.StringUtils;
import com.sun.mail.pop3.POP3Message;
public class EmailUtils {
protected final Logger log = Logger.getLogger(getClass());
private MimeMessage msg = null;
private String saveAttchPath = "C:\\temp\\";
private StringBuffer bodytext = new StringBuffer();
private String dateformate = "yyyy-MM-dd";
public EmailUtils(MimeMessage msg) {
this.msg = msg;
}
public void setMsg(MimeMessage msg) {
this.msg = msg;
}
public EmailUtils() {
}
/**
* 获取发送邮件者信息
*
* @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;
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 (!StringUtils.isNullOrBlank(filename)
&& (filename.toLowerCase().indexOf("gb18030") != -1 || filename
.toLowerCase().indexOf("gbk") != -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("gbk") != -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 {
// 过滤:如果不是txt文件 不保存
if (StringUtils.isNullOrBlank(filename) || !filename.contains(".txt")) {
log.info("文件名为:" + filename + ",不是txt格式不保存.");
return;
}
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 = "C://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 receive(Part part, String filePath, int i, String date)
throws MessagingException, IOException {
log.info("------------------receive Email START-----------------------");
log.info("Message" + i + " subject:" + getSubject());
log.info("Message" + i + " from:" + getFrom());
log.info("Message" + i + " isNew:" + isNew());
String sendDate = getSendDate();
if (!sendDate.equals(date)) {
log.info("Email SendDate :" + sendDate + ",we get date:" + date
+ ",----receive Email END-----------------------");
return;
}
boolean flag = isContainAttch(part);
log.info("Message" + i + " isContainAttch:" + flag);
getMailContent(part);
log.info("Message" + i + " content:" + getBodyText());
setSaveAttchPath(filePath);
if (flag) {
saveAttchMent(part);
}
log.info("------------------receive Email END-----------------------");
}
/**
* 判断文件夹是否存在,不存在则创建,存在则删除文件夹里面的文件
*
* @param filePath
*/
private void dealFile(String filePath) {
File file = new File(filePath);
if (!file.exists()) {
file.mkdirs();
} else {
String[] str = file.list();
for (String s : str) {
File f = new File(filePath + FileUtils.getFileSeparator() + s);
f.delete();
}
}
}
/***
* 下载附件
*
* @param smtp
* @param pop
* @param userName
* @param pwd
* @param date
* (yyyy-MM-dd)
*/
public void downLoadAttchMent(String smtp, String pop, String userName,
String pwd, String date) {
Properties props = new Properties();
props.setProperty("mail.smtp.host", smtp);
props.setProperty("mail.smtp.auth", "true");
Session session = Session.getDefaultInstance(props, null);
// 这里使用的是sina的邮件服务器,输入邮箱用户名和密码直接运行就可以收邮件
URLName urlname = new URLName("pop3", pop, 110, null, userName, pwd);
String filePath = saveAttchPath + date;
// 文件夹不存在则创建,存在则删除里面数据
dealFile(filePath);
try {
Store store = session.getStore(urlname);
store.connect();
Folder folder = store.getFolder("INBOX");
folder.open(Folder.READ_ONLY);
Message msgs[] = folder.getMessages();
int count = msgs.length;
EmailUtils rm = null;
for (int i = 0; i < count; i++) {
if (!msgs[i].getFolder().isOpen()) // 判断是否open
msgs[i].getFolder().open(Folder.READ_ONLY); // 如果close，就重新open
rm = new EmailUtils((MimeMessage) msgs[i]);
try {
rm.receive(msgs[i], filePath, i, date);
((POP3Message) msgs[i]).invalidate(true);// 每封邮件读取完后，设置不往cache中添加
} catch (Exception e) {
log.info("收件异常:" + ExceptionUtils.getFullStackTrace(e));
continue;
}
}
} catch (Exception e) {
log.info("邮件属性配置错误:" + ExceptionUtils.getFullStackTrace(e));
}
}
public static void main(String[] args) {
// 这里使用的是sina的邮件服务器,输入邮箱用户名和密码直接运行就可以收邮件
// new
// EmailUtils().downLoadAttchMent("smtp.sina.com","pop.sina.com","zzjicdi@sina.com",
// "","2013-09-04");
// new
// EmailUtils().downLoadAttchMent("mail.jade388.com","mail.jade388.com","zijinbu@jade388.com",
// "123456","2013-09-02");
// new
// EmailUtils().downLoadAttchMent("smtp.qq.com","pop.qq.com","214203258@qq.com",
// "","2013-09-02");
}
}
相关推荐
基于Javamail的邮件收发系统.zip基于Javamail的邮件收发系统.zip基于Javamail的邮件收发系统.zip基于Javamail的邮件收发系统.zip基于Javamail的邮件收发系统.zip基于Javamail的邮件收发系统.zip基于Javamail的邮件...
commons-email-1.1.jar：这是Apache Commons Email库的一个版本，它简化了使用JavaMail发送邮件的过程。这个库提供了许多实用方法，如创建HTML邮件、添加附件、设置抄送和密送等。通过使用Apache Commons Email，...
在IT行业中，电子邮件的收发是一项基础且重要的功能，尤其对于开发者来说，了解如何通过编程方式实现邮件的发送和接收是非常必要的。在这个例子中，我们将深入探讨如何利用James服务器和JavaMail API来实现这一目标...
### JavaMail收发Gmail邮件知识点详解 ...通过以上步骤，我们可以使用JavaMail实现对Gmail邮件的收发功能，并且通过SSL加密技术确保了数据的安全传输。这对于开发涉及邮件处理的应用程序非常有用。
JavaMail邮件收发实例_JavaMail_API JavaMail邮件收发实例_JavaMail_API JavaMail邮件收发实例_JavaMail_API JavaMail邮件收发实例_JavaMail_API JavaMail邮件收发实例_JavaMail_API
JavaMail 是一个强大的开源库，专门用于在Java应用程序中实现电子邮件的发送和接收。它支持多种邮件协议，如SMTP（简单邮件传输协议）用于发送邮件，IMAP（因特网消息访问协议）和POP3（邮局协议）用于接收邮件。在...
以下将详细阐述如何使用JavaMail和Struts框架实现一个真实的邮件系统。 1. **Struts框架介绍**： Struts是基于MVC（Model-View-Controller）设计模式的Java Web框架，它提供了一种组织应用程序代码的方式，使...
**基于Javamail的邮件收发系统** JavaMail是一个开放源码的API，它为Java程序员提供了一套全面的接口来处理电子邮件。这个系统的设计目的是使得开发者能够方便地发送和接收邮件，包括附件、HTML内容以及MIME多部分...
【描述】:本文档详细介绍了如何使用JavaMail技术设计和实现一个电子邮件收发系统，涵盖了系统设计的目标、国内外发展趋势、技术选型、需求分析、详细设计以及功能实现和测试。 【标签】:互联网 【正文】: 基于...
JavaMail通过`mail.smtp.socketFactory.class`和`mail.smtp.socketFactory.port`属性实现此功能。 6. **证书与信任管理**： - 当使用加密连接时，需要处理服务器证书验证。JavaMail默认会检查服务器的证书是否由受...
基于Javamail的邮件收发系统是一款简单、方便、快捷的邮件系统。它能实现邮件的接收与发送，并能完成附件的传输，具有较好的人机交互性，易于使用。 开发环境：JDK1.6 + Windows平台 开发技术：Javamail 开发工具：...
在实际开发中，使用 JavaMail 进行邮件收发的步骤大致如下： 1. 创建 Session 对象，配置邮件服务器的相关信息。 2. 使用 Session 创建 Store 对象，连接到邮件服务器。 3. 打开 Folder，读取或管理邮件。 4. 如果...
在这个主题中，我们将深入探讨如何使用 JavaMail 实现邮件的加密和解密，以及如何进行邮件的签名，确保通信的安全性。 1. **JavaMail 基础** 在 JavaMail 中，`javax.mail` 和 `javax.mail.internet` 包提供了主要...
这个简单的JavaMail程序包含了收发邮件的基本功能，对于理解JavaMail的工作原理和使用方法非常有帮助。 首先，让我们从发送邮件的部分开始。在JavaMail中，发送邮件的核心类是`javax.mail.Session`和`javax.mail....
### 基于JavaMail的Web邮件客户端设计与实现的关键知识点 #### 一、JavaMail简介 JavaMail API是Sun Microsystems提供的一套用于发送、接收和处理电子邮件的标准接口集合。它建立在JavaBeans的基础上，提供了丰富...
JavaMail 是一个强大的开源类库，用于在Java应用程序中实现电子邮件的发送和接收。它提供了对SMTP（简单邮件传输协议）、POP3（邮局协议）和IMAP（因特网消息访问协议）等标准的全面支持，使得开发者可以方便地进行...
本篇将深入探讨如何使用JavaMail实现发送邮件，以及相关的源码分析。 首先，我们需要了解JavaMail的基本组件。`javax.mail`库主要包含以下关键接口和类： 1. `Session`：这是JavaMail的核心，代表与邮件服务器的...
**JavaMail API** 是由SUN公司（现已被Oracle收购）为Java开发者提供的一个公共API框架，用于在Java应用中实现电子邮件功能的支持。它的设计遵循了开放性原则，避免了对特定供应商解决方案的依赖，这为开发者提供了...
在这个资源中，我们将探讨如何使用 JavaMail 实现邮件的发送、接收、查看邮件数量以及未读邮件的标记为已读。 首先，让我们从发送邮件开始。在 JavaMail 中，你需要创建一个 `Session` 对象来配置邮件服务器的连接...