golang--redis連接池


通過golang對redis操作,還可以通過redis連接池,流程如下:

(1)事先初始化一定數量的連接,投入到連接池;

(2)當go需要操作redis時,直接從連接池取出連接即可;

(3)這樣可以節省臨時獲取redis的時間,從而提高效率;

package main

import (
    "fmt"

    "github.com/garyburd/redigo/redis"
)

var pool *redis.Pool

func init() {
    pool = &redis.Pool{
        MaxIdle:     8,
        MaxActive:   0,
        IdleTimeout: 100,
        Dial: func() (redis.Conn, error) {
            return redis.Dial("tcp", "localhost:6379")
        },
    }
}

func main() {
    conn := pool.Get()
    defer conn.Close()

    _, err1 := conn.Do("HMSet", "user1", "name", "beijing", "address", "beijing")
    if err1 != nil {
        fmt.Println("HMSet err=", err1)
        return
    }
    _, err3 := conn.Do("HMSet", "user2", "name", "wuhan", "address", "wuhan")
    if err3 != nil {
        fmt.Println("HMSet err=", err3)
        return
    }

    //向redis讀取數據,返回的r是個空接口
    r, err2 := redis.Strings(conn.Do("HMGet", "user1", "name", "address"))
    if err2 != nil {
        fmt.Println("HMGet err=", err2)
        return
    }
    for i, v := range r {
        fmt.Printf("r[%d]=%v\n", i, v)
    }
}


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM