栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

SpringBoot三种实现邮箱发送功能

SpringBoot三种实现邮箱发送功能

SpringBoot实现邮件发送
  • 邮件协议
    • 一:SpringBoot集成邮件
      • 二:以HTML形式发送邮件
        • 三:SpringBoot+RabbitMQ

邮件协议

SMTP:SMTP全称Simple Mail Transfer Protocol(简单邮件传输协议),它是一种用于从源地址到目的地的地址传输邮件的规范,通过它来控制邮件的中转方式。SMTP必须提供账号密码才能登入,防止乱发。
IMAP:IMAP全称Internet Message Access Protocol(互联网访问协议),IMAP允许从邮件服务器上获取邮件的信息、下载邮件等。IMAP于POP类似,都是一种邮件获取协议。
POP3:POP3全称Post Office Protocol 3(邮局协议),POP3支持客户端远程管理服务器端的邮件。POP3常用于“离线”邮件处理,即允许客户端下载服务器邮件,然后服务器上的邮件将会被删除。目前很多POP3的邮件服务器只提供下载邮件功能,服务器本身并不删除邮件,这种属于改进版的POP3协议。

一:SpringBoot集成邮件

1.以文本形式发送邮件
(1.1)准备工作
开通邮箱SMTP服务,这里以163为列:


启动后会发来一个授权码,你保存起来后就可以发送邮件了。
(1.2)导入依赖


	org.springframework.boot
	spring-boot-starter-thymeleaf
	

	org.springframework.boot
	spring-boot-starter-web



	org.projectlombok
	lombok
	true


	org.springframework.boot
	spring-boot-starter-test
	test




	 org.springframework.boot
	 spring-boot-starter-mail


(1.3)配置yml文件

spring:
  # 邮件配置
  mail:
    # 邮件服务器地址
    host: smtp.qq.com
    # 你的邮箱地址
    username: *****@qq.com
    # 授权码
    password: *****
    # 编码格式
    default-encoding: utf-8
    # 协议
    protocol: smtp
    properties:
      mail:
        smtp:
          auth: true
          starttls:
            enable: true
            required: true

格式自己注意好。
(1.4)实体MailBean类

package com.xxxx.springbootemail.pojo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;

import java.io.Serializable;

@Data
@ToString
@AllArgsConstructor
@NoArgsConstructor
public class MailBean implements Serializable {
    private static final long serialVersionUID = -2116367492649751914L;
    private String recipient;//邮件接收人
    private String subject; //邮件主题
    private String content; //邮件内容
}

创建RespBean类

package com.xxxx.springbootemail.pojo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;


@Data
@AllArgsConstructor
@NoArgsConstructor
public class RespBean {
    private long code;
    private String message;
    private Object obj;

    
    public static RespBean success(String message){
        return new RespBean(200,message,null);
    }

    
    public static RespBean success(String message,Object data){
        return new RespBean(200,message,data);
    }

    
    public static RespBean error(String message){
        return new RespBean(500,message,null);
    }

    
    public static RespBean error(String message,Object data){
        return new RespBean(500,message,data);
    }
}

创建User类

package com.xxxx.springbootemail.pojo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;

@Data
@ToString
@AllArgsConstructor
@NoArgsConstructor
public class User {
    private static final long serialVersionUID = -2116367492649751914L;

    //用户名
    private String name;
    //密码
    private String password;
    //邮箱
    private String mailbox;

}

(1.5)创建MailUtil类

package com.xxxx.springbootemail.utils;

import com.xxxx.springbootemail.pojo.MailBean;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.stereotype.Component;

@Component
public class MailUtil {

    @Value("${spring.mail.username}")
    private String MAIL_SENDER; //邮件发送者

    @Autowired
    private JavaMailSender javaMailSender;//注入QQ发送邮件的bean

    private Logger logger = LoggerFactory.getLogger(MailUtil.class);

    
    public void sendSimpleMail(MailBean mailBean) {
        try {
            SimpleMailMessage mailMessage= new SimpleMailMessage();
            mailMessage.setFrom(MAIL_SENDER);//发送者
            mailMessage.setTo(mailBean.getRecipient());//接收者
            mailMessage.setSubject(mailBean.getSubject());//邮件标题
            mailMessage.setText(mailBean.getContent());//邮件内容
            javaMailSender.send(mailMessage);//发送邮箱
        } catch (Exception e) {
            logger.error("邮件发送失败", e.getMessage());
        }
    }
}

