问题标签 [rabbitmqctl]

我已经安装了 rabbitmq 并且工作正常，我知道如何接收日志，但不知道如何使用烧瓶将其显示给 UI。

烧瓶应用程序.py

我不知道如何使用多线程来运行烧瓶应用程序并不断从队列中接收日志。

我正在检查是否有办法使用 curl 清除 rabbitmq 队列？我知道使用命令行，但我需要使用 curl 的东西？

建议/帮助表示赞赏

注意：-使用此链接，我没有得到要使用的确切 curl 命令

I have created a MQTT topic from Python client on the RabbitMQ broker installed in localhost . I am publishing few messages in this topic and able to see those in MQTTLens Chrome plug-in also from the Subscriber written in Python. Where to see the list of topics created in RabbitMQ broker? I have enabled web interface for this server . But I am not able to see the topic under "Exchanges" tab . Please let me know where to see the topics and individual messages on each topic.

Publisher:

Subscriber :

我在 C# 中有 2 个 Windows 服务。服务 1 将消息发布到 RabbitMQ 队列。服务 2 订阅 RabbitMQ 队列。服务 2 还连接到 TCP 服务器并将它从 RabbitMQ 接收到的消息发送到该服务器。我的问题是，当使用此消息的服务 2 由于某些错误而失败时，有什么方法可以阻止服务 1 将消息发布到队列中（通常是 SocketException，如果它无法连接到服务器）。任何指针都会非常有帮助。如果需要更多信息，请告诉我。

提前致谢。

我们有一个将消息发布到 RabbitMQ 并从中订阅的系统，每一个都在 C# 中作为 Task 完成。当找到一些匹配的条件时，有什么方法可以停止发布和订阅。可以说，例如，我在发布特定消息时遇到了异常（只是假设），所以现在我想停止发布到队列以及消费者从同一个队列中消费。有什么办法可以实现吗？我们有一个控制总线实现和一个基于任务的实现。每条消息都通过不同的任务发布。

提前致谢。

设置： Celery 4.1、RabbitMQ 3.6.1（作为代理）、Redis（作为后端，此处不相关）。

有两个兔子用户：

• admin_user具有.* .* .*.
• remote_user具有ack ack ack.

admin_user可以触发任务，被芹菜工人用来处理任务。

remote_user只能触发一种类型的任务 -ack并被排入专用ack队列，稍后由ack工作人员（由admin_user）消耗。

通过以下remote_user代码发送任务：

这在 Celery 3.1 中完美运行。升级到 Celery 4.1 后，它不再发送任务。该调用返回一个AsyncResult但我在 Celery 花（或通过兔子管理 ui）或日志中看不到该消息。

• 尝试将权限设置remote_user .* .* .*为admin_user- 无济于事。
• 尝试添加administrator标签 - 没有帮助。

将经纪人的用户更改为 'amqp://admin_user:admin_pass@<machine_ip>:5672/vhost'确实有效：

但我不想给远程机器admin_user权限。知道我能做什么吗？

我正在学习rabbitMq，现在我想知道如何处理队列内容。

首先，我想在谷歌上搜索这个问题并了解命令

我写了 2 个独立的应用程序。

发件人：

接收者：

如果我一起运行这些应用程序 - 我会在接收方看到消息。

为了查看队列中的消息，我决定停止receiver并运行sender

1. 我运行发件人
2. 执行python rabbitmqadmin list queues

并查看以下结果：

3.然后我运行接收器并查看接收器接受消息的日志

你能澄清我在控制台中看不到消息的原因吗？

如何查看队列消息内容。

我在 CentOS 7 中使用 rabbitmq-server-3.6.6 和 Erlang R16B03-1。安装 rabbitmq 之后，我正在尝试使用 pika 构建一个 rpc 服务器。但是 pika.BlockingConnection() 连接到 127.0.0.1 的部分太慢了，超过 8 秒，通常应该在 1~5ms 左右。

这是我的 rabbitmq-env.conf 设置和 pika 连接代码的列表：

1. /etc/rabbitmq/rabbitmq-env.conf： NODENAME=rabbit@localhost ulimit -S -n 4096

