Spring系列之Redis的两种集成方式

createh53个月前 (03-07)技术教程48

在工作中,我们用到分布式缓存的时候,第一选择就是Redis,今天介绍一下SpringBoot如何集成Redis的,分别使用Jedis和Spring-data-redis两种方式。

一、使用Jedis方式集成#

1、增加依赖

Copy Line-numbers language-xml

	org.springframework.boot
	spring-boot-starter-web


	org.projectlombok
	lombok
	true


	redis.clients
	jedis



	com.alibaba
	fastjson
	1.2.73

2、配置项

Copy Line-numbers language-noneredis.host=localhost
redis.maxTotal=5
redis.maxIdle=5
redis.testOnBorrow=true
#以下方式也可以,SpringBoot同样能将其解析注入到JedisPoolConfig中
#redis.max-total=3
#redis.max-idle=3
#redis.test-on-borrow=true

3、配置连接池

Copy Line-numbers language-java/**
 * @author 公-众-号:程序员阿牛
 * 由于Jedis实例本身不非线程安全的,因此我们用JedisPool
 */
@Configuration
public class CommonConfig {
    @Bean
    @ConfigurationProperties("redis")
    public JedisPoolConfig jedisPoolConfig() {
        return new JedisPoolConfig();
    }

    @Bean(destroyMethod = "close")
    public JedisPool jedisPool(@Value("${redis.host}") String host) {
        return new JedisPool(jedisPoolConfig(), host);
    }
}

4、测试

Copy Line-numbers language-java/**
 * @author 公-众-号:程序员阿牛
 */
@RestController
public class JedisController {
    @Autowired
    private JedisPool jedisPool;

    @RequestMapping("getUser")
    public String getUserFromRedis(){
        UserInfo userInfo = new UserInfo();
        userInfo.setUserId("A0001");
        userInfo.setUserName("张三丰");
        userInfo.setAddress("武当山");
        jedisPool.getResource().set("userInfo", JSON.toJSONString(userInfo));
        UserInfo userInfo1 = JSON.parseObject(jedisPool.getResource().get("userInfo"),UserInfo.class);
        return userInfo1.toString();
    }
}

运行结果如下:


我们可以自己包装一个RedisClient,来简化我们的操作

使用spring-data-redis#

1、引入依赖

Copy Line-numbers language-xml		
			org.springframework.boot
			spring-boot-starter-data-redis
		

2、配置项

在application.properties中增加配置

Copy Line-numbers language-nonespring.redis.host=localhost
spring.redis.port=6379

3、使用

Copy Line-numbers language-java/**
 * @author 公-众-号:程序员阿牛
 */
@RestController
public class RedisController {
    @Autowired
    private RedisTemplate redisTemplate;

    @RequestMapping("getUser2")
    public String getUserFromRedis(){
        UserInfo userInfo = new UserInfo();
        userInfo.setUserId("A0001");
        userInfo.setUserName("张三丰");
        userInfo.setAddress("武当山");
        redisTemplate.opsForValue().set("userInfo", userInfo);
        UserInfo userInfo1 = (UserInfo) redisTemplate.opsForValue().get("userInfo");
        return userInfo1.toString();
    }
}

是的,你只需要引入依赖、加入配置就可以使用Redis了,不要高兴得太早,这里面会有一些坑

4、可能会遇到的坑


使用工具查看我们刚才set的内容,发现key前面多了一串字符,value也是不可见的

原因

使用springdataredis,默认情况下是使用
org.springframework.data.redis.serializer.JdkSerializationRedisSerializer这个类来做序列化

具体我们看一下RedisTemplate 代码如何实现的

Copy Line-numbers language-java/**
*在初始化的时候,默认的序列化类是JdkSerializationRedisSerializer
*/
public void afterPropertiesSet() {
        super.afterPropertiesSet();
        boolean defaultUsed = false;
        if (this.defaultSerializer == null) {
            this.defaultSerializer = new JdkSerializationRedisSerializer(this.classLoader != null ? this.classLoader : this.getClass().getClassLoader());
        }
   ...省略无关代码
}

如何解决

很简单,自己定义RedisTemplate并指定序列化类即可

Copy Line-numbers language-java/**
 * @author 公-众-号:程序员阿牛
 */
@Configuration
public class RedisConfig {
    @Bean
    public RedisTemplate redisTemplate(RedisConnectionFactory connectionFactory) {
        RedisTemplate template = new RedisTemplate<>();
        template.setConnectionFactory(connectionFactory);
        template.setValueSerializer(jackson2JsonRedisSerializer());
        //使用StringRedisSerializer来序列化和反序列化redis的key值
        template.setKeySerializer(new StringRedisSerializer());
        template.setHashKeySerializer(new StringRedisSerializer());
        template.setHashValueSerializer(jackson2JsonRedisSerializer());
        template.afterPropertiesSet();
        return template;
    }

    @Bean
    public RedisSerializer<Object> jackson2JsonRedisSerializer() {
        //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值
        Jackson2JsonRedisSerializer serializer = new Jackson2JsonRedisSerializer(Object.class);
        ObjectMapper mapper = new ObjectMapper();
        mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        mapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        serializer.setObjectMapper(mapper);
        return serializer;
    }

}

查看运行结果:

哨兵和集群#

只需要改一下配置项即可

Copy Line-numbers language-none# 哨兵
spring.redis.sentinel.master=mymaster
spring.redis.sentinel.nodes=127.0.0.1:26379,127.0.0.1:26380,127.0.0.1:26381

#集群
spring.redis.cluster.max-redirects=100
spring.redis.cluster.nodes=127.0.0.1:6379,127.0.0.1:6380,127.0.0.1:6381,127.0.0.1:6382,127.0.0.1:6383,127.0.0.1:6384

总结:#

以上两种方式都可以,但是还是建议你使用Spring-data-redis,因为Spring经过多年的发展,尤其是Springboot的日渐成熟,已经为我们简化了很多操作。

相关文章

SpringBoot集成Swagger,更酷的UI方案

本文地址:sf.gg/a/1190000038170506之前在创业公司待的时候,用过swagger,因为我第一天来这家公司工作,第一个任务就是做接口文档自动化。后来觉得它不太好用,在浏览技术网站的时...

手把手教你将 DeepSeek 集成到 Java 的 Spring Boot 项目中

前面阳仔给大家介绍了如何将deepseek结合进入办公软件中,今天阳仔将详细介绍如何将 DeepSeek 集成到 Java 的 Spring Boot 项目中,让你的项目具备智能交互能力。一、准备工...

Shiro学习系列教程三:集成web

相关推荐:《Shiro学习系列教程一:Shiro之helloworld》《Shiro学习系列教程三:集成web》《Shiro学习系列教程四:集成web(二)》《Shiro学习系列教程五:自定义Real...

全面的集成能力:流程引擎与第三方系统的集成对接

关键词:系统集成、流程审批、API接口、数字化转型、业务流程编者按:本文介绍在现代企业信息化建设的进程中,流程引擎作为业务流程管理的核心组件,其集成能力显得尤为重要。一个具备全面集成能力的流程引擎,能...