统一消息系统

import pika

def send_batch_messages(messages):

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

channel = connection.channel()

channel.queue_declare(queue='batch_messages')

for message in messages:

channel.basic_publish(exchange='',

routing_key='batch_messages',

body=message)

print("批量消息已发送")

connection.close()

if __name__ == '__main__':

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

send_batch_messages(messages)