2. def loop_rpc_1(): import pika, time, uuid host = '127.0.0.1' port = 5672 user = 'rpc_user' passwd = '123456' vhost = '/dev' credentials = pika.PlainCredentials(user, passwd) list = range(1, 100) for i in list: start_time = time.time() conn = pika.BlockingConnection(pika.ConnectionParameters(host, port, vhost, credentials, )) conn.close() print(i, time.time() - start_time)

输出： loop_rpc_1() 1 7.42911958694458 2 5.011636972427368 3 0.008404970169067383 4 0.00924539566040039 5 8.006478071212769 6 2.010906934738159 7 0.008637666702270508 8 0.008483409881591797 9 5.0115368366241455 10 0.00960850715637207 11 0.008922576904296875 12 5.015120506286621 13 8.005479335784912 14 2.011262893676758 15 8.005752325057983 16 2.0079636573791504 17 8.006184816360474 18 2.0097343921661377 19 0.008991718292236328 20 8.00625205039978

/var/log/rabbitmq/rabbitmq@localhost.log 就像：

=INFO REPORT==== 17-Aug-2017::20:17:12 === 接受 AMQP 连接 <0.5344.4> (127.0.0.1:44705 -> 127.0.0.1:5672)

=INFO REPORT==== 2017 年 8 月 17 日::20:17:14 === 关闭 AMQP 连接 <0.5344.4> (127.0.0.1:44705 -> 127.0.0.1:5672)

=INFO REPORT==== 17-Aug-2017::20:17:14 === 接受 AMQP 连接 <0.5371.4> (127.0.0.1:44706 -> 127.0.0.1:5672)

=INFO REPORT==== 17-Aug-2017::20:17:19 === 关闭 AMQP 连接 <0.5371.4> (127.0.0.1:44706 -> 127.0.0.1:5672)

=INFO REPORT==== 17-Aug-2017::20:17:19 === 接受 AMQP 连接 <0.5427.4> (127.0.0.1:44707 -> 127.0.0.1:5672)

=INFO REPORT==== 2017 年 8 月 17 日::20:17:19 === 关闭 AMQP 连接 <0.5427.4> (127.0.0.1:44707 -> 127.0.0.1:5672)

=INFO REPORT==== 17-Aug-2017::20:17:19 === 接受 AMQP 连接 <0.5434.4> (127.0.0.1:44708 -> 127.0.0.1:5672)

=INFO REPORT==== 2017 年 8 月 17 日::20:17:19 === 关闭 AMQP 连接 <0.5434.4> (127.0.0.1:44708 -> 127.0.0.1:5672)

=INFO REPORT==== 17-Aug-2017::20:17:19 === 接受 AMQP 连接 <0.5441.4> (127.0.0.1:44709 -> 127.0.0.1:5672)

=INFO REPORT==== 17-Aug-2017::20:17:27 === 关闭 AMQP 连接 <0.5441.4> (127.0.0.1:44709 -> 127.0.0.1:5672)

=INFO REPORT==== 17-Aug-2017::20:17:27 === 接受 AMQP 连接 <0.5515.4> (127.0.0.1:44710 -> 127.0.0.1:5672)

=INFO REPORT==== 17-Aug-2017::20:17:29 === 关闭 AMQP 连接 <0.5515.4> (127.0.0.1:44710 -> 127.0.0.1:5672)`

3. 此外，像time rabbitmqctl list_users,这样service rabbitmq-server start/stop/status的命令也很慢。

调试此类问题的标准程序是什么？
非常感谢！

我想跟踪哪条消息已送达或已过期。我怎样才能以编程方式获得它？

帮助！如果有人知道的话。

提前致谢。

我是 RabbitMQ 的新手，我决定从控制台工具开始，以便更好地理解管理。然后我将使用 Web 控制台，然后使用 Java 客户端。

我遇到了一些可以同时执行的操作rabbitmqctl：

并与rabbitmqadmin：

但是我没有成功，例如，用 rabbitmqctl 创建新的交换。这两个工具有什么区别？