SSM框架整合Redis資料庫【Redis·4】
阿新 • • 發佈：2019-02-01
最近專案中引進redis用來存放圖片或者一些不常修改的資料，以減輕程式及資料庫壓力。記錄下配置過程。
框架：SpringMVC+Mybatis
版本：
Spring4.0
Mybatis3.0
jedis-2.9.0
spring-data-commons-1.8.6.RELEASE.jar
spring-data-redis-1.8.6.RELEASE.jar
備註：如果是Spring3.0 的版本，請使用低版本的 jedis-2.4.2.jar spring-data-commons-core-1.4.0.RELEASE.jar spring-data-redis-1.4.2.RELEASE.jar
redis配置
1、將下載好的jar包放入專案中。
2、建立一個spring-context-redis.xml，將redis相關資訊整合進Spring中
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:util="http://www.springframework.org/schema/util" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd"> <!-- 載入配置屬性檔案 --> <context:property-placeholder ignore-unresolvable="true" location="classpath:config.properties" /> <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig"> <property name="maxIdle" value="1" /> <property name="maxTotal" value="5" /> <property name="blockWhenExhausted" value="true" /> <property name="maxWaitMillis" value="30000" /> <property name="testOnBorrow" value="true" /> </bean> <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"> <property name="hostName" value="${jedis.JedisServerIp}" /> <property name="port" value="${jedis.JedisServerPort}"/> <!-- <property name="timeout" value="${jedis.timeout}"/>--> <property name="password" value="${jedis.auth}"></property> <property name="poolConfig" ref="jedisPoolConfig" /> <property name="usePool" value="true"/> </bean> <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"> <property name="connectionFactory" ref="jedisConnectionFactory" /> <property name="keySerializer"> <bean class="org.springframework.data.redis.serializer.StringRedisSerializer" /> </property> <property name="valueSerializer"> <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" /> </property> <property name="hashKeySerializer"> <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/> </property> <property name="hashValueSerializer"> <bean class="com.bonc.wechat.services.redis.CustomRedisSerializer"/> </property> </bean> </beans>
注：hashValueSerializer 是 自己配置的用來序列化的類，可以注掉，也可以改用jedis本身的序列化方法。
在config.properties中配置好連線地址，埠，密碼等資訊。
3、在web.xml中註冊剛才配置的檔案，保證專案啟動後能夠載入
至此redis已經整合進了專案之中，可能出現的錯誤就是版本不匹配，即Spring的版本與jedis的版本不匹配產生的，更換相應的版本即可。
redis的使用
1、完成redis配置後，需要建立一個redis的工具類 或者 是 service方法，用來方便的呼叫redis中的相關增刪改查的方法
package com.bonc.wechat.services.redis; import java.util.HashMap; import java.util.Map; import java.util.Map.Entry; import java.util.Set; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.HashOperations; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.ValueOperations; import org.springframework.stereotype.Service; import com.bonc.wechat.common.util.JSONUtil; import com.bonc.wechat.common.util.RedisDecodeUtil; @Service public class RedisService { @Autowired RedisTemplate<String, Object> redisTemplate; /** * 清楚快取物件 * @param rkey * @throws Exception */ public void del(String rkey) throws Exception { redisTemplate.delete(rkey); } /** * 向redis快取放入任意物件 * @param rkey Map鍵 * @param map * @throws Exception */ public void oset(String rkey, Object object) throws Exception { ValueOperations<String, Object> value = redisTemplate.opsForValue(); if(object instanceof String){ value.set(rkey, object.toString()); }else{ value.set(rkey, JSONUtil.serialize(object,true)); } } /** * 向redis快取放入Map * @param rkey Map鍵 * @param map * @throws Exception */ public void oset(String rkey, Map<String,Object> map) throws Exception { oset(rkey,map,false); } /** * 向redis快取放入Map * @param rkey Map鍵 * @param map * @param override 是否覆蓋 * @throws Exception */ public void oset(String rkey, Map<String,Object> map, boolean override) throws Exception { del(rkey); // if(override) { // } HashOperations<String, String, Object> objList = redisTemplate.opsForHash(); Set<Entry<String, Object>> keys = map.entrySet(); Map<String,String> temp = new HashMap<String, String>(); for (Entry<String, Object> entry : keys) { temp.put(entry.getKey(), JSONUtil.serialize(entry.getValue(),true)); } objList.putAll(rkey,temp); } /** * 自增 * @param rkey 存放在redis的key * @return * @throws Exception */ public Long incr(String rkey) throws Exception { return incrBy(rkey, 1L); } /** * 自增 * @param rkey 存放在redis的key * @return * @throws Exception */ public Long incrBy(String rkey,long l) throws Exception { ValueOperations<String, Object> value = redisTemplate.opsForValue(); return value.increment(rkey, l); } /** * 取出String * @param rkey 存放在redis的key * @return * @throws Exception */ public String get(String rkey) throws Exception { ValueOperations<String, Object> value = redisTemplate.opsForValue(); Object val = value.get(rkey); return val==null?null:val.toString(); } /** * 取出物件 * @param rkey 存放在redis的key * @return * @throws Exception */ public Object oget(String rkey) throws Exception { switch(redisTemplate.type(rkey).code()){ case "string": ValueOperations<String, Object> value = redisTemplate.opsForValue(); return RedisDecodeUtil.parse(value.get(rkey).toString()); case "hash": HashOperations<String, String, Object> objList = redisTemplate.opsForHash(); return objList.entries(rkey); default: return null; } } /** * 按型別獲取 * @param rkey 存放在redis的key * @param cls value的類型別 * @return * @throws Exception */ @SuppressWarnings("unchecked") public <T> T oget(String rkey, Class<?> cls) throws Exception { return (T) oget(rkey); } /** * 按型別獲取Map值 * @param rkey 存放在redis的key * @param key map的key * @param cls value的類型別 * @return * @throws Exception */ @SuppressWarnings("unchecked") public <T> T oget(String rkey, String key, Class<?> cls) throws Exception { return (T) hget(rkey,key); } /** * 獲取map值 * @param rkey 存放在redis的key * @param key map的key * @return * @throws Exception */ public Object hget(String rkey,String key) throws Exception { if(redisTemplate.hasKey(rkey)){ HashOperations<String, String, Object> objList = redisTemplate.opsForHash(); return objList.get(rkey, key); } return null; } }
備註：JSONUtil 與 RedisDecodeUtil 下載地址
2、controller中呼叫。
@Resource
private RedisService redisService;/**
* 從redis中獲取資料
* 返回值為物件
*/
@RequestMapping(value="/getRedisData")
@ResponseBody
public AppReply<T> getRedisData(@RequestParam("key")String key){
AppReply<T> appReply = new AppReply<>();
try {
Object obj = redisService.oget(key);
if(obj != null){
appReply.setCode("1");
appReply.setObj(obj);
}else{
appReply.setCode("0");
appReply.setObj(null);
}
} catch (Exception e) {
e.printStackTrace();
}
return appReply;
}3、返回資料檢視
返回結果：
資料庫資料：
至此，SSM整合redis就全部完成。