redis watch使用场景_redis不得不会的事务玩法

我们都知道redis追求的是简单,快速,高效,在这种情况下也就拒绝了支持window平台,学sqlserver的时候,我们知道事务还算是个比较复杂的东西,

所以这吊毛要是照搬到redis中去,理所当然redis就不是那么简单纯碎的东西了,但是呢,事务是我们写程序无法逃避的场景,所以redis作者折衷的写了个简

化版的事务机制,下面我来扯一下它的蛋蛋。

一: 事务实战

具体到事务是什么,要保证什么。。。这个我想没必要说了,先不管三七二十一,看一下redis手册,领略下它的魔力。

1. multi,exec

还记得sqlserver是怎么玩的吗?一般都是这样的三个步骤,生成事务,产生命令,执行事务,对吧,而对应redis呢??multi就是生成事务,然后

输入redis命令,最后用exec执行命令,就像下面这样:

可以看到,我set完命令之后,反馈信息是QUEUED,最后我再执行exec,这些命令才会真正的执行,就是这么的简单,一切执行的就是那么的顺利,

一点都不拖泥带水,牛逼的不要不要的,可能有些人说,其实事务中还有一个rollback操作,但好像在redis中没有看到,哈哈,牛逼哈,很遗憾是

redis中没有rollback操作,比如下面这样。

在图中我故意用lpush命令去执行string,可想而知自然不会执行成功,但从结果中,你看到什么了呢?两个OK,一个Error,这就是违反了事务

的原子性,对吧,但是我该怎么反驳呢??? 我会说,错你妹啊。。。连个基本的命令都写错了,你搞个毛啊。。。还写个吊毛代码,reids仅仅

是个数据结构服务器,多简单的一件事情,退一万步说,很明显的错误命令它会直接返回的,比如我故意把lpush写成lpush1:

2. watch

不知道你看完multi后面的三条set命令之后,有没有一种心虚的感觉,怎么说呢,就是只要命令是正确的,redis保证会一并执行,誓死完成

任务,虽然说命令是一起执行的,但是谁可以保证我在执行命令的过程中,其他client不会修改这些值呢???如果修改了这些值,那我的exec

还有什么意义呢???没关系,这种烂大街的需求,redis怎可能袖手旁观???这里的watch就可以助你一臂之力。WATCHWATCH key [key ...]监视一个(或多个) key ,如果在事务执行之前这个(或这些) key 被其他命令所改动,那么事务将被打断。

上面就是redis手册中关于watch的解释,使用起来貌似很简单,就是我在multi之前,用watch去监视我要修改的key,如果说我在exec之前,

multi之后的这段时间,key被其他client修改,那么exec就会执行失败,返回(nil),就这么简单,我还是来举个例子:

二:原理探索

关于事务操作的源代码,大多都在redis源码中的multi.c 文件中,接下来我会一个一个的简单剖析一下:

1. multi

在redis的源代码中,它大概是这么写的:1 void multiCommand(redisClient *c) {

2     if (c->flags & REDIS_MULTI) {

3         addReplyError(c,"MULTI calls can not be nested");

4         return;

5     }

6     c->flags |= REDIS_MULTI;

7     addReply(c,shared.ok);

8 }

从这段代码中,你可以看到multi只是简单的把redisClient的REDIS_MULTI状态打开,告诉这个redis客户端已经进入事务模式了,对吧。

2. 生成命令

在redisClient中,里面有一个multiState命令:typedef struct redisClient {

。。。

multiState mstate;      /* MULTI/EXEC state */

。。。

} redisClient;

从注释中你大概也看到了这个命令和multi/exec肯定有关系,接下来我很好奇的看看multiState的定义:typedef struct multiState {

multiCmd *commands;     /* Array of MULTI commands */

int count;              /* Total number of MULTI commands */

int minreplicas;        /* MINREPLICAS for synchronous replication */

time_t minreplicas_timeout; /* MINREPLICAS timeout as unixtime. */

} multiState;

从multiState这个枚举中,你可以看到下面有一个*command命令,从注释中可以看到它其实指向的是一个数组,这个数组我想你闭着眼睛都

能想得到吧。。。它就是你的若干条命令啦。。。下面还有一个count,可以看到是实际的commands的总数。

3. watch

为了方便说到后面的exec,这里想说一下watch大概是怎么实现的,在multi.c源代码中是这样写的。1 typedef struct watchedKey {

2     robj *key;

3     redisDb *db;

4 } watchedKey;

5

6 void watchCommand(redisClient *c) {

7     int j;

8

9     if (c->flags & REDIS_MULTI) {

10         addReplyError(c,"WATCH inside MULTI is not allowed");

11         return;

12     }

13     for (j = 1; j argc; j++)

14         watchForKey(c,c->argv[j]);

15     addReply(c,shared.ok);

16 }

17

18 /* Watch for the specified key */

