Spring Boot 如何快速集成 Redis?

简介: Java技术栈www.javastack.cn关注阅读更多优质文章Spring Boot 如何快速集成 Redis?没错,栈长本文教你,让大家少走弯路!

image.png

Java技术栈

www.javastack.cn

关注阅读更多优质文章

Spring Boot 如何快速集成 Redis?没错,栈长本文教你,让大家少走弯路!

添加依赖

使用像 Redis 这类的 NoSQL 数据库就必须要依赖 spring-data-redis 这样的能力包,开箱即用,Spring Boot 中都封装好了:

引入spring-boot-starter-data-redis:

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

Spring Boot 基础知识就不介绍了,不熟悉的可以关注公众号Java技术栈,在后台回复:boot,可以阅读我写的历史实战教程。


它主要包含了下面四个依赖:


spring-boot-dependencies


spring-boot-starter


spring-data-redis


lettuce-core


添加 Redis 连接配置

Redis 自动配置支持配置单机、集群、哨兵,来看下 RedisProperties 的参数类图吧:

image.png


本文以单机为示例,我们在 application.yml 配置文件中添加 Redis 连接配置,:

spring:
  redis:
    host: 192.168.8.88
    port: 6379
    password: redis2020
    database: 1

也可以将参数配置在 Spring Cloud Config Server 配置中心中。


Redis 自动配置

添加完依赖和连接配置参数之后,Redis 就能自动配置,参考 Redis 的自动配置类:


org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration


源码:

@Configuration(proxyBeanMethods = false)
@ConditionalOnClass(RedisOperations.class)
@EnableConfigurationProperties(RedisProperties.class)
@Import({ LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class })
public class RedisAutoConfiguration {
    ...
}

通过看源码,Redis内置两种客户端的自动配置:


1)Lettuce(默认):


org.springframework.boot.autoconfigure.data.redis.LettuceConnectionConfiguration


2)Jedis:


org.springframework.boot.autoconfigure.data.redis.JedisConnectionConfiguration


为什么默认Lettuce,其实文章之前的四个依赖也看出来了,请看默认依赖:

image.png


自动配置提供了两种操作模板:


1)RedisTemplate


key-value 都为 Object 对象,并且默认用的 JDK 的序列化/反序列化器:


org.springframework.data.redis.serializer.JdkSerializationRedisSerializer


使用这个序列化器,key 和 value 都需要实现 java.io.Serializable 接口。


2)StringRedisTemplate


key-value 都为 String 对象,默认用的 String UTF-8 格式化的序列化/反序列化器:


org.springframework.data.redis.serializer.StringRedisSerializer


上面提到了两种序列化器,另外还有两种 JSON 的序列化器值得学习一下,下面配置会用到。


Jackson2JsonRedisSerializer


GenericJackson2JsonRedisSerializer


使用方式上,两种都可以序列化、反序列化 JSON 数据,Jackson2JsonRedisSerializer 效率高,但 GenericJackson2JsonRedisSerializer 更为通用,不需要指定泛型类型。


核心配置

除了自动配置之外,下面是 Redis 的核心配置,主要是自定义了 RedisTemplate 使用 JSON 序列化器。


另外就是,把几个数据类型的操作类进行了 Bean 池化处理。

@Configuration
public class RedisConfig {
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(factory);
        StringRedisSerializer stringSerializer = new StringRedisSerializer();
        RedisSerializer jacksonSerializer = getJacksonSerializer();
        template.setKeySerializer(stringSerializer);
        template.setValueSerializer(jacksonSerializer);
        template.setHashKeySerializer(stringSerializer);
        template.setHashValueSerializer(jacksonSerializer);
        template.setEnableTransactionSupport(true);
        template.afterPropertiesSet();
        return template;
    }
    private RedisSerializer getJacksonSerializer() {
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        return new GenericJackson2JsonRedisSerializer(om);
    }
    @Bean
    public HashOperations<String, String, Object> hashOperations(RedisTemplate<String, Object> redisTemplate) {
        return redisTemplate.opsForHash();
    }
    @Bean
    public ValueOperations<String, Object> valueOperations(RedisTemplate<String, Object> redisTemplate) {
        return redisTemplate.opsForValue();
    }
    @Bean
    public ListOperations<String, Object> listOperations(RedisTemplate<String, Object> redisTemplate) {
        return redisTemplate.opsForList();
    }
    @Bean
    public SetOperations<String, Object> setOperations(RedisTemplate<String, Object> redisTemplate) {
        return redisTemplate.opsForSet();
    }
    @Bean
    public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {
        return redisTemplate.opsForZSet();
    }
}

如果你只想用默认的 JDK 序列化器,那 RedisTemplate 相关配置就不是必须的。

缓存实战

下面写了一个示例,用来缓存并读取缓存中一个类对象。

