【Redis学习笔记03】Java客户端

1. 初识Jedis

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

1.1 快速入门

使用步骤：
注意：如果是云服务器用户使用redis需要先配置防火墙！

  1. 引入maven依赖

    <dependencies>
    <!-- 引入Jedis依赖 -->
    <dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
        <version>5.0.0</version>
    </dependency>
    <!-- 引入单元测试 -->
    <dependency>
        <groupId>org.junit.jupiter</groupId>
        <artifactId>junit-jupiter</artifactId>
        <version>5.10.1</version>
        <scope>test</scope>
    </dependency>
</dependencies>

  2. 建立连接

    @BeforeEach
void setUp() {
    jedis = new Jedis("114.55.236.21:22", 6379);
    jedis.auth("123456");
    jedis.select(0);
}

  3. 测试String类的方法

    @Test
void testString() {
    // 1. 尝试set方法
    jedis.set("name", "wjj");
    // 2. 尝试get方法
    String name = jedis.get("name");
    System.out.println(name);
}

  4. 释放连接

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

运行结果：
image.png
image.png

2. 使用Jedis连接池

由于Jedis是线程不安全的，并且频繁创建销毁线程具有很大开销，因此我推荐使用连接池的方式使用Jedis
使用步骤：

  1. 使用连接池创建连接工厂类

    /**
 * 基于连接池实现连接工厂类
 */
public class JedisConnectionFactory {
    private static final JedisPool jedisPool;

    static {
        // 1. 创建连接池配置
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(8); // 最大连接数
        config.setMaxIdle(8); // 最大空闲连接数
        config.setMinIdle(0); // 最小空闲连接数
        config.setMaxWaitMillis(200); // 最长等待时间
        // 2. 创建JedisPool连接池
        jedisPool = new JedisPool(config, "114.55.236.21", 6379, 1000, "123456");
    }

    public static Jedis getConnection() {
        return jedisPool.getResource();
    }
}

  2. 编写测试类测试Hash类型方法

    public class TestJedisPool {
    private Jedis jedis;
    @BeforeEach
    void setUp() {
        jedis = JedisConnectionFactory.getConnection();
    }

    @Test
    void testHash() {
        // 1. 使用hset方法
        jedis.hset("user:1", "name", "rice");
        jedis.hset("user:1", "age", "22");
        // 2. 使用hgetAll方法
        Map<String, String> map = jedis.hgetAll("user:1");
        System.out.println(map);
    }

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

运行结果：
image.png
image.png

2. 使用SpringBoot整合Redis

现在基于SpringBoot整合Redis已经成为企业的标配，其中SpringDataRedis就是专门用来操作Redis的集成模块，其具有以下特点：

  • 提供了对不同客户端的整合，比如Jedis和Lettuce
  • 提供了RedisTemplate统一API来操作Redis
  • 支持Redis的发布订阅模型
  • 支持Redis的哨兵和集群
  • 支持Lettuce的响应式编程
  • 支持基于JDK、JSON、String等对象的序列化和反序列化
  • 支持基于Redis的JDKCollection实现

2.1 SpringDataRedis快速入门

使用步骤：

  1. 引入maven依赖

    <!-- 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>
  <version>2.11.1</version>
</dependency>

  2. 在application.yml中配置相关参数

    # 配置redis
spring:
  data:
    redis:
      host: 114.55.236.21
      port: 6379
      password: 123456
      lettuce:
        pool:
          max-active: 8
          max-idle: 8
          min-idle: 0
          max-wait: 200

    由于Spring官方默认使用lettuce作为客户端，因此如果想要使用Jedis的配置，还需要引入Jedis的maven依赖

  3. 在测试类中自动装配RedisTemplate对象

    @Autowired
private RedisTemplate redisTemplate;

  4. 创建测试类测试redisTemplate的使用

    @SpringBootTest
class SpringDataRedisDemoApplicationTests {

	@Resource
	public RedisTemplate redisTemplate;

	@Test
	public void testString() {
		System.out.println(redisTemplate);
		// 1. 存入String类型数据
		redisTemplate.opsForValue().set("id", "1");
		// 2. 取出String类型数据
		Object id = redisTemplate.opsForValue().get("id");
		System.out.println(id);
	}

}

运行结果：
image.png
image.png
但是我们发现其中插入了一个\xac\xed\x00\x05t\x00\x02id这样不知名的key，但是貌似是我们在代码中插入的key值id，但是怎么会以这样的方式呈现呢？
image.png
我们追溯源码可以发现RedisTemplate中使用默认的序列化器就是JDK序列化器，其接收Object类型参数并转换成字节数组存入Redis中，但是我们发现具有以下问题：

  1. 可读性差
  2. 内存占用较大

因此我们更加建议使用String类型序列化器作为keySerializer，而使用JSON序列化器作为valueSerializer

2.2 使用自定义序列化器

使用步骤：

  1. 创建Redis配置类RedisConfig.java

    @Configuration
public class RedisConfig {

    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        // 设置连接工厂
        redisTemplate.setConnectionFactory(connectionFactory);
        // 设置序列化工具
        GenericJackson2JsonRedisSerializer jsonRedisSerializer = new GenericJackson2JsonRedisSerializer();
        // key和hashKey使用StringSerializer
        redisTemplate.setKeySerializer(RedisSerializer.string());
        redisTemplate.setHashKeySerializer(RedisSerializer.string());
        // value和hashValue使用GenericJackson2JsonRedisSerializer
        redisTemplate.setValueSerializer(jsonRedisSerializer);
        redisTemplate.setHashValueSerializer(jsonRedisSerializer);
        return redisTemplate;
    }
}

  2. 编写测试类TestJsonSerializer.java

    @SpringBootTest
