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

我有一个正在启动的 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



LEATH
浏览 189回答 1
1回答

潇湘沐

我也遇到过类似的问题。在我们的案例中,问题是由位于客户端计算机和数据库之间的连接跟踪防火墙引起的。这样的防火墙会跟踪 TCP 级别的连接,并且为了限制资源使用,然后会超时在它们看来长时间不活动的连接。我们在这种情况下观察到的症状与您的非常相似:在客户端,连接似乎挂起,而在服务器端,您可以看到connection reset by peer.防止这种情况的一种方法是确保启用TCP Keepalive,并且 Keepalive 间隔小于导致连接问题的防火墙、路由器等的超时时间。这是由libpq的连接参数控制keepalives,keepalives_idle,keepalives_interval和keepalives_count您可以在连接字符串中设置。有关这些参数的说明,请参阅手册。keepalive确定是否启用keepalive 功能。它默认为1(启用),因此您可能不需要指定它。keepalives_idle确定发送保活之前的空闲时间量。如果不指定此项,它将默认为操作系统的默认值。在 Linux 系统中,您可以通过检查来查看默认值/proc/sys/net/ipv4/tcp_keepalive_time- 在我的服务器中,它设置为 7200 秒,这在您的情况下太长了,因为您观察到连接在大约 1 小时后断开。您可以尝试将其设置为 2500 秒。Linux 文档项目提供了一个有用的TCP Keepalive HOWTO文档,其中详细描述了它们的工作原理。请注意,并非所有操作系统都支持 TCP keepalive。如果您无法启用 keepalive,这里有一些您可能需要考虑的其他选项:如果它在您的控制之下,请重新配置正在断开连接的防火墙/路由器,以便它不会对 Postgresql 客户端连接这样做在应用程序级别,您可能能够发送一些流量来保持数据库句柄处于活动状态 - 例如发送一个语句,例如SELECT 1;每小时左右。如果您的编程环境提供连接缓存(根据我收集的评论),那么这可能会很棘手。
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Go