文档章节

SpringBoot2.0高级案例(03):集成 JavaMail ,实现异步发送邮件

知了一笑
 知了一笑
发布于 07/16 19:58
字数 1991
阅读 86
收藏 2
本文源码
码云地址:知了一笑
https://gitee.com/cicadasmile/middle-ware-parent

一、JavaMail的核心API

1、API功能图解

2、API说明

(1)、Message 类: javax.mail.Message 类是创建和解析邮件的一个抽象类 子类javax.mail.internet.MimeMessage :表示一份电子邮件。 发送邮件时,首先创建出封装了邮件数据的 Message 对象, 然后把这个对象传递给邮件发送Transport 类,执行发送。 接收邮件时,把接收到的邮件数据封装在Message 类的实例中,从这个对象中解析收到的邮件数据。

(2)、Transport 类 javax.mail.Transport 类是发送邮件的核心API 类 创建好 Message 对象后, 只需要使用邮件发送API 得到 Transport 对象, 然后把 Message 对象传递给 Transport 对象, 并调用它的发送方法, 就可以把邮件发送给指定的邮件服务器。

(3)、Store 类 javax.mail.Store 类是接收邮件的核心 API 类 实例对象代表实现了某个邮件接收协议的邮件接收对象,接收邮件时, 只需要得到 Store 对象, 然后调用 Store 对象的接收方法,就可以从指定的邮件服务器获得邮件数据,并把这些邮件数据封装到表示邮件的 Message 对象中。

(4)、Session 类: javax.mail.Session 类定义邮件服务器的主机名、端口号、协议等 Session 对象根据这些信息构建用于邮件收发的 Transport 和 Store 对象, 以及为客户端创建 Message 对象时提供信息支持。

二、邮件服务器配置

以 smtp 为例

1、smtp.mxhichina.com  
阿里云企业邮箱配置(账号+密码)

2、smtp.aliyun.com
阿里云个人邮箱配置(账号+密码)

3、smtp.163.com
网易邮箱配置(账号+授权码)

三、公共代码块

1、邮件通用配置

package com.email.send.param;
/**
 * 邮箱发送参数配置
 */
public class EmailParam {
    /**
     * 邮箱服务器地址
     */
    // public static final String emailHost = "smtp.mxhichina.com" ; 阿里云企业邮箱配置(账号+密码)
    // public static final String emailHost = "smtp.aliyun.com" ; 阿里云个人邮箱配置(账号+密码)
    public static final String emailHost = "smtp.163.com" ; // 网易邮箱配置(账号+授权码)
    /**
     * 邮箱协议
     */
    public static final String emailProtocol = "smtp" ;
    /**
     * 邮箱发件人
     */
    public static final String emailSender = "xxxxxx@163.com" ;
    /**
     * 邮箱授权码
     */
    public static final String password = "authCode";
    /**
     * 邮箱授权
     */
    public static final String emailAuth = "true" ;
    /**
     * 邮箱昵称
     */
    public static final String emailNick = "知了一笑" ;
}

2、常用常量

package com.email.send.param;
/**
 * 邮件发送类型
 */
public enum EmailType {
	EMAIL_TEXT_KEY("email_text_key", "文本邮件"),
	EMAIL_IMAGE_KEY("email_image_key", "图片邮件"),
	EMAIL_FILE_KEY("email_file_key", "文件邮件");
	private String code;
	private String value;
	EmailType(String code, String value) {
		this.code = code;
		this.value = value;
	}
	public static String getByCode(String code) {
		EmailType[] values = EmailType.values();
		for (EmailType emailType: values) {
			if (emailType.code.equalsIgnoreCase(code)) {
				return emailType.value;
			}
		}
		return null;
	}
	// 省略 get set
}

四、邮件发送封装

1、纯文本邮件发送

(1)、代码封装

/**
 * 邮箱发送模式01:纯文本格式
 */
