1. //下载redis
    2. go get github.com/gomodule/redigo/redis
    3. package main
    5. import (
    6.     "fmt"
    7.     "github.com/gomodule/redigo/redis"
    8.     "reflect"
    9. )
    11. var pool *redis.Pool
    13. func init() {
    14.     pool = &redis.Pool{
    15.         MaxIdle:     16, //最初的连接数量
    16.         MaxActive:   0,
    17.         IdleTimeout: 300, //连接关闭时间
    18.         Dial: func() (redis.Conn, error) {
    19.             return redis.Dial("tcp", "127.0.0.1:6379")
    20.         },
    21.     }
    22. }
    23. //set存储参数
    24. func set(key, value interface{}) {
    25.     //获取连接
    26.     c := pool.Get()
    27.     _, err := c.Do("set", key, value)
    28.     if err != nil {
    29.         fmt.Println(err)
    30.         return
    31.     }
    32.     fmt.Println("set success")
    33.     defer c.Close() //关闭连接
    34. }
    36. //Get获取参数
    37. func get(key string) (value interface{}) {
    38.     c := pool.Get()
    39.     value, err := redis.String(c.Do("Get", key))
    40.     fmt.Println(reflect.TypeOf(value))
    41.     if err != nil {
    42.         fmt.Println(err)
    43.         return 0
    44.     }
    45.     fmt.Println()
    46.     defer c.Close()
    47.     return
    48. }
    49. func setEx(key string, value interface{}, ex int64) {
    50.     conn := pool.Get()
    51.     _, err := conn.Do("SET", key, value, "EX", ex)
    52.     if err != nil {
    53.         fmt.Println(err)
    54.         return
    55.     }
    57. }
    58. func main() {
    59.     set("name", "张三")
    60.     get("name")
    61.     //单位为秒
    62.     setEx("userId", 1, 10)
    63. }