javamail模拟邮箱功能收取电子邮件-中级实战篇【内容|附件下载方法】（javamail API电子邮件实例）

package com.cplatform.movie.back.javamail;

import java.io.UnsupportedEncodingException;
import java.util.Properties;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.NoSuchProviderException;
import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import com.cplatform.movie.back.javamail.SimpleEmailFunction.MyAuthenricator;

/**
 * 邮件服务支持类
 * @author liuyt
 * @date  2014-10-24 下午2:11:38
 */
public class EmailServiceEnity extends EmailEntity{
    // java.util.propertis 类
    private transient Properties props;
    // 一个邮件会话
    private transient Session session;
    // 邮件消息
    private transient MimeMessage message;
    // 邮件传输对象
    private Transport transport;
    // 邮件发送内容
    private String content;
    // 邮件内容格式
    private final String CONTENT_TYPE_HTML = "text/html;charset=utf-8";
    // 端口号 
    private final static String MAIL_PORT = "25";
    // 邮箱协议常量
    public static final  String MAIL_PROTOCOL_SMTP = "smtp";
    public static final  String MAIL_PROTOCOL_POP3 = "pop3";
    // 邮箱所使用的协议
    private String mailProtocol;
    // 邮箱服务器列表
    private String hostPort;
    
//////////////////分//////////////////界/////////////////////线/////////////////////////////    
    
    /**
     * 实参构造
     * @param  mailToaddress  收件人地址，多个以逗号隔开
     * @param  content               邮件内容
     * @throws MessagingException 
     * @throws UnsupportedEncodingException 
     */
    public EmailServiceEnity(String mailToaddress, String content, String mailProtocol) throws UnsupportedEncodingException, MessagingException {
        super(username, password);
        this.setMailProtocol(mailProtocol);
        this.setHostPort(mailProtocol +"."+ username.split("@")[1]);
        this.content = content;
        this.session = this.initSession();
        this.message = this.initMessage(this.getSession(), mailToaddress);
        // 这里需要对协议进行判断，SMTP:为发送协议（初始化Transport）    POP3：则为接收协议（只能初始化Store，在接收邮件章节用到）
        if(this.getMailProtocol().equals(MAIL_PROTOCOL_SMTP)){
            this.transport = this.initTransport(this.getSession());
        }
    }
    
    /**
     * 初始化perps文件
     * @return
     */
    public Properties initPrope() {
        // 初始化props文件
        props = new Properties();
        props.setProperty("mail.transport.protocol", this.getMailProtocol());//发送邮件协议
        props.put("mail.smtp.auth", "true");        //需要验证
        props.put("mail.smtp.host", this.getHostPort());    //服务器地址  
        return props;
    }
    
    /**
     * 初始化session会话
     * @return
     */
    public Session initSession() {
        session = Session.getInstance(this.initPrope(),new MyAuthenricator(username, password));
        session.setDebug(true);
        return session;
    }
    
    /**
     * 初始化Message消息
     * @param session
     * @return
     * @throws MessagingException
     * @throws UnsupportedEncodingException
     */
    public MimeMessage initMessage(Session session, String mailToaddress) throws MessagingException, UnsupportedEncodingException {
        message = new MimeMessage(session);
        
        // 设置发件人地址
        message.setFrom(new InternetAddress(username, "要显示的发件人名称"));
        
        // 设置邮件主题
        message.setSubject("主题：默认主题");
        
        // 设置邮件发送内容和内容的content-type
        message.setContent(content.toString(),this.CONTENT_TYPE_HTML);
        
        // 设置邮件接收人地址
        if(mailToaddress.trim().length() > 0) {
            String [] address = mailToaddress.split(",");
            for(int i=0; i<address.length; i++) {
                // addRecipient（该方法为添加收件人列表，参数一为类型：TO-收件人，CC-抄送，参数二为一个邮件地址）
                message.addRecipient(Message.RecipientType.TO, new InternetAddress(address[i].trim()));
                // 下面方法为传递一个收件地址字符串 （二者方法任选其一即可）
                message.addRecipients(Message.RecipientType.CC, address[i].trim());
            }
        }
        return message;
    }
    
