AI 助理
文档备案控制台
开发者社区 开发与运维 文章 正文

Spring Data Redis 管理Redis 之1

2017-11-27 2013
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

本文简单介绍Spring Data框架提供的spring_data_redis模块，所提供的强大功能。虽然，spring_data_redis不具体负责与redis通信，但提供了丰富的外围功能。

主要包含以下内容

  1. 搭建测试环境

  2. 序列工具

  3. 认识RedisConnectionFactory&RedisTemplate

1.搭建测试环境

1.1 pom.xml

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
<? xml  version = "1.0"  encoding = "UTF-8" ?>
< project  xmlns = "http://maven.apache.org/POM/4.0.0"
          xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation = "http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
     < modelVersion >4.0.0</ modelVersion >
     < parent >
         <!-- Your own application should inherit from spring-boot-starter-parent -->
         < groupId >org.springframework.boot</ groupId >
         < artifactId >spring-boot-starter-parent</ artifactId >
         < version >1.3.5.RELEASE</ version >
     </ parent >
     < groupId >com.hellodb.springdata</ groupId >
     < artifactId >redisdemo</ artifactId >
     < version >1.0-SNAPSHOT</ version >
     < dependencies >
         < dependency >
             < groupId >org.springframework.data</ groupId >
             < artifactId >spring-data-redis</ artifactId >
         </ dependency >
         <!-- 客户端 -->
         < dependency >
             < groupId >redis.clients</ groupId >
             < artifactId >jedis</ artifactId >
         </ dependency >
         < dependency >
                     < groupId >biz.paluch.redis</ groupId >
                     < artifactId >lettuce</ artifactId >
                     < version >3.2.Final</ version >
         </ dependency >
         <!--序列化工具 -->
         < dependency >
             < groupId >com.fasterxml.jackson.core</ groupId >
             < artifactId >jackson-databind</ artifactId >
         </ dependency >
         < dependency >
             < groupId >org.springframework.boot</ groupId >
             < artifactId >spring-boot-starter-test</ artifactId >
             < scope >test</ scope >
         </ dependency >
     </ dependencies > 
</ project >

1.2配置XML

jedis-context.xml

1
2
3
4
5
6
7
8
9
10
11
12
13
14
<? xml  version = "1.0"  encoding = "UTF-8" ?>
< beans  xmlns = "http://www.springframework.org/schema/beans"
        xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance"
        xmlns:p = "http://www.springframework.org/schema/p"
        xsi:schemaLocation = "http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd" >
 
        <!-- Jedis ConnectionFactory -->
        < bean  id = "jedisConnectionFactory"  class = "org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
               p:port = "6379"  p:hostName = "192.168.163.146" />
 
        < bean  id = "redisTemplate"  class = "org.springframework.data.redis.core.RedisTemplate" >
               < property  name = "connectionFactory"  ref = "jedisConnectionFactory" ></ property >
        </ bean >
</ beans >

lettuce-context.xml

1
2
3
4
5
6
7
8
9
10
11
12
13
14
<? xml  version = "1.0"  encoding = "UTF-8" ?>
< beans  xmlns = "http://www.springframework.org/schema/beans"
        xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance"
        xmlns:p = "http://www.springframework.org/schema/p"
        xsi:schemaLocation = "http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd" >
 
        <!-- Jedis ConnectionFactory -->
        < bean  id = "lettuceConnectionFactory"  class = "org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory"
               p:port = "6379"  p:hostName = "192.168.163.146" />
 
        < bean  id = "redisTemplate"  class = "org.springframework.data.redis.core.RedisTemplate" >
               < property  name = "connectionFactory"  ref = "lettuceConnectionFactory" ></ property >
        </ bean >
</ beans >

实际环境中，只需要选择一个客户端即可。当然，各个客户端的使用场景有所区别，这儿就不深入讨论了。

