mysql과 결합된 golang의 최대 연결 수와 최대 유휴 연결 수를 설정하는 방법

최대 연결 수와 최대 유휴 연결 수는 golang 표준 라이브러리의 데이터베이스/sql에 정의되어 있습니다.

MySQL에 연결하기 위해 예제에서 사용된 SQL 드라이버 패키지는 github.com/go-sql-driver/mysql입니다.

최대 연결 수를 설정하는 인터페이스는

func (db *DB) SetMaxOpenConns(n int)

최대 연결 수를 설정합니다. MySQL에 연결하기 위해 열립니다.

n <= 0이면 열린 연결 수에 제한이 없음을 의미합니다.

기본값은 0이며, 이는 연결 수에 제한이 없음을 의미합니다.

연결 수와 관련된 또 다른 매개변수는 최대 유휴 연결 수를 나타내는 MaxIdleConns입니다.

MaxIdleConns가 0보다 크고 MaxOpenConns보다 큰 경우 MaxIdleConns는 MaxOpenConns와 동일하도록 조정됩니다. 초과 연결이 있으면 초과 연결이 닫힙니다.

최대 유휴 연결 수를 설정하는 인터페이스는 다음과 같습니다.

func (db *DB) SetMaxIdleConns(n int)

n<=0이면 유휴 연결 풀이 사용되지 않습니다. 즉, 유휴 연결 풀이 사용되지 않으면 사용되지 않은 연결은 저장되지 않습니다. 그 안에. 따라서 이 방법은 연결을 재사용하지 않으며, SQL 문이 실행될 때마다 새로운 연결을 다시 설정해야 합니다. <=0时，空闲连接池不会被使用，即不使用空闲连接池时，未使用的连接将不会被存入其中。因此，这种方法不会重复利用连接，每次执行SQL语句都需要重新建立新的连接。

기본 최대 유휴 연결 수는 2입니다.
const defaultMaxIdleConns = 2

열린 연결과 유휴 연결 사이의 관계에 대해 다음을 추가합니다.

열린 연결 = 사용 중인 연결(사용 중) + 유휴 연결(유휴)

최대 연결 수와 최대 유휴 연결 수를 테스트하고 확인해 보겠습니다.

1. 최대 연결 수 테스트

먼저 최대 연결 수를 1로 설정한 다음 20개의 고루틴을 열면 각 고루틴은 sql 문을 실행하고 sql을 실행하는 데 사용된 연결의 연결 ID를 인쇄합니다. 연결을 차지하는 시간이 많이 소요되는 SQL 문을 실행할 때 SQL을 실행해야 하는 다른 고루틴의 실행을 관찰하세요.

예제 코드는 다음과 같습니다.

package main

