如果不使用,数据库会挂起

Question

我有一个我正在启动的Web应用程序.在启动时工作正常,但如果我离开它(比如说,一小时)并用另一个请求命中它,查询就会挂起.我想在每次查询之后关闭它然后打开一个新的连接,但是文档明确地说"关闭数据库是很少见的,因为数据库句柄意味着很长时间并且在许多goroutine之间共享." 我究竟做错了什么？

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

Answer 1

我也经历过类似的问题。在我们的例子中，问题是由位于客户端计算机和数据库之间的连接跟踪防火墙引起的。

此类防火墙会跟踪 TCP 级别的连接，并且为了限制资源使用，会使在较长时间内不活动的连接超时。我们在这种情况下观察到的症状与您的非常相似：在客户端，连接似乎挂起，而在服务器端您可以看到connection reset by peer.

防止这种情况的一种方法是确保启用TCP Keepalive，并且 keepalive 间隔小于导致连接问题的防火墙、路由器等的超时。这是由 libpq 连接参数keepalives、 、控制的keepalives_idle，您可以在连接字符串中设置这些参数。有关这些参数的说明，请参阅手册。keepalives_intervalkeepalives_count

• keepalive确定keepalive功能是否启用。它默认为1（启用），因此您可能不需要指定它。

• keepalives_idle确定发送 keepalive 之前的空闲时间量。如果您不指定此项，它将默认为操作系统的默认值。

  在 Linux 系统中，您可以通过检查来查看默认值/proc/sys/net/ipv4/tcp_keepalive_time- 在我的服务器中，它设置为 7200 秒，这对于您的情况来说太长了，因为您观察到连接在大约 1 小时后断开。

  您可以尝试将其设置为 2500 秒。

Linux 文档项目提供了有用的TCP Keepalive HOWTO文档，详细描述了它们的工作原理。

请注意，并非所有操作系统都支持 TCP keepalive。如果您无法启用保活，您可能需要考虑以下一些其他选项：

1. 如果它在您的控制范围内，请重新配置正在删除连接的防火墙/路由器，以便它不会对 Postgresql 客户端连接执行此操作

2. 在应用程序级别，您也许能够发送一些流量来保持数据库句柄处于活动状态 - 例如SELECT 1;每小时左右发送一条语句。如果您的编程环境提供连接缓存（从我收集的评论来看），那么这可能会很棘手。