问题标签 [rabbitmqctl]

我注意到，当我从命令行 ( rabbitmqctl status) 运行 RabbitMQ 状态命令时，所有报告的数字都与我所知道的现实不符。我在管理门户网站中看到的内容证实了我的现实。

这是 CLI 状态的输出：

读者数量、作者数量、渠道数量等，基本上每个数量都成千倍。

在管理门户（下面的 ss）中看到的数字是正确的。总共 10 个连接，每个连接有两个通道

我所有的队列都是非持久的，我只使用扇出交换发送非持久性消息。据我了解，这应该意味着如果出现问题（这对我的需要来说很好），什么都不会持续存在。

我注意到，每当我启动或关闭连接到代理的模块之一时，在命令行上读取器/写入器的数量会增加约 17,000 个，尽管门户中仅向上/向下 1 个。

这是我的代理配置代码供参考：

客户端使用构建器模式来实例化代理连接，此时他们指定他们的发布交换和他们希望订阅的任意数量的交换。这个系统总共只有 19 个交易所。

消息正在正确发布和接收，但我收到报告称代理正在阻塞服务器。我会更密切地监视它，但我真的很想能够解释状态调用的这些古怪结果。我已经尝试停止应用程序并重置然后重新配置代理，这会使连接计数回到 0，但是一旦模块开始重新连接，数字就会开始回升。

感谢您抽出宝贵时间浏览此内容。任何建议将不胜感激！

我的 django celery 中的用户重置了 104 连接，我假设它与来宾用户有关，因此要检查我何时在服务器上执行 sudo rabbitmqctl list_users ，它只是永远等待并且什么都不做。如果有人知道这两个，请告诉我。此外，如果您可以共享一些 rabbitmq 指针，那就太好了。

我正在尝试用 Celery 运行任务。我按照这个教程链接

一切都已成功设置。现在的问题是我不知道如何执行任务。我运行 celeryd，它找不到任务。我想知道我需要调用什么来执行任务以及我需要如何在 RabbitMQ 服务器 django-admin 上配置任务。我找不到任何关于它的完整教程。

我试图在每台机器上使用 Dockers 来创建一个带有不同机器上的节点的 RabbitMQ 集群，并且我在连接节点时遇到了一些问题。当我获得rabbitMQ主机名时，它仅指容器，因此当我尝试将节点加入集群时它会失败，因为它找不到域。我如何告诉 RabbitMQ 主机名实际服务器的 IP？

我试图将一台服务器中的节点与另一台外部服务器的节点连接起来，两者都是 EC2 实例，但是关于 EC2 实例主机的 RabbitMQ 主机名应该有哪些信息才能从外部连接？

如果我使用 ip-172-31-12-135.us-west-1.compute.internal，它会失败......

我想用所有三种模式重现网络分区场景-ignore和。我怎样才能做到这一点？我尝试停止（/sbin/service reboot）集群的一个节点，但这并没有导致任何网络分区。我还尝试删除一个节点上的 mnesia 以在集群中创建不一致的 mnesia，但这也无济于事。autohealpause_minority

我正在尝试在 RABBITMQ 上进行集群。我添加了 2 个节点，但无法添加第三个节点。我已经聚集了rabbit@node1和rabbit@node2。现在我正在尝试集群rabbit@node3与rabbit@node1聚类。这是我想要做的

有什么解决方案可以在集群中添加第三个节点吗？或任何解决方案：mnesia_not_running

我在 Ubuntu 14.04 上安装了 RabbitMQ，但无法从网络上的其他计算机连接到 RabbitMQ 服务器。

从安装 RabbitMQ 的机器连接到服务器没有问题，只有从网络上的其他计算机连接。

该页面声明“默认情况下，RabbitMQ 将在所有可用接口上侦听端口 5672”。

当尝试在 python 中使用 pika 从另一个服务器连接时，我收到以下错误：

我添加了一个具有权限的新用户set_permissions newuser ".*" ".*" ".*"并尝试了 URI 身份验证方法，但是我仍然收到相同的错误。

我也无法从网络上的其他计算机连接到 RabbitMQ 管理，但可以在本地 pc 上访问它。

此外，通过检查开放端口，我可以看到以下内容：

我正在使用 RabbitMQ 教程中的 python 代码：

我错过了什么？

我有多个键值类型的对象，我需要将它们发送到 RabbitMQ，因此转发会消耗它们。所以，在通过这个RabbitMQ链接之后。它只告诉发布简单纯文本消息的方式。谁能告诉我如何在 RabbitMQ go lang 中发布和使用地图对象？

正如 RabbitMQ 文档中提到的那样，建立 tcp 连接的成本很高。因此，引入了渠道的概念。现在我遇到了这个例子。每次发布消息时，main()它都会创建连接。 conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/"). 它不应该被全局声明一次，并且应该有故障转移机制，以防连接像单例对象一样关闭。如果 amqp.Dial 是线程安全的，我想它应该是

编辑问题：

我正在以下列方式处理连接错误。我在其中收听频道并在错误时创建新连接。但是当我终止现有连接并尝试发布消息时。我收到以下错误。

错误 ：

代码 ：

我使用以下命令在 CentOS 7 上添加 RabbitMQ 用户

问题是这个配置不是永久的，所以每次我重新启动服务器时我都会做同样的事情。

有没有办法让它永久化？

另外，如果我有一个节点集群，我是否必须在每个节点上添加相同的用户？