import (
        "database/sql"
        "log"

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

var DB *sql.DB
var dataBase = "root:Aa123456@tcp(127.0.0.1:3306)/?loc=Local&parseTime=true"

func Init() {
        var err error
        DB, err = sql.Open("mysql", dataBase)
        if err != nil {
                log.Fatalln("open db fail:", err)
        }

        DB.SetMaxOpenConns(1)

        err = DB.Ping()
        if err != nil {
                log.Fatalln("ping db fail:", err)
        }
}

func main() {
        Init()
        
        //开启20个goroutine
        for i:=0; i < 20; i++ {
                go one_worker(i)
        }
        
        select {
        }

}

func one_worker(i int) {
        var connection_id int
        err := DB.QueryRow("select CONNECTION_ID()").Scan(&connection_id)
        if err != nil {
                log.Println("query connection id failed:", err)
                return
        }

        log.Println("worker:", i, ", connection id:", connection_id)

        var result int
        err = DB.QueryRow("select sleep(10)").Scan(&result)
        if err != nil {
                log.Println("query sleep connection id faild:", err)
                return
        }

}

output

2019/10/02 18:14:25 작업자: 2 , 연결 ID: 55
2019/10/02 18:14:25 작업자: 17 , 연결 id: 55
2019/10/02 18:14:25 작업자: 11, 연결 ID: 55
2019/10/02 18:14:35 작업자: 3, 연결 ID: 55
2019/10/02 18:14 :45 작업자 : 0 , 연결 ID: 55
2019/10/02 18:14:45 작업자: 4 , 연결 ID: 55
2019/10/02 18:14:45 작업자: 5 , 연결 ID: 55
2019 /10/ 02 18:15:05 작업자: 7 , 연결 ID: 55
2019/10/02 18:15:25 작업자: 15 , 연결 ID: 55
2019/10/02 18:15:25 작업자: 6 , 연결 ID: 55
2019/10/02 18:15:35 작업자: 13 , 연결 ID: 55
2019/10/02 18:15:45 작업자: 19 , 연결 ID: 55
2019/10/02 18 :15: 45 작업자: 10 , 연결 ID: 55
2019/10/02 18:15:45 작업자: 12 , 연결 ID: 55
2019/10/02 18:15:55 작업자: 14 , 연결 ID: 55
2019/10/02 18:16:15 작업자: 8 , 연결 ID: 55
2019/10/02 18:16:35 작업자: 18 , 연결 ID: 55
2019/10/02 18:16:35 작업자 : 1 , 연결 ID: 55
2019/10/02 18:17:05 작업자: 16 , 연결 ID: 55
2019/10/02 18:17:35 작업자: 9 , 연결 ID: 55

Show 사용 processlist를 사용하여 연결 보기

mysql> show processlist;
+----+------+-----------------+------+---------+------+------------+------------------+
| Id | User | Host            | db   | Command | Time | State      | Info             |
+----+------+-----------------+------+---------+------+------------+------------------+
| 20 | root | localhost       | NULL | Query   |    0 | starting   | show processlist |
| 55 | root | localhost:59518 | NULL | Query   |    5 | User sleep | select sleep(10) |
+----+------+-----------------+------+---------+------+------------+------------------+
2 rows in set (0.00 sec)

netstat를 사용하여 연결 보기

netstat -an | grep 3306
tcp4       0      0  127.0.0.1.3306         127.0.0.1.59518        ESTABLISHED
tcp4       0      0  127.0.0.1.59518        127.0.0.1.3306         ESTABLISHED
tcp46      0      0  *.3306                 *.*                    LISTEN

결과에서 볼 수 있듯이 20개의 고루틴이 동일한 연결(연결 ID는 55)을 사용하여 차례로 SQL 문을 실행합니다.

연결이 사용 중이면 다른 고루틴은 차단 상태로 들어갑니다. 연결이 모두 소모될 때까지 다른 고루틴은 연결을 사용할 수 없습니다.

여러 고루틴이 SQL을 실행하더라도 다중 연결은 생성되지 않습니다.

따라서 최대 연결 수 설정이 적용됩니다.

일부 독자들은 설정된 최대 유휴 연결 수를 보지 못했다면 현재 최대 공간 연결 수는 얼마입니까?라고 물을 수 있습니다.

앞서 언급했듯이 기본 최대 유휴 연결 수는 2입니다.

최대 공간 연결 수를 테스트해 보겠습니다.

2. 최대 유휴 연결 수 테스트

다음 예에서는 최대 연결 수를 1로, 최대 유휴 연결 수를 0으로 설정합니다.

그리고 3초마다 SQL 문을 실행합니다.

코드는 다음과 같습니다:

package main

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

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

)

var DB *sql.DB
var dataBase = "root:Aa123456@tcp(127.0.0.1:3306)/?loc=Local&parseTime=true"

func mysqlInit() {
        var err error
        DB, err = sql.Open("mysql", dataBase)
        if err != nil {
                log.Fatalln("open db fail:", err)
        }

        DB.SetMaxOpenConns(1)
        DB.SetMaxIdleConns(0)

        err = DB.Ping()
        if err != nil {
                log.Fatalln("ping db fail:", err)
        }
}

func main() {
        mysqlInit()

        for {
                execSql()
                time.Sleep(3*time.Second)
        }
}


func execSql() {
        var connection_id int
        err := DB.QueryRow("select CONNECTION_ID()").Scan(&connection_id)
        if err != nil {
                log.Println("query connection id failed:", err)
                return
        }

        log.Println("connection id:", connection_id)
}

output:

2019/10/13 23:06:00 연결 ID: 26
2019/10/13 23:06:03 연결 ID: 27
2019/10/ 13 23: 06:06 연결 ID: 28
2019/10/13 23:06:09 연결 ID: 29
2019/10/13 23:06:12 연결 ID: 30
2019/10/13 23:06: 15 연결 ID : 31
2019/10/13 23:06:18 연결 ID: 32
2019/10/13 23:06:21 연결 ID: 33
2019/10/13 23:06:24 연결 ID: 34
2019/10/13 23:06:27 연결 ID: 35
2019/10/13 23:06:30 연결 ID: 36
2019/10/13 23:06:33 연결 ID: 37
2019/10/ 13 23: 06:36 커넥션 id: 38

결과를 보시면 아시겠지만, SQL을 실행하는데 사용된 커넥션 id가 매번 다릅니다.

최대 유휴 연결 수를 0으로 설정합니다. SQL을 실행할 때마다 연결은 유휴 연결 풀에 포함되지 않지만 다음에 SQL이 실행될 때 새 연결이 다시 설정됩니다. .

위 내용은 mysql과 결합된 golang의 최대 연결 수와 최대 유휴 연결 수를 설정하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!