Redis的Java客户端

news2025/1/16 14:04:57

目录

1 前言

2 Jedis客户端

2.1 jedis快速入门 

 2.2Jedis连接池

3 SpringDataRedis

3.1快速入门 

3.2ReisTemplate配置序列化工具

3.3 StringRedisTemplate 

1 前言

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

 

因为前三个是官方推荐学习的，而第三个又是基于分布式的，不适合基础学习，所以重点学习前两个。

又因为Java中有前两个命令的整合，叫做Spring Data Redis，但有的企业又是只用到了第一个

 所以，我们主要学习两个，Jedis和Spring Data Redis

2 Jedis客户端

2.1 jedis快速入门 

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

温馨提示：一下代码都是在单元测试里实现的哦~

1. 创建Maven工程

2. 导入Jedis客户端h和单元测试依赖：

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

3.  开始实现Jdedis客户端操作

  • 建立连接
  • @BeforeEach
    public void setUp(){
        // 1.new Jedis(ip地址，端口)
        jedis = new Jedis("192.168.110.128",6379);
        //2.输入密码 auth
        jedis.auth("123321");
        //3.选择库
        jedis.select(0);
}
  • 编写Redis操作（String类型操作）
  • //redis操作
    @Test
    public void testString(){
        String result = jedis.set("name", "Jack");
        System.out.println(result);
        String name = jedis.get("name");
        System.out.println(name);
    }
  • 关闭资源
  •     //关闭资源
    @AfterEach
    public void tearDown(){
        //健壮性判断
        if (jedis != null){
            jedis.close();
        }
    }

最后运行结果：

 完整代码如下：

package com.itheima.test;

import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import redis.clients.jedis.Jedis;

/**
 * @Author 华子
 * @Date 2022/11/19 11:15
 * @Version 1.0
 */
public class JedisTest {

    private Jedis jedis;


    //建立连接
    @BeforeEach
    public void setUp(){
        // 1.new Jedis(ip地址，端口)
        jedis = new Jedis("192.168.110.128",6379);
        //2.输入密码 auth
        jedis.auth("123321");
        //3.选择库
        jedis.select(0);
    }

    //redis操作
    @Test
    public void testString(){
        String result = jedis.set("name", "Jack");
        System.out.println(result);
        String name = jedis.get("name");
        System.out.println(name);
    }

    //关闭资源
    @AfterEach
    public void tearDown(){
        //健壮性判断
        if (jedis != null){
            jedis.close();
        }
    }

}

 2.2Jedis连接池

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

连接池创建方法如下代码：

package com.itheima.jedis.util;

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

/**
 * @Author 华子
 * @Date 2022/11/19 11:41
 * @Version 1.0
 */
public class JedisConnectFactory {

    private static final JedisPool jedisPool;

    static {
        //1.配置连接池
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        //设置最大连接池数量
        jedisPoolConfig.setMaxTotal(8);
        //设置最大空闲连接
        jedisPoolConfig.setMaxIdle(8);
        //设置最小空闲连接
        jedisPoolConfig.setMinIdle(0);
        //设置最大等待时间（当没有空闲连接时，等待的时间）
        jedisPoolConfig.setMaxWaitMillis(1000);

        //2.建立连接池（配置参数，ip地址，端口，等待时间，密码）
        jedisPool = new JedisPool(jedisPoolConfig,"192.168.110.128",6379,1000,"123321");
    }

    //3.提供对外调用方法
    public static Jedis getJedis(){
        return jedisPool.getResource();
    }
}

这样连接池就创建成功啦~

而我们Jedis快速入门的时候，建立连接就变为调用这个静态类的getJedis方法了

如图：

整体代码：

package com.itheima.test;

import com.itheima.jedis.util.JedisConnectFactory;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import redis.clients.jedis.Jedis;

/**
 * @Author 华子
 * @Date 2022/11/19 11:15
 * @Version 1.0
 */
public class JedisTest {

    private Jedis jedis;


    //建立连接
    @BeforeEach
    public void setUp(){
        // 1.new Jedis(ip地址，端口)
        //jedis = new Jedis("192.168.110.128",6379);
        jedis = JedisConnectFactory.getJedis();
        //2.输入密码 auth
        jedis.auth("123321");
        //3.选择库
        jedis.select(0);
    }

    //redis操作
    @Test
    public void testString(){
        String result = jedis.set("name", "Jack");
        System.out.println(result);
        String name = jedis.get("name");
        System.out.println(name);
    }

    //关闭资源
    @AfterEach
    public void tearDown(){
        //健壮性判断
        if (jedis != null){
            jedis.close();
        }
    }

}

这里提一嘴，关闭资源依然是jedis.close 方法，但是，底层变成了归还线程池

 

