（六）SpringBoot2.0基础篇- Redis整合（JedisCluster集群连接）

2023-01-06 10:36:13

一、环境

　　Redis:4.0.9

　　SpringBoot:2.0.1

　　Redis安装：Linux(Redhat)安装Redis

二、SpringBoot整合Redis

　　1、项目基本搭建：

　　　　我们基于（五）SpringBoot2.0基础篇- Mybatis与插件生成代码该项目来做Redis整合；

　　2、添加maven相关依赖和Redis的连接信息：

　　　　Pom.xml

    <!-- Redis的依赖库 -->

    <dependency>

      <groupId>org.springframework.boot</groupId>

      <artifactId>spring-boot-starter-redis</artifactId>

      <version>1.4.7.RELEASE</version>

    </dependency>

    <!-- fastJson 依赖库 -->

    <dependency>

      <groupId>com.alibaba</groupId>

      <artifactId>fastjson</artifactId>

      <version>1.2.28</version>

    </dependency>

    <!-- aop依赖库-->

    <dependency>

      <groupId>org.springframework.boot</groupId>

      <artifactId>spring-boot-starter-aop</artifactId>

    </dependency>

　　　　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;

/**

 * @program: spring-boot-example

 * @description:

 * @author:

 * @create: 2018-05-16 15:15

 **/

@Configuration

@ConfigurationProperties(prefix = "spring.redis.cluster")

public class RedisConfigurationProperties {

    private List<String> nodes = new ArrayList<>();

    public List<String> getNodes() {

        return nodes;

    }

    public void setNodes(List<String> 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;

/**

 * @program: spring-boot-example

 * @description: Redis的配置文件

 * @author:

 * @create: 2018-05-16 15:01

 **/

@Configuration

public class RedisConfig {

    @Autowired

    private RedisConfigurationProperties redisConfigurationProperties;

    @Bean

    public JedisCluster jedisCluster() {

        Set<HostAndPort> 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;

/**

 * @program: spring-boot-example

 * @description:

 * @author:

 * @create: 2018-05-16 15:27

 **/

public interface JedisService {

    /**

     * @Description: 是否存在

     * @Param:

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    boolean exists(String key);

    /**

     * @Description:缓存set值

     * @Param:  seconds:缓存时间，不设置则为0

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    String set(String key,String value,int seconds);

    /**

     * @Description:  重新缓存getSet值

     * @Param:

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    String getSet(String key,String value, int seconds);

    /**

     * @Description: 获取set值

     * @Param:

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    String get(String key);

    /**

     * @Description: 添加地理位置

     * @Param:

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    Long geoadd(String key,double longitude,double latitude,byte[] obj);

    /**

     * @Description: 地理位置查询

     * @Param:

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    List<GeoRadiusResponse> georadius(String key,double longitude,double latitude);

    /**

     * @Description: 删除key

     * @Param:

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    void delKey(String key);

    /**

     * @Description: 删除native key

     * @Param:

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    void delNativeKey(String key);

    /**

     * @Description: 获取map格式的数据

     * @Param:

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    Map<String ,Object> getMapData(String key);

    /**

     * @Description: 加锁，避免重复提交

     * @Param:

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    boolean lock(String key,int seconds);

    /**

     * @Description: 解锁

     * @Param:

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    void unlock(String key);    

    /**

     * @Description: 统计锁定次数

     * @Param:

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    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;

/**

 * @program: spring-boot-example

 * @description:

 * @author:

 * @create: 2018-05-16 15:45

 **/

@Service

public 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<GeoRadiusResponse> 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<String, Object> getMapData(String key) {

        String str = jedisCluster.get(key);

        Map<String,Object> map = JSON.parseObject(str, Map.class);

        return map;

    }

    /**

     * @Description: 如为第一次，则加上锁，每次调用值会自动加1

     * @Param:

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    @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;

/**

 * @Description: 加上该注解，代理service命中缓存则从缓存中读取数据，否则从service业务逻辑获得，并存入缓存

 * @Param:

 * @return:

 * @Author:

 * @Date: 2018/5/16

 */

@Retention(RetentionPolicy.RUNTIME)

@Target({ElementType.METHOD,ElementType.TYPE})

@Documented

public @interface RedisCache {

    /**

     * @Description: 数据返回类型

     * @Param:

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    Class type();

    /**

     * @Description: 数据缓存时间单位s秒

     * @Param:  默认10分钟

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    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;

/**

 * @program: spring-boot-example

 * @description:

 * @author:

 * @create: 2018-05-16 16:29

 **/

@Aspect

@Component

public 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;

    }

    /**

     * @Description: 生成key

     * @Param:

     * @return:

     * @Author:

     * @Date: 2018/5/16

     */

    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;

/**

 * @program: spring-boot-example

 * @description:

 * @author:

 * @create: 2018-05-11 10:55

 **/

@Service

public class StudentServiceImpl implements StudentService{

    @Autowired

    private StudentMapper studentMapper;

    @Override

    @RedisCache(type = Student.class)

    public Student getStudentByPrimaryKey(int id) {

        return studentMapper.selectByPrimaryKey(id);

    }

}