微服务中间件--MQ

微服务中使用消息队列（MQ）作为中间件是一种常见的模式，它有助于服务解耦、异步通信、流量控制等。以下是一个使用RabbitMQ的Python示例，演示如何发送和接收消息。

首先，安装RabbitMQ和Python的pika库（RabbitMQ的客户端）：

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}")
 
# 告诉RabbitMQ使用callback函数来处理队列中的消息
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
 
# 开始监听队列，并接收消息
channel.start_consuming()

确保RabbitMQ服务正在运行，然后先运行生产者发送消息，随后运行消费者接收消息。