如何在 Go 中实现基于 Redis 的布隆过滤器-Golang-PHP中文网

因为 Redis 原生不支持布隆过滤器，需依赖第三方模块 RedisBloom；而 go-redis/v8 官方客户端未封装 BF 命令，且线上环境常未加载该模块，直接调用会报“ERR unknown command bf.add”错误。

为什么不能直接用 `redis.BloomFilter`

go 官方 redis 客户端（github.com/go-redis/redis/v8）本身不提供布隆过滤器封装。redis 原生支持布隆过滤器是通过 redisbloom 模块（即 bf.add、bf.exists 等命令），但它不是 redis 默认内置功能，必须单独加载模块。很多线上环境 redis 实例压根没装 redisbloom，直接调用会报错：err unknown command `bf.add`。

所以第一步永远是确认服务端支持：

登录 Redis CLI 执行 MODULE LIST，看输出里是否有 name:bf
或者用 Go 发送 MODULE LIST 命令并检查响应
若不支持，要么推动运维加模块，要么退回到客户端实现（但会失去去重一致性）

用 `github.com/redis/go-redis/v9` 调用 `BF.ADD` 和 `BF.EXISTS`

假设已确认服务端启用了 RedisBloom，推荐使用当前主流的 redis/go-redis/v9 客户端。它支持直接执行自定义命令，无需额外封装库。

关键点在于：命令参数必须是 []interface{} 类型，且 key 和 value 都要转成字符串（BF.ADD 不接受二进制或结构体）：

ctx := context.Background()
key := "bloom:user:email"
item := "user@example.com"

// 添加
err := rdb.Do(ctx, "BF.ADD", key, item).Err()
if err != nil && !strings.Contains(err.Error(), "key does not exist") {
    // 注意：首次 ADD 时若 key 不存在，RedisBloom 会自动创建，默认 error_rate=0.01, capacity=100
    log.Printf("BF.ADD failed: %v", err)
}

// 查询
exists, err := rdb.Do(ctx, "BF.EXISTS", key, item).Bool()
if err != nil {
    log.Printf("BF.EXISTS failed: %v", err)
}

BF.ADD 返回 1 表示新增，0 表示已存在（注意不是布尔值，是整数）
BF.EXISTS 返回 true 表示“可能已存在”，false 表示“一定不存在”
如果需要自定义容量和误判率，得先用 BF.RESERVE 显式建 key：rdb.Do(ctx, "BF.RESERVE", key, 0.001, 1000000)

如何安全处理 `BF.RESERVE` 的并发重复创建

BF.RESERVE 在 key 已存在时会报错：ERR not enough memory or key already exists。多个服务实例冷启动时可能同时尝试创建，导致部分请求失败。

Redis Skill - 高性能缓存管理

Redis 缓存和数据结构管理技能。通过自然语言操作 Redis，支持 String、Hash、List、Set、ZSet、Stream 等数据结构操作。当用户提到 Redis、缓存、消息队列、会话存储时使用此技能。

下载

不要用 “先查再建” 的方式（竞态明显），而是利用 Redis 命令本身的原子性：

始终先执行 BF.RESERVE，忽略 key already exists 类型错误
只对真正影响业务的错误（如连接失败、OOM）做重试或告警
用 strings.Contains(err.Error(), "key already exists") 判断是否可静默忽略
避免在热路径中频繁调用 BF.RESERVE；建议在应用初始化阶段完成

示例判断逻辑：

err := rdb.Do(ctx, "BF.RESERVE", key, 0.002, 500000).Err()
if err != nil {
    if strings.Contains(err.Error(), "key already exists") {
        // 忽略，正常流程
    } else if errors.Is(err, redis.Nil) || strings.Contains(err.Error(), "OOM") {
        // 记录告警，不可恢复
        log.Warn("BF.RESERVE OOM or unexpected error")
    }
}