微服务中间件 RabbitMq学习

RabbitMQ是一个开源的消息代理和队列服务器，用于通过插件支持多种消息协议，并且可以提供用于消息传递的高级队列特性，如：消息负载的可靠传递、消息的排队管理等。

以下是一个使用RabbitMQ的Python示例，演示了如何发送和接收消息：

首先，安装RabbitMQ和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')
 
print(' [*] Waiting for messages. To exit press CTRL+C')
 
# 定义回调函数处理消息
def callback(ch, method, properties, body):
    print(f" [x] Received {body}")
 
# 接收消息
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
 
# 开始监听消息
channel.start_consuming()

在这个例子中，发送者发送一条消息到名为hello的队列，接收者从同一队列接收消息并打印出来。这个例子演示了如何使用RabbitMQ进行基本的消息发送和接收。