当前位置: 首页 > news >正文

使用 Spring Data Redis 实现 Redis 数据存储详解

使用 Spring Data Redis 实现 Redis 数据存储详解

Spring Data Redis 是 Spring 生态中操作 Redis 的核心模块,它封装了 Redis 客户端的底层细节(如 Jedis 或 Lettuce),提供了统一的 API 来操作 Redis 的数据结构。以下是详细实现步骤:


一、配置 Spring Data Redis

1. 引入依赖

pom.xml 中添加依赖(以 Spring Boot 3.x 为例):

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- 使用 Lettuce 客户端(默认) -->
<dependency><groupId>io.lettuce</groupId><artifactId>lettuce-core</artifactId>
</dependency>
<!-- 可选:连接池(如使用 Jedis) -->
<dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId>
</dependency>
2. 配置 Redis 连接

application.yml 中配置 Redis 服务器信息:

spring:redis:host: localhost      # Redis 服务器地址port: 6379          # 默认端口password: 123456    # 密码(若无则省略)database: 0         # 默认数据库索引lettuce:pool:max-active: 8   # 最大连接数max-idle: 4     # 最大空闲连接min-idle: 1     # 最小空闲连接
3. 配置 RedisTemplate

自定义 RedisTemplate 序列化方式(避免二进制乱码):

@Configuration
public class RedisConfig {@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(factory);// Key 统一使用字符串序列化template.setKeySerializer(RedisSerializer.string());template.setHashKeySerializer(RedisSerializer.string());// Value 统一使用 JSON 序列化Jackson2JsonRedisSerializer<Object> jsonSerializer = new Jackson2JsonRedisSerializer<>(Object.class);template.setValueSerializer(jsonSerializer);template.setHashValueSerializer(jsonSerializer);// 特殊数据结构的 Value 序列化(根据需求覆盖)// template.setDefaultSerializer(jsonSerializer); // 可选:全局默认序列化template.afterPropertiesSet();return template;}
}

二、操作 Redis 数据结构

在这里插入图片描述

1. String(字符串)
  • 用途:存储简单键值对(如缓存、计数器)。
  • 核心方法opsForValue()
@Autowired
private RedisTemplate<String, Object> redisTemplate;// 写入值
redisTemplate.opsForValue().set("user:1:name", "Alice");// 读取值
String name = (String) redisTemplate.opsForValue().get("user:1:name");// 原子递增
Long count = redisTemplate.opsForValue().increment("article:100:views");
2. Hash(哈希表)
  • 用途:存储对象字段(如用户信息)。
  • 核心方法opsForHash()
// 存储用户对象
Map<String, String> user = new HashMap<>();
user.put("name", "Bob");
user.put("age", "25");
redisTemplate.opsForHash().putAll("user:2", user);// 获取单个字段
String age = (String) redisTemplate.opsForHash().get("user:2", "age");// 更新字段
redisTemplate.opsForHash().put("user:2", "age", "26");// 获取所有字段
Map<Object, Object> userData = redisTemplate.opsForHash().entries("user:2");
3. List(列表)
  • 用途:实现队列、栈或消息列表。
  • 核心方法opsForList()
// 左侧插入元素
redisTemplate.opsForList().leftPush("task:queue", "task1");// 右侧弹出元素(阻塞式)
String task = (String) redisTemplate.opsForList().rightPop("task:queue", 10, TimeUnit.SECONDS);// 获取列表范围
List<Object> tasks = redisTemplate.opsForList().range("task:queue", 0, -1);
4. Set(集合)
  • 用途:存储唯一值(如标签、共同好友)。
  • 核心方法opsForSet()
// 添加元素
redisTemplate.opsForSet().add("article:100:tags", "tech", "java", "spring");// 判断元素是否存在
boolean exists = redisTemplate.opsForSet().isMember("article:100:tags", "java");// 求交集
Set<Object> commonTags = redisTemplate.opsForSet().intersect("article:100:tags", "article:101:tags");
5. Sorted Set(有序集合)
  • 用途:排行榜、优先级队列。
  • 核心方法opsForZSet()
// 添加元素及分数
redisTemplate.opsForZSet().add("leaderboard", "player1", 100.0);
redisTemplate.opsForZSet().add("leaderboard", "player2", 85.5);// 获取前 10 名
Set<ZSetOperations.TypedTuple<Object>> topPlayers = redisTemplate.opsForZSet().reverseRangeWithScores("leaderboard", 0, 9);// 更新分数
redisTemplate.opsForZSet().incrementScore("leaderboard", "player1", 20.0);
6. HyperLogLog
  • 用途:近似统计独立用户数(UV)。
  • 核心方法opsForHyperLogLog()
// 添加元素
redisTemplate.opsForHyperLogLog().add("uv:20231001", "user1", "user2", "user3");// 统计基数
Long uv = redisTemplate.opsForHyperLogLog().size("uv:20231001");
7. Bitmaps
  • 用途:位操作(如用户签到)。
  • 核心方法opsForValue().setBit()
