golang学习（二十三）：Go操作Redis

[code]一、通过Golang向redis 写入数据和读取数据

[code]//1、创建链接，链接到redis

[code]package main

import (
"fmt"
"github.com/garyburd/redigo/redis"
)

func main() {

//一、通过Golang向redis 写入数据和读取数据
//1、创建链接，链接到redis
conn, err := redis.Dial("tcp","127.0.0.1:6379")
if err != nil{
fmt.Println("redis.Dial err=", err)
return
}
defer conn.Close()

//2.向redis写入数据 string [key-val]
_, err = conn.Do("Set","test-key","test-value")
if err != nil {
fmt.Println("Set err=", err)
}

//3.向redis读取数据 string [key-val]
//redis.String()类型转换
r, err := redis.String(conn.Do("Get","test-key"))
if err != nil {
fmt.Println("Get err=", err)
return
}

//因为返回的r 是interface{},name对应的值是string，因此需要转换
//nameString := r.(string)

fmt.Println("操作成功", r)
}

运行及测试结果：

[code]//二、逐个操作Hash

[code]//二、逐个操作Hash//通过Golang对Redis操作Hash数据类型
package main

import (
"fmt"
"github.com/garyburd/redigo/redis"
)

func main() {
conn, err := redis.Dial("tcp","127.0.0.1:6379")
if err != nil{
fmt.Println("redis.Dial err=", err)
return
}
//关闭
defer conn.Close()

//2.对Hash操作这里需要把Set改为HSet
_, err = conn.Do("HSet","user01", "name", "tom")
if err != nil {
fmt.Println("HSet err=", err)
}

_, err = conn.Do("HSet","user01", "age", 20)
if err != nil {
fmt.Println("HSet err=", err)
}

//3.向redis读取数据name
//对Hash操作这里需要把Get改为HGet
//redis.String()类型转换
r1, err := redis.String(conn.Do("HGet","user01", "name"))
if err != nil {
fmt.Println("HGet err=", err)
return
}

//向redis读取数据age
r2, err := redis.Int(conn.Do("HGet","user01", "age"))
if err != nil {
fmt.Println("HGet err=", err)
return
}

//因为返回的r 是interface{},name对应的值是string，因此需要转换
//nameString := r.(string)

fmt.Printf("操作成功 r1=%v r2=%v\n", r1, r2)
}

运行及测试结果：

[code]三、批量操作Hash

[code]//三、批量操作Hash
package main

import (
"fmt"
"github.com/garyburd/redigo/redis"
)

func main() {
conn, err := redis.Dial("tcp","127.0.0.1:6379")
if err != nil{
fmt.Println("redis.Dial err=", err)
return
}
//关闭
defer conn.Close()

//2.对Hash操作这里需要把HSet改为HMSet
_, err = conn.Do("HMSet","user02", "name", "tom", "age", 18, "job", "student")
if err != nil {
fmt.Println("HMSet err=", err)
}

//3.向redis读取数据name
//对Hash操作这里需要把HGet改为HMGet
//redis.String()类型转换
//多个值 redis.String 改为 redis.Strings
r, err := redis.Strings(conn.Do("HMGet","user02", "name", "age", "job"))
if err != nil {
fmt.Println("HMGet err=", err)
return
}

//因为返回的r 是interface{},name对应的值是string，因此需要转换
//nameString := r.(string)

//fmt.Printf("操作成功 r1=%v ", r)
//遍历
for i, v := range r {
fmt.Printf("r[%d]=%s\n", i, v)
}
}

运行及测试结果：

[code]四、通过链接池对Redis操作

[code]//四、通过链接池对Redis操作
package main

import (
"fmt"
"github.com/garyburd/redigo/redis"
)

//定义一个全局的pool
var pool *redis.Pool

//当启动程序时，就初始化
func init() {
pool = &redis.Pool{ //最大空闲链接数
MaxIdle:     8, //表示和数据库的最大链接数， 0 表示没有限制
MaxActive:   0, //最大空闲时间
IdleTimeout: 100,
Dial: func() (redis.Conn, error) { //初始化链接的代码，链接哪个ip
return redis.Dial("tcp", "127.0.0.1:6379")
},
}
}

func main() {
//先从pool取出一个链接
conn := pool.Get()
defer conn.Close()

_, err := conn.Do("set", "name", "john")
if err != nil {
fmt.Println("conn.Do err=", err)
return
}

//取出
r, err := redis.String(conn.Do("Get", "name"))
if err != nil {
fmt.Println("conn.Do err=", err)
return
}
fmt.Println("r=", r)

//如果要从 pool 取出链接，一定要保证连接池是关闭的

}

 运行及测试结果：

参考：尚硅谷韩顺平Go语言核心编程

欢迎大家指正补充，感谢阅读。