文章詳情頁

IDEA SSM整合Redis項目實例附源碼

瀏覽：3日期：2024-07-15 08:54:16

IDEA SSM整合Redis項目實例

1、pom.xml 配置

<dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.9.0</version> </dependency>2、spring-redis.xml 配置

<?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:context='http://www.springframework.org/schema/context'xsi:schemaLocation='http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd'><bean class='redis.clients.jedis.JedisPoolConfig'><property name='maxTotal' value='${redis.pool.maxActive}' /><property name='maxIdle' value='${redis.pool.maxIdle}' /><property name='maxWaitMillis' value='${redis.pool.maxWait}' /><property name='testOnBorrow' value='${redis.pool.testOnBorrow}' /></bean><bean class='com.mlr.controller.cache.JedisPoolWriper'depends-on='jedisPoolConfig'><constructor-arg index='0' ref='jedisPoolConfig' /><constructor-arg index='1' value='${redis.hostname}' /><constructor-arg index='2' value='${redis.port}' type='int' /></bean><bean scope='singleton'><property name='jedisPool'><ref bean='jedisWritePool' /></property></bean><bean class='com.mlr.controller.cache.JedisUtil$Keys'scope='singleton'><constructor-arg ref='jedisUtil'></constructor-arg></bean><bean class='com.mlr.controller.cache.JedisUtil$Strings'scope='singleton'><constructor-arg ref='jedisUtil'></constructor-arg></bean><bean class='com.mlr.controller.cache.JedisUtil$Lists'scope='singleton'><constructor-arg ref='jedisUtil'></constructor-arg></bean><bean class='com.mlr.controller.cache.JedisUtil$Sets'scope='singleton'><constructor-arg ref='jedisUtil'></constructor-arg></bean><bean class='com.mlr.controller.cache.JedisUtil$Hash'scope='singleton'><constructor-arg ref='jedisUtil'></constructor-arg></bean></beans> 3、redis.properties 配置

redis.hostname=Redis所在服務器ipredis.port=6379redis.database=0redis.pool.maxActive=100redis.pool.maxIdle=20redis.pool.maxWait=3000redis.pool.testOnBorrow=true4、redis連接池和工具類 JedisUtil.java

