Redis中缓存穿透的实现示例

public Product getProductById(Long id) {
    // 1. 先查缓存
    String cacheKey = "product:" + id;
    String productJson = jedis.get(cacheKey);
    
    if (productJson != null) {
        // 缓存命中（包括空值）
        return productJson.isEmpty() ? null : JSON.parseObject(productJson, Product.class);
    }
    
    // 2. 缓存未命中，查数据库
    Product product = productMapper.selectById(id);
    
    if (product != null) {
        // 3. 数据库存在，写入缓存（过期时间加随机值防雪崩）
        jedis.setex(cacheKey, 3600 + new Random().nextInt(100), JSON.toJSONString(product));
    } else {
        // 4. 数据库不存在，缓存空值（短过期时间）
        jedis.setex(cacheKey, 60, ""); // 空字符串代表不存在
    }
    
    return product;
}
// 优点：实现简单，适合突发少量无效请求场景。​
// 缺点：可能缓存大量空值键，浪费内存；若过期时间设置不当，会影响数据实时性。

// 1. 初始化布隆过滤器（单例，服务启动时加载所有有效ID）
@Configuration
public class BloomFilterConfig {
    @Bean
    public BloomFilter<Long> productIdBloomFilter(ProductMapper productMapper) {
        // 加载数据库中所有有效商品ID
        List<Long> allProductIds = productMapper.selectAllIds();
        // 预计数据量100万，误判率0.01
        BloomFilter<Long> filter = BloomFilter.create(Funnels.longFunnel(), 1000000, 0.01);
        allProductIds.forEach(filter::put);
        return filter;
    }
}

// 2. 在查询接口中使用
@Service
public class ProductService {
    @Autowired
    private BloomFilter<Long> productIdBloomFilter;
    
    public Product getProductById(Long id) {
        // 1. 布隆过滤器校验，不存在直接返回
        if (!productIdBloomFilter.mightContain(id)) {
            return null;
        }
        
        // 2. 后续流程同缓存空值方案（查缓存→查数据库→更新缓存）
        // ...省略代码...
    }
}
//优点：拦截效率高，适合海量数据场景，内存占用远低于缓存空值。​
/*缺点：存在一定误判率（可通过参数调整）；需维护过滤器与数据库的一致性（如新增数据时同步更新过滤器）。*/

# Spring Cloud Gateway限流配置示例
spring:
  cloud:
    gateway:
      routes:
        - id: product_route
          uri: lb://product-service
          predicates:
            - Path=/product/**
          filters:
            - name: RequestRateLimiter
              args:
                redis-rate-limiter.replenishRate: 50  # 稳定速率（每秒50个请求）
                redis-rate-limiter.burstCapacity: 100 # 突发容量
                key-resolver: "#{@ipKeyResolver}"     # 按IP限流