备案控制台
开发者社区 安全 文章 正文

springboot发邮件，javaxmail收邮件功能

2022-11-06 236
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： springboot发邮件，javaxmail收邮件功能

​
import com.sun.mail.imap.IMAPFolder;
import com.sun.mail.imap.protocol.IMAPProtocol;
import org.apache.tomcat.util.http.fileupload.IOUtils;
import org.springframework.util.ObjectUtils;

import javax.mail.*;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import javax.mail.internet.MimeUtility;
import java.io.*;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;

public class ReceivedIMAPMail {

public static String NORM_DATETIME_PATTERN = "yyyy-MM-dd hh:mm:ss";

private MimeMessage mimeMessage;
/**
 * 附件下载后的存放目录
 */
private String saveAttachPath = "";
/**
 * 存放邮件内容的StringBuffer对象
 */
private StringBuffer bodyText = new StringBuffer();

/**
 * 构造函数,初始化一个MimeMessage对象
 *
 * @param mimeMessage
 */
public ReceivedIMAPMail(MimeMessage mimeMessage) {
    this.mimeMessage = mimeMessage;
}

/**
 * 获得发件人的地址和姓名
 *
 * @return
 * @throws MessagingException
 */
public String getFrom() throws MessagingException {
    InternetAddress address[] = (InternetAddress[]) mimeMessage.getFrom();
    String from = address[0].getAddress();
    if (from == null) {
        from = "";
    }
    String personal = address[0].getPersonal();

    if (personal == null) {
        personal = "";
    }

    String fromAddr = null;
    if (personal != null || from != null) {
        fromAddr = personal + "<" + from + ">";
    }
    return fromAddr;
}

/**
 * 获得邮件的收件人，抄送，和密送的地址和姓名，根据所传递的参数的不同
 *
 * @param type "to"----收件人 "cc"---抄送人地址 "bcc"---密送人地址
 * @return
 * @throws MessagingException
 * @throws UnsupportedEncodingException
 */
public String getMailAddress(String type) throws MessagingException, UnsupportedEncodingException {
    if (ObjectUtils.isEmpty(type)) {
        return "";
    }

    String addType = type.toUpperCase();

    if (!addType.equals("TO") && !addType.equals("CC") && !addType.equals("BCC")) {
        return "";
    }
    InternetAddress[] address;

    if (addType.equals("TO")) {
        address = (InternetAddress[]) mimeMessage.getRecipients(Message.RecipientType.TO);
    } else if (addType.equals("CC")) {
        address = (InternetAddress[]) mimeMessage.getRecipients(Message.RecipientType.CC);
    } else {
        address = (InternetAddress[]) mimeMessage.getRecipients(Message.RecipientType.BCC);
    }

    if (ObjectUtils.isEmpty(address)) {
        return "";
    }
    StringBuilder mailAddr = new StringBuilder();
    String emailAddr;
    String personal;
    for (int i = 0; i < address.length; i++) {
        emailAddr = address[i].getAddress();
        if (emailAddr == null) {
            emailAddr = "";
        } else {
            emailAddr = MimeUtility.decodeText(emailAddr);
        }
        personal = address[i].getPersonal();
        if (personal == null) {
            personal = "";
        } else {
            personal = MimeUtility.decodeText(personal);
        }
        mailAddr.append(",").append(personal).append("<").append(emailAddr).append(">");
    }
    return mailAddr.toString().substring(1);
}

/**
 * 获得邮件主题
 *
 * @return
 * @throws MessagingException
 * @throws UnsupportedEncodingException
 */
public String getSubject() throws MessagingException, UnsupportedEncodingException {
    String subject = MimeUtility.decodeText(mimeMessage.getSubject());
    if (subject == null) {
        subject = "";
    }
    return subject;
}

/**
 * 获得邮件发送日期
 *
 * @return
 * @throws MessagingException
 */
public String getSentDate() throws MessagingException {
    Date sentDate = mimeMessage.getSentDate();
    SimpleDateFormat format = new SimpleDateFormat(NORM_DATETIME_PATTERN);
    return format.format(sentDate);
}

/**
 * 获得邮件正文内容
 *
 * @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;
    }

    if (part.isMimeType("text/plain") && conName == false) {
        bodyText.append((String) part.getContent());
    } else if (part.isMimeType("text/html") && conName == false) {
        bodyText.append((String) part.getContent());
    } else if (part.isMimeType("multipart/*")) {
        Multipart multipart = (Multipart) part.getContent();
        int counts = multipart.getCount();
        for (int i = 0; i < counts; i++) {
            this.getMailContent(multipart.getBodyPart(i));
        }
    } else if (part.isMimeType("message/rfc822")) {
        this.getMailContent((Part) part.getContent());
    }
}

/**
 * 判断此邮件是否需要回执，如果需要回执返回"true",否则返回"false"
 *
 * @return
 * @throws MessagingException
 */
public boolean getReplySign() throws MessagingException {

    boolean replySign = false;

    String needReply[] = mimeMessage.getHeader("Disposition-Notification-To");

    if (needReply != null) {
        replySign = true;
    }
    return replySign;
}

/**
 * 判断此邮件是否已读，如果未读返回false,反之返回true
 *
 * @return
 * @throws MessagingException
 */
public boolean isNew() throws MessagingException {
    boolean isNew = false;
    Flags flags = mimeMessage.getFlags();
    Flags.Flag[] flag = flags.getSystemFlags();
    for (int i = 0; i < flag.length; i++) {
        if (flag[i] == Flags.Flag.SEEN) {
            isNew = true;
        }
    }
    return isNew;
}

/**
 * 判断此邮件是否包含附件
 *
 * @param part
 * @return
 * @throws MessagingException
 * @throws IOException
 */
public boolean isContainAttach(Part part) throws MessagingException, IOException {
    boolean attachFlag = false;
    if (part.isMimeType("multipart/*")) {
        Multipart mp = (Multipart) part.getContent();
        BodyPart mPart;
        String conType;
        for (int i = 0; i < mp.getCount(); i++) {
            mPart = mp.getBodyPart(i);
            String disposition = mPart.getDisposition();
            if (Part.ATTACHMENT.equals(disposition) || Part.INLINE.equals(disposition)) {
                attachFlag = true;
            } else if (mPart.isMimeType("multipart/*")) {
                attachFlag = this.isContainAttach(mPart);
            } else {
                conType = mPart.getContentType();
                if (conType.toLowerCase().indexOf("application") != -1
                        || conType.toLowerCase().indexOf("name") != -1) {
                    attachFlag = true;
                }
            }
        }
    } else if (part.isMimeType("message/rfc822")) {
        attachFlag = isContainAttach((Part) part.getContent());
    }
    return attachFlag;
}

/**
 * 保存附件
 *
 * @param part
 * @throws MessagingException
 * @throws IOException
 */
public void saveAttachMent(Part part) throws MessagingException, IOException {
    String fileName;
    if (part.isMimeType("multipart/*")) {
        Multipart mp = (Multipart) part.getContent();
        BodyPart mPart;
        for (int i = 0; i < mp.getCount(); i++) {
            mPart = mp.getBodyPart(i);
            String disposition = mPart.getDisposition();
            if (Part.ATTACHMENT.equals(disposition) || Part.INLINE.equals(disposition)) {
                fileName = mPart.getFileName();
                if (null != fileName && fileName.toLowerCase().indexOf("gb2312") != -1) {
                    fileName = MimeUtility.decodeText(fileName);
                }
                fileName = fileName.replaceAll("\\?|=", "");
                this.saveFile(fileName, mPart.getInputStream());
            } else if (mPart.isMimeType("multipart/*")) {
                this.saveAttachMent(mPart);
            } else {
                fileName = mPart.getFileName();
                if ((fileName != null) && (fileName.toLowerCase().indexOf("GB2312") != -1)) {
                    fileName = MimeUtility.decodeText(fileName);
                    this.saveFile(fileName, mPart.getInputStream());
                }
            }
        }
    } else if (part.isMimeType("message/rfc822")) {
        this.saveAttachMent((Part) part.getContent());
    }
}

/**
 * 设置附件存放路径
 *
 * @param attachPath
 */
public void setAttachPath(String attachPath) {
    this.saveAttachPath = attachPath;
}

/**
 * 获得附件存放路径
 *
 * @return
 */
public String getAttachPath() {
    return saveAttachPath;
}

/**
 * 真正的保存附件到指定目录里
 *
 * @param fileName
 * @param in
 * @throws IOException
 */
private void saveFile(String fileName, InputStream in) throws IOException {
    String osName = System.getProperty("os.name");
    String storeDir = this.getAttachPath();
    if (null == osName) {
        osName = "";
    }
    if (osName.toLowerCase().indexOf("win") != -1) {
        if (ObjectUtils.isEmpty(storeDir))
            storeDir = "C:\\tmp";
    } else {
        storeDir = "/tmp";
    }
    FileOutputStream fos = new FileOutputStream(new File(storeDir + File.separator + fileName));
    IOUtils.copy(in, fos);
    IOUtils.closeQuietly(fos);
    IOUtils.closeQuietly(in);
}

/**
 * 获取阿里云邮箱信息
 *
 * @param host     邮件服务器
 * @param username 邮箱名
 * @param password 密码
 * @param protocol 协议
 * @return
 * @throws MessagingException
 */
public static Message[] getALiYunMessage(String host, String username, String password, String protocol)
        throws MessagingException {
    Properties props = new Properties();
    Session session = Session.getDefaultInstance(props, null);

    Store store = session.getStore(protocol);
    store.connect(host, username, password);

    Folder folder = store.getFolder("INBOX");
    folder.open(Folder.READ_ONLY);
    return folder.getMessages();
}

/**
 * 获取163邮箱信息
 *
 * @param host
 * @param username
 * @param password
 * @param protocol
 * @return
 * @throws MessagingException
 */
public static Message[] getWEMessage(String host, String username, String password, String protocol)
        throws MessagingException {
    Properties props = System.getProperties();
    props.setProperty("mail.store.protocol", protocol);
    Session session = Session.getDefaultInstance(props, null);
    Store store = session.getStore(protocol);
    store.connect(host, username, password);
    Folder folder = store.getFolder("INBOX");

    if (folder instanceof IMAPFolder) {
        IMAPFolder imapFolder = (IMAPFolder) folder;
        // javamail中使用id命令有校验checkOpened, 所以要去掉id方法中的checkOpened();
        imapFolder.doCommand(new IMAPFolder.ProtocolCommand() {
            public Object doCommand(IMAPProtocol p) throws com.sun.mail.iap.ProtocolException {
                Map<String, String> gmap = new HashMap<>();
                gmap.put("GUID", "FUTONG");
                // p.id("FUTONG");
                p.id(gmap);
                return null;
            }
        });
    }

    if (folder != null) {
        folder.open(Folder.READ_WRITE);
    }

    return folder.getMessages();
}

/**
 * 过滤邮箱信息
 *
 * @param messages
 * @param fromMail  只读取该邮箱发来的邮件，如果为空则不过滤
 * @param startDate 只读取该日期以后的邮件，如果为空则不过滤
 * @return
 * @throws MessagingException
 */
public static List<Message> filterMessage(Message[] messages, String fromMail, String startDate)
        throws MessagingException, ParseException {
    List<Message> messageList = new ArrayList<>();
    if (ObjectUtils.isEmpty(messages)) {
        return messageList;
    }
    boolean isEnptyFromMail = ObjectUtils.isEmpty(fromMail);
    boolean isEnptyStartDate = ObjectUtils.isEmpty(startDate);
    if (isEnptyFromMail && isEnptyStartDate) {
        return Arrays.asList(messages);
    }

    String from;
    for (Message message : messages) {
        from = (message.getFrom()[0]).toString();
        if (isEnptyFromMail) {
            if (new SimpleDateFormat(NORM_DATETIME_PATTERN).parse(startDate).getTime() > message.getSentDate()
                    .getTime()) {
                continue;
            }
        } else if (null != from && from.contains(fromMail)) {
            if (!isEnptyStartDate && new SimpleDateFormat(NORM_DATETIME_PATTERN).parse(startDate)
                    .getTime() > message.getSentDate().getTime()) {
                continue;
            }
        } else {
            continue;
        }
        messageList.add(message);
    }
    return messageList;
}

/**
 * 打印邮件
 *
 * @param messageList
 * @throws IOException
 * @throws MessagingException
 */
public static void printMailMessage(List<Message> messageList) throws IOException, MessagingException {
    System.out.println("邮件数量:" + messageList.size());
    ReceivedIMAPMail re;
    Message message;
    for (int i = 0, leng = messageList.size(); i < leng; i++) {
        message = messageList.get(i);
        re = new ReceivedIMAPMail((MimeMessage) message);
        System.out.println("邮件【" + i + "】主题:" + re.getSubject());
        System.out.println("邮件【" + i + "】发送时间:" + re.getSentDate());
        System.out.println("邮件【" + i + "】是否需要回复:" + re.getReplySign());
        System.out.println("邮件【" + i + "】是否已读:" + re.isNew());
        System.out.println("邮件【" + i + "】是否包含附件:" + re.isContainAttach(message));
        System.out.println("邮件【" + i + "】发送人地址:" + re.getFrom());
        System.out.println("邮件【" + i + "】收信人地址:" + re.getMailAddress("to"));
        System.out.println("邮件【" + i + "】抄送:" + re.getMailAddress("cc"));
        System.out.println("邮件【" + i + "】暗抄:" + re.getMailAddress("bcc"));
        System.out.println("邮件【" + i + "】发送时间:" + re.getSentDate());
        System.out.println("邮件【" + i + "】邮件ID:" + ((MimeMessage) message).getMessageID());
        re.getMailContent(message);
        // System.out.println("邮件【" + i + "】正文内容:\r\n" + re.getBodyText());
        if(re.isContainAttach(message)) {
            System.out.println("邮件包含附件，开始下载到D:\\xl下面");
            re.setAttachPath("D:\\xl\\mail\\");
            re.saveAttachMent(message);
        }
    }
}

public static void main(String[] args) throws MessagingException, IOException, ParseException {
    // 阿里云登录信息

// String host = "pop3.mxhichina.com";
// String username = "liwei@xiaostudy.com";
// String password = "密码";
// String protocol = "pop3";
// String fromMail = "XXX@163.com";
// String startDate = "2020-2-24 23:35:40";
// List messageList = filterMessage(getALiYunMessage(host, username, password, protocol), fromMail, startDate);

    // 163登录信息
    String host = "imap.163.com";
    String username = "*****@163.com";
    String password = "客户端授权码";
    String protocol = "imaps";
    String fromMail = "";// "****@163.com";
    String startDate = "";// "2020-2-24 23:35:40";
    List<Message> messageList = filterMessage(getWEMessage(host, username, password, protocol), fromMail,
            startDate);

    printMailMessage(messageList);
}

}

