rabbitmq routingkey

RabbitMQ中的Routing Key是用于将消息路由到指定队列的关键字。它在消息发布时与消息一起发送，作为消息的一个属性。Routing Key的主要作用是根据一定的规则将消息发送到匹配的队列中。以下是关于RabbitMQ的Routing Key的详细介绍：

RabbitMQ中的Routing Key

作用：根据一定的规则将消息发送到匹配的队列中。
应用场景：在需要将消息特定地发送给特定消费者时，使用Routing Key可以确保消息被正确地路由到对应的队列。

RabbitMQ中的Routing Key类型

Direct Exchange：直接匹配，消息的Routing Key必须与队列的绑定键完全匹配。
Topic Exchange：支持模糊匹配，Routing Key是由点分隔的字符串，可以包含特殊字符*和#。
Fanout Exchange：广播模式，不考虑Routing Key，消息会被广播到所有绑定的队列。
Headers Exchange：根据消息头属性来路由消息，而不是路由键。

如何使用Routing Key

生产者发送消息时需要指定一个Routing Key，交换机根据这个Key将消息路由到相应的队列。消费者在监听队列时，也需要指定相应的Routing Key来接收特定路由的消息

页面内容是否对你有帮助？

有帮助

没帮助

相关·内容

AMQP-RabbitMQ4路由模式

