统一消息系统

// 消息生产者示例代码

import pika

def send_message(message):

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

channel = connection.channel()

channel.queue_declare(queue='notifications')

channel.basic_publish(exchange='', routing_key='notifications', body=message)

print(" [x] Sent %r" % message)

connection.close()

# 示例调用

send_message('{"type":"email","to":"student@example.com","subject":"Class Reminder"}')

]]>

// WebSocket服务器示例代码

const WebSocket = require('ws');

const wss = new WebSocket.Server({ port: 8080 });

wss.on('connection', function connection(ws) {

ws.on('message', function incoming(message) {

console.log('received: %s', message);

});

ws.send('Hello! Message from server');

});

]]>