    /**
     * 初始化Transport
     * @param session
     * @return
     * @throws NoSuchProviderException
     */
    public Transport initTransport(Session session) throws NoSuchProviderException {
        transport = session.getTransport(); 
        return transport;
    }
    
    
    /***************** 提供必要的get set方法支持  ************飘逸的分割线****************/
    public Session getSession() {
        return session;
    }

    public void setSession(Session session) {
        this.session = session;
    }

    public MimeMessage getMessage() {
        return message;
    }

    public void setMessage(MimeMessage message) {
        this.message = message;
    }

    public Properties getProps() {
        return props;
    }

    public  String getContentTypeHtml() {
        return CONTENT_TYPE_HTML;
    }

    public static String getMailPort() {
        return MAIL_PORT;
    }

    public String getHostPort() {
        return hostPort;
    }

    public void setHostPort(String hostPort) {
        this.hostPort = hostPort;
    }

    public Transport getTransport() {
        return transport;
    }

    public void setTransport(Transport transport) {
        this.transport = transport;
    }

    public void setProps(Properties props) {
        this.props = props;
    }

    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }

    public String getCONTENT_TYPE_HTML() {
        return CONTENT_TYPE_HTML;
    }

    public static String getMailProtocolSmtp() {
        return MAIL_PROTOCOL_SMTP;
    }

    public static String getMailProtocolPop3() {
        return MAIL_PROTOCOL_POP3;
    }

    public String getMailProtocol() {
        return mailProtocol;
    }

    public void setMailProtocol(String mailProtocol) {
        this.mailProtocol = mailProtocol;
    }
    
    
}

package com.cplatform.movie.back.javamail;

import java.io.File;
import java.io.UnsupportedEncodingException;
import javax.activation.DataHandler;
import javax.activation.FileDataSource;
import javax.mail.BodyPart;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Multipart;
import javax.mail.internet.MimeBodyPart;
import javax.mail.internet.MimeMultipart;

import com.sun.xml.internal.messaging.saaj.packaging.mime.internet.MimeUtility;

/**
 * 邮件发送业务类
 * @author liuyt
 * @date  2014-10-26 上午11:17:45
 */
public class SendEmailService {
    private EmailServiceEnity serviceEnity;
    
    /**
     * 发送HTML内容邮件 （包括TEXT格式）
     * @throws MessagingException 
     */
    public void sendHtmlOrText() throws MessagingException {
        this.send();
    }
    
    /**
     * 附件发送 
     * @param file        java.io.File
     * @param fileName    附件名
     * @throws MessagingException
     * @throws UnsupportedEncodingException
     */
    public void sendFile(File file, String fileName) throws MessagingException, UnsupportedEncodingException {
        // 获得Message实例
        Message message = serviceEnity.getMessage();
        
        // 创建multipart容器用来容纳bodyPart(部件)
        Multipart multipart = new MimeMultipart();
        
        /**
         * 创建一个BodyPart内容报文
         * 每个消息都有多个部分组成，每个部分是一个BodyPart报文部分，多个BodyPart部分又同时组成一个Multipart的容器
         */
        BodyPart messageBodyPart = new MimeBodyPart();
        
        // 设置该报文的内容
        messageBodyPart.setContent(serviceEnity.getContent(),serviceEnity.getCONTENT_TYPE_HTML());
        
        // 添加bodyPart报文部分到multiPart容器
        multipart.addBodyPart(messageBodyPart);

        // 创建一个附件报文
        messageBodyPart = new MimeBodyPart();
        
        // 文件源
        FileDataSource fds = new FileDataSource(file);
        
        // 设置邮件的内含附件 （设置数据源为复件）
        messageBodyPart.setDataHandler(new DataHandler(fds));
        
        // 设置附件的文件名，需进行编码，否则文件名会乱码
        messageBodyPart.setFileName(MimeUtility.encodeText(fileName));
        
        // 添加到容器
        multipart.addBodyPart(messageBodyPart);

        // 添加报文容器到消息实例
        message.setContent(multipart);
        
        // 发送消息
        this.send();
    }
    
