rabbitmq 相关问题

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

用nestjs更改rabbitmq交换

我正在使用rabbitmq和nestjs。我需要将消息从一个队列复制到另一个队列。我在rabbitmq上建立了一个交换以使其正常工作。但是我怎样才能改变nest内rabbitmq的交换...

rabbitmq nestjs

回答 1 投票 0

Celery 中 app.tasks 如何不同时启动？

经过多次测试和搜索，我没有得到结果，希望您能指导我。我的代码可以在这个 GitHub 地址上找到。由于主要代码比较复杂，所以我写了一个简单的...

python rabbitmq celery

回答 2 投票 0

如何更改 MassTransit for RabbitMQ 中的错误队列和交换的名称？

我尝试在一个简单的配置中抛出一些异常，并注意到创建了一些交换器和一个与错误相关的队列：交流：公共交通：故障 MassTransit：故障--ConsoleApp1：

c# .net-core rabbitmq masstransit

回答 3 投票 0

NestJS 微服务，带有无模式的rabbitmq

我有一个rabbitmq服务，它有一个队列，消息中没有模式json。像这样： {“customFieldOne”：“foo”，“another”：“bar”，“numbers”：[3，...

rabbitmq nestjs

回答 2 投票 0

Nestjs 中的 RabbitMQ，生产者和消费者出错

我正在尝试使用 Rabbitmq 在 Nestjs 中实现微服务，但我进入了 Producer ：与 RMQ 断开连接。正在尝试重新连接。 [Nest] 21700 - 08/05/2023, 9:01:28 PM 错误 [ClientProxy] 对象...

rabbitmq nestjs

回答 1 投票 0

使用公共交通和发件箱模式时，消息不会传递到 RabbitMQ

我使用发件箱模式与MassTransit，当我发布消息时，它将保留在数据库中的OutboxMessages表中，并且不会传递给代理，这是配置：套餐：...

asp.net rabbitmq masstransit outbox-pattern

回答 1 投票 0

celery 功能“reply_to”无法按预期工作

我需要配置芹菜应将任务执行结果放入哪个队列，我使用文档中描述的方式（项目“reply_to”）： @app.task(reply_to='export_task') # <= configured

python rabbitmq celery

回答 1 投票 0

RabbitMQ sendtoQueue 并在同一个 REST API 调用中消费

我正在使用 2 个快速微服务，第一个（产品）负责产品队列，第二个（出价）负责出价队列。通道和连接是在服务器自行启动时建立的...

node.js express rabbitmq amqp

回答 1 投票 0

mqtt客户端收到来自rabbit mq的重复消息

我使用rabbitmq作为mqtt代理，我有一个android pad作为mqtt客户端，并使用org.eclipse.paho.client作为客户端sdk。当我从服务器发送消息到 pad 时，我将保留标志设置为 true。但当我

duplicates rabbitmq mqtt

回答 0 投票 0

当合约位于 nuget 包中时，为什么 Masstransit 消费者未收到对象内的对象

我有一个公共交通发布者和一个消费者（均在下面）。发送的消息是公共类SendEmailContract { 公共列表附件{ get;内部设置...

c# dll rabbitmq nuget-package masstransit

回答 0 投票 0

传递correlationId时如何从队列中获取响应？（系统设计/RabbitMQ）

我们想使用rabbitMQ作为电子邮件服务的代理。为了更好的用户体验，我们希望首先向客户确认正在处理发送电子邮件的请求，然后在完成时显示...

rabbitmq microservices system-design

回答 0 投票 0

最好的事件版本控制技术是什么？

我目前正在我的 C# 应用程序中使用 MassTransit RabbitMQ 事件来促进生产者和消费者之间的通信。但是，我担心潜在的问题可能......

events version-control rabbitmq versioning masstransit

回答 0 投票 0

FastApi：Celery Worker 未执行任务并且任务停留在 Unack 中

我给自己写了一个测试应用程序来掌握 Celery 和 RabbitMQ 的窍门。我的所有消息似乎都停留在 RabbitMQ 上的“Unack”状态...... 该任务应该由工人执行，然后...

python mongodb rabbitmq celery

回答 0 投票 0

如何让Spring Boot云连接到现有的RabbitMQ Exchange和队列

所以我有一个 Spring Boot 应用程序，我正在使用 Spring Cloud 连接到我的 RabbitMQ 服务器。我阅读了文档，但有些事情对我来说仍然很模糊。现在我的应用程序创建了...

spring-boot rabbitmq spring-cloud spring-cloud-config

回答 0 投票 0

消息队列：Kafka 与 RabbitMQ？

我是消息队列和流媒体的新手。我对RabbitMQ和Kafka的区别和应用有疑问。有人可以解释一下技术差异以及每个差异通常如何......

apache-spark apache-kafka rabbitmq message-queue

回答 1 投票 0

我的excel消费者服务（java微服务）如何可以将数据发送到rabbitmq，以前从未使用过ques，我可以从哪里开始考虑这个

所以我开发了一个消费者服务，当前正在使用Excel文件中的单元格并打印它，我需要将单元格值发送到rabbitmq并存储在que中，这是我的服务代码。打包...

java excel rabbitmq microservices

回答 0 投票 0

使用 RabbitMQ 优化和扩展 Celery 以执行 I/O 密集型任务

我有一个 celery 任务，它接受来自生产者的关键字并使用该关键字查询数据库 - DB1，然后将其插入到另一个数据库 - DB2 中。一个任务周期大约需要15秒。

python postgresql sqlalchemy rabbitmq celery

回答 0 投票 0

如何在SpringBoot AMQP中动态生成消息队列并使用PK值绑定键

我想实现一个功能，属于特定群组的用户可以在群组内发布内容，并且该群组的所有成员都会收到通知。为了实现这个目标，我研究了 AMQP...

spring-boot rabbitmq amqp spring-amqp

回答 0 投票 0

Celery 中工人之间的任务智能分配

经过一周的尝试和搜索，我没有得到任何结果，我将感谢您的帮助。概括：我有 10 个工人，每个工人里面都有一个 app.task 。每天，这10名工人...

python rabbitmq celery distributed-computing

回答 1 投票 0

RabbitMQ 使用基于铲子/标头的铲子过滤消息

使用Shovel时是否有过滤消息的选项。例如， vhost1 > Exchange1 > 消息过滤器集 > vhost2 > Exchange2。或使用标头交换 vhost1 > 标头交换...

rabbitmq rabbitmq-shovel

回答 0 投票 0

最新问题

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