在Go语言中使用Redis：完整指南

WBOY

发布时间：2023-06-17 09:41:21

5642人浏览过

来源于php中文网

原创

随着互联网和移动应用的快速发展，数据处理已成为现代应用程序中不可或缺的一部分。数据库缓存技术正在变得越来越重要，redis 作为一个高性能的 in-memory 应用程序，越来越受欢迎。在这篇文章中，我们将介绍在 go 语言中使用 redis 的全面教程。

准备工作

在开始使用 Redis 前，我们需要安装和启动 Redis 服务器。这是通过下载 Redis 并运行 Redis 服务器命令来完成的。运行 Redis 并启动服务器后，我们将能够使用 Redis 进行操作。

使用 Go Redis 客户端

在 Go 语言中，有许多 Redis 客户端库可用于连接和与 Redis 服务器通信。这里我们选用最受欢迎的 Go Redis 客户端库之一 - go-redis。

下载和安装 go-redis：

go get github.com/go-redis/redis

基本操作

连接 Redis 服务器：

立即学习“go语言免费学习笔记（深入）”；

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

func main() {
    client := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379", // Redis 服务器地址
        Password: "",               // Redis 密码
        DB:       0,                // Redis 数据库
    })

    pong, err := client.Ping().Result()
    fmt.Println(pong, err)
}

输出：PONG

在此示例中，我们建立了一个 Redis 连接并对其进行了 ping 操作，检查连接是否正常。

在 Redis 中设置和获取键值对：

err := client.Set("key", "value", 0).Err()
if err != nil {
    panic(err)
}

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

输出：key value

在此示例中，我们使用 SET 命令设置 Redis 中的键值对，然后使用 GET 命令检索该键值对。

高级操作

Redis 中有许多高级命令可用于更复杂的操作。下面我们将介绍一些常用的高级命令。

盛世企业网站管理系统1.1.2

免费盛世企业网站管理系统(SnSee)系统完全免费使用，无任何功能模块使用限制，在使用过程中如遇到相关问题可以去官方论坛参与讨论。开源系统Web代码完全开源，在您使用过程中可以根据自已实际情况加以调整或修改，完全可以满足您的需求。强大且灵活独创的多语言功能，可以直接在后台自由设定语言版本，其语言版本不限数量，可根据自已需要进行任意设置；系统各模块可在后台自由设置及开启；强大且适用的后台管理支

下载

4.1 发布/订阅

Redis 提供了发布/订阅模式，可以用于将消息发送到多个客户端。在此示例中，我们将创建两个客户端，一个订阅频道 foo，一个发布消息到频道 foo。

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

func main() {
    client1 := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379",
        Password: "",
        DB:       0,
    })

    client2 := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379",
        Password: "",
        DB:       0,
    })

    pubsub := client2.Subscribe("foo")
    _, err := pubsub.Receive()
    if err != nil {
        panic(err)
    }

    err = client1.Publish("foo", "hello world").Err()
    if err != nil {
        panic(err)
    }

    msg, err := pubsub.ReceiveMessage()
    if err != nil {
        panic(err)
    }

    fmt.Println(msg.Channel, msg.Payload)
}

输出：foo hello world

在此示例中，我们使用 PUBLISH 命令发布消息到频道 foo，并使用 SUBSCRIBE 命令订阅该频道以接收消息。当我们发布消息时，我们将在我们的订阅客户端中收到该消息。

4.2 事务

Redis 提供了事务功能，用于处理需要同时执行多个操作的情况。我们可以使用以下命令创建一个事务，并将多个 Redis 命令添加到事务中。

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

func main() {
    client := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379",
        Password: "",
        DB:       0,
    })

    err := client.Watch(func(tx *redis.Tx) error {
        _, err := tx.Pipelined(func(pipe redis.Pipeliner) error {
            pipe.Set("key1", "hello")
            pipe.Set("key2", "world")
            return nil
        })
        if err != nil {
            return err
        }

        val1, err := tx.Get("key1").Result()
        if err != nil {
            return err
        }
        fmt.Println("key1", val1)

        val2, err := tx.Get("key2").Result()
        if err != nil {
            return err
        }
        fmt.Println("key2", val2)

        return nil
    }, "key1", "key2")

    if err != nil {
        panic(err)
    }
}

输出：key1 hello key2 world

在此示例中，我们使用 WATCH 命令创建一个事务，并将两个 SET 命令添加到该事务中。然后我们尝试读取这两个键来确保 SET 操作已成功。如果 SET 操作失败，整个事务将被取消。