统一消息系统

// 使用RabbitMQ作为消息队列

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

// 创建连接到RabbitMQ服务器的通道

amqp.connect('amqp://localhost', (err, conn) => {

conn.createChannel((err, ch) => {

const queue = 'message_center';

// 发送消息到队列

function sendMessage(message) {

ch.sendToQueue(queue, Buffer.from(message));

企业云服务管理平台

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

}

// 接收消息

ch.consume(queue, msg => {

console.log(" [x] Received %s", msg.content.toString());

// 这里可以添加将消息转发给厂家系统的代码

}, {noAck: true});

});

});

// 创建一个简单的HTTP服务器来接收来自厂家的请求

const http = require('http');

const hostname = '127.0.0.1';

const port = 3000;

const server = http.createServer((req, res) => {

let body = [];

req.on('data', chunk => {

body.push(chunk);

}).on('end', () => {

body = Buffer.concat(body).toString();

// 将接收到的数据发送到消息队列

sendMessage(body);

res.writeHead(200, {'Content-Type': 'text/plain'});

res.end('Message received and forwarded to message center.');

});

});

server.listen(port, hostname, () => {

console.log(`Server running at http://${hostname}:${port}/`);

});

]]>