package com.mlr.controller.cache;import com.mlr.controller.cache.JedisPoolWriper;import java.util.List;import java.util.Map;import java.util.Set;import redis.clients.jedis.BinaryClient.LIST_POSITION;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;import redis.clients.jedis.SortingParams;import redis.clients.util.SafeEncoder;public class JedisUtil { /** * 緩存生存時間 */ private final int expire = 60000; /** * 操作Key的方法 */ public Keys KEYS; /** * 對存儲結構為String類型的操作 */ public Strings STRINGS; /** * 對存儲結構為List類型的操作 */ public Lists LISTS; /** * 對存儲結構為Set類型的操作 */ public Sets SETS; /** * 對存儲結構為HashMap類型的操作 */ public Hash HASH; /** * Redis連接池對象 */ private JedisPool jedisPool; /** * 獲取redis連接池 */ public JedisPool getJedisPool() { return jedisPool; } /** * 設置redis連接池 */ public void setJedisPool(JedisPoolWriper jedisPoolWriper) { this.jedisPool = jedisPoolWriper.getJedisPool(); } /** * 從jedis連接池中獲取獲取jedis對象 */ public Jedis getJedis() { return jedisPool.getResource(); } /** * 設置過期時間 * * @author xiangze */ public void expire(String key, int seconds) { if (seconds <= 0) { return; } Jedis jedis = getJedis(); jedis.expire(key, seconds); jedis.close(); } /** * 設置默認過期時間 * * @author xiangze */ public void expire(String key) { expire(key, expire); } // *******************************************Keys*******************************************// public class Keys { public Keys(JedisUtil jedisUtil) { } /** * 清空所有key */ public String flushAll() { Jedis jedis = getJedis(); String stata = jedis.flushAll(); jedis.close(); return stata; } /** * 更改key * * @return 狀態碼 */ public String rename(String oldkey, String newkey) { return rename(SafeEncoder.encode(oldkey), SafeEncoder.encode(newkey)); } /** * 更改key,僅當新key不存在時才執行 * * @return 狀態碼 */ public long renamenx(String oldkey, String newkey) { Jedis jedis = getJedis(); long status = jedis.renamenx(oldkey, newkey); jedis.close(); return status; } /** * 更改key * * @return 狀態碼 */ public String rename(byte[] oldkey, byte[] newkey) { Jedis jedis = getJedis(); String status = jedis.rename(oldkey, newkey); jedis.close(); return status; } /** * 設置key的過期時間，以秒為單位 * * */ public long expired(String key, int seconds) { Jedis jedis = getJedis(); long count = jedis.expire(key, seconds); jedis.close(); return count; } /** * 設置key的過期時間,它是距歷元（即格林威治標準時間 1970 年 1 月 1 日的 00:00:00，格里高利歷）的偏移量。 * * * */ public long expireAt(String key, long timestamp) { Jedis jedis = getJedis(); long count = jedis.expireAt(key, timestamp); jedis.close(); return count; } /** * 查詢key的過期時間 * * @param key * @return 以秒為單位的時間表示 */ public long ttl(String key) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); long len = sjedis.ttl(key); sjedis.close(); return len; } /** * 取消對key過期時間的設置 * * @return 影響的記錄數 */ public long persist(String key) { Jedis jedis = getJedis(); long count = jedis.persist(key); jedis.close(); return count; } /** * 刪除keys對應的記錄,可以是多個key * * @param keys * @return 刪除的記錄數 */ public long del(String... keys) { Jedis jedis = getJedis(); long count = jedis.del(keys); jedis.close(); return count; } /** * 刪除keys對應的記錄,可以是多個key * * @param keys * @return 刪除的記錄數 */ public long del(byte[]... keys) { Jedis jedis = getJedis(); long count = jedis.del(keys); jedis.close(); return count; } /** * 判斷key是否存在 * * @param key * @return boolean */ public boolean exists(String key) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); boolean exis = sjedis.exists(key); sjedis.close(); return exis; } /** * 對List,Set,SortSet進行排序,如果集合數據較大應避免使用這個方法 * * @param key * @return List<String> 集合的全部記錄 **/ public List<String> sort(String key) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); List<String> list = sjedis.sort(key); sjedis.close(); return list; } /** * 對List,Set,SortSet進行排序或limit * * @param key * @param parame 定義排序類型或limit的起止位置. * @return List<String> 全部或部分記錄 **/ public List<String> sort(String key, SortingParams parame) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); List<String> list = sjedis.sort(key, parame); sjedis.close(); return list; } /** * 返回指定key存儲的類型 * * @param key * @return String string|list|set|zset|hash **/ public String type(String key) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); String type = sjedis.type(key); sjedis.close(); return type; } /** * 查找所有匹配給定的模式的鍵 * * @param pattern key的表達式,*表示多個，？表示一個 */ public Set<String> keys(String pattern) { Jedis jedis = getJedis(); Set<String> set = jedis.keys(pattern); jedis.close(); return set; } } // *******************************************Strings*******************************************// public class Strings { public Strings(JedisUtil jedisUtil) { } /** * 根據key獲取記錄 * * @param key * @return 值 */ public String get(String key) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); String value = sjedis.get(key); sjedis.close(); return value; } /** * 根據key獲取記錄 * * @param key * @return 值 */ public byte[] get(byte[] key) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); byte[] value = sjedis.get(key); sjedis.close(); return value; } /** * 添加記錄,如果記錄已存在將覆蓋原有的value * * @param key * @param value * @return 狀態碼 */ public String set(String key, String value) { return set(SafeEncoder.encode(key), SafeEncoder.encode(value)); } /** * 添加記錄,如果記錄已存在將覆蓋原有的value * * @param key * @param value * @return 狀態碼 */ public String set(String key, byte[] value) { return set(SafeEncoder.encode(key), value); } /** * 添加記錄,如果記錄已存在將覆蓋原有的value * * @param key * @param value * @return 狀態碼 */ public String set(byte[] key, byte[] value) { Jedis jedis = getJedis(); String status = jedis.set(key, value); jedis.close(); return status; } /** * 添加有過期時間的記錄 * * @param key * @param seconds 過期時間，以秒為單位 * @param value * @return String 操作狀態 */ public String setEx(String key, int seconds, String value) { Jedis jedis = getJedis(); String str = jedis.setex(key, seconds, value); jedis.close(); return str; } /** * 添加有過期時間的記錄 * * @param key * @param seconds 過期時間，以秒為單位 * @param value * @return String 操作狀態 */ public String setEx(byte[] key, int seconds, byte[] value) { Jedis jedis = getJedis(); String str = jedis.setex(key, seconds, value); jedis.close(); return str; } /** * 添加一條記錄，僅當給定的key不存在時才插入 * * @param key * @param value * @return long 狀態碼，1插入成功且key不存在，0未插入，key存在 */ public long setnx(String key, String value) { Jedis jedis = getJedis(); long str = jedis.setnx(key, value); jedis.close(); return str; } /** * 從指定位置開始插入數據，插入的數據會覆蓋指定位置以后的數據 * 例:String str1='123456789'; * 對str1操作后setRange(key,4,0000)，str1='123400009'; * * @param key * @param offset * @param value * @return long value的長度 */ public long setRange(String key, long offset, String value) { Jedis jedis = getJedis(); long len = jedis.setrange(key, offset, value); jedis.close(); return len; } /** * 在指定的key中追加value * * @param key * @param value * @return long 追加后value的長度 **/ public long append(String key, String value) { Jedis jedis = getJedis(); long len = jedis.append(key, value); jedis.close(); return len; } /** * 將key對應的value減去指定的值，只有value可以轉為數字時該方法才可用 * * @param key * @param number 要減去的值 * @return long 減指定值后的值 */ public long decrBy(String key, long number) { Jedis jedis = getJedis(); long len = jedis.decrBy(key, number); jedis.close(); return len; } /** * 可以作為獲取唯一id的方法 * 將key對應的value加上指定的值，只有value可以轉為數字時該方法才可用 * * @param key * @param number 要減去的值 * @return long 相加后的值 */ public long incrBy(String key, long number) { Jedis jedis = getJedis(); long len = jedis.incrBy(key, number); jedis.close(); return len; } /** * 對指定key對應的value進行截取 * * @param key * @param startOffset 開始位置(包含) * @param endOffset 結束位置(包含) * @return String 截取的值 */ public String getrange(String key, long startOffset, long endOffset) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); String value = sjedis.getrange(key, startOffset, endOffset); sjedis.close(); return value; } /** * 獲取并設置指定key對應的value * 如果key存在返回之前的value,否則返回null * * @param key * @param value * @return String 原始value或null */ public String getSet(String key, String value) { Jedis jedis = getJedis(); String str = jedis.getSet(key, value); jedis.close(); return str; } /** * 批量獲取記錄,如果指定的key不存在返回List的對應位置將是null * * @param keys * @return List<String> 值得集合 */ public List<String> mget(String... keys) { Jedis jedis = getJedis(); List<String> str = jedis.mget(keys); jedis.close(); return str; } /** * 批量存儲記錄 * * @param keysvalues 例:keysvalues='key1','value1','key2','value2'; * @return String 狀態碼 */ public String mset(String... keysvalues) { Jedis jedis = getJedis(); String str = jedis.mset(keysvalues); jedis.close(); return str; } /** * 獲取key對應的值的長度 * * @param key * @return value值得長度 */ public long strlen(String key) { Jedis jedis = getJedis(); long len = jedis.strlen(key); jedis.close(); return len; } } // *******************************************Sets*******************************************// public class Sets { public Sets(JedisUtil jedisUtil) { } /** * 向Set添加一條記錄，如果member已存在返回0,否則返回1 * * @param key * @param member * @return 操作碼, 0或1 */ public long sadd(String key, String member) { Jedis jedis = getJedis(); long s = jedis.sadd(key, member); jedis.close(); return s; } public long sadd(byte[] key, byte[] member) { Jedis jedis = getJedis(); long s = jedis.sadd(key, member); jedis.close(); return s; } /** * 獲取給定key中元素個數 * * @param key * @return 元素個數 */ public long scard(String key) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); long len = sjedis.scard(key); sjedis.close(); return len; } /** * 返回從第一組和所有的給定集合之間的差異的成員 * * @param keys * @return 差異的成員集合 */ public Set<String> sdiff(String... keys) { Jedis jedis = getJedis(); Set<String> set = jedis.sdiff(keys); jedis.close(); return set; } /** * 這個命令等于sdiff,但返回的不是結果集,而是將結果集存儲在新的集合中，如果目標已存在，則覆蓋。 * * @param newkey 新結果集的key * @param keys 比較的集合 * @return 新集合中的記錄數 **/ public long sdiffstore(String newkey, String... keys) { Jedis jedis = getJedis(); long s = jedis.sdiffstore(newkey, keys); jedis.close(); return s; } /** * 返回給定集合交集的成員,如果其中一個集合為不存在或為空，則返回空Set * * @param keys * @return 交集成員的集合 **/ public Set<String> sinter(String... keys) { Jedis jedis = getJedis(); Set<String> set = jedis.sinter(keys); jedis.close(); return set; } /** * 這個命令等于sinter,但返回的不是結果集,而是將結果集存儲在新的集合中，如果目標已存在，則覆蓋。 * * @param newkey 新結果集的key * @param keys 比較的集合 * @return 新集合中的記錄數 **/ public long sinterstore(String newkey, String... keys) { Jedis jedis = getJedis(); long s = jedis.sinterstore(newkey, keys); jedis.close(); return s; } /** * 確定一個給定的值是否存在 * * @param key * @param member 要判斷的值 * @return 存在返回1，不存在返回0 **/ public boolean sismember(String key, String member) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); boolean s = sjedis.sismember(key, member); sjedis.close(); return s; } /** * 返回集合中的所有成員 * * @param key * @return 成員集合 */ public Set<String> smembers(String key) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); Set<String> set = sjedis.smembers(key); sjedis.close(); return set; } public Set<byte[]> smembers(byte[] key) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); Set<byte[]> set = sjedis.smembers(key); sjedis.close(); return set; } /** * 將成員從源集合移出放入目標集合 * 如果源集合不存在或不包哈指定成員，不進行任何操作，返回0 * 否則該成員從源集合上刪除，并添加到目標集合，如果目標集合中成員已存在，則只在源集合進行刪除 * * @param srckey 源集合 * @param dstkey 目標集合 * @param member 源集合中的成員 * @return 狀態碼，1成功，0失敗 */ public long smove(String srckey, String dstkey, String member) { Jedis jedis = getJedis(); long s = jedis.smove(srckey, dstkey, member); jedis.close(); return s; } /** * 從集合中刪除成員 * * @param key * @return 被刪除的成員 */ public String spop(String key) { Jedis jedis = getJedis(); String s = jedis.spop(key); jedis.close(); return s; } /** * 從集合中刪除指定成員 * * @param key * @param member 要刪除的成員 * @return 狀態碼，成功返回1，成員不存在返回0 */ public long srem(String key, String member) { Jedis jedis = getJedis(); long s = jedis.srem(key, member); jedis.close(); return s; } /** * 合并多個集合并返回合并后的結果，合并后的結果集合并不保存 * * @param keys * @return 合并后的結果集合 * @see */ public Set<String> sunion(String... keys) { Jedis jedis = getJedis(); Set<String> set = jedis.sunion(keys); jedis.close(); return set; } /** * 合并多個集合并將合并后的結果集保存在指定的新集合中，如果新集合已經存在則覆蓋 * * @param newkey 新集合的key * @param keys 要合并的集合 **/ public long sunionstore(String newkey, String... keys) { Jedis jedis = getJedis(); long s = jedis.sunionstore(newkey, keys); jedis.close(); return s; } } // *******************************************Hash*******************************************// public class Hash { public Hash(JedisUtil jedisUtil) { } /** * 從hash中刪除指定的存儲 * * @param key * @param fieid 存儲的名字 * @return 狀態碼，1成功，0失敗 */ public long hdel(String key, String fieid) { Jedis jedis = getJedis(); long s = jedis.hdel(key, fieid); jedis.close(); return s; } public long hdel(String key) { Jedis jedis = getJedis(); long s = jedis.del(key); jedis.close(); return s; } /** * 測試hash中指定的存儲是否存在 * * @param key * @param fieid 存儲的名字 * @return 1存在，0不存在 */ public boolean hexists(String key, String fieid) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); boolean s = sjedis.hexists(key, fieid); sjedis.close(); return s; } /** * 返回hash中指定存儲位置的值 * * @param key * @param fieid 存儲的名字 * @return 存儲對應的值 */ public String hget(String key, String fieid) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); String s = sjedis.hget(key, fieid); sjedis.close(); return s; } public byte[] hget(byte[] key, byte[] fieid) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); byte[] s = sjedis.hget(key, fieid); sjedis.close(); return s; } /** * 以Map的形式返回hash中的存儲和值 * * @param key * @return Map<Strinig,String> */ public Map<String, String> hgetAll(String key) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); Map<String, String> map = sjedis.hgetAll(key); sjedis.close(); return map; } /** * 添加一個對應關系 * * @param key * @param fieid * @param value * @return 狀態碼 1成功，0失敗，fieid已存在將更新，也返回0 **/ public long hset(String key, String fieid, String value) { Jedis jedis = getJedis(); long s = jedis.hset(key, fieid, value); jedis.close(); return s; } public long hset(String key, String fieid, byte[] value) { Jedis jedis = getJedis(); long s = jedis.hset(key.getBytes(), fieid.getBytes(), value); jedis.close(); return s; } /** * 添加對應關系，只有在fieid不存在時才執行 * * @param key * @param fieid * @param value * @return 狀態碼 1成功，0失敗fieid已存 **/ public long hsetnx(String key, String fieid, String value) { Jedis jedis = getJedis(); long s = jedis.hsetnx(key, fieid, value); jedis.close(); return s; } /** * 獲取hash中value的集合 * * @param key * @return List<String> */ public List<String> hvals(String key) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); List<String> list = sjedis.hvals(key); sjedis.close(); return list; } /** * 在指定的存儲位置加上指定的數字，存儲位置的值必須可轉為數字類型 * * @param key * @param fieid 存儲位置 * @param value 要增加的值,可以是負數 * @return 增加指定數字后，存儲位置的值 */ public long hincrby(String key, String fieid, long value) { Jedis jedis = getJedis(); long s = jedis.hincrBy(key, fieid, value); jedis.close(); return s; } /** * 返回指定hash中的所有存儲名字,類似Map中的keySet方法 * * @param key * @return Set<String> 存儲名稱的集合 */ public Set<String> hkeys(String key) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); Set<String> set = sjedis.hkeys(key); sjedis.close(); return set; } /** * 獲取hash中存儲的個數，類似Map中size方法 * * @param key * @return long 存儲的個數 */ public long hlen(String key) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); long len = sjedis.hlen(key); sjedis.close(); return len; } /** * 根據多個key，獲取對應的value，返回List,如果指定的key不存在,List對應位置為null * * @param key * @param fieids 存儲位置 * @return List<String> */ public List<String> hmget(String key, String... fieids) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); List<String> list = sjedis.hmget(key, fieids); sjedis.close(); return list; } public List<byte[]> hmget(byte[] key, byte[]... fieids) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); List<byte[]> list = sjedis.hmget(key, fieids); sjedis.close(); return list; } /** * 添加對應關系，如果對應關系已存在，則覆蓋 * * @param key * @param map 對應關系 * @return 狀態，成功返回OK */ public String hmset(String key, Map<String, String> map) { Jedis jedis = getJedis(); String s = jedis.hmset(key, map); jedis.close(); return s; } /** * 添加對應關系，如果對應關系已存在，則覆蓋 * * @param key * @param map 對應關系 * @return 狀態，成功返回OK */ public String hmset(byte[] key, Map<byte[], byte[]> map) { Jedis jedis = getJedis(); String s = jedis.hmset(key, map); jedis.close(); return s; } } // *******************************************Lists*******************************************// public class Lists { public Lists(JedisUtil jedisUtil) { } /** * List長度 * * @param key * @return 長度 */ public long llen(String key) { return llen(SafeEncoder.encode(key)); } /** * List長度 * * @param key * @return 長度 */ public long llen(byte[] key) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); long count = sjedis.llen(key); sjedis.close(); return count; } /** * 覆蓋操作,將覆蓋List中指定位置的值 * * @param key * @param index 位置 * @param value 值 * @return 狀態碼 */ public String lset(byte[] key, int index, byte[] value) { Jedis jedis = getJedis(); String status = jedis.lset(key, index, value); jedis.close(); return status; } /** * 覆蓋操作,將覆蓋List中指定位置的值 * * @param index 位置 * @param value 值 * @return 狀態碼 */ public String lset(String key, int index, String value) { return lset(SafeEncoder.encode(key), index, SafeEncoder.encode(value)); } /** * 在value的相對位置插入記錄 * * @param where 前面插入或后面插入 * @param pivot 相對位置的內容 * @param value 插入的內容 * @return 記錄總數 */ public long linsert(String key, LIST_POSITION where, String pivot, String value) { return linsert(SafeEncoder.encode(key), where, SafeEncoder.encode(pivot), SafeEncoder.encode(value)); } /** * 在指定位置插入記錄 * * @param key * @param where 前面插入或后面插入 * @param pivot 相對位置的內容 * @param value 插入的內容 * @return 記錄總數 */ public long linsert(byte[] key, LIST_POSITION where, byte[] pivot, byte[] value) { Jedis jedis = getJedis(); long count = jedis.linsert(key, where, pivot, value); jedis.close(); return count; } /** * 獲取List中指定位置的值 * * @param key * @param index 位置 * @return 值 **/ public String lindex(String key, int index) { return SafeEncoder.encode(lindex(SafeEncoder.encode(key), index)); } /** * 獲取List中指定位置的值 * * @param key * @param index 位置 * @return 值 **/ public byte[] lindex(byte[] key, int index) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); byte[] value = sjedis.lindex(key, index); sjedis.close(); return value; } /** * 將List中的第一條記錄移出List * * @param key * @return 移出的記錄 */ public String lpop(String key) { return SafeEncoder.encode(lpop(SafeEncoder.encode(key))); } /** * 將List中的第一條記錄移出List * * @param key * @return 移出的記錄 */ public byte[] lpop(byte[] key) { Jedis jedis = getJedis(); byte[] value = jedis.lpop(key); jedis.close(); return value; } /** * 將List中最后第一條記錄移出List * * @param key * @return 移出的記錄 */ public String rpop(String key) { Jedis jedis = getJedis(); String value = jedis.rpop(key); jedis.close(); return value; } /** * 向List尾部追加記錄 * * @param key * @param value * @return 記錄總數 */ public long lpush(String key, String value) { return lpush(SafeEncoder.encode(key), SafeEncoder.encode(value)); } /** * 向List頭部追加記錄 * * @param key * @param value * @return 記錄總數 */ public long rpush(String key, String value) { Jedis jedis = getJedis(); long count = jedis.rpush(key, value); jedis.close(); return count; } /** * 向List頭部追加記錄 * * @param key * @param value * @return 記錄總數 */ public long rpush(byte[] key, byte[] value) { Jedis jedis = getJedis(); long count = jedis.rpush(key, value); jedis.close(); return count; } /** * 向List中追加記錄 * * @param key * @param value * @return 記錄總數 */ public long lpush(byte[] key, byte[] value) { Jedis jedis = getJedis(); long count = jedis.lpush(key, value); jedis.close(); return count; } /** * 獲取指定范圍的記錄，可以做為分頁使用 * * @param key * @param start * @param end * @return List */ public List<String> lrange(String key, long start, long end) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); List<String> list = sjedis.lrange(key, start, end); sjedis.close(); return list; } /** * 獲取指定范圍的記錄，可以做為分頁使用 * * @param key * @param start * @param end 如果為負數，則尾部開始計算 * @return List */ public List<byte[]> lrange(byte[] key, int start, int end) { // ShardedJedis sjedis = getShardedJedis(); Jedis sjedis = getJedis(); List<byte[]> list = sjedis.lrange(key, start, end); sjedis.close(); return list; } /** * 刪除List中c條記錄，被刪除的記錄值為value * * @param key * @param c 要刪除的數量，如果為負數則從List的尾部檢查并刪除符合的記錄 * @param value 要匹配的值 * @return 刪除后的List中的記錄數 */ public long lrem(byte[] key, int c, byte[] value) { Jedis jedis = getJedis(); long count = jedis.lrem(key, c, value); jedis.close(); return count; } /** * 刪除List中c條記錄，被刪除的記錄值為value * * @param key * @param c 要刪除的數量，如果為負數則從List的尾部檢查并刪除符合的記錄 * @param value 要匹配的值 * @return 刪除后的List中的記錄數 */ public long lrem(String key, int c, String value) { return lrem(SafeEncoder.encode(key), c, SafeEncoder.encode(value)); } /** * 算是刪除吧，只保留start與end之間的記錄 * * @param key * @param start 記錄的開始位置(0表示第一條記錄) * @param end 記錄的結束位置（如果為-1則表示最后一個，-2，-3以此類推） * @return 執行狀態碼 */ public String ltrim(byte[] key, int start, int end) { Jedis jedis = getJedis(); String str = jedis.ltrim(key, start, end); jedis.close(); return str; } /** * 算是刪除吧，只保留start與end之間的記錄 * * @param key * @param start 記錄的開始位置(0表示第一條記錄) * @param end 記錄的結束位置（如果為-1則表示最后一個，-2，-3以此類推） * @return 執行狀態碼 */ public String ltrim(String key, int start, int end) { return ltrim(SafeEncoder.encode(key), start, end); } }}5、JedisPoolWriper.java

package com.mlr.controller.cache;import redis.clients.jedis.JedisPool;import redis.clients.jedis.JedisPoolConfig;/** * 強指定redis的JedisPool接口構造函數，這樣才能在centos成功創建jedispool * * @author xiangze * */public class JedisPoolWriper {/** Redis連接池對象 */private JedisPool jedisPool;public JedisPoolWriper(final JedisPoolConfig poolConfig, final String host,final int port) {try {jedisPool = new JedisPool(poolConfig, host, port);} catch (Exception e) {e.printStackTrace();}}/** * 獲取Redis連接池對象 * @return */public JedisPool getJedisPool() {return jedisPool;}/** * 注入Redis連接池對象 * @param jedisPool */public void setJedisPool(JedisPool jedisPool) {this.jedisPool = jedisPool;}}6、然后我們的Jedis就可以用了

把我們的業務邏輯中不需要頻繁更換的數據保存到redis中，例如，下部分代碼：

@Transactional public List<Area> getAreaList(){// 定義redis的key String key = AREALISTKEY; // 定義接收對象 List<Area> areaList = null; // 定義jackson數據轉換操作類 ObjectMapper mapper = new ObjectMapper(); // 判斷key是否存在if (!jedisKeys.exists(key)) { // 若不存在，則從數據庫里面取出相應數據 areaList = areaDao.queryArea(); // 將相關的實體類集合轉換成string,存入redis里面對應的key中 String jsonString; try { jsonString = mapper.writeValueAsString(areaList); } catch (JsonProcessingException e) { e.printStackTrace(); logger.error(e.getMessage()); throw new AreaOperationException(e.getMessage()); } jedisStrings.set(key, jsonString); } else { // 若存在，則直接從redis里面取出相應數據 String jsonString = jedisStrings.get(key); // 指定要將string轉換成的集合類型 JavaType javaType = mapper.getTypeFactory().constructParametricType(ArrayList.class, Area.class); try { // 將相關key對應的value里的的string轉換成對象的實體類集合 areaList = mapper.readValue(jsonString, javaType); } catch (JsonParseException e) { e.printStackTrace(); logger.error(e.getMessage()); throw new AreaOperationException(e.getMessage()); } catch (JsonMappingException e) { e.printStackTrace(); logger.error(e.getMessage()); throw new AreaOperationException(e.getMessage()); } catch (IOException e) { e.printStackTrace(); logger.error(e.getMessage()); throw new AreaOperationException(e.getMessage()); } }return areaList;}

以上就是IDEA SSM整合Redis項目實例的詳細內容，更多關于IDEA SSM整合Redis的資料請關注好吧啦網其它相關文章！

IDEA

上一條：IDEA 包轉模塊的解決步驟下一條：關于idea中ssm框架的編碼問題分析

相關文章：

1. IntelliJ IDEA配置Tomcat服務器的方法2. IntelliJ IDEA刪除類的方法步驟3. IntelliJ IDEA恢復刪除文件的方法4. Android 開發使用PopupWindow實現加載等待界面功能示例5. CSS3實現動態翻牌效果仿百度貼吧3D翻牌一次動畫特效6. CSS 使用Sprites技術實現圓角效果7. Python Tricks 使用 pywinrm 遠程控制 Windows 主機的方法8. 詳解CSS不受控制的position fixed9. 5個HTML5的常用本地存儲方式詳解與介紹10. 用于ETL的Python數據轉換工具詳解

排行榜

					
					IntelliJ IDEA配置Tomcat服務器的方法
IntelliJ IDEA恢復刪除文件的方法
Android 開發使用PopupWindow實現加載等待界面功能示例
CSS3實現動態翻牌效果 仿百度貼吧3D翻牌一次動畫特效
CSS 使用Sprites技術實現圓角效果
IntelliJ IDEA刪除類的方法步驟
不使用XMLHttpRequest對象實現Ajax效果的方法小結
詳解CSS不受控制的position fixed
《CSS3實戰》筆記--漸變設計（二)
5個HTML5的常用本地存儲方式詳解與介紹
用于ETL的Python數據轉換工具詳解
				