// 设置第 5 位为 1(表示用户 ID=5 已签到)
redisTemplate.opsForValue().setBit("sign:user:202310", 5, true);// 统计总签到数
Long count = redisTemplate.execute((RedisCallback<Long>) conn -> conn.bitCount("sign:user:202310".getBytes())
);
8. GEO(地理空间)
  • 用途:附近位置查询。
  • 核心方法opsForGeo()
// 添加地理位置
redisTemplate.opsForGeo().add("cities", new Point(116.405285, 39.904989), "Beijing");// 查询距离
Distance distance = redisTemplate.opsForGeo().distance("cities", "Beijing", "Shanghai", Metrics.KILOMETERS);// 附近 100km 内的城市
GeoResults<GeoLocation<Object>> results = redisTemplate.opsForGeo().radius("cities", "Beijing", new Distance(100, Metrics.KILOMETERS));

三、高级功能

1. 事务支持
redisTemplate.execute(new SessionCallback<List<Object>>() {@Overridepublic List<Object> execute(RedisOperations operations) {operations.multi();  // 开启事务operations.opsForValue().set("key1", "value1");operations.opsForHash().put("hash1", "field", "value");return operations.exec();  // 提交事务}
});
2. 发布订阅
// 发布消息
redisTemplate.convertAndSend("news", "Breaking news: Spring 6 released!");// 订阅消息(需定义 MessageListener)
@Bean
public MessageListenerAdapter listenerAdapter(MessageReceiver receiver) {return new MessageListenerAdapter(receiver, "receiveMessage");
}@Bean
public RedisMessageListenerContainer container(RedisConnectionFactory factory,MessageListenerAdapter listener) {RedisMessageListenerContainer container = new RedisMessageListenerContainer();container.setConnectionFactory(factory);container.addMessageListener(listener, new ChannelTopic("news"));return container;
}
3. 管道操作(批量执行)
List<Object> results = redisTemplate.executePipelined((RedisCallback<Object>) connection -> {connection.stringCommands().set("key1".getBytes(), "value1".getBytes());connection.stringCommands().set("key2".getBytes(), "value2".getBytes());return null;
});

四、测试与验证

1. 注入 RedisTemplate
@SpringBootTest
public class RedisTest {@Autowiredprivate RedisTemplate<String, Object> redisTemplate;@Testvoid testString() {redisTemplate.opsForValue().set("testKey", "Hello Redis");assertEquals("Hello Redis", redisTemplate.opsForValue().get("testKey"));}
}
2. 检查 Redis 连接
@Autowired
private RedisConnectionFactory redisConnectionFactory;@Test
void testConnection() {RedisConnection conn = redisConnectionFactory.getConnection();assertTrue(conn.ping().equals("PONG"));conn.close();
}

五、注意事项

  1. 序列化一致性
    确保所有操作的 Key/Value 序列化方式一致,避免出现乱码或类型错误。

  2. 连接泄漏
    使用 @Transactional 或手动关闭连接,避免未释放的连接耗尽资源。

  3. 数据淘汰策略
    在 Redis 配置中设置 maxmemory-policy(如 allkeys-lru),防止内存溢出。

  4. 集群模式
    若使用 Redis 集群,需在配置中指定所有节点地址:

    spring:redis:cluster:nodes: host1:6379,host2:6379,host3:6379
    

http://www.xdnf.cn/news/228619.html

相关文章:

  • 【数据结构】——顺序表刷题
  • 论文阅读:2024 EMNLP User Inference Attacks on Large Language Models
  • MySQL表的内外连接
  • 黑群晖Moments视频无缩略图,安装第三方ffmpeg解决
  • kivy android打包buildozer.spec GUI配置
  • (Go Gin)Gin学习笔记(二):路由配置、基本路由、表单参数、上传单个文件、上传多个文件、浅扒路由原理
  • 2025年- H13-Lc121-189.轮转数组(普通数组)---java版
  • Neo4j多关系或多路径
  • 云备份服务器,数据备份服务器的方法有哪些?
  • 嵌入式软件--stm32 DAY 5 USART串口通讯(上)
  • java瘦身、升级graalvm
  • QT6 源(63)篇六:阅读与注释 QString 这个类,包含了 QString 类的 完整源码,也附上 QLatin1String 类的
  • Redis的简单介绍
  • k8s术语之Replication Controller
  • mmdeploy 转换torch为onnx
  • 2025磐石行动第八周WP
  • JavaScript性能优化实战之代码层面性能优化
  • 贪心算法求解边界最大数
  • 精益数据分析(34/126):深挖电商运营关键要点与指标
  • SAP-ABAP:在SAP系统中,COEP表(成本控制对象行项目表)详解
  • AI 生成UI交互效果
  • 基于C++的IOT网关和平台6:github项目ctGateway后台服务和数据模型
  • C++负载均衡远程调用学习之自定义内存池管理
  • SVTAV1源码-set_all_ref_frame_type
  • 专家访谈:从文本到视频,GEO多模态优化的实战法则
  • IDEA git配置[通俗易懂]
  • halcon打开图形窗口
  • 模型部署技巧(一)
  • Python爬虫实战:获取彼岸网高清素材图片
  • Windows 10 环境二进制方式安装 MySQL 8.0.41