前面講介紹了Go 語言的基礎入門及Golang的語法結構。同時也介紹Golang的接口及協程等內容。感興趣的朋友可以先看看之前的文章。這些都是Golang的基礎內容，必須熟練掌握。

接下來我會介紹golang 的實戰，實際開發過程中怎麼用golang寫實際的功能需求，怎麼集成其他框架。

今天跟大家分享的是如何在golang中使用redis數據緩存。

安裝

1. Redis 的安裝很簡單，我這裡測試直接用的是windows 的版本。如何安裝就不細說了。想了解的可以看之前的文章：https://www.cnblogs.com/zhangweizhong/category/771056.html

2. golang 客戶端，用的是 go-redis，

　　1、go get github.com/go-redis

2、接著在代碼中導入此包即可:

<code>  import "github.com/go-redis/redis"/<code>

Redis連接

通過 redis.NewClient 函數即可創建一個 redis 客戶端, 這個方法接收一個 redis.Options 對象參數, 通過這個參數, 我們可以配置 redis 相關的屬性, 例如 redis 服務器地址, 數據庫名, 數據庫密碼等。

<code>// 創建 redis 客戶端
func GetRedisClient() *Client {
    redisdb := NewClient(&Options{
        Addr:     "127.0.0.1:6379",
        Password: "",           // no password set
        DB:       0,                 // use default DB 

    })

    pong, err := redisdb.Ping().Result()
    if err != nil {
        fmt.Println(pong, err)
    }
    return redisdb
}/<code>

通過 cient.Ping() 來檢查是否成功連接到了 redis 服務器

基本使用

Redis支持諸如字符串（strings）、哈希（hashes）、列表（lists）、集合（sets）、帶範圍查詢的排序集合（sorted sets）、位圖（bitmaps）、hyperloglogs、帶半徑查詢和流的地理空間索引等數據結構（geospatial indexes）。其實主要常用的就是：字符串、列表、哈希和集合這四種數據結構。

1、String 操作

　　Set(key, value)：給數據庫中名稱為key的string賦予值valueget(key)：返回數據庫中名稱為key的string的value

　　GetSet(key, value)：給名稱為key的string賦予上一次的value

　　MGet(key1, key2,…, key N)：返回庫中多個string的value

　　SetNX(key, value)：添加string，名稱為key，值為value

　　SetXX(key, time, value)：向庫中添加string，設定過期時間time

　　MSet(key N, value N)：批量設置多個string的值

　　MSetNX(key N, value N)：如果所有名稱為key i的string都不存在

　　Incr(key)：名稱為key的string增1操作

　　Incrby(key, integer)：名稱為key的string增加integer

　　Decr(key)：名稱為key的string減1操作

　　Decrby(key, integer)：名稱為key的string減少integer

　　Append(key, value)：名稱為key的string的值附加valuesubstr(key, start, end)：返回名稱為key的string的value的子串

示例代碼如下：

<code>func StringDemo() {
    fmt.Println("-----------------------welcome to StringDemo-----------------------")
    redisClient:=GetRedisClient()
    if redisClient ==nil{
        fmt.Errorf("StringDemo redisClient is nil")
        return
    }

    name := "張三"
    key :="name:zhangsan"
    redisClient.Set(key , name,1 * time.Second)
    val := redisClient.Get(key)
    if val == nil {
        fmt.Errorf("StringDemo get error")
    }
    fmt.Println("name", val)
}/<code>

2、List 操作

　　RPush(key, value)：在名稱為key的list尾添加一個值為value的元素

　　LPush(key, value)：在名稱為key的list頭添加一個值為value的 元素

　　LLen(key)：返回名稱為key的list的長度

　　LRange(key, start, end)：返回名稱為key的list中start至end之間的元素

　　LTrim(key, start, end)：截取名稱為key的list

　　LIndex(key, index)：返回名稱為key的list中index位置的元素

　　LSet(key, index, value)：給名稱為key的list中index位置的元素賦值

　　LRem(key, count, value)：刪除count個key的list中值為value的元素

　　LPop(key)：返回並刪除名稱為key的list中的首元素

　　RPop(key)：返回並刪除名稱為key的list中的尾元素

　　BLPop(key1, key2,… key N, timeout)：lpop命令的block版本。

　　BRPop(key1, key2,… key N, timeout)：rpop的block版本。

　　RPopLPush(srckey, dstkey)：返回並刪除名稱為srckey的list的尾元素，並將該元素添加到名稱為dstkey的list的頭部

示例代碼如下：

