使用 Go 操作 Reids 的發布與訂閱

做法

新增 main.go 檔：

package main

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

func main() {
	// 建立一個 Client 實體
	rdb := redis.NewClient(&redis.Options{
		Addr:     "localhost:6379",
		Password: "", // 密碼
		DB:       0,  // 資料庫
	})

	ctx := context.Background()

	// 建立一個訂閱頻道
	pubsub := rdb.Subscribe(ctx, "my-channel")

	// 等待並確認訂閱頻道被建立
	if _, err := pubsub.Receive(ctx); err != nil {
		panic(err)
	}

	// 發布訊息到訂閱頻道
	if err := rdb.Publish(ctx, "my-channel", "hello").Err(); err != nil {
		panic(err)
	}

	// 一秒後關閉訂閱頻道
	time.AfterFunc(time.Second, func() {
		// 當訂閱頻道被關閉，Go 通道也會被關閉
		_ = pubsub.Close()
	})

	// 使用 Go 通道來接收訊息
	ch := pubsub.Channel()

	// 消化 Go 通道中的訊息
	for msg := range ch {
		fmt.Println(msg.Channel, msg.Payload)
	}
}

資料來源

• go-redis/redis