在項目開發中redis的使用也比較頻繁，本文介紹了Go語言中go-redis庫的基本使用。

Redis介紹

Redis是一個開源的內存數據庫，Redis提供了多種不同類型的數據結構，很多業務場景下的問題都可以很自然地映射到這些數據結構上。除此之外，通過復制、持久化和客戶端分片等特性，我們可以很方便地將Redis擴展成一個能夠包含數百GB數據、每秒處理上百萬次請求的系統。

Redis支持的數據結構

Redis支持諸如字符串(strings)、哈希(hashes)、列表(lists)、集合(sets)、帶范圍查詢的排序集合(sorted sets)、位圖(bitmaps)、hyperloglogs、帶半徑查詢和流的地理空間索引等數據結構(geospatial indexes)。

Redis應用場景

• 緩存系統，減輕主數據庫(MySQL)的壓力。

• 計數場景，比如微博、抖音中的關注數和粉絲數。

• 熱門排行榜，需要排序的場景特別適合使用ZSET。

• 利用LIST可以實現隊列的功能。

準備Redis環境

這里直接使用Docker啟動一個redis環境，方便學習使用。

docker啟動一個名為redis507的5.0.7版本的redis server示例：

docker run --name redis507 -p 6379:6379 -d redis:5.0.7

注意：此處的版本、容器名和端口號請根據自己需要設置。

啟動一個redis-cli連接上面的redis server：

docker run -it --network host --rm redis:5.0.7 redis-cli

go-redis庫

安裝

區別于另一個比較常用的Go語言redis client庫：redigo，我們這里采用https://github.com/go-redis/redis?連接Redis數據庫并進行操作，因為go-redis支持連接哨兵及集群模式的Redis。

使用以下命令下載并安裝：

go get -u github.com/go-redis/redis

連接

普通連接

package mainimport "github.com/go-redis/redis"// 聲明一個全局的rdb變量var rdb *redis.Client// 初始化連接func initClient() (err error) {  rdb = redis.NewClient(&redis.Options{    Addr:     "localhost:6379",    Password: "", // no password set    DB:       0,  // use default DB  })  _, err = rdb.Ping().Result()  if err != nil {    return err  }  return nil}func main() {  err := initClient()  if err != nil {    panic(err)  }}

V8新版本相關

最新版本的go-redis庫的相關命令都需要傳遞context.Context參數，例如：

