前言

在上一章【Redis从入门到精通(二)Redis的数据类型和常见命令介绍】中，学习了Redis的五种基本数据类型，即String、Hash、List、Set、SortedSet类型，及其常用的命令。

这一节学习Redis的两种Java客户端：Jedis和SpringDataRedis。

第3章 Redis的Java客户端

3.1 Jedis客户端

Jedis是Redis的一个Java客户端，旨在提高性能和易用性。 Jedis的官网地址：https://github.com/redis/jedis。

3.1.1 快速使用

• 1）创建一个maven项目，引入jedis依赖：

<!--jedis-->
<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>2.9.0</version>
</dependency>
<!--单元测试-->
<dependency><groupId>org.junit.jupiter</groupId><artifactId>junit-jupiter</artifactId><version>5.7.0</version><scope>test</scope>
</dependency>

• 2）编写单元测试

public class JedisTest01 {private Jedis jedis;@Beforepublic void setUp() {// 1.建立连接jedis = new Jedis("192.168.146.128", 6379);// 2.设置密码jedis.auth("123321");// 3.选择库jedis.select(0);}@Testpublic void testJedis() {// 存入String类型数据String result = jedis.set("myPro:user", "马老板");System.out.println("result = " + result);// 获取String类型数据String user = jedis.get("myPro:user");System.out.println("user = " + user);// 存入Hash类型数据Long result2 = jedis.hset("myPro:book", "name", "《三体1：地球往事》");System.out.println("result2 = " + result2);// 获取Hash类型数据String name = jedis.hget("myPro:book", "name");System.out.println("name = " + name);}@Afterpublic void cleanUp() {if(jedis != null) {jedis.close();}}
}

• 3）执行单元测试

result = OK
user = 马老板
result2 = 1
name = 《三体1：地球往事》

在桌面客户端查看数据：

3.1.2 连接池

Jedis本身是线程不安全的，并且频繁地创建和销毁连接会有性能损耗，因此推荐使用Jedis连接池代替Jedis直连。

下面创建一个Jedis连接工厂，保存Jedis连接池：

public class JedisConnectionFactory {private static JedisPool jedisPool;static {// 配置连接池JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();// 最大连接数jedisPoolConfig.setMaxTotal(8);// 最大空闲连接数jedisPoolConfig.setMaxIdle(8);// 最小空现连接数jedisPoolConfig.setMinIdle(0);// 连接用尽后，最大等待时间（毫秒）jedisPoolConfig.setMaxWaitMillis(1000);// 创建连接池对象，参数分别是：配置信息、服务端IP、端口、超时时间（毫秒）、密码jedisPool = new JedisPool(jedisPoolConfig, "192.168.146.128", 6379, 1000, "123321");}public static Jedis getJedis() {return jedisPool.getResource();}
}

在单元测试中，可以改成从连接池中获取Jedis对象：

@Before
public void setUp() {// 1.建立连接// jedis = new Jedis("192.168.146.128", 6379);// 改用连接池方式获取Jedis对象jedis = JedisConnectionFactory.getJedis();// 2.设置密码jedis.auth("123321");// 3.选择库jedis.select(0);
}

3.2 SpringDataRedis客户端

SpringData是Spring中的数据操作模块，包含对各种数据库操作的集成，其中对Redis的集成模块就叫做SpringDataRedis。 官网地址是：https://spring.io/projects/spring-data-redis。

在官网文档中，列出了SpringDataRedis的主要特点：

• 提供了对不同Redis客户端的整合（Lettuce和Jedis）
• 提供了RedisTemplate工具类来统一操作Redis
• 支持Redis的发布订阅模型
• 支持Redis哨兵模式和集群模式
• 支持基于Lettuce的响应式编程
• 支持基于JDK、JSON、字符串、Spring对象的数据序列化和反序列化
• 支持基于Redis的JDK Collection实现

对开发人员来说，最需要关注的是RedisTemplate工具类，它封装了各种对Redis的操作API：

3.2.1 快速使用

SpringBoot已经提供了对SpringDataRedis的支持，因此可以通过SpringBoot项目类使用SpringDataRedis。

• 1）创建一个SpringBoot项目，引入相关依赖：

<?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><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.3.11.RELEASE</version></parent><groupId>com.star.redis</groupId><artifactId>redis_learning_spring</artifactId><version>1.0-SNAPSHOT</version><dependencies><!--redis--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency><!--commons-pool--><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId></dependency><!--json--><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId></dependency><!--lombok--><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><!--test--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies>
</project>

• 2）在src/test/resources目录下新建配置文件application.yml，配置Redis相关信息：

spring:redis:host: 192.168.146.128port: 6379password: 123321lettuce:pool:max-active: 8max-idle: 8min-idle: 0max-wait: 1000

• 3）在src/main/java目录下新建SpringBoot主启动类

@SpringBootApplication
public class MyApp {public static void main(String[] args) {SpringApplication.run(MyApp.class, args);}
}

• 4）在src/test/java目录下新建测试类RedisSpringTest，编写单元测试

@RunWith(SpringRunner.class)
@SpringBootTest(classes = MyApp.class)
public class RedisSpringTest {@Autowiredprivate RedisTemplate redisTemplate;@Testpublic void test() {// 添加String类型数据redisTemplate.opsForValue().set("mySpring:name", "孙悟空");// 获取String类型数据Object name = redisTemplate.opsForValue().get("mySpring:name");System.out.println("name = " + name);}}

最终的项目结构如下：

• 5）执行单元测试

name = 孙悟空

3.2.2 自定义序列化

在上面的案例中，redisTemplate.opsForValue().set()方法的两个参数的类型均为Object，在写入Redis之前会把Object序列化为字节形式（默认采用JDK序列化），取出时又会反序列化。因此在Redis中保存的数据是这样的：

缺点比较明显：可读性差、内存占用较大。

为此，可以通过自定义RedisTemplate的序列化方法解决这个问题。

在项目中新建一个配置类RedisConfig：

@Configuration
public class RedisConfig {@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {// 创建RedisTemplate对象RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();// 设置连接工厂redisTemplate.setConnectionFactory(redisConnectionFactory);// 创建JSON序列化工具GenericJackson2JsonRedisSerializer jsonRedisSerializer = new GenericJackson2JsonRedisSerializer();// 设置Key的序列化redisTemplate.setKeySerializer(RedisSerializer.string());redisTemplate.setHashKeySerializer(RedisSerializer.string());// 设置Value的序列化redisTemplate.setValueSerializer(jsonRedisSerializer);redisTemplate.setHashValueSerializer(jsonRedisSerializer);// 返回return redisTemplate;}
}

新建一个实体对象User：

@Data
@NoArgsConstructor
@AllArgsConstructor
public class User {private String name;private Integer age;private Date birthday;
}

编写一个单元测试：

@Test
public void testJson() {// 添加String类型数据User user = new User("猪八戒", 500, new Date());redisTemplate.opsForValue().set("mySpring:user", user);// 获取String类型数据User user1 = (User) redisTemplate.opsForValue().get("mySpring:user");System.out.println(user1);
}

执行单元测试：

User(name=猪八戒, age=500, birthday=Sun Mar 31 14:48:27 CST 2024)

可见，在将User对象存入Redis时，会自动的序列化为JSON字符串，查询时也会自动地反序列化为Java对象。整体可读性有了很大的提升。

但要注意，序列化后的数据保存了Java对象对应的Class名称，目的是为了查询时实现自动地反序列化，但这会带来额外的内存开销。

3.2.3 StringRedisTemplate

使用JSON序列化器来处理Value值，会将class信息写入Redis，带来额外的内存开销。

要解决这个问题，可以统一使用String序列化器，也就是Key和Value值都只能使用String类型。这样意味着Java对象的序列化和反序列化需要手动实现。

这种用法比较普遍，因此SpringDataRedis就已经提供了一个RedisTemplate的子类：StringRedisTemplate，它的Key和Value值都采用String类型的序列化方式。

源码：org.springframework.data.redis.core.StringRedisTemplatepublic class StringRedisTemplate extends RedisTemplate<String, String> {public StringRedisTemplate() {setKeySerializer(RedisSerializer.string());setValueSerializer(RedisSerializer.string());setHashKeySerializer(RedisSerializer.string());setHashValueSerializer(RedisSerializer.string());}
}

在代码中可以直接使用StringRedisTemplate，例如：

@RunWith(SpringRunner.class)
@SpringBootTest(classes = MyApp.class)
public class StringRedisTemplateTest {@Autowiredprivate StringRedisTemplate stringRedisTemplate;private static final ObjectMapper mapper = new ObjectMapper();@Testpublic void testSaveUser() throws JsonProcessingException {User user = new User("唐僧", 98, new Date());// 手动序列化String json = mapper.writeValueAsString(user);// 写入数据stringRedisTemplate.opsForValue().set("mySpring:user:200", json);// 获取数据String jsonUser = stringRedisTemplate.opsForValue().get("mySpring:user:200");// 手动反序列化User user1 = mapper.readValue(jsonUser, User.class);System.out.println(user1);}
}

执行单元测试：

User(name=唐僧, age=98, birthday=Sun Mar 31 15:02:25 CST 2024)

3.3 小结

第3章到此就学习完毕了，本章的主题是：Redis的Java客户端。回顾一下本章的学习的内容：

(三)Jedis客户端、SpringDataRedis客户端

更多内容请查阅分类专栏：Redis从入门到精通

第4章主要学习：Redis实战项目：短信登录。

感兴趣的读者还可以查阅我的另外几个专栏：

• SpringBoot源码解读与原理分析(已完结)
• MyBatis3源码深度解析(已完结)
• 再探Java为面试赋能(持续更新中…)