Redis 7 第九讲 微服务集成Redis 应用篇

Jedis

理论 

        Jedis是redis的java版本的客户端实现,使用Jedis提供的Java API对Redis进行操作,是Redis官方推崇的方式;并且,使用Jedis提供的对Redis的支持也最为灵活、全面;不足之处,就是编码复杂度较高。 

引入包 

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

案例演示

 直连案列

 

 获取Redis连接对象

// 获取Jedis对象private static Jedis getJedis() {Jedis jedis = new Jedis("自己的地址", 端口);jedis.auth("111111");return jedis;}

Redis 案列

Jedis jedis = getJedis();     //geoString geo_key = getKey();jedis.geoadd(geo_key, getGeo());logger.info(String.valueOf(jedis.geodist(geo_key, "成都", "上海", GeoUnit.KM)));private static String getKey() {return "TOC-" + RandomUtil.randomString(6);}private static Map<String, GeoCoordinate> getGeo() {Map<String, GeoCoordinate> geoCoordinateHashMap = new HashMap<>(5);geoCoordinateHashMap.put("成都", new GeoCoordinate(103.954887, 30.569293));geoCoordinateHashMap.put("北京", new GeoCoordinate(116.427185, 39.93682));geoCoordinateHashMap.put("上海", new GeoCoordinate(121.477665, 31.236176));geoCoordinateHashMap.put("西安", new GeoCoordinate(108.952789, 34.36515));geoCoordinateHashMap.put("重庆", new GeoCoordinate(106.454377, 29.581309));return geoCoordinateHashMap;}

关闭Jedis对象 

  jedis.close();

 池案列

 获取连接池对象

    JedisPool jedisPool = getJedisPool();Jedis jedis = jedisPool.getResource();// 获取Jedispoll对象private static JedisPool getJedisPool() {GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();poolConfig.setMaxIdle(8);poolConfig.setMinIdle(2);poolConfig.setMaxWait(Duration.ofSeconds(30000));return new JedisPool(poolConfig, "自己的ip", 端口, 100000, "111111");}

 代码案列

        //hashString hash_key = getKey();jedis.hset(hash_key, getMapStr());for (String hkey : jedis.hkeys(hash_key)) {logger.info(jedis.hget(hash_key, hkey));}

 关闭Jedis和Pool

 try {if (!Objects.isNull(jedis)) {jedis.close();}} finally {jedis = null;}try {if (Objects.isNull(jedisPool)){jedisPool.close();}} finally {jedisPool = null;}

总结

优点缺点
直连

1.简单方便new-close

2.适用于连接数比较少且使用时间较长,可构成长连接的场景(只使用一个Jedis,比如down数据、大量数据更新)

1.存在每次新建和关闭TCP的开销(三次握手四次挥手)

2.每次都去new,系统资源可能无法在有效范围内进行控制,会存在连接容易发生泄漏

3.Jedis对象本身是线程不安全的

池连接

1.Jedis是预先生成的,不需要随用随创,随用完随关闭,降低了这些开销

2.连接池能够更好地保护和控制资源使用,有固定的参数去控制最大连接数或者空闲数目等

1.相对直连,使用起来麻烦,特别是资源管理上需要非常多的参数来保证,一旦出现规划不合理的情况就会出现问题(比如池满、连接空闲、连接超时等情况)

Lettuce

理论

        Lettuce 是一个可伸缩线程安全的 Redis 客户端。多个线程可以共享同一个 RedisConnection。它利用优秀 netty NIO 框架来高效地管理多个连接。 

引入包

        <dependency><groupId>io.lettuce</groupId><artifactId>lettuce-core</artifactId><version>6.2.5.RELEASE</version></dependency>

案列演示

