异常教程

springboot redis（超详细）

更新时间:

💡一则或许对你有用的小广告

欢迎加入小哈的星球 ，你将获得：专属的项目实战 / 1v1 提问 / Java 学习路线 / 学习打卡 / 每月赠书 / 社群讨论

  • 新项目:《从零手撸：仿小红书（微服务架构）》 正在持续爆肝中，基于 Spring Cloud Alibaba + Spring Boot 3.x + JDK 17...，点击查看项目介绍 ;
  • 《从零手撸：前后端分离博客项目（全栈开发）》 2 期已完结，演示链接： http://116.62.199.48/ ;

截止目前， 星球 内专栏累计输出 82w+ 字，讲解图 3441+ 张，还在持续爆肝中.. 后续还会上新更多项目，目标是将 Java 领域典型的项目都整一波，如秒杀系统, 在线商城, IM 即时通讯，权限管理，Spring Cloud Alibaba 微服务等等，已有 2900+ 小伙伴加入学习 ，欢迎点击围观

在互联网应用开发中，系统性能优化与高并发场景的应对是开发者必须面对的核心挑战之一。Spring Boot与Redis的结合，为这些问题提供了高效的解决方案。Redis 是一个基于内存的键值对存储系统，因其高速读写能力和丰富的数据结构支持，成为现代应用中不可或缺的缓存与数据中间件。本文将从零开始，通过案例与代码示例，系统讲解如何在 Spring Boot 项目中集成和使用 Redis，并深入探讨其核心功能与最佳实践。

一、Redis 的基础概念与核心优势

1.1 什么是 Redis？

Redis（Remote Dictionary Server）是一个开源的、高性能的键值存储系统，它支持多种数据结构（如字符串、哈希、列表、集合、有序集合等），并通过内存存储实现毫秒级的响应速度。

  • 类比解释：可以将 Redis 想象为一个“超级快的内存数据库”，它将数据保存在内存中，避免了磁盘 I/O 的延迟，因此读写速度远超传统关系型数据库。

1.2 Redis 的核心优势

  • 高速读写：内存操作让 Redis 的响应时间通常在毫秒级，适合高频访问场景。
  • 数据结构丰富：支持列表、集合、哈希等复杂结构，能够灵活应对不同业务需求。
  • 持久化能力：通过 RDB（快照）和 AOF（日志追加）两种方式保障数据不丢失。
  • 分布式支持：通过集群模式（Redis Cluster）或分片（Redis Sharding）实现横向扩展。

1.3 Redis 的典型应用场景

  • 缓存加速：如网页静态资源、数据库查询结果的缓存。
  • 实时计数器：例如统计网页点击量、用户登录次数。
  • 消息队列：利用 List 结构实现轻量级的消息中间件。
  • 会话共享：在分布式系统中存储用户会话信息。

二、Spring Boot 与 Redis 的集成

2.1 添加依赖

在 Spring Boot 项目中，只需通过 Maven 或 Gradle 添加以下依赖即可集成 Redis：

<!-- Maven 依赖 -->  
<dependency>  
    <groupId>org.springframework.boot</groupId>  
    <artifactId>spring-boot-starter-data-redis</artifactId>  
</dependency>  
<dependency>  
    <groupId>io.lettuce</groupId>  
    <artifactId>lettuce-core</artifactId>  
</dependency>

2.2 配置 Redis 连接

在 application.properties 文件中配置 Redis 服务器地址和端口：

spring.redis.host=localhost  
spring.redis.port=6379

2.3 创建配置类（可选）

若需自定义连接池或序列化策略，可通过配置类实现：

@Configuration  
public class RedisConfig {  
    @Bean  
    public LettuceClientConfiguration clientConfig() {  
        return LettuceClientConfiguration.builder()  
                .commandTimeout(Duration.ofSeconds(5))  
                .shutdownTimeout(Duration.ZERO)  
                .build();  
    }  
}

三、Spring Boot 中 Redis 的核心操作

3.1 基础键值操作

通过 RedisTemplate 或 StringRedisTemplate 实现键值对的增删改查：

@Autowired  
private RedisTemplate<String, Object> redisTemplate;  

// 存储数据  
redisTemplate.opsForValue().set("user:1001", user);  
// 获取数据  
User user = (User) redisTemplate.opsForValue().get("user:1001");

3.2 常用数据结构操作

3.2.1 列表（List）

// 向列表左侧插入元素  
redisTemplate.opsForList().leftPush("messages", "Hello Redis");  
// 获取列表长度  
Long length = redisTemplate.opsForList().size("messages");

3.2.2 哈希（Hash）

