golang操作redis

直接上代码吧：
package main
import (
    "fmt"
    "os"
    "os/signal"
    "syscall"
    "time"
    "github.com/garyburd/redigo/redis"
)
var (
    Pool *redis.Pool
)
func init() {
    redisHost := ":6379"
    Pool = newPool(redisHost)
    close()
}
func newPool(server string) *redis.Pool {
    return &redis.Pool{
        MaxIdle:     3,
        IdleTimeout: 240 * time.Second,
        Dial: func() (redis.Conn, error) {
            c, err := redis.Dial("tcp", server)
            c.Do("auth","pUD85cOEvX22")
            if err != nil {
                return nil, err
            }
            return c, err
        },
        TestOnBorrow: func(c redis.Conn, t time.Time) error {
            _, err := c.Do("PING")
            return err
        },
    }
}
func close() {
    c := make(chan os.Signal, 1)
    signal.Notify(c, os.Interrupt)
    signal.Notify(c, syscall.SIGTERM)
    signal.Notify(c, syscall.SIGKILL)
    go func() {
        <-c
        Pool.Close()
        os.Exit(0)
    }()
}
func Get(key string) ([]byte, error) {
    conn := Pool.Get()
    defer conn.Close()
    var data []byte
    data, err := redis.Bytes(conn.Do("GET", key))
    if err != nil {
        return data, fmt.Errorf("error get key %s: %v", key, err)
    }
    return data, err
}
func Set(key string, val string) ([]byte, error) {
    conn := Pool.Get()
    defer conn.Close()
    var data []byte
    data, err := redis.Bytes(conn.Do("SET", key, []byte(val)))
    if err != nil {
        return data, fmt.Errorf("error set key %s: %v", key, err)
    }
    return data, err
}
func main() {
    _, err := Set("test", "this is a test!")
    test, err := Get("test")
    fmt.Println(string(test), err)
}
golang操作redis

微信号：腾讯云折扣返现

技术讨论QQ群： 863102326

作者: catherine

搜索

标签
