Springboot整合RedisStack的实现示例

最近在折腾 Spring Boot 整合 Redis Stack 做 JSON 搜索，发现 Redisson 的客户端封装得相当顺手。这里把完整的实现步骤拆开来讲，从依赖配置到服务编写再到测试验证，一条线走通。

1. pom 依赖

首先，引入必要的依赖。这里用到了 Spring Boot 的 Redis Starter、Redisson 的 Spring Boot Starter，以及 Web 和 Lombok。注意 Redisson 的版本我们指定了 3.28.0，这是目前比较稳定的一个版本。

	org.springframework.boot
	spring-boot-starter-data-redis


	org.redisson
	redisson-spring-boot-starter
	3.28.0


	org.springframework.boot
	spring-boot-starter-web


	org.projectlombok
	lombok
	true

2. application.properties

配置方面很简单，就指定一下应用名、端口，以及 Redis 的连接地址。本地测试就按默认的 localhost:6379 来写。

spring.application.name=demo-redisstack
server.port: 8088
spring.data.redis.host: localhost
spring.data.redis.port: 6379

3. RedisStackService

核心服务类，负责创建索引、保存 JSON 数据、获取数据以及执行搜索。这里用到了 Redisson 的 RJsonBucket 和搜索 API，代码量不大但功能完整。

package com.example.demoredisstack.service;

import com.example.demoredisstack.entity.User;
import jakarta.annotation.PostConstruct;
import org.redisson.api.RJsonBucket;
import org.redisson.api.RedissonClient;
import org.redisson.api.options.JsonBucketOptions;
import org.redisson.api.search.index.FieldIndex;
import org.redisson.api.search.index.IndexOptions;
import org.redisson.api.search.index.IndexType;
import org.redisson.api.search.query.QueryOptions;
import org.redisson.api.search.query.SearchResult;
import org.redisson.client.codec.StringCodec;
import org.redisson.codec.JacksonCodec;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;


@Service
public class RedisStackService {

	@Autowired
	private RedissonClient redissonClient;

	private static final String INDEX_NAME = "idx:users";
	private static final String KEY_PREFIX = "user:";

	// 项目启动时自动创建索引
	@PostConstruct
	public void initIndex() {
		try {
			redissonClient.getSearch().createIndex(INDEX_NAME,
					IndexOptions.defaults()
							.on(IndexType.JSON)
							.prefix(KEY_PREFIX),
					FieldIndex.text("$.name").as("name"),
					FieldIndex.numeric("$.age").as("age"),
					FieldIndex.tag("$.tags").as("tags")
			);
		} catch (Exception e) {
			System.out.println("索引可能已存在或创建失败: " + e.getMessage());
		}
	}

	// 1. 保存 JSON 数据
	public void sa veUser(User user) {
		JsonBucketOptions