rabbitmq 相关问题

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

基于 RabbitMQ 的消息传递和长期运行的消费者进程 - 我需要一个更好的模式

我有一个使用来自 RabbitMQ 队列的消息的服务。它的主要特点是长时间运行的处理程序，处理时间可能需要 5 分钟到 6 小时（事实上，没有真正的限制...

.net architecture rabbitmq message-bus

回答 1 投票 0

DirectRabbitListenerContainerFactory 与 DirectMessageListenerContainer

使用这个有什么区别 @豆公共DirectRabbitListenerContainerFactoryrabbitListenerContainerFactory（最终ConnectionFactory customConnectionFactory，最终ThreadPoolTaskExe ...

java spring spring-boot rabbitmq spring-amqp

回答 1 投票 0

在 RabbitMQ 中处理数百万条消息

我是消息队列的新手。我正在使用 RabbitMQ 进行消息队列。我已经创建了消费者和侦听器，它们工作得很好。场景是我有一个 Flask 应用程序并且我正在发送

python rabbitmq pika scalable

回答 2 投票 0

GO 中的 MQTT 和 RabbitMQ 客户端

我开始学习 golang，作为训练示例，我选择虚拟应用程序从 mqtt 代理（作为主题的订阅者）获取消息并将其传递到 RabbitMQ 实例中的队列。对...

go rabbitmq mqtt

回答 1 投票 0

协议错误：Mosquitto - RabbitMQ MQTT 通过 TLS 从本地计算机到服务器的连接

在rabbitmq tls支持页面之后，我使用以下terraform脚本在GCP上部署了rabbitmq服务器：提供商“谷歌”{ 项目 = var.project_id 区域 = var.region } 解决...

ssl rabbitmq ssl-certificate mqtt

回答 1 投票 0

如何使用amqpblig在RabbitMQ中无限期地消费消息？

我按照 RabbitMQ 官方文档使用 ampqlib 做了一个原生的简单方法来无限期地使用消息：经过几天的痛苦，我的经理解释说这真的很愚蠢......

javascript rabbitmq queue message-queue ampqlib

回答 1 投票 0

minikube 上的 RabbitMQ 集群 Kubernetes Operator

我正在尝试使用 RabbitMQ Cluster Operator 在 Minikube 上设置 RabbitMQ：当我尝试附加持久卷时，出现以下错误： $ kubectl 日志 -frabbitmq-rabbitmq-server-0

kubernetes rabbitmq

回答 5 投票 0

如何使用Celery（无需第三方包）发送Django的密码重置邮件？

首先，我知道这个问题之前已经在这里得到了回答，它使用第三方包 django-celery-email，但我试图弄清楚如何在不依赖任何...的情况下完成这样的工作......

python django django-forms rabbitmq celery

回答 3 投票 0

RMQ 和 TypeOrm Nestjs 冲突

我使用TypeOrm时发生冲突=> RMQ崩溃我不知道为什么。使用库 golevelup/nestjs-rabbitmq 我在这个问题上浪费了7个小时.. @模块（{ 进口：[ ConfigModule.forRoot({ ...

node.js typescript rabbitmq nestjs typeorm

回答 1 投票 0

异步 API - 简单 @RabbitListener 的最低限度 asyncapi.yaml

我很难理解 AsyncApi 格式，我尝试从 RabbitMQ 的一个非常简单的 SpringBoot 项目的基础开始所以我们假设我的代码中有：一个名为...

spring rabbitmq asyncapi springwolf

回答 1 投票 0

Nestjs 在 Docker 中连接 RabbitMQ 的问题

如果您能帮我解决连接 RabbitMQ 和 Node js (nest js) 的问题，我会很高兴。一切都可以在本地运行，但是当使用 docker-compose 时。事实证明授权成功...

node.js docker-compose rabbitmq nestjs

回答 1 投票 0

如何使用rabbitmq_prometheus插件监控RabbitMQ的特定队列？

有没有办法使用“rabbitmq_prometheus”插件来监控 RabbitMQ 上的特定队列？我正在寻找如果特定队列有 0 个消费者，Prometheus 应该监视我...

rabbitmq prometheus monitoring grafana

回答 2 投票 0

RabbitMQ 在 Debian Stretch 上安装/启动失败

以下 sudo apt-get 安装rabbitmq-server 当服务尝试启动时（也在使用 systemctl start 时），我遇到错误： ●rabbitmq-server.service - RabbitMQ 消息传递服务器

rabbitmq debian

回答 2 投票 0

如何使用 celery AsyncTask 的结果回调

我有以下情况。我的客户向工作人员发送以下任务：＃客户任务 = my_task.apply_async((some_params), 队列='my_queue') # task.get() # 这会阻塞我的工人执行...

python callback rabbitmq celery

回答 1 投票 0

RabbitMQ - 自动生成名称为“amq.gen-*”的随机队列

我有一个设置，可以从服务器（NodeJS）向持久队列发送消息，客户端（android应用程序）监听各自队列上的消息（每个android设备监听其相应的......

android node.js rabbitmq

回答 3 投票 0

芹菜任务时间慢

我正在使用 Django、Celery 和 RabbitMQ。我有一个发送电子邮件的简单任务。该任务有效，但速度非常慢。例如，我发送 5000 封电子邮件，所有 5000 封电子邮件都直接发送到 RabbitMQ 作为规范...

python django rabbitmq celery

回答 2 投票 0

MassTransit 为工作消费者展示 LIFO（后进先出）顺序

在我的 .NET Core 应用程序中，我使用 MassTransit Job Consumer 来运行一些长时间运行的作业。然而，我注意到同时提交的作业（几秒钟之内）似乎是

.net rabbitmq masstransit

回答 1 投票 0

RabbitMQ。是否可以为多个队列配置consumer并指定优先级？

是否可以设置为消费者首先从第一个队列接收消息，然后从第二个队列接收消息，然后从第三个队列接收消息？即，使得不同队列中的消息具有不同的

php rabbitmq

回答 1 投票 0

尝试从.net core 5应用程序连接aws mq上的rabbit mq时出现异常

我在尝试连接到rabbitmq时遇到了这个异常。我的应用程序在 .NET 5 上运行。我不使用私有 vpc 我已将 mq 设置为公共异常：指定的端点均未响应...

c# .net amazon-web-services asp.net-core rabbitmq

回答 2 投票 0

删除celery中所有待处理的任务？

如何在不知道每个任务的task_id的情况下删除所有待处理的任务？

task rabbitmq celery celery-task

回答 12 投票 0

rabbitmq 相关问题

最新问题