统一消息推送与在线功能的实现与优化

小明：最近我们项目需要实现一个统一的消息推送功能，你觉得怎么做比较好？

小李：我觉得可以考虑使用消息队列来统一处理所有消息，比如用RabbitMQ或者Kafka。这样不仅能够保证消息的可靠性，还能支持批量发消息。

小明：那怎么判断用户是否在线呢？

小李：可以通过WebSocket保持长连接，或者在后端维护一个在线状态表，记录每个用户的登录状态。当用户在线时，直接推送；离线时则存储到数据库，等用户上线后再推送。

小明：听起来不错。那具体怎么实现批量发消息呢？

小李：可以在前端将多个消息打包成一个请求发送到后端，后端再将这些消息分批处理并推送到对应用户。例如，使用JSON数组传递消息内容，然后循环遍历发送。

小明：有没有具体的代码示例？

小李：当然有。比如用Node.js写一个简单的推送服务：

    const express = require('express');
    const app = express();
    app.use(express.json());

    app.post('/send-batch', (req, res) => {
        const messages = req.body.messages;
        messages.forEach(msg => {
            // 模拟消息推送逻辑
            console.log(`推送消息: ${msg.content} 到用户: ${msg.userId}`);
        });
        res.send({ status: 'success' });
    });

    app.listen(3000, () => console.log('Server running on port 3000'));
    

小明：明白了，这样就能支持批量发消息了。

小李：对，同时结合在线状态判断，可以优化用户体验，避免消息丢失。

小明：谢谢你的讲解！

小李：不客气，有问题随时交流。