<!-- Spring Boot Reids 依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId><version>1.5.7.RELEASE</version></dependency><!--spring2.0集成redis所需common-pool2--><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId><version>2.4.2</version></dependency>

springredis:host: 192.168.65.128port: 6379timeout: 0password: # 密码 没有则不填

@Service
public class AddressServiceImpl extends BaseServiceImpl<Address> implements AddressService {@ResourceAddressMapper addressMapper;@Autowiredprivate RedisTemplate<Object,Object> redisTemplate;@Overridepublic Address selectByPrimaryKey(Object key) {String redisKey=key.toString();Address address=(Address) redisTemplate.opsForValue().get(redisKey);if(address==null){//防止缓存穿透synchronized (this) {address = (Address) redisTemplate.opsForValue().get(redisKey);if (address == null) {address = super.selectByPrimaryKey(key);redisTemplate.opsForValue().set(redisKey, address);}}}else {System.out.println("使用缓存了");}return address;}
}

@Configuration
public class RedisConfig {/*** redisTemplate 序列化使用的jdkSerializeable, 存储二进制字节码, 所以自定义序列化类* @param redisConnectionFactory* @return*/@Beanpublic RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();redisTemplate.setConnectionFactory(redisConnectionFactory);// 使用Jackson2JsonRedisSerialize 替换默认序列化Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);ObjectMapper objectMapper = new ObjectMapper();objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);jackson2JsonRedisSerializer.setObjectMapper(objectMapper);// 设置value的序列化规则和 key的序列化规则redisTemplate.setKeySerializer(new StringRedisSerializer());redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);redisTemplate.afterPropertiesSet();return redisTemplate;}
}

