MongoDB 架构设计 - 实时聊天

MongoDB 是一种流行的非关系型数据库，其灵活性和可扩展性使其成为实时聊天应用程序的理想选择。在本文中，我们将探讨如何使用 MongoDB 构建一个实时聊天系统，并提供一些示例代码。

javascript
{
  "_id": ObjectId("605c3f9a3f5a9d48bea3d8c1"),
  "username": "Alice",
  "password": "hashed_password",
  "email": "alice@example.com",
  "friends": ["Bob", "Charlie"]
}

javascript
{
  "_id": ObjectId("605c3f9a3f5a9d48bea3d8c2"),
  "name": "Room 1",
  "members": ["Alice", "Bob", "Charlie"]
}

javascript
{
  "_id": ObjectId("605c3f9a3f5a9d48bea3d8c3"),
  "sender": "Alice",
  "receiver": "Bob",
  "timestamp": ISODate("2021-03-26T09:00:00Z"),
  "content": "Hello Bob!"
}

bash
$ npm install node
$ npm install socket.io
$ npm install mongodb

javascript
const MongoClient = require('mongodb').MongoClient;
const io = require('socket.io')(3000);
MongoClient.connect('mongodb://localhost:27017', (err, client) => {
  if (err) throw err;
  const db = client.db('chat');
  io.on('connection', (socket) => {
    // 处理用户加入聊天室的事件
    socket.on('join', (room) => {
      socket.join(room);
    });
    // 处理发送消息的事件
    socket.on('message', (data) => {
      const message = {
        sender: data.sender,
        receiver: data.receiver,
        timestamp: new Date(),
        content: data.content
      };
      db.collection('messages').insertOne(message, (err, res) => {
        if (err) throw err;
        // 将消息发送给聊天室中的所有成员
        io.to(data.receiver).emit('message', message);
      });
    });
  });
});

html
  
  
  
  
  发送