如何使用Go語言和Redis開發個人化推播服務.

package main

import (
    "fmt"
    "log"
    "time"

    "github.com/go-redis/redis/v8"
)

func main() {
    // 创建Redis客户端
    client := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379", // Redis的地址和端口号
        Password: "",               // Redis的认证密码
        DB:       0,                // 连接的数据库
    })

    // 测试与Redis的连接
    pong, err := client.Ping(client.Context()).Result()
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("Redis连接成功:", pong)

    // 存储用户的兴趣标签
    err = client.SAdd(client.Context(), "user:1:tags", "电影", "音乐", "美食").Err()
    if err != nil {
        log.Fatal(err)
    }

    // 获取用户的兴趣标签
    tags, err := client.SMembers(client.Context(), "user:1:tags").Result()
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("用户1的兴趣标签:", tags)

    // 存储内容和标签的对应关系
    err = client.SAdd(client.Context(), "tag:电影", "content:1", "content:2").Err()
    if err != nil {
        log.Fatal(err)
    }

    // 获取与用户兴趣标签相关的内容
    contentKeys, err := client.SUnion(client.Context(), tags...).Result()
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("与用户1的兴趣相关的内容:", contentKeys)

    // 获取内容详情
    for _, key := range contentKeys {
        content, err := client.Get(client.Context(), key).Result()
        if err == redis.Nil {
            fmt.Println("内容不存在:", key)
        } else if err != nil {
            log.Fatal(err)
        } else {
            fmt.Println("内容详情:", key, content)
        }
    }

    // 关闭Redis连接
    err = client.Close()
    if err != nil {
        log.Fatal(err)
    }
}