public class TestJsonSerializer {
    @Autowired
    private RedisTemplate<String, Object> redisTemplate;
    @Test
    public void testJsonSerializer() {
        // 存放id
        redisTemplate.opsForValue().set("id", "2");
        // 取出id
        Object id = redisTemplate.opsForValue().get("id");
        System.out.println(id);
    }
}

如果出现如下异常（莫慌，这是正常的！）：
image.png
只要引入如下依赖即可：

<!-- 引入jackson-databind依赖 -->
<dependency>
  <groupId>com.fasterxml.jackson.core</groupId>
  <artifactId>jackson-databind</artifactId>
  <version>2.14.1</version>
</dependency>
<dependency>
  <groupId>com.fasterxml.jackson.core</groupId>
  <artifactId>jackson-core</artifactId>
  <version>2.14.1</version>
</dependency>
<dependency>
  <groupId>com.fasterxml.jackson.core</groupId>
  <artifactId>jackson-annotations</artifactId>
  <version>2.14.1</version>
</dependency>

运行结果：
image.png
image.png
此时可以发现id正常显示！
但是如果我们尝试将value设置为Java的对象，就会出现一定问题：
使用步骤：

  1. 创建pojo包下的实体类User.java

    @Data
@NoArgsConstructor
@AllArgsConstructor
public class User {
    private Integer id;
    private String name;
    private Integer age;
}

  2. 在测试类中新增测试方法

    @Test
public void testJsonObjectSerializer() {
    // 创建User类对象
    User user = new User(1, "zhangsan", 22);
    // 存放User对象
    redisTemplate.opsForValue().set("user:1", user);
    // 取出User对象
    User getUser = (User) redisTemplate.opsForValue().get("user:1");
    System.out.println(getUser);
}

上述方法尝试将一个User类对象作为value，由于之前我们自定义了value的序列化器为JSON序列化器，因此其内部会自动进行序列化和反序列化
运行结果：
image.png
image.png
我们需要重点关注其中的@class的字段内容，不难发现，RedisTemplate自动进行序列化和反序列化的依据就是利用Java的反射机制，因此需要保存类信息，但是这也引入了一个严重的问题：

  • 如果有上千万的数据量，每条信息都需要保存对应的类信息，会极大浪费内存空间！

因此我们还是建议使用手动序列化的方式进行存取！

2.3 手动序列化

使用步骤：

  1. 引入JSON工具依赖

    <dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>fastjson</artifactId>
  <version>1.2.35</version>
</dependency>

  2. 编写测试类手动序列化

    @Test
public void testMyJSON() {
    // 1. 创建User对象
    User user = new User(2, "lisi", 22);
    // 2. 手动序列化为JSON格式数据
    String jsonString = JSONObject.toJSONString(user);
    redisTemplate.opsForValue().set("user:2", jsonString);
    // 3. 取出数据并手动序列化为User对象
    String userJSONString = (String) redisTemplate.opsForValue().get("user:2");
    User toUser = JSONObject.parseObject(userJSONString, User.class);
    System.out.println(toUser);
}

运行结果：
image.png
image.png
此时我们就实现了手动序列化的方式存储Java对象，一切大功告成！

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

机器学习：SVM算法（Python）

机器学习：SVM算法（Python）

