发送消息

import pika# 设置RabbitMQ连接参数(更改账号密码)
credentials = pika.PlainCredentials('username', 'password')
# 更改为自己的服务器地址
parameters = pika.ConnectionParameters('192.168.0.157', 5672, '/', credentials)# 建立到RabbitMQ的连接
connection = pika.BlockingConnection(parameters)
channel = connection.channel()# 声明队列，确保它存在
queue_name = 'radarQueue'  # 队列名字
channel.queue_declare(queue=queue_name, durable=True, passive=True)# 要发送的消息
crawled_data = {'key': 'value00'}# 将字典转换为JSON字符串
crawled_data_json = json.dumps(crawled_data)# 发布消息到指定队列
channel.basic_publish(exchange='',routing_key=queue_name,body=crawled_data_json.encode("utf-8"),  # 要传字节 properties=pika.BasicProperties(delivery_mode=2,  # 使消息持久化))
print(crawled_data)# 关闭连接
connection.close()

接收消息

import pika# 设置RabbitMQ连接参数
credentials = pika.PlainCredentials('username', 'password')
parameters = pika.ConnectionParameters('192.168.0.157', 5672, '/', credentials)# 建立到RabbitMQ的连接
connection = pika.BlockingConnection(parameters)
channel = connection.channel()# 声明队列，确保它存在
queue_name = 'radarQueue'
channel.queue_declare(queue=queue_name, durable=True, passive=True)# 定义一个回调函数，用来处理队列中的消息
def callback(ch, method, properties, body):print(f" [x] Received {body}")# 告诉RabbitMQ从队列中接收消息
channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)print(' [*] Waiting for messages. To exit press CTRL+C')
try:# 开始接收消息，这会一直运行直到被中断channel.start_consuming()
except KeyboardInterrupt:channel.stop_consuming()# 关闭连接
connection.close()