统一消息系统

import pika

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

channel = connection.channel()

channel.queue_declare(queue='notifications')

channel.basic_publish(exchange='',

routing_key='notifications',

body='新消息来了！')

print(" [x] Sent '新消息来了！'")

connection.close()

const socket = new WebSocket('ws://your-websocket-endpoint');

socket.onmessage = function(event) {

console.log('收到消息:', event.data);

// 更新页面上的消息列表

};