在这个商业世界中,如果你占领了概念高地就意味着有种先天的优势。就好比你给自己起了一个名字叫Java。
最近几年圈里流行“stream”这个词,只要沾上这个词,就感觉不一样了。流动起来如丝般爽滑。
java api 加入了stream。让静止的水强行流动。
Flink号称自己是在一条Data Stream的河流上做计算。
Kafka直接说自己是分布式流平台。
Ignite说自己也适合做stream:
Spark直接有个模块:Spark Stream:
看了下,只有ActiveMQ还在说自己只是一个message queue。可能因为名字上带了MQ了吧:
于是,Redis也耐不住寂寞了,觉得stream这个词应该引入。看了上面的各种stream,你大概知道Redis是干什么的了吧,没错,就和kafka做的事情很像。
此时,我其实可以结束了。
但作为一篇成熟的文章还是要多写一点。凑不够三百字不让标原创。
一个新的数据类型
用Redis官方的说法,stream是redis众多数据类型的其中一个,这是一个新的数据类型。把stream归为数据类型的一种,这有利于Redis概念上的一脉相承。
秩序要井然,否则显得乱糟糟。这一点也在redis官方介绍中可见端倪,其实连他们自己都不好意思把stream作为一个数据类型:
所以,此时stream充其量作为一个抽象的数据类型,划归为抽象,这样既和之前的概念对齐,也确保了描述的精确。
一个append only数据结构
官方说他们这个stream是对日志数据结构(log data structure)的高度抽象。stream首先是一个append only日志数据结构,但实现更加的复杂,要比一般的日志文件更强大。
一个既可以检索又可以消费MQ
你是不是嗅出了一丝Kafka的气息。kafka消费的时候就是在移动offset,数据依然在。你可以用同样的逻辑来想Redis的stream。既然数据一直在是不是就可以检索了,是的。
消费支持单一和consumer group
是不是又有kafka的既视感,没错,redis stream的单一消费和consumer group消费的概念都和kafka是一样的。consumer group可以协调一组消费者来消费。
命令全都以X开头
XADD、XRANGE 、XREVRANGE、XLEN、XREAD
添加
XADD
查询
XRANGE、XREVRANGE
长度
XLEN
监听
XREAD
组监听
XGROUP、XREADGROUP、XACK
更多具体的命令手册请移步https://redis.io/topics/streams-intro,或直接点击“阅读原文”。或者移步阿飞兄的公号链接《Streams:深入剖析Redis5.0全新数据结构》https://mp.weixin.qq.com/s/GpG3t_O_SxLGNklVnoOiYQ
一个天生骄傲的MQ
我不小心在redislab上找到了两张图,拿来供大家赏玩:
看起来简直要比传统的MQ吊炸天,不过人们发表了如下观点:
希望Redis Streams真的如表格中那么叼,这样我们也就放心了。
本文分享自 ImportSource 微信公众号,前往查看
如有侵权,请联系 cloudcommunity@tencent.com 删除。
本文参与 腾讯云自媒体同步曝光计划 ,欢迎热爱写作的你一起参与!