如何使用Go语言和Redis开发电商后台系统

mkdir ecommerce-backend
cd ecommerce-backend
go mod init

import "GitHub.com/go-redis/redis/v8"

func connectRedis() *redis.Client {
    rdb := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379", // Redis服务器地址
        PassWord: "",               // Redis密码，如果没有设置请留空
        DB:       0,                // Redis数据库索引
    })
    return rdb
}

func getProductFromCache(productID int) *Product {
    rdb := connectRedis()
    defer rdb.Close()

    key := fmt.Sprintf("product:%d", productID)
    val, err := rdb.Get(ctx, key).Result()
    if err == redis.Nil {
        // 从数据库中查询产品数据
        product := getProductFromDB(productID)

        // 将产品数据保存到Redis缓存中
        JSON, _ := json.Marshal(product)
        rdb.Set(ctx, key, json, 30*time.Minute)

        return product
    } else if err != nil {
        log.Println(err)
    } else {
        var product Product
        json.Unmarshal([]byte(val), &product)
        return &product
    }

    return nil
}

func addToCart(userID int, productID int, quantity int) {
    rdb := connectRedis()
    defer rdb.Close()

    carTKEy := fmt.Sprintf("cart:%d", userID)
    productKey := fmt.Sprintf("%d", productID)

    rdb.ZIncrBy(ctx, cartKey, float64(quantity), productKey)
}

func getCartItems(userID int) map[int]int {
    rdb := connectRedis()
    defer rdb.Close()

    cartKey := fmt.Sprintf("cart:%d", userID)
    items, _ := rdb.ZRangeWithScores(ctx, cartKey, 0, -1).Result()

    cartItems := make(map[int]int)
    for _, item := range items {
        productID, _ := strconv.Atoi(item.Member.(string))
        quantity := int(item.Score)
        cartItems[productID] = quantity
    }

    return cartItems
}