我有两个组件(让我们称它们为生产者和消费者)连接到相同的基于RabbitMQ主题的交换。 生产者可以发送两种不同的消息类型：Foo和Bar(每条消息的内容都是无关的，但假设它们都有一个id字段)。消费者有一个队列，该队列使用路由关键字msg.#绑定到相同的交换。一旦被使用，消费者所要做的就是在
浏览 29提问于2019-09-08得票数 1
Rebus具有灵活的系统，允许我在web.config中或通过实现自定义IDetermineMessageOwnership来为不同的消息类型指定不同的端点。
据我所知，消息所有权只由一个字符串表示。使用MSMQ传输，此字符串指向消息传递到的队列。使用RabbitMQ，字符串被用作消息的主题，然后将消息传递到名为"Re
浏览 3提问于2013-02-08得票数 3
回答已采纳
我想使用一个非常简单的spring启动应用程序向rabbitmq队列demo-queue发送消息： package com.example.demo;
import java.time.LocalDateTimesampleProducer编写的消息。因此启动供应商并向其查询新消息。但是，我没有看到rabbitmq中的队列被创建并填充了生成的消息。 pom.xm
浏览 32提问于2020-11-24得票数 1
回答已采纳
3回答
使用RabbitMQ web UI，当我在没有当前队列绑定的情况下发布到主题交换时，rabbitmq表示消息已经发布，但没有路由。使用amqp.node时，当我将一个队列绑定到交换并使用"#“(all)开始消费时，我什么也得不到。
我希望收到之前发布但未路由的消息。这个是可能的吗？
浏览 22提问于2016-08-17得票数 3
1回答
使用RabbitMQ 3.7.16和spring-amqp 2.2.3.RELEASE。
多个客户端使用唯一的路由密钥将消息发布到我们的DataExchange服务器中的RabbitMQ主题交换。在没有任何绑定的情况下，交换将通过AE将所有消息路由到data.queue.generic。，并将其绑定到主
浏览 0提问于2020-02-11得票数 2
回答已采纳
4回答
我使用RabbitMQ web-UI创建了一个主题交换TX，并将其绑定到交换的两个队列TX.Q1和TX.Q2，每个队列都绑定了路由密钥rk1和rk1 2，并相应地生成了很少的消息。现在，我想使用创建一个消费者，它只接收来自Q1的消息。以及用于使用消息的方法的注释@StreamListner(S
浏览 5提问于2016-12-13得票数 6
回答已采纳
因此，我们决定在向微服务体系结构的迁移中使用RabbitMQ作为消息/事件总线，但是我们无法找到关于放置队列的最佳方式的明确答案，我们有两个选项可供选择：
一个主交换将是一个扇出交换，然后将消息扇出到一个主队列中进行日志记录和其他用途，另一个子交换将是一个主题交换，并使用消息路由键将消息路由到每个
浏览 1提问于2017-05-10得票数 23
1回答
在这里，我将解释我想要的用例：
然后使用MQTT客户端设置client="client1“，使用相同的交换连
浏览 1提问于2020-10-29得票数 1
回答已采纳
2回答
我创建了一个Spring，它使用了应用程序中的。我使用的是带有RabbitMQ绑定的。这将自动使用我的路由器表达式的结果创建RabbitMQ交换(类型:主题)。我认为下一步是为每个路由器结果创建新的数据流。但是，只能将配置为从队列中读取。当然，我可以手动创建队列并将它们绑定到自动创建的
浏览 0提问于2018-01-16得票数 1
回答已采纳
我已经了解了RabbitMQ的基本原理。有一件事我发现发布者不会直接在队列上发布。exchange根据routing-key和exchange类型决定消息应该在哪个队列上发布(下面的代码使用默认交换)。我还找到了publisher的示例代码。pdfprocess', body='User information')connection.clo
浏览 5提问于2021-02-24得票数 0
回答已采纳
2回答
我成功地设置了一个主题交换( Topic )，并且能够同时向多个消费者传递消息。
使用给定的主题<
浏览 4提问于2016-09-16得票数 2
回答已采纳
1回答
我要寻找的拓扑是到目前为止，我还没有看到在Cloud中定义每个消息的主题的方法。我知道消费者将被绑定到特定的主题，但是在将消息发送到交换之前，生产者如何设置每个消息的主题？source.output().send(MessageBuilder.withPayload(myMessage).build());
不提供任何方式来设置<em
浏览 0提问于2018-05-05得票数 2
回答已采纳
1回答
我有一个使用RabbitMQ的Spring流转换器应用程序。它是从兔子队列中读取，进行一些转换，并写入到兔子交换。我已经将我的应用程序部署到PCF，并绑定到兔子服务。这很好，但是现在我需要一个单独的连接来消费和生成消息。(我想使用一个连接从兔子队列中读取，然后使用不同的连接写入兔子交换)。我该
浏览 3提问于2017-10-04得票数 0
回答已采纳
我基本上是在研究RabbitMQ。我正在编写python代码，其中我试图查看在发生主题交换的情况下，路由密钥是否与绑定模式匹配。我偶然发现了一个链接-- ，其中写道：“但是，绑定键有两个重要的特殊情况：
* (star) can substitute for exactly one word.那么，如何将消息的路由密钥与队列的绑定模式相匹配呢？例如，消息的
浏览 2提问于2018-06-04得票数 2
回答已采纳
1回答
我在生产中使用rabbitmq，在集成测试中使用QPid。我需要编写集成测试，以验证无法路由的消息是否调用了返回通道。我设置了mandatory=true和解除绑定的队列和交换，但是调用的是nack通道(抛出NackedAmqpMessageException)而不是返回通道。从不调用返回通道。我使用Spring AMQP和Spring Boot + Spring
浏览 11提问于2020-04-10得票数 0
应用服务器(消费者)都在监听特定队列。一旦接收到web套接字连接，特定的应用服务器就会将队列与路由密钥{userId}绑定到直接交换。我希望仅由发生绑定的特定应用服务器接收发送到具有路由键{userId}的直接交换的消息。
在这种情况下，直接交换是正确的交换吗？还是应该使用其他类型的交换？当w
浏览 3提问于2016-03-03得票数 4
回答已采纳
我需要将扇出交换绑定到Spring Boot RabbitMQ客户端中的默认交换，但我做不到。当我尝试下面的代码时，我没有看到任何错误，但交换并未绑定(至少它不会在rabbitmq admin中显示，消息也不会路由到该交换)。我的代码：
将路由关键字testq放入testex exchange的消息消失-不会传
浏览 6提问于2021-05-20得票数 0
2回答
我对RabbitMQ和AMQP协议有丰富的经验，并且构建了一个包含命令、请求和事件模式的系统。现在我将构建一个运行在AWS Lambda上的系统，因此使用SNS、SQS等，我想了解这些东西之间的“映射”。其他人是怎么处理的？在我看来，RabbitMQ是一个为满足
浏览 4提问于2017-10-22得票数 9
回答已采纳
我是RabbitMQ的新手。在RabbitMQ中，一旦消息被使用者使用，它是否仍然在队列中可用？来自特定队列的单个消息能被多个使用者使用吗？与卡夫卡不同，在文件系统中存储消息是如何在RabbitMq中存储的？
浏览 4提问于2017-06-12得票数 1
回答已采纳
我有一个服务，它使用来自RabbitMQ队列的消息(向队列投递是通过主题交换完成的)。假设服务理论上可能会失败并失去其状态，那么备份所有用于灾难恢复的消息的可能性就会派上用场。想到的第一个想法是为主题交换添加另一个绑定，以便消息也被发布到另一个队列，并创建一个自定义服务来备份
浏览 0提问于2014-10-14得票数 5
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
