rabbitmq 相关问题

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

如何使用 Rabbitmq 操作符和 csi-hostpath-driver 运行 RabbitmqCluster?

我没有成功尝试使用带有“csi-hostpath-driver”插件的 minikube 测试 bitnami rabbitmq-cluster-operator。我使用插件的原因是因为默认的主机路径卷

回答 0 投票 0

更新后无 AMQP 连接

今晚 plesk 服务更新了我的 Rabbitmq 服务器版本 3.11.12-1(旧版本 3.11.11-1)。 现在我遇到了远程 AMQP 连接的问题。服务器拒绝所有连接尝试。 202...

回答 0 投票 0

如果失去与兔子队列的连接,如何将服务标记为不健康?

在我的应用程序(托管在谷歌云平台上)中,我使用骆驼来制作路线并连接到 rabbitMQ 队列。当与 rabbitMQ 队列的连接丢失时,camel 只会抛出并记录异常...

回答 0 投票 0

RabbitMQ headers 交换路由到所有队列而不是匹配 headers

我有一个 Exchange 定义为标题交换。然后我像这样绑定队列: 当我如图所示发布消息时,消息最终会进入所有绑定队列。我的

回答 0 投票 0

如何配置 Windows 服务以使用 RabbitMQ docker 容器

我有一个依赖于 RabbitMQ 的 Windows 服务。 在新机器上,我决定设置 RabbitMQ docker 容器,而不是从头开始安装 Rabbit。 所以,在 Rabbit docker 容器启动后

回答 0 投票 0

想要一个简单的 kubernetes rabbitmq 集群 yaml 和 erlang cookie 被传递而没有任何用户问题

当前 Yaml: -------------- api版本:v1 种类:服务 元数据: 名称:rabbitmq1 标签: 应用程序:rabbitmq1 规格: 端口: - 端口:5672 目标端口:5672 名称:amqp - 端口:15672 ...

回答 1 投票 0

在不同线程中运行的函数之间传递函数(回调)变量

我正在尝试开发一个使用 pika 和线程模块的 Python 3.6 脚本。 我有一个问题,我认为是由于我的 A) 对 Python 和编码很陌生,B) 我不是

回答 1 投票 0

Celery 的任务 ETA 不准确

我正在使用 Celery 和 eta 功能。根据文档,不能保证任务会在 ETA 的确切时间执行,但会在这之后的某个时间执行。 我发现与...有明显的滞后

回答 1 投票 0

与 RabbitMQ 的全双工通信

我们有一个消息传递应用程序,它在 .NET Framework 服务上使用 SignalR 连接到各种客户端(浏览器中的本机移动 + web)。我们正在寻找可能取代 Sig...

回答 1 投票 0

为什么 rabbitmq 队列中的发布和消费者确认意外下降?

这里是排队消息和消息速率图的屏幕截图 队列详情 我试过增加队列的消费者,消息发布率是 150,但仍然有下降。

回答 1 投票 0

RabbitMQ 消费者从未附加到队列,响应到达并且队列从未被删除

我的 rpc 请求场景中有一个奇怪的案例。由于 autodelete 的属性设置为 true,我发现了它。 此属性表示当...时删除至少有一个消费者的队列

回答 0 投票 0

关于RabbitMQ的设计题将图片发送给后台worker上传

我有一个函数可以获取多部分表单数据并将多个图像上传到minio并检索图像的url。 由于上传多张图片是一个巨大的过程,我想把这个发送给...

回答 0 投票 0

如何使用 Metricbeat 监控 RabbitMQ 队列中消息的发布和传递率?

我正在尝试使用 Metricbeat 监控 RabbitMQ 中消息的发布和传递速率,但我找不到任何提供这些指标的 Metricbeat 字段。 我已经配置好 Metricbea...

回答 0 投票 0

Spring-amqp-QueueBuilder 应该保留对队列的引用而不是字符串名称

我有 2 个匿名队列。他们都设置了 ___Declarables extends AbstractAmqpDeclarables 在启动时实例化为@Bean。 但是在启动时 - rabbitMQ 还没有给出 ...

回答 0 投票 0

为RabbitMq检查notifyClose的几个goroutines;如果连接断开,我该如何关闭所有 goroutines?

我有这个函数,然后在连接和通道初始化时在循环中调用它。因此,如果一个连接出现故障,我该如何终止所有 go 通道? func (c 连接) connectingBalanci...

回答 0 投票 0

消费者服务中的异常管理(微服务架构)

我们有一个由三个表组成的微服务,它的数据由事件填充,这些表相互关联,出于任何原因我们收到一条消息,该消息具有外键 ano...

回答 0 投票 0

在前端使用 2 个或更多微服务响应的最佳方法是什么 [关闭]

我们有 2 个微服务,第一个用于用户列表,第二个用于状态列表。我们必须显示带有州名称的用户列表。 我认为可能有两种方式: 方法一: 使用循环并通过 hitti 为每个用户获取状态...

回答 2 投票 0

Rabbitmq 客户端陷入循环 golang

最近遇到了很多问题,因为我试图观察我的秘密上发生的事件,我修改了我的 go 脚本以实例化 RabbitMQ。添加了一个 EventWatcher 和一个 go routine 以解决...

回答 1 投票 0

在 Kubernetes 中升级 RabbitMQ

我正在尝试将 Kubernetes 中的 RabbitMQ 从 3.8.6 升级到 3.11.10。在我的 Helm 图表中,我看到使用的图像是 3.8.6-debian-10-r0-pg-389。我已经查看了文档,它似乎是最好的

回答 0 投票 0

向 RabbitMQ 消息队列添加任务时出现 Django 芹菜错误:AttributeError: 'ChannelPromise' object has no attribute '__value__'

我在 digitalocean 上设置了 celery、rabbitmq 和 django 网络服务器。 RabbitMQ 在我的 Django 应用程序未运行的另一台服务器上运行。 当我尝试使用延迟将任务添加到队列时,我...

回答 2 投票 0

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