其中:
from,即为邮件发送者,一般设置在配置文件中
to,邮件接收者,此参数可以为数组,同时发送多人
subject,邮件主题
Text,邮件内容
content,邮件的主体
copyTo:抄送人

(1.6)编写Controller类

package com.xxxx.springbootemail.controller;

import com.xxxx.springbootemail.pojo.MailBean;
import com.xxxx.springbootemail.pojo.RespBean;
import com.xxxx.springbootemail.pojo.User;
import com.xxxx.springbootemail.utils.MailUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import java.util.Date;

@Controller
public class Mail {

    @Autowired
    private MailUtil mailUtil;

    @PostMapping("/mails")
    @ResponseBody
    public RespBean doMail(User user){
        System.out.println("数据: " + user);
        if (user != null){
            MailBean mailBean = new MailBean();
            mailBean.setRecipient(user.getMailbox());//接收者
            mailBean.setSubject("用户信息");//标题
            //内容主体
            mailBean.setContent("SpringBootMail发送一个简单格式的邮件,时间为:" + new Date());

            mailUtil.sendSimpleMail(mailBean);
            return RespBean.success("查询成功",user);
        }
        return RespBean.error("发送失败!");
    }

}

(1.7)编写html模板
下面展示一些 内联代码片。




    
    Title


用户名: 密码: 邮箱:

(1.8)测试

这里就邮件发送成功啦!!

二:以HTML形式发送邮件

与文本格式邮件代码对比,富文本HTML邮件发送使用MimeMessageHelper类,把setText()方法的消息文本设置为html,并将第二个参数设置为true,表示这是html的富文本。MimeMessageHelper支持发送复杂邮件模板,支持文本、附件、HTML、图片等。

(2.1)导入依赖


    org.springframework.boot
    spring-boot-starter-thymeleaf

(2.2)创建email.html




    
    Title


	


您有代金券即将到期,逾期失效,请尽早使用。点此查看

(2.3)编写MailUtil类

    public void sendHTMLMail(MailBean mailBean) {
        MimeMessage mimeMailMessage = null;
        try {
            mimeMailMessage = javaMailSender.createMimeMessage();
            //true 表示需要创建一个multipart message
            MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMailMessage, true);
            mimeMessageHelper.setFrom(MAIL_SENDER);//发送者
            mimeMessageHelper.setTo(mailBean.getRecipient());//接受者
            mimeMessageHelper.setSubject(mailBean.getSubject());//邮件标题
            //这里的 true,你加了的话,它发送你HTML页面里面的内容
            //不加的话,默认是 false,它发送整个HTML页面代码
            mimeMessageHelper.setText(mailBean.getContent(), true);
            //邮件抄送
            javaMailSender.send(mimeMailMessage);//发送邮件
        } catch (Exception e) {
            logger.error("邮件发送失败", e.getMessage());
        }
    }

(2.4)编写Controller类

@Autowired
private TemplateEngine templateEngine;

@PostMapping("/mails2")
    @ResponseBody
    public RespBean doMail2(User user){
        System.out.println("数据: " + user);
        //以HTML模板发送邮件
        if (user != null){
            //注意:Context 类是在org.thymeleaf.context.Context包下的。
            Context context = new Context();
            //html中填充动态属性值
            context.setVariable("username", "码农用户");
            context.setVariable("url", "https://www.aliyun.com/?utm_content=se_1000301881");
            //注意:process第一个参数名称要和templates下的模板名称一致。要不然会报错
            //org.thymeleaf.exceptions.TemplateInputException: Error resolving template [email]
            String emailContent = templateEngine.process("email", context);

            MailBean mailBean = new MailBean();
            mailBean.setRecipient(user.getMailbox());
            mailBean.setSubject("主题:这是模板邮件");
            mailBean.setContent(emailContent);

            mailUtil.sendHTMLMail(mailBean);
            return RespBean.success("查询成功",user);
        }
        return RespBean.error("发送失败!");
    }

(2.5)测试

三:SpringBoot+RabbitMQ

利用Springboot集成邮箱,如果邮箱内容太大的话,发送消息会很慢,会阻挡程序继续运行下去,所以利用RabbitMQ的话,可以分开进行,发送邮件继续发,程序也可以继续往下运行。
(1)导入依赖


	org.springframework.boot
	spring-boot-starter-amqp



	org.springframework.boot
	spring-boot-starter-mail

