序言

Redis中的管道（PipeLine）特性：简述一下就是，Redis如何从客户端一次发送多个命令，服务端到客户端如何一次性响应多个命令。

Redis使用的是客户端-服务器模型和请求/响应协议的TCP服务器,这就意味着一个请求要有以下步骤才能完成：1、客户端向服务器发送查询命令，然后通常以阻塞的方式等待服务器相应。2、服务器处理查询命令，并将相应发送回客户端。这样便会通过网络连接，如果是本地回环接口那么就能特别迅速的响应，但是如果走外网，甚至外网再做一系列的层层转发，那就显的格外难受。无论网络延时是多少，那么都将占用整体响应的时间。这样一来如果一次发送1个命令，网络延时为100ms，我们不得不做。那么如果1次发1000个命令，那么网络延时100*1000ms就很难容忍啦。

针对与上面的问题，Redis在2.6版本以后就都提供啦管道（Pipeline）功能。他可以使客户端在没有读取旧的响应时，处理新的请求。这样便可以向服务器发送多个命令，而不必等待答复，直到最后一个步骤中读取答复。这被称为管线（PipeLine），并且是几十年来广泛使用的技术。例如，许多POP3协议实现已经支持此功能，大大加快了从服务器下载新电子邮件的过程。

那么事务这个词汇，经常遇到，就不多唧唧啦，目标要一致就好，便是一组操作怎么做成原子性操作，使他去不了终点，回到原点。

简述wireshark抓包工具

为啦让大家对管线有更形象的感观，这一节我们先说说Wireshark抓包工具，他会让你看到客户端到服务器通过tcp协议发送的redis命令的过程与详细。

wireshark能够扑捉到系统发送和接受的每一个报文，我们这里只做一些过滤的简述。下图就是他的样子，你打开后可以可以摸索下他的用法。

简述几个过滤规则：

1、ip过滤：目标ip过滤：ip.dst==172.18.8.11,源ip地址过滤：ip.src==192.168.1.12;

2、端口过滤：tcp.port==80，这条规则是把源端口和目的端口为80的都过滤出来。使用tcp.dstport==80只过滤目的端口为80的，tcp.srcport==80只过滤源端口为80的包；

3、协议过滤：直接在fiter框中输入协议名称即可，如：http，tcp，udp，...

4、http模式过滤:过滤get包，http.request.method=="GET",过滤post包，http.request.method=="POST"；

5、如果使用多条件过滤，则需要加连接符号，and。比如 ip.src==192.168.1.12 and http.request.method=="POST" and tcp.srcport==80

StackExchange.Redis实现Redis管线（Pipeline）

上两张图片管线便一目了然啦。

客户端对redis服务器进行多次请求的话，一般普通模式是这样子的

客户端对redis服务器进行多次请求的话，管道模式是这样子的

一般模式我们上代码：

public static void GetNoPipelining()
  {
   for (var i = 0; i < 3; i++)
   {
    var key = "name:" + i;
    db.StringAppend(key, "张龙豪");
   }
  }

查看tcp请求报文的data

这样你自己做的过程中，可以看到我圈起来的3个tcp请求的key分别为name：0，name:1,name:2这样子。

那么我们使用管道模式

public static void GetPipelining()
  {
   var batch = db.CreateBatch();
   for (int i = 0; i < 3; i++)
   {
    var key = "mename:" + i;
    batch.StringAppendAsync(key, "张龙豪");
   }
   batch.Execute();
  }

再来看下请求

这样很明显就能看出来是1个请求发送出来啦多个命令。那么我们不用createBatch（）也是可以实现这样的效果的。

var a = db.StringAppendAsync("zlh:1", "zhanglonghao1");
   var b = db.StringAppendAsync("zlh:2", "zhanglonghao2");
   var c = db.StringAppendAsync("zlh:3", "zhanglonghao3");
   var aa = db.Wait(a);
   var bb = db.Wait(a);
   var cc = db.Wait(a);

在接下来我们做一个简单的性能比较。代码如下：

static void Main(string[] args)
  {
   Stopwatch watch = new Stopwatch();
   Stopwatch watch1 = new Stopwatch();
   watch.Start();
   GetNoPipelining();
   Console.WriteLine("一般循环耗时：" + watch.ElapsedMilliseconds);
   watch.Stop();
   watch1.Start();
   GetPipelining();
   Console.WriteLine("Pipelining插入耗时：" + watch1.ElapsedMilliseconds);
   watch1.Stop();
   Console.ReadLine();
  }
  public static void GetNoPipelining()
  {
   for (var i = 0; i < 5000; i++)
   {
    var key = "name:" + i;
    db.StringAppend(key, "张龙豪");
   }
  }
  public static void GetPipelining()
  {
   var batch = db.CreateBatch();
   for (int i = 0; i < 5000; i++)
   {
    var key = "mename:" + i;
    batch.StringAppendAsync(key, "张龙豪");
   }
   batch.Execute();
  }

