写一个用到rabbitmq的demo
时间: 2023-07-01 10:05:08 浏览: 104
好的,下面是一个简单的使用 RabbitMQ 的 demo:
首先,需要安装 RabbitMQ,并启动 RabbitMQ 服务。
然后,在 Python 中使用 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!'")
# 接收消息
def callback(ch, method, properties, body):
print(" [x] Received %r" % body)
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()
# 关闭连接
connection.close()
这个 demo 实现了一个简单的消息队列,发送者可以将消息发送到队列中,接收者从队列中接收消息。在这个 demo 中,我们定义了一个名为 "hello" 的队列,发送者会将消息发送到这个队列中,而接收者会从这个队列中接收消息。当发送者发送消息后,接收者会立即接收到该消息并打印出来。
运行该脚本后,可以在发送者和接收者之间进行通信,测试 RabbitMQ 的使用。
相关推荐














