*************************************Redis工具*********************************
/**
* Redis工具類
*/
@Component
public class RedisUtils {
@Autowired
private RedisTemplate redisTemplate;
@Resource(name = "redisTemplate")
private ValueOperations<String, String> valueOperations;
@Resource(name = "redisTemplate")
private HashOperations<String, String, Object> hashOperations;
@Resource(name = "redisTemplate")
private ListOperations<String, Object> listOperations;
@Resource(name = "redisTemplate")
private SetOperations<String, Object> setOperations;
@Resource(name = "redisTemplate")
private ZSetOperations<String, Object> zSetOperations;
/** 默認過時時長,單位:秒 */
public final static long DEFAULT_EXPIRE = 60 * 60 * 24;
/** 不設置過時時長 */
public final static long NOT_EXPIRE = -1;
public void set(String key, Object value, long expire) {
valueOperations.set(key, toJson(value));
if (expire != NOT_EXPIRE) {
redisTemplate.expire(key, expire, TimeUnit.SECONDS);
}
}
public void set(String key, Object value) {
set(key, value, DEFAULT_EXPIRE);
}
public <T> T get(String key, Class<T> clazz, long expire) {
String value = valueOperations.get(key);
if (expire != NOT_EXPIRE) {
redisTemplate.expire(key, expire, TimeUnit.SECONDS);
}
return value == null ? null : fromJson(value, clazz);
}
public <T> T get(String key, Class<T> clazz) {
return get(key, clazz, NOT_EXPIRE);
}
public String get(String key, long expire) {
String value = valueOperations.get(key);
if (expire != NOT_EXPIRE) {
redisTemplate.expire(key, expire, TimeUnit.SECONDS);
}
return value;
}
public String get(String key) {
return get(key, NOT_EXPIRE);
}
public void delete(String key) {
redisTemplate.delete(key);
}
/**
* Object轉成JSON數據
*/
private String toJson(Object object) {
if (object instanceof Integer || object instanceof Long || object instanceof Float || object instanceof Double || object instanceof Boolean || object instanceof String) {
return String.valueOf(object);
}
return JSON.toJSONString(object);
}
/**
* JSON數據,轉成Object
*/
private <T> T fromJson(String json, Class<T> clazz) {
return JSON.parseObject(json, clazz);
}
}
**************************************實例部分************************************************
@RunWith(SpringRunner.class)@SpringBootTestpublic class RedisTest { @Autowired private RedisUtils redisUtils; @Test public void contextLoads() { //生成一個對象 SysUserEntity user = new SysUserEntity(); user.setEmail("123456@qq.com"); redisUtils.set("user", user);//把對象存到redis中 redisUtils.set("zhangsan","123");//將一個字符串存到redis中 //獲得redis中的對象 System.out.println(ToStringBuilder.reflectionToString(redisUtils.get("user", SysUserEntity.class))); Date s= redisUtils.get("user",SysUserEntity.class).getCreateTime();//獲取對象屬性 System.out.println("s:"+s); Map paramap=new HashMap();//存map集合 paramap.put("userName","lc"); paramap.put("password","1234"); redisUtils.set("map",paramap); Map pp=redisUtils.get("map",Map.class);//獲取map集合 System.out.println("password"+pp.get("password"));//獲取map集合中存入的數據 System.out.println(redisUtils.get("map")); System.out.println(redisUtils.get("zhangsan"));//從redis中獲取zhangsan對象 redisUtils.delete("zhangsan");//從redis中刪除一個對象 System.out.println(redisUtils.get("zhangsan")); redisUtils.set("lisi","1234",5);//向redis中設置一個字符串,而且設置過時時間爲5秒中 System.out.println(redisUtils.get("lisi")); try { Thread.sleep(5000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(redisUtils.get("lisi")); }