rabbitmq 相关问题

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

RabbitMQ:连接丢失后如何处理不必要的重复取消确认消息?

在我的应用程序(多个实例)中,我们偶尔会看到由于网络问题(我的应用程序和Rabbitmq都处于活动状态)而导致我的应用程序和Rabbitmq之间失去连接的情况,然后在连接之后...

回答 1 投票 0

Spring boot 2.0服务:从Rabbit mq传递但未到达Java代码的消息

我们正在使用一个在Spring Boot 2.0之上构建并使用spring集成框架的高性能Rabbit mq用户。预取计数设置为150,并且并发使用方的数量不为4。一切...

回答 1 投票 0

无法创建RabbitMQ队列

我收到有关此问题的建议,并发表评论,说我可能没有所需的Exchange,因为我的队列已经存在。因此,我手动将其全部删除。但是,当重新...

回答 1 投票 0

Pika-RabbitMQ-为什么为消费者使用预取计数1时我的交付率大于确认率

我在Python中使用RabbitMQ实现PIKA时遇到问题。我想从队列中使用1条消息,对其进行处理,并在工作完成后对其进行确认。然后下一条消息应该是...

回答 1 投票 2

延迟处理死信队列

我要执行以下操作:当一条消息失败并落入我的死信队列时,我想等待5分钟,然后将同一条消息重新发布到我的队列中。今天,使用Spring Cloud Streams和...

回答 1 投票 0

RabbitMQ中是否可能有一个同时作为消费者和生产者的回调?如果是,这是一个好方法吗?

我有一个队列来发送消息。当使用者从该队列中接收到一条消息时,它将对其进行处理并生成大量需要发送到另一个队列的特定消息。然后我...

回答 1 投票 -1

Service Fabric中的可靠并发队列

我有一个服务结构应用程序,其中包含一个无状态服务和多个有状态服务。无状态服务从RabbtitMQ读取(使用MassTransit),并将消息传递到相应的...

回答 1 投票 0

[aio-pika 2使用者不同时通过扇出接收消息

我是RabbitMQ和Pika的新手,但我认为我已经清楚地了解了它的工作原理。我需要实现:生产者创建消息并通过扇出交换发送,多个生产者(2 in ...

回答 1 投票 0

以编程方式生成/写入Celery登录文件

我正在尝试使用celery和Rabbitmq作为消息代理来运行一个简单的异步任务。我想生成并以编程方式将终端中显示的芹菜日志写入文件。 ...

回答 2 投票 0

XA交易MongoDb和Rabbit MQ

我在mongo db和Rabbit mq之间进行了xa事务处理。数据应同时提交并回滚。在mongo db中提交并将消息发布到Rabbit MQ。如果失败了,应该...

回答 1 投票 0

在Django-Celery中停止/清除定期任务

通过将PeriodicTask子类化,我设法使定期任务在django-celery中工作。我试图创建一个测试任务并将其设置为无用地运行。有用。现在我无法阻止它。我是...

回答 2 投票 7

如何在Docker上安装RabbitMQ?

我正在尝试使用Ubuntu 18.04映像在Docker容器内安装RabbitMQ,以对其运行单元测试。要安装,我正在运行普通的sudo apt-get install rabbitmq-server,然后...

回答 1 投票 0

在HostedService或WebContext中运行的RabbitMQ侦听器

我有一个dotnet核心项目,其csproj中引用了SDK Microsoft.NET.Sdk.Web,主要是为了获得一些出色的功能(即IoC,appsettings等)。在这个项目中,我没有添加...

回答 1 投票 0

关于队列删除的RabbitMQ通知

当我们在dotnet中的RabbitMQ上删除队列时,我们试图获得通知。 RabbitMQ的“启用rabbitmq_event_exchange”命令似乎启用了该功能。 https://www.rabbitmq.com/event-exchange ....

回答 1 投票 0

我的视频处理微服务体系结构有意义吗?

我正在设计一个基于Kubernetes精心策划的微服务的视频处理后端体系结构,我想问你们您对此的看法,因为我真的是新来的。所以这就是...

回答 1 投票 0

用于在接收到的每条消息上设置多租户作用域值的预期MassTransit中间件构造是什么?

我正在将MassTransit与Autofac结合使用,并且需要一种查询租户ID的入站消息的方法,该方法将用于动态构造连接字符串。因此,逻辑步骤应为...

回答 1 投票 0

basic_get之后的pika确认消息

我有一个python代码,一次消耗RMQ的消息message_count = queue_state.method.message_count,如果不是queue_empty:message_cursor = 1而message_cursor&...

回答 1 投票 0

如何通过C#中的RabbitMQ队列发送接收文件?

我需要使用RabbitMQ通过队列发送和接收文件。我没有直接发送文件的任何解决方案,因此我正在使用下面的代码,并计划读取文件并将文件数据发送到...

回答 1 投票 0

用于处理死信队列的配置

我有一个使用Spring Cloud Streams-RabbitMQ在微服务中交换消息的项目。对我的项目至关重要的一件事是,我一定不会丢失任何消息。为了...

回答 1 投票 0

RabbitMQ:具有单个队列的主题交换的消息的循环分发

RabbitMQ是否在以下情况下轮流分发消息? RabbitMQ配置:交换类型-主题路由键-notify。#生产者正在推动...

回答 1 投票 0

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