@GetMapping("/redis/set")
public String set(@RequestParam("name") String name) {
    User user = new User();
    user.setId(RandomUtils.nextInt());
    user.setName(name);
    user.setBirthday(new Date());
    List<String> list = new ArrayList<>();
    list.add("sing");
    list.add("run");
    user.setInteresting(list);
    Map<String, Object> map = new HashMap<>();
    map.put("hasHouse", "yes");
    map.put("hasCar", "no");
    map.put("hasKid", "no");
    user.setOthers(map);
    redisOptService.set(name, user, 30000);
    User userValue = (User) redisOptService.get(name);
    return userValue.toString();
}

测试:


http://localhost:8080/redis/set?name=zhangsan


返回:


User(id=62386235, name=zhangsan, birthday=Tue Jun 23 18:04:55 CST 2020, interesting=[sing, run], others={hasHouse=yes, hasKid=no, hasCar=no})


Redis中的值:


192.168.8.88:6379> get zhangsan "["cn.javastack.springboot.redis.pojo.User",{"id":62386235,"name":"zhangsan","birthday":["java.util.Date",1592906695750],"interesting":["java.util.ArrayList",["sing","run"]],"others":["java.util.HashMap",{"hasHouse":"yes","hasKid":"no","hasCar":"no"}]}]"



相关文章
|
7月前
|
数据可视化 Java BI
将 Spring 微服务与 BI 工具集成:最佳实践
本文探讨了 Spring 微服务与商业智能(BI)工具集成的潜力与实践。随着微服务架构和数据分析需求的增长,Spring Boot 和 Spring Cloud 提供了构建可扩展、弹性服务的框架,而 BI 工具则增强了数据可视化与实时分析能力。文章介绍了 Spring 微服务的核心概念、BI 工具在企业中的作用,并深入分析了两者集成带来的优势,如实时数据处理、个性化报告、数据聚合与安全保障。同时,文中还总结了集成过程中的最佳实践,包括事件驱动架构、集中配置管理、数据安全控制、模块化设计与持续优化策略,旨在帮助企业构建高效、智能的数据驱动系统。
361 1
将 Spring 微服务与 BI 工具集成:最佳实践
|
9月前
|
XML 人工智能 Java
Spring Boot集成Aviator实现参数校验
Aviator是一个高性能、轻量级的Java表达式求值引擎,适用于动态表达式计算。其特点包括支持多种运算符、函数调用、正则匹配、自动类型转换及嵌套变量访问,性能优异且依赖小。适用于规则引擎、公式计算和动态脚本控制等场景。本文介绍了如何结合Aviator与AOP实现参数校验,并附有代码示例和仓库链接。
588 0
|
9月前
|
安全 Java 数据库
第16课:Spring Boot中集成 Shiro
第16课:Spring Boot中集成 Shiro
1032 0
|
9月前
|
消息中间件 存储 Java
第15课: Spring Boot中集成ActiveMQ
第15课: Spring Boot中集成ActiveMQ
621 0
|
10月前
|
人工智能 Java 测试技术
Spring Boot 集成 JUnit 单元测试
本文介绍了在Spring Boot中使用JUnit 5进行单元测试的常用方法与技巧,包括添加依赖、编写测试类、使用@SpringBootTest参数、自动装配测试模块(如JSON、MVC、WebFlux、JDBC等),以及@MockBean和@SpyBean的应用。内容实用,适合Java开发者参考学习。
1080 0
|
6月前
|
NoSQL Java 网络安全
SpringBoot启动时连接Redis报错:ERR This instance has cluster support disabled - 如何解决?
通过以上步骤一般可以解决由于配置不匹配造成的连接错误。在调试问题时,一定要确保服务端和客户端的Redis配置保持同步一致。这能够确保SpringBoot应用顺利连接到正确配置的Redis服务,无论是单机模式还是集群模式。
540 5
|
7月前
|
NoSQL Java 调度
分布式锁与分布式锁使用 Redis 和 Spring Boot 进行调度锁(不带 ShedLock)
分布式锁是分布式系统中用于同步多节点访问共享资源的机制,防止并发操作带来的冲突。本文介绍了基于Spring Boot和Redis实现分布式锁的技术方案,涵盖锁的获取与释放、Redis配置、服务调度及多实例运行等内容,通过Docker Compose搭建环境,验证了锁的有效性与互斥特性。
594 0
分布式锁与分布式锁使用 Redis 和 Spring Boot 进行调度锁(不带 ShedLock)
|
7月前
|
监控 Cloud Native Java
Spring Integration 企业集成模式技术详解与实践指南
本文档全面介绍 Spring Integration 框架的核心概念、架构设计和实际应用。作为 Spring 生态系统中的企业集成解决方案,Spring Integration 基于著名的 Enterprise Integration Patterns(EIP)提供了轻量级的消息驱动架构。本文将深入探讨其消息通道、端点、过滤器、转换器等核心组件,以及如何构建可靠的企业集成解决方案。
685 0
|
9月前
|
Java 关系型数据库 数据库连接
Spring Boot项目集成MyBatis Plus操作PostgreSQL全解析
集成 Spring Boot、PostgreSQL 和 MyBatis Plus 的步骤与 MyBatis 类似,只不过在 MyBatis Plus 中提供了更多的便利功能,如自动生成 SQL、分页查询、Wrapper 查询等。
874 3