深入理解redis中multi与pipeline_Redis

深入理解redis中multi与pipeline

2021-08-09 17:41Walker5883 Redis

pipeline 只是把多个redis指令一起发出去，redis并没有保证这些指定的执行是原子的；multi相当于一个redis的transaction的，保证整个操作的原子性，避免由于中途出错而导致最后产生的数据不一致。本文详细的介绍，感兴趣的可以了解一

背景

由于对redis缓存中数据有批量操作，例如预热缓存数据，或者在列表页批量去获取缓存数据，在使用了multi批量提交事务后，发现redis压力高居不下，而使用了pipeline之后压力回落了平常，也因为这个案例，特在此写个分析与笔记。

multi

简介

标记一个事务块的开始。
事务块内的多条命令会按照先后顺序被放进一个队列当中，最后由 exec 命令原子性(atomic)地执行。

实现原理

我用php扩展调起redis服务，执行，代码如下：

				?

									$redis = new redis();

									$redis->connect('127.0.0.1',6379);

									$handle = $redis->multi();

									$handle->incr('a');

									$handle->incr('b');

									$handle->exec();

为了查看这期间具体的连接过程，用wireshark监听回环地址端口6379，抓包请求如下图所示：

深入理解redis中multi与pipeline

redis客户端与服务端建立连接后，multi标记事务开始，之后每次执行，服务端返回queued队列标志。查看redis源码src/multi.c文件：

				?

									void queuemulticommand(client *c) {

									    multicmd *mc;

									    int j;

									    c->mstate.commands = zrealloc(c->mstate.commands,

									            sizeof(multicmd)*(c->mstate.count+1));

									    mc = c->mstate.commands+c->mstate.count;

									    mc->cmd = c->cmd;

									    mc->argc = c->argc;

									    mc->argv = zmalloc(sizeof(robj*)*c->argc);

									    memcpy(mc->argv,c->argv,sizeof(robj*)*c->argc);

									    for (j = 0; j < c->argc; j++)

									        incrrefcount(mc->argv[j]);

									    c->mstate.count++;

									}

在上述源码中可以看到redis服务端每次会把事务块中的命令保存到内存中，上述简介已经解释过最后通过exec命令执行，再看下面示例图的返回结果可以了解到redis服务端一次性返回所有命令执行返回结果。

深入理解redis中multi与pipeline

pipeline

简介

客户端将执行的命令写入到缓冲中，最后由exec命令一次性发送给redis执行返回。

实现原理

同样，用相关代码调用redis抓包；

				?

									$redis = new redis();

									$redis->connect('127.0.0.1',6379);

									$handle = $redis->pipeline();

									$handle->incr('a');

									$handle->incr('b');

									$handle->exec();