前奏
工欲善其事必先利其器；预备一下工具对于整个环境的整合有极大的帮助
- linux环境中单例redis服务搭建，参考博客 centos7自学之7-redis-4.0.1单例服务器搭建
- redisDesktopManage redis可视化工具安装
- idea开发工具
开始
现如今，越来越多的公司注重用户对网站访问速度的体验。而缓存技术的出现无疑很好的适用以上场景。
因此掌握一门缓存技术对一名IT男无疑是必要的。
建项目
新建spring集成的web项目（spring-redis）-不用边看边做，后面会贴源码
添加配置文件
新建配置文件 redis.properties
#访问地址
redis.host=172.16.191.102
# redis.host=192.168.1.106
#访问端口
redis.port=6379
#授权密码，有没有这一项取决于要连接的redis服务是否设置了此项
redis.auth=123456
redis.dbIndex=0
#连接池的最大数据库连接数。设为0表示无限制
redis.maxIdle=1024
#最大空闲数，数据库连接的最大空闲时间。超过空闲时间，数据库连接将被标记为不可用，然后被释放。设为0表示无限制。
redis.maxActive=200
#最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。
redis.maxWait=10000
#在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；
redis.testOnBorrow=truespring集成redis配置文件
<context:property-placeholder location="classpath:properties/redis.properties" ignore-resource-not-found="true" />
<!--<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<list>
<value>classpath:properties/redis.properties</value>
</list>
</property>
</bean>-->
<!-- redis config start -->
<!-- 配置JedisPoolConfig实例 -->
<bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
<property name="maxIdle" value="${redis.maxIdle}" />
<property name="maxTotal" value="${redis.maxActive}" />
<property name="maxWaitMillis" value="${redis.maxWait}" />
<property name="testOnBorrow" value="${redis.testOnBorrow}" />
</bean>
<!-- 配置JedisConnectionFactory -->
<bean id="jedisConnectionFactory"
class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
<property name="hostName" value="${redis.host}" />
<property name="port" value="${redis.port}" />
<property name="password" value="${redis.auth}" />
<property name="database" value="${redis.dbIndex}" />
<property name="poolConfig" ref="poolConfig" />
</bean>
<!--
使用JDK提供的序列化功能。 优点是反序列化时不需要提供类型信息(class)，但缺点是序列化后的结果非常庞大，是JSON格式的5倍左右，这样就会消耗redis服务器的大量内存。
-->
<bean id="stringKeySerializer" class="org.springframework.data.redis.serializer.StringRedisSerializer"/>
<!--
JdkSerializationRedisSerializer，这个序列化方法是Idk提供的，
要求要被序列化的类继承自Serializeable接口，然后通过Jdk对象序列化的方法保存，
这个序列化保存的对象，即使是个String类型的，在redis控制台，也是看不出来的，
因为它保存了一些对象的类型什么的额外信息。
-->
<bean id="jdkSerializationRedisSerializer" class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>
<bean id="genericJackson2JsonRedisSerializer" class="org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer"/>
<!--
使用Jackson库将对象序列化为JSON字符串。优点是速度快，序列化后的字符串短小精悍。
但缺点也非常致命，那就是此类的构造函数中有一个类型参数，必须提供要序列化对象的类型信息(.class对象)。
通过查看源代码，发现其只在反序列化过程中用到了类型信息。
-->
<!--<bean id="jackson2JsonRedisSerializer" class="org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer">
<constructor-arg type="java.lang.Object" ></constructor-arg>
</bean>-->
<!-- 配置RedisTemplate -->
<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
<property name="connectionFactory" ref="jedisConnectionFactory" />
<!-- 如果不配置Serializer，那么存储的时候只能使用String，如果用对象类型存储，那么会提示错误 can't cast to String！！！-->
<property name="keySerializer" ref="stringKeySerializer"/>
<property name="hashKeySerializer" ref="stringKeySerializer"/>
<property name="valueSerializer" ref="genericJackson2JsonRedisSerializer"/>
<property name="hashValueSerializer" ref="genericJackson2JsonRedisSerializer"/>
</bean>
<!-- 配置StringRedisTemplate 下面的各种key都是stringKeySerializer序列化方式-->
<bean id="stringRedisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
<property name="connectionFactory" ref="jedisConnectionFactory" />
</bean>
<!-- redis config end -->redis增删改查
@Repository(value = "redisRepository")
public class RedisRepository extends AbstractSpringRedisCacheEnhance {
@Autowired
RedisTemplate<String, Object> redisTemplate;
@Override
public StringRedisTemplate getStringRedisTemplate() {
return null;
}
@Override
public RedisTemplate<String, Object> getRedisTemplate() {
return redisTemplate;
}
}此处增删改查写在了抽象类当中，具体代码上千行，有兴趣的可以访问我代码仓库查看（后面会附上仓库链接）
测试
编写测试类，测试增删改查api
@RunWith(SpringRunner.class)
@ContextConfiguration({"classpath*:/spring/applicationContext.xml"})
public class RedisRepositoryTest {
private Logger logger = LoggerFactory.getLogger(getClass());
@Autowired private RedisRepository redisRepository;
public Map<String, Object> generateMap(){
Map<String, Object> returnMap = new HashMap<>();
returnMap.put("aa", "aa");
Map<String, Object> innerMap = new HashMap<>();
innerMap.put("ss", 3);
innerMap.put("rr",false);
innerMap.put("tt","中文");
returnMap.put("bb", innerMap);
returnMap.put("cc", 1.000);
returnMap.put("dd", true);
returnMap.put("ee", 1);
return returnMap;
}
public List<Map<String, Object>> generateList(){
List<Map<String, Object>> list = new ArrayList<>();
for (int i = 0; i < 10; i++) {
list.add(generateMap());
}
return list;
}
@Test
public void clear(){
redisRepository.clear();
}
@Test
public void testSet(){
redisRepository.valueSet("name", "robot");
redisRepository.valueSet("name2", "robot", 1600, TimeUnit.SECONDS);
redisRepository.valueSet("set:map", generateMap());
redisRepository.valueSet("set:map", generateMap(), 1600, TimeUnit.SECONDS);
redisRepository.valueSet("set:list", generateList());
redisRepository.valueSet("set:list", generateList(), 1600, TimeUnit.SECONDS);
}
@Test
public void testGet(){
logger.info("{}", redisRepository.valueGet("name", false));
logger.info("{}", redisRepository.valueGet("name2", true));
logger.info("{}", redisRepository.valueGet("set:map", false));
logger.info("{}", redisRepository.valueGet("set:map", true));
logger.info("{}", redisRepository.valueGet("set:list", false));
logger.info("{}", redisRepository.valueGet("set:list", true));
//logger.info("{}", redisRepository.getAndSet("name", "new value",false));
//logger.info("{}", redisRepository.getAndSet("name", "new value",true));
}
@Test
public void testIncrement(){
for (int i = 0; i < 10; i++) {
logger.info("{}", redisRepository.valueIncrement("mobile:15911111111", 1l, 60, TimeUnit.MINUTES));
logger.info("{}", redisRepository.valueIncrement("tel:15911111111", 1.0, 70, TimeUnit.MINUTES));
}
}
@Test
public void testSetArray(){
for (int i = 0; i < 10; i++) {
logger.info("{}", redisRepository.setAdd("set:array1",i));
}
for (int i = 5; i < 20; i++) {
logger.info("{}", redisRepository.setAdd("set:array1",i));
logger.info("{}", redisRepository.setAdd("set:array2",i));
}
//logger.info("{}", redisRepository.setPop("set:array"));
logger.info("{}", redisRepository.setDifference("set:array1","set:array2"));
logger.info("{}", redisRepository.setDifferenceAndStore("set:array1","set:array2", "set:array3"));
logger.info("{}", redisRepository.setAdd("set:add:map",generateMap()));
logger.info("{}", redisRepository.setAdd("set:add:list",generateList()));
logger.info("{}", redisRepository.setPop("set:add:map"));
logger.info("{}", redisRepository.setPop("set:add:list"));
}
@Test
public void testList(){
for (int i = 0; i < 10; i++) {
logger.info("{}", redisRepository.listLeftPush("list:lilo:list", generateList()));
logger.info("{}", redisRepository.listLeftPush("list:liro:list", generateList()));
logger.info("{}", redisRepository.listRightPush("list:rilo:list", generateList()));
logger.info("{}", redisRepository.listRightPush("list:riro:list", generateList()));
}
for (int i = 0; i < 5; i++) {
logger.info("{}", redisRepository.listLeftPop("list:lilo:list"));
logger.info("{}", redisRepository.listRightPop("list:liro:list"));
logger.info("{}", redisRepository.listLeftPop("list:rilo:list"));
logger.info("{}", redisRepository.listRightPop("list:riro:list"));
}
for (int i = 0; i < 10; i++) {
logger.info("{}", redisRepository.listLeftPush("list:lilo:map", generateMap()));
logger.info("{}", redisRepository.listLeftPush("list:liro:map", generateMap()));
logger.info("{}", redisRepository.listRightPush("list:rilo:map", generateMap()));
logger.info("{}", redisRepository.listRightPush("list:riro:map", generateMap()));
}
for (int i = 0; i < 5; i++) {
logger.info("{}", redisRepository.listLeftPop("list:lilo:map"));
logger.info("{}", redisRepository.listRightPop("list:liro:map"));
logger.info("{}", redisRepository.listLeftPop("list:rilo:map"));
logger.info("{}", redisRepository.listRightPop("list:riro:map"));
}
}
@Test
public void testZSet(){
for (int i = 0; i < 10; i++) {
logger.info("{}", redisRepository.zSetAdd("zset:map", generateMap(), i));
}
redisRepository.zSetIncrementScore("zset:Map", "4", 30);
}
@Test
public void testHash(){
for (int i = 0; i < 10; i++) {
redisRepository.hashPut("hash:map", String.valueOf(i), generateMap());
logger.info("{}", redisRepository.hashGet("hash:map", String.valueOf(i)));
}
for (int i = 0; i < 10; i++) {
redisRepository.hashPut("hash:list", String.valueOf(i), generateList());
logger.info("{}", redisRepository.hashGet("hash:list", String.valueOf(i)));
}
}
}