雖然ActiveMQ以被其他MQ所替代，但仍有學(xué)習(xí)的意義，本文采用郵件發(fā)送的例子展示ActiveMQ

文章目錄

• • • 1. 生產(chǎn)者
    • • 1.1 引入maven依賴
      • 1.2 application.yml配置
      • 1.3 創(chuàng)建配置類ConfigQueue
      • 1.4 創(chuàng)建生產(chǎn)者類Producer
      • 1.5 啟動(dòng)類AppProducer
    • 2. 消費(fèi)者
    • • 2.1 引入maven依賴
      • 2.2 application.yml配置
      • 2.3 創(chuàng)建消費(fèi)者類Consumer
      • 2.4 啟動(dòng)類AppConsumer
    • 3. 啟動(dòng)截圖
    • • 3.1 生產(chǎn)者截圖
      • 3.2 消費(fèi)者截圖
      • 3.3 ActiveMQ后臺(tái)截圖
      • 3.4 郵件系統(tǒng)截圖

1. 生產(chǎn)者

1.1 引入maven依賴

<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.itmayiedu</groupId><artifactId>springboot-p2p-roducer</artifactId><version>0.0.1-SNAPSHOT</version><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.1.RELEASE</version></parent><!-- 管理依賴 --><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>Finchley.M7</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><dependencies><!-- SpringBoot整合Web組件 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- SpringBoot Activemq --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-activemq</artifactId></dependency><!-- https://mvnrepository.com/artifact/com.alibaba/fastjson --><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.49</version></dependency></dependencies><!-- 注意： 這里必須要添加， 否者各種依賴有問題 --><repositories><repository><id>spring-milestones</id><name>Spring Milestones</name><url>https://repo.spring.io/libs-milestone</url><snapshots><enabled>false</enabled></snapshots></repository></repositories></project>

1.2 application.yml配置

spring:activemq:###MQ連接通訊地址broker-url: tcp://127.0.0.1:61616###賬號(hào)user: admin###密碼 password: admin###自定義隊(duì)列 my_queue: springboot2.0-queueserver:port: 8089

1.3 創(chuàng)建配置類ConfigQueue

@Component public class ConfigQueue {@Value("${my_queue}")private String myQueue;/*** 1.首先需要將隊(duì)列注入springboot容器中** @return*/@Beanpublic Queue queue() {return new ActiveMQQueue(myQueue);}}

1.4 創(chuàng)建生產(chǎn)者類Producer

@Component public class Producer {@Autowiredprivate JmsMessagingTemplate jmsMessagingTemplate;@Autowiredprivate Queue queue;/*** 每隔5秒種時(shí)間向隊(duì)列中發(fā)送消息*/@Scheduled(fixedDelay = 5000)public void send() {String userName = System.currentTimeMillis() + "";JSONObject jsonObject = new JSONObject();jsonObject.put("userName", userName);jsonObject.put("email", "apkdream@163.com");String msg = jsonObject.toJSONString();jmsMessagingTemplate.convertAndSend(queue, msg);System.out.println("采用點(diǎn)對(duì)點(diǎn)通訊模式,msg:" + msg);} }

1.5 啟動(dòng)類AppProducer

@SpringBootApplication @EnableScheduling public class AppProducer {public static void main(String[] args) {SpringApplication.run(AppProducer.class, args);}}

2. 消費(fèi)者

2.1 引入maven依賴

<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.itmayiedu</groupId><artifactId>springboot-p2p-consumer</artifactId><version>0.0.1-SNAPSHOT</version><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.1.RELEASE</version></parent><!-- 管理依賴 --><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>Finchley.M7</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><dependencies><!-- SpringBoot整合Web組件 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- SpringBoot Activemq --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-activemq</artifactId></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.49</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-mail</artifactId></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-lang3</artifactId></dependency></dependencies><!-- 注意： 這里必須要添加， 否者各種依賴有問題 --><repositories><repository><id>spring-milestones</id><name>Spring Milestones</name><url>https://repo.spring.io/libs-milestone</url><snapshots><enabled>false</enabled></snapshots></repository></repositories> </project>

2.2 application.yml配置

spring:activemq:###MQ連接通訊地址broker-url: tcp://127.0.0.1:61616###賬號(hào)user: admin###密碼 password: adminmail:###163郵件服務(wù)host: smtp.163.com###發(fā)送郵件賬號(hào)username: apkdream@163.com###pop協(xié)議授權(quán)碼 password: xxxxxxenable: truesmtp:auth: truestarttls:enable: truerequired: true###自定義隊(duì)列 my_queue: springboot2.0-queueserver:port: 8088

2.3 創(chuàng)建消費(fèi)者類Consumer

import com.alibaba.fastjson.JSONObject; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jms.annotation.JmsListener; import org.springframework.mail.SimpleMailMessage; import org.springframework.mail.javamail.JavaMailSender; import org.springframework.stereotype.Component;/*** 消費(fèi)者*/ @Component public class Consumer {@Autowiredprivate JavaMailSender javaMailSender;/*** 冪等性* @param msg* @throws Exception*/@JmsListener(destination = "${my_queue}")public void receive(String msg) throws Exception {if (StringUtils.isEmpty(msg)) {return;}/** 1.解析json **/JSONObject parseObject = JSONObject.parseObject(msg);String userName = parseObject.getString("userName");String email = parseObject.getString("email");sendSimpleMail(email, userName);System.out.println("采用點(diǎn)對(duì)點(diǎn)模式，消費(fèi)者成功獲取到生產(chǎn)者的消息,msg:" + msg);}public void sendSimpleMail(String eamil, String userName) throws Exception {SimpleMailMessage message = new SimpleMailMessage();/** 郵件來自 自己發(fā)自己 **/message.setFrom(eamil);/** 發(fā)送給誰 **/message.setTo(eamil);/** 郵件標(biāo)題 **/message.setSubject("niceyoo 新郵件提醒");/** 郵件內(nèi)容 **/message.setText("收到一批新的" + userName + "郵件!");/** 發(fā)送郵件 **/javaMailSender.send(message);System.out.println("郵件發(fā)送完成," + JSONObject.toJSONString(message));}}

2.4 啟動(dòng)類AppConsumer

@SpringBootApplication public class AppConsumer {public static void main(String[] args) {SpringApplication.run(AppConsumer.class, args);}}

3. 啟動(dòng)截圖

3.1 生產(chǎn)者截圖

3.2 消費(fèi)者截圖

3.3 ActiveMQ后臺(tái)截圖

Number Of Consumers? 消費(fèi)者 這個(gè)是消費(fèi)者端的消費(fèi)者數(shù)量 ;

Number Of Pending Messages 等待消費(fèi)的消息 這個(gè)是當(dāng)前未出隊(duì)列的數(shù)量。可以理解為總接收數(shù)-總出隊(duì)列數(shù);

Messages Enqueued 進(jìn)入隊(duì)列的消息? 進(jìn)入隊(duì)列的總數(shù)量,包括出隊(duì)列的。 這個(gè)數(shù)量只增不減?;

Messages Dequeued 出了隊(duì)列的消息? 可以理解為是消費(fèi)這消費(fèi)掉的數(shù)量?;

3.4 郵件系統(tǒng)截圖

總結(jié)

以上是生活随笔為你收集整理的Springboot整合ActiveMQ发送邮件的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。