​

文章标签：
Java
数据安全/隐私保护
关键词：
Spring Boot功能
Spring Boot邮件功能
Spring Boot邮件
springboot功能
技能实验室
目录
相关文章
喜欢猪猪
|
5天前
|
存储 Java 分布式数据库
Spring Boot 优雅实现hbase功能
【6月更文挑战第24天】要在 Spring Boot 项目中实现 HBase 和 Memcached 的功能，首先需要理解各自的原理和作用，然后通过实际操作将其集成到 Spring Boot 项目中。
喜欢猪猪
25 6
多多!
|
5天前
|
Java 应用服务中间件 Maven
Springboot入门基础知识详解 parent starter 引导类 辅助功能
Springboot入门基础知识详解 parent starter 引导类 辅助功能
多多!
13 2
青欢
|
9天前
|
安全 Java Maven
在 Spring Boot 中实现邮件发送功能可以通过集成 Spring Boot 提供的邮件发送支持来完成
在 Spring Boot 中实现邮件发送功能可以通过集成 Spring Boot 提供的邮件发送支持来完成
青欢
17 2
青欢
|
9天前
|
缓存 监控 安全
在 Spring Boot 中使用 AOP（Aspect-Oriented Programming）实现日志记录功能
在 Spring Boot 中使用 AOP（Aspect-Oriented Programming）实现日志记录功能
青欢
19 1
weixin_836869520
|
1天前
|
缓存 NoSQL Java
Spring Boot中集成Redis实现缓存功能
Spring Boot中集成Redis实现缓存功能
weixin_836869520
5 0
喜欢猪猪
|
1天前
|
XML 负载均衡 Java
Spring Boot 中实现负载均衡：概念、功能与实现
【6月更文挑战第28天】在分布式系统中，负载均衡（Load Balancing）是指将工作负载和流量分配到多个服务器或服务实例上，以提高系统可用性和响应速度。负载均衡器可以是硬件设备，也可以是软件解决方案。
喜欢猪猪
6 0
泥腿子架构师
|
1天前
|
Java 机器人 程序员
Spring Boot中如何实现邮件发送功能
Spring Boot中如何实现邮件发送功能
泥腿子架构师
5 0
公众号:码到三十五
|
2天前
|
Java Spring 容器
在Spring Boot中实现类似SPI机制的功能（二）
在Spring Boot中实现类似SPI机制的功能（二）
公众号:码到三十五
9 0
米诺斯
|
4天前
|
Java
springboot使用邮件服务
springboot使用邮件服务
米诺斯
11 0
多多!
|
5天前
|
Java 数据安全/隐私保护
Springboot拓展之整合邮件 JavaMail的使用与实操
Springboot拓展之整合邮件 JavaMail的使用与实操
多多!
5 0