public static void sendEmail01(String receiver, String title, String body) throws Exception {
	Properties prop = new Properties();
	prop.setProperty("mail.host", EmailParam.emailHost);
	prop.setProperty("mail.transport.protocol", EmailParam.emailProtocol);
	prop.setProperty("mail.smtp.auth", EmailParam.emailAuth);
	//使用JavaMail发送邮件的5个步骤
	//1、创建session
	Session session = Session.getInstance(prop);
	//开启Session的debug模式,这样就可以查看到程序发送Email的运行状态
	session.setDebug(true);
	//2、通过session得到transport对象
	Transport ts = session.getTransport();
	//3、使用邮箱的用户名和密码连上邮件服务器,发送邮件时,发件人需要提交邮箱的用户名和密码给smtp服务器,用户名和密码都通过验证之后才能够正常发送邮件给收件人。
	ts.connect(EmailParam.emailHost, EmailParam.emailSender, EmailParam.password);
	//4、创建邮件
	// Message message = createEmail01(session,receiver,title,body);
	Message message = createEmail01(session, receiver, title, body);
	//5、发送邮件
	ts.sendMessage(message, message.getAllRecipients());
	ts.close();
}
/**
 * 创建文本邮件
 */
private static MimeMessage createEmail01(Session session, String receiver, String title, String body)
throws Exception {
	//创建邮件对象
	MimeMessage message = new MimeMessage(session);
	//指明邮件的发件人
	String nick = javax.mail.internet.MimeUtility.encodeText(EmailParam.emailNick);
	message.setFrom(new InternetAddress(nick + "<" + EmailParam.emailSender + ">"));
	//指明邮件的收件人
	message.setRecipient(Message.RecipientType.TO, new InternetAddress(receiver));
	//邮件的标题
	message.setSubject(title);
	//邮件的文本内容
	message.setContent(body, "text/html;charset=UTF-8");
	//返回创建好的邮件对象
	return message;
}

(2)、执行效果图

2、文本+图片+附件邮件

(1)、代码封装

/**
 * 邮箱发送模式02:复杂格式
 */
public static void sendEmail02(String receiver, String title, String body) throws Exception {
	Properties prop = new Properties();
	prop.setProperty("mail.host", EmailParam.emailHost);
	prop.setProperty("mail.transport.protocol", EmailParam.emailProtocol);
	prop.setProperty("mail.smtp.auth", EmailParam.emailAuth);
	//使用JavaMail发送邮件的5个步骤
	//1、创建session
	Session session = Session.getInstance(prop);
	//开启Session的debug模式,这样就可以查看到程序发送Email的运行状态
	session.setDebug(true);
	//2、通过session得到transport对象
	Transport ts = session.getTransport();
	//3、使用邮箱的用户名和密码连上邮件服务器,发送邮件时,发件人需要提交邮箱的用户名和密码给smtp服务器,用户名和密码都通过验证之后才能够正常发送邮件给收件人。
	ts.connect(EmailParam.emailHost, EmailParam.emailSender, EmailParam.password);
	//4、创建邮件
	// Message message = createEmail01(session,receiver,title,body);
	Message message = createEmail02(session, receiver, title, body);
	//5、发送邮件
	ts.sendMessage(message, message.getAllRecipients());
	ts.close();
}
private static MimeMessage createEmail02(Session session, String receiver, String title, String body)
throws Exception {
	//创建邮件对象
	MimeMessage message = new MimeMessage(session);
	//指明邮件的发件人
	String nick = javax.mail.internet.MimeUtility.encodeText(EmailParam.emailNick);
	message.setFrom(new InternetAddress(nick + "<" + EmailParam.emailSender + ">"));
	//指明邮件的收件人
	message.setRecipient(Message.RecipientType.TO, new InternetAddress(receiver));
	//邮件的标题
	message.setSubject(title);
	//文本内容
	MimeBodyPart text = new MimeBodyPart();
	text.setContent(body, "text/html;charset=UTF-8");
	//图片内容
	MimeBodyPart image = new MimeBodyPart();
	image.setDataHandler(new DataHandler(new FileDataSource("ware-email-send/src/gzh.jpg")));
	image.setContentID("gzh.jpg");
	//附件内容
	MimeBodyPart attach = new MimeBodyPart();
	DataHandler file = new DataHandler(new FileDataSource("ware-email-send/src/gzh.zip"));
	attach.setDataHandler(file);
	attach.setFileName(file.getName());
	//关系:正文和图片
	MimeMultipart multipart1 = new MimeMultipart();
	multipart1.addBodyPart(text);
	multipart1.addBodyPart(image);
	multipart1.setSubType("related");
	//关系:正文和附件
	MimeMultipart multipart2 = new MimeMultipart();
	multipart2.addBodyPart(attach);
	// 全文内容
	MimeBodyPart content = new MimeBodyPart();
	content.setContent(multipart1);
	multipart2.addBodyPart(content);
	multipart2.setSubType("mixed");
	// 封装 MimeMessage 对象
	message.setContent(multipart2);
	message.saveChanges();
	// 本地查看文件格式
	message.writeTo(new FileOutputStream("F:\\MixedMail.eml"));
	//返回创建好的邮件对象
	return message;
}