(2)配置yml文件

server:
  port: 8083

spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/xadmin?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
    username: root
    password: 123456
    hikari:
      # 连接池名
      pool-name: DateHikariCP
      # 最小空闲连接数
      minimum-idle: 5
      # 空闲连接存活最大时间,默认600000(10分钟)
      idle-timeout: 180000
      # 最大连接数,默认10
      maximum-pool-size: 10
      # 从连接池返回的连接的自动提交
      auto-commit: true
      # 连接最大存活时间,0表示永久存活,默认1800000(30分钟)
      max-lifetime: 1800000
      # 连接超时时间,默认30000(30秒)
      connection-timeout: 30000
      # 测试连接是否可用的查询语句
      connection-test-query: SELECt 1

  # 邮件配置
  mail:
    # 邮件服务器地址
    host: smtp.qq.com
    # 你的邮箱地址
    username: *****@qq.com
    # 授权码
    password: *****
    # 编码格式
    default-encoding: utf-8
    # 协议
    protocol: smtp
    properties:
      mail:
        smtp:
          auth: true
          starttls:
            enable: true
            required: true

  # rabbitmq配置
  rabbitmq:
    # 服务器地址
    host: *****
    # 端口
    port: 5672
    # 用户名
    username: admin
    # 密码
    password: admin
    # 权限
    virtual-host: /shop

# Mybatis-plus配置
mybatis-plus:
  # 配置Mapper映射文件
  mapper-locations: classpath*:/mapper
    @Bean
    public Queue mailQueue() {
        return new Queue("mq.email");//队列名称
    }
}

(3.2)配置MailReceiver

package com.example.demo3.utils;

import com.example.demo3.entity.TUser;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.mail.MailProperties;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.mail.javamail.MimeMessageHelper;
import org.springframework.stereotype.Component;
import org.thymeleaf.TemplateEngine;
import org.thymeleaf.context.Context;

import javax.mail.MessagingException;
import javax.mail.internet.MimeMessage;
import java.util.Date;



@Component
public class MailReceiver {

    private static final Logger LOGGER = LoggerFactory.getLogger(MailReceiver.class);

    @Autowired
    private JavaMailSender javaMailSender;

    @Autowired
    private MailProperties mailProperties;

    @Autowired
    private TemplateEngine templateEngine;

    @RabbitListener(queuesToDeclare = {@Queue("mq.email")})//获取队列名称
    public void handler(TUser user){
        MimeMessage mimeMessage = javaMailSender.createMimeMessage();
        MimeMessageHelper helper = new MimeMessageHelper(mimeMessage);
        try {
            //发件人
            helper.setFrom(mailProperties.getUsername());
            //收件人
            helper.setTo(user.getMailbox());
            //主题
            helper.setSubject("入职欢迎邮件");
            //发送日期
            helper.setSentDate(new Date());
            //邮件内容
            Context context = new Context();
            context.setVariable("username", "码农用户");
            context.setVariable("url", "https://www.aliyun.com/?utm_content=se_1000301881");
            String mail = templateEngine.process("email", context);//跟模板名称要一样
            helper.setText(mail,true);
            //发送邮件
            javaMailSender.send(mimeMessage);
        } catch (MessagingException e) {
            LOGGER.error("邮件发送失败========>{}",e.getMessage());
        }
    }
}

(4)配置HTML模板




    
    Title



您有代金券即将到期,逾期失效,请尽早使用。点此查看

(5)配置Controller
下面展示一些 内联代码片。

package com.example.demo3.controller;

import com.example.demo3.entity.RespBean;
import com.example.demo3.entity.TUser;
import com.example.demo3.service.TUserService;
import com.example.demo3.utils.MailUtil;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.thymeleaf.TemplateEngine;

import javax.annotation.Resource;
import java.util.Date;


@RestController
@RequestMapping("/tUser")
public class TUserController {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @PostMapping("/mails")
    public RespBean doMail(@RequestBody TUser user){
        System.out.println("数据: " + user);
        if (user != null){
            rabbitTemplate.convertAndSend("mq.email",user);
            return RespBean.success("查询成功",user);
        }
        return RespBean.error("发送失败!");
    }

}

(6.)测试

OK!

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/285735.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号