7、stream消息队列

简介: 7、stream消息队列
XADD geekhour * course redis
"1686495710450-0"
XADD geekhour * course git
"1686495727844-0"
XADD geekhour * course docker
"1686495730661-0"
XLEN geek
(integer) 3
XRANGE geekhour - + 
1) 1) "1686495710450-0"
  2)  1)"course"
    2) "redis"
2) 1) "1686495727844-0"
  2)  1)"course"
    2) "git"
3) 1)"1686495730661-0"
  2)  1) "course"
    2)"docker"
XDEL geekhour 1686495710450-0
XTRIM geekhour MAXLEN 0
(integer) 2
XREAD COUNT 2 BLOCK 1000 STREAMS geekhour 0
XREAD COUNT 2 BLOCK 1000 STREAMS geekhour 1

消费者组

sql

复制代码

XGROUP CREATE geekhour group1 0
"oK"
XINFO GROUPs geekhour
1) 1) "name"
   2) "group1" 
   3) "consumers" 
   4) "0"
   5) "pending " 
   6) "0"
   7) "last-delivered-id"
   8) "0-0"
   9) "entries-read"
   10) "null"
   11) "lag"
   12) "4"
XGROUP CREATECONSUMER geekhour group1 consumer1
(integer) 1
XGROUP CREATECONSUMER geekhour group1 consumer2
(integer) 1
XGROUP CREATECONSUMER geekhour group1 consumer3
(integer) 1
XINFO GROUPS geekhour


相关文章
|
2月前
|
消息中间件 存储 NoSQL
深入Redis消息队列:Pub/Sub和Stream的对决【redis第六部分】
深入Redis消息队列:Pub/Sub和Stream的对决【redis第六部分】
110 0
|
2月前
|
消息中间件 NoSQL Java
别再用 Redis List 实现消息队列了,Stream 专为队列而生
别再用 Redis List 实现消息队列了,Stream 专为队列而生
107 0
|
17天前
|
消息中间件 负载均衡 NoSQL
Redis系列学习文章分享---第七篇(Redis快速入门之消息队列--List实现消息队列 Pubsub实现消息队列 stream的单消费模式 stream的消费者组模式 基于stream消息队列)
Redis系列学习文章分享---第七篇(Redis快速入门之消息队列--List实现消息队列 Pubsub实现消息队列 stream的单消费模式 stream的消费者组模式 基于stream消息队列)
17 0
|
消息中间件 NoSQL Java
【Redis】浅尝Redis Stream做消息队列
SpringBoot整合Redis5.0新特性Redis Stream
1254 0
【Redis】浅尝Redis Stream做消息队列
|
2月前
|
消息中间件 缓存 NoSQL
Redis stream 用做消息队列完美吗
Redis Stream 是 Redis 5.0 版本中引入的一种新的数据结构,它用于实现简单但功能强大的消息传递模式。 这篇文章,我们聊聊 Redis Stream 基本用法 ,以及如何在 SpringBoot 项目中应用 Redis Stream 。
Redis stream 用做消息队列完美吗
|
2月前
|
消息中间件 存储 中间件
【SpringCloud Stream消息驱动、设计思想以及整合rabbitmq消息队列案例--学习笔记】
【SpringCloud Stream消息驱动、设计思想以及整合rabbitmq消息队列案例--学习笔记】
112 0
|
2月前
|
消息中间件 NoSQL 算法
Redis进阶-Stream多播的可持久化的消息队列
Redis进阶-Stream多播的可持久化的消息队列
124 1
|
消息中间件 存储 NoSQL
深入学习Redis 消息队列 Stream
Stream 是 Redis 5.0 版本中新增的一种数据结构,它是一个高性能、持久化的消息队列,可以用于实现消息的发布和订阅。Stream 可以看作是一个有序的消息队列,每个消息都有一个唯一的 ID,可以根据 ID 进行消息的查找、删除和确认。在 Stream 中,消息以键值对的形式存储,可以存储任意类型的数据。Stream 还支持多个消费者组,每个消费者组可以独立消费消息,避免消息重复消费。Stream 的引入使得 Redis 在消息队列领域更具竞争力,同时也为开发者提供了一种高效、可靠的消息处理方式
528 0
深入学习Redis 消息队列 Stream
|
消息中间件 传感器 NoSQL
redis灵魂拷问:如何使用stream实现消息队列
redis灵魂拷问:如何使用stream实现消息队列
701 0
redis灵魂拷问:如何使用stream实现消息队列
|
15天前
|
消息中间件 测试技术 RocketMQ
消息队列 MQ产品使用合集之在异步发送消息函数sendMessage()中出现了错误,错误代码为-3,该如何解决
消息队列(MQ)是一种用于异步通信和解耦的应用程序间消息传递的服务,广泛应用于分布式系统中。针对不同的MQ产品,如阿里云的RocketMQ、RabbitMQ等,它们在实现上述场景时可能会有不同的特性和优势,比如RocketMQ强调高吞吐量、低延迟和高可用性,适合大规模分布式系统;而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集,这些场景涵盖了多种行业和业务需求。

热门文章

最新文章