StackExchange.Redis学习笔记(四) 事务控制和Batch批量操作

Redis事物

Redis命令实现事务

Redis的事物包含在multiexec(执行)或者discard(回滚)命令中

和sql事务不同的是,Redis调用Exec只是将所有的命令变成一个单元一起执行,期间不会插入其他的命令。

这种方式不保证事务的一致性,即使中间有一条命令出错了,其他命令仍然可以正常执行,并且无法回滚

下面的例子演示了一个基本的事务操作

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set name mike
QUEUED
127.0.0.1:6379> set age 20
QUEUED
127.0.0.1:6379> exec
1) OK
2) OK
127.0.0.1:6379> get name
"mike"

可以看到,直到调用Exec命令时,才开始执行之前的所有命令,同时会返回两个结果,discard 命令类似,就不贴代码了。

下面模拟一个会报错的命令来看一下

127.0.0.1:6379> get age
"20"
127.0.0.1:6379> get name
"mike"
127.0.0.1:6379> multi
OK
127.0.0.1:6379> incr name
QUEUED
127.0.0.1:6379> incr age
QUEUED
127.0.0.1:6379> exec
1) (error) ERR value is not an integer or out of range
2) (integer) 21
127.0.0.1:6379> get age
"21"
127.0.0.1:6379>

我们同时将用户name和age 进行自增1操作,然而name不是数字类型,结果执行失败,但是age的自增操作仍然成功了。这无疑是个很令人不舒服的弊端,所以在写相关代码时要注意

乐观锁

前面说到通过multi命令只是保证一个事物中的所有命令可以在一起执行,显然只是实现这一点的话对于大部分的业务都是无法满足的。

所以Redis提供了Watch命令来监控一个key以达到乐观锁的效果。关于乐观锁的原理有不了解的小伙伴可以抽十分钟去科普一下

下面展示一个乐观锁实例:

                         

这里模拟了两个客户端同时操作一个相同的键

左边为client1,我们用watch监控了name和age两个键,然后分别设置name和age的值。在exec命令之前,通过另一个客户端client2设置了name的值。

client1执行exec命令时,Redis检测到name的值已经被其他客户端改过了,因此在事物中的所有命令都会回滚。

watch命令是对整个连接有效的,用完之后可以用discard、unwatch、exec命令清除监视

StackExchange.Redis中的事物控制

在StackExchange.Redis是无法用watch multi命令来执行的,因为在并发环境下,会产生多个watch multi命令,全混在一起就乱套了。

但是StackExchange.Redis提供了一套非常简单易懂的创建事物的方式 ,下面为示例代码

 public void TestTran()
        {
            IDatabase db = StackExchangeRedisHelper.GetDatabase();
            string name = db.StringGet("name");
            string age = db.StringGet("age");
            Console.WriteLine("NAME:" + name);
            Console.WriteLine("Age:" + age);
            var tran = db.CreateTransaction();
            tran.AddCondition(Condition.StringEqual("name", name));
            Console.WriteLine("tran begin");
            tran.StringSetAsync("name", "leap");
            tran.StringSetAsync("age", 12);
            Thread.Sleep(4000);
            bool result = tran.Execute();
            Console.WriteLine("执行结果:" + result);
            Console.WriteLine("Age:" + db.StringGet("age"));
            Console.WriteLine("Name:" + db.StringGet("name"));
        }

这里通过CreateTransaction函数(multi)来创建一个事物,调用其Execute函数(exec)提交事物,其中的 "Condition.StringEqual("name", name)" 就相当于Redis命令中的watch name。

其中睡眠四秒是我需要在事物提交之前打开另一个客户端来修改name的值.最终的执行结果如下

NAME:leo
Age:20
tran begin
执行结果:False
Age:20
Name:mike

  在程序睡眠期间我用另一个客户端将name改成了mike,所以事物最终执行失败

通过查询Redis的慢日志。其调用的命令也是watch multi exec。(慢日志没有记录Exec命令,实际上是执行了的)

