Go语言操作Redis（一）

怼烎@ 2022-02-02 02:27 260阅读 0赞

**Redis 简介**

redis(REmote DIctionary Server)是一个由Salvatore Sanfilippo写key-value存储系统，它由C语言编写、遵守BSD协议、支持网络、可基于内存亦可持久化的日志型、Key-Value类型的数据库，并提供多种语言的API。和Memcached类似，它支持存储的value类型相对更多，包括string(字符串)、list(链表)、set(集合)、zset(sorted set --有序集合)和hash（哈希类型）。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作，而且这些操作都是原子性的。在此基础上，redis支持各种不同方式的排序。与memcached一样，为了保证效率，数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件，并且在此基础上实现了master-slave(主从)同步，redis在3.0版本推出集群模式。

官方网站：https://redis.io/

**redis使用**

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

命令行输入 ：

go get github.com/garyburd/redigo/redis

**Go语言链接Redis：**

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

Redis连接池：

package main
    import(
        "fmt"
        "github.com/garyburd/redigo/redis"
    )
    
    var pool *redis.Pool  //创建redis连接池
    
    func init(){
        pool = &redis.Pool{     //实例化一个连接池
            MaxIdle:16,    //最初的连接数量
            // MaxActive:1000000,    //最大连接数量
            MaxActive:0,    //连接池最大连接数量,不确定可以用0（0表示自动定义），按需分配
            IdleTimeout:300,    //连接关闭时间 300秒 （300秒不使用自动关闭）    
            Dial: func() (redis.Conn ,error){     //要连接的redis数据库
                return redis.Dial("tcp","localhost:6379")
            },
        }
    }
    
    func main(){
        c := pool.Get() //从连接池，取一个链接
        defer c.Close() //函数运行结束 ，把连接放回连接池
    
            _,err := c.Do("Set","abc",200)
            if err != nil {
                fmt.Println(err)
                return
            }
    
            r,err := redis.Int(c.Do("Get","abc"))
            if err != nil {
                fmt.Println("get abc faild :",err)
                return
            }
            fmt.Println(r)
            pool.Close() //关闭连接池
    }

运行结果：

200