「中间件」rabbitmq 消息队列基础知识

RabbitMQ是一个开源的消息队列服务器，用于通过推送消息来处理应用程序之间的通信。以下是RabbitMQ的基础概念和一个简单的Python生产者和消费者示例。

RabbitMQ基本概念：

1. 队列（Queue）：存放消息的虚拟节点。
2. 生产者（Producer）：发送消息到队列的应用程序。
3. 消费者（Consumer）：从队列接收消息的应用程序。
4. 交换器（Exchange）：用于接收生产者发送的消息并将它们路由到一个或多个队列。
5. 绑定（Binding）：将交换器和队列连接的规则，确定消息如何路由。

Python示例代码：

生产者（发送消息）：

import pika
 
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
 
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}")
 
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()  # 开始接收消息

确保RabbitMQ服务正在运行，然后先运行消费者，再运行生产者，你将在消费者控制台看到打印出的消息内容。