golang连接redis

连接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"
)

func main() {
    c, err := redis.Dial("tcp", "localhost:6379")
    defer c.Close()
    if err != nil {
        fmt.Println("conn redis failed,", err)
        return
    }
    r, _ := c.Do("set", "name", "mac") //这里写redis语句
    fmt.Println(r)
    res, _ := redis.String(c.Do("get", "name"))
    fmt.Println(res)
}

package main

import (
    "fmt"
    "github.com/garyburd/redigo/redis"
)

func main() {
    c, err := redis.Dial("tcp", "localhost:6379")
    defer c.Close()
    if err != nil {
        fmt.Println("conn redis failed,", err)
        return
    }
    c.Send("set", "name", "mac")
    c.Send("set", "age", 18)
    c.Send("get", "name")
    c.Send("get", "age")
    c.Flush()
    res, _ := redis.String(c.Receive())
    fmt.Println(res)
    res, _ = redis.String(c.Receive())
    fmt.Println(res)
    res, _ = redis.String(c.Receive())
    fmt.Println(res)
    res, _ = redis.String(c.Receive())
    fmt.Println(res)

}

publish&subscribe

package main

import (
    "fmt"
    "github.com/garyburd/redigo/redis"
    "time"
)

func publish() {
    c2, err := redis.Dial("tcp", "localhost:6379")
    if err != nil {

    }

    for {
        var t string = "现在时间为: "
        t += time.Now().String()

        c2.Do("publish", "bbc", t)
        time.Sleep(time.Second)

    }
}
func main() {

    c, err := redis.Dial("tcp", "localhost:6379")
    defer c.Close()
    if err != nil {
        fmt.Println("conn redis failed,", err)
        return
    }
    psc := redis.PubSubConn{
        Conn: c,
    }
    psc.Subscribe("bbc")
    go publish()
    for {
        switch v := psc.Receive().(type) {
        case redis.Message:
            fmt.Printf("%s: message: %s\n", v.Channel, v.Data)
        case redis.Subscription:
            fmt.Printf("%s: %s %d\n", v.Channel, v.Kind, v.Count)
        case error:
            return
        }
    }
}

scan用法

func main() {

    c, err := redis.Dial("tcp", "localhost:6379")
    defer c.Close()
    if err != nil {
        fmt.Println("conn redis failed,", err)
        return
    }
    c.Do("mset", "name", "mac", "age", 18)
    reply, _ := redis.Values(c.Do("mget", "name", "age"))
    var age int
    var name string
    redis.Scan(reply, &name, &age)
    fmt.Println(name, age)

}

连接池

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() //关闭连接池
}