    /**
     * 发送
     * 推荐使用方法一，因为方法二如果收件人为多个的话，会为每个人都打开一个Transport通道再关闭
     * 而方法一在发送过程中一直保持连接通常，所有操作完成后才关闭
     * @throws MessagingException
     */
    public void send() throws MessagingException {
        Message message = serviceEnity.getMessage();
        // 方法一
        serviceEnity.getTransport().connect();
        serviceEnity.getTransport().sendMessage(message, message.getAllRecipients());
        serviceEnity.getTransport().close();
        
        // 方法二
        // Transport.send(this.getMessage());
    }
    
    // main 方法测试
    public static void main(String[] args) {
        SendEmailService service;
        EmailServiceEnity enity;
        // 多个收件人中间以逗号间隔
        String mailToaddress = "418874847@qq.com,12450374@qq.com";
        
        // 正文（内容）部分
        String content = "点击进入» <a href=‘http://www.cnblogs.com/liuyitian‘>刘一天的博客</a>";
        
        try {
            service = new SendEmailService();
            enity = new EmailServiceEnity(mailToaddress, content, EmailServiceEnity.MAIL_PROTOCOL_SMTP);
            service.setServiceEnity(enity);
            service.sendHtmlOrText(); // 测试HTML文本
            
            /**
             * 切勿使用同一个EmailServiceEnity实例来发送不同内容，如有需要就再初始化一个新实例(否则附件发送失败且乱码)
             * 因为每个实例在发送完邮件后就会关闭Transport
             */
            enity = new EmailServiceEnity(mailToaddress, content, EmailServiceEnity.MAIL_PROTOCOL_SMTP);
            service.setServiceEnity(enity);
            // 传入一个绝对位置的文件路径
            File file = new File("d:/data/adimg/20141022/09/ad_20141022094708943.jpg");
            service.sendFile(file,"测试附件发送.jpg"); // 测试复件发送
            
        } catch (UnsupportedEncodingException e1) {
            e1.printStackTrace();
        } catch (MessagingException e1) {
            e1.printStackTrace();
        }
    }
    
    public EmailServiceEnity getServiceEnity() {
        return serviceEnity;
    }

    public void setServiceEnity(EmailServiceEnity serviceEnity) {
        this.serviceEnity = serviceEnity;
    }
}

package com.cplatform.movie.back.javamail;

import java.io.DataInputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
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;
    
    public void lookEmail() throws MessagingException, IOException, InterruptedException {
        
        /**
         * 接收邮件时，邮箱的协议为POP3，SMTP为邮件传输协议，这里别搞混了
         * 并且检查你的邮箱设置POP3功能是否开启
         */
        emailService = new EmailServiceEnity("", "",EmailServiceEnity.MAIL_PROTOCOL_POP3);
        
        /**
         *  javax.mail.Store类用于连接邮件接收服务器，并访问邮件接收服务器上的各个邮箱夹
         *  javax.mail.Folder类表示邮件夹
         *  通过一个Session我们可以拿到一个邮箱对应的Store
         */
        Store store = emailService.getSession().getStore(emailService.getMailProtocol());
        store.connect(emailService.getHostPort(), EmailServiceEnity.username, EmailServiceEnity.password);
        
        /**
         *     通过Store拿到收件箱文件夹
         *  INBOX 标识获取到邮件夹里的收件箱  （对于POP3协议仅INBOX可用--蛋疼哦） 
         *  并以只读方式打开收件箱
         */
        Folder folder = store.getFolder("INBOX");
        folder.open(Folder.READ_ONLY);
        
        /**
         * 读取到的邮件是存在Message里面，有不同的获取方法
         * 方法一：获取的是全部邮件，返回一个Message数组
         * 方法二：获取指定条目的邮件（1表示邮箱里面的第一封邮件，也就是最早的一封）
         * 还有很多方法，如起始位置和结束位置......不一一列举
         */
         Message[] messages = folder.getMessages();    // 方法一，得到全部邮件数组
         Message message = folder.getMessage(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("***********************飘逸的分割线*****************************");
         
         // 得到邮件的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();
    }
    
    // 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();
        }
    }
}