rabbitmq 相关问题

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

Spring Boot 消费者类也应该是生产者/rabbitmq

我正在使用rabbitmq和springBoot。我有一个消费者当前正在侦听一个队列,并且应该根据收到的消息向另一个队列发送一条新消息。这就是我的问题。我...

回答 1 投票 0

如何使用pika消费RabbitMQ队列中的所有消息

我想用Python编写一个守护进程,它定期唤醒以处理RabbitMQ队列中排队的一些数据。 当守护进程醒来时,它应该消耗队列中的所有消息(或最小...

回答 2 投票 0

RabbitMQ 真的可以与 Amazon MQ (ActiveMQ) 配合使用吗?

我有一个 Java RabbitMQ 生产者应用程序,我想从 Amazon MQ 在 ActiveMQ 上发送一些消息(我已经创建了代理)。我按照此页面中的步骤进行操作。 我为

回答 1 投票 0

当消息到达共享 RabbitMQ 队列时,KEDA ScaledObject 无法扩展多个 pod

我有以下情况:我有一个 Kubernetes 集群,其中有一个使用 RabbitMQ 进行通信的 Celery 应用程序。我有一个包含 Celery 任务的 pod,但有 3 个不同的

回答 1 投票 0

如何使用 KEDA 查看来自 RabbitMQ 的未确认消息?

我创建了一个 ScaledObject,它根据 RabbitMQ 队列中存在的请求数量来扩展 Celery 工作单元。这是在 Azure Kubernetes 服务集群中。 我使用了以下网址...

回答 1 投票 0

在 RabbitMQ 中,如何判断现有的经典队列是 v1 还是 v2?

有什么方法可以确定现有的经典队列是v1还是v2? 除非我做错了什么,否则管理 UI 似乎不会区分 v1 和 v2。我是不是漏掉了什么……

回答 1 投票 0

spring boot3、rabbitMQ、Zipkin 中的不同请求

我正在使用 Spring Boot 3 和 RabbitMQ。事实证明,当我从微服务 A 向微服务 B 发出请求时,Zipkin 显示了针对微服务 A 的单独请求和不同的

回答 1 投票 0

MassTransit IBusControl.StartAsync“代理无法访问”异常

我正在使用 MassTransit(版本 8.1.3)。我们有 2 个不同的 RabbitMQ 集群,到目前为止我一直在使用其中之一。一切都运转良好。现在,我已经换了一个不同的俱乐部...

回答 1 投票 0

有没有办法通过pika列出rabbitmq中的队列?

我知道我们可以这样做来列出rabbitmq中的队列: rabbitmqctl list_queues 但我怎样才能通过鼠兔做到这一点呢?

回答 2 投票 0

有没有办法通过pika列出rabbitmq中的队列?

我知道我们可以这样做来列出rabbitmq中的队列: rabbitmqctl list_queues 但我怎样才能通过鼠兔做到这一点呢?

回答 2 投票 0

在单活跃消费者模式下使用Spring RabbitMQ Camel

RabbitMQ 具有单一主动消费者模式,其中多个连接的侦听器中只有一个从队列中获取消息 一次只有一个消费者从队列中消费并故障转移到

回答 1 投票 0

RabbitMQ 队列消息

在rabbitMQ Web界面的队列选项卡上,我看到“概述”面板,我在其中找到了这些: 排队的消息: 准备好 未确认 全部的 我猜“总计”消息是什么。但什么是“Rea...

回答 2 投票 0

如何使用 OpenTelemetry 添加 RabbitMQ 跟踪?

我正在使用 OpenTelemetry 来跟踪我的 Web API (ASP.NET)。我使用 Jaeger 来显示痕迹。我有 HTTP、SQL、EF 和 Redis 跟踪。我的 Web API 使用 RabbitMQ 和 MassTransit。我怎样才能将他们的痕迹添加到...

回答 1 投票 0

如何将任意参数传递给 RabbitMQ 中的回调函数?

我试图在 RabbitMQ basic_consume 方法中传递一个需要额外参数的回调函数。 例如,RabbitMQ中的回调函数签名是: def 回调(ch, 方法,

回答 2 投票 0

为什么要用rabbitMQ替换ocelot api网关

我们正在 dotnet core mvc 平台上制作云原生企业业务应用程序。前端应用程序和后端微服务之间的 dotnet core 默认 api 网关是

回答 2 投票 0

使用 RabbitMQ 和 AWS Batch 处理长时间运行的任务和子任务

问题: 我正在开发一个系统,其中有一个生产者启动多个任务,每个任务都可能需要大量时间才能完成。以下是系统架构的概述...

回答 1 投票 0

在 Spring Cloud 配置服务器中转义登录

我有spring cloud配置服务器,它为rabbit提供密码。密码包含“@”。当我使用 static appliation.yaml 运行应用程序时,我必须用 '' 包围值 春天: 兔子MQ:

回答 1 投票 0

在 ASP.NET Core 应用程序中设置 RabbitMQ 使用者

我有一个 ASP.NET Core 应用程序,我想在其中使用 RabbitMQ 消息。 我已经在命令行应用程序中成功设置了发布者和消费者,但我不知道如何设置...

回答 4 投票 0

Node.js 连接到 RabbitMQ 时失败

我有一个node.js应用程序与rabbitmq和mysql一起运行。 设置完所有内容后,当我执行 npm start 时 我已授予用户管理员标签和权限 rabbitmqctl set_permissions

回答 4 投票 0

RabbitMQ:如果消费者永远消失,则删除队列?

想象每个用户都有自己的队列。当用户离线时,消息被放入队列中,当他们重新连接时,他们会收到所有这些消息。 但是,如果客户离开后再也没有

回答 3 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.