(2)、执行效果

3、实现异步发送

(1)、配置异步执行线程

package com.email.send.util;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;
/**
 * 定义异步任务执行线程池
 */
@Configuration
public class TaskPoolConfig {
    @Bean("taskExecutor")
    public Executor taskExecutor () {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 核心线程数10:线程池创建时候初始化的线程数
        executor.setCorePoolSize(10);
        // 最大线程数20:线程池最大的线程数,只有在缓冲队列满了之后才会申请超过核心线程数的线程
        executor.setMaxPoolSize(15);
        // 缓冲队列200:用来缓冲执行任务的队列
        executor.setQueueCapacity(200);
        // 允许线程的空闲时间60秒:当超过了核心线程数之外的线程在空闲时间到达之后会被销毁
        executor.setKeepAliveSeconds(60);
        // 线程池名的前缀:设置好了之后可以方便定位处理任务所在的线程池
        executor.setThreadNamePrefix("taskExecutor-");
        /*
        线程池对拒绝任务的处理策略:这里采用了CallerRunsPolicy策略,
        当线程池没有处理能力的时候,该策略会直接在 execute 方法的调用线程中运行被拒绝的任务;
        如果执行程序已关闭,则会丢弃该任务
         */
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        // 设置线程池关闭的时候等待所有任务都完成再继续销毁其他的Bean
        executor.setWaitForTasksToCompleteOnShutdown(true);
        // 设置线程池中任务的等待时间,如果超过这个时候还没有销毁就强制销毁,以确保应用最后能够被关闭,而不是阻塞住。
        executor.setAwaitTerminationSeconds(600);
        return executor;
    }
}

(2)、业务方法使用

注意两个注解 @Component @Async("taskExecutor")

@Component
@Service
public class EmailServiceImpl implements EmailService {
    @Async("taskExecutor")
    @Override
    public void sendEmail(String emailKey, SendEmailModel model) {
        try{
            // 异步执行
            Thread.sleep(1000);
            String textBody = EmailUtil.convertTextModel(BodyType.getByCode(emailKey),"知了","一笑");
            // 发送文本邮件
            EmailUtil.sendEmail01(model.getReceiver(), EmailType.getByCode(emailKey),textBody);
            // 发送复杂邮件:文本+图片+附件
            String body = "自定义图片:<img src="cid:gzh.jpg">,网络图片:<img src="https://oscimg.oschina.net/oscnet/8800276_184927469000_2.png">";
            // EmailUtil.sendEmail02(model.getReceiver(),"文本+图片+附件",body);
        } catch (Exception e){
            e.printStackTrace();
        }

    }
}