19 void watchForKey(redisClient *c, robj *key) {

20     list *clients = NULL;

21     listIter li;

22     listNode *ln;

23     watchedKey *wk;

24

25     /* Check if we are already watching for this key */

26     listRewind(c->watched_keys,&li);

27     while((ln = listNext(&li))) {

28         wk = listNodeValue(ln);

29         if (wk->db == c->db && equalStringObjects(key,wk->key))

30             return; /* Key already watched */

31     }

32     /* This key is not already watched in this DB. Let's add it */

33     clients = dictFetchValue(c->db->watched_keys,key);

34     if (!clients) {

35         clients = listCreate();

36         dictAdd(c->db->watched_keys,key,clients);

37         incrRefCount(key);

38     }

39     listAddNodeTail(clients,c);

40     /* Add the new key to the list of keys watched by this client */

41     wk = zmalloc(sizeof(*wk));

42     wk->key = key;

43     wk->db = c->db;

44     incrRefCount(key);

45     listAddNodeTail(c->watched_keys,wk);

46 }

这段代码中大概最核心的一点就是:/* This key is not already watched in this DB. Let's add it */

clients = dictFetchValue(c->db->watched_keys,key);

就是通过dicFetchValue这个字典方法,从watched_keys中找到指定key的value,而这个value是一个clients的链表,说明人家其实是想找到

关于这个key的所有client,对吧,最后还会将本次key塞入到redisclient的watched_keys字典中,如下代码:/* Add the new key to the list of keys watched by this client */

wk = zmalloc(sizeof(*wk));

wk->key = key;

wk->db = c->db;

incrRefCount(key);

listAddNodeTail(c->watched_keys,wk);

如果非要画图,大概就是这样:

其中watched_key是个字典结构,字典的键为上面的key1,key2。。。,value为client的链表,这样的话,我就非常清楚某个key

中是被哪些client监视着的,对吧。

4.exec

这个命令里面大概做了两件事情:

<1>:   判断c->flags=REDIS_DIRTY_EXEC 打开与否,如果是的话,取消事务discardTransaction(c),也就是说这个key已经

被别的client修改了。

<2>:   如果没有修改,那么就for循环执行comannd[]中的命令,如下图中的两处信息:

好了,大概就这么说了,希望对你有帮助哈~~~

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

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

相关文章

加快Android Studio的编译速度

从Eclipse切换到Android Studio后&#xff0c;感觉Android Studio的build速度比Eclipse慢很多&#xff0c;以下几个方法可以提高Android Studio的编译速度使用Gradle 2.4Gradle 2.4对执行性能有很大的优化&#xff0c;但Android Studio现在默认使用的是Gradle 2.2,所以我们需要…

开发中 MySQL 规范

一、建表规范 1、数据库名、表名、字段名必须使用小写字母或数字&#xff0c;并且禁止以数字开头 示例&#xff1a;goods_category、agent_operate_201812_log 2、数据库名、表名、字段名要做到见名识意 示例&#xff1a;goods_category&#xff0c;不能 gc 3、配置表建议以 …

PaddleOCR在 Linux下的webAPI部署方案

很多小伙伴在使用OCR时都希望能采用API的方式调用&#xff0c;这样就可以跨端跨平台了。本文将介绍一种基于python的PaddleOCR识别WebAPI部署方案。喜欢的可以关注公众号&#xff0c;获取更多内容。一、 Linux环境下部署1.环境要求操作系统&#xff1a;CenterOS7&#xff1b;主…

影响程序员生涯的三个错误观念,你千万不要犯!

程序员在社会上&#xff0c;到底是怎样一个生活群体&#xff1f;是否能找到自己方向&#xff1f;其实&#xff0c;路一直都在那里&#xff0c;只是你看不到而已&#xff01; 当初的你&#xff0c;可能一直被一些技术牵着鼻子走&#xff0c;并不是自己在做着自己想做的&#xff…

心电图计算心率公式_心电图到底能反应啥问题,看过之后你也能当“医生”

只要是经历过健康体检的健康人&#xff0c;或者做过手术的患者&#xff0c;基本都做过心电图检查。都说久病成医&#xff0c;所以有些人对血、尿常规等各项检查的结果都门清儿得很&#xff0c;最起码看一眼也能说出个大概齐。偏偏心电图这种常做的检查&#xff0c;不但老病号如…

获取正在运行的服务

手机上安装的App&#xff0c;在后台运行着很多不同功能的服务&#xff0c;最常见的例如消息推送相关的服务。如何查看这些服务&#xff1f;如何判断某个服务是否正在运行&#xff1f;如何停止某一个服务呢&#xff1f;请看下面的方法&#xff1a; package com.example.servicel…

openstack的vnc启动ssl

1、制作ssl证书# cd /etc/pki/tls/certs [rootwww certs]# make vnc.key Enter pass phrase:# 输入密码 Verifying - Enter pass phrase:#确认# 从private key 中删除密码# openssl rsa -in vnc.key -out vnc.key # make vnc.csr Country Name (2 letter code) [XX]:CN# 国家 S…

开发composer包

