Method DelPubList

internal/repository/cache/post.go:326–372

DelPubList 删除已发布帖子列表缓存

(ctx context.Context, key string)

// DelPubList 删除已发布帖子列表缓存
func (c *postCache) DelPubList(ctx context.Context, key string) error {
	if key == "*" {
		pattern := c.listPubPrefix + key
		var cursor uint64
		var keys []string

		for {
			var scanKeys []string
			var err error

			// 每次扫描100个key
			scanKeys, cursor, err = c.client.Scan(ctx, cursor, pattern, 100).Result()
			if err != nil {
				return fmt.Errorf("扫描缓存键失败: %v", err)
			}

			keys = append(keys, scanKeys...)

			// 如果游标为0，表示扫描完成
			if cursor == 0 {
				break
			}
		}

		// 如果有key需要删除,则使用pipeline批量删除
		if len(keys) > 0 {
			var err error
			for i := 0; i < 3; i++ { // 重试3次
				pipe := c.client.Pipeline()
				for _, key := range keys {
					pipe.Del(ctx, key)
				}

				if _, err = pipe.Exec(ctx); err == nil {
					break
				}

				if i == 2 { // 最后一次重试失败
					return fmt.Errorf("批量删除缓存键失败(重试3次): %v", err)
				}
				time.Sleep(time.Millisecond * 50) // 失败后短暂等待再重试
			}
		}
		return nil
	}
	return c.client.Del(ctx, c.pubListKey(key)).Err()
}

// GetPub 获取已发布帖子缓存
func (c *postCache) GetPub(ctx context.Context, key string) (domain.Post, error) {