rabbitmq 相关问题

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

代理重启后 Spring-AMQP 客户端无法恢复,空闲通道被卡住

所以我有两个微服务通过 RabbitMQ 进行通信,其中一个向另一个微服务发送 RPC 请求(使用 RabbitTemplate#sendAndReceive)。我注意到,如果

回答 1 投票 0

有什么方法可以从SendEndpoint发送消息以与参数alternate-exchange进行交换吗?

我正在尝试使用 ISendEnpoint.Send 方法将消息发送到具有参数alternate-exchange 的 RabbitMq 交换,但我没有找到任何方法来设置此参数的值。 如果我不指定这个

回答 2 投票 0

Rabbitmq:如何使用 spring xml 实现 x-consistency-hash-exchange

所有其他交换类型均在 http://www.springframework.org/schema/rabbit 模式中声明,但在其中找不到 x-consistency-hash-exchange。它在哪里定义的? 尝试实施一致的...

回答 1 投票 0

RabbitMQ Web-MQTT WSS 关闭客户端连接。不安全的 WS 和其他安全协议可以工作

我部署了 RabbitMQ,它使用自己的证书进行端到端加密。它使用 AMQP 和 MQTT-over-WSS 来连接多种类型的客户端。 AMQP 客户端能够连接

回答 1 投票 0

长时间运行的芹菜工作任务即使成功后也不会返回结果

我正在运行远程芹菜工作人员,完成一项任务大约需要 2 小时。 我使用的代理是rabbitmq,后端是rpc。任务完成后,芹菜工人没有回来

回答 2 投票 0

rabbitmq 升级后,RabbitMQ 客户端 .Net Core 在负载下超时。消费者 System.TimeoutException

我们有一个运行 RabbitMQ 3.8.5 和 RabbitMQ.Client 5.2.0 的系统。系统使用rabbit的部分方式是创建一个消费者来等待来自不同执行程序的特定命令...

回答 1 投票 0

如何应对rabbitmq 4.0弃用?

我正在使用rabbitmq和celery。当rabbitmq启动时,我看到以下警告: 已弃用的功能:“transient_nonexcl_queues”:已弃用功能“transient_nonexcl_queues”。 默认情况下,这个

回答 1 投票 0

Flask + Celery + RabbitMQ - kombu.exceptions.operationalerror errno 111 连接被拒绝

下面是flask+celery+rabbitMQ的代码片段,问题是它们在本地工作,但是当我部署在EC2实例上时,我收到errno 111连接被拒绝。 start_celery.py 来自c...

回答 1 投票 0

很多SimpleMessageListenerContainer导致“Consumer启动失败”

我使用 spring boot amqp 和 x-consistency-hash RabbitMQ 插件。我需要 多个队列绑定到同一个 x-consistant-hash 交换 每个队列都有单独的侦听器以保持部分排序 嗬...

回答 1 投票 0

在 django docker 容器中运行 celery 应用程序

我有一个使用 docker 和 docker-compose 的 Django 项目,我想在 Django 项目中使用 Celery。 我按照 Celery 文档创建了一个应用程序、一个任务并将其与 RabbitMQ b 连接...

回答 2 投票 0

为什么 Rabbitmq 集群以循环方式向消费者传递消息

我有 2 个 Rabbitmq 节点作为集群连接(无队列复制),并且有 4 个工作线程,所有节点都绑定到同一个队列“myqueue”,现在,我手动将消息发布到该队列(发布者 c...

回答 2 投票 0

用于清除所有虚拟主机的所有 RabbitMQ 队列的 Powershell 脚本

我正在运行测试,用消息填充 RabbitMQ 队列。我有多个虚拟主机,每个主机都有多个包含大量消息的队列。我想要一个能够简单地清除所有内容的 Powershell 脚本

回答 1 投票 0

SpringCloud Stream 错误处理程序定义不起作用

我正在使用 spring-cloud-starter-stream-rabbit 4.0.2,并且想为那些发送失败消息的人编写自己的 ErrorHandler 。请参阅 Spring 文档,使用“error-handler-definition”属性,但它......

回答 2 投票 0

RMQ 中的云到本地通信扩展

我们的应用程序由两部分组成:云后端 API 和客户端安装的本地服务。服务和客户端之间的通信是通过 RMQ 服务完成的...

回答 1 投票 0

RabbitMQ:“完成升级后必须启用所有稳定功能标志。” - 如何修复?

我刚刚在全新的 Windows 11 安装上安装了 RabbitMQ,并通过在 RabbitMq 命令提示符中运行命令rabbitmq-plugins启用rabbitmq_management来启用管理插件...

回答 1 投票 0

RabbitMQ 和 PHP 无法连接到通道

我对 RabbitMQ 非常陌生,并尝试添加到 RabbitMQ 队列。这是我连接到 RabbitMQ 的类的连接部分。错误发生在从

回答 1 投票 0

rabbitmq管理api文档关于api的json响应参数

我正在尝试使用 RabbitMQ 管理 HTTP API 监视我的rabbitmq 服务器的所有队列。我需要有关 json 返回的所有参数的详细文档 本地主机:15672/api/queues

回答 1 投票 0

kombu.exceptions.OperationalError:[Errno 111]连接被拒绝

我正在尝试在容器 Docker 上将 django 与 celery 和rabbitmq 一起使用。它在没有 docker 的情况下运行良好,但是当我在容器上运行时,我收到此错误: kombu.exceptions.OperationalError: [Errno 111]

回答 1 投票 0

Jmeter:如何仅在第一个线程完成所有循环时才执行最后一次检查

我测试的第一部分是将X消息发送到特定的rabbitmq队列,这是一个负载测试,我需要使用多个线程和循环来设置它。 测试的第二部分是ge...

回答 1 投票 0

Jmeter:无法从嵌套数组中提取值

我正在尝试在 Jmeter 上自动化负载测试,以便能够安排它们并让它们在特定时间运行。我没有权力控制队列,也没有权力控制我们的兔子风景,我只能……

回答 1 投票 0

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