SpringBoot筆記7:使用JavaMail結合RabbitMQ發送郵件

時間 2019-11-22

標籤 springboot 筆記使用 javamail 結合 rabbitmq 發送郵件欄目 Spring 简体版

原文原文鏈接

一、建立郵件消息生產者：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