> db.Subscriptions.find() { "_id" : ObjectId("678768d1b3a57bc85615da79"), "nfStatusNotificationUri" : "", "subscriptionId" : "78" } { "_id" : ObjectId("678768d8b3a57bc85615da7a"), "nfStatusNotificationUri" : "", "subscriptionId" : "39" } 这个设计一个re...-Go服务器开发

要将 MongoDB 中的订阅数据结构存储到 Redis，我们可以选择使用 Hash 作为 Redis 数据结构。我们将为每个订阅创建一个哈希表，哈希表的键将是 subscriptionId，而字段则包含其他相关信息。

数据结构设计

我们会在 Redis 中为每个订阅创建一个哈希表，具体如下：

Redis Key: subscription:<subscriptionId>
Hash Fields:
- nfStatusNotificationUri

示例代码实现

下面是 Go 语言中如何实现这个数据结构，并提供存储功能的示例代码。

1. 定义数据结构

package main
import (
	"context"
	"fmt"
	"log"
	"github.com/go-redis/redis/v8"
)
type Subscription struct {
	ID                     string `json:"_id"`
	NfStatusNotificationUri string `json:"nfStatusNotificationUri"`
	SubscriptionId        string `json:"subscriptionId"`
}

2. 实现存储方法

// 将订阅数据保存到Redis
func storeSubscription(ctx context.Context, rdb *redis.Client, subscription Subscription) error {
	key := fmt.Sprintf("subscription:%s", subscription.SubscriptionId)
	// 存入Hash表
	err := rdb.HSet(ctx, key, map[string]interface{}{
		"nfStatusNotificationUri": subscription.NfStatusNotificationUri,
	}).Err()
	return err
}
func main() {
	ctx := context.Background()
	rdb := redis.NewClient(&redis.Options{
        Addr: "localhost:6379",
    })
	defer rdb.Close()
	subscriptions := []Subscription{
	    {ID: "678768d1b3a57bc85615da79", NfStatusNotificationUri: "", SubscriptionId: "78"},
	    {ID: "678768d8b3a57bc85615da7a", NfStatusNotificationUri: "", SubscriptionId: "39"},
    }
	for _, sub := range subscriptions {
        err := storeSubscription(ctx, rdb, sub)
        if err != nil {
            log.Fatalf("Failed to store subscription %s in Redis : %v", sub.SubscriptionId, err)
        }
    }
	fmt.Println("Subscriptions stored successfully!")
}