如何使用redis-om-spring的EntityStream API实现全字段搜索？

Redis OM Spring的EntityStream没有提供一键式的全字段搜索API，但可以通过以下两种方式实现你需要的跨所有@Searchable字段搜索的效果：

方法一：手动构建多字段OR谓词 #

针对所有标记了@Searchable的字段，构建对应的匹配谓词，再用OrPredicate组合起来，实现跨字段的OR搜索：

// 针对Product的所有@Searchable字段构建OR谓词
Predicate<Product> fullTextPredicate = new OrPredicate<>(
    new ContainsPredicate<>(Product$.FIELD1.getField(), "searchTerm"),
    new ContainsPredicate<>(Product$.FIELD2.getField(), "searchTerm"),
    new ContainsPredicate<>(Product$.FIELDN.getField(), "searchTerm")
);

// 执行搜索
List<Product> results = entityStream.of(Product.class)
    .filter(fullTextPredicate)
    .collect(Collectors.toList());

如果字段数量较多，可以通过反射动态获取所有带@Searchable注解的字段，自动生成谓词，避免硬编码：

// 反射获取Product类中所有@Searchable字段
Field[] fields = Product.class.getDeclaredFields();
List<Predicate<Product>> fieldPredicates = new ArrayList<>();

for (Field field : fields) {
    if (field.isAnnotationPresent(Searchable.class)) {
        String fieldName = field.getName();
        // 构建对应字段的ContainsPredicate
        Predicate<Product> predicate = new ContainsPredicate<>(fieldName, "searchTerm");
        fieldPredicates.add(predicate);
    }
}

// 组合所有谓词为OR条件
Predicate<Product> fullTextPredicate = fieldPredicates.stream()
    .reduce((p1, p2) -> new OrPredicate<>(p1, p2))
    .orElseThrow(() -> new IllegalArgumentException("No @Searchable fields found"));

// 执行搜索
List<Product> results = entityStream.of(Product.class)
    .filter(fullTextPredicate)
    .collect(Collectors.toList());

方法二：执行原生Redis搜索命令 #

直接借助RedisTemplate执行FT.SEARCH原生命令，然后将结果映射回实体类，完全模拟你想要的FT.SEARCH my-idx "thesearchTerm"效果：

@Autowired
private RedisTemplate<String, Object> redisTemplate;

public List<Product> fullTextSearch(String searchTerm) {
    // 实体对应的索引名：Redis OM默认是类名小写+"-idx"，如果自定义了@RedisHash(indexName = "...")则用自定义名称
    String indexName = "product-idx";

    // 执行原生FT.SEARCH命令
    List<Object> rawResults = redisTemplate.execute((RedisCallback<List<Object>>) connection -> {
        return connection.execute("FT.SEARCH", indexName, searchTerm);
    });

    // 解析结果并映射为Product实体
    List<Product> products = new ArrayList<>();
    if (rawResults.size() > 1) {
        // 跳过第一个元素（匹配总数），后续按[Key, 文档Map]的结构循环
        for (int i = 1; i < rawResults.size(); i += 2) {
            Map<String, Object> docMap = (Map<String, Object>) rawResults.get(i + 1);
            Product product = new Product(
                (String) docMap.get("uniqueId"),
                (String) docMap.get("field1"),
                (String) docMap.get("field2"),
                (String) docMap.get("fieldN")
            );
            products.add(product);
        }
    }
    return products;
}

补充说明 #

如果不需要刻意使用EntityStream，你原本用Repository的search方法就完全满足需求——它底层就是生成跨所有@Searchable字段的FT.SEARCH命令，和你期望的效果一致。

内容的提问来源于stack exchange，提问作者rjdkolb