python连接rabbitmq

连接 RabbitMQ 可以使用 Pika 库，以下是一个简单的 Python 代码示例：

import pika

# 连接 RabbitMQ
connection = pika.BlockingConnection(
    pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

# 创建一个队列
channel.queue_declare(queue='hello')

# 发送消息到队列
channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
print(" [x] Sent 'Hello World!'")

# 关闭连接
connection.close()

这个示例中，我们首先使用 `pika.BlockingConnection` 连接到了本地的 RabbitMQ 服务。然后，我们使用 `channel.queue_declare` 创建了一个名为 "hello" 的队列。最后，我们使用 `channel.basic_publish` 发送了一条消息到这个队列中。

注意，这个示例中我们使用了默认的 exchange，即 `exchange=''`，这意味着我们将消息直接发送到了队列中。在实际场景中，你可能需要使用不同的 exchange 和 routing key 来控制消息的路由。

另外，如果你的 RabbitMQ 服务不在本地，你需要将 `host` 参数设置为相应的 IP 地址或域名。