【中间件】RabbitMQ入门

RabbitMQ是一个开源的消息代理和队列服务器，用于通过可靠的消息传递进行软件之间的集成。以下是一个简单的Python代码示例，演示如何使用pika库（Python的RabbitMQ客户端）来发送和接收消息。

安装pika库（如果尚未安装）:

pip install pika

生产者（发送消息）:

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()

消费者（接收消息并处理）:

import pika
 
# 连接到RabbitMQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
 
# 声明队列
channel.queue_declare(queue='hello')
 
def callback(ch, method, properties, body):
    print(f" [x] Received {body}")
 
# 告诉RabbitMQ我们想要接收消息，并告诉它我们想要使用callback函数来处理消息
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
 
print(' [*] Waiting for messages. To exit press CTRL+C')
 
# 开始接收信息
channel.start_consuming()

在这个例子中，我们首先声明了一个队列，然后生产者发送了一个简单的字符串消息到这个队列中。随后，消费者开始监听这个队列，并在消息到达时调用回调函数callback来处理消息。这个回调函数简单地打印出接收到的消息。

确保RabbitMQ服务正在运行，并且在发送和接收消息之前，根据需要更改连接参数（例如主机名）。