Redis 7 第五讲 事务、管道、发布订阅 过渡篇

 事务

理论

         可以一次执行多个命令,本质是一组命令的集合。一个事务中的所有命令都会序列化,按顺序地串行化执行而不会被其它命令插入,不许加塞

        一个队列中,一次性、顺序性、排他性的执行一系列命令

Redis事务 VS 关系型数据库事务 

单独的隔离操作Redis的事务仅仅是保证事务里的操作会被连续独占的执行,redis命令执行是单线程架构,在执行完事务内所有指令前是不可能再去同时执行其他客户端的请求的
没有隔离级别的概念事务提交前任何指令不会被执行,因此不存在脏读、幻读等
不保证原子性Redis的事务不保证原子性,也就是不保证所有指令同时成功或同时失败,只有决定是否开始执行全部指令的能力,没有执行到一半进行回滚的能力
排它性Redis会保证一个事务内的命令依次执行,而不会被其它命令插入

命令

DISCARD取消事务,放弃执行事务块内的所有命令。
DISCARD取消事务,放弃执行事务块内的所有命令。
EXEC标记一个事务块的开始。
UNWATCH 取消 WATCH 命令对所有 key 的监视。
WATCH  监视一个(或多个) key ,如果在事务执行之前这个(或这些) key 被其他命令所改动,那么事务将被打断。

案例

 正常放行

         (MULTI->指令集->EXEC)

 放弃事务

        (MULTI->指令集->DISCARD) 

全部连坐

        一个队列中,命令在写入队列时出现错误,将直接影响队列整体的提交。

冤头债主

        一个队列中,命令在写入队列时未出现错误,但在执行时出错。只影响错误指令的执行结果,其他正常执行的指令结果没影响。

WATCH监控 

        Redis 使用watch提供乐观锁锁定,类似CAS(CHECK-AND-SET)

悲观锁(Pessimistic Lock)每次去拿数据的时候都认为别人会修改,所以每次在拿数据的时候都会上锁,想拿这个数据就会block直到它拿到锁。
乐观锁(Optimistic Lock)每次去拿数据的时候都认为别人不会修改,所以不会上锁,在更新 的时候会判断一下在此期间别人有没有去更新这个数据。
乐观锁策略:提交版本必须 大于 记录当前版本才能执行更新
CAS利用WATCH去监控key,EXEC时去验证是否被操作

        初始化acount和balance两个key,先监控再开启multi保证两key变动在同一个事务内

未加塞 

加塞 

如果监控的balance事务开启后,被其他客户端修改后,当前客户端的事务失败。

 UNWATCH

管道 

 面试题

        如何优化频繁命令往来造成的性能瓶颈?

        管道(pipeline)可以一次性发送多条命令给服务端,服务端依次处理完完毕,通过一次性将响应结果返回,减少客户端与redis的通信次数来实现降低往返延时时间。

        pipeline实现的原理是队列,先进先出特性就保证数据的顺序性。 

作用

         Pipeline是为了解决RTT往返回时,仅仅是将命令打包一次性发送,对整个Redis的执行不造成其它任何影响。简言之,批处理命令变种优化,类似Redis的原生批处理命令(mget/mset)

 案例 

         利用Linux的CAT命令特性,返回结果集作为pipe的参数

 总结

管道与原生批量命令对比原生批量命令是服务端实现的,管道需要服务的与客户端共同完成
原生批量命令一次只能执行一种命令,管道支持批量执行不同命令
原生命令是原子性(如mset\mget),管道是非原子性的
管道与事务对比事务具有原子性,管道不具有原子性
事务逐条发送到队列,接收到exec命令后才执行;管道一次性将多条命令发送到服务器
执行事务时会阻塞其他命令执行;管道中的命令不会阻塞
使用管道注意事项管道缓冲的指令只会依次执行,不保证原子性,执行过程中发生异常,会继续执行后续指令
使用管道组装的命令个数不能太多,数据量过大客户端阻塞的时间可能过久,服务端也被迫回复一个队列答复,占用很多内存

发布订阅 (了解)

理论

        一种消息通信模式:发送者(PUBLISH)发送消息,订阅者(SUBSCRIBE)接收消息,可以实现进程间的消息传递 。

        Redis可以实现消息中间件MQ的功能,通过发布订阅实现消息的引导和分流。

        代表我个人,不推荐使用该功能,专业的事情交给专业的中间件处理,redis就做好分布式缓存功能

