Redis学习路线（3）——Redis的Java客户端

一、如何使用Redis的Java客户端

官方文档： https://redis.io/docs/clients/java/

Java-Redis客户端	使用场景
Jeids	以Redis命令作为方法名称，学习成本低，简单实现，但是Jedis实例是线程不安全的，多线程环境下需要基于连接池使用。
lettuce	Lettuce 是基于Netty实现的，支持同步、异步和响应式编程方式，并且是线程安全的。Redis的哨兵模式、集群模式和管道模式。
Redisson	Redisson是基于Redis实现的分布式、可伸缩的Java数据结构集合。包含了诸如Map、Queue、Lock、Semaphore（信号量）、AtomicLong（原子类）等强大功能

SpringDataRedis： 一款结合了Jedis和Lettuce的SpringBoot框架整合Redis组件。

---

二、Jedis

Jedis官网： https://github.com/redis/jedis

Redis的官方也推荐了这种客户端。

（一）引入依赖

<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>4.3.1</version>
</dependency>

（二）建立连接

方式一：单点连接

    private Jedis jedis;@BeforeEachvoid setup() {//建立连接jedis = new Jedis("192.168.92.131",6379);//设置密码jedis.auth("123321");//选择数据库jedis.select(0);}@Testvoid redisTest(){//插入数据String result = jedis.set("name","张三");System.out.println("result="+result);//获取数据String name = jedis.get("name");System.out.println("name="+name);}@AfterEachvoid destroy() {if (jedis != null)jedis.close();}//获取的结果
result=OK
name=张三

方式二：连接池建立连接

public class JedisConnectionFactory {private static final JedisPool jedisPool;static {//1、创建连接池配置对象JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();//2、配置连接池相关信息// 最大连接数jedisPoolConfig.setMaxTotal(8);// 最大空间连接jedisPoolConfig.setMaxIdle(8);// 最小空闲连接jedisPoolConfig.setMinIdle(0);// 设置最长等待时间，msjedisPoolConfig.setMaxWaitMillis(200);//3、建立连接池，需要连接池配置，ip，端口，等待时间，密码jedisPool = new JedisPool(jedisPoolConfig, "192.168.92.131",6379,1000,"123321");}public static Jedis getConnection(){//获取单个连接return jedisPool.getResource();}}

---

三、SpringDataRedis

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实现

（一）RedisTemplate

RedisTemplate将不同的数据类型操作API封装到不同类型中。

API	返回值类型	说明
redisTemplate.opsForValue()	ValueOperations	操作String类型数据
redisTemplate.opsForHash()	HashOperations	操作Hash类型数据
redisTemplate.opsForList()	ListOperations	操作List类型数据
redisTemplate.opsForSet()	SetOperations	操作Set类型数据
redisTemplate.opsForZSet()	ZSetOperations	操作SortedSet类型数据
redisTemplate		通用命令

（二）RedisTemplate的基本使用

1、引入依赖

<!--Redis依赖-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency><!--连接池依赖-->
<dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId>
</dependency>

2、配置redis

spring:redis:host: 192.168.92.131port: 6379password: 123321lettuce:pool:max-active: 8 #最大连接数max-idle: 8 #最大空闲连接min-idle: 0 #最小空闲连接max-wait: 100 #连接等待时间

3、注入RedisTemplate

@Autowired
private RedisTemplate redisTemplate;

4、使用RedisTemplate

@Autowired
private RedisTemplate redisTemplate;public void operateString(){// 插入一条string类型的数据，存储的格式是Java序列化的格式redisTemplate.opsForValue().set("name", "李四");// 读取一条string类型数据Object name = redisTemplate.opsForValue().get("name");System.out.println("name = " + name);
}

5、优化RedisTemplate存储序列化的现象

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

缺点： JSON序列化时会将calss的类型写入json结果中，存入Redis中，带来额外的内存。

为了节省内存空间，我们并不会使用JSON序列化器来处理value，而是统一使用String序列化器，要求只能存储String类型的key 和 value，当需要存储Java对象时，手动完成序列化和反序列化。

Spring默认提供了一个StringRedisTemplate类，它的key和value的序列化方式默认就是String方式，省去自定义RedisTemplate的过程。**
（PS：不如直接用alibaba开源的fastjson，减少学习成本，但要注意的是 在JSON插件的排行中 ，jackson-databind > gson > fastjson，这就说明了问题，fastjson 专注于性能，但安全性不足，gson是保证了安全性，如果可以，在项目中应该使用gson）**

@Autowired
private StringRedisTemplate stringRedisTemplate;//JSON工具
private static final ObjectMapper mapper = new ObjectMapper();@Test
void testStringTemplate() throws JsonProcessingException {//准备对象User user = new User("zain", 23);//手动序列化String json = mapper.writeValueAsString(user);//写入一条数据stringRedisTemplate.opsForValue().set("jedis:user:2", json);// 读取数据String val = stringRedisTemplate.opsForValue().get("jedis:user:2");// 反序列化User user1 = mapper.readValue(val, User.class);
}