rabbitmq 相关问题

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

MassTransit (C#) 中跨端点的并发限制

公共交通3.5, 兔子Mq 我有一个总线连接服务,可以侦听队列数量。 Q1 Q2 第三季度 第四季度 ETC 所有队列都接受相同的消息类型,并且所有队列都使用竞争的 con...

回答 2 投票 0

尝试使用 Celery+RabbitMQ 设置优先级队列时出现“PreconditionFailed - 队列的不等价参数‘x-max-priority’”错误

我有 RabbitMQ 设置,有两个队列:低和高。我希望我的芹菜工作人员在消耗低优先级队列的任务之前先消耗高优先级队列的任务。我得到以下信息...

回答 1 投票 0

在 Spring Boot 中使用连接字符串进行 RabbitMQ 配置

在 Spring Boot API 中配置 RabbitMQ 时,通常会转到 application.properties 文件并添加 # RabbitMQ spring.rabbitmq.host=主机 spring.rabbitmq.port=端口 spring.rabbitmq.username=用户 春天。

回答 1 投票 0

bitnami helm 图表中的 Rabbitmq,Azure AD 登录按钮不显示

从 Helm Chart 安装了 bitnami/rabbitmq:11.1.1 到 AKS 集群,没有任何问题,但是当我尝试启用 Azure AD 身份验证时,Azure AD 登录按钮不显示。我按照这个指示...

回答 1 投票 0

如何用RabbitMQ实现单一职责原则?

我有几个微服务: WebClient,将数据从 UI 发送到其他服务 服务一,它可以对来自 WebClient 的数据执行一些操作并将其返回给 WebClient 服务二,...

回答 1 投票 0

1 分钟内发送 100 万条消息到队列

我正在使用rabbitMQ接收消息。 我有 1,000,000 条消息需要在 1 分钟内发送并排队。我正在使用 python 的多重处理。我的代码可以发送超过 5 分钟。有可能吗...

回答 1 投票 0

使用 TestContainer 运行集成测试时从数据库获取 null

我正在学习 Java、Spring,并且遇到了用于编写(单元/集成)测试的 TestContainers 库。我尝试编写一个示例应用程序,制作了一个 RabbitMQ 生产者、消费者,然后我编写了一个

回答 1 投票 0

处理微服务请求和响应

如果使用微服务架构实现以下功能,会使用什么样的设计模式? 有一个 API 网关和某种用户管理服务。 T...

回答 1 投票 0

RabbitMQ内存占用高

我目前在生产中使用 RabbitMQ (3.10.25),具有 3 个节点,并包含多个队列: 一个经典的队列 一个仲裁队列(用于处理 nservicebus 命令 - NServiceBus.RabbitMQ 包 8.0...

回答 1 投票 0

多个服务之间状态更新的架构

我有一个前端与主后端通信,该后端依次使用服务 A 和 B,使用 gRPC 调用-响应调用。 A 和 B 各自负责他们所安装的硬件组件...

回答 1 投票 0

使用 Celery 和 RabbitMQ 对 Django 项目进行 docker 化时出现问题

我正在尝试使用 Celery 和 RabbitMQ 来 dockerize 我的 Django 项目。我有一个 Docker Compose 文件,但无法使其正常工作。 这是我的 Docker Compose 文件: 服务: 兔子MQ: ...

回答 1 投票 0

AMQP 将消息插入 Rabbit MQ

我正在尝试使用主机、端口、用户、通行证、交换队列、队列名称和路由密钥将消息插入 Rabbit MQ 在此输入图像描述 出现这些错误- ForgivingExceptionHandler:一个

回答 1 投票 0

Django Pytest 使用rabbitmq 和 celery 给出 Kombu 连接被拒绝[111]

目前我正在使用 pytest、django 和rabbitmq-server 以及 celery 来执行后台任务 然而,我确实注意到,当我运行 pytest 而不在本地计算机上运行服务器时,它会导致很长的

回答 1 投票 0

EasyNetQ 订阅抛出 taskCanceledException

我正在尝试使用 C# 中的 EasynetQ lib 创建 RabitMQ 消息传递的基本示例。 当我在本地主机上执行此操作时,它工作正常,但是当我尝试连接到另一台Mac上的rabbitmq服务器时......

回答 1 投票 0

如何在Python中将输出保存为csv文件

我使用这个Python片段来获取rabbitmq队列大小输出,它已经是csv格式,但是我需要知道如何将此数据保存到文件中。 导入子流程 proc = 子进程。

回答 1 投票 0

如何让我的 RabbitMQ 辅助函数作为 Lambda 函数保持活动状态?

这些工作函数是 RabbitMQ 消费者,用于处理传入请求并回复响应。 我正在寻找有关如何在部署

回答 2 投票 0

如何让我的 RabbitMQ 辅助函数作为 Lambda 函数保持活动状态?

这些工作函数是 RabbitMQ 消费者,用于处理传入请求并回复响应。 我正在寻找有关如何在部署

回答 1 投票 0

我可以在node.js中指定RabbitMQ凭证吗?

我开始使用rabbit.js从node.js应用程序连接到RabbitMQ。 我被阻止在: 错误:服务器关闭通道:403(ACCESS-REFUSED),消息“ACCESS_REFUSED - 操作不

回答 6 投票 0

supervisord 不包括 [include] files=/abs/path/to/files/*conf

我在开发流浪机器中全新安装了supervisord。我已经设置了rabbitmq并从我的Symfony2生产者接收消息。我正在尝试使用supervisord来维护X

回答 1 投票 0

如何使用 RabbitMQ 从 C# 应用程序将二进制数据传输到 C++ 应用程序

我们有一个桌面 C# 应用程序,它将与 C++ 中的 Windows 服务进行通信。我们需要使用 RabbitMQ 将复杂对象(具有许多实体)发送到此 Windows 服务。我们想使用垃圾箱...

回答 1 投票 0

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