首先在生產者和消費者中都添加兩個依賴

<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>

然后在生產者和消費者中都添加配置文件application.yml

server:port: 44000 spring:application:name: test-rabbitmq-producerrabbitmq:host: 127.0.0.1port: 5672username: guestpassowrd: guestvirtualHost: /

編寫生產者test-springBoot-producer的配置類RabbitMQConfig

import org.springframework.amqp.core.*; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration;@Configuration public class RabbitMQConfig {//定義隊列的名稱public static final String QUEUE_EMAIL="queue_topic_email";public static final String QUEUE_SMS="queue_topic_sms";//定義交換機的名稱public static final String EXCHANGE_TOPIC_INFORM="exchange_topic_inform";//定義路由key的值public static final String ROUTING_EMAIL="inform.#.email.#"; // inform.emailpublic static final String ROUTING_SMS="inform.#.sms.#";//聲明隊列@Bean(QUEUE_EMAIL)public Queue QUEUE_EMAIL(){Queue queue = new Queue(QUEUE_EMAIL);return queue;}@Bean(QUEUE_SMS)public Queue QUEUE_SMS(){Queue queue = new Queue(QUEUE_SMS);return queue;}//聲明交換機@Bean(EXCHANGE_TOPIC_INFORM)public Exchange EXCHANGE_TOPIC_INFORM(){return ExchangeBuilder.topicExchange(EXCHANGE_TOPIC_INFORM).durable(true).build();}//隊列綁定交換機@Beanpublic Binding BIND_QUEUE_EMAIL(@Qualifier(QUEUE_EMAIL)Queue queue,@Qualifier(EXCHANGE_TOPIC_INFORM)Exchange exchange){return BindingBuilder.bind(queue).to(exchange).with(ROUTING_EMAIL).noargs();}@Beanpublic Binding BIND_QUEUE_SMS(@Qualifier(QUEUE_SMS)Queue queue,@Qualifier(EXCHANGE_TOPIC_INFORM)Exchange exchange){return BindingBuilder.bind(queue).to(exchange).with(ROUTING_SMS).noargs();} }

編寫test-springBoot-producer的啟動類

import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplicationpublic class TestProducerApplication {public static void main(String[] args) {SpringApplication.run(TestProducerApplication.class,args);}}

編寫消費者test-springBoot-consummer的監聽類MyConsummer

import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component;@Component public class MyConsumer {//監聽方法@RabbitListener(queues = {"queue_topic_email"})public void receiveEmailMessage(String message){System.out.println("郵件隊列："+message);}@RabbitListener(queues = {"queue_topic_sms"})public void receiveSmsMessage(String message){System.out.println("短信隊列："+message);} }

配置test-springBoot-consummer的啟動類

import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplicationpublic class TestConnsumerApplication {public static void main(String[] args) {SpringApplication.run(TestConnsumerApplication.class,args);}}

這樣就整合完成了

總結

以上是生活随笔為你收集整理的SpringBoot整合RabbitMQ测试的全部內容，希望文章能夠幫你解決所遇到的問題。

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