Golang笔记一

如果Golang脚本中有go-sql-driver/mysqlredigo,使用多goroutine并发时都要启用连接池,否则会报错,记录一下。

脚本并发时redigo的报错:

1
redigo: unexpected response line (possible server error or unsupported concurrent read by application)

由于redigo单线程,不支持并发,需要启用连接池并设置MaxIdleMaxActive参数。

脚本并发时mysql模块的报错:

1
[mysql] 2020/07/06 14:32:46 packets.go:36: read tcp 127.0.0.1:64348->127.0.0.1:3306: read: connection reset by peer

也是使用连接池解决,go-sql-driver/mysql在创建连接后设置两配置即可启用连接池:

1
2
3
4
mysqlUri := "root:passwd@tcp(127.0.0.1:3306)/sqldata"
mysqlConn, _ := sql.Open("mysql", mysqlUri)
mysqlConn.SetMaxOpenConns(100)
mysqlConn.SetMaxIdleConns(10)

自己写了个Redis同步数据到Mysql的脚本,其中使用到的连接池写法如下:
redis连接池例子

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
//config与logs需要自己写个代替
import (
"RedisSync/config"
"RedisSync/logs"
"fmt"
"github.com/gomodule/redigo/redis"
"time"
)

var err error
var redisConn redis.Conn

func GetRedisPool(config config.Config) *redis.Pool {
return &redis.Pool{
MaxIdle: config.Redis.MaxIdle, //最大空闲连接数
MaxActive: config.Redis.Active, //最大连接数
IdleTimeout: time.Duration(config.Redis.IdleTimeout) * time.Second,
Wait: true, //超过连接数后是否等待
Dial: func() (redis.Conn, error) {
redisUri := fmt.Sprintf("%s:%d", config.Redis.Host, config.Redis.Port)
if config.Redis.Auth {
redisConn, err := redis.Dial("tcp", redisUri,
redis.DialPassword(config.Redis.Passwd),)
logs.ErrHandle(err)
return redisConn, nil
} else {
redisConn, err := redis.Dial("tcp", redisUri)
logs.ErrHandle(err)
return redisConn, nil
}
return redisConn, nil
},
}
}

mysql连接池例子

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
import (
"RedisSync/config"
"RedisSync/logs"
"database/sql"
_ "github.com/go-sql-driver/mysql"
)

type MySQL struct {
MysqlPool *sql.DB
}

//调用此方法初始化MySQL连接池
func (m *MySQL) Initial(config config.Config) {
mysqlUri := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?charset=%s",
config.Mysql.UserName,
config.Mysql.Passwd,
config.Mysql.Host,
config.Mysql.Port,
config.Mysql.DB,
config.Mysql.Charset)
mysqlConn, err := sql.Open("mysql", mysqlUri)
logs.ErrHandle(err)

//设置mysql pool参数,设置即代表启用连接池
mysqlConn.SetMaxOpenConns(config.Mysql.MaxOpenConns)
mysqlConn.SetMaxIdleConns(config.Mysql.MaxIdleConns)

m.MysqlPool = mysqlConn
}

- - END - -


腾讯云
0%