一、核函数 kernel_func.py import numpy as npdef linear():"""线性核函数:return:"""def _linear(x_i, x_j):return np.dot(x_i, x_j)return _lineardef poly(degree3, coef01.0):"""多项式核函数:param degree: 阶次:param …
阅读更多...
stream流-＞ 判定 + 过滤 + 收集

stream流-＞ 判定 + 过滤 + 收集

List<HotArticleVo> hotArticleVos hotArticleVoList .stream() .filter(x -> x.getChannelId().equals(wmChannel.getId())).collect(Collectors.toList()); 使用Java 8中的Stream API对一个名为hotArticleVoList的列表进行过滤操作&#xff0c;筛选出符合指定条件…
阅读更多...
一次登录、便捷访问所有？聊聊CAS单点登录是如何实现的

一次登录、便捷访问所有？聊聊CAS单点登录是如何实现的

前言 之前我们说到“”对组织建设的价值和建设思路&#xff0c;知道了通过实施统一身份管理解决方案&#xff0c;能够简化用户管理、降本增效、并加强安全性。对于员工来说&#xff0c;给予一套单一的凭证&#xff08;如账号密码&#xff09;&#xff0c;就可以使其访问多个权限…
阅读更多...
conda 导出/导出配置好的虚拟环境

conda 导出/导出配置好的虚拟环境

一. 导出环境配置&#xff08;yml文件&#xff09; 1. 在主目录下激活虚拟环境&#xff08;UE4是我的虚拟环境名称&#xff0c;请根据你自己的名称进行修改&#xff09; conda activate UE4 2. 运行此代码 conda env export > environment.yml 二. 导入环境配置&#xf…
阅读更多...
备战蓝桥杯---基础算法刷题2

备战蓝桥杯---基础算法刷题2

题目有一点水&#xff0c;不过还是有几个好题的&#xff0c;我在这分享一下&#xff1a; 很容易想到先往最高处跳再往最低处跳&#xff0c;依次类推&#xff0c;那怎么保证其正确性呢&#xff1f; 证法1. 在此&#xff0c;我们从0开始&#xff0c;假设可以跳到a,b,c(a<b<…
阅读更多...
NUS神经网络生成我感觉解读过于夸大了

NUS神经网络生成我感觉解读过于夸大了

网上对其解读有点过了&#xff0c;只是合成了最后标准化层的参数&#xff0c;或者是更多的其他层参数。而不是网络结构。对于新任务下的网络结构以及参数如何生成&#xff0c;应该是做不到的&#xff0c;论文意义有限。 论文片段&#xff1a;我们提出了神经网络扩散&#xff0…
阅读更多...
以 All-in-One 模式安装 KubeSphere时避坑

以 All-in-One 模式安装 KubeSphere时避坑

环境 ubuntu 18.04 准备 安装服务插件 socat 必须 可选但建议 conntrack 必须 可选但建议 ebtables 可选但建议 可选但建议 ipset 可选但建议 可选但建议 命令 sudo apt-get install socat安装docker 建议自行安装&#xff0c;不用KubeSphere 自带的 处理服务器配置 1…
阅读更多...
1906_ AMBA_高级MCU总线架构

1906_ AMBA_高级MCU总线架构

1906_ AMBA_高级MCU总线架构 全部学习汇总&#xff1a; g_arm_cores: ARM内核的学习笔记 (gitee.com) 在看内核相关的文件的时候看到了AMBA这个缩写&#xff0c;查了一下具体的概念。这个其实是一个总线架构&#xff0c;应该是ARM设计的。我找到了相关的介绍网页&#xff1a; A…
阅读更多...
基于容器和集群技术的数据自动化采集设计和实现

基于容器和集群技术的数据自动化采集设计和实现

目标&#xff1a;部署mysql服务容器并使用docker构建包含python爬虫脚本的容器采集数据到mysql数据库。 环境&#xff1a;Centos7、已配置Kubernetes集群及docker。 环境配置请参考以下文章&#xff1a; CentOS7搭建Kubernetes集群 Kubernetes集群信息如下(虚拟机主机名和IP…
阅读更多...
浪潮信息服务器蝉联全球第二，中国第一持续领跑

浪潮信息服务器蝉联全球第二，中国第一持续领跑

作为服务器领域的专家&#xff0c;浪潮信息多年来持续通过技术创新更新服务&#xff0c;提升产品竞争力&#xff0c;领衔全球服务器市场。根据国际权威研究机构高德纳&#xff08;Gartner&#xff09;公布的《2023年第3季度全球服务器市场追踪报告》可见&#xff0c;2023Q3全球…
阅读更多...
Java里常用的集合哪些是线程安全的和不安全的

Java里常用的集合哪些是线程安全的和不安全的

最近在做一个业务的时候&#xff0c;需要考虑线程的安全性&#xff0c;然后选用集合的时候专门去整理了一下。 线程安全的是: Hashtable&#xff0c;ConcurrentHashMap&#xff0c;Vector &#xff0c;CopyOnWriteArrayList &#xff0c;CopyOnWriteArraySet 线程不安全的是: H…
阅读更多...
计算机网络：思科实验【4-生成树协议STP及虚拟局域网VLAN】

计算机网络：思科实验【4-生成树协议STP及虚拟局域网VLAN】

&#x1f308;个人主页&#xff1a;godspeed_lucip &#x1f525; 系列专栏&#xff1a;Cisco Packet Tracer实验 本文对应的实验报告源文件请关注微信公众号程序员刘同学&#xff0c;回复思科获取下载链接。 实验目的实验环境实验内容交换机生成树协议**STP**虚拟局域网**VLAN…
阅读更多...
vue3个人网站电子宠物

vue3个人网站电子宠物

预览 具体代码 Attack.gif Attacked.gif Static.gif Walk.gif <template><div class"pet-container" ref"petContainer"><p class"pet-msg">{{ pet.msg }}</p><img ref"petRef" click"debounce(attc…
阅读更多...
FreeRTOS学习第8篇--同步和互斥操作引子

FreeRTOS学习第8篇--同步和互斥操作引子

目录 FreeRTOS学习第8篇--同步和互斥操作引子同步和互斥概念实现同步和互斥的机制PrintTask_Task任务相关代码片段CalcTask_Task任务相关代码片段实验现象本文中使用的测试工程 FreeRTOS学习第8篇–同步和互斥操作引子 本文目标&#xff1a;学习与使用FreeRTOS中的同步和互斥操…
阅读更多...
01背包问题：组合问题

01背包问题：组合问题

01背包问题&#xff1a;组合问题 题目 思路 将nums数组分成left和right两组&#xff0c;分别表示相加和相减的两部分&#xff0c;则&#xff1a; left - right targetleft right sum 进而得到left为确定数如下&#xff0c;且left必须为整数&#xff0c;小数表示组合不存在&…
阅读更多...
Android Gradle 开发与应用 (一) : Gradle基础

Android Gradle 开发与应用 (一) : Gradle基础

1. Gradle是什么 Gradle是一个通用的构建工具&#xff0c;支持诸多主要的 IDE&#xff0c;包括 Android Studio、IntelliJ IDEA、Visual Studio 等 Gradle 的底层实现(核心引擎和框架)其实是用 Java 编写的开发者通常使用 Groovy 或 Kotlin 来编写构建脚本 1.1 那么为什么Gra…
阅读更多...
【JavaScript 漫游】【021】EventTarget 接口

【JavaScript 漫游】【021】EventTarget 接口

事件的本质是程序各个组成部分之间的一种通信方式&#xff0c;也是异步编程的一种实现。DOM 支持大量的事件。 EventTarget 接口概述 DOM 的事件操作&#xff08;监听和触发&#xff09;&#xff0c;都定义在 EventTarget 接口。所有节点对象都部署了这个接口&#xff0c;其他…
阅读更多...
Request 和 Response详解

Request 和 Response详解

文章目录 1.Request和Response的概述2.Request对象2.1 Request继承体系2.2 Request获取请求数据2.2.1 获取请求行数据2.2.2 获取请求头数据2.2.3 获取请求体数据2.2.4 获取请求参数的通用方式 2.3 解决post请求乱码问题 掌握学习目标内容讲解内容小结 2.4 Request请求转发 3.HT…
阅读更多...
electron+vue3全家桶+vite项目搭建【27】封装窗口工具类【1】雏形

electron+vue3全家桶+vite项目搭建【27】封装窗口工具类【1】雏形

文章目录 引入思路抽出公共声明文件抽出全局通用数据类型和方法主进程模块1.抽离基础常量2.封装窗口工具类 渲染进程模块测试结果 引入 demo项目地址 可以看到我们之前在主进程中的逻辑全部都塞到index.ts文件中&#xff0c;包括窗口的一些事件处理&#xff0c;handle监听&am…
阅读更多...
docker 容器访问 GPU 资源使用指南

docker 容器访问 GPU 资源使用指南

概述 nvidia-docker 和 nvidia-container-runtime 是用于在 NVIDIA GPU 上运行 Docker 容器的两个相关工具。它们的作用是提供 Docker 容器与 GPU 加速硬件的集成支持&#xff0c;使容器中的应用程序能够充分利用 GPU 资源。 nvidia-docker 为了提高 Nvidia GPU 在 docker 中的…
阅读更多...
最新文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发 尧图建网站