0
点赞
收藏
分享

微信扫一扫

SpringBoot-RabbitMQ路由和主题模式

生产者

配置生产者

/**
* @author BNTang
*/
@Configuration
public class RoutingTopicConfig {

/**
* 声明交换机
*
* @return 交换机
*/
@Bean
public TopicExchange topicExchange() {
return new TopicExchange("topics");
}

/**
* 声明队列1 绑定info和warm
*
* @return 队列1
*/
@Bean
public Queue topicQueue1() {
return new Queue("topicQueue1");
}

/**
* 声明队列2
*
* @return 队列2
*/
@Bean
public Queue topicQueue2() {
return new Queue("topicQueue2");
}

/**
* 把队列1 绑定到交换机里面指定user.*的路由key
*
* @return 绑定之后的一个关系
*/
@Bean
public Binding binding1() {
return BindingBuilder.bind(topicQueue1()).to(topicExchange()).with("user.*");
}

/**
* 把队列2 绑定到交换机里面指定user.#的路由key
*
* @return 绑定之后的一个关系
*/
@Bean
public Binding binding2() {
return BindingBuilder.bind(topicQueue2()).to(topicExchange()).with("user.#");
}
}

发送消息

@Test
public void testTopic() {
this.rabbitTemplate.convertAndSend("topics", "user.save", "user.save 的消息");
this.rabbitTemplate.convertAndSend("topics", "user.save.findAll", "user.save.findAll 的消息");
this.rabbitTemplate.convertAndSend("topics", "user", "user 的消息");
}

消费者

消费消息

/**
* @author BNTang
*/
@Component
public class RoutingTopicConsumer {

@RabbitListener(bindings = {
@QueueBinding(
value = @Queue("topicQueue1"),
key = {"user.*"},
exchange = @Exchange(name = "topics", type = ExchangeTypes.TOPIC)
)
})
public void receive1(String message) {
System.out.println("消费者【1】接收到【user.*】消息:" + message);
}

@RabbitListener(bindings = {
@QueueBinding(
value = @Queue("topicQueue2"),
key = {"user.#"},
exchange = @Exchange(name = "topics", type = ExchangeTypes.TOPIC)
)
})
public void receive2(String message) {
System.out.println("消费者【2】接收到【user.#】消息:" + message);
}

}

测试方式同之前章节中的一样。




举报

相关推荐

0 条评论