Nodejs 关于多个node服务器使用mongodb的问题，请指导。

Nodejs 关于多个node服务器使用mongodb的问题，请指导。

我创建了两个node服务器，其中一个服务器创建了一个mongo数据库：test，数据库里有个集合eparas……现在我要从另一个node服务器来访问eparas并从中查询数据，该怎么做呢？

5 回复

Node.js 多个服务器使用 MongoDB 的问题

在多个 Node.js 服务器之间共享 MongoDB 数据库时，你可以通过以下步骤来实现：

  1. 确保 MongoDB 服务可用：确保 MongoDB 服务在所有服务器上都可以访问。如果 MongoDB 部署在本地机器上，则需要配置网络使其可以在其他服务器上访问。

  2. 连接到 MongoDB：每个 Node.js 服务器都需要使用 MongoDB 客户端库（如 mongoose 或 mongodb）连接到 MongoDB 数据库。

  3. 执行查询：在第二个 Node.js 服务器中，你可以使用相同的 MongoDB 客户端库来执行查询操作。

下面是一个简单的示例，展示如何在第二个 Node.js 服务器中连接到 MongoDB 并查询 eparas 集合中的数据。

示例代码

首先，你需要安装 mongodb 包。如果你还没有安装，可以使用以下命令安装：

npm install mongodb

然后，在你的 Node.js 服务器代码中，你可以这样写：

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

// MongoDB 连接字符串
const uri = 'mongodb://<username>:<password>@<mongodb-host>:<port>/test?retryWrites=true&w=majority';

// 创建客户端
const client = new MongoClient(uri, { useNewUrlParser: true, useUnifiedTopology: true });

async function connectAndQuery() {
    try {
        // 连接到 MongoDB
        await client.connect();
        console.log("Connected successfully to server");

        // 选择数据库
        const db = client.db('test');
        
        // 选择集合
        const collection = db.collection('eparas');

        // 查询数据
        const result = await collection.find({}).toArray();

        console.log(result);
    } catch (err) {
        console.error(err);
    } finally {
        // 关闭连接
        await client.close();
    }
}

connectAndQuery();

解释

  1. MongoDB 连接字符串：将 <username>、<password>、<mongodb-host> 和 <port> 替换为你的实际 MongoDB 服务器的用户名、密码、主机名和端口。

  2. 创建客户端：使用 MongoClient 创建一个 MongoDB 客户端实例，并传入连接字符串和其他选项。

  3. 连接到 MongoDB：调用 client.connect() 方法连接到 MongoDB 服务器。

  4. 选择数据库和集合：使用 client.db('test') 选择数据库 test，然后使用 db.collection('eparas') 选择集合 eparas。

  5. 执行查询：使用 collection.find({}).toArray() 查询集合中的所有文档，并将其转换为数组。

  6. 关闭连接：最后，确保在操作完成后关闭 MongoDB 连接。

通过这种方式，你可以在多个 Node.js 服务器之间共享和查询 MongoDB 数据库。


我的一个想法是在nodejs服务器中使用的mongo数据库的管理员用户名和密码连接数据库就可以吧。

那样只是连上了数据库啊，关键是怎么去访问文档

举一个mongoskin的例子。(db_path按照自己需求改，db_name就是指明你需要访问哪个mongodb实例，你需要的文档就是在里面）

var db_path = "http://" + config.username + ":" + config.password + "@" + config.db_host + ":" + config.db_port + "/" + config.db_name + '?auto_reconnect=true',
    db = require('mongoskin').db(db_path, {safe: true});

要让多个Node.js服务器访问同一个MongoDB数据库，你可以通过以下步骤来实现：

  1. 确保MongoDB配置正确：首先，确保你的MongoDB服务器已经启动并且可以被网络上的其他服务器访问。通常情况下，MongoDB默认监听本地端口（如27017），你需要将它配置为监听所有网络接口（例如，使用bindIp: 0.0.0.0）。

  2. 安装MongoDB驱动：在每个Node.js服务器上安装mongodb npm包，以便它们能够连接到MongoDB。

npm install mongodb
  1. 建立数据库连接：在每个Node.js服务器上，创建一个MongoDB客户端实例，并使用该实例进行数据库操作。

示例代码

服务器A（创建数据库和集合）

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

async function main() {
    const uri = "your_mongodb_connection_string"; // MongoDB连接字符串
    const client = new MongoClient(uri);

    try {
        await client.connect();
        console.log("Connected to MongoDB");

        const database = client.db('test');
        const collection = database.collection('eparas');

        // 插入数据示例
        await collection.insertOne({ name: 'example' });
        console.log("Data inserted successfully");
    } catch (error) {
        console.error("Error:", error);
    } finally {
        await client.close();
    }
}

main().catch(console.error);

服务器B（读取数据）

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

async function main() {
    const uri = "your_mongodb_connection_string"; // MongoDB连接字符串
    const client = new MongoClient(uri);

    try {
        await client.connect();
        console.log("Connected to MongoDB");

        const database = client.db('test');
        const collection = database.collection('eparas');

        // 查询数据示例
        const data = await collection.findOne();
        console.log("Data fetched:", data);
    } catch (error) {
        console.error("Error:", error);
    } finally {
        await client.close();
    }
}

main().catch(console.error);

解释

  • uri 是MongoDB的连接字符串，包含了数据库的地址、端口、认证等信息。
  • client.connect() 方法用于建立与MongoDB的连接。
  • database.collection('eparas') 获取名为eparas的集合。
  • insertOne 和 findOne 分别用于插入和查询数据。

确保两个Node.js服务器都使用相同的uri连接到同一个MongoDB实例，这样就可以共享数据了。

回到顶部