簡介

在Spring項目中，可以使用Spring-Rabbit去操作RabbitMQ

尤其是在spring boot項目中只需要引入對應的amqp啟動器依賴即可，方便的使用RabbitTemplate發送消息，使用注解接收消息。

一般在開發過程中：

生產者工程：

application.yml文件配置RabbitMQ相關信息；

在生產者工程中編寫配置類，用于創建交換機和隊列，并進行綁定

注入RabbitTemplate對象，通過RabbitTemplate對象發送消息到交換機

消費者工程：

application.yml文件配置RabbitMQ相關信息

創建消息處理類，用于接收隊列中的消息并進行處理

搭建生產者工程

添加依賴

修改pom.xml文件內容為如下：

<?xml version="1.0" encoding="UTF-8"?><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><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.4.RELEASE</version></parent><groupId>cs.wanyuan</groupId><artifactId>springboot-rabbitmq-producer</artifactId><version>1.0-SNAPSHOT</version><dependencies><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></dependencies></project>

啟動類

@SpringBootApplicationpublic class ProducerApplication {public static void main(String[] args) {SpringApplication.run(ProducerApplication.class);}}

配置RabbitMQ

1）配置文件

創建application.yml，內容如下：

spring:rabbitmq:host: localhostport: 5672virtual-host: /wanyuanusername: wanyuanpassword: wanyuan

2）綁定交換機和隊列

創建RabbitMQ隊列與交換機綁定的配置類RabbitMQConfig

@Configurationpublic class RabbitMQConfig {//交換機名稱public static final String TOPIC_EXCHANGE = "topic_exchange";//隊列名稱public static final String QUEUE = "queue";//聲明交換機@Bean("topicExchange")public Exchange topicExchange(){return ExchangeBuilder.topicExchange(TOPIC_EXCHANGE).durable(true).build();}//聲明隊列@Bean("queue")public Queue queue(){return QueueBuilder.durable(QUEUE).build();}//綁定隊列和交換機@Beanpublic Binding itemQueueExchange(@Qualifier("queue") Queue queue,@Qualifier("topicExchange") Exchange exchange){return BindingBuilder.bind(queue).to(exchange).with("wanyuan.#").noargs();}}

搭建消費者工程

添加依賴

修改pom.xml文件內容為如下：

<?xml version="1.0" encoding="UTF-8"?><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><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.4.RELEASE</version></parent><groupId>cs.wanyuan</groupId><artifactId>springboot-rabbitmq-consumer</artifactId><version>1.0-SNAPSHOT</version><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency></dependencies></project>

啟動類

@SpringBootApplicationpublic class ConsumerApplication {public static void main(String[] args) {SpringApplication.run(ConsumerApplication.class);}}

配置RabbitMQ

創建application.yml，內容如下：

spring:rabbitmq:host: localhostport: 5672virtual-host: /wanyuanusername: wanyuanpassword: wanyuan

消息監聽處理類

編寫消息監聽器MyListener

@Componentpublic class MyListener {/*** 監聽某個隊列的消息* @param message 接收到的消息*/@RabbitListener(queues = "queue")public void myListener1(String message){System.out.println("消費者接收到的消息為：" + message);}}

測試

在生產者工程springboot-rabbitmq-producer中創建測試類，發送消息：

@RunWith(SpringRunner.class)@SpringBootTestpublic class RabbitMQTest {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void test(){rabbitTemplate.convertAndSend(RabbitMQConfig.TOPIC_EXCHANGE, "wanyuan.insert", "商品新增，routing key 為wanyuan.insert");rabbitTemplate.convertAndSend(RabbitMQConfig.TOPIC_EXCHANGE, "wanyuan.update", "商品修改，routing key 為wanyuan.update");rabbitTemplate.convertAndSend(RabbitMQConfig.TOPIC_EXCHANGE, "wanyuan.delete", "商品刪除，routing key 為wanyuan.delete");}}

先運行上述測試程序（交換機和隊列才能先被聲明和綁定），然后啟動消費者；在消費者工程springboot-rabbitmq-consumer中控制臺查看是否接收到對應消息。

另外；也可以在RabbitMQ的管理控制臺中查看到交換機與隊列的綁定

總結

以上是生活随笔為你收集整理的【消息中间件】Spring Boot整合RabbitMQ的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。