0

在这个简单的程序中，我想在主节点崩溃时重新连接到副本集。但它不起作用：如果主节点崩溃，这个程序将立即终止，没有任何输出，并返回141。我不知道为什么。重新连接到副本集的正确方法是什么？

#include <stdio.h>
#include <mongo.h>

int insertVal(mongo *conn, int val) {
    bson op[1];
    bson_init(op);
    bson_append_int(op, "val", val);
    bson_finish(op);

    int status = mongo_insert(conn, "test.vals", op, NULL);

    bson_destroy(op);
    return status;
}

int main()
{
    mongo conn[1];
    mongo_replset_init(conn, "test");
    mongo_replset_add_seed(conn, "localhost", 27017);
    mongo_replset_add_seed(conn, "localhost", 27018);
    mongo_replset_add_seed(conn, "localhost", 27019);
    int status = mongo_replset_connect(conn);
    if (status != MONGO_OK) {
    return 1;
    }

    for (int i = 0; i < 1000 * 1000; ++i) {
        status = insertVal(conn, i);
        if (status != MONGO_OK) {
            printf("%d\n", status);
            --i;
            mongo_reconnect(conn);
        }
    }

    mongo_destroy(conn);
    return 0;
}
4

1 回答 1

0

不需要自己做DB管理操作mongo_reconnect(conn);，可能会和mongodb冲突。

请参阅此处的文档。“Mongodb 副本集具有自动故障转移功能。如果主节点离线或无响应，并且大多数原始集成员仍然可以相互连接，则该集将选择一个新的主节点”。

于 2012-12-23T19:05:48.017 回答