Go에서 Redis 사용: 전체 가이드-Golang-php.cn

Go에서 Redis 사용: 전체 가이드

WBOY

풀어 주다： 2023-06-17 09:41:21

원래의

4765명이 탐색했습니다.

인터넷과 모바일 애플리케이션의 급속한 발전으로 인해 데이터 처리는 현대 애플리케이션에서 없어서는 안 될 부분이 되었습니다. 데이터베이스 캐싱 기술은 점점 더 중요해지고 있으며 Redis는 고성능 인 메모리 애플리케이션으로 점점 인기를 얻고 있습니다. 이 기사에서는 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 서버에 연결:

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 <nil>PONG <nil>

在此示例中，我们建立了一个 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 中有许多高级命令可用于更复杂的操作。下面我们将介绍一些常用的高级命令。

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

이 예에서는 Redis를 연결하고 ping을 해서 연결이 정상인지 확인했습니다.