(3)、启动类注解

@EnableAsync

@EnableAsync
@SpringBootApplication
public class EmailApplication {
    public static void main(String[] args) {
        SpringApplication.run(EmailApplication.class,args) ;
    }
}

五、源代码地址

GitHub地址:知了一笑
https://github.com/cicadasmile/middle-ware-parent
码云地址:知了一笑
https://gitee.com/cicadasmile/middle-ware-parent

© 著作权归作者所有

知了一笑

知了一笑

粉丝 111
博文 45
码字总数 44492
作品 0
杭州
私信 提问
刚刚学习到的Android使用Javamail通过XOauth调用Gmail API发送邮件的方法

前景知识:OAuth,Javamail-android,Javamail api in android using XOauth 我的一个App项目需要在Service中自动发送邮件的功能,因为是后台自动发送邮件,不能出现邮件UI所以需要使用Javam...

since1986
2014/04/12
783
0
邮件发送失败:Mail server connection failed; 501 Syntax: HELO hostname

出现这个问题,是系统利用javamail组件发送邮件,Javamail在提取本地hostname的时候会dig 改hostname,然后以改ip发送邮件。 由于hostname对应的ip地址,linux无法解析(如果是windows则无这...

红薯
2011/10/13
1K
0
通过JavaMail访问Hotmail邮箱

相信许多人都有MSN聊天工具的帐号,例如abc@hotmail.com ,这个账号其实也是一个邮件地址,可以进行正常的邮件收发功能,你可以通过网址 http://www.hotmail.com 来访问和操作这个邮箱进行邮...

红薯
2008/10/05
2.7K
7
Android发送email(不用javamail)

学习android开发中…… 看了一些发送email的方法,不调用的话基本就都是用的javamail 可是我在实际验证过程中发现javamail好像和android并不很兼容呢,2.2都没有问题,再高就各种bug 大神们能...

garfieldo
2014/05/13
414
0
JavaMail(JAVA邮件服务) API详解

一、JavaMail API简介 JavaMail API是读取、撰写、发送电子信息的可选包。我们可用它来建立如Eudora、Foxmail、MS Outlook Express一般的邮件用户代理程序(Mail User Agent,简称MUA)。而不...

唏嘘猪肉佬
2015/05/21
449
0

没有更多内容

加载失败,请刷新页面

加载更多

spring cloud

一、从面试题入手 1.1、什么事微服务 1.2、微服务之间如何独立通讯的 1.3、springCloud和Dubbo有哪些区别 1.通信机制:DUbbo基于RPC远程过程调用;微服务cloud基于http restFUL API 1.4、spr...

榴莲黑芝麻糊
36分钟前
2
0
Executor线程池原理与源码解读

线程池为线程生命周期的开销和资源不足问题提供了解决方 案。通过对多个任务重用线程,线程创建的开销被分摊到了多个任务上。 线程实现方式 Thread、Runnable、Callable //实现Runnable接口的...

小强的进阶之路
昨天
6
0
maven 环境隔离

解决问题 即 在 resource 文件夹下面 ,新增对应的资源配置文件夹,对应 开发,测试,生产的不同的配置内容 <resources> <resource> <directory>src/main/resources.${deplo......

之渊
昨天
8
0
详解箭头函数和普通函数的区别以及箭头函数的注意事项、不适用场景

箭头函数是ES6的API,相信很多人都知道,因为其语法上相对于普通函数更简洁,深受大家的喜爱。就是这种我们日常开发中一直在使用的API,大部分同学却对它的了解程度还是不够深... 普通函数和...

OBKoro1
昨天
7
0
轻量级 HTTP(s) 代理 TinyProxy

CentOS 下安装 TinyProxy yum install -y tinyproxy 启动、停止、重启 # 启动service tinyproxy start# 停止service tinyproxy stop# 重启service tinyproxy restart 相关配置 默认...

Anoyi
昨天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部