goredis-cli --version
redis-cli 5.0.14.1 (git:ec77f72d)

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

package redis

import (
    "MyKindom-Server-v2.0/com/xzm/core/config/yaml"
    "MyKindom-Server-v2.0/com/xzm/core/config/yaml/pojo"
    "context"
    "fmt"
    "github.com/go-redis/redis/v8"
    "time"
)

// RDB
var RDB *redis.Client
var globalConfig = yaml.GlobalConfig

// initRedis 初始化Redis連接
func initRedis(config pojo.RedisConfig) error {
    RDB = redis.NewClient(&redis.Options{
        Addr:     config.Address,//Redis地址：localhost:6379
        Password: config.Password,//密碼：123456
        DB:       config.DbIndex,//索引 ：0
    })

    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    defer cancel()

    // 測試連接
    if err := RDB.Ping(ctx).Err(); err != nil {
        return fmt.Errorf("連接Redis失敗: %v", err)
    }

    return nil
}

func init() {
    initRedis(globalConfig.Redis)
}

package main

import (
    "context"
    "fmt"

    "MyKindom-Server-v2.0/com/xzm/core/dadabase/redis"
)

/**
 * @Author: XuZhiMing
 * @Date: 2024/7/18 17:04
 * @Description: 測試redis發(fā)布訂閱
 */
func main() {

    backgroundCtx := context.Background()
    channelName := "new"
    go subscribeChannel(backgroundCtx, channelName)
    for {
        var message string
        fmt.Print("請輸入消息: ")
        fmt.Scanln(&message)
        err := publishMessage(backgroundCtx, channelName, message)
        if err != nil {
            fmt.Println("發(fā)布消息失敗:", err)
        }
    }
    // 保持程序運(yùn)行，以便訂閱者可以接收到消息
    select {}

}

// 訂閱指定頻道
func subscribeChannel(ctx context.Context, channel string) {
    pubsub := redis.RDB.Subscribe(ctx, channel)
    defer pubsub.Close()

    fmt.Printf("已訂閱頻道 [%s]\n", channel)

    // 監(jiān)聽消息
    ch := pubsub.Channel()
    for msg := range ch {
        fmt.Printf("[收到] 頻道: %s | 內(nèi)容: %s\n", msg.Channel, msg.Payload)
    }
}

// 發(fā)布消息到指定頻道
func publishMessage(ctx context.Context, channel, message string) error {
    err := redis.RDB.Publish(ctx, channel, message).Err()
    if err != nil {
        return err
    }
    fmt.Printf("[發(fā)布] 頻道: %s | 內(nèi)容: %s\n", channel, message)
    return nil
}