1. String类型

基础命令

• SET key value：设置键值。
• GET key：获取键值。
• DEL key：删除键。
• INCR key：数值自增。
• DECR key：数值自减。

应用场景

• 缓存功能：缓存数据库查询结果或网页内容。
• 计数器：统计访问量或商品库存。
• 分布式锁：在分布式系统中实现互斥访问。
• 限流：限制API的调用频率。
• 共享session：在多服务器环境中共享用户会话。

代码示例

// 缓存商品信息
func cacheProductInfo(productID string, productInfo map[string]interface{}) {
    cacheKey := generateProductCacheKey(productID)
    productJSON, _ := json.Marshal(productInfo)
    rdb.Set(ctx, cacheKey, string(productJSON), 0) // 0表示永不过期
}

// 生成商品缓存键
func generateProductCacheKey(productID string) string {
    return "product:" + productID
}

2. List类型

基础命令

• LPUSH key value：在列表头部插入元素。
• RPUSH key value：在列表尾部插入元素。
• LPOP key：移除列表头部元素。
• RPOP key：移除列表尾部元素。
• LRANGE key start stop：获取列表指定范围内的元素。

应用场景

• 消息队列：实现异步任务处理。
• 排行榜：管理如文章点赞数的排行榜数据。

代码示例

// 将新订单添加到订单处理队列
func addOrderToQueue(order Order) {
    redisClient.LPUSH(ctx, "order_queue", order.ToString())
}

// 从订单处理队列中获取待处理的订单
func getNextOrder() (Order, error) {
    orderJSON, err := redisClient.RPOP(ctx, "order_queue").Result()
    if err != nil {
        return Order{}, err
    }
    var order Order
    json.Unmarshal([]byte(orderJSON), &order)
    return order, nil
}

3. Set类型

基础命令

• SADD key member：向集合添加元素。
• SREM key member：从集合删除元素。
• SISMEMBER key member：检查元素是否在集合中。
• **SINTER key [key ...]**：取多个集合的交集。
• **SUNION key [key ...]**：取多个集合的并集。
• **SDIFF key [key ...]**：取集合的差集。

应用场景

• 标签系统：存储和管理文章或商品的标签。
• 社交网络好友关系：表示用户的好友列表。

代码示例

// 给文章添加标签
func addTagToArticle(articleID string, tag string) {
    redisClient.SADD(ctx, "article:"+articleID+":tags", tag)
}

// 根据标签获取文章列表
func getArticlesByTag(tag string) []string {
    return redisClient.SMEMBERS(ctx, "global:tags:"+tag).Val()
}

4. Sorted Set类型

基础命令

• ZADD key score member：添加元素及其分数。
• **ZRANGE key start stop [WITHSCORES]**：按分数获取元素。
• ZREM key member：删除元素。
• ZINCRBY key increment member：增加元素的分数。
• ZCARD key：获取集合中元素的数量。

应用场景

• 排行榜系统：如游戏得分排行榜。
• 实时数据统计：如商品销量统计。

代码示例

// 更新玩家得分
func updatePlayerScore(playerID string, score float64) {
    sortedSetKey := "playerScores"
    rdb.ZAdd(ctx, sortedSetKey, &redis.Z{Score: score, Member: playerID})
}

// 获取排行榜
func getLeaderboard(start int, stop int) []string {
    sortedSetKey := "playerScores"
    leaderboard, _ := rdb.ZRangeWithScores(ctx, sortedSetKey, start, stop).Result()
    var result []string
    for _, entry := range leaderboard {
        result = append(result, fmt.Sprintf("%s: %.2f", entry.Member.(string), entry.Score))
    }
    return result
}

5. Hash类型

基础命令

• HSET key field value：设置字段的值。
• HGET key field：获取字段的值。
• HDEL key field：删除字段。
• HINCRBY key field increment：增加字段的整数值。
• HGETALL key：获取所有字段和值。

应用场景

• 用户信息存储：存储用户属性，如用户名、年龄等。
• 购物车管理：记录用户选择的商品及其数量。

代码示例

