최대 연결 수와 최대 유휴 연결 수는 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로 설정한 다음 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입니다.
최대 공간 연결 수를 테스트해 보겠습니다.
다음 예에서는 최대 연결 수를 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 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
