一、添加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);
}
