Springboot如何搭建郵件服務(wù)

這篇文章主要介紹了Spring boot如何搭建郵件服務(wù)，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

創(chuàng)新互聯(lián)公司是專業(yè)的華亭網(wǎng)站建設(shè)公司，華亭接單;提供成都做網(wǎng)站、網(wǎng)站建設(shè)、外貿(mào)營銷網(wǎng)站建設(shè),網(wǎng)頁設(shè)計,網(wǎng)站設(shè)計,建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進(jìn)行華亭網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴(kuò)展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團(tuán)隊,希望更多企業(yè)前來合作!

前言：

發(fā)送郵件，肯定是每個公司都會有的基本業(yè)務(wù)。很多公司都會選擇把發(fā)送郵件作為一個基礎(chǔ)服務(wù)，對外提供接口。直接調(diào)用就可發(fā)郵件了。但是我們都知道發(fā)送郵件耗時都比較長。那么今天就介紹下使用Spring boot+eventbus來打造一個簡單郵件服務(wù)

規(guī)劃接口列表

發(fā)送郵件的類型準(zhǔn)備的有三種

發(fā)送普通郵件
發(fā)送html郵件
發(fā)送圖文郵件

還有一個細(xì)節(jié)，如果我們同步的取發(fā)送郵件會有兩個問題。

接口響應(yīng)時間比較長
遇到并發(fā)的情況，容易導(dǎo)致服務(wù)器壓力過大或者郵箱服務(wù)封ip

所以我們準(zhǔn)備使用隊列來執(zhí)行發(fā)送郵件的操作?？梢越鉀Q這個問題。隊列我選用的是Google的eventbus。是一款很輕量的隊列。直接走的內(nèi)存

準(zhǔn)備工作

首先要在pom.xml中引入需要使用的包

 <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-mail</artifactId>
 </dependency>
 <dependency>
   <groupId>com.google.guava</groupId>
   <artifactId>guava</artifactId>
   <version>23.0</version>
  </dependency>
  <dependency>
   <groupId>org.projectlombok</groupId>
   <artifactId>lombok</artifactId>
  </dependency>

spring-boot-starter-mail :spring-boot提供的發(fā)郵件的maven庫
guava：google提供的開源庫。里面包含來很多工具
lombok：可以幫你省去編寫實體類的工具

引入之后，我們還需要配置發(fā)送郵件所需要的必要配置

在application.properties中配置郵箱

spring.mail.host=smtp.mail.me.com //郵箱發(fā)送服務(wù)器
spring.mail.port=587//服務(wù)器端口
spring.mail.username=xxx6666@icloud.com//發(fā)件人郵箱
spring.mail.password=password//客戶端專用密碼
//如果和我一樣使用的icloud郵箱 還需要下列兩個配置，別的有的郵箱不需要
spring.mail.properties.mail.smtp.starttls.enable=true
spring.mail.properties.mail.smtp.starttls.required=true

做到這里其實就已經(jīng)完成了，發(fā)郵件所需要的配置了。但是我們是要用隊列來發(fā)送，所以還需要配置下隊列

@Configuration
public class AsyncEventBusConfig {
 //實例化bean，采用單例形式注入容器
 @Bean
 @Scope("singleton")
 public AsyncEventBus asyncEventBus(){
  //創(chuàng)建線程池對象
  final ThreadPoolExecutor executor=executor();
  return new AsyncEventBus(executor);
 }
 //創(chuàng)建線程池方法
 private ThreadPoolExecutor executor(){
  return new
    ThreadPoolExecutor(2,
    2,0L,
    TimeUnit.MICROSECONDS,
    new LinkedBlockingQueue<>());
 }
}

封裝EmailService

準(zhǔn)備好了之后，就可以直接來封裝發(fā)送郵件的業(yè)務(wù)了。之前有提到我們需要三個接口，同樣的，我們也需要三個service方法

@Service
public class EmailService {

 @Autowired
 private JavaMailSender javaMailSender;

 /**
  * 發(fā)件人。這里發(fā)件人一般是同使用的發(fā)件郵箱一致
  */
 @Value("${spring.mail.username}")
 private String from;


 /**
  * 發(fā)送文本郵件
  * @param to 收件人郵箱地址
  * @param subject 主題
  * @param content 內(nèi)容
  */
 public void sendTextMail(String to,
        String subject,
        String content) {
  SimpleMailMessage simpleMailMessage = new SimpleMailMessage();
  simpleMailMessage.setTo(to);
  simpleMailMessage.setSubject(subject);
  simpleMailMessage.setText(content);
  simpleMailMessage.setFrom(from);
  javaMailSender.send(simpleMailMessage);
 }


 /**
  * 發(fā)送html內(nèi)容的郵件
  * @param to 收件人
  * @param htmlContent html內(nèi)容
  * @param subject 主題
  * @throws MessagingException
  */
 public void sendHtmlMail(String to,
        String htmlContent,
        String subject) throws MessagingException {
  MimeMessage message = javaMailSender.createMimeMessage();
  MimeMessageHelper messageHelper = new MimeMessageHelper(message, true);
  messageHelper.setTo(to);
  messageHelper.setSubject(subject);
  messageHelper.setFrom(from);
  messageHelper.setText(htmlContent, true);
  javaMailSender.send(message);
 }

