Redis基础篇——集成客户端

四、Redis的Java客户端

在Redis官网中提供了各种语言的客户端，地址：https://redis.io/clients

image-20241210215022257

• jedis和Lettuce：这两个主要是提供了Redis命令对应的API，方便我们操作Redis，而SpringDataRedis又对这两种做了抽象和封装（SpringBoot默认使用Lettuce），因此后期可以以SpringDataRedis来学习。
• Redisson：是在Redis基础上实现了分布式的可伸缩的java数据结构，例如Map.Queue等，而且支持跨进程的同步机制：Lock.Semaphore等待，比较适合用来实现特殊的功能需求。

4.1、Jedis

快速入门

1. 引入依赖

<!--jedis-->
<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>3.7.0</version>
</dependency>

2. 建立连接

private Jedis jedis;@BeforeEach
void setUp() {// 1.建立连接jedis = new Jedis("主机ip", 6379);// 2.设置密码jedis.auth("123321");// 3.选择库jedis.select(0);
}

3. 测试

@Test
void testString() {// 存入数据String result = jedis.set("name", "虎哥");System.out.println("result = " + result);// 获取数据String name = jedis.get("name");System.out.println("name = " + name);
}@Test
void testHash() {// 插入hash数据jedis.hset("user:1", "name", "Jack");jedis.hset("user:1", "age", "21");// 获取Map<String, String> map = jedis.hgetAll("user:1");System.out.println(map);
}

4. 释放资源

@AfterEach
void tearDown() {if (jedis != null) {jedis.close();}
}

Jedis连接池

Jedis本身是线程不安全的，并发模式下需要为每个线程创建Jedis连接，使用完再释放连接。频繁的创建和销毁连接会有性能损耗，因此推荐使用Jedis连接池代替Jedis的直连方式

创建Jedis连接池，通过连接池获取Jedis连接

