转到：客户端已断开连接

Question

自从我加入Gophers团队以来已经有几周了。目前为止，一切都好。我开始了一个新项目，使用光纤Web框架来构建后端API。

我使用蒙哥DB作为我的数据库。

数据库/数据库

package database

import (

    "context"

    "log"

    "time"

    "go.mongodb.org/mongo-driver/mongo"

    "go.mongodb.org/mongo-driver/mongo/options"

    "go.mongodb.org/mongo-driver/mongo/readpref"

)

var DB *mongo.Database

// InitMongo : Initialize mongodb...

func connectToMongo() {

    log.Printf("Initializing database")

    client, err := mongo.NewClient(options.Client().ApplyURI("mongodb://localhost:27017"))

    if err != nil {

        log.Fatal("Could not able to connect to the database, Reason:", err)

    }

    ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)

    err = client.Connect(ctx)

    if err != nil {

        log.Fatal("Context error, mongoDB:", err)

    }

    //Cancel context to avoid memory leak

    defer cancel()

    defer client.Disconnect(ctx)

    // Ping our db connection

    err = client.Ping(context.Background(), readpref.Primary())

    if err != nil {

        log.Fatal("Ping, mongoDB:", err)

    }

    log.Printf("Database connected!")

    // Create a database

    DB = client.Database("golang-test")

    return

}

// In Golang, init() functions always initialize whenever the package is called.

// So, whenever DB variable called, the init() function initialized

func init() {

    connectToMongo()

}

控制器/mongo.controller/mongo.controller.go

package mongocontroller

import (

    "log"

    "github.com/gofiber/fiber/v2"

    service "gitlab.com/.../services/mongoservice"

)

// GetPersons godoc

// @Summary Get persons.

// @Description Get persons

// @Tags persons

// @Produce json

// @Success 200 {object} []service.Person

// @Failure 400 {object} httputil.HTTPError

// @Failure 404 {object} httputil.HTTPError

// @Failure 500 {object} httputil.HTTPError

// @Router /v1/persons [get]

func GetPersons(c *fiber.Ctx) error {

    res, err := service.GetPersons()

    if err != nil {

        log.Fatal("ERROR: in controller...", err)

    }

    return c.JSON(res)

}

以下是我存储在数据库中的数据：

Answer 1

您正在调用正在创建连接的同一函数 （），因此它将在调用该函数后关闭连接。您应该返回连接并在完成任务后关闭。我的意思是这些部分：defer client.Disconnect(ctx)connectToMongo defer cancel() defer client.Disconnect(ctx)