【发布时间】: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=<nil>)
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"