一. 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能读的速度是110000次/秒,写的速度是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 mainimport ("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 mainimport ("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 mainimport ("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 mainimport ("fmt""github.com/garyburd/redigo/redis"
)var pool *redis.Poolfunc init() {pool = &redis.Pool{MaxIdle: 16, //最初的连接数量//MaxActive: 1000000, //最大连接数量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() //关闭连接池
}