更多SpringBoot3内容请关注我的专栏：《SpringBoot3》
期待您的点赞👍收藏⭐评论✍

随着 Spring Boot 3 的发布，开发者可以享受更多的功能提升和性能优化。在现代开发中，Redis 作为高性能的缓存数据库，被广泛应用于提高系统的响应速度和减少数据库的压力。本文将介绍如何通过 Spring Boot 3 来整合 Redis，实现缓存和存储功能。

1. 项目初始化

可以通过 Spring Initializr 创建一个新的 Spring Boot 项目，选择 Spring Boot 3，并设置项目 JDK 为 Java 17。需要添加以下依赖：

• Spring Web：用于构建 REST API。
• Spring Data Redis：用于 Redis 数据库的操作。
• Lettuce：Redis 客户端，Spring Boot 默认支持。
• Spring Boot DevTools（可选）：方便开发时进行热部署。

选择好依赖后，点击 “Generate” 下载项目模板。

2. 配置 Redis

首先，需要在本地或远程部署 Redis 服务器。如果使用的是 Docker，可以用以下命令快速启动 Redis，如果是 Redis 集群请参考Docker搭建Redis集群模式。

docker run --name redis -p 6379:6379 -d redis

项目创建后，打开 application.yml 文件，如果是单机版 Redis 服务，添加如下 Redis 配置：

spring:
  data:
    redis:
      host: localhost
      port: 6379            # Redis 端口
      password:             # 如果有密码可以在这里配置
      lettuce:
        pool:
          max-active: 100    # 最大并发连接数
          max-idle: 50       # 最大空闲连接数
          min-idle: 10       # 最小空闲连接数

如果是集群版 Redis 服务，修改为如下 Redis 配置：

spring:
  data:
    redis:
      cluster:
        nodes:
          - 127.0.0.1:6379
          - 127.0.0.2:6379
          - 127.0.0.3:6379
      password:             # 如果有密码可以在这里配置
      lettuce:
        pool:
          max-active: 100    # 最大并发连接数
          max-idle: 50       # 最大空闲连接数
          min-idle: 10       # 最小空闲连接数

3. 配置 Redis 序列化

Spring Boot 默认使用 JdkSerializationRedisSerializer 进行序列化，而我们通常更倾向于使用 StringRedisSerializer 和 Jackson2JsonRedisSerializer 进行更高效的序列化操作，尤其是在处理 JSON 数据时。

我们可以通过配置 RedisTemplate 来使用自定义的序列化器：

package com.coderjia.boot310redis.config;

import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

/**
 * @author CoderJia
 * @create 2024/10/4 下午 12:43
 * @Description
 **/
@Configuration
public class RedisConfig {

    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(redisConnectionFactory);

        // 使用String序列化器序列化Key
        template.setKeySerializer(new StringRedisSerializer());

        // 使用Jackson2JsonRedisSerializer序列化Value
        ObjectMapper objectMapper = new ObjectMapper();
        Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer<>(objectMapper,Object.class);
        template.setValueSerializer(serializer);

        return template;
    }
}

4. 操作 Redis 工具类

接下来，我们可以创建一个简单的工具类来操作 Redis。我们将通过 RedisTemplate 对象进行数据的存取操作。

package com.coderjia.boot310redis.utils;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

import java.util.concurrent.TimeUnit;

/**
 * @author CoderJia
 * @create 2024/10/4 下午 12:48
 * @Description
 **/
@Service
public class RedisUtils {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    // 保存数据
    public void save(String key, Object value) {
        redisTemplate.opsForValue().set(key, value, 10, TimeUnit.MINUTES);  // 设置数据的有效期为10分钟
    }

    // 获取数据
    public Object get(String key) {
        return redisTemplate.opsForValue().get(key);
    }

    // 删除数据
    public void delete(String key) {
        redisTemplate.delete(key);
    }
}

5. 编写 REST 控制器

为了展示如何通过 REST API 来操作 Redis，我们可以创建一个简单的控制器，通过 GET 和 POST 请求来存取 Redis 中的数据。

package com.coderjia.boot310redis.demos.web;

import com.coderjia.boot310redis.utils.RedisUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author CoderJia
 */
@RestController
@RequestMapping("/api/redis")
public class BasicController {

    @Autowired
    private RedisUtils redisUtils;

    // 保存数据
    @PostMapping("/save")
    public String save(@RequestParam("key") String key, @RequestParam("value") String value) {
        redisUtils.save(key, value);
        return "Data saved successfully!";
    }

    // 获取数据
    @GetMapping("/get")
    public Object get(@RequestParam("key") String key) {
        Object value = redisUtils.get(key);
        return value != null ? value : "Key not found";
    }

    // 删除数据
    @DeleteMapping("/delete")
    public String delete(@RequestParam("key") String key) {
        redisUtils.delete(key);
        return "Data deleted successfully!";
    }
}

6. 测试 API

启动 Spring Boot 应用程序，使用 curl 或 Postman 测试 API：

保存数据：

curl -X POST "http://localhost:8080/api/redis/save?key=testKey&value=helloRedis"

获取数据：

curl "http://localhost:8080/api/redis/get?key=testKey"

删除数据：

curl -X DELETE "http://localhost:8080/api/redis/delete?key=testKey"

7. 总结

通过本文，相信你已经学会了如何在 Spring Boot 3 和 Java 17 中整合 Redis，并实现基本的存取操作以及缓存功能。使用 Redis 可以大大提升应用的响应速度和性能，尤其在高并发的场景中，使用 Redis 作为缓存是一个非常有效的优化手段。