package main

import (
    redis "github.com/go-redis/redis/v7"
    "log"
)

func main() {
    rdb := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379", // 使用默认数据库
        Password: "",               // 没有密码则置空
        DB:       0,                // 使用默认的数据库
    })

    pong, err := rdb.Ping().Result() // 检查是否连接
    if err != nil {
        log.Fatal(err)
    }

    // 连接成功啦
    log.Println(pong)

    // 订阅全部消息
    pubsub := rdb.Subscribe("name")
    // 等待消息返回，原因是上一个方法不是立即返回的，囧
    _, err = pubsub.Receive()
    if err != nil {
        log.Fatal(err)
    }

    // 用管道来接收消息
    ch := pubsub.Channel()

    // 处理消息
    for msg := range ch {
        log.Println(msg.Channel, ":", msg.Payload)
    }

}