如何使用ActiveMQ中間件方式發(fā)送郵件
更新時間：2021年07月05日 10:13:57 作者：王小白_Ada
這篇文章主要介紹了如何使用ActiveMQ中間件方式發(fā)送郵件的操作，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
前言
在大型互聯網公司中，一般都會搭建內部的消息服務平臺，處理公司內部的各種消息服務，比如：發(fā)送郵件、發(fā)送短信、微信推送等，公司內部消息平臺再去調用第三發(fā)消息平臺。消息服務平臺的接口有兩種：同步和異步，同步需求一般是需要返回調用第三方平臺是否成功，否則都采用異步的。
公司內部消息服務平臺
調用內部消息服務平臺，使用消息中間件
發(fā)送消息一般都會做消息模板，調用的時候傳模板id
整合Eamil實現異步發(fā)送郵件信息
采用163郵件接口，先注冊163郵箱，并開通pop3協(xié)議，此時會有一個授權碼，發(fā)送內容不能帶有廣告，否則會被163攔截，導致發(fā)送失敗。
場景：會員服務調用內部消息服務平臺發(fā)送郵件
會員服務（生產者）
Maven依賴
<!-- SpringBoot整合web組件 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- ActiveMQ依賴 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<!-- FastJson工具包 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>LATEST</version>
</dependency>
YML配置文件
spring:
activemq:
broker-url: tcp://127.0.0.1:61616 # ActiveMQ消息中間件服務器通訊地址
user: admin # 用戶名
password: admin #密碼
queue: springboot-queue #自定義隊列名，等下程序中會用到
server:
port: 8080
配置類
@Configuration
public class QueueConfig {
//獲取隊列名
@Value("${queue}")
private String queue;
//注冊bean
@Bean
public Queue logQueue() {
return new ActiveMQQueue(queue);
}
}
創(chuàng)建Producer
@Component
@EnableScheduling
public class Producer {
@Autowired
private JmsMessagingTemplate jmsMessagingTemplate;
@Autowired
private Queue queue;
//每隔5秒向消息隊列發(fā)送消息
@Scheduled(fixedDelay = 5000)
public void send(){
//用戶名，封裝郵件內容時使用
String userName = "張三"+ new Random().nextInt(20);
//指定發(fā)送到哪個郵箱 (郵件接收者郵箱)
String email = "593****77@qq.com";
JSONObject jsonObject = new JSONObject();
jsonObject.put("userName",userName);
jsonObject.put("email",email);
//將發(fā)送的消息轉換為Json字符串
String msg = jsonObject.toJSONString();
System.out.println("生產者向消費者發(fā)送內容：" + msg);
jmsMessagingTemplate.convertAndSend(queue,msg);
}
}
啟動類
@EnableScheduling
@SpringBootApplication
public class ActivemqQueueApplication {
public static void main(String[] args) {
SpringApplication.run(ActivemqQueueApplication.class, args);
}
}
消息服務平臺（消費者）
Maven依賴
<!-- SpringBoot整合Web組件 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- activemq依賴 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<!-- SpringBoot 整合Emai -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-mail</artifactId>
</dependency>
<!-- 工具包 -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>LATEST</version>
</dependency>
YML配置文件
spring:
activemq:
# ActiveMQ消息中間件服務器通訊地址
broker-url: tcp://127.0.0.1:61616
user: admin # 用戶名
password: admin #密碼
# 發(fā)送郵件配置
mail:
# 郵件服務器地址
host: smtp.163.com
# 郵箱用戶名(郵件發(fā)送者)
username: *********@163.com
# 授權碼，163郵箱開通協(xié)議時設置的那個授權碼，不是登錄密碼
password: wx1**********3
enable: true
smtp:
auth: true
starttls:
enable: true
required: true
#自定義隊列名屬性，等下程序中會用到（以生產者的隊列名一致）
queue: springboot-queue
server:
port: 8081
創(chuàng)建Consumer
@Component
public class Consumer{
@Autowired
private JavaMailSender javaMailSender;
@Value("${spring.mail.username}") //發(fā)送方郵箱
private String toEmail;
@JmsListener(destination = "${queue}") //監(jiān)聽的隊列，配置文件中的queue屬性
public void receive(String msg){
if(StringUtils.isEmpty(msg)){
return;
}
System.out.println("收到生產者消息："+msg);
JSONObject jsonObject = JSONObject.parseObject(msg);
String userName = jsonObject.getString("userName");
String eamil = jsonObject.getString("eamil");
//發(fā)送郵件
sendEmail(userName,toEmail);
}
/**
* 發(fā)送簡單郵件
* @param userName 用戶名，用戶封裝郵件內容
* @param toEmail 通過哪個郵箱發(fā)送
* @return
*/
public String sendEmail(String userName,String toEmail){
//發(fā)送消息對象
SimpleMailMessage message = new SimpleMailMessage();
//發(fā)送者
message.setFrom(toEmail);
//接收者
message.setTo(toEmail);
//主題(標題)
message.setSubject("尊敬的"+userName);
//內容
message.setText("歡迎使用您使用本公司的產品！"); //發(fā)送html，發(fā)送html格式源碼
javaMailSender.send(message);
System.out.println("郵件發(fā)送完成："+ JSONObject.toJSONString(message));
return "send success!";
}
}
啟動類
@SpringBootApplication
public class ActivemqQueueConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(ActivemqQueueConsumerApplication.class, args);
}
}
測試
- 啟動會員服務和消息服務平臺服務
- 注意：啟動前保證消息隊列里面沒有消息，有的話則先刪除該隊列，否則容易造成數據類型不一致導致Json解析異常出錯。
會員服務：
消息服務平臺：
此時消息服務平臺發(fā)送郵件成功！
以上為個人經驗，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關文章
這篇文章主要介紹了Sequelize 常用操作詳解及實例代碼的相關資料,希望能幫助到大家，需要的朋友可以參考下2016-11-11
本文主要介紹了Java中List分片的5種方法小結，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-11-11
Java的MyBatis+Spring框架中使用數據訪問對象DAO模式的方法
Data Access Object數據訪問對象模式在Java操作數據庫部分的程序設計中經常被使用到,這里我們就來看一下Java的MyBatis+Spring框架中使用數據訪問對象DAO模式的方法:2016-06-06
這篇文章主要介紹了Java cglib動態(tài)代理的相關資料，幫助大家更好的理解和學習使用Java，感興趣的朋友可以了解下2021-05-05
Antlr4 是一款強大的語法生成器工具,可用于讀取、處理、執(zhí)行和翻譯結構化的文本或二進制文件,基本上是當前 Java 語言中使用最為廣泛的語法生成器工具,本文給大家介紹了SpringBoot集成antlr實現詞法和語法分析,需要的朋友可以參考下2024-06-06
這篇文章主要介紹了Spring集成Seata方式,本案例使用Seata-All演示,結合實例代碼給大家講解的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2023-08-08
Java并發(fā)LinkedBlockingQueue源碼分析
這篇文章主要為大家介紹了Java并發(fā)LinkedBlockingQueue源碼分析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-02-02
這篇文章主要介紹了解決@Scope(“prototype“)不生效的問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-06-06
這篇文章主要為大家介紹了RocketMQ源碼解析broker啟動流程詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-03-03
這篇文章主要介紹了Java中使用內存映射實現大文件上傳實例,本文對比測試了FileInputStream 或者FileOutputStream 抑或RandomAccessFile的頻繁讀寫操作,最后總結出映射到內存后進行讀寫以提高速度,需要的朋友可以參考下2015-01-01