JedisRedisTemplateTest.java :使用jedis客户端

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
@RunWith (SpringJUnit4ClassRunner. class )
@ContextConfiguration ( "classpath:jedis-context.xml" )
public  class  JedisRedisTemplateTest {
     @Resource
     RedisTemplate redisTemplate;
      @Test
     public  void  testOpsForValue() {   
         String redisKey1 =  "jedis_redis_key_1" ;
         String originValue =  "redis by jedis!" ;
         Jackson2JsonRedisSerializer<String> serializer =  new  Jackson2JsonRedisSerializer(String. class );
         redisTemplate.setKeySerializer(serializer);
         redisTemplate.setValueSerializer(serializer);
         redisTemplate.opsForValue().set(redisKey1, originValue);
         redisStoredValue = redisTemplate.opsForValue().get(redisKey1);
         assertEquals(redisStoredValue, originValue);
     }
}

LettuceRedisTemplateTest.java :使用lettuce客户端

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
@RunWith (SpringJUnit4ClassRunner. class )
@ContextConfiguration ( "classpath:lettuce-context.xml" )
public  class  LettuceRedisTemplateTest{
     @Resource
     RedisTemplate redisTemplate;
      @Test
     public  void  testOpsForValue() {   
         String redisKey1 =  "lettuce_redis_key_1" ;
         String originValue =  "redis by lettuce!" ;
         Jackson2JsonRedisSerializer<String> serializer =  new  Jackson2JsonRedisSerializer(String. class );
         redisTemplate.setKeySerializer(serializer);
         redisTemplate.setValueSerializer(serializer);
         redisTemplate.opsForValue().set(redisKey1, originValue);
         redisStoredValue = redisTemplate.opsForValue().get(redisKey1);
         assertEquals(redisStoredValue, originValue);
     }
}

对比两个测试用例, 测试用例方法，基本一致，很清晰的感受到spring data redis框架带来的扩展性。修改底层redis客户端实现技术，而不会影响到上层现有方法（如redisTemplate方法）

运行2个用例结果

1
2
3
4
5
6
7
127.0.0.1:6379> keys *
1)  "\"lettuce_redis_key_1\""
2)  "\"jedis_redis_key_1\""
127.0.0.1:6379> get   "\"lettuce_redis_key_1\""
"\"redis by lettuce!\""
127.0.0.1:6379> get   "\"jedis_redis_key_1\""
"\"redis by jedis!\""

现在环境搭建完毕。

2.序列工具

从框架的角度来看，Redis中存储的数据只是字节数。虽然Redis本身支持各种类型，但大多数情况下，这些指的是数据存储的方式，而不是它所代表的格式。由用户决定信息是否转换为字符串或任何其他对象。用户（自定义）类型和原始数据（反之亦然）之间的转换通过RedisSerializer接口（包org.springframework.data.redis.serializer）在Spring Data Redis中处理，顾名思义，它负责处理序列化过程。Spring data redis提供了多个序列化工具。

2.1 RedisSerializer API

1
2
3
4
5
6
7
8
9
10
11
12
13
//对象到字节数组（二进制数据）的基本接口序列化和反序列化
public  interface  RedisSerializer<T> {
 
    /**
     *将给定对象序列化为二进制数据
     */
    byte [] serialize(T t)  throws  SerializationException;
 
    /**
     * 从给定的二进制数据反序列化对象。
     */
    T deserialize( byte [] bytes)  throws  SerializationException;
}

2.2 内置序列化实现

org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer

org.springframework.data.redis.serializer.GenericToStringSerializer

org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer

org.springframework.data.redis.serializer.JacksonJsonRedisSerializer

org.springframework.data.redis.serializer.JdkSerializationRedisSerializer

org.springframework.data.redis.serializer.OxmSerializer

org.springframework.data.redis.serializer.StringRedisSerializer

2.3 RedisSerializer使用场景

在RedisTemplate，RedisMessageListenerContainer，DefaultStringRedisConnection使用。

