如何将副本集成员添加到 mongo 实例的主节点？

积累知识，胜过积蓄金银！毕竟在Golang开发的过程中，会遇到各种各样的问题，往往都是一些细节知识点还没有掌握好而导致的，因此基础知识点的积累是很重要的。下面本文《如何将副本集成员添加到 mongo 实例的主节点？》，就带大家讲解一下知识点，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

这可能是我误解了 mongo 的工作原理/新的 go 开发 - 但我无法从 go 连接到我的 mongo 实例。当我使用 studio 3t 连接到我的 mongo 实例时，我可以很好地连接、浏览表等。但是如果我尝试使用 go 模块进行连接，它会抱怨无法找到所有节点。是否需要能够访问所有节点？我认为副本集本身应该处理复制？

例如，我有这个 go 代码：

    package main
    
    import (
        "context"
        "go.mongodb.org/mongo-driver/mongo"
        "go.mongodb.org/mongo-driver/mongo/options"
        "go.mongodb.org/mongo-driver/mongo/readpref"
        "log"
        "time"
    )
    
    func main() {
        log.println("hello world!")
    
        ctx, cancel := context.withtimeout(context.background(), 10*time.second)
        defer cancel()
    
        client, err := mongo.connect(ctx, options.client().applyuri("mongodb://mongoinsance:27017"))
        if err != nil {
            log.fatal("failed to connect to mongo db", err)
        }
    
        if err := client.ping(ctx, readpref.primary()); err != nil {
            log.fatal("not actually connected ", err)
        }
    
        res, err := client.listdatabases(ctx, nil)
        if err != nil{
            log.fatal("failed to list databases")
        }
    
        for _, val := range res.databases {
            log.println(val.name)
        }
        defer disconnect(client, &ctx)
    }
    
    func disconnect(client *mongo.client, ctx *context.context) {
        if err := client.disconnect(*ctx); err != nil {
            panic(err)
        }
    }

但是运行所述代码时得到的响应给出了错误：

not actually connected server selection error: context deadline exceeded, current topology: { type: replicasetnoprimary, servers: [{ addr: mqtt-ingester-db-mast:27017, type: unknown, last error: connection() error occured during connection handshake: dial tcp: lookup mqtt-ingester-db-mast: no such host }, { addr: mqtt-ingester-db-rep1:27017, type: unknown, last error: connection() error occured during connection handshake: dial tcp: lookup mqtt-ingester-db-rep1: no such host }, { addr: mqtt-ingester-db-rep2:27017, type: unknown, last error: connection() error occured during connection handshake: dial tcp: lookup mqtt-ingester-db-rep2: no such host }, ] }

我实际上还需要公开所有副本集吗？ 目前，我有一个主节点和 2 个辅助节点在主机 mongoinstance 上的 docker 中运行，其中主节点连接到端口 27017：

docker-compose.yml

    services:
      ...
      mqtt-ingester-db-mast:
        container_name: mqtt-ingester-db-mast
        restart: always
        image: mongo:latest
        ports:
          - 27017:27017
        volumes:
          - 'mongo_main:/data/db'
        entrypoint: [ "/usr/bin/mongod", "--bind_ip_all", "--replSet", "rs0" ]
      mqtt-ingester-db-rep1:
        container_name: mqtt-ingester-db-rep1
        restart: always
        image: mongo:latest
        expose:
          - 27017
        volumes:
          - 'mongo_rep1:/data/db'
        entrypoint: [ "/usr/bin/mongod", "--bind_ip_all", "--replSet", "rs0" ]
      mqtt-ingester-db-rep2:
        container_name: mqtt-ingester-db-rep2
        restart: always
        image: mongo:latest
        expose:
          - 27017
        volumes:
          - 'mongo_rep2:/data/db'
        entrypoint: [ "/usr/bin/mongod", "--bind_ip_all", "--replSet", "rs0" ]
      mqtt-ingester-setup:
        image: mongo:latest
        container_name: mqtt-ingester-setup
        links:
          - mqtt-ingester-db-mast:mqtt-ingester-db-mast
          - mqtt-ingester-db-rep1:mqtt-ingester-db-rep1
          - mqtt-ingester-db-rep2:mqtt-ingester-db-rep2
        depends_on:
          - mqtt-ingester-db-mast
          - mqtt-ingester-db-rep1
          - mqtt-ingester-db-rep2
        volumes:
          - ./mqtt-ingester:/scripts
        restart: "no"
        entrypoint: [ "bash", "/scripts/mqtt_ingester_setup.sh" ]
      mqtt-ingester-explorer:
        container_name: mqtt-ingester-explorer
        restart: always
        image: mongo-express:latest
        ports:
          - '8081:8081'
        depends_on:
          - mqtt-ingester-db-mast
        links:
          - mqtt-ingester-db-mast:mongo
      ...

正确答案

我实际上还需要公开所有副本集吗？

是的。客户端需要查看副本集中的所有节点，以便在主节点出现故障时可以进行故障转移。

理论要掌握，实操不能落！以上关于《如何将副本集成员添加到 mongo 实例的主节点？》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！