16-1 Redis分布式缓存引入与保存缓存功能实现

r囧r小猫 2021-11-05 19:26 245阅读 0赞

现在功能已经完成了，但是我们还是要考虑一下性能问题，现在任何请求都是要到数据库中查询很多的数据，才能知道当前的用户是否有权限可以访问当前的url，当我们的请求量很大时，它对我们数据库的请求量也是非常大的，这时，我们就会想到对我们的权限进行缓存，

这里就讲一下权限的缓存如何进行，

这里使用的是redis

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70][]

<?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">
    
    
    
        <context:property-placeholder location="classpath:redis.properties" />
    
    
        <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig" />
    
    
        <bean id="shardedJedisPool" class="redis.clients.jedis.ShardedJedisPool" scope="singleton" >
    
            <constructor-arg index="0" ref="jedisPoolConfig" />
            <constructor-arg index="1">
                <list>
    
                    <bean class="redis.clients.jedis.JedisShardInfo">
                        <constructor-arg name="host" value="${redis.host}"/>
                        <constructor-arg name="port" value="${redis.port}"/>
                        <constructor-arg name="timeout" value="${redis.timeout}"/>
                    </bean>
                </list>
            </constructor-arg>
        </bean>
    
    </beans>

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 1][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 2][]

redis.host=127.0.0.1
    redis.port=6379
    redis.timeout=3000

\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 3][]

package com.mmall.service;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.stereotype.Service;
    import redis.clients.jedis.ShardedJedis;
    import redis.clients.jedis.ShardedJedisPool;
    
    import javax.annotation.Resource;
    
    
    
    //  封装一下radis
    @Service("redisPool")//加注释让spring来管理
    @Slf4j
    public class RedisPool {
    
    //    使用刚刚定义的spring管理的类radis
        @Resource(name = "shardedJedisPool")//直接调用radis了  单例的serviece
        private ShardedJedisPool shardedJedisPool;
    
        //返回单例的实例
        public ShardedJedis instance() {
            return shardedJedisPool.getResource();
        }
    
        //安全关闭的方法
        public void safeClose(ShardedJedis shardedJedis) {
            try {
               if (shardedJedis != null) {
                   shardedJedis.close();
               }
            } catch (Exception e) {
                log.error("return redis resource exception", e);
            }
        }
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 4][]

package com.mmall.service;
    
    import com.google.common.base.Joiner;
    import com.mmall.beans.CacheKeyConstants;
    import com.mmall.util.JsonMapper;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.stereotype.Service;
    import redis.clients.jedis.ShardedJedis;
    
    import javax.annotation.Resource;
    
    @Service
    @Slf4j
    public class SysCacheService {
    
        //引用刚定义的reaispool
        @Resource(name = "redisPool")
        private RedisPool redisPool;
    
        /**
         *
         * @param toSavedValue   要保存的值
         * @param timeoutSeconds   要保存多少秒
         * @param prefix   前缀 自定义
         */
        public void saveCache(String toSavedValue, int timeoutSeconds, CacheKeyConstants prefix) {
            //调用下面的方法
            saveCache(toSavedValue, timeoutSeconds, prefix, null);
        }
    
        //保存cache
        public void saveCache(String toSavedValue, int timeoutSeconds, CacheKeyConstants prefix, String... keys) {
            if (toSavedValue == null) {
                return;
            }
            ShardedJedis shardedJedis = null;
            //网络连接可能会有问题 try catch
            try {
                //1.生成对应的key
                String cacheKey = generateCacheKey(prefix, keys);//拼接key  系统所有权限大家一样  但是单个用户权限大家不一样
                //2.拿到资源
                shardedJedis = redisPool.instance();//单例获取redis
                //提供好的方法处理  一定要写radis 的api
                shardedJedis.setex(cacheKey, timeoutSeconds, toSavedValue);
            } catch (Exception e) {
                log.error("save cache exception, prefix:{}, keys:{}", prefix.name(), JsonMapper.obj2String(keys), e);
            } finally {
                //别忘了释放radis
                redisPool.safeClose(shardedJedis);
            }
        }
    
        //获取cache
        //  参数  前缀    key
        public String getFromCache(CacheKeyConstants prefix, String... keys) {
            ShardedJedis shardedJedis = null;
            String cacheKey = generateCacheKey(prefix, keys);//拼接key  系统所有权限大家一样  但是单个用户权限大家不一样
            try {
                shardedJedis = redisPool.instance();//单例获取redis
                String value = shardedJedis.get(cacheKey);//获取值
                return value;//返回值
            } catch (Exception e) {
                log.error("get from cache exception, prefix:{}, keys:{}", prefix.name(), JsonMapper.obj2String(keys), e);
                return null;
            } finally {
                //别忘了释放radis
                redisPool.safeClose(shardedJedis);
            }
        }
    
        private String generateCacheKey(CacheKeyConstants prefix, String... keys) {
            String key = prefix.name();
            //多个string可以进行拼接
            if (keys != null && keys.length > 0) {
                key += "_" + Joiner.on("_").join(keys);
            }
            return key;
        }
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 5][]

