在远程主机上监听 rabbitmq 队列答案

【问题标题】：Listening to rabbitmq queue on a remote host在远程主机上监听 rabbitmq 队列
【发布时间】：2019-12-10 07:58:04
【问题描述】：

我想听听不在同一主机上的队列。这可能吗。在 rabbitmq 文档中，我刚刚找到了如何发送到远程队列的信息，但没有找到如何接收的信息。这可能不是故意的吗？我试过这段代码。但这没有用。

#!/usr/bin/python2.6
import pika
import sys
from datetime import datetime

QUEUE="LMS"
DATE=datetime.now()
credentials = pika.PlainCredentials('USERXX', 'PWXX')
connection = pika.BlockingConnection(pika.ConnectionParameters('172.16.1.48', '5672', '/', credentials)
channel = connection.channel()

channel.queue_declare(queue=QUEUE)


def callback(ch, method, properties, body):
    print("Neue Nachricht:  %r" % body)

channel.basic_consume(
    queue=QUEUE, on_message_callback=callback, auto_ack=True)

print(' Warte auf nachricht in Queue', QUEUE, ' Abbrechen mit  CTRL+C')

channel.start_consuming()

谁能告诉我鼠兔是否可以，如果可以，怎么做？

提前致谢

【问题讨论】：

是的，有可能，“没用”是什么意思，你遇到了什么问题？
什么方法没用？这是破坏了您的计算机还是显示错误消息还是冻结？始终将完整的错误消息（从单词“Traceback”开始）作为文本（不是截图）（不是评论）。还有其他有用的信息。
我不知道如何使用pika，因为我使用paho-mqtt 和mosquitto，但是mosquitto 也有控制台/终端工具来处理队列，所以我可以测试它。也许rabbitmq 有一些控制台工具可以使用队列。要接收消息，您必须发送新消息 - 它可能不会收到旧消息。
感谢您的回答和信息。这是错误：./rabbit_receive.py 文件“./rabbit_receive.py”，第 10 行 channel = connection.channel() ^ SyntaxError: invalid syntax 但我没有看到任何语法错误
总是在 QUESTION 中输入完整的错误信息，而不是在评论中。你应该在一开始就这样做——我们无法读懂你的想法，也不要指望我们会运行代码来查看错误消息。

标签： python rabbitmq pika

【解决方案1】：

原因是旧的 python 版本。谢谢你的帮助

【讨论】：