比如RedisTemplate。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
public  class  RedisTemplate<K, V>  extends  RedisAccessor  implements  RedisOperations<K, V> {
...
/ **
*  @return 是否应使用默认的序列化程序。 如果没有，任何序列化不明确集将会
*保持为空，值将不会被序列化或反序列化。
* /
public  boolean  isEnableDefaultSerializer（）{
     return  enableDefaultSerializer;
}
 
 
/ **
*  @param  enableDefaultSerializer是否应使用默认的序列化程序。 如果没有，任何serializer不
*展示集将保持为空，值将不会被序列化或反序列化。
* /
public  void  setEnableDefaultSerializer（ boolean  enableDefaultSerializer）{
     this .enableDefaultSerializer = enableDefaultSerializer;
}
 
 
/ **
*返回此模板使用的默认序列化程序。
*：
*  @return 模板默认序列化
* /
public  RedisSerializer <?> getDefaultSerializer（）{
     return  defaultSerializer;
}
 
 
/ **
*设置要用于此模板的默认序列化程序。 所有序列化（期望
*  @link  #setStringSerializer（RedisSerializer））初始化为此值，除非显式设置。 默认为
*  @link  JdkSerializationRedisSerializer。
*：
*  @param  serializer默认序列化程序使用
* /
public  void  setDefaultSerializer（RedisSerializer <?> serializer）{
     this .defaultSerializer = serializer;
}
 
 
/ **
*设置此模板使用的密钥序列化程序。 默认为 @link  #getDefaultSerializer（）。
*：
*  @param  serializer此模板使用的密钥序列化程序。
* /
public  void  setKeySerializer（RedisSerializer <?> serializer）{
     this .keySerializer = serializer;
}
 
 
/ **
*返回此模板使用的密钥序列化程序。
*：
* @返回此模板使用的密钥序列化程序。
* /
public  RedisSerializer <?> getKeySerializer（）{
     return  keySerializer;
}
 
 
/ **
*设置此模板使用的值序列化程序。 默认为 @link  #getDefaultSerializer（）。
*：
*  @param  serializer此模板使用的值序列化程序。
* /
public  void  setValueSerializer（RedisSerializer <?> serializer）{
     this .valueSerializer = serializer;
}
 
 
/ **
*返回此模板使用的值序列化程序。
*：
* @返回此模板使用的值序列化程序。
* /
public  RedisSerializer <?> getValueSerializer（）{
     return  valueSerializer;
}
...
}

2.4  测试

上面的JedisRedisTemplateTest 使用的序列化工具Jackson2JsonRedisSerializer。

1
2
3
4
127.0.0.1:6379> keys *
1)  "\"jedis_redis_key_1\""
127.0.0.1:6379> get  "\"jedis_redis_key_1\""
"\"redis by jedis!\""

改用StringRedisSerializer，操作redis后效果

1
2
3
4
5
6
127.0.0.1:6379> flushdb
OK
127.0.0.1:6379> keys *
1)  "jedis_redis_key_1"
127.0.0.1:6379> get jedis_redis_key_1
"redis by jedis!"

3.认识RedisConnectionFactory&RedisTemplate

wKiom1htEGjzneikAACAPOYPyvQ594.png

通过这个结构，可以实现客户端工具的无缝切换。

RedisConnection
与Redis服务器的连接。 作为各种Redis客户端库（或驱动程序）的通用抽象。
RedisConnectionFactory
 线程安全的Redis连接工厂。
RedisTemplate
 帮助类，简化了Redis数据访问模板代码。






RedisTemplate模板提供了操作视图（根据Redis命令引用进行分组），它提供丰富的，一般化的接口，用于对某种类型或某个键（通过KeyBound接口）进行处理，如下所述

操作视图：Operational views

Interface

Description

Key Type Operations

ValueOperations

Redis string (or value) operations

ListOperations

Redis list operations

SetOperations

Redis set operations

ZSetOperations

