Spring Boot(10)——使用Redis

本文涉及的产品
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
简介:

使用Redis

Spring Boot提供了spring-boot-starter-data-redis这样一个Starter,通过加入这样一个依赖,会自动配置RedisConnectionFactory,默认是基于Lettuce的实现。然后会基于RedisConnectionFactory自动配置RedisTemplate和基于String操作的StringRedisTemplate。

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

默认连接的Redis主机是localhost,端口号是6379。可以通过spring.redis.host指定需要连接的主机,通过spring.redis.port指定需要连接的主机端口号。比如下面指定了需要连接的Redis主机地址是192.168.0.104,端口号是6378。

spring.redis.host=192.168.0.104
spring.redis.port=6378

接着就可以按照Spring Data Redis中使用RedisTemplate和StringRedisTemplate的用法进行Redis的基本操作了。下面的代码中通过StringRedisTemplate设置了key1为一个String类型的缓存,为其指定了值和缓存失效时间。key2为List类型的缓存,每次都从最左边存入一个值,一共存了10个,然后再从Redis中获取key2对应的值依次输出。

@Autowired
private StringRedisTemplate stringRedisTemplate;

public void basicOperation() {
    BoundValueOperations<String, String> boundValueOps = this.stringRedisTemplate.boundValueOps("key1");
    boundValueOps.set("test string value", 60, TimeUnit.MINUTES);
    
    BoundListOperations<String, String> boundListOps = this.stringRedisTemplate.boundListOps("key2");
    for (int i=0; i<10; i++) {
        boundListOps.leftPush("V_" + (i*10 + i+1));
    }
    
    List<String> list = boundListOps.range(0, boundListOps.size());
    list.forEach(System.out::println);
}

Redis中存放Key和Value也可以是Java对象,对象默认会被序列化后再写入到Redis,然后读取的时候会被反序列化。下面的代码就是往Redis中存入Java对象的示例,Key和Value都可以是对象。

@Autowired
private RedisTemplate<Object, Object> redisTemplate;

public void operForUser() {
    User user = new User();
    user.setId(1L);
    user.setUsername("zhangsan");
    user.setName("张三");
    ValueOperations<Object, Object> opsForValue = this.redisTemplate.opsForValue();
    opsForValue.set(user, user);
    
    Object object = opsForValue.get(user);
    System.out.println(object);
    
    System.out.println("================================================");
    
    opsForValue.set("user::" + user.getId(), user);
    
    object = opsForValue.get("user::" + user.getId());
    System.out.println(object);
    
}

@Data
public static class User implements Serializable {
    private static final long serialVersionUID = -1479529526911953462L;
    private Long id;
    private String username;
    private String name;
}

Spring Boot自动配置Redis会将相关配置属性绑定到org.springframework.boot.autoconfigure.data.redis.RedisProperties类,更多的配置信息可以参考该类的API文档或源代码,比如配置连接池信息,配置数据库索引等。

Reactive

如果需要基于Reactive编程,则可以添加spring-boot-starter-data-redis-reactive依赖,这样org.springframework.boot.autoconfigure.data.redis.RedisReactiveAutoConfiguration自动配置类将会生效,它会为我们自动创建一个ReactiveRedisTemplate类型的bean。

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

之后就可以通过ReactiveRedisTemplate基于Reactive进行编程了。下面是一个简单的示例。

@Autowired
private ReactiveRedisTemplate<Object, Object> reactiveRedisTemplate;

public void reactive() {
    ReactiveValueOperations<Object, Object> opsForValue = this.reactiveRedisTemplate.opsForValue();
    User user = new User();
    user.setId(1L);
    user.setUsername("zhangsan");
    user.setName("张三");
    String key = "user::" + user.getId();
    Mono<Boolean> mono = opsForValue.set(key, user);
    if (mono.block()) {
        Mono<Object> mono2 = opsForValue.get(key);
        mono2.blockOptional().ifPresent(System.out::println);
    }
    
    ReactiveListOperations<Object, Object> opsForList = this.reactiveRedisTemplate.opsForList();
    String listKey = "list1";
    opsForList.leftPushAll(listKey, "A", "B", "C", "D", "E").subscribe();
    Flux<Object> flux = opsForList.range(listKey, 0, 10);
    flux.subscribe(System.out::println);
}

(注:本文基于Spring Boot 2.0.3所写)

