网络宣传网站建设定制,网页版qq可以聊天吗,颜色搭配的网站,企业为什么选择网站建设Go语言入门心法(一): 基础语法
Go语言入门心法(二): 结构体
Go语言入门心法(三): 接口
Go语言入门心法(四): 异常体系 Go语言入门心法(五): 函数
Go语言入门心法(六): HTTP面向客户端|服务端编程
Go语言入门心法(七): 并发与通道
Go语言入门心法(八): mysql驱动安装报错o… Go语言入门心法(一): 基础语法
Go语言入门心法(二): 结构体
Go语言入门心法(三): 接口
Go语言入门心法(四): 异常体系 Go语言入门心法(五): 函数
Go语言入门心法(六): HTTP面向客户端|服务端编程
Go语言入门心法(七): 并发与通道
Go语言入门心法(八): mysql驱动安装报错onnection failed
Go语言入门心法(九): 引入三方依赖
Go语言入门心法(十):Go语言操作MYSQL(CRUD)|事务处理
Go语言入门心法(十一): 文件处理 Go语言入门心法(十二): GORM映射框架
Go语言入门心法(十三): 反射认知升维
Go语言入门心法(十四): Go操作Redis实战
Go语言入门心法(十五):Go微服务实战
Go语言入门心法(十六):Go远程过程调用框架GRPC实战 go操作redis客户端官网推荐: go-redis客户端详细文档 一:安装redis依赖包 下载远程redigo依赖到本地 PS D:\program_file\go_workspace go get github.com/garyburd/redigo/redis go: downloading github.com/garyburd/redigo v1.6.4 go: module github.com/garyburd/redigo is deprecated: Use github.com/gomodule/redigo instead. go: added github.com/garyburd/redigo v1.6.4 项目中引入依赖
import (fmtgithub.com/garyburd/redigo/redistime
) 二: go连接redis并设置相关参数 go操作redis认知升维:(1)go语言操作Redis客户端的包有很多,比如:redigogo-redis等;redigo包的使用方法很简单;(2)通常使用Dial()函数来连接Redis,当任务完成时,应用程序必须调用Close()函数来完成操作;(3)通常使用Conn接口中的Do()方法执行Redis命令。可以使用Go的类型断言或者reply辅助函数将返回的interface{}转换为对应的类型(4)go操作redis常用设置参数基本配置说明MaxIdle最大的空闲连接数表示即使没有redis连接时依然可以保持N个空闲的连接而不被清除随时处于待命状态。MaxActive最大的连接数表示同时最多有N个连接。0表示不限制。IdleTimeout最大的空闲连接等待时间超过此时间后空闲连接将被关闭。如果设置成0空闲连接将不会被关闭。应该设置一个比redis服务端超时时间更短的时间。DialConnectTimeout连接Redis超时时间。DialReadTimeout从Redis读取数据超时时间。DialWriteTimeout向Redis写入数据超时时间。package mainimport (fmtgithub.com/garyburd/redigo/redistime
)/*
go操作redis认知升维:(1)go语言操作Redis客户端的包有很多,比如:redigogo-redis等;redigo包的使用方法很简单;(2)通常使用Dial()函数来连接Redis,当任务完成时,应用程序必须调用Close()函数来完成操作;(3)通常使用Conn接口中的Do()方法执行Redis命令。可以使用Go的类型断言或者reply辅助函数将返回的interface{}转换为对应的类型(4)go操作redis常用设置参数基本配置说明MaxIdle最大的空闲连接数表示即使没有redis连接时依然可以保持N个空闲的连接而不被清除随时处于待命状态。MaxActive最大的连接数表示同时最多有N个连接。0表示不限制。IdleTimeout最大的空闲连接等待时间超过此时间后空闲连接将被关闭。如果设置成0空闲连接将不会被关闭。应该设置一个比redis服务端超时时间更短的时间。DialConnectTimeout连接Redis超时时间。DialReadTimeout从Redis读取数据超时时间。DialWriteTimeout向Redis写入数据超时时间。
*/
func main() {// 1.连接到redisconn, err : redis.Dial(tcp, 192.168.1.111:6379)// 设置操作的数据库redis.DialDatabase(0)redis.DialConnectTimeout(time.Duration(1000) * time.Millisecond)redis.DialWriteTimeout(time.Duration(1000) * time.Millisecond)if err ! nil {fmt.Println(connection redis server : , err)return}println()fmt.Println(redis连接成功......)fmt.Println(conn)// 关闭连接defer conn.Close()}运行效果 GOROOTD:\program_file_worker\go1.20 #gosetup GOPATHD:\program_file_worker\go1.20\bin;C:\Users\Administrator\go #gosetup D:\program_file_worker\go1.20\bin\go.exe build -o C:\Users\Administrator\AppData\Local\Temp\GoLand\___go_build_org_jd_data_org_jd_data_redis.exe org.jd.data/org.jd.data/redis #gosetup C:\Users\Administrator\AppData\Local\Temp\GoLand\___go_build_org_jd_data_org_jd_data_redis.exe redis连接成功...... {{0 0} 0 nil 0xc000068048 0 0xc000078060 0 0xc000076080 [0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0] [0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0]} Process finished with the exit code 0 三:go操作redis命令执行读写数据 package mainimport (fmtgithub.com/garyburd/redigo/redis
)
/*go操作redis读写*/
func main() {conn, err : redis.Dial(tcp, 192.168.1.111:6379)if err ! nil {fmt.Println(connection redis error: , err.Error())return}// 延迟执行关闭函数defer conn.Close()_, err conn.Do(SET, bookName, go语言从入门到放弃实战)if err ! nil {fmt.Println(redis set error:, err.Error())}bookName, err : redis.String(conn.Do(GET, bookName))if err ! nil {fmt.Println(redis get error:, err.Error())} else {fmt.Printf(获取bookName%s \n, bookName)}}运行效果 GOROOTD:\program_file_worker\go1.20 #gosetup GOPATHD:\program_file_worker\go1.20\bin;C:\Users\Administrator\go #gosetup D:\program_file_worker\go1.20\bin\go.exe build -o C:\Users\Administrator\AppData\Local\Temp\GoLand\___go_build_org_jd_data_org_jd_data_redis__1_.exe D:\program_file\go_workspace\org.jd.data\redis\OOPRedisToGrammarSetFindData.go #gosetup C:\Users\Administrator\AppData\Local\Temp\GoLand\___go_build_org_jd_data_org_jd_data_redis__1_.exe 获取bookNamego语言从入门到放弃实战 Process finished with the exit code 0 四:go引入连接池支持
一个数据库服务器只拥有有限的连接资源一旦所有的连接资源都在使用那么其它需要连接的资源就只能等待释放连接资源。所以在连接资源有限的情况下提高单位时间的连接的使用效率缩短连接时间就能显著缩短请求时间。
所以就有了连接池的概念在初始化时创建一定数量的连接先把所有连接存起来然后谁需要使用从这里取走干完活立马放回来。 如果请求数超出连接池容量那么就排队等待或者直接丢弃掉。这样就可以省掉每次都创建和关闭连接的资源消耗和时间。
如果不使用连接池那么每次传输数据我们都需要耗费大量的系统资源进行创建连接收发数据关闭连接。很明显重复创建连接 关闭连接这样的消耗是可以节省。 下载远程依赖 PS D:\program_file\go_workspace go get github.com/gomodule/redigo/redis go: downloading github.com/gomodule/redigo v1.8.9 go: added github.com/gomodule/redigo v1.8.9 项目模块中引入依赖: import github.com/gomodule/redigo/redis package main/*redis连接池操作
*/
import (fmtredisPoll github.com/gomodule/redigo/redistime
)type Redis struct {pool *redisPoll.Pool
}var redis *Redisfunc initRedisPool() {redis new(Redis)redis.pool redisPoll.Pool{MaxIdle: 256,MaxActive: 0,IdleTimeout: time.Duration(120),Dial: func() (redisPoll.Conn, error) {return redisPoll.Dial(tcp,192.168.1.111:6379,redisPoll.DialReadTimeout(time.Duration(1000)*time.Millisecond),redisPoll.DialWriteTimeout(time.Duration(1000)*time.Millisecond),redisPoll.DialConnectTimeout(time.Duration(1000)*time.Millisecond),redisPoll.DialDatabase(0),//red.DialPassword(),)},}
}func ExecCommand(cmd string, key interface{}, args ...interface{}) (interface{}, error) {con : redis.pool.Get()if err : con.Err(); err ! nil {return nil, err}defer con.Close()parma : make([]interface{}, 0)parma append(parma, key)if len(args) 0 {for _, v : range args {parma append(parma, v)}}return con.Do(cmd, parma...)
}func main() {initRedisPool()ExecCommand(set, userName, 老杨,欢迎来到Go操作Redis的世界!)fmt.Print(2)result, err : ExecCommand(get, userName)if err ! nil {fmt.Print(err.Error())}str, _ : redisPoll.String(result, err)fmt.Println(str)}运行效果 GOROOTD:\program_file_worker\go1.20 #gosetup GOPATHD:\program_file_worker\go1.20\bin;C:\Users\Administrator\go #gosetup D:\program_file_worker\go1.20\bin\go.exe build -o C:\Users\Administrator\AppData\Local\Temp\GoLand\___go_build_OOPRedisToGrammarPool_go.exe D:\program_file\go_workspace\org.jd.data\redis\OOPRedisToGrammarPool.go #gosetup C:\Users\Administrator\AppData\Local\Temp\GoLand\___go_build_OOPRedisToGrammarPool_go.exe 2老杨,欢迎来到Go操作Redis的世界! Process finished with the exit code 0 更详细的go操作redis查找官方文档
go语言操作redis详细文档
go-redis客户端操作redis详细文档见官网