我有以下代碼用于連接到 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 可用。即使代碼睡眠 if 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")
// http.HandleFunc("/", HomeHandler(*buildDir))
// http.Handle("/search", &SearchHandler{db: pgpool})
// http.Handle("/bases", &BasesHandler{db: pgpool})
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")
}
uj5u.com熱心網友回復：
問題是在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
轉載請註明出處，本文鏈接：https://www.uj5u.com/ruanti/388878.html