 /**
  * 發(fā)送圖文郵件
  * @param to 收件人
  * @param imgContent 圖文內(nèi)容
  * @param subject 主題
  * @param rscId 資源id
  * @param imgPath 資源路徑
  * @throws MessagingException
  */
 public void sendImgMail(String to,
       String imgContent,
       String subject,
       String rscId,
       String imgPath) throws MessagingException {
  MimeMessage message = javaMailSender.createMimeMessage();
  MimeMessageHelper messageHelper = new MimeMessageHelper(message, true);
  messageHelper.setTo(to);
  messageHelper.setSubject(subject);
  messageHelper.setFrom(from);
  messageHelper.setText(imgContent, true);
  messageHelper.addInline(rscId, new File(imgPath));
  javaMailSender.send(message);
 }
}

隊列監(jiān)聽

既然封裝好了方法，那么就需要調(diào)用。調(diào)用的方式，其實就是將接口傳來的數(shù)據(jù)傳到隊列里。隊列的消費者接收到了消息就將消息拿來調(diào)用發(fā)送郵件的方法

我們首先創(chuàng)建一個消費類，用來接受消息，處理消息。

@Service
public class EventBusListener {

 /**
  * 引入bean
  */
 @Autowired
 private AsyncEventBus asyncEventBus;

 @Autowired
 private EmailService emailService;

 /**
  * 注冊服務(wù)類
  */
 @PostConstruct
 public void init(){
  asyncEventBus.register(this);
 }

 /**
  * 線程安全，消費 文本消息
  * @param textEmailDTO
  */
 @AllowConcurrentEvents
 @Subscribe
 public void sendTextMail(TextEmailDTO textEmailDTO){
  emailService.sendTextMail(
    textEmailDTO.getTo(),
    textEmailDTO.getSubject(),
    textEmailDTO.getContent()
  );
 }

 /**
  * 線程安全 消費 html消息
  * @param htmlEmailDTO
  */
 @AllowConcurrentEvents
 @Subscribe
 public void sendHtmlMail(HtmlEmailDTO htmlEmailDTO){
  try {
   emailService.sendHtmlMail(
     htmlEmailDTO.getTo(),
     htmlEmailDTO.getHtmlContent(),
     htmlEmailDTO.getSubject()
   );
  } catch (MessagingException e) {
   // nothing to do
  }
 }

 /**
  * 線程安全 消費 圖文消息
  * @param imgEmailDTO
  */
 @AllowConcurrentEvents
 @Subscribe
 public void sendImgMail(ImgEmailDTO imgEmailDTO){
  try {
   emailService.sendImgMail(
     imgEmailDTO.getTo(),
     imgEmailDTO.getImgContent(),
     imgEmailDTO.getSubject(),
     imgEmailDTO.getRscId(),
     imgEmailDTO.getImgPath()
   );
  } catch (MessagingException e) {
   // nothing to do
  }
 }
}

其實eventbus拋消息都是使用的post方法來拋消息。走到不同的方法里面是利用了類的多態(tài)，拋入不同的實體類就可以進(jìn)行區(qū)分了。走進(jìn)了不同的方法，就調(diào)用相應(yīng)Service方法。

控制器與測試

控制器部分，沒什么好說的，我就貼出圖文的代碼。其余代碼可以在我的github上面看

先看眼實體類

@Data
public class ImgEmailDTO implements Serializable {
 public ImgEmailDTO() {
 }

 /**
  * 圖片路徑
  */
 private String imgPath;

 /**
  * 資源id
  */
 private String rscId;

 /**
  * 主題
  */
 private String subject;

 /**
  * 圖片正文（同樣可以使用html）
  */
 private String imgContent;

 /**
  * 收件人
  */
 private String to;
}

 /**
  * 發(fā)送圖文郵件
  * @param request
  * @return
  */
 @RequestMapping(value = "/sendImgMail", method = RequestMethod.POST)
 public Result<Integer> sendImgMail(@RequestBody Request<ImgEmailDTO> request) {
  Result<Integer> result = Result.create();
  ImgEmailDTO imgEmailDTO=request.getData();
  StringBuilder sb=new StringBuilder();
  sb.append(imgEmailDTO.getImgContent());
  //cid:資源id。在spring中會自動綁定
  sb.append("<img src=\'cid:").append(imgEmailDTO.getRscId()).append("\'></img>");
  imgEmailDTO.setImgContent(sb.toString());
  asyncEventBus.post(imgEmailDTO);
  return result.success(1);
 }

圖文要稍微特殊一點，需要拼接下正文內(nèi)容。然后將實體類中的content替換。最后將實體類拋入隊列。直接返回接口請求。隊列那邊就會排著隊搞定所有的郵件

下面來做個測試

Spring boot如何搭建郵件服務(wù)

請求很迅速的返回了結(jié)果

然后去郵箱中查看結(jié)果

Spring boot如何搭建郵件服務(wù)

感謝你能夠認(rèn)真閱讀完這篇文章，希望小編分享的“Spring boot如何搭建郵件服務(wù)”這篇文章對大家有幫助，同時也希望大家多多支持創(chuàng)新互聯(lián)，關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，更多相關(guān)知識等著你來學(xué)習(xí)!

分享名稱：Springboot如何搭建郵件服務(wù)
當(dāng)前URL：http://muchs.cn/article4/ijccoe.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供虛擬主機、外貿(mào)建站、品牌網(wǎng)站制作、響應(yīng)式網(wǎng)站、搜索引擎優(yōu)化、標(biāo)簽優(yōu)化

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容