我们可以通过设置redis.windows-service.conf文件中的slowlog-log-slower-than的值为0让Redis记录所有的命令日志

127.0.0.1:6379> slowlog get 100
 1) 1) (integer) 293
    2) (integer) 1511257634
    3) (integer) 1
    4) 1) "GET"
       2) "name"
 2) 1) (integer) 292
    2) (integer) 1511257634
    3) (integer) 0
    4) 1) "GET"
       2) "age"
 3) 1) (integer) 291
    2) (integer) 1511257634
    3) (integer) 3
    4) 1) "SELECT"
       2) "0"
 4) 1) (integer) 290
    2) (integer) 1511257634
    3) (integer) 1
    4) 1) "SET"
       2) "age"
       3) "12"
 5) 1) (integer) 289
    2) (integer) 1511257634
    3) (integer) 1
    4) 1) "SET"
       2) "name"
       3) "leap"
 6) 1) (integer) 288
    2) (integer) 1511257634
    3) (integer) 1
    4) 1) "MULTI"
 7) 1) (integer) 287
    2) (integer) 1511257634
    3) (integer) 3
    4) 1) "GET"
       2) "name"
 8) 1) (integer) 286
    2) (integer) 1511257634
    3) (integer) 11
    4) 1) "WATCH"
       2) "name"
 9) 1) (integer) 285
    2) (integer) 1511257634
    3) (integer) 4
    4) 1) "GET"
       2) "age"
10) 1) (integer) 284
    2) (integer) 1511257634
    3) (integer) 6
    4) 1) "GET"
       2) "name"

  这里可能大家会有个疑惑,既然tran是直接调用的watch multi等命令,为什么不会有并发的顺序问题?

这是因为Tran开启后,所做的watch,stringset等操作,都会再调用Exec函数时把相应的命令封装成一个请求发送给Redis一起执行。这样每个事务之间都是独立的,就不会有问题了。

Batch批量操作

StackExchange.Redis中对于连续多次的缓存等请求,我们会多次调用相关的函数来执行Redis命令。然而这种方式有个弊端就是每一次的请求都需要等待返回结果

如果在网络状况不好的情况下,可能会造成不好的用户体验。

对于这种问题可以用StackExchange.Redis提供的CreateBatch()解决

 public void TestPipeLine()
        {
            IDatabase db = StackExchangeRedisHelper.GetDatabase();
            var batch = db.CreateBatch();
            Task t1 = batch.StringSetAsync("name", "bob");
            Task t2 = batch.StringSetAsync("age", 100);
            batch.Execute();
            Task.WaitAll(t1, t2);
            Console.WriteLine("Age:" + db.StringGet("age"));
            Console.WriteLine("Name:" + db.StringGet("name"));
        }

batch会把所需要执行的命令打包成一条请求发到Redis,然后一起等待返回结果。这样批量操作的速度就大大提升啦!

时间: 2024-10-24 14:41:55

StackExchange.Redis学习笔记(四) 事务控制和Batch批量操作的相关文章

Redis学习笔记(7)-事务

package cn.com; import java.util.List; import redis.clients.jedis.Jedis; import redis.clients.jedis.Transaction; public class Redis_Transactions { public static Jedis redis = new Jedis("localhost", 6379);// 连接redis /** * 基本事务用法 * 默认给user1,user2都

西门子PLC学习笔记四-(控制三项异步电动机的启动停止)

本篇是学习S7-300的一个小程序,用于对PLC开发简单直观的认识. 1.三项异步电动机电路图 2.PLC控制接线图 从图中可以看出控制按钮接PLC 信号模块SM的I0.0.I0.1端口,输出信号从Q4.1输出 3.PLC SM模块选择 1)输入模块选择 SM321 DI32*24V 2)输出模块选择 SM322 DO32*AC120/230/1A 4.硬件组态图如下: 5.编辑符号变量 6.编写梯形图程序 7.编写程序 程序解释: sb1_start使用开路符号表示:当接通时整条线路都接通,默