<code>func ListDemo(){
    fmt.Println("-----------------------welcome to ListDemo-----------------------")
    redisClient:=GetRedisClient()
    if redisClient == nil {
        fmt.Errorf("ListDemo redisClient is nil")
        return
    }
    articleKey := "article"
    result,err:=redisClient.RPush(articleKey, "a","b","c").Result() //
    if err!=nil {
        fmt.Println(err)
        return
    }
    fmt.Println("result:",result) 


    result,err = redisClient.LPush(articleKey, "d").Result() //
    if err!=nil {
        fmt.Println(err)
        return
    }
    fmt.Println("result:",result)

    length, err := redisClient.LLen(articleKey).Result()
    if err != nil {
        fmt.Println("ListDemo LLen is nil")
    }
    fmt.Println("length: ", length) // 長度

    mapOut,err1:=redisClient.LRange(articleKey,0,100).Result()
    if err1!=nil {
        fmt.Println(err1)
        return
    }
    for inx, item := range mapOut {
        fmt.Printf("\\n %s:%s", inx, item)
    }
}/<code>

3、Hash 操作

　　HSet(key, field, value)：向名稱為key的hash中添加元素field

　　HGet(key, field)：返回名稱為key的hash中field對應的value

　　HMget(key, (fields))：返回名稱為key的hash中field i對應的value

　　HMset(key, (fields))：向名稱為key的hash中添加元素field

　　HIncrby(key, field, integer)：將名稱為key的hash中field的value增加integer

　　HExists(key, field)：名稱為key的hash中是否存在鍵為field的域

　　HDel(key, field)：刪除名稱為key的hash中鍵為field的域

　　HLen(key)：返回名稱為key的hash中元素個數

　　HKeys(key)：返回名稱為key的hash中所有鍵

　　HVals(key)：返回名稱為key的hash中所有鍵對應的value

　　HGetall(key)：返回名稱為key的hash中所有的鍵（field）及其對應的value

示例代碼如下：

<code>func HashDemo() {
    fmt.Println("-----------------------welcome to HashDemo-----------------------")
    redisClient := GetRedisClient()
    if redisClient == nil {
        fmt.Errorf("HashDemo redisClient is nil")
        return
    }
    article := Article{18, "測試文章內容22222", "測試文章內容22222測試文章內容22222測試文章內容22222", 10, 0}
    articleKey := "article:18"
 
    redisClient.HMSet(articleKey, ToStringDictionary(&article))
    mapOut := redisClient.HGetAll(articleKey).Val()
    for inx, item := range mapOut {
        fmt.Printf("\\n %s:%s", inx, item)
    }
    fmt.Print("\\n")
 
    redisClient.HSet(articleKey, "Content", "測試文章內容")
    mapOut = redisClient.HGetAll(articleKey).Val()
    for inx, item := range mapOut {
        fmt.Printf("\\n %s:%s", inx, item)
    }
    fmt.Print("\\n")
 
    view, err := redisClient.HIncrBy(articleKey, "Views", 1).Result()
    if err != nil {
        fmt.Printf("\\n HIncrBy error=%s ", err)
    } else {
        fmt.Printf("\\n HIncrBy Views=%d ", view)
    }
    fmt.Print("\\n")
  

    mapOut = redisClient.HGetAll(articleKey).Val()
    for inx, item := range mapOut {
        fmt.Printf("\\n %s:%s", inx, item)
    }
    fmt.Print("\\n")
 
}/<code>

連接池

go-redis 已經實現了 redis 的連接池管理, 因此我們不需要自己手動管理 redis 的連接。

默認情況下,連接池大小是10, 可以通過 redis.Options 的 PoolSize 屬性, 我們設置了 redis 連接池的大小為5。

<code>func GetRedisClientPool() *Client{
    redisdb := NewClient(&Options{
        Addr: "127.0.0.1:6379",
        Password: "",
        DB: 0,
        PoolSize: 5,})

    pong, err := redisdb.Ping().Result()
    if err != nil {
        fmt.Println(pong, err)
    }
    return redisdb
}/<code>

連接池測試方法：

<code>// 連接池測試
func connectPoolTest() {
    fmt.Println("-----------------------welcome to connect Pool Test-----------------------")
    client :=GetRedisClientPool()
    wg := sync.WaitGroup{}
    wg.Add(10)

    for i := 0; i < 10; i++ {
        go func() {
            defer wg.Done()

            for j := 0; j < 1000; j++ {
                client.Set(fmt.Sprintf("name%d", j), fmt.Sprintf("xys%d", j), 0).Err() 

                client.Get(fmt.Sprintf("name%d", j)).Result()
            }

            fmt.Printf("PoolStats, TotalConns: %d, IdleConns: %d\\n", client.PoolStats().TotalConns, client.PoolStats().IdleConns);
        }()
    }

    wg.Wait()
}/<code>

最後

以上已經把Redis 的基本的用法講完了，go語言使用Redis 還是非常簡單的，大家可以自己動手寫代碼試試。

獲取完整的源代碼，歡迎關注：章為忠學架構

閱讀更多 章為忠學架構 的文章

關鍵字: pong 數據結構 數據庫