SpringBoot集成RabbitMQ

一、添加maven依赖及yml配置

<dependency>

        <groupId>org.springframework.boot</groupId>

        <artifactId>spring-boot-starter-amqp</artifactId>

</dependency>

spring.application.name=spirng-boot-rabbitmq

spring.rabbitmq.host=127.0.0.1

ing.rabbitmq.port=5672

spring.rabbitmq.username=admin

spring.rabbitmq.password=123456

二、添加配置类

rabbitmq有三种分发模式，这里使用Topic模式

@Configuration

publicclassTopicRabbitConfig{

finalstaticString message ="topic.message";

finalstaticString messages ="topic.messages";

@Bean

publicQueuequeueMessage(){

returnnewQueue(TopicRabbitConfig.message);

    }

@Bean

publicQueuequeueMessages(){

returnnewQueue(TopicRabbitConfig.messages);

    }

@Bean

TopicExchangeexchange(){

returnnewTopicExchange("exchange");

    }

@Bean

BindingbindingExchangeMessage(Queue queueMessage, TopicExchange exchange){

returnBindingBuilder.bind(queueMessage).to(exchange).with("topic.message");

    }

@Bean

BindingbindingExchangeMessages(Queue queueMessages, TopicExchange exchange){

returnBindingBuilder.bind(queueMessages).to(exchange).with("topic.#");

    }

}

三、添加消息生产者

public void send1() {

String context ="hi, i am message 1";

System.out.println("Sender : "+ context);

this.rabbitTemplate.convertAndSend("exchange","topic.message", context);

}