python 操作 rabbitmq代码

好的，如果你想在 Python 中操作 RabbitMQ，可以使用 Pika 库。Pika 是一个 Python 实现的 RabbitMQ 客户端库，它提供了简单易用的接口来连接、发布和消费消息。以下是一个使用 Pika 库连接 RabbitMQ 并发送消息的示例代码：

import pika

# 连接 RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('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()

以上代码会连接到名为 `localhost` 的 RabbitMQ 实例，并声明一个名为 `hello` 的队列。然后，它会将一条消息发送到该队列，并在控制台输出一条消息以确认发送已完成。

相关问题

python 操作 rabbitmq消费者代码

好的，以下是一个使用 Pika 库连接 RabbitMQ 并消费消息的示例代码：

import pika

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

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

# 定义回调函数来处理消息
def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)

# 告诉 RabbitMQ 将消息发送到回调函数
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)

# 开始消费消息
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

以上代码会连接到名为 `localhost` 的 RabbitMQ 实例，并声明一个名为 `hello` 的队列。然后，它会定义一个回调函数来处理从队列中接收的消息，并告诉 RabbitMQ 将消息发送到该回调函数。最后，它会开始消费来自队列的消息，并在控制台输出每个接收到的消息。

python 操作 RabbitMQ

Python可以使用pika库来操作RabbitMQ。

以下是使用pika库连接RabbitMQ，创建队列并发送消息的示例代码：

import pika

# 连接RabbitMQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('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库连接RabbitMQ，接收消息的示例代码：

import pika

# 连接RabbitMQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

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

# 定义回调函数，用于处理接收到的消息
def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)

# 订阅队列
channel.basic_consume(queue='hello',
                      auto_ack=True,
                      on_message_callback=callback)

print(' [*] Waiting for messages. To exit press CTRL+C')
# 开始接收消息
channel.start_consuming()

# 关闭连接
connection.close()

以上是pika库的使用示例，更多关于pika库的详细使用可以参考官方文档：https://pika.readthedocs.io/en/stable/