package mainimport (  "context"  "fmt"  "github.com/go-redis/redis"  "time"  "github.com/go-redis/redis/v8" // 注意導入的是新版本)var (  rdb *redis.Client)// 初始化連接func initClient() (err error) {  rdb = redis.NewClient(&redis.Options{    Addr:     "localhost:16379",    Password: "",  // no password set    DB:       0,   // use default DB    PoolSize: 100, // 連接池大小  })  ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)  defer cancel()  _, err = rdb.Ping(ctx).Result()  return err}func V8Example() {  ctx := context.Background()  if err := initClient(); err != nil {    return  }  err := rdb.Set(ctx, "key", "value", 0).Err()  if err != nil {    panic(err)  }  val, err := rdb.Get(ctx, "key").Result()  if err != nil {    panic(err)  }  fmt.Println("key", val)  val2, err := rdb.Get(ctx, "key2").Result()  if err == redis.Nil {    fmt.Println("key2 does not exist")  } else if err != nil {    panic(err)  } else {    fmt.Println("key2", val2)  }  // Output: key value  // key2 does not exist}

連接Redis哨兵模式

func initClient()(err error){  rdb := redis.NewFailoverClient(&redis.FailoverOptions{    MasterName:    "master",    SentinelAddrs: []string{"x.x.x.x:26379", "xx.xx.xx.xx:26379", "xxx.xxx.xxx.xxx:26379"},  })  _, err = rdb.Ping().Result()  if err != nil {    return err  }  return nil}

連接Redis集群

func initClient()(err error){  rdb := redis.NewClusterClient(&redis.ClusterOptions{    Addrs: []string{":7000", ":7001", ":7002", ":7003", ":7004", ":7005"},  })  _, err = rdb.Ping().Result()  if err != nil {    return err  }  return nil}

基本使用

set/get示例

func redisExample() {  err := rdb.Set("score", 100, 0).Err()  if err != nil {    fmt.Printf("set score failed, err:%v\n", err)    return  }  val, err := rdb.Get("score").Result()  if err != nil {    fmt.Printf("get score failed, err:%v\n", err)    return  }  fmt.Println("score", val)  val2, err := rdb.Get("name").Result()  if err == redis.Nil {    fmt.Println("name does not exist")  } else if err != nil {    fmt.Printf("get name failed, err:%v\n", err)    return  } else {    fmt.Println("name", val2)  }}

zset示例

func redisExample2() {  zsetKey := "language_rank"  languages := []redis.Z{    redis.Z{Score: 90.0, Member: "Golang"},    redis.Z{Score: 98.0, Member: "Java"},    redis.Z{Score: 95.0, Member: "Python"},    redis.Z{Score: 97.0, Member: "JavaScript"},    redis.Z{Score: 99.0, Member: "C/C++"},  }  // ZADD  num, err := rdb.ZAdd(zsetKey, languages...).Result()  if err != nil {    fmt.Printf("zadd failed, err:%v\n", err)    return  }  fmt.Printf("zadd %d succ.\n", num)  // 把Golang的分數加10  newScore, err := rdb.ZIncrBy(zsetKey, 10.0, "Golang").Result()  if err != nil {    fmt.Printf("zincrby failed, err:%v\n", err)    return  }  fmt.Printf("Golang's score is %f now.\n", newScore)  // 取分數最高的3個  ret, err := rdb.ZRevRangeWithScores(zsetKey, 0, 2).Result()  if err != nil {    fmt.Printf("zrevrange failed, err:%v\n", err)    return  }  for _, z := range ret {    fmt.Println(z.Member, z.Score)  }  // 取95~100分的  op := redis.ZRangeBy{    Min: "95",    Max: "100",  }  ret, err = rdb.ZRangeByScoreWithScores(zsetKey, op).Result()  if err != nil {    fmt.Printf("zrangebyscore failed, err:%v\n", err)    return  }  for _, z := range ret {    fmt.Println(z.Member, z.Score)  }}

輸出結果如下：

$ ./06redis_demo zadd 0 succ.Golang's score is 100.000000 now.Golang 100C/C++ 99Java 98JavaScript 97Java 98C/C++ 99Golang 100

根據前綴獲取Key

vals, err := rdb.Keys(ctx, "prefix*").Result()

執行自定義命令

res, err := rdb.Do(ctx, "set", "key", "value").Result()

按通配符刪除key

當通配符匹配的key的數量不多時，可以使用Keys()得到所有的key在使用Del命令刪除。如果key的數量非常多的時候，我們可以搭配使用Scan命令和Del命令完成刪除。

func exampleTongPeiFu() {  ctx := context.Background()  iter := rdb.Scan(ctx, 0, "prefix*", 0).Iterator()  for iter.Next(ctx) {    err := rdb.Del(ctx, iter.Val()).Err()    if err != nil {      panic(err)    }  }  if err := iter.Err(); err != nil {    panic(err)  }}

Pipeline

Pipeline?主要是一種網絡優化。它本質上意味著客戶端緩沖一堆命令并一次性將它們發送到服務器。這些命令不能保證在事務中執行。這樣做的好處是節省了每個命令的網絡往返時間(RTT)。

Pipeline?基本示例如下：

pipe := rdb.Pipeline()incr := pipe.Incr("pipeline_counter")pipe.Expire("pipeline_counter", time.Hour)_, err := pipe.Exec()fmt.Println(incr.Val(), err)

上面的代碼相當于將以下兩個命令一次發給redis server端執行，與不使用Pipeline相比能減少一次RTT。

INCR pipeline_counterEXPIRE pipeline_counts 3600

也可以使用Pipelined：

var incr *redis.IntCmd_, err := rdb.Pipelined(func(pipe redis.Pipeliner) error {  incr = pipe.Incr("pipelined_counter")  pipe.Expire("pipelined_counter", time.Hour)  return nil})fmt.Println(incr.Val(), err)

在某些場景下，當我們有多條命令要執行時，就可以考慮使用pipeline來優化。

完整示例代碼歸檔地址：

https://github.com/Scoefield/gokeyboardman/tree/main/goredis

以上是關于Go語言操作Redis的介紹，感謝您的閱讀，如有疑問或意見請及時反饋給我們。

---

上一篇文章：

Golang操作數據庫MySql

總結

以上是生活随笔為你收集整理的golang 字符串排序_Golang操作数据库Redis的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。