rabbitmq 相关问题

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

RabbitMQ MassTransit 批量竞争消费者

我已经设置了事件ExampleEvent的批量使用者,并将其设置为ConcurrencyLimit = 16、MessageLimit = 100、TimeLimit = 5秒并按ExampleEvent.GroupingKey字段分组。 这很好用...

回答 2 投票 0

错误:主机“172.27.0.5”没有 pg_hba.conf 条目,什么?

我有一个错误困扰了我好几天,当我尝试编译我的auth(rabbitmq)和我的hyper(api网关)时,我的api有点工作,我需要下载一些包,但我的auth给出了Postg ...

回答 1 投票 0

使用供应商为 RabbitMq 生成消息

我需要轮询消息并将其发布到 RabbitMQ。设置了100个store,每个store可以轮询5条以上消息并将其发布到RabbitMQ。每分钟进行一次轮询。下面是

回答 1 投票 0

NestJS RabbitMQ @golevelup/nestjs-rabbitmq 如何模拟服务调用来发布

我有一个使用 @golevelup/nestjs-rabbitmq 模块的工作发布/订阅实现。 我想编写一个服务规范来测试 MessagingService 的发布方法,该方法调用 AmqpConne...

回答 1 投票 0

RabbitMQ:多个消费者的循环

项目主要由三部分组成: 生产者(设备)通过 MQTT 协议向 Broker 发送数据 RabbitMQ 代理 用于应用程序和代理之间通信的消费者(spring AMQP)。 (设备 MQTT

回答 1 投票 0

向所有应用程序实例广播事件

在其中一个应用程序中,正在使用内存缓存,考虑到该应用程序有多个实例正在运行,是否有办法刷新/更新相同的内容。 使用集中式缓存...

回答 1 投票 0

rabbitmq:在预检查阶段检查每个rabbit主机名是否唯一解析为正确的IP地址

我尝试按照此链接在运行 CentOS 8.3.2011 的虚拟机上部署 OpenStack,但在运行命令时在预检查阶段出现错误: kolla-ansible -i ./一体化

回答 3 投票 0

RabbitMQ 将有效负载铲入 ActiveMQ Classic 的消息格式问题

我有一个设置,其中 RabbitMQ 中的队列通过 AMQP (1.0) 将数据铲到 ActiveMQ Clasic 6.0.1 中的队列。 从 RabbitMQ 发布以下数据(JSON)时 {“你好”:“世界&q...

回答 1 投票 0

Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection::ack():返回值必须是bool类型,返回null

我在处理消息时遇到此错误,问题出在哪里?它在重新启动之前有效。我可以连接到兔子。 我没有改变任何东西,作曲家使用该作曲家配置进行更新。排队停止工作...

回答 1 投票 0

Celery Beat 无法连接到 Rabbitmq 容器

我的 celery Beat docker 容器(据我认为)连接消息代理时出现问题。 我有一个正在运行的 RabbitMQ 容器: .... 兔子MQ: 图片:rabbitmq:3.11.13-management-alpine

回答 1 投票 0

如何重启SimpleMessageListenerContainer

我尝试使用 Spring Boot 连接到 RabbitMQ。连接应始终重新启动/重试连接。我在发生致命异常后重新连接时遇到问题。应用程序永远不会丢失

回答 2 投票 0

连接到docker容器内的rabbitmq时出现问题

我正在编写一个简单的应用程序来测试与rabbitmq的使用。这是代码: 包主 进口 ( “日志” “时间” “github.com/streadway/amqp” ) 功能

回答 1 投票 0

Spring Integration MQTT 共享订阅

我的项目需要支持mqtt。我使用 RabbitMQ 作为代理。我开发了 Spring Boot 应用程序,并使用 Spring Integration MQTT。 @配置 公共类 MqttConfig { @豆 公开

回答 1 投票 0

如何使用 updateUser(rabbitmq) 哈希新传递的密码?

好吧,我可以在 createUser 中对我的密码进行哈希处理,但是,要更新用户,我需要对这个新传递的密码进行哈希处理,但是当我有 data.senha: senhaHasheada 或 usuarioachar.senha: senhaHasheada 时,我可以...

回答 1 投票 0

使用bitnami/rabbitmq图表从github安装额外的rabbitmq插件

目标:为bitnami提供的rabbitmq图表准备一个values.yaml文件,以便插件rabbitmq-message-deduplication在运行helm install后准备就绪并可用... 以前的解决方案...

回答 2 投票 0

如何配置消费者生成的错误队列以使用与正常队列相同的路由键?

假设我有一个消费者: 公共类 TestConsumer : IConsumer { ... 配置为使用路由密钥: cfg.ReceiveEndpoint("test_queue", e=> {...

回答 1 投票 0

没有端点可访问rabbitmq客户端,安装后我无法从任何vsto连接到rabbit mq服务器

已经用 C# 构建了一个 VSTO Outlook 插件,它使用 RabbitMQClient 库与我的 RabbitMQ 代理集成。在 Visual Studio 2022 中进行开发期间,连接按预期运行。哈...

回答 1 投票 0

无法向邮递员发送请求,列违反了非空约束?

我需要使用rabbitmq通过apigateway将用户发送到我的存储库(postgres),但它说名称和其他列违反了非空约束?什么?是数据库错误吗?一些错误? ,d...

回答 1 投票 0

rabbitmq 管理页面上输入错误

我已经安装了rabbitmq并且使用得很好,但仅在某些PC上出现以下错误。我认为是版本问题,所以我重新安装了版本到最新的3.12.12,删除了c...

回答 1 投票 0

pika `从空队列中弹出`

我在 kubernetes 集群中使用 pika 并使用队列中的消息,这会触发在新线程中启动函数。然而 RabbitMQ 似乎崩溃了,这些是我找到的最好的日志,所以......

回答 2 投票 0

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