推荐学习

• 撸了35天，奉上最强干货“全家桶”之Spring系列
• 缓存架构技术：Redis+MongDB，阿里P7面试必跳的坑

一、引言

之前提过把这个redis单机版整合到spring容器中去了，同时大家也应该知道怎么用java连接redis服务了吧。那我们redis在项目充当什么角色呢？ 打个比方，一个商城的首页，每一个客户端去访问该商城，商城所有的数据(包括 商品分类、商品列表、一些广告之类的)这些数据都是需要从数据库中去读取的。如果访问的人数很大，那是不是给我们的数据库造成的压力就非常大。这个时候redis就登场了，只需要去数据库中查询一遍，然后放入redis当中，后期只需要从redis取数据即可。

二、思路构建

在我们实际开发调试中我们是使用redis单机版的，后期上线后可能需要切换到集群版，但是这两个可能写的代码稍微有一些区别。虽然两者有点区别，但是他们调用redis的方法都是一样的。我们可以写一个redis接口，然后定义一些redis常用的方法，然后单机版、集群版分别去实现这些方法。这样只需要在切换的时候，调用不同的实现类即可。

三、具体实现

1、redis方法定义，以下只是简单的几个方法，以下方法在之前的博客都是有说过的。

public interface JedisClient {
    String get(String key);
    String hget (String hkey,String key);
    String set(String key,String value);
    Long hset(String hkey ,String key,String value);
    Long incr(String key);
}

2、实现redis定义的方法，单机版为例，集群版后面再讲。JedisPool对象在之前文章已经整合到spring容器当中，需要调用只需要注入即可，没有密码可忽略auth方法。

public class JedisClientSingle implements JedisClient {
 
    //可以在配置文件中配置，或者写在代码里面都行
    private static String REDIS_PASSWORD = "123456";
 
    @Autowired
    private JedisPool jedisPool;
 
 
    @Override
    public String get(String key) {
        Jedis jedis = jedisPool.getResource();
        jedis.auth(REDIS_PASSWORD);
        String result = jedis.get(key);
        jedis.close();
        return result;
    }
 
    @Override
    public String hget(String hkey, String key) {
        Jedis jedis = jedisPool.getResource();
        jedis.auth(REDIS_PASSWORD);
        String result = jedis.hget(hkey,key);
        jedis.close();
        return result;
    }
 
    @Override
    public String set(String key, String value) {
        Jedis jedis = jedisPool.getResource();
        jedis.auth(REDIS_PASSWORD);
        String result = jedis.set(key,value);
        jedis.close();
        return result;
    }
 
    @Override
    public Long hset(String hkey, String key, String value) {
        Jedis jedis = jedisPool.getResource();
        jedis.auth(REDIS_PASSWORD);
        Long result = jedis.hset(hkey,key,value);
        jedis.close();
        return result;
    }
 
    @Override
    public Long incr(String key) {
        Jedis jedis = jedisPool.getResource();
        jedis.auth(REDIS_PASSWORD);
        Long result = jedis.incr(key);
        jedis.close();
        return result;
    }
}

3、添加到项目的业务逻辑中，比如我们在从数据库中查询某一些数据，我们可以先从redis读取，如果这些数据在redis已经存在，则直接把数据返回出去，不存在则查询数据库，然后添加到redis缓存中。

这里注意如果后台有修改数据参数，需要将存放在redis中的数据，清除掉。

@Service
public class ItemCatServiceImpl implements ItemCatService {
 
 
    private static String REDIS_SAVE_TYPE = "ITEMCAT";
 
    @Autowired
    private JedisClient jedisClient;
 
 
    @Override
    public CatResult getItemCat() {
        CatResult result = new CatResult();
        result.setData(getItemCatList(new Long(0)));
        return result;
    }
 
    /**
     * 获取商品分类
     * @param parentid
     * @return
     */
    public List<?> getItemCatList(Long parentid){
 
        //从缓存中读取商品分类
        List redisList = getRedisList(parentid);
        if(redisList != null){
            return redisList;
        }
 
        // 查询所需要的数据
        // 省略查询步骤，根据自己项目需求，这只是一个简单的dome
        
        //保存缓存
        setRedisList(parentid,JsonUtils.objectToJson(resultList));
 
        return resultList;
    }
 
 
    /**
     * 从缓存中读取商品分类
     * @param parentid
     * @return
     */
    public List getRedisList(Long parentid){
        try {
            String result = jedisClient.hget(REDIS_SAVE_TYPE,parentid+"");
            if(!StringUtils.isBlank(result)){
                List resultList = JsonUtils.jsonToPojo(result,ArrayList.class);
                return resultList;
            }
            else {
                return null;
            }
        }catch (Exception e){
            e.printStackTrace();
        }
        return null;
    }
 
    /**
     * 保存商品分类到redis中
     * @param parentid
     * @param value
     * @return
     */
    public Long setRedisList(Long parentid,String value){
        try {
            return jedisClient.hset(REDIS_SAVE_TYPE,parentid+"",value);
        }catch (Exception e){
            e.printStackTrace();
        }
        return null;
    }
}

4、既然我们项目当中需要用的jedisClient这个对象，所以我们需要将这个对象放入到spring容器中进行管理，只需要在配置文件中配置一下bean即可。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
 
    <!--连接池配置-->
    <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <!-- 最大连接数 -->
        <property name="maxTotal" value="100" />
        <!-- 最大空闲连接数 -->
        <property name="maxIdle" value="50" />
        <!-- 获取连接时的最大等待毫秒数,小于零:阻塞不确定的时间,默认-1 -->
        <property name="maxWaitMillis" value="1500" />
        <!-- 在获取连接的时候检查有效性, 默认false -->
        <property name="testOnBorrow" value="true" />
    </bean>
 
 
    <!-- reids baen 注入-->
    <bean id="redisClient" class="redis.clients.jedis.JedisPool" destroy-method="destroy"  depends-on="jedisPoolConfig">
        <!-- 加载jedisPool配置信息 -->
        <constructor-arg name="host" value="127.0.0.1"></constructor-arg>
        <constructor-arg name="port" value="6379"></constructor-arg>
        <constructor-arg name="poolConfig" ref="jedisPoolConfig" />
        <constructor-arg name="password" value="123456"/>
        <constructor-arg name="database" value="0"/>
        <constructor-arg name="timeout" value="2000"/>
    </bean>
 
    <bean id="JedisClient" class="cn.zgjkw.dplatform.own.code.redis.JedisClientSingle"></bean>
 
</beans>

作者：IT贱男

原文链接：https://jiannan.blog.csdn.net/article/details/82718626