Redis:4.0.9
SpringBoot:2.0.1
Redis安装：Linux(Redhat)安装Redis
二、SpringBoot整合Redis1、项目基本搭建：
我们基于（五）SpringBoot2.0基础篇- Mybatis与插件生成代码 该项目来做Redis整合；
2、添加maven相关依赖和Redis的连接信息：
Pom.xml
org.springframework.boot spring-boot-starter-redis1.4.7.RELEASE com.alibaba fastjson1.2.28 org.springframework.boot spring-boot-starter-aop
application.properties:
spring.redis.cluster.nodes=192.168.1.124:7001
3、创建RedisProperties属性类和RedisConfig配置类，将JedisCluster放入Spring容器中：
RedisConfigurationProperties:
package com.cn.common.redis;import java.util.ArrayList;import java.util.List;import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.context.annotation.Configuration;@Configuration
@ConfigurationProperties(prefix = "spring.redis.cluster")public class RedisConfigurationProperties { private List nodes = new ArrayList<>(); public List getNodes() { return nodes;
} public void setNodes(List nodes) { this.nodes = nodes;
}
} RedisConfig:
package com.cn.common.redis;import java.util.HashSet;import java.util.Set;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import redis.clients.jedis.HostAndPort;import redis.clients.jedis.JedisCluster;@Configurationpublic class RedisConfig {
@Autowired private RedisConfigurationProperties redisConfigurationProperties;
@Bean public JedisCluster jedisCluster() {
Set nodeSet = new HashSet<>(); for(String node :redisConfigurationProperties.getNodes()) {
String[] split = node.split(":");
nodeSet.add(new HostAndPort(split[0],Integer.valueOf(split[1])));
} return new JedisCluster(nodeSet);
}
} 4、创建封装Redis的增删改查（JedisService,JedisServiceImpl）：
package com.cn.common.service;import java.util.List;import java.util.Map;import redis.clients.jedis.GeoRadiusResponse;public interface JedisService {
boolean exists(String key);
String set(String key,String value,int seconds);
String getSet(String key,String value, int seconds);
String get(String key);
Long geoadd(String key,double longitude,double latitude,byte[] obj);
List georadius(String key,double longitude,double latitude);
void delKey(String key);
void delNativeKey(String key);
Map getMapData(String key);
boolean lock(String key,int seconds);
void unlock(String key);
String getLocakValue(String key);
} JedisService.java
package com.cn.common.service;import com.alibaba.fastjson.JSON;import java.util.List;import java.util.Map;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Service;import redis.clients.jedis.GeoRadiusResponse;import redis.clients.jedis.JedisCluster;@Servicepublic class JedisServiceImpl implements JedisService {
@Autowired private JedisCluster jedisCluster;
@Override public boolean exists(String key) { boolean flag = false;
flag = jedisCluster.exists(key); return flag;
}
@Override public String set(String key, String value, int seconds) {
String responseResult = jedisCluster.set(key,value); if(seconds!=0)
jedisCluster.expire(key,seconds); return responseResult;
}
@Override public String getSet(String key, String value, int seconds) {
String jedisClusterSet = jedisCluster.getSet(key, value);
jedisCluster.expire(key,seconds); return jedisClusterSet;
}
@Override public String get(String key) {
String str = jedisCluster.get(key); return str;
}
@Override public Long geoadd(String key, double longitude, double latitude, byte[] obj) { return null;
}
@Override public List georadius(String key, double longitude, double latitude) { return null;
}
@Override public void delKey(String key) {
jedisCluster.del(key);
}
@Override public void delNativeKey(String key) {
jedisCluster.del(key);
}
@Override public Map getMapData(String key) {
String str = jedisCluster.get(key);
Map map = JSON.parseObject(str, Map.class); return map;
}
@Override public boolean lock(String key, int seconds) { if(jedisCluster.incr(key)==1) {
jedisCluster.expire(key,seconds); return false;
} return true;
}
@Override public void unlock(String key) {
jedisCluster.del(key);
}
@Override public String getLocakValue(String key) { return jedisCluster.get(key);
}
} JedisServiceImpl.java
5、创建注解类和切面类（我使用注解来实现缓存的set和get）:
RedisCache:
package com.cn.common.redis;import java.lang.annotation.documented;import java.lang.annotation.ElementType;import java.lang.annotation.Retention;import java.lang.annotation.RetentionPolicy;import java.lang.annotation.Target;@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD,ElementType.TYPE})
@documentedpublic @interface RedisCache {
Class type();
int cacheTime() default 600;
}RedisCacheAspect:
package com.cn.common.redis;import com.alibaba.fastjson.JSON;import com.cn.common.service.JedisService;import java.lang.reflect.Method;import org.aspectj.lang.ProceedingJoinPoint;import org.aspectj.lang.Signature;import org.aspectj.lang.annotation.Around;import org.aspectj.lang.annotation.Aspect;import org.aspectj.lang.annotation.Pointcut;import org.aspectj.lang.reflect.MethodSignature;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Component;@Aspect
@Componentpublic class RedisCacheAspect { private Logger logger = LoggerFactory.getLogger(this.getClass());
@Autowired private JedisService jedisService;
@Pointcut("execution(public * com.cn.service..*.*(..))") public void webAspect(){}
@Around("webAspect()") public Object redisCache(ProceedingJoinPoint pjp) throws Throwable { //得到类名、方法名和参数
String redisResult = "";
String className = pjp.getTarget().getClass().getName();
String methodName = pjp.getSignature().getName();
Object[] args = pjp.getArgs(); //根据类名，方法名和参数生成key
String key = genKey(className,methodName,args);
logger.info("生成的key[{}]",key); //得到被代理的方法
Signature signature = pjp.getSignature(); if(!(signature instanceof MethodSignature)){ throw new IllegalArgumentException();
}
MethodSignature methodSignature = (MethodSignature) signature;
Method method = pjp.getTarget().getClass().getMethod(methodSignature.getName(),methodSignature.getParameterTypes()); //得到被代理的方法上的注解
Class modelType = method.getAnnotation(RedisCache.class).type(); int cacheTime = method.getAnnotation(RedisCache.class).cacheTime();
Object result = null; if(!jedisService.exists(key)) {
logger.info("缓存未命中"); //缓存不存在，则调用原方法，并将结果放入缓存中
result = pjp.proceed(args);
redisResult = JSON.toJSonString(result);
jedisService.set(key,redisResult,cacheTime);
} else{ //缓存命中
logger.info("缓存命中");
redisResult = jedisService.get(key); //得到被代理方法的返回值类型
Class returnType = method.getReturnType();
result = JSON.parseObject(redisResult,returnType);
} return result;
}
private String genKey(String className, String methodName, Object[] args) {
StringBuilder sb = new StringBuilder("SpringBoot:");
sb.append(className);
sb.append("_");
sb.append(methodName);
sb.append("_"); for (Object object: args) {
logger.info("obj:"+object); if(object!=null) {
sb.append(object+"");
sb.append("_");
}
} return sb.toString();
}
}6、在StudentServiceImpl中加入缓存注释：
StudentServiceImpl:
package com.cn.service;import com.cn.common.redis.RedisCache;import com.cn.entity.Student;import com.cn.mapper.StudentMapper;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Service;@Servicepublic class StudentServiceImpl implements StudentService{
@Autowired private StudentMapper studentMapper;
@Override
@RedisCache(type = Student.class) public Student getStudentByPrimaryKey(int id) { return studentMapper.selectByPrimaryKey(id);
}
}7、启动测试:
第一次调用：
查看控制台：
第二次调用：
查看控制台：
发现第二次未打印出MyBatis的查询日志，并且显示缓存命中，通过RedisDeskManager工具查看Redis缓存：
实例代码：https://gitee.com/lfalex/spring-boot-example/tree/dev/spring-boot-mybatis-redis
原文出处
