简单 大气 网站模版,吕邵苍设计公司网站,公司网站模板中英文,品牌建设的十六个步骤一、简单动态字符串SDS
无论是Redis中的key还是value#xff0c;其基础数据类型都是字符串。如#xff0c;Hash型value的field与value的类型#xff0c;List型#xff0c;Set型#xff0c;ZSet型value的元素的类型等都是字符串。redis没有使用传统C中的字符串而是自定义了…一、简单动态字符串SDS
无论是Redis中的key还是value其基础数据类型都是字符串。如Hash型value的field与value的类型List型Set型ZSet型value的元素的类型等都是字符串。redis没有使用传统C中的字符串而是自定义了一种字符串结构类型这种字符串本身的结构比较简单但是功能强大称为简单动态字符串 Simple Dynamic String ,简称为SDS。
SDS结构
SDS不同于C中的字符串C中的字符串是以一个双引号括起来以空字符\0结尾的字符序列。而SDS是重新定义的一个结构体在redis的安装目录src/sds.h
这个结构体有三个部分组成
struct sdshdr{// 字节数组用来保存字符串char buf[];// SDS的长度在buf[]中使用的字节数量int len;// buf[]中没有使用的字节数量int free;
}
注意虽然redis当中定义了结构体sds但是并不是所有的字符串都使用这种方式存储比如我们执行一个set命令返回了一个OK这个OK就是C语言中的字符串。get命令获取的值返回的也是C语言的字符串。C 字符串只会出现在字符串“字面常量”中并且该字符串不可能发生变更 我们看下面的命令我们来了解一下类型与实际内存中的存储结构的区别
set name zhangsan # 写入key为name的值为zhangsan,这里写入的是zhangsan应该是SDS结构类型的
type name # 这里返回的会是string 表示是字符串
object encoding name # 这里会返回embstr它就表示是SDS是内存中的存储类型set age 23 # 写入key为age的值为23
type age # 这里返回的是string,表示是字符串
object encoding age # 这里返回的是int,表示在内存中是以整型存储的
SDS优势
C字符串底层是一个数组字符串最后以’\0‘来结束。
优势一防止字符串长度获取性能瓶颈
C字符串的长度获取必须要通过遍历整个字符串直到\0结束才可以获得这样的话对于超长的字符串遍历还是会产生性能瓶颈的。
SDS结构体中我们可以看到直接存放着字符串长度的数据所以不管字符串有多长获取字符串的长度所要消耗的系统性能都是一样的不会成为redis的性能瓶颈。
优势二保障二进制安全
C字符串对于字符串中的字符是有要求的遇到\0就表示字符串结束了但是我们在redis中会用字符串存储二进制数据图片视频压缩文件...,在这些文件中使用\0在中间作为分隔符的情况是很常见的。所以redis中的SDS不以\0作为字符串结束标志而是通过len属性来判断字符串是否结束所以对于程序处理SDS中的字符串数据不需要对数据做任何的限制、过滤等处理直接读取即可。写入的是什么读出来的就是什么。
优势三减少内存再分配
SDS中采用了空间预分配策略与惰性空间释放策略来避免内存再分配的问题。
这两个策略就是以空间换时间的做法
如果我们要释放SDS的未使用空间可以通过sdsRemoveFreeSpace(函数来释放。
优势四兼容C函数
redis中提供了很多的SDS的api方便用户对redis进行二次开发为了兼容C函数SDS的底层数组buf[]中的字符串仍以空字符\0结尾。
SDS常用操作函数
空间预分配策略每次SDS进行空间扩展的时候程序不但为其分配所需的空间还会为其分配额外的未使用空间从而减少内存再分配次数客户分配的未使用空间大小取决于空间扩展后SDS的len属性值。 如果len属性值小于1M那么会分配未使用空间保持与len属性相当如果len属性值大于等于1M那么会固定分配未使用空间1M 惰性空间释放策略如果SDS字符串长度如果缩短那么多出的未使用空间会暂时不释放而是增加到free当中去从而保证后期扩展SDS时减少再分配的次数
函数功能sdsnew()使用指定的C字符串创建一个SDSsdsempty()创建一个不包含任何字符串数据的SDSsdsdup()创建一个指定SDS的副本sdsfree()释放是定的SDSsdsclear()清空指定SDS的字符串内容sdslen()获取指定SDS的已使用空间len值sdsavail()获取指定SDS的未使用空间free值sdsMakeRoomFor()使指定的SDS的free空间增加指定的大小sdsRemoveFreeSpace()释放指定SDS的free空间sdscat()把指定的C字符串拼接到指定SDS的字符串末尾sdscatsds()把指定的SDS字符串拼接到另一个指定的SDS字符串末尾sdscpy()把指定C字符串复制到指定的SDS中覆盖原SDS字符串内容sdsgrouzero()扩展SDS字符串到指定长度这个扩展使用空字符\0填充sdsrange()截取指定SDS中指定范围内的字符串sdstrim()在指定SDS中删除报有指定C字符串中出现的所有字符sdsemp()对比给定的两个SDS字符串是否相同sdstolow()把指定SDS字符串中的所有字母变为小写sdstoupper()把指定SDS字符串中所有字母变为大写 这些函数在需要对redis二次开发时可能会用到正常使用redis时用不到
集合底层实现原理
Set集合
对于set我们看它底层的实现可以如下
sadd cities bj sh gz sz # 添加一个set集合
type cities # 返回的类型是set
object encoding cities # 返回的是hashtable
从上面可以看到set底层是使用hashtable存储的
Hash与ZSet
这两种它们的底层实际上有两种压缩列表zipList跳跃列表skipList
至于Redis什么时候用zipList什么时候用skipList对于我们用户来说是透明的用户写入不同的数据系统会自动判断使用不同的实现。
只要我们的数据量不超过我们设定的阈值则会使用zipList一旦超过这个阈值则什么变为skipList。
关于这个阈值的查看可以使用命令进行查看
config get zset-*-ziplist-*
# 运行后得到的结果类似如下
1) zset-max-ziplist-entries
2) 128
3) zset-max-ziplist-value
4) 64
上面的信息表示zset中包含的元素不超过128并且每一个元素的大小不超过64字节就会使用ziplist。这两个任意一个不满足就会变为skipList。
同样hash的查询方式也类似其查询命令如下
config get hash-*-ziplist-*
# 运行这个命令后的结果如下
1) hash-max-ziplist-value
2) 64
3) hash-max-ziplist-entries
4) 512
关于zipList的底层结构
首先什么是zipList
通常称为压缩列表是一个经过特殊编码体现了zip压缩的的用于存储字符串或整数的双向链表。其底层数据结构由三部分构成head基础信息、entries元素、end结束标记这三部分在内存上是连续存放的。
zipList的三部分在底层如何存储
说明head 它包含总括性信息由三部分组成 zlbytes4个字节用来存放zipList列表整体数据结构所占的字节数包括zlbytes本身的长度 zltail4个字节用于存放zipList中最后一个entry在整个数据结构中的偏移量字节这个数据可以快速定位列表的尾entry位置便于操作。 zllen两个字节用于存放列表包含的entry的个数两个字节是16位所以zipList最多可以包含有个一旦元素个数超过了它这里就没有办法表示元素个数了这部分的值也就没有意义了此时要看有多少个元素就只能通过遍历来确定了 entries entries是真正的列表由很多的列表元素entry构成由于不同的元素类型、数值是不同的从而导致每个entry的长度不同。每个entry由三部分构成 prevlength用来记录上一个entry的长度用以实现逆序遍历默认长度是1字节只要上一个entry的长度254字节prevlength就会占1字节否则会扩展为3字节长度。 注意这里分节点为什么是小于254不是255因为zipList中有一个部分是1字节的全为1表示结束所以不能用255而254也是一个保留的值用来做为prevlength的自动扩展标志的 encoding用来标记后面的data具体类型。如果data为整数类型encoding固定长度是1字节如果data为字符串类型则encoding长度可能会是1字节、2字节或5字节。data字符串不同的长度对应着不同的encoding长度 data真正存储的数据。数据类型只能是整数类型或字符串类型不同的数据占用的字节长度不同 endend只包含一部分称为zlend。其占一个字节值固定为255也就是二进制全为1表示一个zipList列表的结束。
zipList的结构图大致如下 关于listPack底层结构
zipList是在Redis7之前版本中使用的到了7版本不再使用zipList而是使用listPack进行了替换。
为什么要把zipList替换为listPack?
在zipList中每一个entry中的prevlength当中会记录前一个entry的长度如果在中间某个元素前插入了一个元素或修改了元素那这个元素entry中的prevlength还要跟着去调整级联更新。在高并发的写操作场景下会极度地降低Redis的性能所以为了实现更紧凑、更快的解析更简单的写操作所以重写了zipList并把它命名为listPack。
那listPack有是什么呢
它也是一种经过特殊编码的用于存储字符串或整数的双向链表。其底层数据结构也是由三部分构成的head、entries、end并且这三部分在内存上也是连续进行存放的。
listPack与zipList的最大区别在于head和每个entry的结构上表示列表结束的end两者是相同的占一个字节且全为1。
说明head 由两部分组成 totalBytes占4个字节用来存放listPack列表整体数据结构所占的字节数也包含totalBytes本身的长度 elemNum占2个字节用于存放列表包含的entry个数其意义与zipList中的zllen是相同的 注意在listPack中没有记录最后一个entry偏移量的zltail entries entries也是listPack中真正的列表由很多的列表元素entry构成。由于不同的元素类型、数值的不同从而导致每个entry的长度不同。但是与zipList的entry结构相比listPack的entry结构发生了较大的变化。其中变化最大的就是没有了记录前一个entry长度的prevlength而增加了记录当前entry长度的element-total-len。而这一变化仍然可以实现逆序遍历(由新的算法来支撑)但去避免了由于在列表中间修改或插入entry引发的级联更新。 每个entry由三个部分组成 encoding标记后面data的具体类型如果是整数类型其长度可能是123459字节。不同的字节长度标识位不同。如果是字符串则长度可能是125字节。data字符串不同的长度对应着不同的encoding长度 data真正存储的数据。数据类型只能是整数类型或字符串类型不同的数据占用的字节长度不同 element-total-len记录当前entry的长度用来支持逆序遍历由于其特殊的记录方式其本身占用的字节数据中能会是12345字节 endend只包含一部分其占一个字节值固定为255也就是二进制全为1表示一个zipList列表的结束。
listPack的底层结构图大致如下 注意encoding是比较复杂的有些数据中可能在encoding中就包含了数据本身了没有data这部分了
关于skipList底层结构
什么是skipList呢
skipList指的是跳跃列表简称跳表是一种随机化的数据结构基于并联的链表实现简单查找效率较高。简单理解这里的跳表也是链表的一种只是在链表的基础上添加了跳跃的功能。因为有了这个跳跃的功能所以在查找元素时能够提供较高的效率。
skipList是如何跳跃后提高查找元素效率的呢原理是什么
我们先看下面这个有序列表 此时如果我们要查找某个数据比如23则需要从头开始一个一个进行比较直接找到包含要找数据的节点或者找到第一个比要找数据还大的节点或者找到末尾节点这后面的两种都表示没有找到这种方式的查找没有效率是不高的为了提升效率可以在偶数结点上加上一个指针让这个指针指向下一个偶数节点如下图所示 此时所有的偶数节点连成了一个新的链表称为高层链表高层链表的节点数只有原链表的一半。如果这个时候要查找某个数据时会先沿着高层链表进行查找当遇到第一个比待查数据大的节点时立即从这个大节点的前一个节点回到原链表进行查找。比如我们想找23先在高层节点进行遍历遍历到31时发现比23大了此时会从它的前一个节点开始也就是19按原链表顺序进行遍历这时遍历到23找到元素。
使用跳表这种方式明显可以减少比较的次数提高查询的效率如果链表的元素比较多还想进一步提升效率可以再加一层高层链表。此时就变成了先遍历最高层的链表再遍历第二高层的链表依次类推。
上面这种跳表的基础结构可能存在的问题
这种对链表的分层级的方式看上去确实提升了查找效率但是实际操作时情况比较多会产生问题比如固定序号的元素有固定的层级那么列表中的元素如果出现增加或删除这会导致列表整体的层级都需要调整这会大大降低系统性能。
解决这种序号变化带来的层级变化影响性能的算法优化办法
为了避免前面的问题skipList采用了随机分配层级方式。在确认了总层级后每添加一个新的元素时会自己动为其随机分配一个层级。这种随机性就解决了节点序号与层级之前的固定关系问题。
数据新插入进来不影响其它节点的层级数。只需要修改插入节点的前后的指针而不需要对很多节点进行调整这也降低了插入操作的复杂度。
skipList指的就是除了最下面第1层链表外它会产生若干层稀疏的链表这些链表里面的指针跳过了一些节点并且越高层级的链表跳过的节点越多。在查找数据的时先在高层级链表中进行查找然后逐层降低最终可能会降到第 1 层链表来精确地确定数据位置。在这个过程中由于跳过了一些节点所以提升了效率。
关于quickList底层结构
什么是quickList呢
它是一个快速列表它本身是一个双向无循环链表它的每一个节点都是一个zipList。从Redis3.2版本开始对于List底层实现使用quickList代替了zipList和linkedList。
quickList本质上来讲是zipList和linkedList的混合体它把linkedList按段切分每一段使用zipList来紧凑存储若干个真正的数据元素多个zipList之间使用双向指针串接起来。对于每个zipList中最多可存放多大容量的数据元素在配置文件中可以通过list-max-ziplist-size属性来指定。
如何对它其中的元素进行检索 首先我们要清楚的是对于List元素的检索操作都是使用索引来操作的。
quickList由一个一个的zipList构成每个zipList的zllen中记录了当前zipList中包含的entry的个数根据要检索的index,从quickList的头节点开始逐个对zipList的zllen做求和操作直到找到第一个求和后的值大于要检索的index时那么要检索的元素就在这个zipList当中。
如何对它进行元素的插入呢
由于zipList是有大小限制的所以在quickList中插入一个元素则相对就比较复杂了。它需要分几种情况来处理。
假设要插入的元素大小为insertBytes而查找到的插入位置所在zipList当前的大小为zlBytes处理情况则如下
情况1当insertBytes zlBytes list-max-ziplist-size时直接插入到zipList中的相应位置即可情况2当insertBytes zlBytes list-max-ziplist-size且插入的位置位于这个zipList的首部位置时此时需要看当前zipList的前一个zipList的大小prev_zlBytes 如果insertBytes prev_zlBytes list-max-ziplist-size时直接把元素插入到前一个zipList的尾部位置如果insertBytes prev_zlBytes list-max-ziplist-size时就会直接创建一个新的zipList并连接入quickList中情况3当insertBytes zlBytes list-max-ziplist-size且插入的位置位于这个zipList的尾部位置时此时需要看当前zipList的后一个zipList的大小next_zlBytes 如果insertBytes next_zlBytes list-max-ziplist-size时直接把元素插入到后一个zipList的首部位置如果insertBytes next_zlBytes list-max-ziplist-size时就会直接创建一个新的zipList并连接入quickList中情况4当insertBytes zlBytes list-max-ziplist-size且插入的位置位于这个zipList的中间位置时则会把zipList分割为两个zipList连接入quickList当中然后把元素插入到分隔后的前面zipList的尾部
删除操作如何操作
对于删除操作只需要注意一点在相应的 zipList 中删除元素后该 zipList 中是否还有元素。如果没有其它元素了则将该 zipList 删除将其前后两个 zipList 相连接。
关于Redis中key与value支持的数量
Redis中最多可以处理个key大约42亿。每个 Redis 实例至少可以处理 2.5 亿个 key每个HashListSetZSet集合都可以包含个元素
二、BitMap操作
BitMap是什么
BitMap是Redis2.2.0版本中引入的一种新的数据类型。这个数据类型本质上就是一个仅包含0和1二进制字符串。而它相关的命令都是对这个字符串二进制位的操作。用于描述这个字符串的属性有三个keyoffsetbitValue
keyBitMap是Redis的key-value中的一种Value的数据类型所以这个value一定是会有对应key的offset每个BitMap数据都是一个字符串字符串中的每个字符都有其对应的索引这个索引是从0开始计数的。该索引则称为每个字符在BitMap中的偏移量offset 它的范围是[0, ],所以最大值是42亿多。bitValue每个BitMap数据中都是一个仅包含0和1的二进制字符串每个offset位上的字符就称这个位的值bitValue它的值只能是0或者1
相关操作命令
命令说明示例setbit 为指定key的BitMap数据的offset位置上设置值为value它的返回值是offset位置的bitValue 对于原BitMap字符串中不存在的offset进行赋值字符串会自动伸展以确保它可以把value保存到指定的offset上当字符串值进行伸展时空白位置上会以0来填充对于value值只能是0或者1。 注意对于较大的offset的setbit操作来说内存分配过程可以造成Redis服务器被阻塞 setbit sing 3 1getbit 对key所存储的BitMap字符串值获取指定offset偏移量上的位值bitValue 当offset比字符串值的长度大或者key不存在时返回0 getbit sing 3bitcount 统计给定字符串中被设置为1的bit位的数量。一般情况下统计范围是给定的整个BitMap字符串。也可以通过指定额外的start或end参数实现仅对指定字节范围内字符串进行统计。 注意是包含start和end的且start与end的单位是字节不是bit并且从0开始计数也可以在后带上BIT选项指定是按bit单位指定统计 bitcount sing 0 1这个命令用来统计前两个字节因为0表示第一个字节1表示第二个字节 bitcount sing 0 8 BIT这里指统计的是0到8位我们给定了单位选项是BIT bitpos返回key指定的BitMap中第一个值为指定值的bit的二进制位的位置默认情况下命令会检测整个BitMap,也可以指定start参数与end参数来指定检测的范围。start 和end默认是字节为单位也可以带上个单位选项bitpos sing 1 0 0这里0 0表示就找第一个字节中值为1的位是哪位bitop 对一个或多个BitMap字符串key进行二进制位操作并把结果保存到目标key上对于操作类型可以是AND,OR,NOT,XOR中的任意一种 AND表示按位与操作 OR表示按位或操作 NOT表示非操作 XOR表示异或操作 bitop AND result rel singAND表示操作result表示结果保存的BitMaprel和sing是两个进行操作的BitMap bitop or result rel sing按位或 bitop not result resultNOT操作只接收一个进行按位操作BitMap这个操作表示把result这个BitMap中各位进行取反再写回去 bitop xor result rel sing按位异或
应用场景
由于 offset 的取值范围很大所以其一般应用于大数据量的二值性统计。
例如平台活跃用户统计二值访问或未访问、支持率统计二值支持或不支持、员工考勤统计二值上班或未上班...
注意对于数据量较小的二值性统计并不适合 BitMap可能使用 Set 更为合适。当然具体多少数据量适合使用 Set超过多少数据量适合使用 BitMap这需要根据具体场景进行具体分析
关于一个平台统计日活跃用户数量的方案
方案一使用set统计
如果使用 Set 来统计只需上线一个用户就将其用户 ID 写入 Set 集合即可最后只需统计出 Set 集合中的元素个数即可完成统计scard取集合长度即可。
方案二使用BitMap统计
先定义一个BitMap其占有的bit位至少为注册用户数量当上线一个用户则立即使用其中一个bit位置为1最后只需要使用bitcout来统计整个BitCount中为1的个数即可。
这两个方案使用哪个合适呢
这个要看数据量如果用户量大活跃用户比较大则使用BitMap更合适更能节省内存空间。
三、HyperLogLog操用
它是Redis2.8.9版本中引入的一种新的数据类型其意义是hyperlog log超级日志记录。这个数据类型可以简单理解为一个set集合集合的元素为字符串。
实际上HyperLogLog是一种基数计数概率算法通过这个算法可以利用极小的内存完成独立总数的统计其所有相关命令都是对这个set集合的操作。
它的命令都是pf开头的目的是纪念念 Philippe Flajolet 博士法国人对组合数学和基数计算算法分析的研究。
相关命令
命令说明示例pfadd把任意数量的元素添加到指定的HyperLogLog集合里如果内部存储被修改了返回1否则返回0pfadd p1 sz ls ww pfcount这个命令对于单个key时给定key的HyperLogLog集合的近似基数对于多个key时返回所有key的HyperLogLog集合的并集的近似基数如果key不存在则返回0pfcount p1 p2 p3pfmerge把多个HyperLogLog集合合并为一个HyperLogLog集合并存储到指定的key中合并后的HyperLogLog的基数接近于所有被合并集合的并集pfmerge destpf p1 p3把p1与p3合并后的集合存在destpf
应用场景
HyperLogLog 可对数据量超级庞大的日志数据做不精确的去重计数统计。
注意这个统计不是是精确的Redis官方给的误差在0.81%
四、Geospatial操作
Geospatial地理空间
Redis在3.2版本中引入的数据类型。这个类型本质上仍是一个集合只不过这个集合元素比较特殊它是由三个部分构成的数据结构。这种数据结构称为空间元素。
经度longitude。有效值是[-180,180]。正数表示东经负数表示西经纬度latitude。有效纬度是[-85.0511287885.05112878]。正的表示北纬负的表示南纬位置名称为经纬度所标注的位置命名和名称也称为Geospatial集合的空间元素名称
可以通过这个类型设置、查询某地理位置的经纬度查询某范围内的空间元素计算两个空间元素之间的距离等它的命令都是以geo开头的。
相关命令
命令说明示例geoadd把一个或多个空间元素添加到指定的空间集合中如果输入一个超出范围的经纬度时会返回一个错误geoadd location 120.58 31.30 szgeopos从指定的地址空间中返回指定元素可以指定返回多个元素的位置经纬度返回的值是一个数组geopos location sz cdgeodist 返回两个给定位置之间的距离其中unit单位必须是以下单位中的一种默认是米 m米 km千米 mi英里 ft英尺 如果两个位置之间其中一个不存在那么返回空值计算距离在极端情况下可能会产生最大0.5%的差距 geodist location cd sz KMgeohash返回一个或多个位置元素的geohash值这个geohash是一种地址编码方法它可以把二维空间经纬度数据编码为一个字符串主要用于底层应用或者调试实际作用并不大geohash location cdgeoradius 以给定的纬度为中心返回指定地址空间中包含的所有位置元素中与中心距离不超过给定半径。返回的时候还可以携带上额外的信息 withdist 返回位置元素的同时把位置元素与中心距离也一并返回。距离单位与给定的半径单位一致withcoord 把位置元素的经纬度也一并返回withhash 把位置元素的Geohash也一并返回命令中可以排序位置可以通过以下两个参数用户可以指定被返回位置元素的排序方式 ASC 根据中心的位置按从近到远的方式返回位置元素DESC 根据中心的位置按从远到近的方式返回位置元素注意默认情况下这个命令会返回所有匹配的位置元素虽然可以使用count来指定获取前n个元素但是命令内部可能会需要对所有匹配的元素进行处理对一个非常大的区域进行搜索时使用count取少量的元素也可能非常慢。 georadius location 111.6 29.046 100 KMgeoradiusbymember这个命令与georadius是相同的都是可以找出位于指定范围内的元素但是这个命令的中心点是由位置元素给定的而不是单独再输入一个中心点georadiusbymember location cd 1000 KM其它因为GEO 数据实际上被存储在有序集合sorted set中所以我们一样可以使用Sorted set中的一些命令 zrem location p1 p2删除其中指定的元素 zrange location 0 -1遍历元素 ...
应用场景
Geospatial 的意义是地理位置所以其主要应用地理位置相关的计算。如微信中的“附近”功能钉钉中的“距离打卡”...
五、发布/订阅操作
发布/订阅也就是pub/sub是一种消息通信模式。发布者也就是消息的生产者生产和发布消息到存储系统当中订阅者也就是消息的消费者从存储系统中接收和消费消息。这个存储系统可以是文件系统FS消息中间件MQ数据库管理系统DBMS也可以是Redis。整个消息发布者、订阅者与存储系统称为消息系统。
消息系统中的订阅者订阅了某类消息后只要存储系统中存在这类消息就可以不断地接收并消费这些信息。当没有这类消息后订阅者的接收、消费会阻塞当发布者把消息写入到存储系统后立即会唤醒订阅者。当存储系统放满时不同的发布者会有不同的处理方式,比如阻塞发布者的发布等待可用的存储空间或者是把多余的消息丢失。
不同的消息系统消息的发布/订阅方式也是不同的如RocketMQ、Kafka等中间件构成的消息系统中发布/订阅的消息都是以主题Topic分类的而Redis当中则是以频道Channel分类的。 相关命令
命令说明示例subscribe redis客户端通过一个subscribe命令可以同时订阅任意数量的频道在输出了订阅主题后命令处理阻塞的状态等待相关频道的消息。 返回订阅的结果报告 subscribe news sports订阅news和sportspublishredis客户端通过一条publish命令可以发布一个频道的消息返回值是接收到这个消息的订阅者数量。publish news this is a fun newspsubscribe订阅一个或多个符合给定模式的频道这里可以指定模式这个模式中只能使用*号如it* 表示的是可以匹配所有以it开头的频道如it.newsit.blog|it.tech等都可以匹配到psubscribe it.* news.*unsubscriberedis客户端退订指定的频道如果没有指定具体的频道那么客户端使用subscribe命令都会被退订这个命令会返回一个信息告知客户端所有被退订的频道。punsubscribe这个与unsubcribe类似只是说它退订的是带模式的频道。pubsub 它是一个查看订阅与发布系统状态的内省命令集它由数个不同格式的子命令组成 pubsub numpat 查询当前redis所有客户端订阅的所有频道模式的数量总和,注意它只接收psubscribe订阅的pusub numsub 返回给定频道订阅者数量。不给定任何频道则返回一个空列表。pubsub channels 列出当前所有活跃频道活跃频道指的是那些至少有一个订阅者的频道它有一个可选的参数pattern如果不指定则列出所有活跃频道如果指定了则只列出相匹配的活跃频道pattern中只能使通配符*
六、Redis事务
Redis的事务本质上是一组命令的批处理这组命令在执行过程中会被顺序地一次性全部执行完毕只要没有出现语法错误这组命令在执行期间是不会被中断的。
Redis事务特性
Redis的事务只保证数据的一致性。
不具备原子性这组命令中的某些命令执行失败不会影响到其它命令的执行没有复杂的隔离级别这组命令使用乐观锁机制实现简单的隔离性这组命令的执行结果是被写入到内存的是否持久化取决于Redis的持久化策略与事务无关
Redis事务实现
三个命令
Redis事务通过三个命令进行控制
muti开始事务
exec执行事务
discard取消事务
基本使用
在multi执行后就会开启事务在其后每写的一个命令都会放到队列当中当执行exec的时候才会一个一个执行队列中的命令。
如果我们事务开启了并且命令也放到队列中了但是我们此时执行了discard则会取消所有命令
exec与discard两者是互斥的。最后要么执行exec要么执行discard 以上的两个命令set age 20 与 incr age是一组在执行过程中不会被中断
如果我们不执行exec而是执行discard则会取消队列中的命令执行 Redis事务异常处理
语法错误
当事务中的命令出现语法错误时整个事务在exec执行时会被取消。 因为在队列中的命令存在错误的语法这个时候exec会取消执行会事务中的命令
执行过程中异常
如果事务中的命令没有语法错误但是在执行过程中出现异常这个异常不会影响到其它命令的执行 这里可以看到事务中的命令都是没有语法错误的但是在执行的时候第二个命令出现的执行异常这个时候第一个命令已经执行成功了第二个不会执行。此时执行命令get score会返回A是因为这个命令执行成功了
Redis事务隔离机制
为什么要隔离呢
在并发的场景下可能会出现多个客户端对同一数据进行修改的情况。
示例如下
假设我们有一个账户里面有金额100元A客户端要扣减80元B客户端要扣减50元。首先他们会去看是否够扣减两个并发执行查看到的金额是100这对于两者来说都是够减的于似乎两者都进行扣减金额的动作这时候时候会出现账户“超扣”的情况。 为了解决这种情况Redis事务通过乐观锁机制实现了多线程下的执行隔离。
隔离实现
Redis通过watch命令再配合事务实现了多线程下的执行隔离
我们先watch 一个key再使用multi开事务 实际上我们watch account的时候我们不仅看到account的值是100而且可以看到有一个版本是1当另一个客户端对这个值进行修改后account中的版本号已经变为了2此时在执行命令时会发现watch中的account的版本是1小于实际数据的版本2表示现在的版本已经过时了。执行时就会取消掉。
版本号要大于等于原数据的版本号时才能执行否则不能执行。
七、benchmark测试工具
在Redis安装安成后会自动安装一个redis-benchmark测试工具它是一个压力测试工具用于测试Redis的性能。
Redis安装完成后这个具体在/usr/local/bin/
通过redis-benchmark --help命令可以查看到其用法。
常用的一些命令选项
-c 表示并行连接的数量默认是50-n 表示请求的总数量默认值是100000-h 表示连接的Redis的ip如查是本机可以省略-p 表示Redis的端口号如果是6379则可以省略-d 表示数据的大小get/set命令时其操作的value的数据长度单位字节默认值是3这个测试其它命令的时候没有用-k 表示这些并发连接的状态如果是1表示一直处于连接状态keep alive0表示中间会出现断连然后重连接的情况reconnect默认值是1
基本测试
命令redis-benchmark -h 127.0.0.1 -p 6379 -c 100 -n 200000
这个测试的命令表示使用100个客户端并发连接总共发起200000个请求
测试的报告如下每一个命令都是一样的报告结构下面是set命令测试报告结果 上在这个测试会把所有命令都测试一遍
指定命令测试
命令 redis-benchmark -t set,lpush,sadd -c 100 -n 100000 -q
上面这个命令中-n如果是100000表示是默认的请求可以省略不写
其它的选项说明
-q 表示测试结果只给出总述性报告-t 指定要测试的命令多个命令之间使用逗号进行分隔不能有空格 通过benchmark的测试我们看到redis的性能非常高其中还是得益于它对五种值类型全部进行了设计经过设计后变成了适合于它自己的结构。
