rabbitmq 相关问题

RabbitMQ是一个开源消息代理，最初实现AMQP协议，并通过插件架构支持其他消息传递协议。此标记应与涉及RabbitMQ服务器消息代理产品的问题一起使用，或者与RabbitMQ产品的源代码和实现有关的问题一起使用。诸如amqp或mqtt之类的特定协议标签也可以是适当的，以及正在使用的OS和编程语言。

重新传递公共交通信息

我正在研究使用 Masstransit 的消费者，对于特定情况，我希望能够在给定处理状态的情况下重新排队消息。我插入了 AddDelayedMessageScheduler() 和

.net-core rabbitmq masstransit schedule

回答 0 投票 0

如何使用 Spring AMQP 检测到 RabbitMQ 生产者未能将消息发送到 Java 中的适当队列？

我正在尝试使用 Spring AMQP 库验证发送的消息是否已成功放入队列中。当我向队列发送消息时，我发现这些方法似乎没有出错......

java spring rabbitmq spring-amqp

回答 1 投票 0

How to connect RabbitMQ using Telegraf with SSL?

如何使用带 SSL 的 Telegraf 连接 RabbitMQ 和 Kafka？我正在尝试使用带有 SSL 选项的 Telegraf 连接 RabbitMQ 和 Kafka。我已经使用 RabbitMQ 版本 3.11.8 / 3.10.7 测试了设置，...

ssl rabbitmq telegraf

回答 0 投票 0

RabbitMQ 队列的第一条消息导致通道关闭

我队列的第一条消息总是失败。从第二个开始，一切正常！不确定这是否可读：创建新连接：rabbitConnectionFactory#1b940034:0/SimpleConn...

rabbitmq spring-rabbit

回答 4 投票 0

仅从 rabbitmq 队列中检索 5 个元素

队列中有 10 条消息。有没有办法在 10 条消息中只消费 5 条消息？我正在使用 nodejs。这是我的源代码：消费者.js const consumer = async ({routeKey}) =&g...

node.js rabbitmq

回答 0 投票 0

在 RPCException 的 Rabbitmq RPC 模型 nestjs 中的错误处理

我有 2 个服务，一个生产者和另一个消费者。我在消费者中创建了一个 RPCException 来测试它。当生产者服务向消费者和消费者服务发送 RPC 消息时抛出一个

node.js rabbitmq nestjs microservices rpc

回答 1 投票 0

监听一个空的rmq队列网络密集吗？

在微服务系统中，我有两个服务：service1 有一段数据，service2 需要不时更新数据。为了获取状态，service2 调用服务 1

networking rabbitmq amqp

回答 2 投票 0

推送通知/邮件应用程序的消息队列？

我需要一个消息队列，我可以在其中为每个用户订购消息，并且会有多个消费者，每个消费者可以接收任何未被另一个消费者处理的消息。消费者可能会...

apache-kafka rabbitmq message-queue

回答 1 投票 0

哪个队列（Apache kafka、RabbitMQ）最适合在新的执行线程上发送电子邮件，这不会影响 spring boot 应用程序中的 api 性能？

我正在研究 Spring Boot。该场景是使用 java 邮件发件人实现的电子邮件发送，但问题是如果所有操作都成功执行，rest api 必须发送电子邮件...

java spring-boot apache-kafka rabbitmq jakarta-mail

回答 1 投票 0

Masstransit - RabbitMQ.Client.Exceptions.AlreadyClosedException 在处理重负载时

尝试发布 1M 左右的事件时，遇到以下异常。处理 30k 事件时连接关闭。即使我设置了限制，也只有一个频道被创建和使用......

rabbitmq .net-6.0 masstransit

回答 0 投票 0

在 Spring Cloud Stream 中使用多个 rabbitmq 绑定器时忽略绑定路由键

我正在尝试将一个小型 Spring Cloud Stream 应用程序连接到两个不同的 RabbitMQ 系统。对于这两个系统，我想将流输入绑定到现有交换，指定路由键。小...

rabbitmq spring-cloud-stream spring-rabbit spring-cloud-stream-binder

回答 0 投票 0

RabbitMQ 如何更改虚拟主机名称？

我有一个正在运行的 RabbitMQ，虚拟主机名为“app1”，它已经包含交换、队列和消息。现在我想将它重命名为不同的名字让我们说“app2” 是...

rabbitmq

回答 1 投票 0

如何从 python 应用程序建立到 RabbitMQ 的 TLS 连接

我使用带有 Mqtt 插件的 RabbitMQ。我的 docker-compose 如下所示： loopback_users.guest = false listeners.tcp = 无 listeners.ssl.default = 5671 password_hashing_module = rabbit_password_hashing_sh...

python rabbitmq paho python-paho

回答 0 投票 0

兔mq 2.1.3版本

通过扇出方法在 rabbit mq 上消费消息时出现以下错误： 2022-08-24 12:53:29.559 错误 42 --- [2.20.43.29:5672] o.s.a.r.c.CachingConnectionFactory：通道舒...

spring-boot rabbitmq protocol-buffers

回答 1 投票 0

RabbitMQ 单消费者如何订阅多个流？ (C#)

是否可以在 RabbitMQ 中使用单个消费者订阅接收来自多个流的消息？我有以下代码来订阅单个流，并且可以正常工作。是吗

c# .net rabbitmq consumer rabbitmq-stream

回答 1 投票 0

如何让 celery 在完成单个任务后关闭而不返回队列？

我在 celery 中有一个任务只能运行一次，因为它每次运行时都需要从不同的文件夹导入我的模块和子模块的新副本。芹菜不能很好地处理这个，它...