SpringBoot笔记7:使用JavaMail结合RabbitMQ发送邮件
一、建立邮件消息生产者：Email-Server-Producer工程
该工程负责使用RabbitMQ将邮件消息发送到RabbitMQ服务器中html
- 在工程的pom.xml中添加相关依赖jar
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.springboot</groupId> <artifactId>email-server-producer</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>email-server-producer</name> <description>Demo project for Spring Boot</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.4.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.31</version> </dependency> <!--amqp 依赖--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> <!--指定项目jdk编译版本和编码方式--> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <version>3.1</version> <configuration> <source>1.8</source> <target>1.8</target> <encoding>UTF-8</encoding> </configuration> </plugin> </plugins> </build> <!--设置maven 仓库为阿里云提供的maven仓库 国外的maven仓库慢--> <repositories> <repository> <id>nexus-aliyun</id> <name>Nexus aliyun</name> <url>http://maven.aliyun.com/nexus/content/groups/public</url> </repository> </repositories> </project>
- 在application.properties文件中添加rabbitmq的链接配置信息
# RabbitMQ 链接配置 spring.rabbitmq.host=localhost spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest
- 建立RabbitMQConfig类
package com.springboot.config;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.core.env.Environment;
/**
* Created by Administrator on 2017/7/3.
*/
@Configuration
public class RabbitMQConfig {
public static final String QUENE_NAME="email_queue";//队列名称
public static final String EXCHANGE="email_exchange";//交换器名称
public static final String ROUTEKEY="email_routekey";
@Autowired
private Environment env;
@Bean
Queue queue() {//队列
String name =QUENE_NAME;
// 是否持久化
boolean durable = true;
// 仅建立者能够使用的私有队列，断开后自动删除
boolean exclusive = false;
// 当全部消费客户端链接断开后，是否自动删除队列
boolean autoDelete = false;
return new Queue(name, durable, exclusive, autoDelete);
}
@Bean
TopicExchange exchange() {//交换器
String name = EXCHANGE;
// 是否持久化
boolean durable = true;
// 当全部消费客户端链接断开后，是否自动删除队列
boolean autoDelete = false;
return new TopicExchange(name, durable, autoDelete);
}
@Bean
Binding binding() {//绑定
return BindingBuilder.bind(queue()).to(exchange()).with(ROUTEKEY);
}
}
- 建立EmailService接口，定义发送邮件消息
public interface EmailService {
/**
* 发送邮件任务存入消息队列
* @param message
* @throws Exception
*/
void sendEmailMsg(String message) throws Exception;
}
- 建立实现EmailService接口的实现类，实现发送邮件消息的接口
@Service
public class EmailServiceImpl implements EmailService{
private static Logger logger = LoggerFactory.getLogger(EmailServiceImpl.class);
@Autowired
private AmqpTemplate rabbitTemplate;
/**
* 发送邮件任务存入消息队列
*
* @param message
* @throws Exception
*/
@Override
public void sendEmailMsg(String message) throws Exception {
logger.info("邮件发送成功");
rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE,RabbitMQConfig.ROUTEKEY,message);
}
}
以上几步便可完成一个向RabbitMQ发送邮件消息的功能，此工程只负责向消息服务器发送消息。java
- 发送消息测试
@RunWith(SpringRunner.class)
@SpringBootTest
public class EmailServiceImplTest {
@Autowired
EmailService emailService;
@Test
public void sendEmailMsg() throws Exception {
Email email=new Email("邮件内容","hgwangxianhong@163.com","邮件主题");
emailService.sendEmailMsg(JSON.toJSONString(email));
}
}
二、建立邮件消息消费者：Email-Server-Consumer工程
此工程负责消费消息，而后使用javamail发送邮件web
- 在工程的pom.xml中添加相关依赖jar
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.springboot</groupId> <artifactId>email-server-consumer</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>email-server-consumer</name> <description>Demo project for Spring Boot</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.4.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.31</version> </dependency> <!--amqp 依赖--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-mail</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> <!--指定项目jdk编译版本和编码方式--> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <version>3.1</version> <configuration> <source>1.8</source> <target>1.8</target> <encoding>UTF-8</encoding> </configuration> </plugin> </plugins> </build> <!--设置maven 仓库为阿里云提供的maven仓库 国外的maven仓库慢--> <repositories> <repository> <id>nexus-aliyun</id> <name>Nexus aliyun</name> <url>http://maven.aliyun.com/nexus/content/groups/public</url> </repository> </repositories> </project>
- 在application.properties文件中添加rabbitmq的链接配置信息和邮件配置
# RabbitMQ 链接配置 spring.rabbitmq.host=localhost spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest #邮件发送人配置 spring.mail.host=smtp.qq.com spring.mail.username=邮箱帐号 spring.mail.password=邮箱登陆密码 spring.mail.properties.mail.smtp.auth=true spring.mail.properties.mail.smtp.starttls.enable=true spring.mail.properties.mail.smtp.starttls.required=true
- 建立RabbitMQConfig类
@Configuration
public class RabbitMQConfig {
public static final String QUENE_NAME="email_queue";//队列名称
@Bean
Queue queue() {//队列
return new Queue(QUENE_NAME);
}
}
- 建立邮件发送接口EmailService
public interface EmailService {
/**
* 发送纯文本邮件
* @param text 邮件文本
* @param to 接收人的邮箱
* @param subject 邮件主题
*/
void sendTextEmail(String text,String to,String subject);
/**
* 发送网页邮件
* @param html 网页
* @param to 接收人的邮箱
* @param subject 邮件主题
*/
void sendHtmlEmail(String html,String to,String subject);
/**
* 发送附件的邮件
* @param to 接收人的邮箱
* @param subject 邮件主题
* @param subject 邮件主题
* @param files 附件的文件地址 c:xxx.jpg
*/
void sendAttachmentsMail(String to,String subject,String text,String ... files);
/**
* 接收rabbitmq的邮件消息
* @param message
*/
void listenerEmailMsg(String message);
}
- 建立邮件发送接口EmailService的实现类
@Service
@RabbitListener(queues = RabbitMQConfig.QUENE_NAME)
public class EmailServiceImpl implements EmailService{
private static Logger logger = LoggerFactory.getLogger(EmailServiceImpl.class);
@Autowired
private JavaMailSender javaMailSender;
@Autowired
MailProperties mailProperties;
/**
* 发送纯文本邮件
*
* @param text 邮件文本
* @param to 接收人的邮箱
* @param subject 邮件主题
*/
@Override
public void sendTextEmail(String text, String to, String subject) {
SimpleMailMessage simpleMailMessage = new SimpleMailMessage();
simpleMailMessage.setSubject("主题：简单邮件");
simpleMailMessage.setText(text);
simpleMailMessage.setFrom(mailProperties.getUsername());
simpleMailMessage.setTo(to);
javaMailSender.send(simpleMailMessage);
}
/**
* 发送网页邮件
*
* @param html 网页
* @param to 接收人的邮箱
* @param subject 邮件主题
*/
@Override
public void sendHtmlEmail(String html, String to, String subject) {
MimeMessage mimeMessage = javaMailSender.createMimeMessage();
try {
MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, true);
helper.setFrom(mailProperties.getUsername());
helper.setTo(to);
helper.setSubject(subject);
// "<html><body><img src='http://baidu.com/2/1.jpg' ></body></html>"
helper.setText(html, true);
} catch (MessagingException e) {
e.printStackTrace();
}
javaMailSender.send(mimeMessage);
}
/**
* 发送附件的邮件
*
* @param to 接收人的邮箱
* @param subject 邮件主题
* @param text 邮件文本
* @param files 附件的文件地址 c:xxx.jpg
*/
@Override
public void sendAttachmentsMail(String to, String subject,String text, String... files) {
try {
MimeMessage mimeMessage = javaMailSender.createMimeMessage();
MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, true);
helper.setFrom(mailProperties.getUsername());
helper.setTo(to);
helper.setSubject(subject);
helper.setText(text);
if (files!=null){
for (String f:files){
FileSystemResource file = new FileSystemResource(new File(f));
helper.addAttachment("附件-1.jpg", file);
helper.addAttachment("附件-2.jpg", file);
}
}
javaMailSender.send(mimeMessage);
} catch (MessagingException e) {
e.printStackTrace();
} finally {
}
}
/**
* 接收rabbitmq的邮件消息
*
* @param message
*/
@Override
@RabbitHandler
public void listenerEmailMsg(String message) {
try {
Email email= JSON.parseObject(message,Email.class);
logger.info("接收到RabbitMQ的消息："+message);
// sendTextEmail(email.getText(),email.getTo(),email.getSubject());
} catch (Exception e) {
e.printStackTrace();
}
}
}
在实现类上加了@RabbitListener(queues = RabbitMQConfig.QUENE_NAME) 注解，表示要监听的消息队列，在listenerEmailMsg方法上 添加了 @RabbitHandler注解，用来处理接收的消息。spring
在springboot的@RabbitHandler注解处理接受消息时，若是在处理消息的过程当中没有发生异常的话，那么springboot会自动进行消息的应答。apache
以上几步便可完成消息的接收和有邮件的发送。json
相关文章
- 1. SpringBoot整合JavaMail发送邮件
- 2. 使用JavaMail发送邮件
- 3. 使用javamail发送邮件
- 4. javamail邮件发送
- 5. Javamail发送邮件
- 6. javaMail发送邮件
- 7. JavaMail发送邮件
- 8. javamail发送邮件
- 9. JavaMail邮件发送
- 10. javamail 发送邮件
- 更多相关文章...
- • ASP 使用 CDOSYS 发送电子邮件 - ASP 教程
- • PHP 发送电子邮件 - PHP教程
- • Tomcat学习笔记（史上最全tomcat学习笔记）
- • Composer 安装与使用
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. 安装cuda+cuDNN
- 2. GitHub的使用说明
- 3. phpDocumentor使用教程【安装PHPDocumentor】
- 4. yarn run build报错Component is not found in path “npm/taro-ui/dist/weapp/components/rate/index“
- 5. 精讲Haproxy搭建Web集群
- 6. 安全测试基础之MySQL
- 7. C/C++编程笔记：C语言中的复杂声明分析，用实例带你完全读懂
- 8. Python3教程(1)----搭建Python环境
- 9. 李宏毅机器学习课程笔记2：Classification、Logistic Regression、Brief Introduction of Deep Learning
- 10. 阿里云ECS配置速记
欢迎关注本站公众号,获取更多信息
相关文章
- 1. SpringBoot整合JavaMail发送邮件
- 2. 使用JavaMail发送邮件
- 3. 使用javamail发送邮件
- 4. javamail邮件发送
- 5. Javamail发送邮件
- 6. javaMail发送邮件
- 7. JavaMail发送邮件
- 8. javamail发送邮件
- 9. JavaMail邮件发送
- 10. javamail 发送邮件