package main import ( "database/sql" "log" "net/http" _ "github.com/lib/pq" ) var Db *sql.DB func main() { var err error Db,err = sql.Open("postgres","user=me password=openupitsme host=my.host.not.yours dbname=mydb sslmode=require") if err != nil { log.Fatal("Cannot connect to db: ",err) } http.HandleFunc("/page",myHandler) http.ListenAndServe(":8080",nil) } func myHandler(w http.ResponseWriter,r *http.Request) { log.Println("Handling Request....",r) query := `SELECT pk FROM mytable LIMIT 1` rows,err := Db.Query(query) if err != nil { log.Println(err) } defer rows.Close() for rows.Next() { var pk int64 if err := rows.Scan(&pk); err != nil { log.Println(err) } log.Println(pk) } log.Println("Request Served...") }
编辑#1:
我的postgres日志显示:
2015-07-08 18:10:01 EDT [7710-1] user@here LOG: could not receive data from client: Connection reset by peer 2015-07-08 18:20:01 EDT [7756-1] user@here LOG: could not receive data from client: Connection reset by peer
这样的防火墙跟踪TCP级别连接,并且为了限制资源使用,那么将超时的连接超时,这些连接在长时间内看起来是非活动的.我们在这种情况下观察到的症状与您的非常相似:在客户端,连接似乎挂起,而在服务器端,您可以看到通过对等方重置连接.
防止这种情况的一种方法是确保启用TCP Keepalives,并且keepalive间隔小于导致连接问题的防火墙,路由器等的超时.这由您可以在连接字符串中设置的libpq连接参数keepalives,keepalives_idle,keepalives_interval和keepalives_count控制.有关这些参数的说明,请参见manual.
> keepalive确定是否启用了keepalive功能.它默认为1(启用),因此您可能不需要指定它.
> keepalives_idle确定发送keepalive之前的空闲时间.如果未指定此选项,则默认为操作系统的默认值.
在Linux系统中,您可以通过检查/ proc / sys / net / ipv4 / tcp_keepalive_time来查看默认值 – 在我的服务器中它设置为7200秒,这在您的情况下会太长,因为您的观察是连接被丢弃约1小时后.
您可以尝试将其设置为2500秒.
Linux Documentation Project提供了一个有用的TCP Keepalive HOWTO文档,该文档详细描述了它们的工作原理.
请注意,并非所有操作系统都支持TCP keepalive.如果您无法在此处启用Keepalive,您可以考虑其他一些选项:
>如果它在您的控制之下,请重新配置正在删除连接的防火墙/路由器,以便它不会对Postgresql客户端连接执行此操作>在应用程序级别,您可能能够发送一些将使DB处理器处于活动状态的流量 – 例如发送SELECT 1等语句;每小时左右.如果您的编程环境提供连接缓存(从我收集的评论中),那么这可能会很棘手.