springboot整合rabbitMQ-路由模型

路由的模型，这个就是多了一个路由键，消息里面有路由键，队列里面有路由键，只有路由键匹配之后，才可以消费者获取到数据。

生产者
@Test
void testRouter() {
//使用rabbitmq直接往队列里面放数据
// convertAndSend（）第一个参数是
rabbitTemplate.convertAndSend("directs","info","direct 模型里面发送的消息");
}

这个生产者在发送消息的时候，就可以在这个消息里面加路由键了。

消费者
@Component
public class RouteConsumer {

@RabbitListener(bindings = {
@QueueBinding(
value = @Queue, //创建临时队列
exchange = @Exchange(value = "directs",type = "direct"), //绑定的交换机
key = {"info","error","warn"}
)
})
public void receivel(String message){
System.out.println("message1="+message);
}

@RabbitListener(bindings = {
@QueueBinding(
value = @Queue, //创建临时队列
exchange = @Exchange(value = "directs",type = "direct"), //绑定的交换机
key = {"error"}
)
})
public void receive2(String message){
System.out.println("message2="+message);
}
}

因为发送者已经发送了加路由键的信息，所以消费者也要写对应的路由键，这样路由键进行匹配之后，才可以接受到对应的数据。

springboot整合rabbitMQ-路由模型相关推荐

RabbitMQ,RabbitMQ 的工作模式,Spring 整合 RabbitMQ,Springboot 整合RabbitMQ
什么是RabbitMQ 1.1 MQ概述 MQ全称 Message Queue(消息队列),是在消息的传输过程中保存消息的容器.多用于分布式系统之间进行通信. ⚫ MQ,消息队列,存储消息的中间件 ⚫ ...
Springboot整合RabbitMQ,包含direct,topic,fanout三种模式的整合
一 RabbitMQ的介绍 RabbitMQ是消息中间件的一种,消息中间件即分布式系统中完成消息的发送和接收的基础软件.这些软件有很多,包括ActiveMQ(apache公司的),RocketMQ(阿 ...
腻害，高人都是这样玩SpringBoot整合RabbitMQ
一.认识 RabbitMQ RabbitMQ 简介以 AMQP 协议: (1)RabbitMQ 是开源的消息代理和队列服务器,用来通过普通协议在完全不同的应用之间共享数据,RabbitMQ 底层是用了 ...
SpringBoot 整合RabbitMq
SpringBoot 整合RabbitMq (黑马讲义) SpringAMQP是基于RabbitMQ封装的一套模板,并且还利用SpringBoot对其实现了自动装配,使用起来非常方便. SpringA ...
九、springboot整合rabbitMQ
springboot整合rabbitMQ 简介 rabbitMQ是部署最广泛的开源消息代理. rabbitMQ轻量级,易于在内部和云中部署. 它支持多种消息传递协议. RabbitMQ可以部署在分布式 ...
SpringBoot整合 ActiveMQ、SpringBoot整合RabbitMQ、SpringBoot整合Kafka
1.概念:SpringBoot 整合消息服务2.具体内容对于异步消息组件在实际的应用之中会有两类:· JMS:代表作就是 ActiveMQ,但是其性能不高,因为其是用 java 程序实现的:· AMQ ...
RabbitMq(八) SpringBoot整合RabbitMQ 生产者代码实现
在本章中我们将创建RabbitMQ的生产者工程,并实现生产者端代码实现. springboot整合RabbitMQ生产者工程步骤如下: 创建maven工程引入springboot及RabbitMQ依 ...
Springboot整合一之Springboot整合RabbitMQ
前言目前,springboot已然成为了最热的java开发整合框架,主要是因其简单的配置,并且本身提供了很多与第三方框架的整合,甚至可以让我们在短短的几分钟里就可以搭建一个完整的项目架构.所以,博主 ...
SpringBoot整合RabbitMQ 消息可靠投递、手动ack、延迟队列、死信队列、消息幂等性保障、消息积压
1.消息可靠投递在使用 RabbitMQ 的时候,作为消息发送方希望杜绝任何消息丢失或者投递失败场景.RabbitMQ 为我们提供了两种方式用来控制消息的投递可靠性模式. confirm 确认模式 ...
RabbitMQ原理及SpringBoot整合RabbitMQ
RabbitMQ原理及SpringBoot整合RabbitMQ 1. RabbitMQ环境搭建参考:https://blog.csdn.net/u013071014/article/details/ ...

springboot整合rabbitMQ-路由模型

springboot整合rabbitMQ-路由模型相关推荐

最新文章

热门文章