1.引入redis依赖 在common下的pom文件中引入Redis依赖

org.springframework.boot spring-boot-starter-data-redis org.apache.commons commons-pool2

2.配置文件配置Redis 在项目配置文件中配置Redis

spring.redis.database=15 spring.redis.host=10.196.1.62 spring.redis.port=7019 spring.redis.password=gpSPcwzK spring.redis.lettuce.pool.max-active=8 spring.redis.lettuce.pool.max-wait=5s spring.redis.lettuce.pool.max-idle=8 spring.redis.lettuce.pool.min-idle=0

3.设置Redis 3.1定义Redis的key 在common文件夹下创建cache文件夹，定义KeyConstans.java文件

public class KeyConstans {/** * 存储预警类型编码与名称的对应关系 * 初始化时执行0 */ public static String DISTKEY = "SSCVHB:DISTLIST:ALARM"; /** * 存储预警类型编码与父类名称的对应关系 * 初始化时执行0 */ public static String DISTPARENTKEY = "SSCVHB:DISTLIST:PARENT:ALARM"; }

3.2设置RedisConfig 在cache文件夹下定义RedisConfig.java文件

package com.hikvision.isc.common.cache; import com.fasterxml.jackson.annotation.JsonAutoDetect; import com.fasterxml.jackson.annotation.PropertyAccessor; import com.fasterxml.jackson.databind.ObjectMapper; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; import org.springframework.data.redis.serializer.StringRedisSerializer; @Configuration public class RedisConfig {/*@Bean public JedisConnectionFactory redisConnectionFactory() {RedisStandaloneConfiguration config = new RedisStandaloneConfiguration(host, port); config.setPassword(password); return new JedisConnectionFactory(config); }*/@Bean @SuppressWarnings("all") public RedisTemplate redisTemplate(RedisConnectionFactory factory) { RedisTemplate template = new RedisTemplate(); template.setConnectionFactory(factory); Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper om = new ObjectMapper(); om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(om); StringRedisSerializer stringRedisSerializer = new StringRedisSerializer(); // key采用String的序列化方式 template.setKeySerializer(stringRedisSerializer); // hash的key也采用String的序列化方式 template.setHashKeySerializer(stringRedisSerializer); // value序列化方式采用jackson template.setValueSerializer(jackson2JsonRedisSerializer); // hash的value序列化方式采用jackson template.setHashValueSerializer(jackson2JsonRedisSerializer); template.afterPropertiesSet(); return template; } }

3.3 定义Redis的set、get等方法 在cache文件夹下定义RedisUtils.java文件

package com.hikvision.isc.common.cache; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.*; import org.springframework.stereotype.Service; import java.io.Serializable; import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.TimeUnit; @Service public class RedisUtils { private static final Logger logger = LoggerFactory.getLogger(RedisUtils.class); @Autowired private RedisTemplate redisTemplate; /** * 获取所有key */ public Set getKeyAll() { Set keySet = redisTemplate.keys("*"); return keySet; }/** * 模糊搜索key */ public Set getKey(String key) { String s = "*" + key + "*"; Set keySet = redisTemplate.keys(s); return keySet; }/** * 写入缓存 * * @param key * @param value * @return */ public boolean set(final String key, Object value) { boolean result = false; try { ValueOperations operations = redisTemplate.opsForValue(); operations.set(key, value); result = true; } catch (Exception e) { e.printStackTrace(); } return result; }/** * 写入缓存设置时效时间 * key过期后，再获取key就是null * * @param key * @param value * @return */ public boolean set(final String key, Object value, Long expireTime, TimeUnit timeUnit) { boolean result = false; try { ValueOperations operations = redisTemplate.opsForValue(); operations.set(key, value); redisTemplate.expire(key, expireTime, timeUnit); result = true; } catch (Exception e) { e.printStackTrace(); } return result; }/** * 设置key的过期时间 */ public void expireKey(String key, Long l, TimeUnit timeUnit) { redisTemplate.expire(key, l, timeUnit); }/** * 批量删除对应的value * * @param keys */public void remove(final String... keys) { for (String key : keys) { remove(key); } }/** * 批量删除key * * @param pattern */public void removePattern(final String pattern) { Set keys = redisTemplate.keys(pattern); if (keys.size() > 0) { redisTemplate.delete(keys); } }/** * 删除对应的value * * @param key */public void remove(final String key) { logger.info("redis删除key:{}", key); if (exists(key)) { redisTemplate.delete(key); } }/** * 判断缓存中是否有对应的value * * @param key * @return */public boolean exists(final String key) { return redisTemplate.hasKey(key); }/** * 断缓存中是否有对应的filed */public boolean hexists(final String key, String field) { return redisTemplate.opsForHash().hasKey(key, field); }/** * 读取缓存 * * @param key * @return */public Object get(final String key) { Object result = null; ValueOperations operations = redisTemplate.opsForValue(); result = operations.get(key); return result; }/** * 哈希 添加 * * @param key * @param hashKey * @param value */public void hmSet(String key, Object hashKey, Object value) { HashOperations hash = redisTemplate.opsForHash(); hash.put(key, hashKey, value); }public void hmSet(String key, Object hashKey, Object value, Long expireTime, TimeUnit timeUnit) { HashOperations hash = redisTemplate.opsForHash(); hash.put(key, hashKey, value); redisTemplate.expire(key, expireTime, timeUnit); }/** * 哈希获取数据 * * @param key * @param hashKey * @return */public Object hmGet(String key, Object hashKey) { HashOperations hash = redisTemplate.opsForHash(); return hash.get(key, hashKey); }/** * 获取hashKey对应的所有键值 */ public Map hmGetMap(String key) { Map map = redisTemplate.opsForHash().entries(key); return map; }/** * 列表添加,单个元素添加 * * @param k * @param v */public void lPush(String k, Object v) { ListOperations list = redisTemplate.opsForList(); list.rightPush(k, v); } /** * 列表取出,单个元素取出 * 使用方法时，redis会同步删除集合中的数据 * @param k * */public Object lPop(String k) { ListOperations list = redisTemplate.opsForList(); returnlist.leftPop(k); }/** * 列表获取 * * @param k * @param l * @param l1 * @return */public List