问题标签 [rabbitmqctl]

下面是我用来创建rabbitmq连接的java代码，用于在elasticsearch中创建索引，这会引发异常。当我使用它factory.setHost("localhost");而不是factory.setHost("192.168.xx.xxx");它工作正常但是当我使用 IP 时它会导致我低于异常

com.rabbitmq.client.PossibleAuthenticationFailureException: 可能是认证失败引起的异常

下面是我用于连接的java代码 -

有没有办法在 Windows 或 RabbitMQ 服务重启后自动启用 Firehose（最好是单个虚拟主机）来设置 RabbitMQ？

我已经使用 rabbitmqctl 命令更改了密码，如下所示

rabbitmqctl change_password CPSCUser Waseem$1234 更改用户“CPSCUser”的密码 ... ...完成。

现在，当我从管理控制台（ http://10.201.127.29:15672/#/ ）使用 CPSCUser 登录时，它会失败。

但是，如果我将 $ 放在密码的末尾，它就可以工作

rabbitmqctl change_password CPSCUser Waseem1234$ 更改用户“CPSCUser”的密码 ... ...完成。

管理控制台登录适用于 CPSCUser/Waseem1234$

有没有办法我可以在密码中包含特殊字符，例如 Waseem$1234

如果这是不可能的，那么我将不得不在我的代码中添加很多密码验证规则。

我想用虚拟机启动rabbitmqserver，没有像rabbitmq-server控制台这样的脚本，有没有这样的命令或方法来启动服务器？

我在 CentOS 5.x 服务器上安装了 RabbitMQ，用于在我的程序之间传递消息。我已经rabbitmqadmin按照https://www.rabbitmq.com/management-cli.html上的说明进行了安装，并且过去曾在我的服务器上使用过它。

据我所知，这个特定的服务器似乎配置错​​误。我的网络搜索未能让我尝试获取有关如何解决此问题的更多信息。

错误：

我尝试了几个不同rabbitmqadmin的命令，它们给出了相同的结果。如果我在没有额外参数的情况下运行命令，它会显示正常的帮助对话框。我有这个设置并在其他几台服务器上工作。

知道根本问题是什么吗？如果没有，无论如何要获取更多详细信息，例如详细信息？

更新：

我只是试图检查 rabbitmq 的版本，它也产生了一个错误：

我要看看我是否能从中找到一些东西......我觉得这很奇怪，因为服务器可以很好地传递消息并且可以通过 Web 控制台进行监控。

二郎版本：

Rabbitmq 版本：

我有一个队列，多个消费者以循环方式工作。

Delivery_tag 用于在消费者完成处理后确认消息。但是多个消费者设置相同delivery_tag，尽管他们正在处理的消息不同。

结果，当 acking 完成时，我得到了precondition failed。

谁能建议我做错了什么？

这是消费者代码。我从这个链接得到它：

http://blogs.digitar.com/jjww/2009/01/rabbits-and-warrens/

我正在尝试这个命令

关闭队列以生成 NACK，但出现错误。

在 Rabbit MQ 中使用集群时，我计划使用竞争订阅者模式。

现在，如果我有一个包含 3 个节点的集群，那么消费者从其中获取消息的队列只有一个（与集群中的节点数量无关）。如果我必须在上述限制条件下扩大规模，您认为我应该拥有多个集群吗？

请指教。

第二个相关问题，集群如何有助于可扩展性？

使用“rabbitmqctl eval 'rabbit_shovel_status:status().'”我可以在我的 rabbitmq 服务器中获取铲子的状态。

我激活了模块“rabbitmq_shovel”和“rabbitmq_shovel_management”。

我使用 HTTP API 创建了一些动态铲子，我遇到的问题是，我希望能够使用 HTTP API 获取铲子的状态，但我找不到这样做的方法。

有没有办法使用 HTTP API 做到这一点？或者我应该使用'rabbitmqctl eval ...'？

我不想使用 rabbitmqctl，因为我想在我自己的 API 中公开这些数据，所以我的应用程序应该能够访问它，而不必创建一个“exec”。

在构建这个 Dockerfile 时，当它到达命令时：

它返回：

我不知道从这里去哪里。

这是我正在使用的 Docker 文件：