IDEA SSM integration Redis project example with source code
- 2021-09-11 20:28:20
- OfStack
IDEA SSM Integration Redis Project Example
1. pom. xml configuration
<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>2. spring-redis. xml configuration
<?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">
<!-- Redis Settings of Connection Pool -->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<!-- Control 1 A pool How many can be allocated jedis Instances -->
<property name="maxTotal" value="${redis.pool.maxActive}" />
<!-- The connection pool can be free at most maxIdle Connections Where the value is 20 That can be maintained even if there is no database connection 20 Idle connections, which are not cleared, are always on standby. -->
<property name="maxIdle" value="${redis.pool.maxIdle}" />
<!-- Maximum waiting time : When no connection is available , Maximum time for connection pool to wait for connection to be returned ( Count in milliseconds ), Throw an exception if the time exceeds -->
<property name="maxWaitMillis" value="${redis.pool.maxWait}" />
<!-- Check the validity when getting the connection -->
<property name="testOnBorrow" value="${redis.pool.testOnBorrow}" />
</bean>
<!-- Create Redis Connection pool and make relevant configuration -->
<bean id="jedisWritePool" 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>
<!-- Create Redis Tool class, encapsulated Redis To perform related operations -->
<bean id="jedisUtil" class="com.mlr.controller.cache.JedisUtil" scope="singleton">
<property name="jedisPool">
<ref bean="jedisWritePool" />
</property>
</bean>
<!-- Redis Adj. key Operation -->
<bean id="jedisKeys" class="com.mlr.controller.cache.JedisUtil$Keys"
scope="singleton">
<constructor-arg ref="jedisUtil"></constructor-arg>
</bean>
<!-- Redis Adj. Strings Operation -->
<bean id="jedisStrings" class="com.mlr.controller.cache.JedisUtil$Strings"
scope="singleton">
<constructor-arg ref="jedisUtil"></constructor-arg>
</bean>
<!-- Redis Adj. Lists Operation -->
<bean id="jedisLists" class="com.mlr.controller.cache.JedisUtil$Lists"
scope="singleton">
<constructor-arg ref="jedisUtil"></constructor-arg>
</bean>
<!-- Redis Adj. Sets Operation -->
<bean id="jedisSets" class="com.mlr.controller.cache.JedisUtil$Sets"
scope="singleton">
<constructor-arg ref="jedisUtil"></constructor-arg>
</bean>
<!-- Redis Adj. HashMap Operation -->
<bean id="jedisHash" class="com.mlr.controller.cache.JedisUtil$Hash"
scope="singleton">
<constructor-arg ref="jedisUtil"></constructor-arg>
</bean>
</beans> 3. redis. properties configuration
redis.hostname=Redis Located server ip
redis.port=6379
redis.database=0
redis.pool.maxActive=100
redis.pool.maxIdle=20
redis.pool.maxWait=3000
redis.pool.testOnBorrow=true4. redis connection pool and tool classes 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的表达式,*表示多个，？表示1个
*/
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;
}
/**
* 添加1条记录，仅当给定的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;
}
/**
* 从指定位置开始插入数据，插入的数据会覆盖指定位置以后的数据<br/>
* 例:String str1="123456789";<br/>
* 对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;
}
/**
* <b>可以作为获取唯1id的方法</b><br/>
* 将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<br/>
* 如果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添加1条记录，如果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;
}
/**
* 返回从第1组和所有的给定集合之间的差异的成员
*
* @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;
}
/**
* 返回给定集合交集的成员,如果其中1个集合为不存在或为空，则返回空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;
}
/**
* 确定1个给定的值是否存在
*
* @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;
}
/**
* 将成员从源集合移出放入目标集合 <br/>
* 如果源集合不存在或不包哈指定成员，不进行任何操作，返回0<br/>
* 否则该成员从源集合上删除，并添加到目标集合，如果目标集合中成员已存在，则只在源集合进行删除
*
* @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;
}
/**
* 合并多个集合并返回合并后的结果，合并后的结果集合并不保存<br/>
*
* @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;
}
/**
* 添加1个对应关系
*
* @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中的第1条记录移出List
*
* @param key
* @return 移出的记录
*/
public String lpop(String key) {
return SafeEncoder.encode(lpop(SafeEncoder.encode(key)));
}
/**
* 将List中的第1条记录移出List
*
* @param key
* @return 移出的记录
*/
public byte[] lpop(byte[] key) {
Jedis jedis = getJedis();
byte[] value = jedis.lpop(key);
jedis.close();
return value;
}
/**
* 将List中最后第1条记录移出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表示第1条记录)
* @param end 记录的结束位置（如果为-1则表示最后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表示第1条记录)
* @param end 记录的结束位置（如果为-1则表示最后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;
/**
* Strong designation redis Adj. JedisPool Interface constructor, so that you can use the centos Successfully created jedispool
*
* @author xiangze
*
*/
public class JedisPoolWriper {
/** Redis Connection pool object */
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();
}
}
/**
* Get Redis Connection pool object
* @return
*/
public JedisPool getJedisPool() {
return jedisPool;
}
/**
* Injection Redis Connection pool object
* @param jedisPool
*/
public void setJedisPool(JedisPool jedisPool) {
this.jedisPool = jedisPool;
}
}6, and then our Jedis can be used
Save the data in our business logic that does not need to be replaced frequently to redis, for example, the following code:
@Transactional
public List<Area> getAreaList(){// Definition redis Adj. key
String key = AREALISTKEY;
// Define the receiving object
List<Area> areaList = null;
// Definition jackson Data conversion operation class
ObjectMapper mapper = new ObjectMapper();
// Judge key Does it exist
if (!jedisKeys.exists(key)) {
// If it does not exist, the corresponding data is taken out from the database
areaList = areaDao.queryArea();
// Converts a collection of related entity classes to string, Deposit redis Corresponding inside key Medium
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 {
// If it exists, it is directly derived from the redis Take out the corresponding data inside
String jsonString = jedisStrings.get(key);
// Specifies that you want to set the string The collection type converted to
JavaType javaType = mapper.getTypeFactory().constructParametricType(ArrayList.class, Area.class);
try {
// Will be related to key Corresponding value Of the inside string A collection of entity classes converted to objects
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;
}The above is the details of IDEA SSM integration Redis project example, more information about IDEA SSM integration Redis please pay attention to other related articles on this site!