获取连接对象 

 
private static StatefulRedisConnection<String, String> getRedis() {// 链式编程 创建RedisUriRedisURI build = RedisURI.builder().withHost("120.77.64.190").withPort(6379).withPassword("111111".toCharArray()).build();//创建客户端StatefulRedisConnection<String, String> conn = RedisClient.create().connect(build);return conn;}StatefulRedisConnection<String, String> conn = getRedis();

 获取操作命令对象

  //链接commandRedisCommands<String, String> jedis = conn.sync();

 案列

//geoString geo_key = getKey();jedis.geoadd(geo_key, 103.954887, 30.569293,"成都");jedis.geoadd(geo_key, 121.477665, 31.236176,"上海");logger.info(String.valueOf(jedis.geodist(geo_key, "成都", "上海", GeoArgs.Unit.km)));

 关闭对象

 private static void closeConn(StatefulRedisConnection<String, String> conn) {// 关闭try {if (!Objects.isNull(conn)){conn.close();}}catch (Exception e){System.out.println(e);}finally {conn = null;}}

总结 

        Lettuce 相比Jedis 客户端,功能更加强大,不仅解决了线程安全的问题,还支持异步和响应式编程,支持集群,Sentinel,管道,编码器等等功能。 


spring-data-redis

单机 

理论

         RedisTemplate 继承自 RedisAccessor , 实现 RedisOperations 和 BeanClassLoaderAware 两个接口。spring-data-redis针对Jedis提供如下功能:

        1. 提供了一个高度封装的“RedisTemplate”类,里面封装了对于Redis的五种数据结构的各种操作

        2. SpringBoot2.x后,RedisTemplate采用是lettuce(基于netty采用异步非阻塞式lO)进行通信,大并发下比jedis效率更高。

        3. RedisTemplate模板使用序列化器操作redis数据

引入包

         <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId><version>3.1.2</version></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId><version>2.11.1</version></dependency>

案列演示

配置文件 

server:port: 8080
spring:application:name: mopredis:host: 自己的ipport: 6379database: 0password: 111111lettuce:pool:max-active: 8max-idle: 8min-idle: 0max-wait: 3s

未加序列化配置 

加入序列化配置

默认走JDK序列化 

加入自定义配置

插入数据后,客户端显示正常

 

后续案列可自行实践 

 集群

集群配置可参考 【Redis 7 第八讲 集群模式(cluster)架构篇】,集群搭建如下

配置文件

server:port: 8080
spring:application:name: mopredis:cluster:max-redirects: 3nodes:- 自己的IP:端口- 自己的IP:端口- 自己的IP:端口- 自己的IP:端口- 自己的IP:端口- 自己的IP:端口database: 0password: 111111lettuce:pool:max-active: 8max-idle: 8min-idle: 0max-wait: 3s

案列演示 

意外模拟6381宕机,从机上位验证代码是否正常

写入时出现无法连接

主机宕机,从机上位

 原因分析:

        SpringBoot 客户端无法动态感知到集群最新变化。

        SpringBoot 2.X版本, Redis默认的连接池采用 Lettuce当Redis 集群节点发生变化后,Letture默认是不会刷新节点拓扑

加入配置参数,动态刷新

server:port: 8080
spring:application:name: mopredis:cluster:max-redirects: 3nodes:- IP:PORT- IP:PORT- IP:PORT- IP:PORT- IP:PORT- IP:PORTdatabase: 0password: 111111lettuce:cluster:refresh:adaptive: trueperiod: 2000pool:max-active: 8max-idle: 8min-idle: 0max-wait: -1ms
#支持集群拓扑动态感应码斯,户适应拓扑树新是查使用所有可用的更斯,默认false 关闭spring.redis.lettuce.cluster .refresh,adaptive=true
#定时刷新
spring.redis,lettuce.cluster.refresh.period-2000

【源码地址】

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【区块链 | IPFS】IPFS cluster私有网络集群搭建

对于联盟链的业务中搭建一个私有网络的 IPFS 集群还是很有必要的,私有网络集群允许 IPFS 节点只连接到拥有共享密钥的其他对等节点,网络中的节点不响应来自网络外节点的通信。 IPFS-Cluster 是一个独立的应用程序和一个 CLI 客户端,它跨一组 IPFS 守护进程分配、复制和跟踪 …

易基因: MeRIP-seq等揭示组蛋白乙酰化和m6A修饰在眼部黑色素瘤发生中的互作调控|肿瘤研究

大家好&#xff0c;这里是专注表观组学十余年&#xff0c;领跑多组学科研服务的易基因。 组蛋白去乙酰化抑制剂(HDACis)在多种恶性肿瘤中显示出令人鼓舞的结果。N6-甲基腺嘌呤(m6A)是最普遍的mRNA修饰&#xff0c;在肿瘤发生调控中起重要作用。然而&#xff0c;对组蛋白乙酰化…

HDMI 直通 ILA 调试实验

FPGA教程学习 第十四章 HDMI 直通 ILA 调试实验 文章目录 FPGA教程学习前言实验原理程序设计实验过程实验尝试总结TODO 前言 HDMI 输入直通到 HDMI 输出的显示&#xff0c;完成一个简单的 HDMI 输入输出检测。 实验原理 开发板 HDMI 输出接口芯片使用 ADV7511&#xff0c;HD…

穿山甲报错 splashAdLoadFail data analysis error

使用swift接入穿山甲&#xff0c;未接入GroMore&#xff0c;这个时候如果代码位配置错误会导致如下错误&#xff1a; splashAdLoadFail(_:error:) Optional(“Error Domaincom.buadsdk Code98764 “data analysis error” UserInfo{NSLocalizedDescriptiondata analysis error,…

什么是区块链,解释区块链的原理和应用场景

1、什么是区块链&#xff0c;解释区块链的原理和应用场景。 区块链是一种分布式数据库&#xff0c;它由一系列按照时间顺序排列的数据块组成&#xff0c;并采用密码学方式保证不可篡改和不可伪造。区块链技术最初起源于比特币&#xff0c;作为比特币的底层技术&#xff0c;用于…

Vue 3.3 发布

本文为翻译 原文地址&#xff1a;宣布推出 Vue 3.3 |The Vue Point (vuejs.org) 今天我们很高兴地宣布 Vue 3.3 “Rurouni Kenshin” 的发布&#xff01; 此版本侧重于开发人员体验改进 - 特别是 TypeScript 的 SFC <script setup> 使用。结合 Vue Language Tools&…

HP惠普暗影精灵8P笔记本OMEN 17.3 英寸游戏本 17-ck1000(509V8AV)原厂Win11系统22H2

适用型号&#xff1a; 17-ck1000TX、17-ck1001TX、17-ck1002TX、17-ck1003TX、17-ck1004TX、17-ck1006TX、17-ck1007TX、17-ck1008TX 原装出厂系统自带所有驱动、出厂主题壁纸、Office办公软件、MyHP、惠普电脑管家、OMEN Command Center等预装程序 链接&#xff1a;https:/…

Kernel for SQL Database Recovery 21.1 Crack

SQL Server恢复工具 Kernel for SQL Database Recovery 21.1 具有针对不同 SQL Server 版本的全面恢复选项。它具有预览和选择功能来恢复精确的数据库对象。 好处 SQL 数据库恢复可为您带来多种好处。 完全恢复所有数据库组件 将损坏的 MDF/NDF 文件有效恢复到 Live SQL Serve…

DC/DC开关电源学习笔记(五)开关电源的主要技术指标

(五)开关电源的主要技术指标 1.输入参数2.输出参数3.效率4.电压调整率和负载调整率5.动态特性:负载突变时输出电压的变化6.电源启动时间(Set-Up Time)与保持时间(Hold-Up Time)1.输入参数 输入电压大小,交流还是直流,相数,频率等。 2.输出参数 输出功率,输出电压,输出…

SVN 索引版本与打包版本号不匹配

今天突然遇到了一个问题&#xff0c;SVN上传不了&#xff0c;错误提示如下&#xff1a; 解决方法&#xff1a; 1.其实&#xff0c;这是SVN库不小心搞坏了&#xff0c;只能重新再创建一个SVN仓库了。

linux7上powerpath卸载

umount挂接点后&#xff0c;直接卸载powerpath告警 [roothydb2 ~]# rpm -qa |grep EMCpower EMCpower.LINUX-6.3.0.01.00-001.ol7.x86_64 [roothydb2 ~]# rpm -e EMCpower.LINUX-6.3.0.01.00 Unable to remove devices from the PowerPath configuration Please make sure no …

C++日期类实现(联系类和对象)

目录 一.6个默认成员函数 二.基本功能函数 三.日期与天数的加减 四.前后置和-- 五.比较运算符重载 六.日期减日期 七.全部代码 1.Date.h 2.Date.cpp C初学者都可以在学习完类和对象后写一个日期类&#xff0c;以下是实现细节。 一.6个默认成员函数 对于日期类默认成员函…

WPS或EXCEL表格单元格下拉快捷选择项修改及设置方法

WPS或新版本EXCEL的设置下拉选项的方法是.点击一个单元格,菜单上选择数据,下拉列表即可设置,双击文字可编辑 EXCEL 旧的版本不同,可能有不同方法 方法一, 1.在空白区域里面&#xff0c;准备好需要填入下拉菜单里面的内容。 2.选中一个需要添加下拉菜单的单元格&#xff0c;然后…

pcl--第三节 关键点

简介 关键点也称为兴趣点&#xff0c;它是 2D 图像或 3D 点云或曲面模型上,可以通过检测标准来获取的具有稳定性、区别性的点集。从技术上来说,关键点的数量比原始点云或图像的数据量少很多&#xff0c;其与局部特征描述子结合组成关键点描述子。常用来构成原始数据的紧凑表示…

嵌入式Linux驱动开发(I2C专题)(一)

一、I2C协议 1.1、硬件连接 I2C在硬件上的接法如下所示&#xff0c;主控芯片引出两条线SCL,SDA线&#xff0c;在一条I2C总线上可以接很多I2C设备。 1.2、IIC传输数据的格式 1.2.1、写操作 流程如下&#xff1a; 主芯片要发出一个start信号然后发出一个设备地址(用来确定是…

【LangChain系列 9】Prompt模版——MessagePromptTemplate

原文地址&#xff1a;【LangChain系列 9】Prompt模版——MessagePromptTemplate 本文速读&#xff1a; MessagePromptTemplate MessagesPlaceholder 在对话模型(chat model) 中&#xff0c; prompt主要是封装在Message中&#xff0c;LangChain提供了一些MessagePromptTemplat…

javaee spring整合mybatis spring帮我们创建dao层

项目结构 pom依赖 <?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/P…

Function之Bluetooth模块

0 Preface/Foreword 1 数据结构 1.1 func_bt_t typedef struct{u16 warning_status;u8 disp_status;u8 hid_menu_flag;u8 hid_discon_flag;u8 siri_kl_flag;u8 user_kl_flag;u8 tws_status;u8 ble_status;u8 bt_is_inited;u8 rec_pause : 1;u8 pp_2_unmute : 1;u8 need_p…

HSRP(热备份路由选择协议)的概念,原理与配置实验

作者&#xff1a;Insist-- 个人主页&#xff1a;insist--个人主页 梦想从未散场&#xff0c;传奇永不落幕&#xff0c;持续更新优质网络知识、Python知识、Linux知识以及各种小技巧&#xff0c;愿你我共同在CSDN进步 目录 一、了解HSRP协议 1. 什么是HSRP协议 2、HSRP协议的…

Pycharm 安装第三方库numpy,显示超时?

一、配置终端Terminal中的镜像源 1.更改pip源&#xff0c;在终端输入如下命令 pip config set global.index-url https://pypi.tuna.tshua.edu.cn/simple2.在终端使用pip install 安装第三方库 例如: pip install numpy二、配置仓库镜像源 1.第一步: 2.第二步&#xff1a;输…