Redis之Java客户端【Jedis，Spring Data Redis】

叫我阿杰好了

发布于 2022-11-07 14:26:18

1.1K0

发布于 2022-11-07 14:26:18

文章被收录于专栏：一切总会归于平淡

2.2 SpringDataRedis的序列化方式

在Redis官网中提供了各种语言的客户端，地址：/docs/clients/，不过我是学Java的，那这里就给大家介绍javad的客户端。

点击图中标红的Java点击。

这里就大家简单介绍一下名列前茅的三种客户端。

1、Jedis

优点：以命令作为方法名称，学习成本低，简单实用。缺点：但是实例是线程不安全的，多线程环境下需要基于连接池来使用

2、lettuce

是基于Netty实现的，支持同步、异步和响应式编程方式，并且是线程安全的。支持Redis的哨兵模式、集群模式和管道模式。

3、Redisson

是一个基于Redis实现的分布式、可伸缩的Java数据结构集合。包含了诸如Map、Queue、Lock、 Semaphore、AtomicLong等强大功能

以上是3种客户端的简单介绍，一般我们使用Redis做一些简单的业务逻辑，使用Jedis和lettuce相对会方便一些。

一个一个去学就优点费劲，所以我们会使用到spring，spring最擅长的东西就是整合了，Spring Data Redis 就整合了这两种方式。

不过可能有很多企业并没有使用spring 这套API ,而是使用Jedis，简单嘛，所以本篇博客也会简单介绍一下Jedis 的简单使用。

1、Jedis

Jedis的官网地址： GitHub - redis/jedis: Redis Java client designed for performance and ease of use.，我们先来个快速入门：

我们先简单建一个MAVEN 项目，然后在pom.xml 引入依赖。

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

最好再引入一个junit 单元测试，我就基于单元测试给大家演示。

引入完依赖，我们就开始下一步，建立连接。

建立连接之后，就可以测试方法啦，比如Reids Stirng类型的 SET

最后别忘记了关闭连接。

运行结果：

除了控制台打印的，我们还可以使用 Redis 的可视化工具看看。

其他方法也是如此，大家可以去试试。

1.1 Jedis 连接池

前面也介绍了Jedis 的线程是不安全的，并且频繁的创建和销毁连接会有性能损耗，因此我们推荐大家使用Jedis连接池代替Jedis的直连方式。这里就直接创建一个工厂类。

package com.jie.introduction;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.JedisSentinelPool;

/**
 * @description:jedis连接池
 * @author: jie
 * @time: 2022/4/27 21:38
 */
public class JedisConnectionFactory {

    private static final JedisPool JEDIS_POOL;

    static {
        //配置连接池
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        //设置连接数
        jedisPoolConfig.setMaxTotal(8);
        //设置最大空闲连接
        jedisPoolConfig.setMaxIdle(8);
        // 设置最小连接
        jedisPoolConfig.setMinIdle(0);
        //等待时长 当连接池没有可用的时候 等不等待 等多久
        jedisPoolConfig.setMaxWaitMillis(1000);

        //创建连接池对象 还是老样子，没有密码就不设置密码。
        JEDIS_POOL = new JedisPool(jedisPoolConfig,"127.0.0.1",6379,1000);

    }

    public static Jedis getJedis(){
        return JEDIS_POOL.getResource();
    }

}

创建完之后我们再去测试测试。

2、Spring Data Redis

SpringData是Spring中数据操作的模块，包含对各种数据库的集成，其中对Redis的集成模块就叫做SpringDataRedis，官网地址：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()	ZSetOperations	操作SortedSet类型数据
redisTemplate		通用的命令

2.1 基于SpringBoot快速入门

SpringBoot已经提供了对SpringDataRedis的支持，使用非常简单：

我们创建一个Spring Boot 项目

勾选上面的选项后会自动引入 spring date Redis 依赖，然后我们再引入一个连接池依赖。

 <!--连接池依赖-->
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
        </dependency>

依赖引入完毕后，我们再去编写yml 配置文件。

server:
  port: 2022
spring:
  redis:
    host: 127.0.0.1 # ip 地址
    port: 6379 # 端口
    password:  #密码 没有就输入
    lettuce:
      pool:
        max-active: 8 # 最大连接
        max-idle: 8 # 最大空闲连接
        min-idle: 0 # 最小连接
        max-wait: 100ms #等待时长

springDataRedis 默认支持lettuce，如果我们要使用jedis，就要去导入相关依赖。

就可以去进行相关测试啦。

这里我们也看到打印成功。

2.2 SpringDataRedis的序列化方式

我现在打开Redis自带的命令行客户端，查看一下我们刚刚插入进去的数据。

发现居然没有变化？这时候查询所有键。

我的博客名称怎么会变成这样？

这是因为RedisTemplate可以接收任意Object作为值写入Redis，只不过写入前会把Object序列化为字节形式，默认是采用JDK序列化，所以得到的结果是这样的。

这种方式有以下缺点：

可读性差
内存占用较大

但是，我们可以自定义RedisTemplate的序列化方式，代码如下。

package com.jie.introduction.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;

/**
 * @description:修改序列化方式
 * @author: jie
 * @time: 2022/4/27 22:56
 */
@Configuration
public class RedisConfig {

    @Bean
    public 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;
    }
}

这里大概还要引入一个依赖，因为我们用到了一个json转换。注：springmvc自带。

 <!--Jackson依赖-->
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
        </dependency>

配置好之后，我们就可以再去发送一次请求，去可视化工具看看效果如何。