// 存储用户信息到Redis Hash
func storeUserInfo(userID string, userInfo map[string]interface{}) {
    hashKey := "user:" + userID
    for field, value := range userInfo {
        rdb.HSet(ctx, hashKey, field, value)
    }
}

// 从Redis Hash获取用户信息
func getUserInfo(userID string) map[string]string {
    hashKey := "user:" + userID
    fields, err := rdb.HGetAll(ctx, hashKey).Result()
    if err != nil {
        return nil
    }
    var userInfo = make(map[string]string)
    for k, v := range fields {
        userInfo[k] = v
    }
    return userInfo
}

6. Bitmap类型

基础命令

• SETBIT key offset value：设置位的值。
• GETBIT key offset：获取位的值。
• **BITCOUNT key [start end]**：计算位值为1的数量。
• **BITOP operation destkey key [key ...]**：执行位运算。

应用场景

• 状态监控：监控用户在线状态或设备状态。
• 功能开关：控制新功能的访问权限。

代码示例

// 更新玩家在线状态
func updatePlayerStatus(playerID int, isOnline bool) {
    bitmapKey := "playerStatus"
    offset := playerID
    if isOnline {
        rdb.SetBit(ctx, bitmapKey, int64(offset), 1)
    } else {
        rdb.SetBit(ctx, bitmapKey, int64(offset), 0)
    }
}

// 查询玩家在线状态
func checkPlayerStatus(playerID int) bool {
    bitmapKey := "playerStatus"
    offset := playerID
    bitValue, err := rdb.GetBit(ctx, bitmapKey, int64(offset)).Result()
    if err != nil {
        return false
    }
    return bitValue == 1
}

7. HyperLogLog类型

基础命令

• **PFADD key element [element ...]**：添加元素到HyperLogLog。
• **PFCOUNT key [key ...]**：获取HyperLogLog中唯一元素的数量。
• **PFMERGE destkey sourcekey [sourcekey ...]**：合并多个HyperLogLog。

应用场景

• 唯一用户访问统计：统计独立访客数量。
• 事件独立性分析：分析不同事件的用户群体是否重叠。

代码示例

// 记录用户访问
func recordUserVisit(userID string) {
    uniqueSetKey := "uniqueVisitors"
    rdb.PFAdd(ctx, uniqueSetKey, userID)
}

// 获取唯一用户访问量
func getUniqueVisitorCount() int64 {
    uniqueSetKey := "uniqueVisitors"
    count, _ := rdb.PFCount(ctx, uniqueSetKey).Result()
    return count
}

8. GEO类型

基础命令

• GEOADD key longitude latitude member：添加地理位置信息。
• GEOPOS key member [member ...]：获取成员的地理坐标。
• GEODIST key member1 member2 [unit]：计算两个成员之间的距离。
• GEOHASH key member [member ...]：获取成员的Geohash。
• GEORADIUS key longitude latitude radius unit [options]：搜索指定半径内的位置。

应用场景

• 附近地点搜索：查找用户附近的服务或设施。
• 用户定位与导航：记录和匹配司机与乘客的位置。

代码示例

// 搜索附近地点
func searchNearbyPlaces(
longitude float64, latitude float64, radius float64) []string {
    geoSetKey := "touristSpots"
    places, _ := rdb.GeoRadius(
        ctx, geoSetKey, longitude, latitude, radius, "km",
        &redis.GeoRadiusQuery{WithCoord: true, WithDist: true, WithHash: true}).Result()
    var nearbyPlaces []string
    for _, place := range places {
        nearbyPlaces = append(nearbyPlaces, fmt.Sprintf("Name: %s, Distance: %.2f km", place.Member.(string), place.Dist))
    }
    return nearbyPlaces
}

注意事项

• 每种数据类型都有特定的应用场景和优势。
• 选择合适的数据类型可以优化性能和存储效率。
• Bitmap和HyperLogLog类型适合处理大量数据的场景，但需要注意内存和性能的限制。
• GEO类型依赖于准确的经纬度信息，适用于需要地理位置服务的应用。