3 SpringDataRedis

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封装到了不同的类型中：

3.1快速入门 

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

1.导入依赖坐标

<?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 https://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.5.7</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.heima</groupId>
    <artifactId>redis-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>redis-demo</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <!--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>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombok</groupId>
                            <artifactId>lombok</artifactId>
                        </exclude>
                    </excludes>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

2. 配置（ redis springboot中的application.yaml文件 ）

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

3. 测试代码

@SpringBootTest
class RedisDemoApplicationTests {

    //注入RedisTemplate
    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    @Test
    void testString() {
        // 写入一条String数据
        redisTemplate.opsForValue().set("name", "虎哥");
        // 获取string数据
        Object name = redisTemplate.opsForValue().get("name");
        System.out.println("name = " + name);
    }
}

3.2ReisTemplate配置序列化工具

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

其实这个就是之前写入的 name:虎哥，只不过被序列化成了这个样子。

为了方便我们的可读性，还有释放内存空间，我们要对RedisTemplate进行配置序列化方式

代码如下：

package com.itheima.redis.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;

/**
 * @Author 华子
 * @Date 2022/11/19 19:47
 * @Version 1.0
 */
@Configuration
public class RedisConfig {

    @Bean
    public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory connectionFactory){

        //1.创建RedisTemplate
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        //2.设置连接工厂
        redisTemplate.setConnectionFactory(connectionFactory);
        //3.创建序列化工具
        GenericJackson2JsonRedisSerializer genericJackson2JsonRedisSerializer = new GenericJackson2JsonRedisSerializer();

        //4.设置序列化工具
        //设置key
        redisTemplate.setKeySerializer(RedisSerializer.string());
        redisTemplate.setHashKeySerializer(RedisSerializer.string());
        //设置value
        redisTemplate.setValueSerializer(genericJackson2JsonRedisSerializer);
        redisTemplate.setHashValueSerializer(genericJackson2JsonRedisSerializer);

        //5.返回
        return redisTemplate;

    }
}

 这样我们在重新运行，就会正常啦~

那么，问题来了，如果传入的是Java对象呢？能不能可以正常的序列化？

直接试一试：

新建一个实体类User

package com.itheima.redis.pojo;

import lombok.Data;

/**
 * @Author 华子
 * @Date 2022/11/19 19:57
 * @Version 1.0
 */

@Data
public class User {
    private String name;
    private Integer age;

    public User(String name, Integer age) {
        this.name = name;
        this.age = age;
    }

    public User() {
    }
}

传入User对象 

@Test
	void testObject(){
		User user = new User("华子",21);

		redisTemplate.opsForValue().set("user:100",user);
		User userInfo = (User) redisTemplate.opsForValue().get("user:100");
		System.out.println(userInfo);
	}

依然可以成功序列化Json对象，并且里面还有一个参数，实体类标识，这是用于读取的时候反序列化Java对象的~

3.3 StringRedisTemplate 

尽管JSON的序列化方式可以满足我们的需求，但依然存在一些问题，如图：

为了在反序列化时知道对象的类型，JSON序列化器会将类的class类型写入json结果中，存入Redis，会带来额外的内存开销。 

 为了减少内存的消耗，我们可以采用手动序列化的方式，换句话说，就是不借助默认的序列化器，而是我们自己来控制序列化的动作，同时，我们只采用String的序列化器，这样，在存储value时，我们就不需要在内存中就不用多存储数据，从而节约我们的内存空间

 代码就变成了如下方式（添加了手动序列化和反序列化）

package com.itheima;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.ObjectWriter;
import com.itheima.redis.pojo.User;
import net.minidev.json.JSONObject;
import net.minidev.json.JSONValue;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;

@SpringBootTest
class StringRedisTemplateTest {

	@Autowired
	private StringRedisTemplate stringRedisTemplate;

	@Test
	void testString() {

		stringRedisTemplate.opsForValue().set("name","小帅");
		String name = stringRedisTemplate.opsForValue().get("name");
		System.out.println(name);

	}

	private static final ObjectMapper mapper = new ObjectMapper();

	@Test
	void testSaveUser() throws JsonProcessingException {
		// 创建对象
		User user = new User("虎哥", 21);
		// 手动序列化
		String json = mapper.writeValueAsString(user);
		// 写入数据
		stringRedisTemplate.opsForValue().set("user:200", json);

		// 获取数据
		String jsonUser = stringRedisTemplate.opsForValue().get("user:200");
		// 手动反序列化
		User user1 = mapper.readValue(jsonUser, User.class);
		System.out.println("user1 = " + user1);
	}

}

这样就可以不用占内存啦~ 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/18973.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

