> 文档中心 > 第三章 SpringBoot快速开发框架 - 集成Redis

第三章 SpringBoot快速开发框架 - 集成Redis


作者简介:
🌹 作者:暗夜91
🤟 个人主页:暗夜91的主页
📝 如果感觉文章写的还有点帮助,请帮忙点个关注,我会持续输出高质量技术博文。


专栏文章:
1、集成Swagger,生成API文档
2、Mysql数据源配置
3、集成Redis
4、Spring Security + JWT实现登录权限认证
5、跨域配置

专栏源码:
针对该专栏功能,对源码进行整理,可以直接下载运行。
源码下载请移步:SpringBoot快速开发框架


三、集成Redis

本项目使用Redis作为服务的缓存管理,用来存储用户登录的token及相关的用户信息。

Redis相关知识这里不做太多赘述,如需学习Redis相关的知识,可以关注本人的另一篇专栏:
Redis技术学习及开发运维

1、集成方法

(1)引入依赖

<dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-data-redis</artifactId></dependency>

(2)添加Redis配置文件

package com.lll.framework.config;import com.fasterxml.jackson.annotation.JsonAutoDetect;import com.fasterxml.jackson.annotation.PropertyAccessor;import com.fasterxml.jackson.databind.ObjectMapper;import org.springframework.cache.CacheManager;import org.springframework.cache.annotation.CachingConfigurerSupport;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.data.redis.cache.RedisCacheConfiguration;import org.springframework.data.redis.cache.RedisCacheManager;import org.springframework.data.redis.connection.RedisConnectionFactory;import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;import org.springframework.data.redis.serializer.RedisSerializationContext;import org.springframework.data.redis.serializer.RedisSerializer;import org.springframework.data.redis.serializer.StringRedisSerializer;@Configurationpublic class RedisConfig extends CachingConfigurerSupport {    private RedisSerializer<Object> valueSerializer() { Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper om = new ObjectMapper(); om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(om); return jackson2JsonRedisSerializer;    }    @Bean    public CacheManager cacheManager(RedisConnectionFactory factory) { RedisSerializer<String> redisSerializer = new StringRedisSerializer(); // 配置序列化 RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig(); RedisCacheConfiguration redisCacheConfiguration =  config.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))   .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer((valueSerializer()))); RedisCacheManager cacheManager = RedisCacheManager.builder(factory)  .cacheDefaults(redisCacheConfiguration)  .build(); return cacheManager;    }}

(3)封装Redis工具类

package com.reach.dv.common.service;import com.alibaba.fastjson.JSON;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.core.StringRedisTemplate;import org.springframework.stereotype.Service;import java.util.Map;import java.util.Set;import java.util.concurrent.TimeUnit;/** * @ClassName RedisTemplateService * @Date 2019/5/16 * @Version 1.0 **/@Servicepublic class RedisTemplateService {    @Autowired    private StringRedisTemplate redisTemplate;    /**     * 数据写入redis     *     * @param key     * @param value     * @param      * @return     */    public <T> boolean set(String key, T value) { String val = beanToString(value); if (val == null || val.length() <= 0) {     return false; } redisTemplate.opsForValue().set(key, val); return true;    }    /**     * 写入hash类型的数据     * @param key     * @param value     * @return     */    public boolean set(String key, Map<String,Object> value) { redisTemplate.opsForHash().putAll(key,value); return true;    }    /**     * 数据写入redis     * @param key     * @param value     * @param timeout 超时时长(S) >0时设置     * @param      * @return     */    public <T> boolean set(String key, T value,int timeout) { String val = beanToString(value); if (val == null || val.length() <= 0) {     return false; } redisTemplate.opsForValue().set(key, val); if (timeout>0){     redisTemplate.expire(key,timeout, TimeUnit.SECONDS); } return true;    }    private <T> String beanToString(T value) { String result = ""; if (value == null) {     return null; } Class clazz = value.getClass(); if (clazz == int.class || clazz == Integer.class) {     result = String.valueOf(value); } else if (clazz == long.class || clazz == Long.class) {     result = String.valueOf(value); } else if (clazz == String.class) {     result = String.valueOf(value); } else {     result = JSON.toJSONString(value); } return result;    }    /**     * 查询数据,返回序列化数据     * @param key     * @param      * @return     */    public <T> T get(String key, Class<T> clazz) { String value = redisTemplate.opsForValue().get(key); if(key.equals("vin")){     value = value.toUpperCase(); } return stringToBean(value, clazz);    }    /**     * 查询hash数据,返回序列化数据     * @param key     * @param mkey     * @param clazz     * @param      * @return     */    public <T> T get(String key,String mkey, Class<T> clazz){ String value = String.valueOf(redisTemplate.opsForHash().get(key,mkey)); if(key.equals("vin")){     value = value.toUpperCase(); } return stringToBean(value, clazz);    }    private <T> T stringToBean(String value, Class<T> clazz) { T result; if (value == null || value.length() <= 0 || clazz == null) {     return null; } if (clazz == int.class || clazz == Integer.class) {     result = (T) Integer.valueOf(value); } else if (clazz == long.class || clazz == Long.class) {     result = (T) Long.valueOf(value); } else if (clazz == String.class) {     result = (T) value; } else {     result = JSON.parseObject(value,clazz);//     result = JSON.toJavaObject(value,clazz); } return result;    }    public boolean delete(String key){ redisTemplate.delete(key); return true;    }    public Set<String> getKeys(String prefix){ Set<String> keys = redisTemplate.keys(prefix); return keys;    }    /**     * 判断key是否存在     * @param key     * @return     */    public boolean hasKey(String key){ return redisTemplate.hasKey(key);    }    /**     * 更新key的过期时间     * @param key     * @param newTimeOut     * @return     */    public Boolean expireKey(String key,int newTimeOut){ return redisTemplate.expire(key, newTimeOut, TimeUnit.SECONDS);    }}

到这里,我们就完成了对Redis的集成,可以在业务模块通过Redis的工具类对Redis进行操作了。