Spring Boot整合Redis注解实现增删改查功能(Redis注解使用)

spring.redis.host=localhost
spring.redis.port=6379
spring.redis.password=
spring.redis.database=0

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

@RedisHash("User")
public class User {
    @Id
    private String id;
    private String name;
    private int age;
    // 省略getter/setter
}

public interface UserRepository extends CrudRepository<User, String> {
}

@Autowired
private UserRepository userRepository;
public void addUser(User user) {
    userRepository.save(user);
}

public User getUserById(String id) {
    return userRepository.findById(id).orElse(null);
}
// 自定义查询（需在Repository中声明方法）
@Indexed
public List<User> findByAge(int age);

public void deleteUser(String id) {
    userRepository.deleteById(id);
}

public void updateUser(User user) {
    userRepository.save(user);
}

@Service
public class UserService {
    @Cacheable(value = "users", key = "#id")
    public User getUser(String id) {
        // 模拟数据库查询
        return userRepository.findById(id).orElse(null);
    }
}

@CachePut(value = "users", key = "#user.id")
public User updateUser(User user) {
    return userRepository.save(user);
}

@CacheEvict(value = "users", key = "#id")
public void deleteUser(String id) {
    userRepository.deleteById(id);
}

@SpringBootTest
public class RedisTest {
    @Autowired
    private UserService userService;
    @Test
    public void testCrud() {
        User user = new User();
        user.setId("1");
        user.setName("Alice");
        userService.addUser(user);
        User cachedUser = userService.getUser("1");
        Assertions.assertNotNull(cachedUser);
    }
}