rabbitmq 相关问题

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

RabbitMQ 与 .NET 异步/等待

与 RabbitMQ 等消息代理相比,.NET async/await 在概念上有何不同? 问题在于我们需要在两种方法之间做出选择。另外我们不应该...

回答 1 投票 0

无法连接到 RabbitMQ 服务器

我正在尝试运行官方页面提供的示例代码: https://www.rabbitmq.com/tutorials/tutorial-one-dotnet.html 我正在使用这段代码: 使用 RabbitMQ.Client; 使用 RabbitMQ.Client.Eve...

回答 2 投票 0

如何为通过 AddConsumer() 创建的队列配置 PurgeOnStartup?

防止 XY 问题的一些背景: 我正在开发一个系统,其中每 X 分钟发送一条消息以在服务中的 Pod 上运行作业。当所有 pod 都不健康或重新启动时,这些

回答 1 投票 0

Django model.save() 执行不一致的更新

我正在 RabbitMQ 消费者的回调函数中使用 django ORM 与 MySQL 数据库进行通信。这些消费者在单独的线程上运行,并且每个消费者都建立了......

回答 1 投票 0

运行“rabbitmq-plugins启用rabbitmq_management”..失败

首先安装 二郎 兔子MQ服务器 然后,尝试运行命令来启用插件,如下所示: C:\Program Files (x86)\RabbitMQ 服务器 abbitmq_server-3.6.9\sbin>rabbitmq-plugins 启用

回答 3 投票 0

无法连接Spring AMQP / Rabbit MQ:org.springframework.amqp.AmqpConnectException:java.net.ConnectException:连接被拒绝:connect

我是 Spring AMQP / Rabbit MQ 的新手。 我在我的项目中使用 Spring AMQP / Rabbit MQ。运行tomcat后遇到以下错误: org.springframework.amqp.rabbit.listener.

回答 6 投票 0

带有 RabbitMQ 崩溃的 Docker 容器

首先,这似乎是一个与此处发布的类似问题:Droping container with RabbitMQ in Docker 然而,几天后该线程似乎不活跃,我很想向...

回答 3 投票 0

如何将来自 RabbitMQ 代理的“byte[]”数据转换为 Ballerina 中的记录类型

我在 ballerina 包中使用 RabbitMQ 模块以及服务器和客户端。在客户端中,我收到的内容为 byte[],需要在...之前转换为 CustomerDetails 记录类型

回答 1 投票 0

Spring Boot RabbitMQ 尝试反序列化未经授权的类异常

我在 Spring Boot 项目中使用 RabbitMQ: 发件人 @成分 @AllArgsConstructor 公共类 UserSender { 私人最终 RabbitTemplaterabbitTemplate; 公共字符串发送(){ 用户你...

回答 1 投票 0

SpringBoot RabbitMQ 尝试反序列化未授权类异常

我在Springboot项目中使用RabbitMQ: 发件人 @成分 @AllArgsConstructor 公共类 UserSender { 私人最终 RabbitTemplaterabbitTemplate; 公共字符串发送(){ 使用我们...

回答 1 投票 0

RabbitMQ 和 GCP Pub/Sub 集成

我正在致力于集成 RabbitMQ 和 GCP Pub/Sub。 我正在使用 Pika 库和 Python。连接是通过BlockingConnection 建立的。 我的消费者作为单独的线程运行。最大预期

回答 1 投票 0

如何在MassTransit中制作过滤器?

我正在尝试处理 MassTransit,我有许多带有 StableDefussion 的服务器,它们接受在队列中生成图像的任务 但事实是不同的服务器有不同的...

回答 1 投票 0

Azure Fuction 应用程序 RabbitMQTrigger AES 加密消息未正确解密。有效负载似乎不是 Base64 字符串

抱歉,但我对解密 aes 消息和 RabbitMQ 还很陌生。 我有一个带有以下 RabbitMQ 触发器的 azure 函数应用程序: 代码: [FunctionName("RabbitMQTriggerTest")]

回答 1 投票 0

在 TestSuite 中模拟 AMQPTemplate

我正在将 JUnits 作为 TestSuite 运行。 JUnit 类之一用于测试将消息发布到 RabbitMQ 的代码。我应该模拟代码以将消息发布到 MQ。怎么会...

回答 1 投票 0

Quarkus 反应式消息传递rabbitmq 连接器,具有客户端证书身份验证

我想使用 Quarkus RabbitMQ 连接器连接到 RabbitMQ Broker(队列)。客户需要同行验证和客户端证书身份验证(而不是用户名/密码...

回答 1 投票 0

Spring Cloud Stream Rabbit Binder 并发

我有一个消费者微服务,用于处理来自其他生产者微服务的消息。我使用 Spring Cloud Stream 和 RabbitMq Binder 管理事件驱动结构。 我想限制最大浓度...

回答 1 投票 0

Spring amqp RetryCache 抛出 AmqpRejectAndDontRequeueException 时未清除

我有一个简单的 Rabbit 侦听器,它总是抛出 AmqpRejectAndDontRequeueException (以测试侦听器是否可以处理多个无效消息)。 配置是: @RabbitListener( id = 测试配置。

回答 1 投票 0

k8s 内部网络似乎堵塞了

有一个 k8s 安装,除了许多其他安装之外,还托管两个 pod:一个微服务和一个 RMQ 实例。我还可以在本地计算机上运行微服务,微服务从中进行对话......

回答 1 投票 0

“无法加载模块E:\.....“,但是我已经将环境变量ERLANG_HOME配置为D:...,

我想在Windows 10上安装RabbitMQ。我按照官方手册告诉我必须先安装erlang。我下载了 erlang 并配置了位于 D 的环境变量...

回答 1 投票 0

通过 RabbitMQ 取消 Rust 中长时间运行的 Rayon 任务的策略 [已关闭]

我正在用 Rust 开发一个执行器来处理计算密集型任务,作为大型 Web 应用程序的一部分。执行器从 RabbitMQ(使用 lapin)接收作业并处理各种 CPU 密集型操作...

回答 1 投票 0

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