Redis zset (or sorted set) operations

HashOperations

Redis hash operations

HyperLogLogOperations

Redis HyperLogLog operations like (pfadd, pfcount,…)

Key Bound Operations

BoundValueOperations

Redis string (or value) key bound operations

BoundListOperations

Redis list key bound operations

BoundSetOperations

Redis set key bound operations

BoundZSetOperations

Redis zset (or sorted set) key bound operations

BoundHashOperations

Redis hash key bound operations


本文转自 randy_shandong 51CTO博客，原文链接：http://blog.51cto.com/dba10g/1889115，如需转载请自行联系原作者

文章标签：
云数据库 Tair（兼容 Redis）
Redis
NoSQL
测试技术
Spring
Java
关键词：
Spring Data
云数据库 Tair（兼容 Redis）spring
云数据库 Tair（兼容 Redis）data
Spring redis
spring data云数据库 Tair（兼容 Redis）
技术小阿哥
目录
相关文章
一枚后端工程狮
|
8月前
|
NoSQL Java 数据库连接
《深入理解Spring》Spring Data——数据访问的统一抽象与极致简化
Spring Data通过Repository抽象和方法名派生查询，简化数据访问层开发，告别冗余CRUD代码。支持JPA、MongoDB、Redis等多种存储，统一编程模型，提升开发效率与架构灵活性，是Java开发者必备利器。（238字）
一枚后端工程狮
439 8
啦啦啦191
|
8月前
|
存储 Java 关系型数据库
Spring Boot中Spring Data JPA的常用注解
Spring Data JPA通过注解简化数据库操作，实现实体与表的映射。常用注解包括：`@Entity`、`@Table`定义表结构；`@Id`、`@GeneratedValue`配置主键策略；`@Column`、`@Transient`控制字段映射；`@OneToOne`、`@OneToMany`等处理关联关系；`@Enumerated`、`@NamedQuery`支持枚举与命名查询。合理使用可提升开发效率与代码可维护性。（238字）
啦啦啦191
698 1
存储 JSON Java
927 0
HELLO程序员
|
9月前
|
NoSQL Java 调度
分布式锁与分布式锁使用 Redis 和 Spring Boot 进行调度锁（不带 ShedLock）
分布式锁是分布式系统中用于同步多节点访问共享资源的机制，防止并发操作带来的冲突。本文介绍了基于Spring Boot和Redis实现分布式锁的技术方案，涵盖锁的获取与释放、Redis配置、服务调度及多实例运行等内容，通过Docker Compose搭建环境，验证了锁的有效性与互斥特性。
HELLO程序员
786 0
分布式锁与分布式锁使用 Redis 和 Spring Boot 进行调度锁（不带 ShedLock）
JJLIN距离
|
9月前
|
SQL Java 数据库连接
Spring Data JPA 技术深度解析与应用指南
本文档全面介绍 Spring Data JPA 的核心概念、技术原理和实际应用。作为 Spring 生态系统中数据访问层的关键组件，Spring Data JPA 极大简化了 Java 持久层开发。本文将深入探讨其架构设计、核心接口、查询派生机制、事务管理以及与 Spring 框架的集成方式，并通过实际示例展示如何高效地使用这一技术。本文档约1500字，适合有一定 Spring 和 JPA 基础的开发者阅读。
JJLIN距离
830 0
Adrian_
|
11月前
|
NoSQL Java Redis
Redis基本数据类型及Spring Data Redis应用
Redis 是开源高性能键值对数据库，支持 String、Hash、List、Set、Sorted Set 等数据结构，适用于缓存、消息队列、排行榜等场景。具备高性能、原子操作及丰富功能，是分布式系统核心组件。
Adrian_
791 2
蓝易云
|
消息中间件 缓存 NoSQL
基于Spring Data Redis与RabbitMQ实现字符串缓存和计数功能（数据同步）
总的来说，借助Spring Data Redis和RabbitMQ，我们可以轻松实现字符串缓存和计数的功能。而关键的部分不过是一些"厨房的套路"，一旦你掌握了这些套路，那么你就像厨师一样可以准备出一道道饕餮美食了。通过这种方式促进数据处理效率无疑将大大提高我们的生产力。
蓝易云
381 32
Coding枫叶
|
缓存 NoSQL Java
springboot业务开发--springboot集成redis解决缓存雪崩穿透问题
该文介绍了缓存使用中可能出现的三个问题及解决方案：缓存穿透、缓存击穿和缓存雪崩。为防止缓存穿透，可校验请求数据并缓存空值；缓存击穿可采用限流、热点数据预加载或加锁策略；缓存雪崩则需避免同一时间大量缓存失效，可设置随机过期时间。文章还提及了Spring Boot中Redis缓存的配置，包括缓存null值、使用前缀和自定义过期时间，并提供了改造代码以实现缓存到期时间的个性化设置。
Coding枫叶
493 0
风水道人
|
NoSQL Java Redis
SpringBoot集成Redis解决表单重复提交接口幂等（亲测可用）
SpringBoot集成Redis解决表单重复提交接口幂等（亲测可用）
风水道人
1052 0
风水道人
|
NoSQL Java Redis
SpringBoot集成Redis并使用Redis发布订阅模式
SpringBoot集成Redis并使用Redis发布订阅模式
风水道人
906 3

