Golang操作Redis

大家好，欢迎来到IT知识分享网。

一. Redis介绍

        1.1 简介

        Redis是完全开源免费的，遵循BSD协议，是一个高性能的key-value数据库。

        Redis与其它的key-value缓存产品有以下三个特点：

• Redis支持数据持久化，可以见内存中的数据报错在磁盘中，重启的时候可以再次加载进行使用。
• Redis不仅仅支持简单的key-value类型的数据，同时还提供string，list(链表)，set(集合)，hash表等数据结构的存储。
• Redis支持数据备份，即master-slave模式的数据备份。

        1.2 Redis优势

• 性能极高——Redis能读的速度是次/秒，写的速度是81000次/秒，单机可以达到15w qps，通常适合做缓存。
• 丰富的数据类型——Redis支持二进制案例的strings，lists，hashes，sets及ordered sets数据类型操作。
• 原子——Redis的所有操作都是原子的，意思就是要么成功执行，要么失败完全不执行。单个操作是原子的。多操作也支持事务，即原子性，通过MULTI和EXEC指令包起来。
• 丰富的特性——Redis还支持publish/subscribe，通知，key过期等特性。

        Redis与其它的key-value存储有什么不同？

        Redis有着更为复杂的数据结构并且提供对他们的原子操作，这是一个不同于其它数据库的进化路径。Redis的数据类型都是基于基本数据结构的同时对程序员透明，无需进行额外的抽象。

        Redis运行在内存中但是可以持久化到磁盘，所以对不同数据集进行高速读写时需要权衡内存，因为数据量不能大于内存大小。在内存数据库方面的另一个优点是，相比在磁盘上相同的复杂数据结构，在内存中操作起来简单，这样Redis可以做很多内部复杂性很强的事情。同时，在磁盘格式方面他们是紧凑的以追加的方式产生，因为他们不需要进行随机访问。

        1.3 redis的使用

        使用第三方开源的redis库：github.com/garyburd/redigo/redis

        命令行输入：

go get github.com/garyburd/redigo/redis

二. 链接Redis

package main import ( "fmt" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "127.0.0.1:6379") if err != nil { fmt.Println("conn redis fail ", err) return } defer c.Close() fmt.Println("conn redis succ") }

三. String类型的Set，Get操作

package main import ( "fmt" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "127.0.0.1:6379") if err != nil { fmt.Println("conn redis fail ", err) return } defer c.Close() _, err = c.Do("Set", "abc", 100) if err != nil { fmt.Println("set fail", err) return } //将返回结果转为int类型 r, err := redis.Int(c.Do("Get", "abc")) if err != nil { fmt.Println("get fail", err) return } fmt.Println(r) }

         输出结果：

        命令行输出：

 四. String批量操作

 五. 设置过期时间

package main import ( "fmt" "time" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "127.0.0.1:6379") if err != nil { fmt.Println("conn redis fail ", err) return } defer c.Close() _, err = c.Do("set", "k1", 1) if err != nil { fmt.Println("set fail ", err) return } //设置过期时间10秒 _, err = c.Do("expire", "k1", 10) if err != nil { fmt.Println("expire fail", err) return } r, err := redis.Int(c.Do("get", "k1")) if err != nil { fmt.Println("get fail ", err) return } fmt.Printf("k1=%d\n", r) time.Sleep(10 * time.Second) //过10秒已经过期 再获得失败 r, err = redis.Int(c.Do("get", "k1")) if err != nil { fmt.Println("get fail ", err) return } fmt.Printf("k1=%d\n", r) }

        输出：

 六. List队列操作

        七.  Hash表

        八. Redis连接池 

package main import ( "fmt" "github.com/garyburd/redigo/redis" ) var pool *redis.Pool func init() { pool = &redis.Pool{ MaxIdle: 16, //最初的连接数量 //MaxActive: , //最大连接数量 MaxActive: 0, //连接池最大连接数量，不确定可以使用0(0表示自动定义)，按需分配 IdleTimeout: 300, //连接关闭时间300秒，(300秒内不使用自动关闭) Dial: func() (redis.Conn, error) { //要连接的数据库 return redis.Dial("tcp", "127.0.0.1:6379") }, } } func main() { c := pool.Get() //从连接池中取一个连接 _, err := c.Do("set", "k1", "v1") if err != nil { fmt.Println("set fail ", err) return } v, err := redis.String(c.Do("get", "k1")) if err != nil { fmt.Println("get fail ", err) return } fmt.Println(v) pool.Close() //关闭连接池 }