结果如下：

到此我还要说一下StackExchange.Redis的三种命令模式，其中使用2和3的模式发送命令，会默认被封装在管道中，不信的话，你可以做个小demo测试下：

1、sync：同步模式，会直接阻塞调用者，但不会阻塞其他线程。

2、async：异步模式，使用task模型封装。

3、fire-and-forget：发送命令，然后完全不关心最终什么时候完成命令操作。在Fire-and-Forget模式下,所有命令都会立即得到返回值，该值都是该返回值类型的默认值,比如操作返回类型是bool将会立即得到false,因为false = default(bool)。

此节参考redis官方文档与StackExchange.Redis官方文档，连接如下：

https://redis.io/topics/pipelining

https://github.com/StackExchange/StackExchange.Redis/blob/master/Docs/PipelinesMultiplexers.md

StackExchange.Redis实现Redis事务（Transactions）

这个看官方文档，我只能说实现的很奇怪吧。我先描述下我的环境，就是准备一个空redis库，然后一步一步往下走，我们写代码看结果，来搞一搞这个事务。

static void Main(string[] args)
  {
   var tran = db.CreateTransaction();
   tran.AddCondition(Condition.ListIndexNotEqual("zlh:1",0,"zhanglonghao"));  
   tran.ListRightPushAsync("zlh:1", "zhanglonghao"); 
   bool committed = tran.Execute();
   Console.WriteLine(committed);
   Console.ReadLine();
  }

执行结果为：true。数据库中结果如下，说明我们插入成功。

即：如果key为：zlh：1的list集合在索引0初的value!=zhanglonghao的话，我们从链表右侧插入一条数据key为zlh：1value为zhanglonghao，成功。因为第一次操作为空库。0处确实不为张龙豪。

数据不清空，继续上代码。

static void Main(string[] args)
  {
   var tran = db.CreateTransaction();
   tran.AddCondition(Condition.ListIndexNotEqual("zlh:1",0,"zhanglonghao"));  
   tran.ListRightPushAsync("zlh:1", "zhanglonghao1");   
   bool committed = tran.Execute();
   Console.WriteLine(committed);
   Console.ReadLine();
  }

结果为false，数据库没有增减数据。已久与上图的数据保持一致。

原因分析：0处此时为zhanglonghao，所以ListIndexNotEqual("zlh:1",0,"zhanglonghao")为假命题，直接回滚，不执行下面的插入命令。

数据不清空，继续上代码：

static void Main(string[] args)
  {
   var tran = db.CreateTransaction();
   tran.AddCondition(Condition.ListIndexEqual("zlh:1",0,"zhanglonghao"));  
   tran.ListRightPushAsync("zlh:1", "zhanglonghao1");   
   bool committed = tran.Execute();
   Console.WriteLine(committed);
   Console.ReadLine();
  }

结果为true，数据结果如下，增长一条值为zhanglonghao1的数据：

原因分析：ListIndexEqual("zlh:1",0,"zhanglonghao")为真命题，执行下面的操作，提交事物。

数据不删继续上代码：

static void Main(string[] args)
  {
   var tran = db.CreateTransaction();
   tran.AddCondition(Condition.ListIndexEqual("zlh:1",0,"zhanglonghao"));  
   tran.ListRightPushAsync("zlh:1", "zhanglonghao2");
   tran.AddCondition(Condition.ListIndexNotEqual("zlh:1", 0, "zhanglonghao"));
   tran.ListRightPushAsync("zlh:1", "zhanglonghao3");
   bool committed = tran.Execute();
   Console.WriteLine(committed);
   Console.ReadLine();
  }

结果为false，数据库数据已久与上面的保持一致，不增不减。

分析原因：Condition.ListIndexEqual("zlh:1",0,"zhanglonghao")为true，但是到下面的ListIndexNotEqual("zlh:1", 0, "zhanglonghao")为false。故整个事物的操作回滚，不予执行，故数据库没有变化。

到此，我就不写多余的代码啦，但我要说几个注意点：

1、执行命令的操作需为异步操作。

