Redis 8.0 与 Spring Boot 完美融合：JSON、AI 搜索等新特性实战指南

@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
public class Car {
    private String id;
    private String brand;
    private String model;
    private int year;
    private double price;
    private String color;
    private String fuelType;
    private int mileage;
    private List<String> features;
}

@Service
public class CarService {
    private static final String CAR_KEY_PREFIX = "car:";
    private final RedisTemplate<String, String> redisTemplate;
    private final ObjectMapper objectMapper;
    
    public CarService(RedisTemplate<String, String> redisTemplate, ObjectMapper objectMapper) {
        this.redisTemplate = redisTemplate;
        this.objectMapper = objectMapper;
    }
    
    public void saveCar(Car car) throws JsonProcessingException {
        String carJson = objectMapper.writeValueAsString(car);
        redisTemplate.opsForValue().set(CAR_KEY_PREFIX + car.getId(), carJson);
    }
    
    public Car getCar(String id) throws JsonProcessingException {
        String carJson = redisTemplate.opsForValue().get(CAR_KEY_PREFIX + id);
        if (carJson != null) {
            return objectMapper.readValue(carJson, Car.class);
        }
        return null; // 或从主数据库获取
    }
    
    public void updateCarMileage(String carId, int newMileage) throws JsonProcessingException {
        Car car = getCar(carId);
        if (car != null) {
            car.setMileage(newMileage);
            saveCar(car);
        }
    }
    
    public List<Car> searchCarsByBrand(String brand) {
        // 这里可以结合 Redis 查询引擎进行更复杂的搜索
        // 为了演示，这里返回模拟数据，使用 Lombok 的 Builder 模式
        return Arrays.asList(
            Car.builder()
                .id("car1")
                .brand(brand)
                .model("Model S")
                .year(2023)
                .price(89999.99)
                .color("白色")
                .fuelType("电动")
                .mileage(15000)
                .features(Arrays.asList("自动驾驶", "全景天窗", "真皮座椅"))
                .build()
        );
    }
}

@Configuration
public class AiConfiguration {
    @Bean
    public VectorStore vectorStore(EmbeddingClient embeddingClient) {
        RedisVectorStore.RedisVectorStoreConfig config = RedisVectorStore.RedisVectorStoreConfig.builder()
            .withIndexName("my-app-vectors")
            .withPrefix("vector:")
            .build();
        return new RedisVectorStore(config, embeddingClient);
    }
}

@Service
public class SemanticSearchService {
    private final VectorStore vectorStore;
    
    public SemanticSearchService(VectorStore vectorStore) {
        this.vectorStore = vectorStore;
    }
    
    public void addDocument(String content) {
        vectorStore.add(List.of(new Document(content)));
        System.out.println("文档已添加到 Redis 向量存储。");
    }
    
    public List<Document> findSimilarDocuments(String query, int topK) {
        System.out.println("为查询 '" + query + "' 查找 " + topK + " 个相似文档");
        return vectorStore.similaritySearch(query, topK);
    }
}

@Service
public class TaskProcessorService {
    private final StringRedisTemplate redisTemplate;
    private static final String TASK_QUEUE_KEY = "task_queue";
    
    public TaskProcessorService(StringRedisTemplate redisTemplate) {
        this.redisTemplate = redisTemplate;
    }
    
    public void addTask(String taskId, String taskData) {
        redisTemplate.opsForHash().put(TASK_QUEUE_KEY, taskId, taskData);
    }
    
    public String claimTask(String taskId) {
        // 使用 HGETDEL 原子地获取和删除任务
        byte[] taskDataBytes = redisTemplate.execute(new RedisCallback<byte[]>() {
            @Override
            public byte[] doInRedis(RedisConnection connection) throws DataAccessException {
                return connection.hashCommands().hGetDel(
                    TASK_QUEUE_KEY.getBytes(), 
                    taskId.getBytes()
                );
            }
        });
        return (taskDataBytes != null) ? new String(taskDataBytes) : null;
    }
}