// 存储用户信息到哈希表  
redisTemplate.opsForHash().put("user:profile", "age", 25);  
// 获取哈希表中的字段值  
Object age = redisTemplate.opsForHash().get("user:profile", "age");

3.2.3 集合（Set）

// 添加元素到集合  
redisTemplate.opsForSet().add("tags", "spring", "redis");  
// 随机获取一个元素  
Object randomTag = redisTemplate.opsForSet().randomMember("tags");

四、Redis 缓存的实战案例

4.1 用户信息缓存

4.1.1 场景描述

假设需要缓存用户信息以减少数据库查询次数。

4.1.2 实现步骤

  1. 定义实体类：
@Data  
public class User {  
    private Long id;  
    private String name;  
    private Integer age;  
}
  1. 创建缓存服务：
@Service  
public class UserService {  
    @Autowired  
    private RedisTemplate<String, User> redisTemplate;  

    public User getUser(Long id) {  
        String key = "user:" + id;  
        User user = redisTemplate.opsForValue().get(key);  
        if (user == null) {  
            // 模拟从数据库查询  
            user = queryUserFromDB(id);  
            redisTemplate.opsForValue().set(key, user, 5, TimeUnit.MINUTES); // 设置过期时间  
        }  
        return user;  
    }  
}

4.2 实时计数器

4.2.1 场景描述

统计某篇文章的阅读量，要求支持每秒百万级的并发请求。

4.2.2 实现代码

public class CounterService {  
    private static final String ARTICLE_VIEWS_KEY = "article:view_count";  

    public Long incrementAndView() {  
        return redisTemplate.opsForValue().increment(ARTICLE_VIEWS_KEY);  
    }  
}

通过 increment 方法，Redis 可以在原子操作中完成计数，避免并发问题。

五、Redis 的高级功能与最佳实践

5.1 发布订阅模式

通过 RedisTemplate 实现消息的发布与订阅：

// 发布消息  
redisTemplate.convertAndSend("channel:chat", "Hello everyone!");  

// 订阅消息  
redisTemplate.getConnectionFactory().getReactiveConnection()  
    .subscribe(ChannelTopic.of("channel:chat"))  
    .map(message -> message.getMessage())  
    .subscribe(message -> System.out.println("Received: " + message));

5.2 事务与 Pipeline

5.2.1 事务

RedisCallback<String> callback = connection -> {  
    connection.multi();  
    connection.set("key1".getBytes(), "value1".getBytes());  
    connection.set("key2".getBytes(), "value2".getBytes());  
    return connection.exec().toString();  
};  
redisTemplate.execute(callback);

5.2.2 Pipeline

批量操作时使用 Pipeline 减少网络延迟：

redisTemplate.executePipelined((RedisConnection connection) -> {  
    connection.set("keyA".getBytes(), "valA".getBytes());  
    connection.set("keyB".getBytes(), "valB".getBytes());  
    return null;  
});

5.3 缓存雪崩与解决方案

  • 问题描述：大量缓存键同时过期，导致数据库压力激增。
  • 解决方案：
    • 随机过期时间：在设置键时，添加随机的过期时间。 
      long randomExpire = new Random().nextInt(60); // 随机 0-60 秒  
redisTemplate.expire(key, randomExpire, TimeUnit.SECONDS);
    • 缓存空值机制：对查询不到数据的键也设置短暂过期时间，避免重复请求。

六、性能优化与监控

6.1 配置序列化策略

默认情况下，Spring Boot 使用 JdkSerializationRedisSerializer，但推荐使用 GenericJackson2JsonRedisSerializer 提升性能：

@Configuration  
public class RedisConfig {  
    @Bean  
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {  
        RedisTemplate<String, Object> template = new RedisTemplate<>();  
        template.setConnectionFactory(factory);  
        template.setKeySerializer(new StringRedisSerializer());  
        template.setValueSerializer(new GenericJackson2JsonRedisSerializer());  
        return template;  
    }  
}

6.2 监控与日志

通过以下方式监控 Redis 性能：

  • Redis 命令行：执行 INFO 命令查看内存使用、连接数等指标。
  • 可视化工具：使用 Redis Desktop Manager 或 Prometheus + Grafana 实现监控。

结论

通过本文的讲解，我们系统掌握了 Spring Boot Redis 的集成方法、核心操作及高级功能。无论是基础的键值缓存，还是复杂的事务、发布订阅场景，Redis 都能提供高效可靠的解决方案。在实际开发中，开发者需要结合业务需求选择合适的数据结构，并通过合理的过期策略和序列化配置优化性能。随着系统复杂度的提升，建议进一步探索 Redis 集群、持久化配置及与 Spring Data Redis 的深度整合，以构建高可用、高性能的应用架构。

（字数统计：约 1800 字）

最新发布

查看更多文章