rabbitmq创建连接账号
时间: 2023-07-11 22:30:25 浏览: 104
rabbitmq连接池
5星 · 资源好评率100%
要创建 RabbitMQ 的连接账号,可以按照以下步骤进行:
1. 打开 RabbitMQ 的 Web 管理界面,在 "Admin" 栏目下点击 "Add a User" 按钮。
2. 在弹出的对话框中输入要创建的用户名和密码,选择 "None" 作为该用户的角色,并点击 "Add User" 按钮。
3. 在 "Admin" 栏目下点击 "Add a Virtual Host" 按钮,创建一个名为 "/test" 的虚拟主机。
4. 在 "Admin" 栏目下点击 "test" 虚拟主机的 "Permissions" 按钮,设置该虚拟主机的访问权限。
5. 在弹出的对话框中选择刚才创建的用户,勾选 "Configure", "Write" 和 "Read" 权限,并点击 "Set permission" 按钮。
6. 在客户端代码中指定连接账号的用户名和密码,并连接到 RabbitMQ 服务器:
```python
import pika
# 创建连接参数对象
credentials = pika.PlainCredentials('username', 'password')
# 创建连接对象
connection = pika.BlockingConnection(pika.ConnectionParameters(
'localhost', 5672, '/', credentials))
# 创建信道对象
channel = connection.channel()
# 创建消息队列
channel.queue_declare(queue='hello')
# 发送消息
channel.basic_publish(exchange='',
routing_key='hello',
body='Hello World!')
# 关闭连接
connection.close()
```
在以上代码中,`credentials` 参数指定了连接账号的用户名和密码,`pika.BlockingConnection` 方法创建了一个连接对象,`channel` 对象通过 `queue_declare` 方法创建了一个名为 "hello" 的消息队列,并通过 `basic_publish` 方法发送了一条消息。
执行以上代码后,你就成功创建了一个连接账号,并使用该账号向 RabbitMQ 服务器发送了一条消息。
阅读全文