  redis:cluster:master: myMasternodes: 192.168.65.128:6379,192.168.65.128:6380,192.168.65.128:6381,192.168.65.128:6382,192.168.65.128:6383,192.168.65.128:6384timeout: 0

@Configuration
public class RedisConfig {@Value("${spring.redis.cluster.nodes}")private String clusterNodes;@Value("${spring.redis.timeout}")private int timeout;@Beanpublic JedisCluster getJedisCluster() {String[] cNodes = clusterNodes.split(",");Set<HostAndPort> nodes = new HashSet<HostAndPort>();// 分割出集群节点for (String node : cNodes) {String[] hp = node.split(":");nodes.add(new HostAndPort(hp[0],Integer.parseInt(hp[1])));}// 创建集群对象
//      JedisCluster jedisCluster = new JedisCluster(nodes,commandTimeout);JedisCluster jedisCluster = new JedisCluster(nodes);return jedisCluster;}}

package com.liqiang.utils;import com.fasterxml.jackson.databind.JsonSerializable;
import org.apache.tomcat.util.buf.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.SerializationUtils;
import redis.clients.jedis.JedisCluster;
import tk.mybatis.mapper.util.StringUtil;import java.io.Serializable;
import java.lang.reflect.ParameterizedType;
import java.util.LinkedHashMap;
import java.util.Map;@Component
public class RedisUtil {protected int DEFAULT_EXPIRED_TIME_SECONDS_OBJECT = 1296000;@Autowiredprivate JedisCluster jedisCluster;public boolean putString(String sKey, String sValue, int expiredInSeconds) {boolean result = false;if (StringUtil.isEmpty(sKey)) {return result;}if (this.jedisCluster != null) {this.jedisCluster.set(sKey, sValue);if (expiredInSeconds > 0) {this.jedisCluster.expire(sKey, expiredInSeconds);}result = true;}return result;}public boolean putString(String sKey, String sValue) {return putString(sKey, sValue, this.DEFAULT_EXPIRED_TIME_SECONDS_OBJECT);}public String getString(String sKey) {String result = null;if (StringUtil.isEmpty(sKey)) {return result;}if (this.jedisCluster != null) {result = this.jedisCluster.get(sKey);}return result;}public boolean putObject(String sKey, Serializable object, int expiredInSeconds) {boolean result = false;if (StringUtil.isEmpty(sKey)) {return result;}if (this.jedisCluster != null) {byte[] datas = SerializationUtils.serialize(object);byte[] arrKey = sKey.getBytes();this.jedisCluster.set(arrKey, datas);if (expiredInSeconds > 0) {this.jedisCluster.expire(arrKey, expiredInSeconds);}result = true;}return result;}public boolean putObject(String sKey, Serializable object) {return putObject(sKey, object, this.DEFAULT_EXPIRED_TIME_SECONDS_OBJECT);}public <T> T getObject(String sKey, Class<T> oclass) {Object result = null;if (StringUtil.isEmpty(sKey)) {return null;}System.out.println(sKey);if (this.jedisCluster != null) {byte[] arrKey = sKey.getBytes();byte[] datas = this.jedisCluster.get(arrKey);if ((datas != null) && (datas.length > 0)) {result = SerializationUtils.deserialize(datas);}}System.out.println("dddd");System.out.println(result);return (T) result;}public boolean putMap(String sKey, Map<String, String> oMap, int expiredInSeconds) {boolean result = false;if ((StringUtil.isEmpty(sKey)) || (oMap == null) || (oMap.size() <= 0)) {return result;}if (this.jedisCluster != null) {this.jedisCluster.hmset(sKey, oMap);if (expiredInSeconds > 0) {this.jedisCluster.expire(sKey, expiredInSeconds);}result = true;}return result;}public boolean putMap(String sKey, Map<String, String> oMap) {return putMap(sKey, oMap, this.DEFAULT_EXPIRED_TIME_SECONDS_OBJECT);}public boolean putMap(String sKey, String sField, String sValue, int expiredInSeconds) {boolean result = false;if ((StringUtil.isEmpty(sKey)) || (StringUtil.isEmpty(sField))) {return result;}if (this.jedisCluster != null) {this.jedisCluster.hset(sKey, sField, sValue);if (expiredInSeconds > 0) {this.jedisCluster.expire(sKey, expiredInSeconds);}result = true;}return result;}public boolean putMap(String sKey, String sField, String sValue) {return putMap(sKey, sField, sValue, this.DEFAULT_EXPIRED_TIME_SECONDS_OBJECT);}public Map<String, String> getMap(String sKey) {Map result = null;if (StringUtil.isEmpty(sKey)) {return result;}if (this.jedisCluster != null) {result = this.jedisCluster.hgetAll(sKey);}return result;}public Map<String, String> getMap(String sKey, String[] fields) {Map result = null;Map mapAll = getMap(sKey);if ((mapAll != null) && (mapAll.size() > 0) && (fields != null) && (fields.length > 0)) {result = new LinkedHashMap();for (String field : fields) {result.put(field, mapAll.get(field));}}return result;}public boolean existsMapItem(String sKey, String sField) {if ((StringUtil.isEmpty(sKey)) || (StringUtil.isEmpty(sField))) {return false;}if (this.jedisCluster != null) {return this.jedisCluster.hexists(sKey, sField).booleanValue();}return false;}public boolean putMapValueAsObject(String sKey, String sField, Serializable oValue, int expiredInSeconds) {boolean result = false;if ((StringUtil.isEmpty(sKey)) || (StringUtil.isEmpty(sField))) {return result;}if (this.jedisCluster != null) {byte[] arrKey = sKey.getBytes();this.jedisCluster.hset(arrKey, sField.getBytes(), SerializationUtils.serialize(oValue));if (expiredInSeconds > 0) {this.jedisCluster.expire(arrKey, expiredInSeconds);}result = true;}return result;}public boolean putMapValueAsObject(String sKey, String sField, Serializable oValue) {return putMapValueAsObject(sKey, sField, oValue, this.DEFAULT_EXPIRED_TIME_SECONDS_OBJECT);}public <T> T getMapValueAsObject(String sKey, String sField, Class<T> oClass) {Object result = null;if ((StringUtil.isEmpty(sKey)) || (StringUtil.isEmpty(sField))) {return null;}if (this.jedisCluster != null) {byte[] datas = this.jedisCluster.hget(sKey.getBytes(), sField.getBytes());if ((datas != null) && (datas.length > 0)) {Object tmpObject = SerializationUtils.deserialize(datas);result = tmpObject;}}return (T) result;}public void remove(String sKey) {if (StringUtil.isEmpty(sKey)) {return;}if (this.jedisCluster != null)this.jedisCluster.del(sKey);}}