RabbitMQ中报头交换的适当路由键值是什么？
RabbitMQ中报头交换的适当路由键值取决于具体的业务需求和设计。报头交换是一种RabbitMQ的交换机类型，它根据消息的报头信息进行路由。报头信息是消息的一部分，包含了自定义的键值对。
在使用报头交换时，可以根据具体的业务场景和需求，选择适当的路由键值。这个值可以是任意的字符串，用于标识消息的特定属性或特征。例如，可以使用报头键值对来标识消息的来源、类型、优先级等信息。
根据不同的路由键值，可以将消息发送到不同的队列或者交换机。消费者可以根据报头信息来选择订阅特定的消息。
对于报头交换的应用场景，可以包括但不限于以下几个方面：
- 根据消息的属性进行灵活的路由和过滤：通过设置不同的报头键值对，可以实现对消息的灵活路由和过滤，将消息发送到不同的消费者或者队列中。
- 实现消息的优先级处理：通过设置报头键值对中的优先级属性，可以实现对消息的优先级处理，确保高优先级的消息能够被及时处理。
- 实现消息的动态路由：通过动态修改报头键值对的值，可以实现消息的动态路由，将消息发送到不同的目标。
腾讯云提供了消息队列 CMQ（Cloud Message Queue）服务，可以用于实现消息的可靠传输和异步处理。CMQ支持基于RabbitMQ的消息队列，可以满足各种场景下的消息通信需求。具体关于CMQ的产品介绍和使用方法，请参考腾讯云官方文档：CMQ产品介绍。
相关·内容
是否可以使用RabbitMQ和Python进行基于内容的路由？
AMQP标准和RabbitMQ声称支持基于内容的路由，但是Python库是否支持指定基于内容的绑定等？
我目前使用的库(py-amqplib )似乎只支持基于主题的路由和简单的模式匹配(#，*)。
浏览 3提问于2010-07-19得票数 11
回答已采纳
我尝试使用RabbitMQ制作聊天应用程序。
每个会话组都有fanout交换，组成员向其中推送消息并绑定其队列。
但是有了这样的路由成员就会收到自己的消息，所以我必须在客户端代码中过滤它们。
有没有办法进行排除模式匹配，这样exchange就不会用相同的键向队列发送消息？
浏览 3提问于2016-06-17得票数 0
回答已采纳
目前，只有一个Tomcat实例在运行，Apache Camel生成和使用直接路由，并且运行良好。例如：
<dataFormats>
<gzip id="gzip" />
</dataFormats>
<route id="1_consumeAdServerMq" >
<from uri="rabbitmq://localhost/adserver?queue=ad_google_dfa_reporting&routingKe
浏览 1提问于2015-01-29得票数 0
2回答
我是RabbitMQ的新手，我试图找出经纪人和交易所之间的区别。
据我所读，这些术语似乎几乎可以互换使用，而在图表中，代理似乎同时包含了交换和队列。
来自"RabbitMQ简明“一书：
Exchange是向messages发送消息的AMQP实体。交换接收消息，然后将其路由到一个或多个队列。
那么什么是经纪人呢？在RabbitMQ管理层中，有一个“交易所”的标签，而不是经纪人的标签。我是否可以直接与代理交互，或者这仅仅是由交换完成的？
浏览 2提问于2016-02-19得票数 5
回答已采纳
1回答
我希望开发能够动态地将消息路由到不同队列(超过10000个队列)的解决方案。这就是我到目前为止所拥有的：
将类型设置为topic的Exchange。这样我就可以根据路由密钥将消息路由到不同的队列。
将路由密钥作为#.%numberOfQueue.#的10000个队列。%numberOfQueue%是该队列的简单数值(但可能会更改为更有意义的队列)。
生成具有路由密钥的消息的生产者：5.10.15.105.10000，这意味着消息应该被路由到具有密钥5、10、15、105和10000的队列，因为它们构成了队列的模式。
从java客户端API来看，它是这样的：
String e
浏览 0提问于2017-09-08得票数 0
1回答
是否可以使用RabbitMQ调度消息，并在满足特定条件时删除消息(计划处理的消息)？我们有一个需求，我们需要调用外部服务来获取一些数据。该调用是异步的。客户端调用服务器的API端点，并提到它需要的数据。服务器只会返回一个确认消息，确认它已经收到了来自客户端的请求。在内部，服务器还开始处理客户端请求，并且它将使用某个时候从客户端收到的查询的实际响应来调用客户端API端点。
客户端需要等待服务器的响应是有时间限制的(30秒)。如果客户端在30秒内收到响应，则它将继续执行。即使客户端在30秒内没有收到来自服务器的响应，它也会继续执行其他步骤。
在客户端和服务器之间，每秒都有数千个独立的事务(请求和响
浏览 3提问于2020-08-18得票数 0
我正在尝试设置一个与队列的邮件头交换，其中的邮件是根据收件人邮件头进行路由的。 交换的类型是headers。 到目前为止，该类能够连接到交换并将消息馈送到队列。它还能够订阅队列并接收消息。每当取消订阅者的连接时，它也会关闭连接。 当前的问题是，邮件不是通过收件人的标头值路由的。 给定以下类： import com.rabbitmq.client.*;
import lombok.extern.slf4j.Slf4j;
import reactor.core.publisher.Flux;
import java.io.IOException;
import java.nio.charset
浏览 7提问于2020-08-31得票数 1
回答已采纳
我们正在重建消息队列系统。在研究RabbitMQ交换类型时，我注意到有两种可能的解决方案来实现路由消息的多播特性。
主题交换。通过设置具有特定模式的主题交换和路由密钥，消息将被路由到指定的队列。即产品*。根据AMQP规范，这通常是实现Pub/Sub模式的交换类型。
报头交换所谓的“类固醇直接交换”。更灵活的是多播消息，因为路由密钥被忽略了，相反，每条消息都有“x匹配”头来表示消息应该传递给哪个队列。每条消息都可以以不同的方式动态路由。但是，这种交换类型可能与消息队列设计紧密耦合，因为使用者/生产者必须了解更多关于目标队列的信息。
因此，问题是，是否有人对这两种交换类型都有经验，
浏览 5提问于2014-06-09得票数 15
2回答
使用RabbitMQ作为代理，我希望将所有消息从一个队列复制到另一个队列，以便进行测试/调试。通过RabbitMQ web管理控制台/ cli最简单的方式是什么？
附注:在指定队列的web控制台下，我只能移动消息，而不能将消息复制到新队列。
浏览 293提问于2018-07-31得票数 7
我的项目要求将日志发送到集中式位置(Graylog)服务器。因此，我考虑使用logback.xml中的“Appender”将日志发送到RabbitMq，然后配置Graylog服务器从RabbitMq获取日志。
这就是我的logback.xml的样子。
<?xml version="1.0" encoding="UTF-8"?>
<configuration>
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender"
浏览 3提问于2016-06-06得票数 1
回答已采纳
我是RabbitMQ的新手。在RabbitMQ中，一旦消息被使用者使用，它是否仍然在队列中可用？来自特定队列的单个消息能被多个使用者使用吗？与卡夫卡不同，在文件系统中存储消息是如何在RabbitMq中存储的？
浏览 4提问于2017-06-12得票数 1
回答已采纳
2回答
我们是否可以将消息推送到RabbitMQ，并有一个到期时间，一旦它过期，它应该提供一个通知。或者有什么方法可以在一定时间后在RabbitMQ中传递消息。例如，我希望在队列中推送一条消息，并希望它在10 seconds..and之后同时传递下一条消息。
浏览 2提问于2019-12-31得票数 1
回答已采纳
下面是我继承的一个项目中现有的spring兔子配置-
<rabbit:connection-factory id="rabbitConnectionFactory"
host="${rabbitmq.host}"
port="${rabbitmq.port}"
virtual-host="${rabbitmq.virtualHost}"
username="${rabbitmq.username}"
password="${rabbitmq.password}&
浏览 2提问于2013-07-23得票数 1
1回答
春集成与春云流
、、、、
我在写一个应用程序
轮询目录(流)
一旦该文件可用，它就会将其放入rabbitmq队列中。
Microservice侦听流RabbitMQ并处理文件(这是用Spring编写的)
现在，我不知道从Spring服务向RabbitMQ发送消息的最佳方法是什么。如何使用中的Spring云流将消息发布到RabbitMQ
浏览 0提问于2018-10-03得票数 3
回答已采纳
我使用的是RabbitMq 3.7.16，我有一个交换，希望绑定到两个可能的队列中的一个。
我的用例是将exchange绑定到第一个队列，并将其切换到第二个队列，然后切换回绑定。
当前实现
交换的类型为直接和路由密钥，两者都是"“。
当切换绑定时，我执行绑定(第二个队列)，然后取消绑定(第一个队列)。当我切换回去的时候，我做的正好相反。
问题
我只有几毫秒的时间，两个队列都绑定到交换中，从而接收到相同的消息。我希望每条消息都能到达一个可能的队列.
用RabbitMQ做这种事情的正确方法是什么？
浏览 2提问于2020-11-23得票数 3
我正在寻找一种在RabbitMQ中实现分层路由的方法。我试图在文档中找到答案，但突然失败了。
通常，RabbitMQ允许您通过一些路由键连接到直接交换，但我不清楚如何在多个交换之间路由。
例如，假设我们有带有路由关键字'host1‘的'root’交换和'host1‘交换。我有一个队列绑定到'host1‘交换通过路由关键字他们自己的pids。我可以像‘routing_key 1.31261’那样将消息发布到‘根’交换吗？显然，它并不完全是这样工作的，但是有没有一种方法可以用不同的直接交换来创建一条复杂的路由呢？
浏览 0提问于2016-07-07得票数 0
我不能弄清楚使用RabbitMQ中提供的不同交换类型的实际场景。
浏览 1提问于2015-04-16得票数 2
因此，我们决定在向微服务体系结构的迁移中使用RabbitMQ作为消息/事件总线，但是我们无法找到关于放置队列的最佳方式的明确答案，我们有两个选项可供选择：
一个主交换将是一个扇出交换，然后将消息扇出到一个主队列中进行日志记录和其他用途，另一个子交换将是一个主题交换，并使用消息路由键将消息路由到每个想要的队列。我们期望在子交换后面的队列数量会有多大的数量。这可以用这个图表来解释：
一个主交换，它将是一个主题交换，仍然有一个主队列使用"#“路由密钥绑定到该交换。该主交换机还将处理到其他子交换的主路由，因此路由密钥可能是"agreements.#“、"a
浏览 1提问于2017-05-10得票数 23
我正在尝试从我的Android应用程序连接到一个名为"messages“的队列。
生产者(一个在AMQP协议下的one服务)已经连接，它可以通过RabbitMQ管理面板检查。
为了从我的Android设备连接，我编写了这样的代码。
private void connect() throws Exception {
this.sampleClient = new MqttClient(this.broker, this.clientId);
MqttConnectOptions connOpts = new MqttConnectOptions();
conn
浏览 0提问于2014-12-01得票数 7
1回答
我正在通过流API从salesforce读取数据。我从salesforce检索到的值的格式如下({Name:abcd，id:21221321})。
我喜欢在Mule中使用AMQP连接器将上面提到的值存储在rabbitMQ中，并且我只需要使用Mule从rabbitmq中检索'id‘值。
有没有可能
提前感谢
浏览 11提问于2014-05-14得票数 0
3回答
使用RabbitMQ web UI，当我在没有当前队列绑定的情况下发布到主题交换时，rabbitmq表示消息已经发布，但没有路由。
使用amqp.node时，当我将一个队列绑定到交换并使用"#“(all)开始消费时，我什么也得不到。
我希望收到之前发布但未路由的消息。这个是可能的吗？
浏览 22提问于2016-08-17得票数 3
我正在使用RabbitMQ的循环特性在多个消费者之间发送消息，但是只有其中一个用户一次接收实际消息。
我的问题是，我的消息代表任务，我希望在我的使用者上有本地会话(状态)。我事先知道哪些消息属于哪个会话，但我不知道最好的方法是什么(或者有什么方法？)要使用我指定的算法将RabbitMQ分派给消费者。
我不想编写我自己的业务流程服务，因为它将成为瓶颈，我不希望我的生产者知道哪个消费者会接收他们的信息，因为我将失去使用兔子的解耦。
有没有一种方法可以让RabbitMQ根据预定义的算法/规则而不是循环规则将我的消息发送给用户？
Clarification:我使用几个用不同语言编写的微服务，每个服务都
浏览 4提问于2017-03-24得票数 12
回答已采纳
我有一些问题，让皮卡与路由密钥或交换的方式是一致的，AMQP或RabbitMQ文档。我知道RabbitMQ文档使用了一个旧版本的Pika，所以我忽略了它们的示例代码。
我想要做的是定义一个队列，"order“，并有两个使用者，一个处理交换或routing_key”生产“，另一个处理”测试“。从RabbitMQ文档中可以看出，通过使用直接交换和路由密钥或使用主题交换，这些文档应该非常容易完成。
然而，皮卡似乎不知道如何处理交换和路由密钥。使用RabbitMQ管理工具来检查队列，很明显，Pika要么没有正确地排队，要么RabbitMQ就把它丢弃了。
在使用者方面，不太清楚我应该如何将使用者
浏览 0提问于2011-03-27得票数 4
我刚刚开始使用Spring boot RabbitMQ。我想知道在spring boot rabbitmq (注解配置)的情况下，我们如何分别配置生产者代码和消费者代码。我的意思是，如果我想在spring boot中编写rabbitmq生产者代码，用python编写消费者代码，或者反之亦然-在spring boot中编写消费者代码，在python中编写生产者代码……我在spring boot中找不到单独的生产者和消费者配置。例如，在Spring XML配置的情况下，在发送方，我们只有交换名和路由键可用。生产者端没有关于队列名称或交换类型的信息。但与此形成对比的是，在Spring启动的情况下，队
浏览 2提问于2018-03-25得票数 0
我需要将扇出交换绑定到Spring Boot RabbitMQ客户端中的默认交换，但我做不到。当我尝试下面的代码时，我没有看到任何错误，但交换并未绑定(至少它不会在rabbitmq admin中显示，消息也不会路由到该交换)。我的代码：
将路由关键字testq放入testex exchange的消息消失-不会传递到testq队列。
@Bean
FanoutExchange testExchange() {
return new FanoutExchange("testex");
}
@Bean
Binding t
浏览 6提问于2021-05-20得票数 0
在我的rabbitMQ中有3种不同的交换，我试图将发送到mainex的所有消息路由到其他两个交易所-- dmyex和monex --我尝试使用channel.exchngeBind方法绑定这些交换。
我仍然无法看到发布给mainex的消息将发送给dmyex和monex。
这在RabbitMq中是可能的吗？
我在这里做什么有什么错误吗？
ch.exchangeDeclare("mainex", DIRECT_EXCHANGE_TYPE, true, false, null);
ch.exchangeDeclare("dmyex", CONSISTENT_HASH_
浏览 9提问于2020-07-21得票数 0
回答已采纳
2回答
我把局域网电缆从LAN-1端口连接到同一个路由器拥有的LAN-2端口。
然后发生了非常奇怪的事情：
在10-15秒的时间里，什么都没有发生，调制解调器上的任何一个灯都没有被改变.
路由器上的灯发狂了，他们眨眼很快。
连接到该路由器的所有计算机都断开连接。
我必须重新启动路由器，否则我的设备将无法连接到它。
我的问题是发生了什么？技术细节是什么？
浏览 0提问于2016-08-05得票数 1
回答已采纳
1回答
我读到了关于单块应用程序的会话粘性的文章。想了解微型服务的可行性。
Q1。特别是对于微服务而言，会话粘性的缺点是什么？互联网上很少谈论这件事！由于同一个实例可能被重载(取决于应用程序的其他设计因素)，它似乎受到了严重的影响。有的优势吗？请在这上面放点光
鉴于rabbitMQ消息用于微服务间通信，是否有可能使rabbitMQ消息具有会话粘性，并将其路由到工作队列。也就是说，消息中的报头可能有session=xxx，所有具有相同会话到达队列的消息都被路由到同一个客户机。
RabbitMQ或AMQP似乎没有这样的配置。
可能的客户端实施：
Publisher发布带有路由密钥handshake和会
浏览 0提问于2018-02-21得票数 4
是否可以将RabbitMQ交换或队列配置为在任何时候最多有一个具有给定路由键的消息处于挂起状态？如果新的消息到达，旧的消息将被丢弃，新的消息将入队。
如果此选项不可用，那么在应用程序级别实现此功能的最佳方式是什么？例如，当应用程序接收到消息时，它如何检查是否有更多的未决消息？
浏览 0提问于2012-11-19得票数 3
回答已采纳
我有一个用于生成文档的RabbitMQ队列。基本上，每个文档都有type和state (新的、处理的、就绪的)，所以我使用主题交换和路由键(如type.state )。每次文档更改时，我都会将带有最后文档描述的消息发送到exchange，这样就足够好了。
然而，有时文件可以处理两次：
用户发送新文档。因此，新消息report.new被发送到交换。
虽然worker尚未启动文档处理(队列尚未到达)，但用户更新了文档。发送同一文档的新消息report.new。
所以现在工人收到第一条消息并开始他的工作，而文档被更改了，所以这个工作是完全没有意义的。
现在，我只是在工作人员中添加
浏览 6提问于2017-08-07得票数 6
回答已采纳
2回答
MPLS报头如何提供有关下一协议的信息？
我在互联网上做了一些研究，发现路由器保存着这些信息，因为路由器是分配标签的人。
但是在每次标签交换时，都必须有一些关于下一个协议的信息，这些信息可以在分组离开MPLS域时提取出来。
浏览 1提问于2015-08-13得票数 2
我们在MSMQ上使用NServiceBus。现在我们正在使用RabbitMQ --我们想要一个集中的队列，并且发现RabbitMQ最能满足我们的需求。
转换我们的项目很容易，在RabbitMQ中，我们注意到它为该端点中的每个端点和消息类型创建了一个交换(和队列)。
我已经阅读了在中更改路由拓扑的部分，并在那里编写了
对于不太复杂的场景，可以使用DirectRoutingTopology
文档未能解释的是将解决方案视为complex的参数。
我已经搜索过了，但是找不到一个地方解释了什么是复杂的，以及什么时候应该在使用多个交换的默认选项之上使用DirectRoutingTopology。或
浏览 7提问于2015-10-14得票数 0
我一直在评估我的公司的消息传递技术，但我对几个术语之间的概念差异感到非常困惑：
Pub/Sub vs Multicast vs 扇出I使用以下定义：
Pub/Sub让发布者将每条消息的一个单独副本传递给每个订阅者，这意味着有机会保证发送
扇出有一个队列推送到所有侦听客户端。
多播只是发送数据，如果有人在监听，那么好的，如果没有，这并不重要。没有任何可能保证客户肯定会收到消息。
这些定义正确吗？或者是Pub/Sub的模式和多播、直接、扇形等方式来实现模式？
我正在努力将开箱即用的RabbitMQ定义应用到我们的体系结构中，但我现在只是在兜圈子，试图为我们的应用编写规范。
请有
浏览 5提问于2011-11-24得票数 52
回答已采纳
我正在尝试向外扩展RabbitMQ消息传递系统。当前的系统非常简单-生产者向扇出交换发送消息，该消息由多个消费者处理-经典的扇出路由。
我有来自不同类型的多个使用者(例如:一个打印到屏幕，一个记录到文件，一个保存到数据库，...)。我的挑战--我不确定扩展消费者的最佳方式是什么。如果我添加来自相同类型的其他使用者-我将在数据库中获得双倍日志或双倍条目。..。(考虑两个DB消费者从相同的扇出交换中消费)。
我想我可以创建一个发布到工作队列的消费者，但我想知道rabbitmq中是否有更好的“内置”解决方案。
提前谢谢，zf
浏览 0提问于2017-01-16得票数 2
我正在浏览这个链接：
它指出，当使用HTTP或基于HTTP的组件构建桥接应用程序时，通常需要删除或过滤掉路由中的某些标题或标题类，以确保应用程序按预期运行。同样，在org.apache.camel.component.netty4.http.NettyHttpHeaderFilterStrategy中，可以看到许多报头被过滤掉，如下所示：
protected void initialize() {
getOutFilter().add("content-length");
getOutFilter().add("content-type");
浏览 0提问于2016-04-22得票数 0
1回答
我要寻找的拓扑是
到目前为止，我还没有看到在Cloud中定义每个消息的主题的方法。我知道消费者将被绑定到特定的主题，但是在将消息发送到交换之前，生产者如何设置每个消息的主题？
source.output().send(MessageBuilder.withPayload(myMessage).build());
不提供任何方式来设置主题，以供交易所路由到适当的使用者。
或者我不太明白什么？
更新
由于bindingRoutingKey是2222，并且我正在与routeTo 1111一起发送，所以我希望不会在消费者中接收消息。但我还是从消费者那里收到的。
制片性质：
spring.ra
浏览 0提问于2018-05-05得票数 2
回答已采纳
我们在Rabbitmq诊断中发现了一个错误，即：
您收到的消息多于已传递的消息。不路由所有消息可能表示缺少绑定。
只是想知道我如何调试和修复这个问题，或者即使这是一件大事？
浏览 3提问于2019-12-04得票数 0
回答已采纳
这是一个场景-有多个应用服务器。浏览器可以通过websocket连接到任何应用服务器。
应用服务器(消费者)都在监听特定队列。一旦接收到web套接字连接，特定的应用服务器就会将队列与路由密钥{userId}绑定到直接交换。
我希望仅由发生绑定的特定应用服务器接收发送到具有路由键{userId}的直接交换的消息。
在这种情况下，直接交换是正确的交换吗？还是应该使用其他类型的交换？
当websocket出现时，我使用spring创建动态绑定。
// create the RabbitMq queue and bind to it
String routingKey = MessageConstan
浏览 3提问于2016-03-03得票数 4
回答已采纳
我使用RabbitMQ作为消息队列/消息总线进行评估，并一直在查看RabbitMQ页面上的示例。
我正在寻找一个没有包含在教程中的特定场景，我不确定是否以及如何通过RabbitMQ来实现。
安装程序
让我们假设我得到了一项服务，我们把它称为“采购订单”，而我不得不将其他服务称为“物流”和“会计”。
当订单被发送时，我想通过RabbitMQ作为消息发送它。
有2个“帐户”和3个“后勤”服务
怎样才能确保“帐户”和“后勤”只处理一次信息？如果我正确理解，使用pub/sub将导致消息被处理两次(帐户)或trice (物流)。
使用工作队列和prefetch=1，可以确保只有一个得
浏览 2提问于2015-11-29得票数 4
回答已采纳
我正试图将两个队列绑定到一个交换。两个队列必须使用相同的消息(路由密钥)。我可以使用RabbitMQ直接创建这两个队列。但是，当我对Apache进行同样的尝试时，它会抛出一个异常，说明“不允许多个消费者使用同一个端点”。我假设这在Camel中是可能的，因为它是RabbitMQ的一个基本特性。
我正在使用插件。是否有一些额外的配置是必要的，以使这一工作？
浏览 1提问于2019-02-09得票数 1
我对RabbitMQ非常陌生。
我已经建立了一个“主题”交换。消费者可以在发布者之后启动。我希望消费者能够接收在启动之前已经发送的消息，而这些消息还没有被使用。
使用以下参数设置交换：
exchange_type => 'topic'
durable => 1
auto_delete => 0
passive => 0
使用此参数发布消息：
delivery_mode => 2
消费者使用get()从交换中检索消息。
不幸的是，在任何客户端启动之前发布的任何消息都会丢失。我使用了不同的组合。
我想我的问题是交换不能保存消息。也许我需要在发布者和消费
浏览 0提问于2011-05-27得票数 72
回答已采纳
我有两种类型的消息，我想通过RabbitMQ发送。因此，我有两个选择，我可以这样做：
发送消息到与队列名称相对应的routing_key的默认空名exchange。
在队列绑定中使用direct exchange的routing_key参数与使用者的routing_key参数相对应
那么哪一种选择更可取，为什么呢？
浏览 6提问于2013-01-23得票数 5
我是RabbitMQ的新手，想知道一个好的方法来解决这个我正在考虑的问题。我想创建一个服务，该服务订阅一个队列，并且只提取满足特定条件的消息；例如，如果消息中有特定的主题标头。
我仍然在学习关于RabbitMQ的知识，并在寻找有关如何实现这一点的提示。我的问题包括:消费者如何才能仅从队列中提取特定的消息？生产者如何在消息中设置主题标头(如果这是正确的术语？)
浏览 0提问于2012-06-21得票数 23
回答已采纳
3回答
据我所知，直接交换没有合适的用例，就像你能用它做的任何事情一样，你可以用一个扇形交换来做，只是更可以扩展。
更具体地说，在阅读“RabbitMQ in Action”时，作者多次提到了这样的用例--“假设用户上传图片时，需要生成缩略图。但后来市场营销也告诉您，上传照片时要奖励点数。使用RabbitMQ，您只需创建另一个队列，而不需要在制作方工作！”
但是，只有在你有远见的情况下，你才能在制片人方面建立一个狂热的交流。据我所知，直接交换不能完成这一任务，而且只有当您真正希望在exchange和队列之间进行紧密耦合时(而不是这样，因为这才是消息传递系统的重点)，这才是合适的。
这是正确的还是有一个
浏览 0提问于2013-02-26得票数 22
2回答
所以我使用 RabbitMq 和PHP，我的服务器包含RabbitMq和两个Vms (ubuntu )，这是我的代码；
在RabbitmQ服务器中: send.php :
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPConnection;
use PhpAmqpLib\Message\AMQPMessage;
//here when i use localhost i don't get error
$connection = new AMQPConnecti
浏览 2提问于2014-03-19得票数 0
回答已采纳
1回答
我使用的是带有RabbitMQ v3的Masstransit dotnet核心v6.3.1。我的案例是从api网关向其他服务发送请求。服务按主题和网关使用每个请求使用不同的主题。我正在尝试对masstransit使用请求/响应。但是requestClient声明了交换类型为扇出。我不能改变类型。我想对每个请求/响应使用不同的routingKey。我该怎么做呢？
我在网关中使用过：(startup.cs)
cfg.AddRequestClient<ISimpleRequest>();
(自定义控制器)
await client.GetResponse<ISimpleRespon
浏览 4提问于2020-05-19得票数 3
My场景:
我们正在使用RabbitMQ向网络中的大约300台其他计算机广播消息。我们在Windows上使用RabbitMQ，C#.Net客户端(EasyNetQ)
基本解决方案是为每台目标计算机分配一个路由密钥，定义一个交换并将每个routingkey绑定到一个队列，并为每个队列定义一个铲子到目标服务器。在这种情况下，我们有一个交换，300个队列和300个铲子。
问题陈述:维护和管理这种数量的铲子和队列是困难的，并迫使更多的负载到狂犬病。
问题:我认为有一个简单的方法:定义一个交换、一个队列和基于路由的铲子(300)。你推荐什么解决方案？
提前谢谢。
浏览 1提问于2017-01-17得票数 0
1回答
我在骆驼中的routeContext中定义了一个简单的路由(这个路由将用于多个路由)。
<route id="sendToRabbitQueue">
<from uri="direct:sendToQueue" />
<convertBodyTo type="java.lang.String"/>
<setHeader headerName="rabbitmq.ROUTING_KEY">
<cons
浏览 5提问于2015-09-03得票数 5
回答已采纳
我正在使用rabbitmq客户端()。我想通知是否有消息发送到rabbitmq服务器，但我找不到任何与消息是否真的发送有关的内容。
谁能告诉我如何知道我是否将一条消息发布到一个队列，该消息是否真的到达rabbitmq服务器？提前感谢！
Kinh
浏览 1提问于2016-11-02得票数 0
我正在做一些研究，看rabbitMQ是不是适合我。
我可以混合使用发布/订阅队列和工作队列吗？
我们的目标是有几个队列，其中包含特定进程的项。每个进程都可以有很多工作进程。
浏览 1提问于2019-07-10得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
