[JAVA] javaMail邮件接收

java官方发布的邮件API，用于邮件的接收和发送。

今天写了一个获取邮件的案例，贴出来给大家参考。

需要的jar包：http://download.csdn.net/detail/gopain/8177253

案例代码：【很久以前写过一个，没有备份，丢了，以下代码也是参考了网上的资源】

package cn.gopain.serverTeacher;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 java.util.UUID;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.NoSuchProviderException;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;/** * 考试邮件服务器接收邮件并解析附件 *  * @author gopain * */public class KaoshiMail {private MimeMessage msg = null;private String saveAttchPath = "";private StringBuffer bodytext = new StringBuffer();private String dateformate = "yy-MM-dd HH:mm";private String path;public static void main(String[] args) throws MessagingException,IOException {Properties props = new Properties();props.setProperty("mail.smtp.host", "smtp.163.com");props.setProperty("mail.smtp.auth", "true");Session session = Session.getDefaultInstance(props, null);URLName urlname = new URLName("pop3", "pop.163.com", 110, null,"账户名称", "密码");Store store = session.getStore(urlname);store.connect();Folder folder = store.getFolder("INBOX");folder.open(Folder.READ_WRITE);// READ_ONLY);Message msgs[] = folder.getMessages();int count = msgs.length;System.out.println("Message Count:" + count);KaoshiMail rm = null;for (int i = 0; i < count; i++) {rm = new KaoshiMail((MimeMessage) msgs[i]);int res = rm.recive(msgs[i], i);if (res == 0) {msgs[i].setFlag(Flags.Flag.DELETED, true);// msgs[i].saveChanges();}}folder.close(true);store.close();}public KaoshiMail(MimeMessage msg) {this.msg = msg;this.path = null;}/** * 获取发送邮件者信息 *  * @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 = "";try {subject = MimeUtility.decodeText(msg.getSubject() == null? "无主题": msg.getSubject());} catch (UnsupportedEncodingException | MessagingException e) {// TODO 要不要在这里添加一点错误信息标记呢，或者要不要处理此处的错误呢，乖e.printStackTrace();}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;String contentType = part.getContentType();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 (filename.toLowerCase().indexOf("gb2312") != -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("gb2312") != -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 {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 = "d://temp";}} else {sepatror = "/";storedir = "/Users/gopain/mail";}if (this.path == null) {sepatror += UUID.randomUUID().toString() + "/";} else {sepatror += this.path + "/";}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 blocke.printStackTrace();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();} finally {bos.close();bis.close();}}@SuppressWarnings("finally")public int recive(Part part, int i) throws MessagingException, IOException {int res = 0;System.out.println("------------------START-----------------------");System.out.println("Message" + i + " subject:" + getSubject());System.out.println("Message" + i + " from:" + getFrom());System.out.println("Message" + i + " isNew:" + isNew());boolean flag = isContainAttch(part);System.out.println("Message" + i + " isContainAttch:" + flag);System.out.println("Message" + i + " replySign:" + getReplySign());getMailContent(part);System.out.println("Message" + i + " content:" + getBodyText());setSaveAttchPath("/Users/gopain/mail/" + i);if (flag) {try {saveAttchMent(part);} catch (Exception e) {// TODO 要不要在这里添加一点错误信息标记呢，或者要不要处理此处的错误呢，乖res = -1;e.printStackTrace();} finally {return res;}}System.out.println("------------------END-----------------------");return res;}public void recive_new(Part part, int i) throws MessagingException,IOException {System.out.println("------------------START-----------------------");System.out.println("Message" + i + " subject:" + getSubject());System.out.println("Message" + i + " from:" + getFrom());boolean is_new = isNew();System.out.println("Message" + i + " isNew:" + is_new);if (!is_new)return;boolean flag = isContainAttch(part);// 是否包含附件System.out.println("Message" + i + " isContainAttch:" + flag);System.out.println("Message" + i + " replySign:" + getReplySign());// 是否需要回执getMailContent(part);// 递归获取邮件内容System.out.println("Message" + i + " content:" + getBodyText());// 邮件正文setSaveAttchPath("/Users/gopain/mail/" + i);if (flag) {saveAttchMent(part);}System.out.println("------------------END-----------------------");}public MimeMessage getMsg() {return msg;// 获取msg的值，亲}public void setMsg(MimeMessage msg) {this.msg = msg;// 给this.msg赋值，思密达}public StringBuffer getBodytext() {return bodytext;// 获取bodytext的值，亲}public void setBodytext(StringBuffer bodytext) {this.bodytext = bodytext;// 给this.bodytext赋值，思密达}public String getPath() {return path;// 获取path的值，亲}public void setPath(String path) {this.path = path;// 给this.path赋值，思密达}public String getDateformate() {return dateformate;// 获取dateformate的值，亲}}

done。[今天累了，不想详细一句一句写了。抱歉]

人生的成功不过是在紧要处多一份坚持，