@redishash注解的作用
时间: 2023-07-14 18:53:09 浏览: 393
`@redishash` 是一种 Redisson 的注解,用于将 Java 对象映射到 Redis 的 hash 结构中。它可以用来简化 Redis 操作,减少手动序列化和反序列化的代码量。在使用 `@redishash` 注解后,Redisson 会自动将 Java 对象的属性转换为 Redis hash 的键值对,可以通过 Redisson 提供的 API 对该对象进行 CRUD 操作。同时,`@redishash` 还支持对象间的关联关系,可以将多个对象存储到同一个 Redis hash 中。
相关问题
帮我写一个 spring 的redis缓存注解
好的,以下是一个简单的 Spring Redis 缓存注解:
```java
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface RedisCache {
String key() default ""; // 缓存键值
String field() default ""; // 缓存字段,用于 Hash
long expire() default 60; // 缓存过期时间,默认60秒
Class<?> type() default Object.class; // 缓存对象类型,默认为 Object 类型
}
```
注解的作用是将方法的执行结果缓存到 Redis 中,下次执行方法时可以直接从缓存中获取结果,避免重复计算。
使用示例:
```java
@Service
public class MyService {
@Autowired
private RedisTemplate<String, Object> redisTemplate;
@RedisCache(key = "myKey", expire = 300)
public Object getData(String param1, int param2) {
// 从数据库或其他服务获取数据
Object data = getDataFromOtherService(param1, param2);
return data;
}
private Object getDataFromOtherService(String param1, int param2) {
// ...
}
}
```
在上面的例子中,`MyService` 的 `getData` 方法被加上了 `@RedisCache` 注解,表示该方法的执行结果需要缓存到 Redis 中。`key` 参数指定了缓存的键值,这里设置为 `myKey`,`expire` 参数指定了缓存的过期时间,这里设置为 300 秒(即 5 分钟)。当 `getData` 方法第一次被调用时,会先从 Redis 中查询缓存,如果缓存中没有对应的结果,则执行 `getDataFromOtherService` 方法获取数据,并将结果缓存到 Redis 中。下次再调用 `getData` 方法时,会直接从 Redis 中获取缓存结果。
需要注意的是,使用 Redis 缓存需要先配置 RedisTemplate,这里省略了配置代码。另外,该注解只适用于方法返回值为 Object 类型的情况,如果要支持其他类型的返回值,需要修改注解中的 `type` 参数。
springboot整合redis整合@Cacheable、@CachePut、@CacheEvict注解增删改查实例
好的,下面是一个使用Spring Boot整合Redis的`@Cacheable`、`@CachePut`、`@CacheEvict`注解实现增删改查的示例:
1. 添加Redis依赖
在pom.xml中添加以下依赖:
```xml
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-cache</artifactId>
</dependency>
```
2. 配置Redis连接
在application.properties中添加以下配置:
```properties
# Redis连接配置
spring.redis.host=localhost
spring.redis.port=6379
spring.redis.password=
# 开启缓存
spring.cache.type=redis
```
3. 编写Redis配置类
```java
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.cache.interceptor.KeyGenerator;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import java.lang.reflect.Method;
import java.util.Arrays;
@Configuration
@EnableCaching
public class RedisConfig {
@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(redisConnectionFactory);
// key序列化方式
RedisSerializer<String> stringRedisSerializer = new StringRedisSerializer();
redisTemplate.setKeySerializer(stringRedisSerializer); // key
redisTemplate.setHashKeySerializer(stringRedisSerializer); // hash key
// value序列化方式
RedisSerializer<Object> valueRedisSerializer = new GenericJackson2JsonRedisSerializer();
redisTemplate.setValueSerializer(valueRedisSerializer); // value
redisTemplate.setHashValueSerializer(valueRedisSerializer); // hash value
redisTemplate.afterPropertiesSet();
return redisTemplate;
}
@Bean
public CacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {
RedisCacheManager.RedisCacheManagerBuilder builder = RedisCacheManager.RedisCacheManagerBuilder.fromConnectionFactory(redisConnectionFactory);
return builder.build();
}
@Bean
public KeyGenerator wiselyKeyGenerator() {
return (Object target, Method method, Object... params) -> {
StringBuilder sb = new StringBuilder();
sb.append(target.getClass().getName());
sb.append(method.getName());
Arrays.stream(params).forEach(param -> sb.append(param.toString()));
return sb.toString();
};
}
}
```
4. 编写实体类
```java
import java.io.Serializable;
public class User implements Serializable {
private static final long serialVersionUID = 1L;
private Integer id;
private String name;
private Integer age;
public User(Integer id, String name, Integer age) {
this.id = id;
this.name = name;
this.age = age;
}
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Integer getAge() {
return age;
}
public void setAge(Integer age) {
this.age = age;
}
}
```
5. 编写Service
```java
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.CacheEvict;
import org.springframework.cache.annotation.CachePut;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;
@Service
public class UserService {
@Autowired
private UserDao userDao;
@Cacheable(value = "user", keyGenerator = "wiselyKeyGenerator")
public User getUserById(Integer id) {
return userDao.getUserById(id);
}
@CachePut(value = "user", keyGenerator = "wiselyKeyGenerator")
public User updateUser(User user) {
userDao.updateUser(user);
return user;
}
@CacheEvict(value = "user", keyGenerator = "wiselyKeyGenerator")
public void deleteUserById(Integer id) {
userDao.deleteUserById(id);
}
}
```
6. 编写Controller
```java
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@RestController
@RequestMapping("/user")
public class UserController {
@Autowired
private UserService userService;
@GetMapping("/{id}")
public User getUserById(@PathVariable Integer id) {
return userService.getUserById(id);
}
@PutMapping("")
public User updateUser(@RequestBody User user) {
return userService.updateUser(user);
}
@DeleteMapping("/{id}")
public void deleteUserById(@PathVariable Integer id) {
userService.deleteUserById(id);
}
}
```
7. 测试
启动应用后,可以通过以下方式测试:
- 获取用户:GET http://localhost:8080/user/1
- 更新用户:PUT http://localhost:8080/user
请求体:
```json
{
"id": 1,
"name": "Tom",
"age": 20
}
```
- 删除用户:DELETE http://localhost:8080/user/1
以上就是一个使用Spring Boot整合Redis的`@Cacheable`、`@CachePut`、`@CacheEvict`注解实现增删改查的示例。
阅读全文