螺栓防松设计

螺栓防松设计

常用的防松方法有三种&#xff1a;摩擦防松、机械防松和永久防松。机械防松和摩擦防松称为可拆卸防松&#xff0c;而永久防松称为不可拆卸防松。常用的永久防松有&#xff1a;点焊、铆接、粘合等&#xff0c;这种方法在拆卸时大多要破坏螺纹紧固件&#xff0c;无法重复使用。常…
阅读更多...
系统测试-从研发到测试过程

系统测试-从研发到测试过程

系统测试是为了发现错误而执行程序的过程&#xff0c;成功的测试是发现了至今尚未发现的错误的测试。目的是在真实系统工作环境下通过与系统的需求定义作比较&#xff0c;检验完整的软件配置项能否和系统正确连接&#xff0c;发现软件与系统/子系统设计文档和软件开发合同规定不…
阅读更多...
[Redis] Redis实战--EVAL

[Redis] Redis实战--EVAL

✨✨个人主页:沫洺的主页 &#x1f4da;&#x1f4da;系列专栏: &#x1f4d6; JavaWeb专栏&#x1f4d6; JavaSE专栏 &#x1f4d6; Java基础专栏&#x1f4d6;vue3专栏 &#x1f4d6;MyBatis专栏&#x1f4d6;Spring专栏&#x1f4d6;SpringMVC专栏&#x1f4d6;SpringBoot专…
阅读更多...
基于移动品台的产品追溯系统设计与实现

基于移动品台的产品追溯系统设计与实现

项目描述 临近学期结束&#xff0c;还是毕业设计&#xff0c;你还在做java程序网络编程&#xff0c;期末作业&#xff0c;老师的作业要求觉得大了吗?不知道毕业设计该怎么办?网页功能的数量是否太多?没有合适的类型或系统?等等。这里根据疫情当下&#xff0c;你想解决的问…
阅读更多...
骚戴独家笔试---算法篇

骚戴独家笔试---算法篇

