接上文 RabbitMQ-发布订阅模式和路由模式
1 主题模式
进行测试,修改配置文件
@Configuration
public class RabbitConfiguration {
@Bean("topicExchange") //这里使用预置的Topic类型交换机
public Exchange exchange(){
return ExchangeBuilder.topicExchange("amq.topic").build();
}
@Bean("yydsQueue")
public Queue queue(){
return QueueBuilder.nonDurable("yyds").build();
}
@Bean("binding")
public Binding binding2(@Qualifier("topicExchange") Exchange exchange,
@Qualifier("yydsQueue") Queue queue){
return BindingBuilder
.bind(queue)
.to(exchange)
.with("*.test.*")
.noargs();
}
}
去掉yyds1,yyds2的绑定关系
启动服务,进入yyds队列详情
进入交换机详情发送消息
首先创建一个消息队列用于接收记录
docker exec -it <容器id> /bin/bash
docker exec -it fa7e07e3ae6366a86a6e5310db56c2414c5dff7795cfeb2c5f22c2c5c39ec5e1 /bin/bash
rabbitmqctl trace_on -p /test
开启后将队列trace
绑定到 amq.rabbitmq.trace
交换机上