javamail模拟邮箱功能--邮件回复-中级实战篇【邮件回复方法】（javamail API电子邮件实例）

package com.cplatform.movie.back.javamail;

import java.io.DataInputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import javax.mail.BodyPart;
import javax.mail.Folder;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Multipart;
import javax.mail.Store;
import javax.mail.internet.MimeUtility;

/**
 * 查看|接收邮件业务类
 * @author liuyt
 * @date  2014-10-24 下午2:04:48
 */
public class LookEmailService {
    private transient EmailServiceEnity emailService;
    private transient Folder folder;
    private transient Store store;
    
    // 初始化对象时附带初始化必要参数
    public LookEmailService() throws UnsupportedEncodingException, MessagingException {
        this.initStoreAndFolder();
    }
    
    // 主方法，这里演示单个邮件的内容读取和附件下载
    public void lookEmail() throws MessagingException, IOException, InterruptedException {
         // 获得邮件
         Message[] messages = this.getAllMessage();    // 方法一，得到全部邮件数组
         Message message = this.getMessageByIndex(messages.length);    // 方法二
         
         System.out.println("邮件接收时间："+message.getSentDate());
         System.out.println("邮件发送者："+message.getFrom()[0]);
         System.out.println("邮件主题："+message.getSubject());
         System.out.println("邮件内容："+message.getContent()); // 内存地址
         System.out.println("***********************飘逸的分割线*****************************");
         
         /**
          * 判断内容是否由多部件组成
          */
         if(!message.getContentType().contains("multipart/")) {
             return;
         }
         
         // 得到邮件的Multipart（内容总部件--【包涵附件】）
         Multipart multipart = (Multipart) message.getContent();
         int count = multipart.getCount();    // 部件个数
         for(int i=0; i<count; i++) {
             // 单个部件     注意：单个部件有可能又为一个Multipart，层层嵌套
             BodyPart part = multipart.getBodyPart(i);
             // 单个部件类型
             String type = part.getContentType().split(";")[0];
             /**
              * 类型众多，逐一判断，其中TEXT、HTML类型可以直接用字符串接收，其余接收为内存地址
              * 可能不全，如有没判断住的，请自己打印查看类型，在新增判断
              */
             if(type.equals("multipart/alternative")) {        // HTML （文本和超文本组合）
                 System.out.println("超文本:" + part.getContent().toString());
             }else if(type.equals("text/plain")) {    // 纯文本
                 System.out.println("纯文本:" + part.getContent().toString());
             }else if(type.equals("text/html")){    // HTML标签元素
                 System.out.println("HTML元素:" + part.getContent().toString());
             }else if(type.equals("multipart/related")){    // 内嵌资源 (包涵文本和超文本组合)
                 System.out.println("内嵌资源:" + part.getContent().toString());
             }else if(type.contains("application/")) {        // 应用附件 （zip、xls、docx等）
                 System.out.println("应用文件：" + part.getContent().toString());
             }else if(type.contains("image/")) {            // 图片附件 （jpg、gpeg、gif等）
                 System.out.println("图片文件：" + part.getContent().toString());
             }
             
/*****************************************获取邮件内容方法***************************************************/
             /**
              * 附件下载
              * 这里针对image图片类型附件做下载操作，其他类型附件同理
              */
             if(type.contains("image/")) {
                 // 打开附件的输入流
                 DataInputStream in = new DataInputStream(part.getInputStream());
                 // 一个文件输出流
                 FileOutputStream out = null;
                 // 获取附件名
                 String fileName = part.getFileName();
                 // 文件名解码
                 fileName = MimeUtility.decodeText(fileName);
                 // 根据附件名创建一个File文件
                 File file = new File("d:/data/" + fileName);
                 // 查看是否有当前文件
                 Boolean b = file.exists();
                 if(!b) {
                    out = new FileOutputStream(file);
                    int data;
                     // 循环读写
                     while((data=in.read()) != -1) {
                         out.write(data);
                     }
                     System.out.println("附件：【" + fileName + "】下载完毕，保存路径为：" + file.getPath());
                 }
                 
                 // 关流
                 if(in != null) {
                    in.close();
                 }
                 if(out != null) {
                    out.close();
                 }
             }
             
             /**
              * 获取超文本复合内容
              * 他本是又是一个Multipart容器
              * 此时邮件会分为TEXT（纯文本）正文和HTML正文（HTML标签元素）
              */
             if(type.equals("multipart/alternative")) {
                 Multipart m = (Multipart) part.getContent();
                for (int k=0; k<m.getCount(); k++) {
                     if(m.getBodyPart(k).getContentType().startsWith("text/plain")) {
                         // 处理文本正文
                        System.out.println("TEXT文本内容："+"\n" + m.getBodyPart(k).getContent().toString().trim()+"\n");
                     } else {
                         // 处理 HTML 正文
                         System.out.println("HTML文本内容："+"\n" + m.getBodyPart(k).getContent()+"\n");
                     }
                }
             }
             
         }
         
        /**
         * 最后千万别忘记了关闭
         */
        folder.close(false); // false为不更新邮件，true为更新，一般在删除邮件后使用
        store.close();
    }
    
    /**
     * 返回一个指定条目的邮件
     * @return
     * @throws MessagingException 
     */
    public Message getMessageByIndex(int index) throws MessagingException {
        return folder.getMessage(index);
    }
    
    /**
     * 返回邮箱所有邮件
     * @param args
     * @throws MessagingException 
     */
    public Message[] getAllMessage() throws MessagingException {
        return folder.getMessages();
    }
    
