rabbitmq 相关问题

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

Spring boot:Exchange 发生错误时的 RabbitMq 和数据库管理

我在管理 RabbitMQ 和数据库事务时遇到问题,以防找不到交换。这是简单的序列: 将消息发送至 Exchange 在数据库中将已发送消息标记为已发送 ...

回答 1 投票 0

Celery、RabbitMQ 在执行任务时从消费者列表中删除工人

我已经启动了我的 celery Worker,它使用 RabbitMQ 作为代理,如下所示: celery -A my_app 工人 -l 信息 -P gevent -c 100 --prefetch-multiplier=1 -Q my_app 然后我的任务看起来很像......

回答 1 投票 0

从 .Net WebAPI 连接到 Docker Swarm 中的 RabbitMQ/Masstransit 服务时出现问题

我刚开始在 Docker Swarm 中使用 RabbitMQ/Masstransit。从所述堆栈中的其他服务(C# .Net WebAPI)连接到我的堆栈中的 RabbitMQ 服务时遇到问题。连接到 RabbitMQ...

回答 1 投票 0

如何重写Spring Cloud Stream的rabbitConnectionFactory?

我有一个使用 Spring Cloud Stream 和自定义 Rabbit 绑定器的应用程序。现在我必须向活页夹添加一些代理配置,但我不知道如何配置活页夹。绑定...

回答 1 投票 0

兔子有耳朵吗?

我正在尝试在运动周围绘制一只兔子,但没有成功:( 结果应该是这样的:兔子围着一个运动。它基本上是 sportello 表面的一部分,但...

回答 1 投票 0

如何使用rabbitmq删除响应队列?

考虑这个rabbitmq回复队列机制,其中仅检索1条消息,发送回客户端,然后必须删除生成的(自动删除)队列。 字符串 startResponseConsumer(

回答 1 投票 0

Spring amqp - 未找到兼容的身份验证机制 - 服务器提供[]

我正在尝试通过外部身份验证机制(https://github.com/rabbitmq/rabbitmq-auth-mechanism-ssl)将spring boot应用程序连接到rabbit mq。 我收到以下错误: org.springframework.amqp.

回答 1 投票 0

Zipkin 无法在 Docker 中工作 - 连接被拒绝

Zipkin 在本地运行良好,但在 docker 容器中运行不佳。所有的微服务都在Eureka中注册良好,并且可以很好地通信。但唯一的问题是Zipkin。我收到以下信息...

回答 3 投票 0

在 Dockerfile 中配置 RabbitMQ

我有一个 Dockerfile,在其中安装 RabbitMQ 并执行一些配置(例如创建虚拟主机和交换)。不幸的是,当我从该 Dockerfile 启动容器时,配置...

回答 1 投票 0

有没有办法确定日志的优先级并将其发送到elasticsearch,以优化服务器上的日志负载

需要读取我的环境中所有应用程序日志中的严重、错误和警告。如果在 1000 次警告后发生严重情况,我希望 Logstash 立即发送它,并给予较高的优先级......

回答 1 投票 0

有rabbitmq队列追踪的调试工具吗?

有rabbitmq队列追踪的调试工具吗?一旦队列出现问题,就可以定位问题

回答 1 投票 0

大众交通中的服装信息消费

我有一个要求,我有两个具有相同代码库的 ASP Net Core 应用程序(A 和 B)。每个应用程序都会发布它使用和处理的一些命令。现在,当应用程序 A

回答 1 投票 0

使用 MassTransit 将服务注入队列消费者

我有一个配置如下的消费者 .ConfigureServices((hostContext, 服务) => { 服务.AddMassTransit(cfg => { cfg.AddConsumer (); ...

回答 1 投票 0

RabbitMQ 单交换和具有多个路由键的单队列

我正在尝试使用 BasicGet 仅检索与通道的 Exchange/Queue/RoutingKey 组合匹配的消息。 我们的路由键的一个例子是 开发:STACK_1_WEBSERVER_V2:1:2.9.0.0...

回答 2 投票 0

我面临着一个rabbitmq [无法建立连接,目标主动拒绝],有人可以告诉我为什么会发生这种情况吗

我正在尝试将rabbitmq连接到celery以进行项目。 ERROR/MainProcess] 消费者:无法连接到 amqp://local:**@127.0.0.1:5672//: [WinError 10061] 无法建立连接,因为 t...

回答 1 投票 0

RabbitMQ 集群的 MassTransit 配置问题

我有一个 RabbitMQ 集群 xx.xx.xx.xx6、xx.xx.xx.xx.xx7 和 xx.xx.xx.xx8。我正在尝试使用 UseCluster 方法注册它们: BusConfigurator.UsingRabbitMq((上下文,配置器) => ...

回答 1 投票 0

更改 RabbitMQ 管理插件刷新率

RabbitMQ 管理插件会以选定的 5、30 或 300 秒间隔自动刷新页面。 我希望它每 1 秒刷新一次。可以吗?

回答 4 投票 0

将 celery 与 Django-verify-email 一起使用

我正在尝试设置一个简单的任务来使用 django-verify-email 包和 celery 发送电子邮件验证 这是我的代码 #任务.py 从芹菜导入共享任务 来自 verify_email.email_handler

回答 1 投票 0

有没有办法消费来自RabbitMQ交换的消息(而不是产生消息)

我正在通过 AMQP 1.0 协议为第三方 RabbitMQ 代理开发消费者。由于第三方要求我们通过连接消费消息,我无法消费消息...

回答 1 投票 0

rabbitmq控制台的队列部分中的AD功能是什么意思?

在以下 RabbitMQ 管理控制台的屏幕截图中,我位于队列和流页面。在所有队列表中有一列称为“特征”。其中一项功能称为 AD。你们可以吗

回答 1 投票 0

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