消息推送系统

// RabbitMQ连接配置

const amqp = require('amqplib/callback_api');

amqp.connect('amqp://localhost', function(error0, connection) {

if (error0) {

throw error0;

}

connection.createChannel(function(error1, channel) {

if (error1) {

throw error1;

}

var queue = 'message_queue';

var msg = 'Hello World!';

channel.assertQueue(queue, {durable: false});

channel.sendToQueue(queue, Buffer.from(msg));

console.log(" [x] Sent %s", msg);

});

});

const socket = new WebSocket('ws://localhost:8080');

socket.onmessage = function(event) {

console.log('Received:', event.data);

};