一、初始化&#xff08;生成composer.json文件&#xff09; composer init#输入你要创建的composer包项目命名空间 Package name (<vendor>/<name>) [root/tiny-laravel]: #haveyb/tiny-laravel #输入composer包的描述 Description []:#this is a tiny laravel h…

Linux本地yum源配置以及使用yum源安装gcc编译环境

本文档是图文安装本地yum源的教程&#xff0c;以安装gcc编译环境为例。 适用范围&#xff1a;所有的cetos,红帽,fedroa版本 适用人群&#xff1a;有一点linux基础的小白 范例系统版本&#xff1a;CentOS Linux release 7.3.1611 (Core) 范例环境&#xff1a;vmware 虚拟机 安装…

word如何设置上标形式_如何在word中设置特殊页码

获取更多业界资讯和深度好文● 点击蓝字关注我们 ●在日常工作中&#xff0c;我们编辑的word文档经常需要设置页码&#xff0c;但有时文档的第一页是封面&#xff0c;第二页才是正文&#xff0c;或者第二页是目录&#xff0c;第三页才是正文&#xff0c;如下图所示&#xff0c;…

[cf797c]Minimal string(贪心+模拟)

题意&#xff1a; 给出了字符串s的内容&#xff0c;字符串t&#xff0c;u初始默认为空&#xff0c;允许做两种操作&#xff1a; 1、把s字符串第一个字符转移到t字符串最后 2、把t字符串最后一个字符转移到u字符串最后 最后要求s、t字符串都为空&#xff0c;问u字符串字典序最小…

发布composer包到 Packagist,并设置自动同步(从github到Packagist)

一、发布composer包 1、将我们写好的项目包发布到github上 这一步不赘述&#xff0c;应该都会。 但是需要注意的是&#xff0c;我们一定要为我们的项目包打上tag之后再提交&#xff0c;否则 我们composer require时可能会报错 Could not find a version of package。 # 设置…

教你在CorelDRAW中导入位图

在CorelDRAW软件中不能直接打开位图图像&#xff0c;在实际操作中&#xff0c;用户需要使用导入位图图像的方法进行操作。导入位图图像时&#xff0c;可以导入整幅图像&#xff0c;也可以在导入的过程中对图像进行裁剪&#xff0c;或重新取样图像&#xff0c;导入整幅位图图像时…

.NET 6 中将 ASP.NET Core 注册成 Windows Service

前言使用 Visual Studio 中的 Worker Service项目模板:我们很容易创建出 Windows Service&#xff1a;IHost host Host.CreateDefaultBuilder(args).UseWindowsService().ConfigureServices(services >{services.AddHostedService<Worker>();}).Build();await host.R…

19.12 添加自定义监控项目 配置邮件告警 测试告警

9月12日任务19.12 添加自定义监控项目19.13/19.14 配置邮件告警19.15 测试告警19.16 不发邮件的问题处理19.12 添加自定义监控项目需求&#xff1a;监控某台web的80端口连接数&#xff0c;并出图两步&#xff1a;1&#xff09;zabbix监控中心创建监控项目&#xff1b;2&#xf…

wab框架

http协议 一、http简介 1.HTTP是一个基于TCP/IP通信协议来传递数据&#xff08;HTML 文件, 图片文件, 查询结果等&#xff09;。 2.HTTP是一个属于应用层的面向对象的协议&#xff0c;由于其简捷、快速的方式&#xff0c;适用于分布式超媒体信息系统。它于1990年提出&#xff0…

c++ 二维矩阵 转vector_Python线性代数学习笔记——矩阵的基本运算和基本性质,实现矩阵的基本运算...

当学习完矩阵的定义以后&#xff0c;我们来学习矩阵的基本运算&#xff0c;与基本性质矩阵的基本运算&#xff1a;矩阵的加法&#xff0c;每一个对应元素相加&#xff0c;对应结果的矩阵例子&#xff1a;矩阵A和矩阵B表示的是同学上学期和下学期的课程的成绩&#xff0c;两个矩…

android 4.4以上能够实现的沉浸式状态栏效果

仅仅有android4.4以及以上的版本号才支持状态栏沉浸效果 先把程序执行在4.4下面的手机上,看下效果: 在4.4以上的效果: 当然图片也是能够作为背景的.效果: 代码: if (Build.VERSION.SDK_INT > Build.VERSION_CODES.KITKAT) {Window window getWindow();window.setFlags(Wind…

为abp vnext生成C#客户端给非abp第三方net程序使用

abp vnext提供了动态C#API客户端和静态C#API客户端来调用abp项目的接口&#xff0c;但是有局限性&#xff1b;要使用动态C#API客户端的项目必须也是ABP vnext的项目。静态C#API客户端也依赖abp的包&#xff0c;如下图为的静态客户端依赖于 Volo.Abp.DependencyInjection、Volo.…

项目中引入composer包

假如在云服务器上&#xff0c;项目根目录在 /data/shop&#xff0c;则 示例&#xff1a; cd /data/shop响应的结果可能会有两种: 1、第一种是直接require成功 示例&#xff1a; composer require haveyb/tiny-laravel #响应结果 ./composer.json has been created Loading …