package com.mmall.beans;
    
    import lombok.Getter;
    
    @Getter
    public enum CacheKeyConstants {
    
        SYSTEM_ACLS,//缓存系统内的所有权限
    
        USER_ACLS;//缓存用户的权限
    
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 6][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 7][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 8][]

//从缓存中获取数据
        public List<SysAcl> getCurrentUserAclListFromCache() {
            //userId
            int userId = RequestHolder.getCurrentUser().getId();
            //通过key获取value
            String cacheValue = sysCacheService.getFromCache(CacheKeyConstants.USER_ACLS, String.valueOf(userId));
            if (StringUtils.isBlank(cacheValue)) {
                //为空说明出问题了  重新获取一次
                List<SysAcl> aclList = getCurrentUserAclList();
                if (CollectionUtils.isNotEmpty(aclList)) {
                    //重新保存   value    600s有效期       key的值（前缀和userid）
                    sysCacheService.saveCache(JsonMapper.obj2String(aclList), 600, CacheKeyConstants.USER_ACLS, String.valueOf(userId));
                }
                return aclList;//没从cache中获取到值从数据库取出来
            }
            //缓存中有
            return JsonMapper.string2Obj(cacheValue, new TypeReference<List<SysAcl>>() {
            });
        }
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 9][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 10][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 11][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 12][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 13][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 14][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 15][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 16][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 17][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 18][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 19][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 20][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 21][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 22][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 23][]

不是每个方法都要缓存的

有些必须是实时数据不就不能进行缓存

不需要进行特别多的数据访问  就不要缓存

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70]: /images/20211104/4e906766eb734ad69ebd9e85c444f478.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 1]: /images/20211104/ff32435a6ff94b44afd0828483c9fc99.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 2]: /images/20211104/459d52568a7447088d1e587244e74c26.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 3]: /images/20211104/f68ea086784a414f950e29239601bdc4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 4]: /images/20211104/b7059ac63d654594bfea2d5bb0453d98.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 5]: /images/20211104/ceedd3b227db417a9685bbef00c2c7c3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 6]: /images/20211104/76d310a38f6541a49b745a9d98f7b8ef.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 7]: /images/20211104/8d95036f8a724871a179c7ad7f8c839b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 8]: /images/20211104/8a2cabf5995642ee885e23805ce66ac6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 9]: /images/20211104/829c5603f649493485b01a688c1a0b0a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 10]: /images/20211104/fe1046abf163461688fd07e947700f77.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 11]: /images/20211104/434b8644647948d3b208a5c3c06ce902.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 12]: /images/20211104/9e1747a5c3e94602af0813663eb6d307.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 13]: /images/20211104/2ca9945173d44a58b8271fb0447092fd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 14]: /images/20211104/048ecfe8bc2849b79c374d935730ac67.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 15]: /images/20211104/199a14548c174fbbbc213a5cb1069677.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 16]: /images/20211104/5793a5ab776b450999f6eb43be878a37.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 17]: /images/20211104/d82177cbb77d4b20bc5cdbf17c769029.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 18]: /images/20211104/70cff9f4d4da420488eb642d9ec75226.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 19]: /images/20211104/fccb10ca94f845aea4f2f06850c051ab.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 20]: /images/20211104/4b96d0bac8fa4d47bfc8942a0308119c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 21]: /images/20211104/1ff662a1eeab402d8cf77bec2094d6e8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 22]: /images/20211104/40b9a00aa91d465584275e697c8b9c7e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3MzI3MjYx_size_16_color_FFFFFF_t_70 23]: /images/20211104/f3e347ee0193456cb6a8f5797473eb29.png