Stream
已收录文章：12篇
-
本文用订单列表示例讲清 Java Stream 分组统计：按状态分组计数、按用户汇总金额、用 summarizingInt 一次拿到数量、总和、最大值和平均值。478 收藏
-
文章 · java教程 | 3星期前 | Java · 正则表达式 · 性能 · Stream · predicate Java教程 Java Pattern.asMatchPredicate Java正则 Stream过滤Pattern.asMatchPredicate 能把已编译正则直接变成 Predicate，适合复用在 Stream.filter 和输入校验中。本文拆开 matches 的完整匹配语义、find 的差异与重复编译成本。464 收藏
-
本文用订单列表统计场景，梳理 Java Stream 的完整处理流程：字段口径、过滤条件、分组汇总、结果校验和常见误区，帮助把零散链式调用整理成可复用的后端数据处理方案。455 收藏
-
用一个可运行的小实验演示 Java Stream 如何把订单列表过滤、分组、金额求和并输出客户消费汇总，补充双维度统计和常见坑检查。355 收藏
-
在 Redis Streams 下游，ACK 只是消费确认，不是消息删除；pending 列表、last-delivered-id 与重试窗口一起决定消息是否真正安全出队。本文用 redis-cli 的最小链路验证常见误区和可上线检查点。339 收藏
-
目前，我开发 HTTP 服务， 用的是 beego框架， 方便了很多。 但是， 有时候，还是会遇到一些 特殊的场景。 比如： 过滤日志。 这应该是一种典型的stream，同时数据量也适中， 不会有人，为了这289 收藏
-
文章 · java教程 | 3星期前 | 排序 · 调试 · 集合 · Stream · Java教程 · java Stream linkedhashmap Collectors.groupingBy 分组顺序Java Stream 用 groupingBy 分组时，结果默认通常是 HashMap，不能把遍历顺序当成输入顺序。本文从订单状态统计场景出发，拆解 LinkedHashMap 作为 mapFactory 的写法、排序边界和测试验收方法。275 收藏
-
Java Stream 做分组统计时，先收集再多次遍历容易放大内存和 CPU 成本。本文用订单状态统计说明 groupingBy、groupingBy+下游收集器与并行流的边界，并给出可复查的基准与选择方法。260 收藏
-
Java Stream 的 mapMulti 适合把一个元素展开为零个或少量结果，尤其适用于带条件分支的解析和提取。本文用订单标签解析示例说明它与 flatMap 的选择、泛型推断、Consumer 生命周期和验收边界。250 收藏
-
Redis Stream 长期运行后，按消息 ID 清理历史记录比按条数裁剪更容易贴合时间窗口。本文用 XTRIM MINID 对比精确裁剪与近似裁剪，说明 LIMIT、消费组 PEL 和回滚验收的实际边界。241 收藏
-
数据库 · Redis | 3个月前 | Redis · 消息队列 · Stream · redis 消息队列 Redis Stream 消费组 XREADGROUP XACK XPENDING XAUTOCLAIM用订单异步处理场景讲清楚 Redis Stream 的实用队列模型：生产者写入消息，消费组分配任务，Worker 处理成功后 ACK，失败或超时的消息进入待确认列表，再通过 XPENDING 和 XAUTOCLAIM 做重投。187 收藏
-
Redis Streams 消费者组出现积压时，XAUTOCLAIM 可以把超过最小空闲时间的 pending 消息交给健康消费者继续处理。本文用故障接管场景说明 start 游标、COUNT、JUSTID、重试次数和删除幽灵消息的验收边界。148 收藏