    /**
     * 返回指定区间（起始条目和结束条目）的邮件
     * @param args
     * @throws MessagingException 
     */
    public Message[] getMessageBySpace(int start, int end) throws MessagingException {
        return folder.getMessages(start, end);
    }
    
    /**
     * 初始化Store连接和获取Folder邮件夹
     * @throws MessagingException 
     * @throws UnsupportedEncodingException 
     */
    public void initStoreAndFolder() throws UnsupportedEncodingException, MessagingException {
        /**
         * 接收邮件时，邮箱的协议为POP3，SMTP为邮件传输协议，这里别搞混了
         * 并且检查你的邮箱设置POP3功能是否开启
         */
        emailService = new EmailServiceEnity("", "",EmailServiceEnity.MAIL_PROTOCOL_POP3);
        
        /**
         *  javax.mail.Store类用于连接邮件接收服务器，并访问邮件接收服务器上的各个邮箱夹
         *  javax.mail.Folder类表示邮件夹
         *  通过一个Session我们可以拿到一个邮箱对应的Store
         */
        store = emailService.getSession().getStore(emailService.getMailProtocol());
        store.connect(emailService.getHostPort(), EmailServiceEnity.username, EmailServiceEnity.password);
        
        /**
         *     通过Store拿到收件箱文件夹
         *  INBOX 标识获取到邮件夹里的收件箱  （对于POP3协议仅INBOX可用--蛋疼哦） 
         *  并以只读方式打开收件箱
         */
        folder = store.getFolder("INBOX");
        folder.open(Folder.READ_ONLY);
    }
    
    // main 方法简单测试
    public static void main(String[] args) {
        try {
            new LookEmailService().lookEmail();
        } catch (IOException  e) {
            e.printStackTrace();
        } catch (MessagingException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    /***************GET********************SET***********************/
    public EmailServiceEnity getEmailService() {
        return emailService;
    }

    public void setEmailService(EmailServiceEnity emailService) {
        this.emailService = emailService;
    }

    public Store getStore() {
        return store;
    }

    public void setStore(Store store) {
        this.store = store;
    }

    public Folder getFolder() {
        return folder;
    }

    public void setFolder(Folder folder) {
        this.folder = folder;
    }
}

package com.cplatform.movie.back.javamail;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import javax.mail.Address;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.internet.InternetAddress;

/**
 * 邮件回复业务类
 * @author liuyt
 * @date  2014-10-27 上午8:48:29
 */
public class ReplyEmailService {
    // 服务实体类
    private transient EmailServiceEnity emailService;
    // 回复内容
    private transient String content;
    
    /**
     * 邮件回复方法
     * 思路：先获取要回复的邮件，然后获取邮件的各个详情，把详情附加给新建邮件，发送
     * @throws MessagingException 
     * @throws IOException 
     */
    public void replyEmail () throws MessagingException, IOException {
        // 获取邮件,和查看邮件相同,调用方法即可
        LookEmailService lookEmail = new LookEmailService();
        emailService = new EmailServiceEnity("", "",EmailServiceEnity.MAIL_PROTOCOL_POP3);
        lookEmail.setEmailService(emailService);
        Message message = lookEmail.getMessageByIndex(lookEmail.getAllMessage().length);
        
        /*************上面为获取邮件************到此处是一个分水岭****************下面为发送邮件****************/
        Message reply = this.newReplyMessage(message);
        
        // 布尔值，true为回复给所有人，false为只回复给发送者
        reply.reply(true);

        // 发送回复
        emailService.getTransport().connect();
        emailService.getTransport().sendMessage(reply, reply.getAllRecipients());
        emailService.getTransport().close();
    }
    
    /**
     * 组装要回复的邮件
     * @param message
     * @return
     * @throws MessagingException
     * @throws IOException
     */
    public Message newReplyMessage(Message message) throws MessagingException, IOException {
        // 出新初始化一个服务类，因为之前为获取邮件，协议为POP3，当前要发送邮件，协议为SMTP
        emailService = new EmailServiceEnity("", "", EmailServiceEnity.MAIL_PROTOCOL_SMTP);
        
        // 新创建一个邮件
        Message reply = emailService.getMessage();
        
        // 获取原邮件的发件人--》为新邮件的接收人
        Address[] addressTo = message.getFrom();
        
        // 获取原邮件内容（暂支持文本和HTML单部件，多部件另需递归循环原邮件，并新增）
        Object content = message.getContent();
        
        // 获取原邮件主题
        String subObject = message.getSubject();
        
        // 获取邮件发送时间
        String date = message.getSentDate().toString();
        
        /** 组装新邮件*/
        // 设置回复内容，新内容+原文
        reply.setContent(this.content + "<br/><br/><br/>" + date +","+
                        InternetAddress.toString(addressTo) + "写到:<br/>> " + 
                        content, "text/html;charset=utf-8");
        
        // 设置邮件回复主题
        reply.setSubject("Re：" + subObject);
        
        // 设置收件人：原发件人
        reply.addRecipients(Message.RecipientType.TO, addressTo);
        
        return reply;
    }
    
    // 简单main方法测试
    public static void main(String[] args) {
        try {
            ReplyEmailService replySend = new ReplyEmailService();
            replySend.setContent("你好，邮件已收到！ <a href=‘http://www.cnblogs.com/liuyitian‘><<--点击进入我的博客-->></a>");
            replySend.replyEmail();
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        } catch (MessagingException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    /**********************GET***********************SET****************************/
    public EmailServiceEnity getEmailService() {
        return emailService;
    }
    public void setEmailService(EmailServiceEnity emailService) {
        this.emailService = emailService;
    }
    public String getContent() {
        return content;
    }
    public void setContent(String content) {
        this.content = content;
    }
}