消息推送系统

// 示例代码：统一消息服务的核心逻辑

const express = require('express');

const mongoose = require('mongoose');

const app = express();

const PORT = process.env.PORT || 3000;

// 连接MongoDB

mongoose.connect('mongodb+srv://:@cluster.mongodb.net/messages', {

useNewUrlParser: true,

useUnifiedTopology: true

});

// 定义消息模型

const MessageSchema = new mongoose.Schema({

sender: String,

recipient: String,

content: String,

timestamp: Date

});

const Message = mongoose.model('Message', MessageSchema);

// 接收消息的API端点

app.post('/messages', async (req, res) => {

try {

const { sender, recipient, content } = req.body;

const message = new Message({ sender, recipient, content, timestamp: new Date() });

await message.save();

res.status(201).send('Message saved successfully!');

} catch (error) {

res.status(500).send('Error saving message.');

}

});

// 启动服务器

app.listen(PORT, () => {

console.log(`Server running on port ${PORT}`);

学工系统

});

]]>