目录
相关文章
|
1月前
|
NoSQL Java 网络安全
SpringBoot启动时连接Redis报错:ERR This instance has cluster support disabled - 如何解决?
通过以上步骤一般可以解决由于配置不匹配造成的连接错误。在调试问题时,一定要确保服务端和客户端的Redis配置保持同步一致。这能够确保SpringBoot应用顺利连接到正确配置的Redis服务,无论是单机模式还是集群模式。
198 5
|
2月前
|
NoSQL Java 调度
分布式锁与分布式锁使用 Redis 和 Spring Boot 进行调度锁(不带 ShedLock)
分布式锁是分布式系统中用于同步多节点访问共享资源的机制,防止并发操作带来的冲突。本文介绍了基于Spring Boot和Redis实现分布式锁的技术方案,涵盖锁的获取与释放、Redis配置、服务调度及多实例运行等内容,通过Docker Compose搭建环境,验证了锁的有效性与互斥特性。
206 0
分布式锁与分布式锁使用 Redis 和 Spring Boot 进行调度锁(不带 ShedLock)
|
7月前
|
NoSQL 安全 Java
深入理解 RedisConnectionFactory:Spring Data Redis 的核心组件
在 Spring Data Redis 中,`RedisConnectionFactory` 是核心组件,负责创建和管理与 Redis 的连接。它支持单机、集群及哨兵等多种模式,为上层组件(如 `RedisTemplate`)提供连接抽象。Spring 提供了 Lettuce 和 Jedis 两种主要实现,其中 Lettuce 因其线程安全和高性能特性被广泛推荐。通过手动配置或 Spring Boot 自动化配置,开发者可轻松集成 Redis,提升应用性能与扩展性。本文深入解析其作用、实现方式及常见问题解决方法,助你高效使用 Redis。
791 4
|
4月前
|
NoSQL Java Redis
Redis基本数据类型及Spring Data Redis应用
Redis 是开源高性能键值对数据库,支持 String、Hash、List、Set、Sorted Set 等数据结构,适用于缓存、消息队列、排行榜等场景。具备高性能、原子操作及丰富功能,是分布式系统核心组件。
559 2
|
6月前
|
消息中间件 缓存 NoSQL
基于Spring Data Redis与RabbitMQ实现字符串缓存和计数功能(数据同步)
总的来说,借助Spring Data Redis和RabbitMQ,我们可以轻松实现字符串缓存和计数的功能。而关键的部分不过是一些"厨房的套路",一旦你掌握了这些套路,那么你就像厨师一样可以准备出一道道饕餮美食了。通过这种方式促进数据处理效率无疑将大大提高我们的生产力。
238 32
|
5月前
|
机器学习/深度学习 数据采集 人机交互
springboot+redis互联网医院智能导诊系统源码,基于医疗大模型、知识图谱、人机交互方式实现
智能导诊系统基于医疗大模型、知识图谱与人机交互技术,解决患者“知症不知病”“挂错号”等问题。通过多模态交互(语音、文字、图片等)收集病情信息,结合医学知识图谱和深度推理,实现精准的科室推荐和分级诊疗引导。系统支持基于规则模板和数据模型两种开发原理:前者依赖人工设定症状-科室规则,后者通过机器学习或深度学习分析问诊数据。其特点包括快速病情收集、智能病症关联推理、最佳就医推荐、分级导流以及与院内平台联动,提升患者就诊效率和服务体验。技术架构采用 SpringBoot+Redis+MyBatis Plus+MySQL+RocketMQ,确保高效稳定运行。
417 0
|
8月前
|
存储 人工智能 NoSQL
SpringBoot整合Redis、ApacheSolr和SpringSession
本文介绍了如何使用SpringBoot整合Redis、ApacheSolr和SpringSession。SpringBoot以其便捷的配置方式受到开发者青睐,通过引入对应的starter依赖,可轻松实现功能整合。对于Redis,可通过配置RedisSentinel实现高可用;SpringSession则提供集群Session管理,支持多种存储方式如Redis;整合ApacheSolr时,借助Zookeeper搭建SolrCloud提高可用性。文中详细说明了各组件的配置步骤与代码示例,方便开发者快速上手。
165 11
|
8月前
|
NoSQL Java API
微服务——SpringBoot使用归纳——Spring Boot 中集成Redis——Spring Boot 集成 Redis
本文介绍了在Spring Boot中集成Redis的方法,包括依赖导入、Redis配置及常用API的使用。通过导入`spring-boot-starter-data-redis`依赖和配置`application.yml`文件,可轻松实现Redis集成。文中详细讲解了StringRedisTemplate的使用,适用于字符串操作,并结合FastJSON将实体类转换为JSON存储。还展示了Redis的string、hash和list类型的操作示例。最后总结了Redis在缓存和高并发场景中的应用价值,并提供课程源代码下载链接。
2004 0
深入实践springboot实战 蓄势待发 我不是雷锋 我是知识搬运工
springboot,说白了就是一个集合了功能的大类库,包括springMVC,spring,spring data,spring security等等,并且提供了很多和可以和其他常用框架,插件完美整合的接口(只能说是一些常用框架,基本在github上能排上名次的都有完美整合,但如果是自己写的一个框架就无法实现快速整合)。
|
Java 数据安全/隐私保护
Neo4j【付诸实践 01】SpringBoot集成报错org.neo4j.driver.exceptions.ClientException:服务器不支持此驱动程序支持的任何协议版本(解决+源代码)
Neo4j【付诸实践 01】SpringBoot集成报错org.neo4j.driver.exceptions.ClientException:服务器不支持此驱动程序支持的任何协议版本(解决+源代码)
772 1