SpringBoot整合RabbitMQ的5種模式實戰(zhàn)
更新時間：2021年08月02日 11:33:33 作者：沮喪的南瓜
本文主要介紹了SpringBoot整合RabbitMQ的5種模式實戰(zhàn)，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
一、環(huán)境準備
1、pom依賴
<!-- 父工程依賴 -->
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.3.6.RELEASE</version>
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<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>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
<version>2.6.0</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
<version>2.6.0</version>
</dependency>
</dependencies>
2、配置文件
server:
port: 8080
spring:
rabbitmq:
host: 192.168.131.171
port: 5672
username: jihu
password: jihu
virtual-host: /jihu
3、啟動類
@SpringBootApplication
public class RabbitMQApplication {
public static void main(String[] args) {
SpringApplication.run(RabbitMQApplication.class);
}
}
5、Swagger2類
@Configuration
@EnableSwagger2
public class Swagger2 {
// http://127.0.0.1:8080/swagger-ui.html
@Bean
public Docket createRestApi() {
return new Docket(DocumentationType.SWAGGER_2)
.apiInfo(apiInfo())
.select()
.apis(RequestHandlerSelectors.basePackage("com.jihu"))
.paths(PathSelectors.any())
.build();
}
private ApiInfo apiInfo() {
return new ApiInfoBuilder()
.title("極狐-Spring Boot中使用spring-boot-starter-amqp集成rabbitmq")
.description("測試SpringBoot整合進行各種工作模式信息的發(fā)送")
/*
.termsOfServiceUrl("https://www.jianshu.com/p/c79f6a14f6c9")
*/
.contact("roykingw")
.version("1.0")
.build();
}
}
6、ProducerController
@RestController
public class ProducerController {
@Autowired
private RabbitTemplate rabbitTemplate;
//helloWorld 直連模式
@ApiOperation(value = "helloWorld發(fā)送接口", notes = "直接發(fā)送到隊列")
@GetMapping(value = "/helloWorldSend")
public Object helloWorldSend(String message) throws AmqpException, UnsupportedEncodingException {
//設(shè)置部分請求參數(shù)
MessageProperties messageProperties = new MessageProperties();
messageProperties.setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN);
//發(fā)消息
rabbitTemplate.send("helloWorldqueue", new Message(message.getBytes("UTF-8"), messageProperties));
return "message sended : " + message;
}
//工作隊列模式
@ApiOperation(value = "workqueue發(fā)送接口", notes = "發(fā)送到所有監(jiān)聽該隊列的消費")
@GetMapping(value = "/workqueueSend")
public Object workqueueSend(String message) throws AmqpException, UnsupportedEncodingException {
MessageProperties messageProperties = new MessageProperties();
messageProperties.setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN);
//制造多個消息進行發(fā)送操作
for (int i = 0; i < 10; i++) {
rabbitTemplate.send("work_sb_mq_q", new Message(message.getBytes("UTF-8"), messageProperties));
}
return "message sended : " + message;
}
// pub/sub 發(fā)布訂閱模式 交換機類型 fanout
@ApiOperation(value = "fanout發(fā)送接口", notes = "發(fā)送到fanoutExchange。消息將往該exchange下的所有queue轉(zhuǎn)發(fā)")
@GetMapping(value = "/fanoutSend")
public Object fanoutSend(String message) throws AmqpException, UnsupportedEncodingException {
MessageProperties messageProperties = new MessageProperties();
messageProperties.setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN);
//fanout模式只往exchange里發(fā)送消息。分發(fā)到exchange下的所有queue
rabbitTemplate.send("fanoutExchange", "", new Message(message.getBytes("UTF-8"), messageProperties));
return "message sended : " + message;
}
//routing路由工作模式 交換機類型 direct
@ApiOperation(value = "direct發(fā)送接口", notes = "發(fā)送到directExchange。exchange轉(zhuǎn)發(fā)消息時，會往routingKey匹配的queue發(fā)送")
@GetMapping(value = "/directSend")
public Object routingSend(String routingKey, String message) throws AmqpException, UnsupportedEncodingException {
if (null == routingKey) {
routingKey = "china.changsha";
}
MessageProperties messageProperties = new MessageProperties();
messageProperties.setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN);
//fanout模式只往exchange里發(fā)送消息。分發(fā)到exchange下的所有queue
rabbitTemplate.send("directExchange", routingKey, new Message(message.getBytes("UTF-8"), messageProperties));
return "message sended : routingKey >" + routingKey + ";message > " + message;
}
//topic 工作模式 交換機類型 topic
@ApiOperation(value = "topic發(fā)送接口", notes = "發(fā)送到topicExchange。exchange轉(zhuǎn)發(fā)消息時，會往routingKey匹配的queue發(fā)送，*代表一個單詞，#代表0個或多個單詞。")
@GetMapping(value = "/topicSend")
public Object topicSend(String routingKey, String message) throws AmqpException, UnsupportedEncodingException {
if (null == routingKey) {
routingKey = "changsha.kf";
}
MessageProperties messageProperties = new MessageProperties();
messageProperties.setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN);
//fanout模式只往exchange里發(fā)送消息。分發(fā)到exchange下的所有queue
rabbitTemplate.send("topicExchange", routingKey, new Message(message.getBytes("UTF-8"), messageProperties));
return "message sended : routingKey >" + routingKey + ";message > " + message;
}
}
7、ConcumerReceiver
@Component
public class ConcumerReceiver {
//直連模式的多個消費者，會分到其中一個消費者進行消費。類似task模式
//通過注入RabbitContainerFactory對象，來設(shè)置一些屬性，相當于task里的channel.basicQos
@RabbitListener(queues = "helloWorldqueue")
public void helloWorldReceive(String message) {
System.out.println("helloWorld模式 received message : " + message);
}
//工作隊列模式
@RabbitListener(queues = "work_sb_mq_q")
public void wordQueueReceiveq1(String message) {
System.out.println("工作隊列模式1 received message : " + message);
}
@RabbitListener(queues = "work_sb_mq_q")
public void wordQueueReceiveq2(String message) {
System.out.println("工作隊列模式2 received message : " + message);
}
//pub/sub模式進行消息監(jiān)聽
@RabbitListener(queues = "fanout.q1")
public void fanoutReceiveq1(String message) {
System.out.println("發(fā)布訂閱模式1received message : " + message);
}
@RabbitListener(queues = "fanout.q2")
public void fanoutReceiveq2(String message) {
System.out.println("發(fā)布訂閱模式2 received message : " + message);
}
//Routing路由模式
@RabbitListener(queues = "direct_sb_mq_q1")
public void routingReceiveq1(String message) {
System.out.println("Routing路由模式routingReceiveq11111 received message : " + message);
}
@RabbitListener(queues = "direct_sb_mq_q2")
public void routingReceiveq2(String message) {
System.out.println("Routing路由模式routingReceiveq22222 received message : " + message);
}
//topic 模式
//注意這個模式會有優(yōu)先匹配原則。例如發(fā)送routingKey=hunan.IT,那匹配到hunan.*(hunan.IT,hunan.eco),之后就不會再去匹配*.ITd
@RabbitListener(queues = "topic_sb_mq_q1")
public void topicReceiveq1(String message) {
System.out.println("Topic模式 topic_sb_mq_q1 received message : " + message);
}
@RabbitListener(queues = "topic_sb_mq_q2")
public void topicReceiveq2(String message) {
System.out.println("Topic模式 topic_sb_mq_q2 received message : " + message);
}
}
二、簡單模式
隊列配置：
/**
* HelloWorld rabbitmq第一個工作模式
* 直連模式只需要聲明隊列，所有消息都通過隊列轉(zhuǎn)發(fā)。
* 無需設(shè)置交換機
*/
@Configuration
public class HelloWorldConfig {
@Bean
public Queue setQueue() {
return new Queue("helloWorldqueue");
}
}
三、工作隊列模式
@Configuration
public class WorkConfig {
//聲明隊列
@Bean
public Queue workQ1() {
return new Queue("work_sb_mq_q");
}
}
四、廣播模式（Fanout）
/**
* Fanout模式需要聲明exchange，并綁定queue，由exchange負責(zé)轉(zhuǎn)發(fā)到queue上。
* 廣播模式 交換機類型設(shè)置為：fanout
*/
@Configuration
public class FanoutConfig {
//聲明隊列
@Bean
public Queue fanoutQ1() {
return new Queue("fanout.q1");
}
@Bean
public Queue fanoutQ2() {
return new Queue("fanout.q2");
}
//聲明exchange
@Bean
public FanoutExchange setFanoutExchange() {
return new FanoutExchange("fanoutExchange");
}
//聲明Binding,exchange與queue的綁定關(guān)系
@Bean
public Binding bindQ1() {
return BindingBuilder.bind(fanoutQ1()).to(setFanoutExchange());
}
@Bean
public Binding bindQ2() {
return BindingBuilder.bind(fanoutQ2()).to(setFanoutExchange());
}
}
五、直連模式（Direct）
/*
路由模式|Routing模式 交換機類型：direct
*/
@Configuration
public class DirectConfig {
//聲明隊列
@Bean
public Queue directQ1() {
return new Queue("direct_sb_mq_q1");
}
@Bean
public Queue directQ2() {
return new Queue("direct_sb_mq_q2");
}
//聲明exchange
@Bean
public DirectExchange setDirectExchange() {
return new DirectExchange("directExchange");
}
//聲明binding，需要聲明一個routingKey
@Bean
public Binding bindDirectBind1() {
return BindingBuilder.bind(directQ1()).to(setDirectExchange()).with("china.changsha");
}
@Bean
public Binding bindDirectBind2() {
return BindingBuilder.bind(directQ2()).to(setDirectExchange()).with("china.beijing");
}
}
六、通配符模式（Topic）
/*
Topics模式 交換機類型 topic
* */
@Configuration
public class TopicConfig {
//聲明隊列
@Bean
public Queue topicQ1() {
return new Queue("topic_sb_mq_q1");
}
@Bean
public Queue topicQ2() {
return new Queue("topic_sb_mq_q2");
}
//聲明exchange
@Bean
public TopicExchange setTopicExchange() {
return new TopicExchange("topicExchange");
}
//聲明binding，需要聲明一個roytingKey
@Bean
public Binding bindTopicHebei1() {
return BindingBuilder.bind(topicQ1()).to(setTopicExchange()).with("changsha.*");
}
@Bean
public Binding bindTopicHebei2() {
return BindingBuilder.bind(topicQ2()).to(setTopicExchange()).with("#.beijing");
}
}
測試
我們啟動上面的SpringBoot項目。
然后我們訪問swagger地址：http://127.0.0.1:8080/swagger-ui.html
然后我們就可以使用swagger測試接口了。
或者可以使用postman進行測試。
到此這篇關(guān)于SpringBoot整合RabbitMQ的5種模式實戰(zhàn)的文章就介紹到這了,更多相關(guān)SpringBoot整合RabbitMQ模式內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
IntelliJ IDEA 2019.1.1 for MAC 下載和注
這篇文章主要介紹了IntelliJ IDEA 2019.1.1 for MAC 下載和注冊碼激活,教程，本文通過圖文并茂的形式給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-04-04
透過Spring源碼查看Bean的命名轉(zhuǎn)換規(guī)則圖文詳解
Java Bean是一種 Java 編程語言編寫的可重用軟件組件,包括符合一定規(guī)范的Java 類、屬性和方法,用于描述和處理應(yīng)用程序中的數(shù)據(jù)對象,下面這篇文章主要給大家介紹了關(guān)于透過Spring源碼查看Bean的命名轉(zhuǎn)換規(guī)則的相關(guān)資料,需要的朋友可以參考下2023-06-06
super?代表父類的存儲空間標識(可以理解為父親的引用)。?this代表當前對象的引用(誰調(diào)用就代表誰)。本文將通過簡單的示例介紹二者的使用與區(qū)別，需要的可以了解一下2022-10-10
Map 使用 Lambda 的 forEach 實現(xiàn)跳出循環(huán)操作
這篇文章主要介紹了Map 使用 Lambda 的 forEach 實現(xiàn)跳出循環(huán)操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-09-09
這篇文章主要介紹了Java8中Stream的使用方式，文章通過Stream的創(chuàng)建展開詳細的介紹，具有一定的參考價值，需要的小伙伴可以參考一下2022-04-04
這篇文章主要為大家詳細介紹了java生成驗證碼圖片的方法，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-02-02
Spring MVC數(shù)據(jù)綁定概述及原理詳解
這篇文章主要介紹了Spring MVC數(shù)據(jù)綁定概述及原理詳解,文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-06-06
SpringBoot基于AbstractRoutingDataSource實現(xiàn)多數(shù)據(jù)源動態(tài)切換
本文主要介紹了SpringBoot基于AbstractRoutingDataSource實現(xiàn)多數(shù)據(jù)源動態(tài)切換，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-05-05
使用OpenFeign實現(xiàn)服務(wù)調(diào)用的方法詳解
OpenFeign是運行在客戶端的聲明式服務(wù)調(diào)用的框架，通過聲明接口的方式來達到對服務(wù)的調(diào)用，本文就來和大家講講如何使用OpenFeign實現(xiàn)服務(wù)調(diào)用吧2023-06-06
這篇文章主要介紹了Java中的@Accessors使用詳解,@RequiredArgsConstructor是Lombok的一個注解,簡化了我們對setter和getter方法操作,它可以作用在類上,也可以作用在類的單個屬性上,需要的朋友可以參考下2024-01-01