使用RedisTemplate(JDK序列化策略)緩存實體類
一、相關配置
1.spring-redis.xml:
[java] view plain copy
- <?xml version="1.0" encoding="UTF-8"?>
- <beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
- xmlns:context="http://www.springframework.org/schema/context"
- xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:cache="http://www.springframework.org/schema/cache"
- xsi:schemaLocation="http://www.springframework.org/schema/beans
- http://www.springframework.org/schema/beans/spring-beans-4.2.xsd
- http://www.springframework.org/schema/context
- http://www.springframework.org/schema/context/spring-context-4.2.xsd
- http://www.springframework.org/schema/mvc
- http://www.springframework.org/schema/mvc/spring-mvc-4.2.xsd
- http://www.springframework.org/schema/cache
- http://www.springframework.org/schema/cache/spring-cache-4.2.xsd">
- <context:property-placeholder location="classpath:redis.porperties" />
- <!-- 這裡注入RedisUtil工具類,service層註解調用-->
- <context:component-scan base-
package
="com.xian.manager.util" /> - <!-- redis 相關配置 -->
- <bean id="poolConfig"
class
="redis.clients.jedis.JedisPoolConfig">
- <property name="maxIdle" value="${redis.maxIdle}" />
- <property name="maxWaitMillis" value="${redis.maxWait}" />
- <property name="testOnBorrow" value="${redis.testOnBorrow}" />
- </bean>
- <bean id="connectionFactory"
class
="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"> - <property name="poolConfig" ref="poolConfig" />
- <property name="port" value="${redis.port}" />
- <property name="hostName" value="${redis.host}" />
- <property name="password" value="${redis.pass}" />
- <property name="timeout" value="${redis.timeout}" />
- </bean>
- <bean id="redisTemplate"
class
="org.springframework.data.redis.core.RedisTemplate"> - <property name="connectionFactory" ref="connectionFactory" />
- </bean>
- </beans>
使用的是RedisTemplate默認的JDK序列化策略。
2.相關工具類:
1).Redis工具類
[java] view plain copy
package
com.xian.manager.util;import
java.util.List;import
java.util.Map;import
java.util.Set;
import
java.util.concurrent.TimeUnit;import
javax.annotation.Resource;import
org.springframework.data.redis.core.RedisTemplate;import
org.springframework.stereotype.Component;import
org.springframework.util.CollectionUtils;- /**
- *
- * 基於spring和redis的redisTemplate工具類
- * 針對所有的hash 都是以h開頭的方法
- * 針對所有的Set 都是以s開頭的方法 不含通用方法
- * 針對所有的List 都是以l開頭的方法
- */
- @Component
public
class
RedisUtil {- @Resource(name = "redisTemplate")
private
RedisTemplate<String, Object> redisTemplate;- //=============================common============================
- /**
- * 指定緩存失效時間
- * @param key 鍵
- * @param time 時間(秒)
- * @return
- */
public
boolean
expire(String key,
long
time){try
{if
(time>0){- redisTemplate.expire(key, time, TimeUnit.SECONDS);
- }
return
true
;- }
catch
(Exception e) { - e.printStackTrace();
return
false
;- }
- }
- /**
- * 根據key 獲取過期時間
- * @param key 鍵 不能為null
- * @return 時間(秒) 返回0代表為永久有效
- */
public
long
getExpire(String key){
return
redisTemplate.getExpire(key,TimeUnit.SECONDS);- }
- /**
- * 判斷key是否存在
- * @param key 鍵
- * @return true 存在 false不存在
- */
public
boolean
hasKey(String key){try
{return
redisTemplate.hasKey(key);- }
catch
(Exception e) { - e.printStackTrace();
return
false
;- }
- }
- /**
- * 刪除緩存
- * @param key 可以傳一個值 或多個
- */
- @SuppressWarnings("unchecked")
public
void
del(String ... key){
if
(key!=null
&&key.length>0){if
(key.length==1){- redisTemplate.delete(key[0]);
- }
else
{ - redisTemplate.delete(CollectionUtils.arrayToList(key));
- }
- }
- }
- //============================String=============================
- /**
- * 普通緩存獲取
- * @param key 鍵
- * @return 值
- */
public
Object get(String key){return
key==null
?null
:redisTemplate.opsForValue().get(key);- }
- /**
- * 普通緩存放入
- * @param key 鍵
- * @param value 值
- * @return true成功 false失敗
- */
public
boolean
set(String key,Object value) {
try
{- redisTemplate.opsForValue().set(key, value);
return
true
;- }
catch
(Exception e) { - e.printStackTrace();
return
false
;- }
- }
- /**
- * 普通緩存放入並設置時間
- * @param key 鍵
- * @param value 值
- * @param time 時間(秒) time要大於0 如果time小於等於0 將設置無限期
- * @return true成功 false 失敗
- */
public
boolean
set(String key,Object value,long
time){try
{
if
(time>0){- redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
- }
else
{ - set(key, value);
- }
return
true
;- }
catch
(Exception e) { - e.printStackTrace();
return
false
;- }
- }
- /**
- * 遞增
- * @param key 鍵
- * @param by 要增加幾(大於0)
- * @return
- */
public
long
incr(String key,long
delta){
if
(delta<0){throw
new
RuntimeException("遞增因子必須大於0");- }
return
redisTemplate.opsForValue().increment(key, delta);- }
- /**
- * 遞減
- * @param key 鍵
- * @param by 要減少幾(小於0)
- * @return
- */
public
long
decr(String key,long
delta){if
(delta<0){throw
new
RuntimeException("遞減因子必須大於0");
- }
return
redisTemplate.opsForValue().increment(key, -delta);- }
- //================================Map=================================
- /**
- * HashGet
- * @param key 鍵 不能為null
- * @param item 項 不能為null
- * @return 值
- */
public
Object hget(String key,String item){return
redisTemplate.opsForHash().get(key, item);- }
- /**
- * 獲取hashKey對應的所有鍵值
- * @param key 鍵
- * @return 對應的多個鍵值
- */
public
Map<Object,Object> hmget(String key){return
redisTemplate.opsForHash().entries(key);- }
- /**
- * HashSet
- * @param key 鍵
- * @param map 對應多個鍵值
- * @return true 成功 false 失敗
- */
public
boolean
hmset(String key, Map<String,Object> map){try
{- redisTemplate.opsForHash().putAll(key, map);
return
true
;- }
catch
(Exception e) { - e.printStackTrace();
return
false
;- }
- }
- /**
- * HashSet 並設置時間
- * @param key 鍵
- * @param map 對應多個鍵值
- * @param time 時間(秒)
- * @return true成功 false失敗
- */
public
boolean
hmset(String key, Map<String,Object> map,long
time){try
{- redisTemplate.opsForHash().putAll(key, map);
if
(time>0){- expire(key, time);
- }
return
true
;- }
catch
(Exception e) { - e.printStackTrace();
return
false
;- }
- }
- /**
- * 向一張hash表中放入數據,如果不存在將創建
- * @param key 鍵
- * @param item 項
- * @param value 值
- * @return true 成功 false失敗
- */
public
boolean
hset(String key,String item,Object value) {try
{- redisTemplate.opsForHash().put(key, item, value);
return
true
;- }
catch
(Exception e) { - e.printStackTrace();
return
false
;- }
- }
- /**
- * 向一張hash表中放入數據,如果不存在將創建
- * @param key 鍵
- * @param item 項
- * @param value 值
- * @param time 時間(秒) 注意:如果已存在的hash表有時間,這裡將會替換原有的時間
- * @return true 成功 false失敗
- */
public
boolean
hset(String key,String item,Object value,long
time) {try
{- redisTemplate.opsForHash().put(key, item, value);
if
(time>0){- expire(key, time);
- }
return
true
;- }
catch
(Exception e) { - e.printStackTrace();
return
false
;- }
- }
- /**
- * 刪除hash表中的值
- * @param key 鍵 不能為null
- * @param item 項 可以使多個 不能為null
- */
public
void
hdel(String key, Object... item){- redisTemplate.opsForHash().delete(key,item);
- }
- /**
- * 判斷hash表中是否有該項的值
- * @param key 鍵 不能為null
- * @param item 項 不能為null
- * @return true 存在 false不存在
- */
public
boolean
hHasKey(String key, String item){return
redisTemplate.opsForHash().hasKey(key, item);- }
- /**
- * hash遞增 如果不存在,就會創建一個 並把新增後的值返回
- * @param key 鍵
- * @param item 項
- * @param by 要增加幾(大於0)
- * @return
- */
public
double
hincr(String key, String item,double
by){return
redisTemplate.opsForHash().increment(key, item, by);- }
- /**
- * hash遞減
- * @param key 鍵
- * @param item 項
- * @param by 要減少記(小於0)
- * @return
- */
public
double
hdecr(String key, String item,double
by){return
redisTemplate.opsForHash().increment(key, item,-by);- }
- //============================set=============================
- /**
- * 根據key獲取Set中的所有值
- * @param key 鍵
- * @return
- */
public
Set<Object> sGet(String key){try
{return
redisTemplate.opsForSet().members(key);- }
catch
(Exception e) { - e.printStackTrace();
return
null
;- }
- }
- /**
- * 根據value從一個set中查詢,是否存在
- * @param key 鍵
- * @param value 值
- * @return true 存在 false不存在
- */
public
boolean
sHasKey(String key,Object value){try
{return
redisTemplate.opsForSet().isMember(key, value);- }
catch
(Exception e) { - e.printStackTrace();
return
false
;- }
- }
- /**
- * 將數據放入set緩存
- * @param key 鍵
- * @param values 值 可以是多個
- * @return 成功個數
- */
public
long
sSet(String key, Object...values) {try
{return
redisTemplate.opsForSet().add(key, values);- }
catch
(Exception e) { - e.printStackTrace();
return
0;- }
- }
- /**
- * 將set數據放入緩存
- * @param key 鍵
- * @param time 時間(秒)
- * @param values 值 可以是多個
- * @return 成功個數
- */
public
long
sSetAndTime(String key,long
time,Object...values) {try
{- Long count = redisTemplate.opsForSet().add(key, values);
if
(time>0) expire(key, time);return
count;- }
catch
(Exception e) { - e.printStackTrace();
return
0;- }
- }
- /**
- * 獲取set緩存的長度
- * @param key 鍵
- * @return
- */
public
long
sGetSetSize(String key){try
{return
redisTemplate.opsForSet().size(key);- }
catch
(Exception e) { - e.printStackTrace();
return
0;- }
- }
- /**
- * 移除值為value的
- * @param key 鍵
- * @param values 值 可以是多個
- * @return 移除的個數
- */
public
long
setRemove(String key, Object ...values) {try
{- Long count = redisTemplate.opsForSet().remove(key, values);
return
count;- }
catch
(Exception e) { - e.printStackTrace();
return
0;- }
- }
- //===============================list=================================
- /**
- * 獲取list緩存的內容
- * @param key 鍵
- * @param start 開始
- * @param end 結束 0 到 -1代表所有值
- * @return
- */
public
List<Object> lGet(String key,long
start,long
end){try
{return
redisTemplate.opsForList().range(key, start, end);- }
catch
(Exception e) { - e.printStackTrace();
return
null
;- }
- }
- /**
- * 獲取list緩存的長度
- * @param key 鍵
- * @return
- */
public
long
lGetListSize(String key){try
{return
redisTemplate.opsForList().size(key);- }
catch
(Exception e) { - e.printStackTrace();
return
0;- }
- }
- /**
- * 通過索引 獲取list中的值
- * @param key 鍵
- * @param index 索引 index>=0時, 0 表頭,1 第二個元素,依次類推;index<0時,-1,表尾,-2倒數第二個元素,依次類推
- * @return
- */
public
Object lGetIndex(String key,long
index){try
{return
redisTemplate.opsForList().index(key, index);- }
catch
(Exception e) { - e.printStackTrace();
return
null
;- }
- }
- /**
- * 將list放入緩存
- * @param key 鍵
- * @param value 值
- * @param time 時間(秒)
- * @return
- */
public
boolean
lSet(String key, Object value) {try
{- redisTemplate.opsForList().rightPush(key, value);
return
true
;- }
catch
(Exception e) { - e.printStackTrace();
return
false
;- }
- }
- /**
- * 將list放入緩存
- * @param key 鍵
- * @param value 值
- * @param time 時間(秒)
- * @return
- */
public
boolean
lSet(String key, Object value,long
time) {try
{- redisTemplate.opsForList().rightPush(key, value);
if
(time > 0) expire(key, time);return
true
;- }
catch
(Exception e) { - e.printStackTrace();
return
false
;- }
- }
- /**
- * 將list放入緩存
- * @param key 鍵
- * @param value 值
- * @param time 時間(秒)
- * @return
- */
public
boolean
lSet(String key, List<Object> value) {try
{- redisTemplate.opsForList().rightPushAll(key, value);
return
true
;- }
catch
(Exception e) { - e.printStackTrace();
return
false
;- }
- }
- /**
- * 將list放入緩存
- * @param key 鍵
- * @param value 值
- * @param time 時間(秒)
- * @return
- */
public
boolean
lSet(String key, List<Object> value,long
time) {try
{- redisTemplate.opsForList().rightPushAll(key, value);
if
(time > 0) expire(key, time);return
true
;- }
catch
(Exception e) { - e.printStackTrace();
return
false
;- }
- }
- /**
- * 根據索引修改list中的某條數據
- * @param key 鍵
- * @param index 索引
- * @param value 值
- * @return
- */
public
boolean
lUpdateIndex(String key,long
index,Object value) {try
{- redisTemplate.opsForList().set(key, index, value);
return
true
;- }
catch
(Exception e) { - e.printStackTrace();
return
false
;- }
- }
- /**
- * 移除N個值為value
- * @param key 鍵
- * @param count 移除多少個
- * @param value 值
- * @return 移除的個數
- */
public
long
lRemove(String key,long
count,Object value) {try
{- Long remove = redisTemplate.opsForList().remove(key, count, value);
return
remove;- }
catch
(Exception e) { - e.printStackTrace();
return
0;- }
- }
- }
2).序列化反序列化工具類
[java] view plain copy
package
com.xian.manager.util;import
java.io.ByteArrayInputStream;import
java.io.ByteArrayOutputStream;import
java.io.ObjectInputStream;import
java.io.ObjectOutputStream;import
org.apache.log4j.Logger;public
class
SerializeUtil {private
static
Logger logger = Logger.getLogger(SerializeUtil.class
);- /*
- * 序列化
- */
public
static
byte
[] serialize(Object object) {- ObjectOutputStream oos =
null
; - ByteArrayOutputStream baos =
null
; try
{- baos =
new
ByteArrayOutputStream(); - oos =
new
ObjectOutputStream(baos); - oos.writeObject(object);
byte
[] bytes = baos.toByteArray();return
bytes;- }
catch
(Exception e) { - logger.warn("序列化對象出現異常: ", e);
- }
return
null
;- }
- /*
- * 反序列化
- */
public
static
Object deserialize(byte
[] bytes) {- ByteArrayInputStream bais =
null
; try
{- bais =
new
ByteArrayInputStream(bytes); - ObjectInputStream ois =
new
ObjectInputStream(bais); return
ois.readObject();- }
catch
(Exception e) { - logger.warn("反序列化對象出現異常: ", e);
- }
return
null
;- }
- }
3). 實體類與位元組數組互轉工具類
[java] view plain copy
package
com.xian.manager.util;import
java.io.ByteArrayInputStream;import
java.io.ByteArrayOutputStream;import
java.io.IOException;import
java.io.ObjectInputStream;import
java.io.ObjectOutputStream;public
class
ObjectAndByteUtil {- /**
- * 對象轉數組
- * @param obj
- * @return
- */
public
static
byte
[] toByteArray (Object obj) {byte
[] bytes =null
;- ByteArrayOutputStream bos =
new
ByteArrayOutputStream(); try
{- ObjectOutputStream oos =
new
ObjectOutputStream(bos); - oos.writeObject(obj);
- oos.flush();
- bytes = bos.toByteArray ();
- oos.close();
- bos.close();
- }
catch
(IOException ex) { - ex.printStackTrace();
- }
return
bytes;- }
- /**
- * 數組轉對象
- * @param bytes
- * @return
- */
public
static
Object toObject (byte
[] bytes) {- Object obj =
null
; try
{- ByteArrayInputStream bis =
new
ByteArrayInputStream (bytes); - ObjectInputStream ois =
new
ObjectInputStream (bis); - obj = ois.readObject();
- ois.close();
- bis.close();
- }
catch
(IOException ex) { - ex.printStackTrace();
- }
catch
(ClassNotFoundException ex) { - ex.printStackTrace();
- }
return
obj;- }
- }
三、具體使用
1.設值:
User user = new User();
user.setUsername("夜gg");
user.setPassword("123456");
redisUtil.set("user", user);
注意點:實體類User需要實現Serializable介面,而且重寫toString()方法。
[java] view plain copy
package
com.xian.manager.entity;import
java.io.Serializable;public
class
Userimplements
Serializable{private
int
id;private
String username;private
String password;private
int
sex;private
int
age;private
int
state;public
User() {- }
public
String getUsername() {return
username;- }
public
void
setUsername(String username) {this
.username = username;- }
public
String getPassword() {return
password;- }
public
void
setPassword(String password) {this
.password = password;- }
public
int
getSex() {return
sex;- }
public
void
setSex(int
sex) {this
.sex = sex;- }
public
int
getAge() {return
age;- }
public
void
setAge(int
age) {this
.age = age;- }
public
int
getId() {return
id;- }
public
void
setId(int
id) {this
.id = id;- }
public
int
getState() {return
state;- }
public
void
setState(int
state) {this
.state = state;- }
- @Override
public
String toString() {return
"User [id=" + id + ", username=" + username + ", password=" + password + ", sex=" + sex + ", age=" + age- + ", state=" + state + "]";
- }
- }
2.取值:
User user = (User) SerializeUtil.deserialize(ObjectAndByteUtil.toByteArray(redisUtil.get("user")));
System.out.println(user.getUsername());
使用可視化工具RedisDesktopManager查看(以位元組數組的形式):
TAG:程序員小新人學習 |