SpringBoot整合RedisStack实战教程

本文详细讲解如何利用 Spring Boot 整合 Redis Stack 实现 JSON 搜索功能。Redisson 作为 Redis 客户端，提供了非常便捷的封装，能够快速完成索引创建、数据存储与全文检索。以下将从依赖配置、服务编写到测试验证，完整演示整个实现流程。

1. 引入 Maven 依赖（pom.xml）

首先，需要在 pom.xml 中添加必要的依赖项。本项目使用了 Spring Boot 的 Redis Starter、Redisson 的 Spring Boot Starter、Spring Web 以及 Lombok。其中 Redisson 版本指定为 3.28.0，这是一个经过验证的稳定版本，能够确保与 Redis Stack 的兼容性。

	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 数据的存储与读取，以及基于 Redis Stack 的全文搜索功能。通过 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