Go语言如何操作Redis

Redis介绍

Redis（Remote Dictionary Server）是一个开源的，内存中的数据结构存储系统，可用作数据库，缓存和消息队列中间件。它支持多种数据类型，如字符串，哈希，列表，集合，有序集合等，并提供了各种各样的持久性选项。由于所有数据都储存在内存中，Redis的读写速度非常快，适合需要高速读写的场景使用。

Go如何操作

在Go语言中，我们可以使用Go-redis这个库进行Redis的操作。以下是Go如何操作Redis的基本步骤：

首先，要确保你已经安装了Redis和Go。

然后，在你的Go项目中，可以通过go module方式引入Go-redis：

go get github.com/go-redis/redis

以下是声明redis客户端的例子：

1、set和get操作

package main

import (
  "fmt"
  "github.com/go-redis/redis"
  "context"
  "time"
)

var ctx = context.Background()

func ExampleClient() {
  rdb := redis.NewClient(&redis.Options{
    Addr:     "localhost:6379",
    Password: "", // no password set
    DB:       0,  // use default DB
    ReadTimeout: 3, //读超时时间
    WriteTimeout: 10,//写超时时间
    MinRetryBackoff: 10 * time.Second,
  })

  err := rdb.Set( "key", "value",100* time.Second ).Err()
  if err != nil {
    panic(err)
  }

  val, err := rdb.Get( "key").Result()
  if err != nil {
    panic(err)
  }
  fmt.Println("key", val)

  val2, err := rdb.Get( "key2").Result()
  if err == redis.Nil {
    fmt.Println("key2 does not exists")
  } else if err != nil {
    panic(err)
  } else {
    fmt.Println("key2", val2)
  }
}

func main() {
  ExampleClient()
}

redis.NewClient创建了一个新的Redis客户端。我们使用set方法设置了一个key和它的value，然后使用get方法获取它的值。Get的结果可能是redis.Nil，这表明这个键在Redis中不存在。

2、redis操作hash

package main

import (
  "fmt"
  "github.com/go-redis/redis"
  "context"
  "time"
)

func ExampleClient() {
  rdb := redis.NewClient(&redis.Options{
    Addr:     "localhost:6379",
    Password: "", // no password set
    DB:       0,  // use default DB
    ReadTimeout: 10, //读超时时间
    WriteTimeout: 10,//写超时时间
    MinRetryBackoff: 10 * time.Second,
  })

  // Set hash field
  err := rdb.HSet( "myhash", "field1", "value1").Err()
  if err != nil {
    panic(err)
  }

  // Fetch hash field
  val, err := rdb.HGet("myhash", "field1").Result()
  if err != nil {
    panic(err)
  }
  fmt.Println("myhash field1:", val)

  // Delete hash field
  err = rdb.HDel( "myhash", "field1").Err()
  if err != nil {
    panic(err)
  }

  // Fetch all hash fields
  vals, err := rdb.HGetAll( "myhash").Result()
  if err != nil {
    panic(err)
  }
  fmt.Println("myhash:", vals)
}

func main() {
  ExampleClient()
}

3、go操作HyperLogLogs相关命令

  // 添加元素
  err := rdb.PFAdd("mykey", "element1", "element2").Err()
  if err != nil {
    panic(err)
  }

  // 获取基数值
  count, err := rdb.PFCount( "mykey").Result()
  if err != nil {
    panic(err)
  }
  fmt.Println("mykey's count:", count)

在这个示例中，我们首先创建了一个连接到Redis的客户端实例。然后，我们调用PFAdd方法将元素添加到HyperLogLog数据结构中。PFCount方法则用来获取给定HyperLogLog的基数估算值。需要注意的是，HyperLogLog的操作是不可逆的，即不能从HyperLogLog中移除元素。

4、redis操作Geospatial

  // 添加地理位置信息
  location := &redis.GeoLocation{
    Name:                      "Shanghai",
    Longitude:                 121.472644,
    Latitude:                  31.231706,
  }
  err := rdb.GeoAdd( "cityGeo", location).Err()
  if err != nil {
    panic(err)
  }

  // 获取地理位置信息
  val, err := rdb.GeoPos( "cityGeo", "Shanghai").Result()
  if err != nil {
    panic(err)
  }
  for _, pos := range val {
    fmt.Println("Shanghai's longitude and latitude are: "+ strconv.FormatFloat(pos.Longitude, 'f', -1, 64) + ", "+ strconv.FormatFloat(pos.Latitude, 'f', -1, 64))
  }

Redis从3.2.0版本开始支持地理空间位置（GEO）功能。如果您需要使用地理位置相关的功能，请确保您的Redis服务器版本在3.2.0及以上。

最后推荐一下go-redis的github地址：https://github.com/redis/go-redis