消息由Exchange发送给Queue时，消息的routingKey必须与该队列订阅的routingKey完全匹配。...- Send msg:[Hello RabbitMq!...- Send msg:[Hello RabbitMq!...- Send msg:[Hello RabbitMq!...- Send msg:[Hello RabbitMq!

4433 0

AMQP-RabbitMQ5主题模式

5633 0

RabbitMQ 最常用的 3 大模式！

消息传递时，RouteKey 必须完全匹配才会被队列接收，否则该消息会被抛弃， import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection...*"只会匹配到"log.erro“ import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory...系列RabbitMQ教程请关注公众号Java技术栈获取阅读。 Fanout交换机转发消息是最快的。...; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; public class FanoutProducer...String routingKey2 = ""; String routingKey3 = "ookjkjjkhjhk";//任意routingkey

3101 0

14-RabbitMQ高级特性-Return返回消息

com.dance.redis.mq.rabbit.returnlistener; import com.dance.redis.mq.rabbit.RabbitMQHelper; import com.rabbitmq.client...; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory...; import com.rabbitmq.client.ReturnListener; import java.io.IOException; public class Sender4ReturnListener...= "abcd.save"; String routingKey2 = "return.save"; String routingKey3 = "return.delete.abc...String msg = "Hello World RabbitMQ 4 Return Listener Message

4253 0

RabbitMQ 最常用的三大模式

5151 0

SpringBoot动态创建绑定rabbitMq队列

SpringBoot动态创建绑定rabbitMq队列一、介绍在以前，我写过一篇如何使用SpringBoot整合rabbitMq的文章。...= rabbitModuleInfo.getRoutingKey(); Assert.isTrue(StrUtil.isNotBlank(routingKey), "RoutingKey...= null, "routingKey:{}未配置exchange", routingKey); Assert.isTrue(StrUtil.isNotBlank(rabbitModuleInfo.getExchange...().getName()), "routingKey:{}未配置exchange的name属性", routingKey); Assert.isTrue(Objects.nonNull...= RABBITMQ_PREFIX + "test.direct.routingKey"; /** * 扇形测试队列 */ String FANOUT_TEST_QUEUE_A

1K1 0

RabbitMQ：订阅模型-匹配模式

阅模型-匹配模式，相比于前两种订阅模型，是更细致的分组，允许在RoutingKey 中使用匹配符 *：匹配一个单词 #：匹配0个或多个单词 RabbitMQ 订阅模型-匹配（topics）模式主要有以下六个角色构成...= "user.save"; channel.basicPublish("logs_topic", routingKey, null, ("The message's routingKey...is " + routingKey + " !")....消息订阅（Fanout）模式 RabbitMQ 消息订阅（Fanout）模式把交换机（Exchange）收到的消息发送给所有绑定了该交换机的队列，忽略路由（RoutingKey）。...2、RabbitMQ 路由（direct）模式 RabbitMQ 路由（direct）模式生产者发送信息时，需要指定一个路由（RoutingKey），交换机（Exchange）会根据路由将消息发送到绑定了此路由的队列中

4722 0

RabbitMQ 安装延迟交换机delay-exchange

安装RabbitMQ 延迟交换机在三台节点上安装延迟交换机插件 1.进入RabbitMQ 插件目录 cd /usr/lib/rabbitmq/lib/rabbitmq_server-3.6.12.../rabbitmq_delayed_message_exchange-20171215-3.6.x.zip 3.解压延迟插件安装包 unzip rabbitmq_delayed_message_exchange...; import java.util.Map; import com.rabbitmq.client.AMQP; import com.rabbitmq.client.Channel; import...; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory...routingKey:delay.delay,convernType:null,deliveryTag:,Msg body:[B@c703b routingKey:delay.delay,convernType

9462 0

hyperf框架使用rabbitMQ生产消息至laravellumen进行消费

需要接管处理消息的queue进行数据格式改造,利用构造同样命名空间的job去进行投递,他会序列化数据,可以debug一下内容哦,然后投递至rabbitMQ后,laravel进行消费就好啦。...('RABBITMQ_EXCHANGE_PASSIVE', false); $this->queue_passive = env('RABBITMQ_QUEUE_PASSIVE', false...); $this->queue_durable = env('RABBITMQ_QUEUE_DURABLE', true); $this->queue_exclusive...= env('RABBITMQ_QUEUE_EXCLUSIVE', false); $this->queue_auto_delete = env('RABBITMQ_QUEUE_AUTODELETE...$ttl; // $delayRoutingKey = $routingKey .

7371 0

快速入门RabbitMQ核心概念

; channel.basicPublish(exchangeName, routingKey, null, msg.getBytes()); } } }...= "user.save"; String routingKey2 = "user.update"; String routingKey3 = "user.delete.abc...(exchangeName, routingKey2, null, msg.getBytes()); channel.basicPublish(exchangeName, routingKey3...= "user.*"; String routingKey = "user.#"; // 声明一个topic类型的Exchange...; // 不设置Exchange默认走direct exchange，此时routingKey就是队列名称 channel.basicPublish

5181 0

RabbitMQ 订阅模型-路由模式

订阅模型-路由模式，此时生产者发送消息时需要指定 RoutingKey，即路由 Key，Exchange 接收到消息时转发到与 RoutingKey 相匹配的队列中。...（Fanout）模式 2、RabbitMQ 路由（direct）模式 3、RabbitMQ 主题（topic）模式 ---- 一、RabbitMQ 订阅模型-路由（Direct）模式 1、RabbitMQ..., null, ("The message's routingKey is " + routingKey + " !")....消息订阅（Fanout）模式 RabbitMQ 消息订阅（Fanout）模式把交换机（Exchange）收到的消息发送给所有绑定了该交换机的队列，忽略路由（RoutingKey）。...2、RabbitMQ 路由（direct）模式 RabbitMQ 路由（direct）模式生产者发送信息时，需要指定一个路由（RoutingKey），交换机（Exchange）会根据路由将消息发送到绑定了此路由的队列中

7031 0

TTL队列消息

TTL队列/消息 TTL: Time To Live, 生存时间 RabbitMQ支持消息的过期时间, 在消息发送时可以指定 RabbitMQ支持队列的过期时间, 从消息进入队列开始计算, 只要超过了队列的超时时间配置...package com.dance.redis.mq.rabbit.ttl; import com.dance.redis.mq.rabbit.RabbitMQHelper; import com.rabbitmq.client...; import com.rabbitmq.client.Channel; import java.util.HashMap; import java.util.Map; public class...4 TTL Exchange Message ... "; channel.basicPublish(exchangeName, routingKey, props, msg.getBytes...; import com.rabbitmq.client.Channel; import java.util.HashMap; import java.util.Map; public class

1.1K2 0

大话RabbitMQ 基础入门

https://cloud.tencent.com/developer/article/1006035 在讲RabbitMQ之前，首先需要在电脑上安装和配置RabbitMQ,网络上已经有很多这类文章，如果懒得去搜索...，可以看看这篇介绍如何安装配置RabbitMQ的文章。...rabbitmq-plugins enable rabbitmq_management 命令时，出现了以下这样的报错 ?...\rabbitmq-plugins enable rabbitmq_management 祝安装顺利！！ ...exchangeName, string routingKey 其中也有一个routingKey,但此RoutingKey非彼Routingkey。

5122 0

深入剖析 RabbitMQ —— Spring 框架下实现 AMQP 高级消息队列协议（上）

目录一、RabbitMQ 与 AMQP 的关系二、RabbitMQ 的实现原理三、RabbitMQ 应用实例四、Producer 端的消息发送与监控五、Consumer 端的消息接收与监控六...1.2 ActiveMQ、RabbitMQ、Kafka 对比现在在市场上有 ActiveMQ、RabbitMQ、Kafka 等多个常用的消息队列框架，与其他框架对比起来，RabbitMQ 在易用性...二、RabbitMQ 的实现原理 2.1 生产者（Producer）、消费者（Consumer）、服务中心（Broker）之间的关系首先简单介绍 RabbitMQ 的运行原理，在 RabbitMQ 使用时...) 设置绑定的 routingKey String getRoutingKey() 获取已绑定的 routingKey void send(String exchange, String routingKey...然后通过 void convertAndSend (String exchange, String routingKey, Object object, CorrelationData data) 方法把信息发送到

1.2K9 0

万字长文：从 C# 入门学会 RabbitMQ 消息队列编程

RabbitMQ 简介 RabbitMQ 是一个实现了 AMQP 协议的消息队列，AMQP 被定义为作为消息传递中间件的开放标准的应用层协议。...安装与配置安装 RabbitMQ 读者可以在 RabbitMQ 官方文档中找到完整的安装教程：https://www.rabbitmq.com/download.html 本文使用 Docker 的方式部署...RabbitMQ 社区镜像列表：https://hub.docker.com/_/rabbitmq 创建目录用于映射存储卷： mkdir -p /opt/lib/rabbitmq 部署容器： docker...run -itd --name rabbitmq -p 5672:5672 -p 15672:15672 \ -v /opt/lib/rabbitmq:/var/lib/rabbitmq \ rabbitmq...: routingKey, basicProperties: null, body: body); // 等待确认已推送到 RabbitMQ if (channel.WaitForConfirms

3.4K4 0

原创 | 消息中间件的工作原理和RabbitMQ入门

：生产者架构消息发给交换器的时候，会指定一个RoutingKey，用来置顶这个消息的路由规则，通过RoutingKey来决定消息流向哪里； Binding：绑定，RabbitMQ中通过绑定将交换器跟队列关联起来...，在绑定的时候会指定一个绑定键（BindingKey），这样RabbitMQ就知道如何正确的将消息路由到对应的队列中去了，也就是生产者将信息发送给交换器时，需要一个RoutingKey，当RoutingKey...完全匹配的队里中，如果消息中的路由键（RoutingKey）如果和 Binding 中的 BindingKey 一致，交换器就将消息发到对应的队列中。...(3) 如果vhost中不存在RoutingKey中指定的队列名，则该消息会被抛弃。 2.fanout 它会将所有发送到该交换器的消息路由到所有与该交换器绑定的队列中。...这种模式的特点： (1) 不需要RoutingKey，我们可以将路由键设置为空即可。

1.6K2 0

RabbitMQ 死信队列

7912 0

RabbitMQ：第三章：Springboot集成RabbitMQ（直连模式，工作队列模式，发布订阅模式，路由模式，通配符模式）

系列文章目录 RabbitMQ：第一章：6 种工作模式以及消息确认机制（理论与代码相结合） RabbitMQ：第二章：Spring整合RabbitMQ（简单模式，广播模式，路由模式，通配符模式，消息可靠性投递...，防止消息丢失，TTL，死信队列，延迟队列，消息积压，消息幂等性） RabbitMQ：第三章：Springboot集成RabbitMQ（直连模式，工作队列模式，发布订阅模式，路由模式，通配符模式 RabbitMQ...例如发送routingKey=hunan.IT,那匹配到hunan....("UTF-8"),messageProperties)); return "message sended : routingKey >"+routingKey+";message >...("UTF-8"),messageProperties)); return "message sended : routingKey >"+routingKey+";message >

4324 0

使用php-amqplib实现RabbitMq

rabbitMq实现的基础类：application/common/lib/classes/rabbitmq/RabbitMq.php 2...., $data) { $this->RabbitMq->sendDirect($routingKey, $data); } /** * 接收(直接交换机...* @param $data */ public function sendTopic($routingKey, $data) { $this->RabbitMq...; $routingKey = input('routingKey', 'info'); $RabbitMqWork = new RabbitMqWork(RabbitMq...; $routingKey = input('routingKey', 'lazy.boy'); $RabbitMqWork = new RabbitMqWork(RabbitMq

8893 0

08-RabbitMQ核心API-Topic Exchange

package com.dance.redis.mq.rabbit.topic; import com.dance.redis.mq.rabbit.RabbitMQHelper; import com.rabbitmq.client...package com.dance.redis.mq.rabbit.topic; import com.dance.redis.mq.rabbit.RabbitMQHelper; import com.rabbitmq.client...; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; public class...= "user.save"; String routingKey2 = "user.update"; String routingKey3 = "user.delete.abc..."; String msg = "Hello World RabbitMQ 4 Topic Exchange Message

1872 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云