Stream
已收录文章：6篇
-
数据库 · Redis | 2天前 | Redis · 消息队列 · Stream · 故障恢复 · 消费者组 · redis streams 消息重试 消费者组 XAUTOCLAIM 积压消息 PELRedis Streams 消费者组出现积压时，XAUTOCLAIM 可以把超过最小空闲时间的 pending 消息交给健康消费者继续处理。本文用故障接管场景说明 start 游标、COUNT、JUSTID、重试次数和删除幽灵消息的验收边界。148 收藏
-
文章 · java教程 | 4天前 | Stream · Java教程 · 性能边界 · mapMulti · flatMap · Java mapMulti Stream flatMap Java Stream 条件展开 Java 16Java Stream 的 mapMulti 适合把一个元素展开为零个或少量结果，尤其适用于带条件分支的解析和提取。本文用订单标签解析示例说明它与 flatMap 的选择、泛型推断、Consumer 生命周期和验收边界。250 收藏
-
用一个可运行的小实验演示 Java Stream 如何把订单列表过滤、分组、金额求和并输出客户消费汇总，补充双维度统计和常见坑检查。355 收藏
-
本文用订单列表统计场景，梳理 Java Stream 的完整处理流程：字段口径、过滤条件、分组汇总、结果校验和常见误区，帮助把零散链式调用整理成可复用的后端数据处理方案。455 收藏
-
文章 · java教程 | 2个月前 | Java · Stream · 集合统计 · 分组聚合 · Collectors · java Stream Collectors groupingBy counting summarizingInt本文用订单列表示例讲清 Java Stream 分组统计：按状态分组计数、按用户汇总金额、用 summarizingInt 一次拿到数量、总和、最大值和平均值。478 收藏
-
数据库 · Redis | 2个月前 | Redis · 消息队列 · Stream · 消费组 · redis 消息队列 Redis Stream 消费组 XREADGROUP XACK XPENDING XAUTOCLAIM用订单异步处理场景讲清楚 Redis Stream 的实用队列模型：生产者写入消息，消费组分配任务，Worker 处理成功后 ACK，失败或超时的消息进入待确认列表，再通过 XPENDING 和 XAUTOCLAIM 做重投。187 收藏