后端开发中的连接池：基本概念，利益和实施

DDD

发布时间：2025-02-06 15:06:01

563人浏览过

来源于dev.to

转载

克里斯汀·图顿吉安（christine tutunjian）的照片

>连接池是一种创建和管理应用程序可以使用的数据库连接池的机制。该概念对于管理与数据库的连接很重要，目的是优化资源使用并改善经常与数据库相互作用的应用程序的性能。

。

>不是每次需要的新连接（在时间和资源方面价格昂贵），而是允许应用程序允许应用程序借用/使用现有连接并在使用它们完成后将其返回池。这就是为什么它被称为连接池。

为什么连接池很重要？

>重要的问题是，为什么连接轮询很重要？为什么不只是建立1个连接以交替使用。让我们讨论1 bot 1为什么连接池很重要。>

更好的性能

>打开与数据库的新连接可能需要时间，因为它经历了多个过程，例如身份验证，网络设置等。使用连接池，应用程序可以避免此过程，因为如果需要时已经可以使用连接。

资源节省

没有池，如果应用程序收到100个请求，则应用程序将创建100个新连接。这可能会负担数据库服务器的负担，该数据库服务器总是忙于执行初始化过程。连接池可以限制同时使用的连接数量，这使数据库服务器负载稳定。

可伸缩性

当应用程序扩展时，连接池帮助应用程序可以很好地管理负载。通过良好的连接池设置，我们可以同时处理大量请求，并确保应用程序保持响应迅速。

负载配置

可以根据需要配置连接池。因此，它可以防止应用程序泛滥到数据库的连接。

如何工作？

>现在我们了解了为什么使用连接池很重要，我们现在将讨论连接轮询的工作原理。

池初始化

>第一次运行应用程序时，它可以与数据库建立一定数量的连接（例如，10个连接）。此数字称为

池大小

。此连接将闲置等待使用。

连接用法

应用程序需要与数据库的连接连接时，它不再创建新连接，而是从池中请求连接。如果池中有连接可用，则将分配给应用程序。如果没有可用的连接，则该应用程序可能必须等到释放连接并在另一个进程使用后返回池。>>>>> image description

还原连接

>应用程序使用连接完成，它将无法关闭连接。相反，连接将返回到池中，以通过下一个请求再次使用。

> image description

连接池中的共同主要参数

>以下是创建连接池时通常使用的一些主要参数。我将尝试详细解释，然后进行类比，这些类比可以帮助我们更好地理解每个上下文。

> image description 游泳池尺寸

我们可以确定

池大小

中提供的连接数量。如果使用了所有连接，则在使用该连接请求时，将排队等待可用连接，否则队列已满，它将失败。

例如，如果我们将最大池大小设置为10，则应用程序只能使用10个活动连接。如果提出第11个请求，则此请求将等待已经使用的池的连接。类比是这样的：

想象一下有一个停车场，如果所有插槽都已满，则想要输入>（连接请求）

必须等到另一辆车出来

>（空闲连接）。

如果我们想容纳更多的汽车，我们必须建造更多的停车位（增加，以便我们可以容纳更多的汽车。但是维护成本增加（>服务器资源）。> 最小连接
>最小池尺寸5，则池将确保始终有5个空闲连接。即使没有主动请求，池仍然可以确保这5个连接开放，以减少请求进来的连接打开时间。 >这对于预测不稳定的负载很有用，例如，突然间，我们的应用程序获得了很多请求，并且可以使用连接，而无需打开新连接。类比是这样的：

空闲连接

闲置连接是未使用的连接数量，但仍在池中打开，也可以称为“空闲连接”。此参数通常由以下方式设置：

最大空闲时间

：关闭之前保持闲置连接的时间。

：允许保留在池中的空闲连接的数量。

例如，如果我们设置

> maxidleconnections = 5，

池将保持最大5个空闲连接。如果有更多空闲连接，它将关闭。如果在一定时间内没有新的请求（例如10分钟），则可以删除这些空闲连接以节省资源。类比是这样的：

在超市，有5个收银员，有3个收银员正在为买家提供服务（主动连接），有2个出纳员在没有买家队列（闲置连接）的情况下待命，只要买家来。 超市有一条规则：“如果收银员在没有客户的情况下待命30分钟，那么他们可以回家。”这30分钟是空闲的时间。
暂停 >我们可以设置应用程序在池失败之前从池中等待连接的最长时间（错误）。这样做是为了防止应用程序忙或饱满的话，应用程序等待了太长时间以无法获得池的可用连接。这对于防止应用程序等待时间太长是有用的，该连接会导致应用程序“冻结”，在此更好地给用户出现错误，以便它可以向用户提供信息，以便再次尝试而不是结果在冻结请求中。

>我们正在排队在餐厅购买（请求），但我们等不及队列（超时限制）。我们决定离开餐厅（返回错误）。>

之前可以持续多长时间，即使连接处于活动状态。通常用于避免旧的连接问题或更新配置，以确保连接保持新鲜和可靠。

最大寿命

20分钟，则使用20分钟的任何连接都将

从池中删除，并将被新的连接取代将创建的连接。

>这很重要，因为有时某些数据库服务器对旧连接的时间限制有时间限制，这可以防止过时连接**问题。类比是这样的：

8小时后，即使前5名军官仍然处于良好状态，也没有问题，而且工作正常运行。但这可以防止官员在检查来访者时疲倦和失去专心（请求）。

执行 >现在我们将尝试使用golang实现连接池。注意以下代码：

package main

import (
    "database/sql"
    "fmt"
    "log"
    "time"

    _ "github.com/go-sql-driver/mysql"
)

func main() {
    dsn := "username:password@tcp(127.0.0.1:3306)/dbname?parsetime=true"

    db, err := sql.open("mysql", dsn)
    if err != nil {
        log.fatalf("failed to open connection to database: %v", err)
    }
    defer db.close()

    db.setmaxopenconns(10)
    db.setmaxidleconns(5)
    db.setconnmaxlifetime(time.minute * 10)
    db.setconnmaxidletime(time.minute * 5)

    err = db.ping()
    if err != nil {
        log.fatalf("failed to ping database: %v", err)
    }
    fmt.println("successfully connected to database!")

    rows, err := db.query("select id, name from users")
    if err != nil {
        log.fatalf("failed to run query: %v", err)
    }
    defer rows.close()

    for rows.next() {
        var id int
        var name string
        if err := rows.scan(&id, &name); err != nil {
            log.fatalf("failed to read query results: %v", err)
        }
        fmt.printf("id: %d, name: %s\n", id, name)
    }

    if err := rows.err(); err != nil {
        log.fatalf("error after iteration: %v", err)
    }
}

我们可以专注于以下代码段：
db.SetMaxOpenConns(10) db.SetMaxIdleConns(5) db.SetConnMaxLifetime(time.Minute * 10) db.SetConnMaxIdleTime(time.Minute * 5)
这是解释：