链表 反转链表 /* public class ListNode { int val; ListNode next null;ListNode(int val) { this.val val; } }*/ import java.util.Stack; public class Solution {public ListNode ReverseList(ListNode head) {Stack<ListNode> stack new Stack<>();//把…
阅读更多...
进程间通信:无名管道+有名管道

进程间通信:无名管道+有名管道

进程间通信&#xff08;Inter-Process Communication&#xff09; 为什么需要进程间通信 当程序是多进程协同工作时&#xff0c;进程间基本都会涉及到数据共享 如何实现进程间数据的共享? 使用进程间通信来实现数据共享 进程间有时需要传递消息 --但是进程在系统有自己的地址…
阅读更多...
msdn下载的系统怎么安装

msdn下载的系统怎么安装

有小伙伴们不知道安装msdn系统的具体操作&#xff0c;那么小编就教大家下载的系统怎么安装吧。 工具/原料&#xff1a; 系统版本&#xff1a;win10 专业版 品牌型号&#xff1a;联想小新Air 13 Pro 软件版本&#xff1a;小鱼一键重装系统v3.1.329.319 方法/步骤&#xff1…
阅读更多...
UNIAPP实战项目笔记41 收货地址页面布局和省市县三级联动

UNIAPP实战项目笔记41 收货地址页面布局和省市县三级联动

UNIAPP实战项目笔记41 收货地址页面布局和省市县三级联动 my-add-path.vue 设置页面布局 具体内容图片自己替换哈&#xff0c;随便找了个图片的做示例 用到了vue的默认组件 城市选择器mpvueCityPicker,从uniappDemo中复制过来即可,具体位置见目录结构 代码 my-add-path.vue 页…
阅读更多...
数据结构二叉排序树应用一

数据结构二叉排序树应用一

2022.11.19 二叉排序树应用一任务描述相关知识编程要求测试说明C/C代码任务描述 本关任务&#xff1a;输入一个无序序列&#xff0c;创建一棵二叉排序树。 相关知识 为了完成本关任务&#xff0c;你需要掌握&#xff1a;1.二叉排序树定义&#xff0c;2.如何创建一棵二叉排序…
阅读更多...
黑*头条_第6章_admin端功能开发通用后端封装

黑*头条_第6章_admin端功能开发通用后端封装

黑*头条_第6章_admin端功能开发&通用后端封装 文章目录黑*头条_第6章_admin端功能开发&通用后端封装admin端功能开发&通用后端封装今日目标1 admin端的登录功能实现1.1 admin项目搭建1.2 登录接口-后端1.2.1接口定义1.2.2mapper定义1.2.3 代码编写1.3 前端项目导入…
阅读更多...
FCN的代码解读

FCN的代码解读

目录 模型初始化 VGG初始化 FCN初始化 图片的预处理 图片处理 图片编码 计算相关参数 模型训练 一个小问题 完整代码 参考 最近浅研究了一下关于图像领域的图像分割的相关知识&#xff0c;发现水还是挺深的&#xff0c;因为FCN差不多也是领域的开山鼻祖&#xff0c;所以就先从…
阅读更多...
Postman进阶篇（十）-在pre-request script或test script中使用pm对象访问变量

Postman进阶篇（十）-在pre-request script或test script中使用pm对象访问变量

在之前的文章中介绍过postman中的两个脚本——pre-request script或test script&#xff0c;在这两个脚本中都有使用到pm对象。&#xff08;pre-request script详细介绍、Test script详细介绍&#xff09;pm对象是在postman的脚本中非常重要&#xff0c;也是十分常用的方法。本…
阅读更多...
Tomcat使用与Servlet

Tomcat使用与Servlet

目录 Tomcat Get与Post请求的区别 Servlet 体系 请求流程 生命周期 配置loadOnStartup 线程安全问题 问题原因 解决方案 Servlet核心类 请求 响应 转发与重定向 转发 重定向 Cookie与HttpSession Cookie HttpSession ServletConfig ServletContext 总结 F…
阅读更多...
基于javaweb,ssm学生宿舍管理系统(带论文)

基于javaweb,ssm学生宿舍管理系统(带论文)

开发工具&#xff1a;IDEA 服务器&#xff1a;Tomcat8.0&#xff0c; jdk1.8 项目构建&#xff1a;maven 数据库&#xff1a;mysql5.7 系统分前后台&#xff0c;非前后端分离 前端技术&#xff1a;vue.jselementUI等框架实现 服务端技术&#xff1a;springspringmvcmybat…
阅读更多...
Java--Lambda（1）简介

Java--Lambda（1）简介

文章目录0 写在前面1 优点2 实现3 写在末尾0 写在前面 阅读公司前辈写的代码的时候&#xff0c;有一些地方总不理解&#xff0c;后来才知道是Lambda表达式。 所以学习了一下&#xff0c;在此记录一下。 通过百度搜索得知&#xff1a;Lambda 表达式也叫作匿名函数&#xff0c…
阅读更多...
简单易懂的 全景图高清下载方法以及原理简要解析（支持下载建E、720yun、酷雷曼、景站、酷家乐、百度街景原图）

简单易懂的 全景图高清下载方法以及原理简要解析（支持下载建E、720yun、酷雷曼、景站、酷家乐、百度街景原图）

简单易懂的 全景图高清下载方法以及原理简要解析&#xff08;支持下载建E、720yun、酷雷曼、景站、酷家乐、百度街景原图&#xff09; 文章目录简单易懂的 全景图高清下载方法以及原理简要解析&#xff08;支持下载建E、720yun、酷雷曼、景站、酷家乐、百度街景原图&#xff09…
阅读更多...
【Linux】在Xilinx平台上实现UVC Gadget（1）

【Linux】在Xilinx平台上实现UVC Gadget（1）

【Linux】在Xilinx平台上实现UVC Gadget&#xff08;1&#xff09;前言&#xff1a;关于UVC一、创建Petalinux工程并修改设备树1) 创建一个基本的petalinux工程2) 配置sstate和downloads3) 配置内核4) 修改设备树二、在petalinux下添加uvc-gadget测试程序1) 创建一个空应用程序…
阅读更多...
Python爬虫采集框架——Scrapy初学入门

Python爬虫采集框架——Scrapy初学入门

一、安装Scrapy依赖包 pip install Scrapy 二、创建Scrapy项目&#xff08;tutorial&#xff09; scrapy startproject tutorial 项目目录包含以下内容 tutorial/scrapy.cfg # deploy configuration filetutorial/ # projects Python module, youl…
阅读更多...
Deformable Attention学习笔记

Deformable Attention学习笔记

Deformable Attention学习笔记 Vision Transformer with Deformable Attention Abstract Transformer 最近在各种视觉任务中表现出卓越的表现。大的(有时甚至是全局的)接受域使Transformer模型比CNN模型具有更高的表示能力。然而&#xff0c;单纯扩大接受野也会引起一些问题…
阅读更多...
Linux【进程间通信】

Linux【进程间通信】

目录 一、什么是进程间通信 管道 管道的原理 匿名管道 1.简单写一个管道 2.总结管道的特点&#xff0c;理解以前的管道 3.扩展 如何写一个进程池&#xff1f; 创建Makefile文件 创建我们的任务头文件Task.cpp 创建我们的主程序文件 一、什么是进程间通信 进程的运…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023