Redis怎样分析流队列的消费情况_通过XINFO指令查看Streams统计信息

浅枫小哥_2422

浅枫小哥_2422

2026-04-08

846人浏览

原创

需结合xinfo consumers与xinfo groups判断streams实时消费延迟:关注pel-count、pending数、idle值及last-delivered-id与流尾id的字典序比较,避免误判离线或假死状态。

redis怎样分析流队列的消费情况_通过xinfo指令查看streams统计信息

怎么看 Streams 的实时消费延迟

用 XINFO CONSUMERS 和 XINFO GROUPS 配合看,不是只查一个就能判断延迟。消费者组里 pending 数量高、idle 值大,说明消息卡住了;但得先确认是不是真卡——比如消费者进程挂了,还是只是处理慢。

  • XINFO CONSUMERS <stream><group></group></stream> 显示每个消费者当前 pending 的消息数和最后空闲毫秒数(idle)
  • XINFO GROUPS <stream></stream> 看整个组的 pending 总量、last-delivered-id(最新发给消费者的 ID),对比流尾部 ID 可估算积压量
  • 注意:idle 是从上一次 XCLAIM 或成功 XREADGROUP 开始算的,不是从消息入队开始算

为什么 XINFO STREAM 返回的 length 和 card 不一致

因为 length 是当前未被任何消费者组标记为「已交付」的消息数量,而 STREAM LEN 或 XRANGE ... COUNT 查的是物理存在的条目数——如果启用了 MAXLEN 或 MINID 自动淘汰,历史消息可能已被删,但消费者组还记着旧 ID,导致 XINFO STREAM 的 length 小于实际插入过的总数。

  • XINFO STREAM <key></key> 中的 length 是「当前可读」的消息数,受 MAXLEN 影响
  • card 字段不存在于 XINFO STREAM 输出中——别和集合命令混淆;想统计总写入量,得靠监控或自己记 counter
  • 流被 XTRIM 后,first-entry 会变,但已分配给消费者组的 pending 消息若未确认,仍算在组的 pending 里,哪怕对应 entry 已被 trim 掉(这时 XCLAIM 会失败)

消费者不在线时,XINFO 能看到哪些残留信息

只要消费者组存在,就算所有消费者都断连了,XINFO CONSUMERS 仍会返回该消费者记录,但 idle 会持续增长,pending 不清零。这时候容易误判“还在工作”,其实只是没心跳也没清理。

  • Redis 不自动删除离线消费者,必须手动 XGROUP DELCONSUMER
  • XINFO GROUPS 的 pel-count(Pending Entries List)才是真实积压数,它包含所有已分发但未确认的消息,不管消费者是否在线
  • 如果消费者用随机名(如 PID)反复重连,会不断堆积新 consumer 条目,XINFO CONSUMERS 结果越来越长,查起来变慢

用 XINFO 查消费情况时最常踩的三个坑

一是把 last-delivered-id 当成最新消息 ID——它只是组内最后一次分发的 ID,流尾部可能已有更新的;二是忽略 entries-added 和 recorded-first-entry 的差值,这个差值才反映实际积压范围;三是以为 pending 为 0 就代表没延迟,其实可能消费者根本没启动或没连上组。

  • 比对延迟,正确姿势是:XRANGE <stream> + - COUNT 1</stream> 拿到最新 ID,再和 last-delivered-id 做字典序比较
  • entries-added 是流创建以来总写入数,length 是当前剩余数,二者差值 ≈ 被 trim 或被消费掉的数量
  • 如果 XINFO CONSUMERS 返回空数组,不代表没消费者——可能是名字输错,也可能是组刚创建还没分发过消息

流消费状态不是静态快照,是多个视角拼出来的动态图景。少看一个字段,就容易把「积压」当成「正常」,或者把「假死」当成「忙碌」。

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
counta和count的区别
counta和count的区别

Count函数用于计算指定范围内数字的个数,而CountA函数用于计算指定范围内非空单元格的个数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2023.11.20

3308

5

堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

2023.07.18

6067

5

堆和栈区别
堆和栈区别

堆(Heap)和栈(Stack)是计算机中两种常见的内存分配机制。它们在内存管理的方式、分配方式以及使用场景上有很大的区别。本文将详细介绍堆和栈的特点、区别以及各自的使用场景。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

2023.08.10

2568

6

length函数用法
length函数用法

length函数用于返回指定字符串的字符数或字节数。可以用于计算字符串的长度,以便在查询和处理字符串数据时进行操作和判断。 需要注意的是length函数计算的是字符串的字符数,而不是字节数。对于多字节字符集,一个字符可能由多个字节组成。因此,length函数在计算字符串长度时会将多字节字符作为一个字符来计算。更多关于length函数的用法,大家可以阅读本专题下面的文章。

2023.09.19

1887

6

常用的数据库软件
常用的数据库软件

常用的数据库软件有MySQL、Oracle、SQL Server、PostgreSQL、MongoDB、Redis、Cassandra、Hadoop、Spark和Amazon DynamoDB。更多关于数据库软件的内容详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.02

4609

19

内存数据库有哪些
内存数据库有哪些

内存数据库有Redis、Memcached、Apache Ignite、VoltDB、TimesTen、H2 Database、Aerospike、Oracle TimesTen In-Memory Database、SAP HANA和ache Cassandra。更多关于内存数据库相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.14

4175

11

mongodb和redis哪个读取速度快
mongodb和redis哪个读取速度快

redis 的读取速度比 mongodb 更快。原因包括:1. redis 使用简单的键值存储,而 mongodb 存储 json 格式的数据,需要解析和反序列化。2. redis 使用哈希表快速查找数据,而 mongodb 使用 b-tree 索引。因此,redis 在需要高性能读取操作的应用程序中是一个更好的选择。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.02

7832

6

redis怎么做缓存服务器
redis怎么做缓存服务器

redis 作为缓存服务器的答案:redis 是一款开源、高性能、分布式的键值存储,可作为缓存服务器使用。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

643

6

redis怎么解决数据一致性
redis怎么解决数据一致性

redis 提供了两种一致性模型,以维护副本数据一致性:强一致性 (sync) 确保写操作仅在复制到所有从节点后才完成;最终一致性 (async) 则在主节点上写操作后认为已完成,牺牲一致性换取性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

756

6

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
热门推荐
/
最新课程
phpStudy极速入门视频教程
phpStudy极速入门视频教程

共6课时 | 54.7万人学习

独孤九贱(4)_PHP视频教程
独孤九贱(4)_PHP视频教程

共89课时 | 133.9万人学习