public class JedisConnectionFactory {private static JedisPool jedisPool;static {//配置连接池JedisPoolConfig poolConfig = new JedisPoolConfig();//最大连接poolConfig.setMaxTotal(10);//最大空闲连接poolConfig.setMaxIdle(8);//最小空闲连接poolConfig.setMinIdle(0);//设置最长等待时间 ，单位mspoolConfig.setMaxWaitMillis(200);//创建连接池对象jedisPool = new JedisPool(poolConfig,"192.168.181.100",6379,1000,"liuhao123");}//获取Jedis对象public static Jedis getJedis() {return jedisPool.getResource();}
}

@BeforeEachvoid setUp(){//建立连接/*jedis = new Jedis("127.0.0.1",6379);*/jedis = JedisConnectionFacotry.getJedis();//选择库jedis.select(0);}@AfterEachvoid tearDown() {if (jedis != null) {jedis.close();}}

1. 在完成了使用工厂设计模式来完成代码的编写之后，我们在获得连接时，就可以通过工厂来获得，而不用直接去new对象，降低耦合，并且使用的还是连接池对象。
2. 当我们使用了连接池后，当我们关闭连接其实并不是关闭，而是将Jedis连接归还给连接池。

4.2、SpringDataRedis

SpringData是Spring中数据操作的模块，包含对各种数据库的集成，其中对Redis的集成模块就叫做SpringDataRedis，官网地址

• 提供了对不同Redis客户端的整合（Lettuce和Jedis）
• 提供了RedisTemplate统一API来操作Redis
• 支持Redis的发布订阅模型
• 支持Redis哨兵和Redis集群
• 支持基于Lettuce的响应式编程
• 支持基于JDK.JSON.字符串.Spring对象的数据序列化及反序列化（方便数据的存储和读取）
• 支持基于Redis的JDKCollection实现

SpringDataRedis中提供了RedisTemplate工具类，其中封装了各种对Redis的操作。像redis一样，对不同数据类型做了分组，将不同数据类型的操作API封装到了不同的类型中：

image-20241210221341487

快速入门

SpringBoot已经提供了对SpringDataRedis的支持，创建一个SpringBoot项目进行测试，步骤如下：

1. 引入依赖

<!--redis依赖--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency><!--common-pool--><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId></dependency><!--Jackson依赖--><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId></dependency>

2. 配置文件

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

3. 测试

@SpringBootTest
class RedisDemoApplicationTests {@Autowiredprivate RedisTemplate<String, Object> redisTemplate;@Testvoid testString() {// 写入一条String数据redisTemplate.opsForValue().set("name", "jack");// 获取string数据Object name = redisTemplate.opsForValue().get("name");System.out.println("name = " + name);}
}

RedisTemplate的两种序列化实践方案

RedisTemplate可以接收任意Object作为值写入Redis，在写入前会把Object序列化为字节形式，默认是采用JDK序列化

image-20241211014252619

得到的结果如下，可读性差，内存占用较大。

image-20241211005242136

可以采用两种方案解决

方案一：

1. 自定义RedisTemplate
2. 修改RedisTemplate的序列化器为GenericJackson2JsonRedisSerializer

@Configuration
public class RedisConfig {@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory){// 创建RedisTemplate对象RedisTemplate<String, Object> template = new RedisTemplate<>();// 设置连接工厂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;}
}

//测试代码
@SpringBootTest
class HmDianPingApplicationTests {@Autowiredprivate RedisTemplate<String,Object> redisTemplate;@Testvoid testString() {// 写入一条String数据redisTemplate.opsForValue().set("name", "jack");// 获取string数据Object name = redisTemplate.opsForValue().get("name");System.out.println("name = " + name);}@Testvoid testUser() {//存入对象数据redisTemplate.opsForValue().set("user:100",new TestUser("Dylan",20));//获取数据TestUser o = (TestUser) redisTemplate.opsForValue().get("user:100");System.out.println("o = "+ o);}
}

采用了JSON序列化来代替默认的JDK序列化方式。最终结果如图：

image-20241211011952945

同时可以将Java对象自动的序列化为JSON字符串，并且查询时能自动把JSON反序列化为Java对象。不过，其中记录了序列化时对应的class名称，目的是为了查询时实现自动反序列化。这会带来额外的内存开销。

image-20241211012224081

方案二：

1. 使用StringRedisTemplate
2. 写入Redis时，手动把对象序列化为JSON
3. 读取Redis时，手动把读取到的JSON反序列化为对象

为了在反序列化时知道对象的类型，JSON序列化器会将类的class类型写入json结果中，存入Redis，会带来额外的内存开销。为了减少内存的消耗，我们可以采用手动序列化和反序列化。

同时，只采用String的序列化器，这样，在存储value时，就不需要在内存中就不用多存储数据，从而节约内存空间。SpringDataRedis就提供了RedisTemplate的子类：<font style="background-color:rgba(175, 184, 193, 0.2);">StringRedisTemplate</font>，它的key和value的序列化方式默认就是String方式。

省去了自定义RedisTemplate的序列化方式的步骤，而是直接使用：StringRedisTemplate

@SpringBootTest
class HmDianPingApplicationTests {@Autowiredprivate StringRedisTemplate stringRedisTemplate;//进行序列化和反序列化的工具private static final ObjectMapper mapper = new ObjectMapper();@Testvoid testUser() throws JsonProcessingException {//创建对象TestUser testUser = new TestUser("Lucy", 21);//手动序列化String json = mapper.writeValueAsString(testUser);//写入数据stringRedisTemplate.opsForValue().set("user:200",json);//获取数据String jsonUser = stringRedisTemplate.opsForValue().get("user:200");//反序列化TestUser user = mapper.readValue(jsonUser, TestUser.class);System.out.println("user ="+ user);}
}

此时存储的内容没有之前的class信息，节约了存储空间

image-20241211013242601

补充

Windows的Redis图形化客户端连接不上虚拟机中的Redis问题

1、修改redis.conf配置文件

image-20241212095439904

2、在linux下的防火墙中开放6379端口

sudo firewall-cmd --zone=public --add-port=6379/tcp --permanent

3、重新载入firewalld以应用更改

sudo firewall-cmd --reload

4、检查端口是否已开放

sudo firewall-cmd --zone=public --list-ports