python - 如何将鼠兔连接到rabbitMQ远程服务器？ ( python 、鼠兔)

Question

在我的本地机器上我可以:

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))

对于两个脚本(send.py 和 recv.py)都是为了建立正确的通信，但是如何建立从 12.23.45.67 到 132.45.23.14 的通信呢？我知道 ConnectionParameters() 采用的所有参数，但我不确定将什么传递给主机或将什么传递给客户端。如果有人可以提供主机脚本和客户端脚本的示例，我们将不胜感激。

Answer 1

第一步是将另一个帐户添加到您的 rabbitMQ 服务器。要在 Windows 中执行此操作...

1. 打开命令提示符窗口(windows键->cmd->enter)
2. 导航到“C:\Program Files\RabbitMQ Server\rabbitmq_server-3.6.2\sbin”目录(键入“cd\Program Files\RabbitMQ Server\rabbitmq_server-3.6.2\sbin”并按回车键)<
3. 启用管理插件(输入“rabbitmq-plugins enable rabbitmq_management”并按回车键)
4. 打开管理控制台的浏览器窗口并导航到管理部分(http://localhost:15672/#/users 使用凭据“guest”-“guest”)
5. 添加一个新用户(例如密码为“the_pass”的“the_user”
6. 授予该用户对虚拟主机“/”的权限(单击用户名，然后单击“设置权限”)

现在，如果您按照以下对 send.py 的修改来修改连接信息，您应该会成功:

#!/usr/bin/env python
import pika

credentials = pika.PlainCredentials('the_user', 'the_pass')
parameters = pika.ConnectionParameters('132.45.23.14',
                                   5672,
                                   '/',
                                   credentials)

connection = pika.BlockingConnection(parameters)

channel = connection.channel()

channel.queue_declare(queue='hello')

channel.basic_publish(exchange='',
                  routing_key='hello',
                  body='Hello W0rld!')
print(" [x] Sent 'Hello World!'")
connection.close()

希望对你有帮助