如何用NodeJS与MongoDB Atlas实现实时聊天（无需采购实时数据库）

完全可以基于你现有的技术栈实现实时聊天，不用额外采购付费实时数据库，核心思路是利用MongoDB Atlas免费版支持的Change Streams结合NodeJS WebSocket服务来实现消息的实时推送，以下是具体实现步骤：

1. NodeJS端：搭建WebSocket服务 + 监听MongoDB数据变化 #

MongoDB Atlas的免费集群已经支持Change Streams，它可以实时监听集合的插入、更新等操作。我们可以用这个特性捕获新消息，再通过WebSocket推送给Android客户端。

实现步骤 #

• 安装WebSocket依赖：npm install ws
• 连接MongoDB Atlas并监听消息集合的插入操作，将新消息推送给对应客户端：

const WebSocket = require('ws');
const { MongoClient } = require('mongodb');

// 初始化WebSocket服务
const wss = new WebSocket.Server({ port: 8080 });
// 替换为你的MongoDB Atlas连接字符串
const mongoUri = 'mongodb+srv://<用户名>:<密码>@cluster0.mongodb.net/';

MongoClient.connect(mongoUri)
  .then(client => {
    const db = client.db('你的数据库名');
    const messagesCollection = db.collection('messages');
    
    // 监听消息集合的插入操作
    const changeStream = messagesCollection.watch([
      { $match: { operationType: 'insert' } }
    ]);

    // 收到新消息时推送给客户端
    changeStream.on('change', (change) => {
      const newMessage = change.fullDocument;
      // 仅推送给对应聊天房间的用户（需维护客户端与房间的映射）
      wss.clients.forEach(client => {
        if (client.readyState === WebSocket.OPEN && client.roomId === newMessage.roomId) {
          client.send(JSON.stringify(newMessage));
        }
      });
    });

    // 处理客户端连接，记录其所属聊天房间
    wss.on('connection', (ws) => {
      ws.on('message', (data) => {
        const { roomId } = JSON.parse(data);
        ws.roomId = roomId;
      });
    });
  })
  .catch(err => console.error('MongoDB连接失败:', err));

2. Android Java端：实现WebSocket客户端接收实时消息 #

使用Java-WebSocket库连接NodeJS的WebSocket服务，收到新消息后直接更新RecyclerView，无需重启应用。

实现步骤 #

• 在app的build.gradle添加依赖：

implementation 'org.java-websocket:Java-WebSocket:1.5.3'

• 实现WebSocket客户端类：

import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;
import android.os.Handler;
import android.os.Looper;
import android.widget.RecyclerView;
import com.google.gson.Gson;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.HashMap;

public class ChatWebSocketClient extends WebSocketClient {
    private final MessageAdapter messageAdapter;
    private final RecyclerView recyclerView;

    public ChatWebSocketClient(String serverUri, MessageAdapter adapter, RecyclerView rv) throws URISyntaxException {
        super(new URI(serverUri));
        this.messageAdapter = adapter;
        this.recyclerView = rv;
    }

    @Override
    public void onOpen(ServerHandshake handshakedata) {
        // 连接成功后发送当前聊天房间ID，让服务端知道要推送哪些消息
        HashMap<String, String> data = new HashMap<>();
        data.put("roomId", "当前聊天的房间ID");
        send(new Gson().toJson(data));
    }

    @Override
    public void onMessage(String message) {
        // 解析新消息并在UI线程更新RecyclerView
        Message newMsg = new Gson().fromJson(message, Message.class);
        new Handler(Looper.getMainLooper()).post(() -> {
            messageAdapter.addMessage(newMsg);
            messageAdapter.notifyItemInserted(messageAdapter.getItemCount() - 1);
            recyclerView.scrollToPosition(messageAdapter.getItemCount() - 1);
        });
    }

    @Override
    public void onClose(int code, String reason, boolean remote) {
        // 连接断开时自动重连
        reconnect();
    }

    @Override
    public void onError(Exception ex) {
        ex.printStackTrace();
    }
}

• 在聊天页面初始化WebSocket客户端：

try {
    ChatWebSocketClient wsClient = new ChatWebSocketClient(
        "ws://你的NodeJS服务器IP:8080",
        messageAdapter,
        chatRecyclerView
    );
    wsClient.connect();
} catch (URISyntaxException e) {
    e.printStackTrace();
}

3. 关键优化点 #

• 离线消息兼容：客户端启动时仍通过API Get请求拉取历史消息，再建立WebSocket连接，确保离线期间的消息不会丢失。
• 精准推送：通过房间ID过滤推送对象，避免给所有客户端发送无关消息，减少资源消耗。
• 重连机制：WebSocket断开后自动尝试重连，保证实时连接的稳定性。

其他功能的兼容方案 #

• 语音/图片消息：保持原有的上传逻辑，上传完成后插入MongoDB，Change Streams会自动捕获插入操作并推送消息。
• 通知功能：NodeJS端结合FCM（Firebase Cloud Messaging），检测到新消息或截图事件时，给目标用户发送推送通知；Android端监听屏幕截图广播，触发后调用API通知对方。
• 音视频通话：集成WebRTC库，用NodeJS的WebSocket服务作为信令服务器，传递通话发起、应答等信令，实现端到端通话。

内容的提问来源于stack exchange，提问作者Hammad