[数据库] Redis学习笔记（二）：Redis Java客户端（Jedis/SpringDataRedis）
Redis学习笔记
Java 客户端
- 官方网站：https://redis.io/clients
- 常见客户端：
- Jedis：以 Redis 命令作为方法名称，学习成本低，简单实用。但是 Jedis 实例是线程不安全的，多线程环境下需要基于连接池来使用。
- Lettuce：基于 Netty 实现，支持同步、异步和响应式编程方式，而且是线程安全的。支持 Redis 的哨兵模式、集群模式和管道模式。
- Redisson：分布式、可伸缩的 Java 数据结构集合。包含了诸如 Map 、Queue 、Lock、Semaphore、AtomicLong 等强大功能。
Jedis
- 官网：https://github.com/redis/jedis
快速入门
- 引入依赖（版本截至文章发布）
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>5.0.0</version>
</dependency>
- 建立连接
private Jedis jedis;
@BeforeEach
void setUp() {
// 建立连接（xx.xx.xx.xx处为Redis连接的ip地址）
jedis = new Jedis("xx.xx.xx.xx", 6379);
// 设置密码
jedis.auth("123456")
// 选择库
jedis.select(0);
}
- 测试 String
@Test
void testString() {
// 插入数据，方法名称就是 redis 命令名称
String result = jedis.set("name", "Alice");
System.out.println("result = " + result);
// 获取数据
String name = jedis.get("name");
System.out.println("name = " + name);
}
- 释放资源
@AfterEach
void tearDown() {
// 释放资源
if (jedis != null) {
jedis.close();
}
}
连接池
- Jedis 本身线程不安全，并且频繁的创建和销毁连接会有性能损耗，因此我们推荐大家使用 Jedis 连接池代替 Jedis 的直连方式。
public class JedisConnectFactory {
private static final JedisPool jedisPool;
static {
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
// 最大连接
jedisPoolConfig.setMaxTotal(8);
// 最大空闲连接
jedisPoolConfig.setMaxIdle(8);
// 最小空闲连接
jedisPoolConfig.setMinIdle(0);
// 设置最长等待时间, ms
jedisPoolConfig.setMaxWaitMillis(200);
jedisPool = new JedisPool(jedisPoolConfig, "xx.xx.xx.xx", 6379, 1000, "123456");
}
// 获取 Jedis 对象
public static Jedis getJedis() {
return jedisPool.getResource();
}
}
Spring Data Redis
介绍
- SpringData 是 Spring 中数据操作的模块，包含对各种数据库的集成，其中对 Redis 的集成模块就叫做 SpringDataRedis 。
- 官网地址：https://spring.io/projects/spring-data-redis
- 提供了对不同 Redis 客户端的整合（Lettuce 和 Jedis）
- 提供了对 RedisTemplate 统一 API 来操作 Redis
- 支持 Redis 的发布订阅模型
- 支持 Redis 哨兵和 Redis 集群
- 支持基于 Lettuce 的响应式编程
- 支持基于 JDK、 JSON、字符串、Spring 对象的数据序列化及反序列化
- 支持基于 Redis 的 JDKCollection 实现
- SpringDataRedis 中提供了
RedisTemplate工具类，其中封装了各种对 Redis 的操作。并且将不同数据类型的操作 API 封装到了不同的类型中：
| API | 返回值类型 | 说明 |
| — | — | — |
|redisTemplate.opsForValue()|ValueOperations| 操作String类型数据 |
|redisTemplate.opsForHash()|HashOperations| 操作Hash类型数据 |
|redisTemplate.opsForList()|ListOperations| 操作List类型数据 |
|redisTemplate.opsForSet()|SetOperations| 操作Set类型数据 |
|redisTemplate.opsForZSet|ZSetOperation| 操作SortedSet类型数据 |
|redisTemplate| | 通用数据 |
快速入门
- 引入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
- 配置文件(
application.yml)
spring.application.name: SpringDataRedisLearning
spring:
data:
redis:
host: 127.0.0.1
port: 6379
password: 31321
lettuce:
pool:
max-active: 8
max-idle: 8
min-idle: 0
max-wait: 100
- 注入
RedisTemplate
@Autowired
private RedisTemplate redisTemplate;
- 编写测试
@Test
void testString() {
redisTemplate.opsForValue().set("name", "Alice");
Object name = redisTemplate.opsForValue().get("name");
System.out.println("name = " + name);
}
序列化
RedisTemplate可以接收任意Object作为值写入Redis，只不过写入前会把Object序列化为字节形式，默认是采用JDK序列化，可读性差且内存占用大。- 自定义 RedisTemplate 的序列化方式：
@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
// 创建RedisTemplate对象
RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
// 设置连接工厂
template.setConnectionFactory(connectionFactory);
// 创建JSON序列化工具
GenericJackson2JsonRedisSerializer jsonRedisSerializer = new GenericJackson2JsonRedisSerializer();
// 设置Key的序列化
template.setKeySerializer(RedisSerializer.string());
template.setHashKeySerializer(RedisSerializer.string());
// 设置value的序列化
template.setValueSerializer(jsonRedisSerializer);
template.setHashValueSerializer(jsonRedisSerializer);
// 返回
return template;
}
在注入时标注泛型：
@Autowired
private RedisTemplate <String, Object> redisTemplate;
自定义序列化之后，可以将对象作为 Value 操作，会序列化为 JSON
@Test
void testSaveUser() {
// 写入数据
redisTemplate.opsForValue().set("user:100", new User("Alice", 18));
// 获取数据
User res = (User) redisTemplate.opsForValue().get("user:100");
System.out.println("res = " + res);
}
在序列化对象时，JSON 序列化器会将对象的类地址标注在 JSON 的 "@class" 属性中，如：
{
"@class": "com.eastwood.redis.pojo.User",
"name": "Alice",
"age": 18
}
StringRedisTemplate
- 背景：JSON 序列化器标注类的特性会导致额外的内存占用，但不标注则无法实现自动反序列化
- 为了节省内存空间，我们并不会使用 JSON 序列化器来处理
value，而是统一使用String序列化器，要求只能存储String类型的key和value。当需要存储 Java 对象时，手动完成对象的序列化和反序列化。 - Spring 默认提供了一个
StringRedisTemplate类，它的 key 和 value 的序列化方式默认就是 String 方式。省去了我们自定义 RedisTemplate 的过程：
private static final ObjectMapper mapper = new ObjectMapper();
@Test
void testSaveUser() throws JsonProcessingException {
// 创建对象
User user = new User("Alice", 18);
// 手动序列化
String json = mapper.writeValueAsString(user);
// 写入数据
stringRedisTemplate.opsForValue().set("user:200", json);
// 获取数据
String jsonUser = stringRedisTemplate.opsForValue().get("user:200");
// 手动反序列化
User res = mapper.readValue(jsonUser, User.class);
System.out.println("res = " + res);
}
RedisTemplate 的 Hash 操作
@Test
void testHash() {
stringRedisTemplate.opsForHash().put("user:400", "name", "Alice");
stringRedisTemplate.opsForHash().put("user:400", "age", "18");
Map <Object, Object> entries = stringRedisTemplate.opsForHash().entries("user:400");
System.out.println("entries = " + entries);
}