案例 

        先订阅再发布 

SUBSCRIBE pattern [pattern ...]订阅一个或多个符答给定模式的频道。

PUBSUB subcommand [argument [argument ...]查看订阅与发布系统状态。 

PUBLISH channel message将信息发送到指定的频道。 

PUNSUBSCRIBE[pattern[pattern ..]退订所有给定模式的频道。 

SUBSCRIBE channel [channel ...]订阅给定的一个或多个频道的信息。 

UNSUBSCRIBE [channel [channel ...]指退订给定的频道。 

 缺点

         发布的消息在Redis系统中不能持久化,因此,必须先执行订阅,再等待消息发布

        消息只管发送对于发布者而言消息是即发即失的,不管接收,也没有ACK机制,无法保证消息的消费成功 

        Redis5.0版本新增了Stream数据结构,不但肢持多播,还支持数据持久化,相比Pub/Sub更加的强大 

🌹 以上分享 Redis 事务、管道、发布订阅,如有问题请指教写。

🌹🌹 如你对技术也感兴趣,欢迎交流。

🌹🌹🌹  如有需要,请👍点赞💖收藏🐱‍🏍分享 

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

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

相关文章

Java 多线程系列Ⅲ(wait+notify+notifyAll)

wait、notify、notifyAll 一、初识 wait、notify、notifyAll二、wait、notify、notifyAll 功能介绍1、wait()2、notify()3、notifyAll()4、wait、notify、notifyAll 要点总结5、wait/notify 使用示例 三、wait、join、sleep 归纳 一、初识 wait、notify、notifyAll 我们知道由…

QtConcurrent和QFuture的使用

在Qt中,有时候我们会遇到这样一种情况,需要执行一个很长时间的操作,这时候我们的主界面就会卡住。我们的通常做法就是把这个很长时间的操作扔到线程里去处理,可以使用标准库中的线程也可以使用QThread。 如果我们要在这个很长时间…

Java泛型机制

✅作者简介:大家好,我是Leo,热爱Java后端开发者,一个想要与大家共同进步的男人😉😉 🍎个人主页:Leo的博客 💞当前专栏:每天一个知识点 ✨特色专栏&#xff1a…

javacv 基础04-读取mp4,avi等视频文件并截图保存图片到本地

javacv 读取mp4,avi等视频文件并截图保存图片到本地 代码如下: package com.example.javacvstudy;import org.bytedeco.javacv.FFmpegFrameGrabber; import org.bytedeco.javacv.Frame; import org.bytedeco.javacv.Java2DFrameConverter;import javax.imageio.Im…

单元测试:优雅编写Kotlin单元测试

一、MockK简介 MockK是一款功能强大、易于使用的Kotlin mocking框架。在编写单元测试时,MockK能够帮助我们简化代码、提高测试覆盖率,并改善测试的可维护性。除了基本用法外,MockK还提供了许多额外的功能和灵活的用法,让我们能够…

ARM DIY(四)WiFi 调试

文章目录 焊接打开内核编译选项重新编译内核烧录 && 运行 && 测试完善脚本测速手搓天线正式天线 焊接 换个粗点的风枪嘴,让热风覆盖 RTL8823BS 整体模块,最终实现自动归位 焊接 SDIO 接口的上拉电阻以及复位引脚上拉电阻 硬件部分就这…

linux centos7 bash中字符串反向输出

给定一个字符串,如何反向(倒序)输出? 字符串反转的方法:a.对各个字符位置进行循环调换(从原字符串左边取出放在新字符串的右边;从原字符串右边取出放在新字符串的左边)。b.对各个字符由水平排列转为垂直排…

时序预测 | MATLAB实现EEMD-SSA-LSTM、EEMD-LSTM、SSA-LSTM、LSTM时间序列预测对比

时序预测 | MATLAB实现EEMD-SSA-LSTM、EEMD-LSTM、SSA-LSTM、LSTM时间序列预测对比 目录 时序预测 | MATLAB实现EEMD-SSA-LSTM、EEMD-LSTM、SSA-LSTM、LSTM时间序列预测对比预测效果基本介绍模型描述程序设计参考资料 预测效果 基本介绍 时序预测 | MATLAB实现EEMD-SSA-LSTM、E…

渗透测试漏洞原理之---【失效的访问控制】

文章目录 1、失效的访问控制1.1、OWASP Top 101.1.1、A5:2017-Broken Access Control1.1.2、A01:2021 – Broken Access Control 1.2、失效的访问控制类别1.2.1、水平越权1.2.2、垂直越权 1.3、攻防案例1.3.1、Pikachu靶场 Over Permision1.3.2、DVWA越权利用失效的访问控制漏洞…

大数据课程K16——Spark的梯度下降法

文章作者邮箱:yugongshiyesina.cn 地址:广东惠州 ▲ 本章节目的 ⚪ 了解Spark的梯度下降法; ⚪ 了解Spark的梯度下降法家族(BGD,SGD,MBGD); ⚪ 掌握Spark的MLlib实现…

Data Rescue Professional for Mac:专业的数据恢复工具

在数字化时代,我们的生活和工作离不开电脑和存储设备。但是,意外情况时常发生,例如误删除文件、格式化硬盘、病毒攻击等,这些都可能导致重要的数据丢失。面对数据丢失,我们迫切需要一款可靠的数据恢复工具。今天&#…

剪枝基础与实战(5): 剪枝代码详解

对模型进行剪枝,我们只对有参数的层进行剪枝,我们基于BatchNorm2d对通道重要度 γ \gamma γ参数进行稀释训练。对BatchNorm2d及它的前后层也需要进行剪枝。主要针对有参数的层:Conv2d、BatchNorm2d、Linear。但是我们不会对Pool2d 层进行剪枝,因为Pool2d只用来做下采样,没…

在windows下进行maven安装配置

下载 https://maven.apache.org/download.cgi 安装配置 配置settings.xml文件 如果需要修改仓库的地址,可新增一条localRepository的记录,加上存放下载jar包的地址。 设置Maven镜像下载地址 配置完成,在命令行输入mvn help:system测试&#…

科创板50ETF期权交易:详细规则、费用、保证金和开户攻略

科创板50ETF期权是指以科创板50ETF为标的资产的期权合约。科创板50ETF是由交易所推出的一种交易型开放式指数基金(ETF),旨在跟踪科创板50指数的表现,下文介绍科创板50ETF期权交易:详细规则、费用、保证金和开户攻略&am…

uni-app中使用iconfont彩色图标

uni-app中使用iconfont彩色图标 大家好,今天我们来学习一下uni-app中使用iconfont彩色图标,好好看,好好学,超详细的 第一步 首先,从iconfont官网(iconfont-阿里巴巴矢量图标库)选择自己需要的图…

QT6为工程添加资源文件,并在ui界面引用

以添加图片资源为例 右键工程名字(不是最上面的名字),点击添加现有文件 这种方式虽然添加到了工程中,但不能在UI设计界面完成引用。主要原因可能是未把文件放入到项目资源文件中,以下面一种方式可以看出区别。 点击添…

FFmpeg报错:Connection to tcp://XXX?timeout=XXX failed: Connection timed out

一、现象 通过FFmpeg(FFmpeg的版本是5.0.3)拉摄像机的rtsp流获取音视频数据,执行命令: ./ffmpeg -timeout 3000000 -i "rtsp://172.16.17.156/stream/video5" 报错:Connection to tcp://XXX?timeoutXXX …

生态项目|Typus如何用Sui特性制作动态NFT为DeFi赋能

对于许多人来说,可能因其涉及的期权、认购和价差在内的DeFi而显得晦涩难懂,但Typus Finance找到了一种通过动态NFT使体验更加丰富的方式。Typus NFT系列的Tails为用户带来一个外观逐渐演变并在平台上提升活动水平时获得新特权的角色。 Typus表示&#x…

解决npm install报错: No module named gyp

今天运行一个以前vue项目,启动时报错如下: ERROR Failed to compile with 1 error上午10:19:33 error in ./src/App.vue?vue&typestyle&index0&langscss& Syntax Error: Error: Missing binding D:\javacode\Springboot-MiMall-RSA\V…

【数据结构】2015统考真题 6

题目描述 【2015统考真题】求下面的带权图的最小(代价)生成树时,可能是Kruskal算法第2次选中但不是Prim算法(从v4开始)第2次选中的边是(C) A. (V1, V3) B. (V1, V4) C. (V2, V3) D. (V3, V4) …