Redis学习笔记3--Redis事务

Redis对事务的支持目前还比较简单.redis只能保证一个client发起的事务中的命令可以连续的执行,而中间不会插入其他client的命令. 由于redis是单线程来处理所有client的请求的所以做到这点是很容易的.一般情况下redis在接受到一个client发来的命令后会立即处理并 返回处理结果,但是当一个client在一个连接中发出multi命令有,这个连接会进入一个事务上下文,该连接后续的命令并不是立即执行,而是先放到一 个队列中.当从此连接受到exec命令后,redis会顺序的执行

Redis 学习笔记四 Mysql 与Redis的同步实践

一.测试环境在Ubuntu kylin 14.04 64bit 已经安装Mysql.Redis.php.lib_mysqludf_json.so.Gearman. 点击这里查看测试数据库及表参考 本文也有些基本操作,在之前文章里有介绍. 1.安装 安装gearman-mysql-udf apt-get install libgearman-dev wget https://launchpad.net/gearman-mysql-udf/trunk/0.6/+download/gearman-my

【Unity 3D】学习笔记四十六:输入与控制——键盘事件

在游戏中,玩家控制主角移动,按键攻击,选择行走.都需要在程序中监听玩家的输入.unity为开发者提供了input库,来支持键盘事件,鼠标事件以及触摸事件.本文主要回顾键盘事件,以后会逐文复习鼠标以及触摸事件. 键盘事件 一般的PC键盘有104个不同的按键,在程序中通过监听这些按键事件,从而进一步执行逻辑操作.如:射击游戏中,W表示前进,S表示后退,A表示左移,D表示右移. 按下事件 在脚本中,用input.GetKeyDown( )方法将按键值作为参数,监听此按键是否被按下.按下返回true,否

(转)redis 学习笔记(1)-编译、启动、停止

redis 学习笔记(1)-编译.启动.停止 一.下载.编译 redis是以源码方式发行的,先下载源码,然后在linux下编译 1.1 http://www.redis.io/download 先到这里下载Stable稳定版,目前最新版本是2.8.17 1.2 上传到linux,然后运行以下命令解压 tar xzf redis-2.8.17.tar.gz 1.3 编译 cd redis-2.8.17make 注:make命令需要linux上安装gcc,若机器上未安装gcc,redhat环境下,如

Redis学习笔记4-Redis配置具体解释

在Redis中直接启动redis-server服务时, 採用的是默认的配置文件.採用redis-server   xxx.conf 这种方式能够依照指定的配置文件来执行Redis服务. 依照本Redis学习笔记中Redis的依照方式依照后,Redis的配置文件是/etc/redis/6379.conf.以下是Redis2.8.9的配置文件各项的中文解释. #daemonize no 默认情况下, redis 不是在后台运行的.假设须要在后台运行,把该项的值更改为 yes daemonize ye

Redis学习笔记7--Redis管道(pipeline)

redis是一个cs模式的tcp server,使用和http类似的请求响应协议.一个client可以通过一个socket连接发起多个请求命令.每个请求命令发出后client通常会阻塞并等待redis服务处理,redis处理完后请求命令后会将结果通过响应报文返回给client.基本的通信过程如下: Client: INCR X Server: 1 Client: INCR X Server: 2 Client: INCR X Server: 3 Client: INCR X Server: 4

【Unity 3D】学习笔记四十三:布料

布料 布料是特殊的组件,它可以变化成任意形状,比如说:随风飘的旗子,窗帘等 创建布料的方法有两种:创建布料对象,在游戏对象中添加布料组件.前者通过hierarchy视图中选择create--cloth即可,创建后,系统会自动将互动布料组件(interactive clothe)与布料渲染组件(cloth renderer)添加值该对象中.后者是在导航菜单中选component--physics--interactive cloth菜单项即可. 交互布料组件是由网格组成的布料,只要用于布料的逻辑判