javascript - 在服务器端编写 mongodb 更改的监听器

Question

我想为服务器端的 Nodejs 应用程序编写一个监听器，用于更改 mongoDB 中的集合。我正在使用 Robe 来获取 oplog。这是我的代码:

  var co = require('co'),
    Robe = require('robe');

  co(function*() {
    // connect to db
    var db = yield Robe.connect('mongodb://localhost/');
    yield collection.addWatcher(function(collectionName, operationType, data) {
      console.log(collectionName)
    });
    var oplog = yield db.oplog();
    yield oplog.start();
    // listen for any operation on any collection
    oplog.onAny(function(collectionName, operationType, data) {
      console.log("something happened!!!")
    });
  })
    .catch(function(err) {
      console.error(err);
    });

Robe 的文档说，要获取 oplog，我需要连接到 mongoDB 中的副本集。我一直在阅读 mongoDB 上的副本集，但我还没有理解它的意义。我确实创建了一个名为“rs0”的副本集。我运行此命令来启动 mongod:

         mongod --replset "rs0"

在数据库更改时它仍然没有执行任何操作。这真的是正确的方法吗？

Answer 1

每当您使用 replSet 配置启动 mongod 实例时，您都必须使用 rs.initiate() 命令启动副本集，然后添加副本集成员。

当您使用驱动程序客户端连接到副本集时，请提供副本集 mongod 主机的完整列表，以便我们能够利用副本集自动故障转移的优势。