Golang操作Redis

灰太狼 2022-10-16 14:26 206阅读 0赞

### **安装第三方库** ###

go get -u github.com/garyburd/redigo/redis

### **连接操作** ###

package main
    
    import (
    	"fmt"
    	"github.com/garyburd/redigo/redis"
    )
    
    func main() { 
    	redisObj, err := redis.Dial("tcp", "127.0.0.1:6379")
    	if err != nil { 
    		fmt.Println("连接失败", err)
    		return
    	}
    	defer redisObj.Close()
        fmt.Println("连接成功")
    }

### **连接之后，就可以使用连接对象下面的Do( )方法发送命令，并接收值** ###

接受值时，我们get操作接收的的值都是字节类型，因此我们要进行转换，但是该库提供了许多转换类型的函数，比如转换成string类型就是`redis.String( )`，int64就是`redis.Int64( )`等等

package main
    
    import (
    	"fmt"
    	"github.com/garyburd/redigo/redis"
    )
    
    func main() { 
    	redisObj, err := redis.Dial("tcp", "127.0.0.1:6379")
    	if err != nil { 
    		fmt.Println("connect reids failed", err)
    		return
    	}
    	defer redisObj.Close()
    
    	setResult, err := redisObj.Do("set", "name", "zhongxiaohang")
    	if err != nil { 
    		fmt.Println("set操作失败", err)
    	} else { 
    		fmt.Println("set操作结果", setResult)
    	}
    
    	getResult, err := redis.String(redisObj.Do("get", "name"))
    	if err != nil { 
    		fmt.Println("get操作失败", err)
    	} else { 
    		fmt.Println("get操作结果", getResult)
    	}
    }
    /* set操作结果 OK get操作结果 zhongxiaohang */

### **接收多个值** ###

接受多个值时类型转换，string是`redis.Strings( )`，int64就是`redis.Int64s( )`等等，接受结果是对应类型的数组

package main
    
    import (
    	"fmt"
    	"github.com/garyburd/redigo/redis"
    )
    
    func main() { 
    	redisObj, err := redis.Dial("tcp", "127.0.0.1:6379")
    	if err != nil { 
    		fmt.Println("connect reids failed", err)
    		return
    	}
    	defer redisObj.Close()
    
    	setResult, err := redisObj.Do("mset", "name", "zhongxiaohang", "age", "18")
    	if err != nil { 
    		fmt.Println("set操作失败", err)
    	} else { 
    		fmt.Println("set操作结果", setResult)
    	}
    
    	getResult, err := redis.Strings(redisObj.Do("mget", "name", "age"))
    	if err != nil { 
    		fmt.Println("get操作失败", err)
    	} else { 
    		fmt.Println("get操作结果", getResult)
    	}
    }
    /* set操作结果 OK get操作结果 [zhongxiaohang 18] */

### **设置键的过期时间** ###

package main
    
    import (
    	"fmt"
    	"time"
    
    	"github.com/garyburd/redigo/redis"
    )
    
    func main() { 
    	redisObj, err := redis.Dial("tcp", "127.0.0.1:6379")
    	if err != nil { 
    		fmt.Println("connect reids failed", err)
    		return
    	}
    	defer redisObj.Close()
    	_, err = redisObj.Do("set", "name", "zhongxiaohang")
    	if err != nil { 
    		fmt.Println("set操作失败", err)
    	}
    	// 设置key的过期时间
    	_, err = redisObj.Do("expire", "name", "5")
    	if err != nil { 
    		fmt.Println("设置过期时间失败", err)
    	}
    	time.Sleep(time.Second * 6) // 沉睡6秒，等待过期
        
    	getResult, err := redis.String(redisObj.Do("get", "name"))
    	if err != nil { 
    		fmt.Println("get操作失败", err)
    	} else { 
    		fmt.Println("get操作结果", getResult)
    	}
    }
    /* get操作失败 redigo: nil returned */

### **连接池操作** ###

package main
    
    import (
    	"fmt"
    
    	"github.com/garyburd/redigo/redis"
    )
    
    var redis_Pool *redis.Pool // 创建连接池
    
    func init() { 
    	redis_Pool = &redis.Pool{ 
    		MaxIdle:     10,   // 初始连接数量
    		MaxActive:   1000, // 连接池最大连接数量
    		IdleTimeout: 60,   // 60秒内没有操作发生就会关闭连接池
    		Dial: func() (redis.Conn, error) { 
    			return redis.Dial("tcp", "127.0.0.1:6379")
    		},
    	}
    }
    
    func main() { 
    	redisObj := redis_Pool.Get() // 从连接池获取一个连接，连接池连接数量-1
    	defer redis_Pool.Close()     // 关闭连接池
    	defer redisObj.Close()       // 本次连接结束，关闭连接，连接池连接数量+1
    	_, err := redisObj.Do("set", "age", "18")
    	if err != nil { 
    		fmt.Println("set失败", err)
    		return
    	}
    	getResult, err := redis.Int(redisObj.Do("get", "age"))
    	if err != nil { 
    		fmt.Println("get失败", err)
    	} else { 
    		fmt.Println("get结果：", getResult)
    	}
    }
    /* get结果： 18 */