热门文章

最新文章

  • 1
    Springboot2.1.1版本升级到2.3.10版本报错合集及解决办法
  • 2
    Mybatis逆向工程---在SpringBoot项目中构建Mybatis生成器
  • 3
    SpringBoot整合MybatisPlus【超详细】
  • 4
    spring jdbc JdbcTemplate入门
  • 5
    Spring Boot 2.x 实战--什么是 Spring Boot？
  • 6
    Spring注解扫描：ComponentScan使用及原理详解
  • 7
    SpringBoot自定义异常，优雅解决业务逻辑中的错误
  • 8
    两种Spring Boot 项目启动自动执行方法的实现方式
  • 9
    springboot整合mybatis-plus详解
  • 10
    Spring Boot 日志记录（log）
  • 1
    SpringBoot启动时连接Redis报错：ERR This instance has cluster support disabled - 如何解决？
    673
  • 2
    Redis 服务器全方位介绍：从入门到核心原理
    844
  • 3
    MySQL 与 Redis 如何保证双写一致性？
    837
  • 4
    【Docker】（3）学习Docker中 镜像与容器数据卷、映射关系！手把手带你安装 MySql主从同步 和 Redis三主三从集群！并且进行主从切换与扩容操作，还有分析 哈希分区 等知识点！
    858
  • 5
    Redis常见面试题全解析
    807
  • 6
    手把手教你用 Docker 部署 Redis
    2569
  • 7
    135_负载均衡：Redis缓存 - 提高缓存命中率的配置与最佳实践
    816
  • 8
    Redis 7.0 高性能缓存架构设计与优化
    1529
  • 9
    redis上db复制的方法
    378
  • 10
    Redis高可用架构全解析：从主从复制到集群方案
    753

    • 相关课程

    更多
  • 大数据实战项目：反爬虫系统（Lua+Spark+Redis+Hadoop框架搭建）第一阶段
  • 大数据实战项目：反爬虫系统（Lua+Spark+Redis+Hadoop框架搭建）第二阶段
  • 大数据实战项目：反爬虫系统（Lua+Spark+Redis+Hadoop框架搭建）第三阶段
  • Redis入门实战演练
  • 云数据库 Redis 版使用教程
  • Redis数据库入门

    • 相关电子书

    更多
  • ApsaraDB for Redis——与创客同行
  • 微博的Redis定制之路
  • 云数据库Redis版的开源之路
    • 下一篇
    阿里云正式发布 Agentic 代码安全：AI驱动的双Agent协同引擎