系列Lambda 函数式实战精通营 · 作者鱼宵配套课程仓库https://gitee.com/j67mk2/lambda-journey 第 10 课先看一个每天都在发生的现场一个订单审核结算系统需求方说审核规则要经常加、折扣要经常调。你看看现在的代码// 老代码审核逻辑写死在方法里if(order.amount()0){return金额非法;}if(order.city()null||order.city().isBlank()){return城市为空;}if(order.amount()50000){return超风控上限;}doublepriceorder.amount();if(VIP.equals(order.level())){priceprice*0.8;}// 折扣也写死加一条规则要改三个地方if 链、报错文案、可能还有调用方。需求方下周二又要加VIP 订单最多打八折和满 1000 减 100 的促销你看着这一坨 if-else头皮发麻。这是 Lambda 系列的收官课。用前面 9 课学的所有零件把这一坨改成能跑、能讲、能面试的小项目规则引擎 报表管道 批量任务三件套一次搭完外加 STAR 面试话术。学完本文你能回答怎么把一堆 if-else 审核规则改造成可插拔的规则引擎一条清洗→聚合→出报表的管道怎么用 Function 链搭出来批量任务怎么做到一条坏数据不拖垮整批这个 lambda 项目你怎么讲给面试官听一句话原理把会变的全部抽成 lambda引擎只管按规矩跑先摆结论规则引擎审核规则抽成ListPredicateOrder规则链引擎只负责逐条过。加规则 往表里加一条 lambda不改引擎策略注入折扣这种会变的算法抽成FunctionOrder, Double运行时注入。换策略 换 lambda管道Function.andThen把清洗 → 聚合 → 拼报表三段串成一条链每段只管自己那一步批量任务Supplier供数据Function加工Consumer消费各管一段单条 try/catch 兜底跑完吐统计。类比出入境的海关柜台。检查员引擎只会一句话“你的材料齐不齐”具体查哪几项规则是单子规则表上印着的。加一个检查项换张单子就行检查员不用重新培训。完整可运行代码三件套骨架完整工程在课程 lesson-10工程有 4 个文件Order是数据 record核心就这两个类加一段组装RuleEngine.java —— 规则链 策略注入packagecom.lambda.lesson10;importjava.util.ArrayList;importjava.util.List;importjava.util.function.Function;importjava.util.function.Predicate;publicclassRuleEngine{/** 规则链每一条都是一个 PredicateOrder默认全过才放行 */privatefinalListPredicateOrderrulesnewArrayList();/** 折扣策略默认不打折系数 1.0由调用方注入 */privateFunctionOrder,DoublediscountPolicyorder-1.0;/** 挂一条审核规则进来返回自己方便链式调用 */publicRuleEngineaddRule(PredicateOrderrule){rules.add(rule);returnthis;}/** 注入折扣策略策略注入 */publicRuleEnginesetDiscountPolicy(FunctionOrder,Doublepolicy){this.discountPolicypolicy;returnthis;}/** 审核一条订单过全部规则全 true 才放行。allMatch 短路全真——责任链模式 */publicbooleanapprove(Orderorder){returnrules.stream().allMatch(rule-rule.test(order));}/** 结算原价 × 折扣系数。策略不同同一个订单结出不同的价 */publicdoublesettle(Orderorder){returnorder.amount()*discountPolicy.apply(order);}}BatchJobRunner.java —— 批量任务编排 单条兜底packagecom.lambda.lesson10;importjava.util.List;importjava.util.function.Consumer;importjava.util.function.Function;importjava.util.function.Supplier;publicclassBatchJobRunner{/** 一次批量跑完的统计结果可观测 可验证直接打印或断言都行 */publicrecordStats(inttotal,intsuccess,intfailed){OverridepublicStringtoString(){return共 total 条成功 success失败 failed;}}/** * 编排批量任务供数据 → 逐条加工 → 发下游。 * param source 数据从哪来Supplier * param worker 每条怎么加工Function * param sink 加工完发去哪Consumer */publicT,RStatsrun(SupplierListTsource,FunctionT,Rworker,ConsumerRsink){ListTbatchsource.get();intsuccess0;for(Titem:batch){try{Rresultworker.apply(item);// 加工sink.accept(result);// 发下游success;}catch(Exceptione){// 兜底单条失败只记录继续跑下一条——绝不一炸全停System.out.println( [兜底] 跳过坏数据item原因e.getMessage());}}returnnewStats(batch.size(),success,batch.size()-success);}}Main.java 组装段 —— 规则链 报表管道 批量任务一次跑完// 1. 规则引擎三条规则 一个折扣策略全部 lambda 注入RuleEngineenginenewRuleEngine().addRule(o-o.amount()0)// 规则一金额必须为正.addRule(o-!o.city().isBlank())// 规则二城市不能为空.addRule(o-o.amount()50000)// 规则三单笔风控上限 5 万.setDiscountPolicy(o-VIP.equals(o.level())?0.8:1.0);// VIP 八折// 2. 报表管道三段 Function用 andThen 串成一条链FunctionListOrder,ListOrdercleanlist-list.stream().filter(o-engine.approve(o)).collect(Collectors.toList());FunctionListOrder,MapString,Doubleaggregatelist-list.stream().collect(Collectors.groupingBy(Order::city,Collectors.summingDouble(Order::amount)));FunctionMapString,Double,StringtoReportmap-map.entrySet().stream().map(e-e.getKey() 合计 String.format(%.1f 元,e.getValue())).collect(Collectors.joining(,城市销售报表,。));Stringreportclean.andThen(aggregate).andThen(toReport).apply(orders);System.out.println(report);// 3. 批量任务三处会变的全部 lambda 注入坏数据被兜底接住BatchJobRunner.Statsstatsrunner.run(()-orders,// Supplier供数据o-{// Function加工审核不过就抛异常if(!engine.approve(o)){thrownewIllegalStateException(审核不过);}returnengine.settle(o);},price-System.out.println( 下发结算价price 元)// Consumer发下游打印);System.out.println(批量任务结果stats);真实运行输出本机 JDK 24.0.1 实测 1. 规则引擎审核 结算 A001审核通过结算价 1039.2 元 A002审核通过结算价 45.5 元 A003审核通过结算价 899.0 元 A004审核通过结算价 2079.2000000000003 元 A005审核通过结算价 666.0 元 A006审核不通过金额-50.0 2. 报表管道一条链出城市销售报表 城市销售报表上海 合计 3498.0 元杭州 合计 2010.5 元。 3. Optional 组合最大单是谁 最大单是 A0042599.0 元 4. 批量任务逐条结算并下发 下发结算价1039.2 元 下发结算价45.5 元 下发结算价899.0 元 下发结算价2079.2000000000003 元 下发结算价666.0 元 [兜底] 跳过坏数据A006(杭州/数码/-50.0元/VIP)原因审核不过 批量任务结果共 6 条成功 5失败 1 有效订单金额统计共 5 笔最大 2599.0 元平均 1101.7 元这段代码讲什么规则引擎规则是数据不是代码engine.approve(order)→ rules.stream().allMatch(rule-rule.test(order))审核规则全部存在ListPredicateOrder里——每条规则就是一个 lambda引擎本体approve/settle一行业务都不写死只负责逐条过加规则 一行addRule(...)不加新方法、不改老方法——这就是可插拔allMatch短路全真任何一条不过立刻返回 false前面的规则白跑不了——责任链模式。策略注入折扣是电池不是机身.setDiscountPolicy(o-VIP.equals(o.level())?0.8:1.0)折扣算法抽成FunctionOrder, Double注入引擎明天要改满 1000 减 100换一个 lambda 就行settle一行不动——策略模式加规则不改引擎、换策略不改引擎规则的增删和策略的更换都是数据层面的操作代码层面零改动。报表管道andThen 三段串成一条链clean.andThen(aggregate).andThen(toReport).apply(orders)三段Function每段只管一步清洗只留审核通过的→ 聚合按城市合计金额→ 拼成人话报表上一段的输出类型 下一段的输入类型ListOrder→MapString,Double→String类型不对编译直接报错编译器帮你对齐Collectors.joining(, 城市销售报表, 。)把字符串流拼成一句话前缀后缀分隔符一次配好手算验证上海 899 2599 3498.0 ✓杭州 1299 45.5 666 2010.5 ✓A006 被清洗段滤掉——可验证。批量任务一条坏数据不拖垮整批try{Rresultworker.apply(item);sink.accept(result);success;}catch(Exceptione){System.out.println( [兜底] 跳过坏数据item原因e.getMessage());}三处会变的全部 lambda 注入() - orders供数、加工 lambda、price - ...消费try 放在每条的循环里面——一条炸了只记一笔继续下一条绝不一炸全停这是最常见的批量踩坑一个 try 包住整批坏数据一来全部白跑跑完吐Stats总数/成功/失败——可观测调用方可以直接断言这个返回值——可验证。那个2079.2000000000003的尾巴1299 × 0.8 打印成2079.2000000000003——double 二进制浮点表示十进制小数的经典尾巴企业里算账必须用BigDecimal别用 double 直接算钱demo 里用 double 只是为了少写代码。 进阶深挖选学规则引擎的工业版真实项目会把规则存数据库谁都能改而不是写死在代码里——本课的ListPredicate就是它的内存版骨架。进阶方向Drools 规则引擎、或自己搞个MapString, Predicate热加载。并行化批量任务本课的 runner 是串行的企业里换parallelStream()或自定义线程池就能并行——但记得第 9 课的坑别在 lambda 里碰共享状态。设计模式综合套娃规则链 责任链模式策略注入 策略模式编排器 模板方法思想。本课就是把前 9 课每个模式用 lambda 串成一个真项目。面试怎么讲这个项目STAR 话术问讲一个你用函数式做的项目。S情境“我做过一个订单审核结算的小系统原始版本是一堆 if-else 审核 写死的折扣计算加一个规则要改三个地方。”T任务“我要把它重构成规则可插拔、批量任务带兜底的版本还要能讲清楚设计。”A行动“审核规则抽成ListPredicateOrder责任链折扣抽成Function策略注入报表用Function.andThen串成清洗→聚合→输出管道批量任务用 Supplier/Function/Consumer 编排单条 try-catch 兜底跑完出统计。”R结果“加新规则只需要一行addRule(...)批量 6 条数据里有 1 条坏数据系统跳过它继续跑完最后打印出成功 5 失败 1——可观测也有了。”追问应对问为什么不用框架→ “骨架自己写过一遍工业级Drools才需要上框架”问并行吗→ “串行够用真要并行记得第 9 课的共享状态坑”问精度呢→ “算账要 BigDecimaldemo 里用 double 只是为了少写代码”。总结表坑 → 原因 → 解法坑原因解法用 double 算钱double 是二进制浮点十进制小数存不准钱用BigDecimal或至少String.format(%.2f, x)展示一个 try 包住整批一条坏数据抛异常整批中断try 放在每条的循环里面本课 runner 就是这么写的管道段之间类型对不上andThen 要求上一段输出 下一段输入一段一段写让编译器帮你对齐规则顺序写反规则链短路失败报错信息对不上业务校验类规则放前面风控类规则放后面报错文案写清楚挑战题答案都在课程源码里⭐ 给规则引擎加一条新规则比如订单金额不能超过客户等级对应的额度重新编译运行确认多一条审核结果。⭐⭐ 换折扣策略把VIP 八折改成满 1000 减 100提示setDiscountPolicy里换成新的 lambda注意返回的是折后价而不是折扣系数。⭐⭐ 加一条报表段在报表管道里再加一段按品类分组的合计用 andThen 接在现有管道后面。⭐⭐⭐ 挑战给BatchJobRunner加一个失败重试 2 次的能力提示worker 外面套一层重试循环Stats 里再多记一个 retry 字段。源码在哪怎么跑完整工程在lambda-journey 课程第 10 课4 个文件Order/RuleEngine/BatchJobRunner/Maingitclone https://gitee.com/j67mk2/lambda-journey.gitcdlambda-journey/lesson-10 mvn-qcleaninstall-DskipTestsjava-cptarget/classes com.lambda.lesson10.Main第 10 课三件套全解 企业级七要素自检表 STAR 话术 课后作业 4 道结课寄语10 课走完你手里已经有一条完整的能力链L1 世界观 → L2 四大接口 → L3 方法引用 → L4 闭包 → L5 异常 → L6 重构 → L7/L8 Stream 组合 → L9 性能 → L10 全家桶。lambda 不是省几行代码的语法糖它是一套把行为当数据传的思维方式——规则、策略、管道全都是这么来的。后续学习路线① 把这个项目搬到 Spring Boot 里规则从配置文件读② 学 CompletableFuture 把批量任务改成异步并行③ 看《Java 8 实战》把 Stream/Collector 源码过一遍④ 回头把老项目也用 lambda 重构一遍——重构老代码是 lambda 功力涨得最快的方式。这是Lambda 函数式实战精通营系列的最后一篇。10 篇全部带完整可运行代码 本机实测输出 挑战题源码都在 https://gitee.com/j67mk2/lambda-journey 。看完想动手的去 lesson-10 跑一遍想深挖的评论区聊聊你的订单审核系统是怎么设计的。
