统一消息系统

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))

channel = connection.channel()

channel.queue_declare(queue='message_queue')

messages = ['消息1', '消息2', '消息3']

学生综合服务门户

for msg in messages:

channel.basic_publish(exchange='',

routing_key='message_queue',

body=msg)

print("消息已成功发送")

connection.close()