【问题标题】:The pool returned by pgxpool.Connect is nil or becomes nil quickly without errorpgxpool.Connect 返回的池为 nil 或快速变为 nil 且无错误
【发布时间】:2022-01-23 02:19:59
【问题描述】:

我有以下用于连接 Postgres 数据库的代码:

func connectToPostgres(ctx context.Context, url string) (*pgxpool.Pool, error) {
    var err error
    for i := 0; i < 5; i++ {
        p, err := pgxpool.Connect(ctx, url)
        if err != nil || p == nil {
            time.Sleep(3 * time.Second)
            continue
        }
        log.Printf("pool returned from connect: %s", p)
        return p, nil
    }
    return nil, errors.Wrap(err, "timed out waiting to connect postgres")
}

用例是在使用 docker-compose 启动我的服务器时等待 Postgres 可用。即使代码在 p == nil 时处于休眠状态,但在第一次返回之前的日志会打印出来:pool returned from connect: %!s(*pgxpool.Pool=&lt;nil&gt;)

pgxpool 中的后台进程是否可以通过某种方式生成p == nil

对为什么会发生这种情况有任何想法吗?

编辑:这似乎只在通过 docker-compose 运行我的应用程序和 Postgres 时发生。我正在使用以下撰写文件:

services:
    app:
        build: .
        ports:
            - "8080:8080"
        depends_on:
            - "db"

    db:
        image: postgres
        restart: always
        environment:
            - POSTGRES_DB=demo_db
            - POSTGRES_PASSWORD=${POSTGRES_PASSWORD}
        ports:
            - "8081:5432"

以及我的应用程序的 Dockerfile:

FROM golang:1.17

WORKDIR /

COPY go.mod .
COPY go.sum .
COPY *.go .

RUN go mod download
RUN go build

EXPOSE 8080

CMD [ "./app" ]

还有一个可重复性最低的示例 go 文件:

package main

import (
    "context"
    "fmt"
    "log"
    "net/http"
    "time"

    "github.com/jackc/pgx/v4/pgxpool"
    "github.com/pkg/errors"
)

func main() {
    log.Printf("connecting to postgres...")
    pgpool, err := connectToPostgres(context.Background(), "postgresql://localhost:5432/demo_db")
    log.Printf("pool: %s", pgpool)
    if err != nil {
        log.Fatalln(err)
    }
    log.Printf("successfully connected to postgres")

    if err := http.ListenAndServe(":8080", nil); err != nil {
        log.Fatal(err)
    }
    log.Println("stopped")
}

func connectToPostgres(ctx context.Context, url string) (*pgxpool.Pool, error) {
    var err error
    for i := 0; i < 5; i++ {
        p, err := pgxpool.Connect(ctx, url)
        if err != nil || p == nil {
            time.Sleep(3 * time.Second)
            continue
        }
        log.Printf("pool returned from connect: %s", p)
        return p, nil
    }
    return nil, errors.Wrap(err, "timed out waiting to connect postgres")
}

【问题讨论】:

  • 太奇怪了,我在本地试了一下,无法重现。您能否提供一个可重现的示例:stackoverflow.com/help/minimal-reproducible-example
  • 确实有一个检查,如果 p 为 nil,它将进入循环,你确定你发布了相同的代码吗?
  • 我可能应该包括这仅在通过 docker-compose 运行我的应用程序和 postgres 时发生。刚刚更新了问题,提供了有关如何重现问题的更多信息。
  • RE:循环中的 nil 检查 - 是的,我检查了三次。我的预感是日志消息在某种程度上延迟了,并且在后台发生了一些事情,因为否则检查会阻止 nil 值溜走。
  • 在你的 docker-compose 中你把数据库设为db,我的连接字符串是:"postgres://postgres:mysecretpassword@db:5432/postgres"

标签: go pgx


【解决方案1】:

问题是在docker-compose 网络中连接时,您必须连接到容器的主机名,在本例中为db

您也可以使用其他容器的IP,但需要额外的工作量,仅使用主机名更简单。

换句话说,你有错误的连接字符串,我在连接到localhost时也得到了这个

app_1  | 2021/12/21 18:53:28 pool: %!s(*pgxpool.Pool=<nil>)
app_1  | 2021/12/21 18:53:28 successfully connected to postgres

使用正确的连接字符串连接时:

 "postgres://postgres:mysecretpassword@db:5432/postgres"

效果很好。

其余的日志

db_1   | 2021-12-21 18:56:04.122 UTC [1] LOG:  database system is ready to accept connections
app_1  | 2021/12/21 18:56:06 pool returned from connect: &{%!s(*puddle.Pool=&{0xc00007c040 0xc0000280b0 [0xc00007c0c0] [0xc00007c0c0] 0x65cb60 0x65dc80 16 1 9872796 1 0 false}) %!s(*pgxpool.Config=&{0xc0000a2000 <nil> <nil> <nil> <nil> 3600000000000 1800000000000 16 0 60000000000 false true}) %!s(func(context.Context, *pgx.ConnConfig) error=<nil>) %!s(func(context.Context, *pgx.Conn) error=<nil>) %!s(func(context.Context, *pgx.Conn) bool=<nil>) %!s(func(*pgx.Conn) bool=<nil>) %!s(int32=0) %!s(time.Duration=3600000000000) %!s(time.Duration=1800000000000) %!s(time.Duration=60000000000) {%!s(uint32=0) {%!s(int32=0) %!s(uint32=0)}} %!s(chan struct {}=0xc000024060)}
app_1  | 2021/12/21 18:56:06 pool: &{%!s(*puddle.Pool=&{0xc00007c040 0xc0000280b0 [0xc00007c0c0] [0xc00007c0c0] 0x65cb60 0x65dc80 16 1 9872796 1 0 false}) %!s(*pgxpool.Config=&{0xc0000a2000 <nil> <nil> <nil> <nil> 3600000000000 1800000000000 16 0 60000000000 false true}) %!s(func(context.Context, *pgx.ConnConfig) error=<nil>) %!s(func(context.Context, *pgx.Conn) error=<nil>) %!s(func(context.Context, *pgx.Conn) bool=<nil>) %!s(func(*pgx.Conn) bool=<nil>) %!s(int32=0) %!s(time.Duration=3600000000000) %!s(time.Duration=1800000000000) %!s(time.Duration=60000000000) {%!s(uint32=0) {%!s(int32=0) %!s(uint32=0)}} %!s(chan struct {}=0xc000024060)}
app_1  | 2021/12/21 18:56:06 successfully connected to postgres

【讨论】:

  • 太好了,非常感谢!
  • 没问题,很有趣:)
猜你喜欢
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2015-08-30
  • 2016-10-05
  • 2011-06-26
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
相关资源
最近更新 更多