RabbitMQ是一个开源消息代理,最初实现AMQP协议,并通过插件架构支持其他消息传递协议。此标记应与涉及RabbitMQ服务器消息代理产品的问题一起使用,或者与RabbitMQ产品的源代码和实现有关的问题一起使用。诸如amqp或mqtt之类的特定协议标签也可以是适当的,以及正在使用的OS和编程语言。
我看到任务在 celery 中似乎“消失”了,使用 2 个节点运行。这似乎是随机发生的。任务是这样创建的: 任务 = Perform_advance.apply_async(...) logger.info('任务创建...
我创建了一个简单的发布者和一个使用 basic.consume 在队列上订阅的消费者。 当作业运行无异常时,我的消费者会确认这些消息。每当我跑步时...
如何配置我的 Helm Chart 来获取 RabbitMQ 社区插件?
目标:在我的rabbitmq-ha helm图表中使用来自https://www.rabbitmq.com/community-plugins.html的rabbitmq社区插件。 需要安装服务器未附带的任何插件。
我在rabbitmq-server上收到此错误,当我重新启动它时一切正常,但有时我会收到相同的错误。 ●rabbitmq-server.service - RabbitMQ代理 已加载:已加载(/usr/lib/syst...
我的笔记本电脑上安装了rabbitmq。有没有办法通过检查Windows任务管理器中的进程来检查rabbitmq是否作为后台进程运行?我在
我的代码中有这个问题:我有 2 个微服务 laravel 10:在第一个微服务中,我向队列发送一个如下变量: 队列::连接('rabbitmq')->push('App\Jobs\UpdateProductStock...
RabbitMQ 使用 terraform helm_release 提供程序设置 LivenessProbe exec 命令
我正在尝试使用 terraform helm_release 提供程序覆盖默认的 livenessProbe 和 readinessProbe 执行命令。 不幸的是,经过多次尝试,该命令似乎不是
我在 Laravel 应用程序中使用 https://github.com/vyuldashev/laravel-queue-rabbitmq 将消息放在 RabbitMQ 队列上,并通过 php artisan rabb 在另一个 Laravel 应用程序中使用它们...
运行 docker 时 RabbitMQ/MassTransit 连接被拒绝
我正在尝试使用 MassTransit 运行 .NET 8 Web 应用程序来连接到 RabbitMQ。 在开发过程中,我只是运行我的 docker-compose 文件并手动运行 .NET 应用程序,这仅适用于...
当峰值超过 3000 个连接/秒时,我们的rabbitmq 服务器无法跟上连接,并且新连接需要很长时间才能建立(达到失败的 3 秒限制)。我们需要公开...
我使用 RabbitMQ 和 Masstransit 进行消息传递。我在 ASP.NET Core 中有 2 个应用程序。其中之一是ConsumerApp,另一个是ProducerApp。他们没有共享的模型项目,每个项目都有自己的......
在我的 kubernetes 集群上,我映射了 persistenet 卷,但我的集群如何重新启动,并且rabbitmq 无法启动, 所以我尝试使用删除 PVC kubectl 删除 pvc pvc-475317d7-5c92-...
在我的应用程序中,我使用令牌向 GitHub 搜索 API 发出经过身份验证的请求。我每 2 秒发出一次请求,以保持在每分钟 30 个请求的主要速率限制内(所以不同意...
我对 RabbitMq 有一个有点奇怪的问题 - 它使用的 CPU 太少。 我在具有 64 个 CPU 和 200GB RAM 的 Debian 服务器上运行单个 RabbitMq 节点 v3.11.13。 通常的用法看起来像这样...
我正在使用 RabbitMQ 对所有消息进行排队,并将消息作为短信发送给各自的消费者。我正在使用直接交换,并且我已经使用路由正确创建了到队列的绑定...
IServiceCollectionConfigurator'不包含'UsingRabbitMq'的定义
在我的配置中尝试使用“UsingRabbitMq”时出现此错误。 “IServiceCollectionConfigurator”不包含“UsingRabbitMq”的定义,并且没有可访问的扩展
OpenTelemetry 与 Quarkus / RabbitMQ 跨记录异常
我一直在使用rabbitMQ和opentelemetry开发有关消息传递和可观察性的Quarkus原型。 一切正常,但现在我试图在管道中进行一些错误处理。 所以我有
RabbitMQ BrokerUnreachableException(.net 4.8 与 .NET 8.0)(不起作用/起作用)
我正在尝试连接到我的计算机上的本地主机 RabbitMQ 服务器并不断收到错误。 错误: RabbitMQ.Client.Exceptions.BrokerUnreachableException:“没有指定的端点
RabbitMQ 中发布的消息没有被传递。我该如何解决这个问题?
我用spring boot、stomp、rabbit mq开发了聊天流程。 当我尝试使用 JMETER 进行负载测试时,我期望所有消息都会被传递,但事实并非如此。 “我构建了测试序列......
RabbitMQ 联邦交换可以与 celery 配合使用吗?
用例是使用联合交换将所有 celery 消息联合到第二个rabbitmq 节点以进行备份(以防发生灾难)。 我已经在 2 个rabbitmq 节点之间建立了联合交换。我的姜戈...