热门文章

最新文章

  • 1
    Springboot项目打war包部署到外置tomcat容器【详解版】
  • 2
    Springboot整合与使用log4j2日志框架【详解版】
  • 3
    Spring Boot优雅实现多租户架构：概念与实战
  • 4
    Spring Boot集成支付宝支付：概念与实战
  • 5
    Spring Boot 整合 LiteFlow 规则引擎：概念与实战
  • 6
    springboot业务开发--springboot集成redis解决缓存雪崩穿透问题
  • 7
    Spring Boot多数据源及事务管理：概念与实战
  • 8
    从前端Vue到后端Spring Boot：接收JSON数据的正确姿势
  • 9
    SpringBoot + Tess4J 实现本地与远程图片处理
  • 10
    SpringBoot-Starter 概念与实战
  • 1
    基于SpringBoot+HTML实现登录注册功能模块
    193
  • 2
    基于 java + Springboot + vue +mysql 大学生实习管理系统（含源码）
    257
  • 3
    【Java】仓库管理系统 SpringBoot+LayUI+DTree（源码）【独一无二】
    62
  • 4
    SpringBoot集成Redis解决表单重复提交接口幂等（亲测可用）
    420
  • 5
    SpringBoot项目调用HTTP接口5种方式你了解多少？
    163
  • 6
    6个SpringBoot 项目拿来就可以学习项目经验接私活
    54
  • 7
    Springboot启动的时候初始化的线程池默认配置tomcat
    38
  • 8
    SpringBoot+async异步调用接口以及几个任务同时完成和异步接口实现和调用
    46
  • 9
    SpringBoot实现多线程定时任务动态定时任务配置文件配置定时任务
    322
  • 10
    SpringBoot中静态类使用配置文件经常遇到读取为NULL的情况，现在我就告诉大家。
    25

    • 相关课程

    更多
  • SpringBoot快速掌握 - 核心技术
  • SpringBoot快速掌握 - 高级应用
  • Java Web开发系列课程 - Spring框架入门
  • Spring Boot 2.5.x开发实战
  • Springboot项目云开发快速迁移
  • Spring Cloud微服务架构设计与开发实战

    • 相关电子书

    更多
  • 云栖社区特邀专家徐雷Java Spring Boot开发实战系列课程（第20讲）：经典面试题与阿里等名企内部招聘求职面试技巧
  • 微服务架构模式与原理Spring Cloud开发实战
  • 阿里特邀专家徐雷Java Spring Boot开发实战系列课程（第18讲）：制作Java Docker镜像与推送到DockerHub和阿里云Docker仓库

    • 相关实验场景

    更多
  • 从零搭建Spring Boot的Hello World
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）