31得票2回答
为什么在RabbitMQ中需要使用路由键?

为什么我们需要路由键来将消息从交换机路由到队列?我们不能直接使用队列名称来路由消息吗?此外,在向多个队列发布时,我们可以使用多个队列名称。有没有人能指出实际上需要路由键而队列名称不足的情况?

8得票1回答
确保在主题交换机上发布的消息至少被一个消费者接收

在主题交换和由消费者动态创建的队列的上下文中,当没有消费者消费消息时如何重新传递消息/通知生产者? 我有以下组件: - 一个主要服务,生成文件。每个文件都有一个特定的类别(例如pictures.profile、pictures.gallery)。 - 一组工作人员,消耗文件并从中产生文本...

7得票1回答
Spring-boot-starter RabbitMQ 全局错误处理

我正在使用spring-boot-starter-amqp 1.4.2。生产者和消费者工作正常,但有时传入的JSON消息语法不正确。这会导致以下(正确的)异常: org.springframework.amqp.rabbit.listener.ListenerExecutionFailedE...

11得票3回答
使用MassTransit发布消息的方法是通过交换器和路由键来实现的。

我已经花了几个星期的时间研究 MassTransit,对其可能性很感兴趣。然而,我似乎还没有完全理解这些概念。 期望行为 我想将消息发布到一个“直接”交换机,该交换机绑定到两个不同的队列以执行其他活动。 当我尝试使用 MassTransit 实现相同的逻辑以获得更好的可扩展性时,我发现 M...

21得票1回答
使用Spring Boot创建多个RabbitMQ队列

从Spring Boot教程中:https://spring.io/guides/gs/messaging-rabbitmq/他们给出了创建一个队列和仅一个队列的示例,但是如果我想创建多个队列怎么办?这是否可能?显然,我不能简单地两次创建相同的bean:@Bean Queue queue() ...

8得票2回答
RabbitMQ镜像队列和交换机

有没有可能使用联邦或铲子将一个服务器上的交换机和队列的创建镜像到另一个服务器上? 所有我看过的使用铲子和联邦的例子都是使用已经存在于服务器上的交换机和队列。我的要求是在服务器A上创建一个交换机,并通过联邦或铲子重新在服务器B上创建它,然后开始向其发送消息。 如果不能使用联邦或铲子来实现此操...

8得票1回答
如何在Web浏览器上使用php-amqplib RabbitMQ

我正在尝试使用php-amqplib进行消息的发送和接收。在终端上,它可以正常地发送/接收消息。但是,在Web浏览器中,无法从队列中接收消息,它会不断等待消息。我在receive.php中使用了以下代码: require_once(__DIR__ . '/lib/php-amqplib/am...

7得票1回答
RabbitMQ - 用户'guest'被拒绝访问虚拟主机'XXX'。

我正在使用RabbitMQ 3.0.3版本。服务在过去的4-5年中一直正常运行。最近服务器安装了一些更新补丁,服务停止响应。以下是发生的情况: RabbitMQ服务(Windows服务)正在运行但没有响应。 在日志文件中,我看到错误信息access to vhost 'XXX' refus...

26得票6回答
Rabbit mq - 等待 Mnesia 表时出错

我已经在Kubernetes集群上使用Helm Chart安装了RabbitMQ。RabbitMQ的pod一直在重新启动。检查pod日志后,我得到了以下错误信息。2020-02-26 04:42:31.582 [warning] <0.314.0> Error while wait...

11得票2回答
RabbitMQ的fanout交换机问题

使用发布/订阅的RabbitMQ Java教程,我可以创建一个扇出交换机,并且任何连接的消费者都将接收到消息的副本。与动态/编程方式声明交换和绑定不同,我想在连接任何消费者之前创建交换和绑定。我通过RabbitMQ管理控制台完成了这个过程。然而,由于某种原因,我的消费者是以轮询的方式接收消息,...