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变动在同一个事务内
未加塞
加塞
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 事务、管道、发布订阅，如有问题请指教写。
🌹🌹 如你对技术也感兴趣，欢迎交流。
🌹🌹🌹 如有需要，请👍点赞💖收藏🐱🏍分享
相关文章：
Redis 7 第五讲 事务、管道、发布订阅 过渡篇
事务 理论 可以一次执行多个命令，本质是一组命令的集合。一个事务中的所有命令都会序列化，按顺序地串行化执行而不会被其它命令插入，不许加塞 一个队列中，一次性、顺序性、排他性的执行一系列命令 Redis事务 VS 关系型数据库事务…...
[SpringBoot3]视图技术Thymeleaf
七、视图技术Thymeleaf Thymeleaf是一个表现层的模板引擎，一般被使用在Web环境中，它可以处理HTML、XML、JS等文档，简单来说，它可以将JSP作为Java Web应用的表现层，有能力展示与处理数据。这样，同一个模板文…...
wangluobiancheng
UDP send: receive: TCP...
大数据之hadoop入门
大数据概念 大数据：无法在一定时间范围内用常规软件工具进行捕捉、管理和处理的数据集合，是需要新处理模式才能具有更强的决策力、洞察发现李和流程优化能力的海量、高增长率和多样化的信息资产。 大的概念是相对来说的：目前来说࿰…...
浅谈多人游戏原理和简单实现。
😜作 者：是江迪呀✒️本文关键词：websocket、网络、原理、多人游戏☀️每日 一言：这世上有两种东西无法直视，一是太阳，二是人心！ 一、我的游戏史 我最开始接触游戏要从一盘300游戏…...
活动预告 | 龙智、紫龙游戏与JFrog专家将出席龙智DevSecOps研讨会，探讨企业大规模开发创新
2023年9月8日（周五）下午13:30-19:45，龙智即将携手Atlassian与JFrog在上海共同举办主题为“大规模开发创新：如何提升企业级开发效率与质量”的线下研讨会。 在此次研讨会上，龙智高级咨询顾问、Atlassian认证专家叶燕秀…...
米每秒和千米每小时的换算
千米每时和米每秒怎么换算?1米/秒3600米/3600秒 米每秒和千米每小时的换算(米每秒和千米每小时的换算) 3.6千米/小时。 3.6千米/小时1米/秒米每秒和千米每小时的换算1 米/秒(米每秒)3.6 千米/时(千米每小时)。 1米每秒3600米每时3.6千米每时。因为1小时3600秒。小时是一个时…...
js实现图形验证码
图形验证码起什么作用： 可以防止：恶意破解密码、刷票、论坛灌水，有效防止某个黑客对某一个特定注册用户用特定程序暴力破解方式进行不断的登录尝试。 验证码一般是防止批量注册的，人眼看起来都费劲，何况是机器。不少…...
一句话画出动漫效果
链接： AI Comic Factory - a Hugging Face Space by jbilcke-hfDiscover amazing ML apps made by the communityhttps://huggingface.co/spaces/jbilcke-hf/ai-comic-factory 选择类型： Japanese 输入提示词： beauty and school love st…...
【openGauss2.1.0 TPC-C数据导入】
openGauss2.1.0 TPC-C数据导入 一、下载tpch测试数据二、导入测试数据 一、下载tpch测试数据 使用普通用户如omm登录服务器执行如下命令下载测试数据库：git clone https://gitee.com/xzp-blog/tpch-kit.git二、导入测试数据 进入dbgen目录下，生成makef…...
vue+elementui表格导出
htmlToExcel.js import FileSaver from file-saver import XLSX from xlsxconst htmlToExcel {getExcel(dom, title 默认标题) {var excelTitle titlevar wb XLSX.utils.table_to_book(document.querySelector(dom))/* 获取二进制字符串作为输出 */var wbout XLSX.write(w…...
掌握前端利器：JavaScript页面渲染高阶方法解析与实战
引言 前端开发中，页面渲染的速度和质量是衡量一个开发者水平的重要标准。而在众多的前端技术中，JavaScript以其强大的页面渲染能力独占鳌头。本文将深入探讨JavaScript在页面渲染中的应用，并通过实例展示其高阶方法，旨在帮助读者…...
面试题——网络IO模型
一、socket socket是在应用层和传输层中间的抽象层，它把传输层（TCP/UDP）的复杂操作抽象成一些简单的接口，供应用层调用实现进程在网络中的通信。Socket起源于UNIX，在Unix一切皆文件的思想下，进程间通信就被…...
【JUC基础】JUC入门基础（二）
目录 异步回调JMM 理解对 volatile 的理解1、保证可见性2、不保证原子性3、禁止指令重排 对 JMM 的理解 详解单例模式饿汉式懒汉式DCL懒汉式：双重检测锁模式的懒汉式单例静态内部类实现单例通过反射破坏单例，修改后的DCL饿汉式枚举实现单例防止反射破坏 …...
Git Bash 和 Git GUI中文汉化
目录 为什么要中文汉化？Git Bash的汉化Git GUI的汉化 为什么要中文汉化？ 看到中文大概能猜出是什么意思，便于使用，特别是Git GUI，中文版的菜单很容易理解是要做什么，如下图： Git Bash的汉化 …...
【Ubuntu】Ubuntu常用软件部署
1.安装jdk1.8 (1).apt方式安装 1).安装 1.在终端中输入以下命令，以更新软件包列表 sudo apt-get update2.在终端中输入以下命令，以安装JDK 1.8 sudo apt-get install openjdk-8-jdk3.将Java 1.8设置为默认版本。在终端中输入以下命令 sudo update-…...
Hadoop HA模式切换
Hadoop HA模式下 主从的切换（操作命令） YARN HA 获取所有RM节点的状态 yarn rmadmin -getAllServiceState获取 rm1 节点的状态 yarn rmadmin -getServiceState rm1手动将 rm1 的状态切换到STANDBY yarn rmadmin -transitionToStandby rm1 ##或者 y…...
自然语言处理(四)：全局向量的词嵌入（GloVe）
全局向量的词嵌入（GloVe） 全局向量的词嵌入（Global Vectors for Word Representation），通常简称为GloVe，是一种用于将词语映射到连续向量空间的词嵌入方法。它旨在捕捉词语之间的语义关系和语法关系&#…...
Flink中RPC实现原理简介
前提知识 Akka是一套可扩展、弹性和快速的系统，为此Flink基于Akka实现了一套内部的RPC通信框架；为此先对Akka进行了解 Akka Akka是使用Scala语言编写的库，基于Actor模型提供一个用于构建可扩展、弹性、快速响应的系统；并被应用…...
ELK安装、部署、调试（五）filebeat的安装与配置
1.介绍 logstash 也可以收集日志，但是数据量大时太消耗系统新能。而filebeat是轻量级的，占用系统资源极少。 Filebeat 由两个主要组件组成：harvester 和 prospector。 采集器 harvester 的主要职责是读取单个文件的内容。读取每个文件&…...
iOS 26 携众系统重磅更新，但“苹果智能”仍与国行无缘
美国西海岸的夏天，再次被苹果点燃。一年一度的全球开发者大会 WWDC25 如期而至，这不仅是开发者的盛宴，更是全球数亿苹果用户翘首以盼的科技春晚。今年，苹果依旧为我们带来了全家桶式的系统更新，包括 iOS 26、iPadOS 26…...
)
Java 语言特性(面试系列1)
一、面向对象编程 1. 封装（Encapsulation） 定义：将数据（属性）和操作数据的方法绑定在一起，通过访问控制符（private、protected、public）隐藏内部实现细节。示例： public …...
AI Agent与Agentic AI：原理、应用、挑战与未来展望
文章目录 一、引言二、AI Agent与Agentic AI的兴起2.1 技术契机与生态成熟2.2 Agent的定义与特征2.3 Agent的发展历程 三、AI Agent的核心技术栈解密3.1 感知模块代码示例：使用Python和OpenCV进行图像识别 3.2 认知与决策模块代码示例：使用OpenAI GPT-3进…...
STM32标准库-DMA直接存储器存取
文章目录 一、DMA1.1简介1.2存储器映像1.3DMA框图1.4DMA基本结构1.5DMA请求1.6数据宽度与对齐1.7数据转运DMA1.8ADC扫描模式DMA 二、数据转运DMA2.1接线图2.2代码2.3相关API 一、DMA 1.1简介 DMA（Direct Memory Access）直接存储器存取 DMA可以提供外设…...
ETLCloud可能遇到的问题有哪些？常见坑位解析
数据集成平台ETLCloud，主要用于支持数据的抽取（Extract）、转换（Transform）和加载（Load）过程。提供了一个简洁直观的界面，以便用户可以在不同的数据源之间轻松地进行数据迁移和转换。…...
第一篇：Agent2Agent (A2A) 协议——协作式人工智能的黎明
AI 领域的快速发展正在催生一个新时代，智能代理（agents）不再是孤立的个体，而是能够像一个数字团队一样协作。然而，当前 AI 生态系统的碎片化阻碍了这一愿景的实现，导致了“AI 巴别塔问题”——不同代理之间…...
sqlserver 根据指定字符 解析拼接字符串
DECLARE LotNo NVARCHAR(50)A,B,C DECLARE xml XML ( SELECT <x> REPLACE(LotNo, ,, </x><x>) </x> ) DECLARE ErrorCode NVARCHAR(50) -- 提取 XML 中的值 SELECT value x.value(., VARCHAR(MAX))…...
人机融合智能 | “人智交互”跨学科新领域
本文系统地提出基于“以人为中心AI(HCAI)”理念的人-人工智能交互(人智交互)这一跨学科新领域及框架,定义人智交互领域的理念、基本理论和关键问题、方法、开发流程和参与团队等,阐述提出人智交互新领域的意义。然后,提出人智交互研究的三种新范式取向以及它们的意义。最后,总结…...
JS手写代码篇----使用Promise封装AJAX请求
15、使用Promise封装AJAX请求 promise就有reject和resolve了，就不必写成功和失败的回调函数了 const BASEURL ./手写ajax/test.jsonfunction promiseAjax() {return new Promise((resolve, reject) > {const xhr new XMLHttpRequest();xhr.open("get&quo…...
Git 3天2K星标：Datawhale 的 Happy-LLM 项目介绍（附教程）
引言 在人工智能飞速发展的今天，大语言模型（Large Language Models, LLMs）已成为技术领域的焦点。从智能写作到代码生成，LLM 的应用场景不断扩展，深刻改变了我们的工作和生活方式。然而，理解这些模型的内部…...