1.使用Spring管理Redis
我们知道在Jedis在处理Redis单机和集群版的时候是不同的。有可能在我们个人测试开发的时候使用的是单机版，项目上用的是集群版。这就需要我们能够自由的切换。为了方便，我们定义一个接口类，然后新建两个实现类来分别代表单机版和集群版，最后在Spring中配置管理
image.png
Jedis接口
/**
* jedis的接口
*/
public interface JedisClient {
String set(String key, String value);
String get(String key);
Boolean exists(String key);
Long expire(String key, int seconds);
Long ttl(String key);
Long incr(String key);
Long hset(String key, String field, String value);
String hget(String key, String field);
Long hdel(String key, String... field);
}
单机版
public class JedisClientPool implements JedisClient {
@Autowired
private JedisPool jedisPool;
@Override
public String set(String key, String value) {
Jedis jedis = jedisPool.getResource();
String result = jedis.set(key, value);
jedis.close();
return result;
}
@Override
public String get(String key) {
Jedis jedis = jedisPool.getResource();
String result = jedis.get(key);
jedis.close();
return result;
}
@Override
public Boolean exists(String key) {
Jedis jedis = jedisPool.getResource();
Boolean result = jedis.exists(key);
jedis.close();
return result;
}
@Override
public Long expire(String key, int seconds) {
Jedis jedis = jedisPool.getResource();
Long result = jedis.expire(key, seconds);
jedis.close();
return result;
}
@Override
public Long ttl(String key) {
Jedis jedis = jedisPool.getResource();
Long result = jedis.ttl(key);
jedis.close();
return result;
}
@Override
public Long incr(String key) {
Jedis jedis = jedisPool.getResource();
Long result = jedis.incr(key);
jedis.close();
return result;
}
@Override
public Long hset(String key, String field, String value) {
Jedis jedis = jedisPool.getResource();
Long result = jedis.hset(key, field, value);
jedis.close();
return result;
}
@Override
public String hget(String key, String field) {
Jedis jedis = jedisPool.getResource();
String result = jedis.hget(key, field);
jedis.close();
return result;
}
@Override
public Long hdel(String key, String... field) {
Jedis jedis = jedisPool.getResource();
Long result = jedis.hdel(key, field);
jedis.close();
return result;
}
}
集群版：
public class JedisClientCluster implements JedisClient {
@Autowired
private JedisCluster jedisCluster;
@Override
public String set(String key, String value) {
return jedisCluster.set(key, value);
}
@Override
public String get(String key) {
return jedisCluster.get(key);
}
@Override
public Boolean exists(String key) {
return jedisCluster.exists(key);
}
@Override
public Long expire(String key, int seconds) {
return jedisCluster.expire(key, seconds);
}
@Override
public Long ttl(String key) {
return jedisCluster.ttl(key);
}
@Override
public Long incr(String key) {
return jedisCluster.incr(key);
}
@Override
public Long hset(String key, String field, String value) {
return jedisCluster.hset(key, field, value);
}
@Override
public String hget(String key, String field) {
return jedisCluster.hget(key, field);
}
@Override
public Long hdel(String key, String... field) {
return jedisCluster.hdel(key, field);
}
}
在spring配置文件中配置
applicationContext-redis.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
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-4.2.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd">
<!-- 配置包扫描器，扫描所有带@Service注解的类 -->
<context:component-scan base-package="com.taotao.jedis"/>
<!--redis单机版-->
<!--<bean id="jedisPool" class="redis.clients.jedis.JedisPool">-->
<!--<constructor-arg name="host" value="192.168.208.50"></constructor-arg>-->
<!--<constructor-arg name="port" value="6379"></constructor-arg>-->
<!--</bean>-->
<!--<bean id="jedisClientPool" class="com.taotao.jedis.JedisClientPool"></bean>-->
<!--集群版-->
<bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
<constructor-arg>
<set>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.208.50"></constructor-arg>
<constructor-arg name="port" value="7001"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.208.50"></constructor-arg>
<constructor-arg name="port" value="7002"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.208.50"></constructor-arg>
<constructor-arg name="port" value="7003"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.208.50"></constructor-arg>
<constructor-arg name="port" value="7004"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.208.50"></constructor-arg>
<constructor-arg name="port" value="7005"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.208.50"></constructor-arg>
<constructor-arg name="port" value="7006"></constructor-arg>
</bean>
</set>
</constructor-arg>
</bean>
<bean class="com.taotao.jedis.JedisClientCluster" id="jedisClientCluster"></bean>
</beans>
测试代码：
public class TestJedisSpring {
@Test
public void TestJedisClient(){
//初始化容器
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-redis.xml");
//从容器中获得JedisClient对象
JedisClient jedisClient = applicationContext.getBean(JedisClient.class);
jedisClient.set("testSpringJedisClient","test-spring-jedisClient");
String value = jedisClient.get("testSpringJedisClient");
System.out.println(value);
//对redis进行操作
}
如果我们想用单机版的话就把集群版注释掉，要用单机版就把集群版的注解掉。这样我们的业务代码完全不用改。非常方便！
2.在业务中使用Redis
Redis添加缓存的方式有两种，一种是set，一种是hset我们一般用的是第二种，因为查询效率更高
功能分析
查询内容列表时添加缓存。
1、查询数据库之前先查询缓存。
2、查询到结果，直接响应结果。
3、查询不到，缓存中没有需要查询数据库。
4、把查询结果添加到缓存中。
5、返回结果。
我们修改taotao-content-service工程下的ContentServiceImpl.java中的getContentListByCid方法。下面是实现的代码：
//获取首页大广告
@Override
public List<TbContent> getContentListByCid(long cid) {
try{
//在缓存中查看有没有已经缓存的数据
String json = jedisClient.hget(INDEX_CONTENT,cid + "");
//查询到结果，把json转换成List返回
if(StringUtils.isNotBlank(json)) {
List<TbContent> list = JsonUtils.jsonToList(json,TbContent.class);
return list;
}
}catch(Exception e) {
e.printStackTrace();
}
//没有设置缓存的时候正常查询
TbContentExample example = new TbContentExample();
TbContentExample.Criteria criteria = example.createCriteria();
criteria.andCategoryIdEqualTo(cid);
List<TbContent> list = tbContentMapper.selectByExample(example);
//查询以后将结果放进缓存中
try{
jedisClient.hset(INDEX_CONTENT,cid + "",JsonUtils.objectToJson(list));
}catch(Exception e) {
e.printStackTrace();
}
//返回结果
return list;
}
PS：
我们在做缓存的时候会有个问题，如果我们新增一个大广告的内容的话。因为缓存的内容是之前的，而且我们没有做同步更新，因此内容会一直是以前的。这就需要我们做一个同步缓存，凡是涉及增，删，改的操作都需要做同步缓存。
public TaotaoResult addContent(TbContent tbContent) {
tbContent.setCreated(new Date());
tbContent.setUpdated(new Date());
tbContentMapper.insert(tbContent);
//同步缓存
//删除对应的缓存信息
//下次同步的时候是最新的数据
jedisClient.hdel(INDEX_CONTENT, tbContent.getCategoryId().toString());
return TaotaoResult.ok();
}
效果如下：
image.png