2、在事物中执行的命令，都不会直接看到结果，故此结果也不能用于下面代码做判断，因为当前的异步命令在Execute()之前是不会对数据库产生任何影响的。

3、参考文档：https://github.com/StackExchange/StackExchange.Redis/blob/master/Docs/Transactions.md

以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，同时也希望多多支持！

# redis pipeline  # 详解redis大幅性能提升之使用管道（PipeLine）和批量（Batch）操作  # Redis基础学习之管道机制详析  # Python redis操作实例分析【连接、管道、发布和订阅等】  # SpringBoot整合Redis管道的示例代码  # redis批量操作pipeline管道操作方法  # Redis内存碎片产生原因及Pipeline管道原理解析  # Springboot下使用Redis管道(pipeline)进行批量操作  # Redis中pipeline(管道)的实现示例  # Redis中管道操作的项目实践  # 客户端  # 多个  # 这样子  # 几个  # 文档  # 已久  # 到此  # 清空  # 返回值  # 端到  # 的是  # 都是  # 我就  # 让你  # 我还  # 你可以  # 那就  # 就能  # 将会  # 很难 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： Laravel Asset编译怎么配置_Laravel Vite前端构建工具使用  在centOS 7安装mysql 5.7的详细教程  ChatGPT 4.0官网入口地址 ChatGPT在线体验官网  Android利用动画实现背景逐渐变暗  如何快速打造个性化非模板自助建站？  Laravel的辅助函数有哪些_Laravel常用Helpers函数提高开发效率  如何在企业微信快速生成手机电脑官网？  制作网站软件推荐手机版,如何制作属于自己的手机网站app应用？  Laravel如何实现本地化和多语言支持？（i18n教程）  laravel怎么使用数据库工厂（Factory）生成带有关联模型的数据_laravel Factory生成关联数据方法  Laravel怎么配置不同环境的数据库_Laravel本地测试与生产环境动态切换【方法】  高防服务器租用指南：配置选择与快速部署攻略  Laravel的HTTP客户端怎么用_Laravel HTTP Client发起API请求教程  Android仿QQ列表左滑删除操作  Laravel如何使用Vite进行前端资源打包？（配置示例）  Laravel API路由如何设计_Laravel构建RESTful API的路由最佳实践  Laravel如何实现URL美化Slug功能_Laravel使用eloquent-sluggable生成别名【方法】  如何快速上传建站程序避免常见错误？  详解MySQL数据库的安装与密码配置  简历没回改：利用AI润色让你的文字更专业  Laravel控制器是什么_Laravel MVC架构中Controller的作用与实践  Laravel路由怎么定义_Laravel核心路由系统完全入门指南  Win11怎样安装网易有道词典_Win11安装词典教程【步骤】  javascript中闭包概念与用法深入理解  香港网站服务器数量如何影响SEO优化效果？  Internet Explorer官网直接进入 IE浏览器在线体验版网址  音响网站制作视频教程,隆霸音响官方网站？  SQL查询语句优化的实用方法总结  弹幕视频网站制作教程下载,弹幕视频网站是什么意思？  Laravel Fortify是什么，和Jetstream有什么关系  如何解决hover在ie6中的兼容性问题  Android自定义listview布局实现上拉加载下拉刷新功能  香港服务器网站推广：SEO优化与外贸独立站搭建策略  济南网站建设制作公司,室内设计网站一般都有哪些功能？  详解Android图表 MPAndroidChart折线图  php做exe能调用系统命令吗_执行cmd指令实现方式【详解】  在线ppt制作网站有哪些软件,如何把网页的内容做成ppt？  手机网站制作平台,手机靓号代理商怎么制作属于自己的手机靓号网站？  如何自己制作一个网站链接,如何制作一个企业网站，建设网站的基本步骤有哪些？  JavaScript如何实现路由_前端路由原理是什么  如何生成腾讯云建站专用兑换码？  Laravel Eloquent：优雅地将关联模型字段扁平化到主模型中  微信小程序 input输入框控件详解及实例（多种示例）  小视频制作网站有哪些,有什么看国内小视频的网站，求推荐？  如何彻底删除建站之星生成的Banner？  Win11任务栏卡死怎么办 Windows11任务栏无反应解决方法【教程】  中山网站推广排名,中山信息港登录入口？  微信小程序 require机制详解及实例代码  HTML5打空格有哪些误区_新手常犯的空格使用错误【技巧】  图片制作网站免费软件,有没有免费的网站或软件可以将图片批量转为A4大小的pdf？