适用人群Java 开发者想了解函数式编程在实际项目中的应用前置知识了解 Java 8 Lambda 表达式基础一、先来看一个实际场景场景同步 10000 条债券数据到接口平台传统做法Java// 一次性查询所有数据ListBondQuotaQueryBO allData bondQuotaQueryService.queryAll(queryBO);// 逐条处理for (BondQuotaQueryBO bo : allData) { syncSingleQuota(bo, tenantId);}问题❌ 10000 条数据一次性加载到内存可能 OOM内存溢出❌ 如果数据有 10 万条呢❌ 查询超时怎么办优雅做法Java// 分页查询逐页处理PageQueryUtil.queryAndProcess( pageInfo - bondQuotaQueryService. queryBondQuotaQueryByPage(queryBO, pageInfo), rows - { for (BondQuotaQueryBO bo : rows) { syncSingleQuota(bo, tenantId); } }, 100 // 每页 100 条);好处✅ 每次只加载 100 条到内存✅ 自动处理所有分页✅ 代码简洁逻辑清晰二、PageQueryUtil 的核心设计1. 方法签名记住这个公式Javapublic static T long queryAndProcess( FunctionPageInfo, PageResultT queryFunction, // ← 怎么查 ConsumerListT pageHandler, // ← 怎么处理 int pageSize // ← 每页多少条)通俗理解参数 1你告诉它怎么查数据给个查询函数参数 2你告诉它查到数据后怎么处理给个处理函数参数 3每页查多少条返回值一共处理了多少条数据三、实战演练完整代码拆解步骤 1准备查询条件JavaBondQuotaQueryBO queryBO new BondQuotaQueryBO();queryBO.setLockStatus(2); // 已审批queryBO.setNotEndType(1); // 未终止步骤 2调用 queryAndProcessJavalong total PageQueryUtil.queryAndProcess( // 参数 1查询函数怎么查 pageInfo - bondQuotaQueryService. queryBondQuotaQueryByPage(queryBO, pageInfo), // 参数 2处理函数怎么处理 rows - { for (BondQuotaQueryBO bo : rows) { syncSingleQuota(bo, tenantId); } }, // 参数 3每页条数 PAGE_SIZE // 100);步骤 3理解 Lambda 表达式参数 1 详解JavapageInfo - bondQuotaQueryService.queryBondQuotaQueryByPage(queryBO, pageInfo)翻译成人话给我一个分页信息pageInfo我返回一页数据给你等价于Javanew FunctionPageInfo, PageResultBondQuotaQueryBO() { Override public PageResultBondQuotaQueryBO apply(PageInfo pageInfo) { return bondQuotaQueryService. queryBondQuotaQueryByPage(queryBO, pageInfo); }}关键点pageInfo 是 Lambda 的参数占位符queryBO 是从外部捕获的变量闭包这个 Lambda 现在不执行只是定义了一个规则参数 2 详解Javarows - { for (BondQuotaQueryBO bo : rows) { syncSingleQuota(bo, tenantId); }}翻译成人话给我一页数据rows我逐条处理它们等价于Javanew ConsumerListBondQuotaQueryBO() { Override public void accept(ListBondQuotaQueryBO rows) { for (BondQuotaQueryBO bo : rows) { syncSingleQuota(bo, tenantId); } }}四、PageQueryUtil 内部是如何工作的执行流程图PlainTextPageQueryUtil.queryAndProcess()│├─ 【第 1 步】创建第 1 页的分页参数│ PageInfo pageInfo new PageInfo(1, 100);│├─ 【第 2 步】调用你的查询函数│ PageResultT result queryFunction.apply(pageInfo);│ ↑│ └─ 实际执行bondQuotaQueryService.queryBondQuotaQueryByPage(queryBO, pageInfo)│├─ 【第 3 步】调用你的处理函数│ pageHandler.accept(result.getRows());│ ↑│ └─ 实际执行for (BondQuotaQueryBO bo : rows) { syncSingleQuota(bo, tenantId); }│├─ 【第 4 步】获取总条数计算总页数│ long total result.getTotal(); // 比如 1000│ int totalPages 1000 / 100 10;│├─ 【第 5 步】循环查询第 2~10 页│ for (int page 2; page 10; page) {│ PageInfo pageInfo new PageInfo(page, 100);│ PageResultT result queryFunction.apply(pageInfo); // 查询│ pageHandler.accept(result.getRows()); // 处理│ }│└─ 【第 6 步】返回总条数 return processedCount;时序图PlainText调用方 PageQueryUtil 你的查询函数 你的处理函数 │ │ │ │ │──queryAndProcess── │ │ │ │ │ │ │ │ │──apply(pageInfo)── │ │ │ │ │ │ │ │─PageResult 返回── │ │ │ │ │ │ │ │────────accept(rows) ────────────────────────── │ │ │ │ │ │ │ (循环第 2~N 页...) │ │ │ │ │ │─返回总条数───────── │ │ │ │ │ │ │五、为什么需要 pageInfo -常见疑惑pageInfo 不是在 queryAndProcess 里面定义了吗为什么 Lambda 还要写一次答案Lambda 是在定义函数不是在调用函数类比理解场景你点外卖传统方式Java// 你直接去餐厅吃ListFood allFood restaurant.getAllFood();eat(allFood);外卖方式PageQueryUtilJava// 你告诉外卖平台FoodDelivery.orderAndEat( // 参数 1怎么取餐 box - restaurant.getFoodByBox(box), // 参数 2怎么吃 foods - { for (Food food : foods) { eat(food); } }, // 参数 3每箱装多少 10);Lambda 的 box - 就像给我一个餐盒编号box我去取对应的菜外卖平台会准备第 1 个餐盒 → 调用你的取餐函数 → 送到你家 → 你开吃准备第 2 个餐盒 → 调用你的取餐函数 → 送到你家 → 你开吃...关键餐盒编号是外卖平台准备的你只需要定义收到编号后怎么做六、闭包Lambda 的超能力问题queryBO 没有作为参数传给 queryAndProcess为什么查询函数里能用答案Lambda 可以记住定义时的上下文JavaBondQuotaQueryBO queryBO new BondQuotaQueryBO(); // ← 外部变量queryBO.setLockStatus(2);PageQueryUtil.queryAndProcess( // Lambda捕获了外部的 queryBO pageInfo - bondQuotaQueryService. queryBondQuotaQueryByPage(queryBO, pageInfo), // ↑ // └─ 外部变量被 Lambda 捕获 ...);通俗理解Lambda 就像一个 closures闭包把定义时能看到的变量都装进包里以后随时能用七、举一反三更多使用场景场景 1批量发送邮件JavaEmailQueryBO queryBO new EmailQueryBO();queryBO.setStatus(PENDING);PageQueryUtil.queryAndProcess( pageInfo - emailService.queryPendingEmails(queryBO, pageInfo), emails - { for (Email email : emails) { sendEmail(email); } }, 50);场景 2导出 ExcelJavaPageQueryUtil.queryAndProcess( pageInfo - orderService.queryOrders(queryBO, pageInfo), orders - { // 逐页写入 Excel excelWriter.write(orders); }, 1000);场景 3数据清洗JavaPageQueryUtil.queryAndProcess( pageInfo - dataService.queryDirtyData(pageInfo), dataList - { for (Data data : dataList) { cleanData(data); } }, 200);八、常见错误避坑❌ 错误 1直接调用方法没有 LambdaJava// 错误pageInfo 未定义PageQueryUtil.queryAndProcess( bondQuotaQueryService.queryBondQuotaQueryByPage (queryBO, pageInfo), ...);正确写法JavaPageQueryUtil.queryAndProcess( pageInfo - bondQuotaQueryService. queryBondQuotaQueryByPage(queryBO, pageInfo), ...);❌ 错误 2忘记写 -Java// 错误这不是 LambdaPageQueryUtil.queryAndProcess( (PageInfo pageInfo) bondQuotaQueryService. queryBondQuotaQueryByPage(queryBO, pageInfo), ...);正确写法JavaPageQueryUtil.queryAndProcess( (PageInfo pageInfo) - bondQuotaQueryService. queryBondQuotaQueryByPage(queryBO, pageInfo), ...);❌ 错误 3类型不匹配Java// 错误queryFunction 返回值类型不对PageQueryUtil.queryAndProcess( pageInfo - bondQuotaQueryService.queryCount (queryBO), // ← 返回 Integer不是 PageResult ...);正确写法JavaPageQueryUtil.queryAndProcess( pageInfo - bondQuotaQueryService. queryBondQuotaQueryByPage(queryBO, pageInfo), ...);九、核心要点总结1. 方法签名背下来JavaqueryAndProcess( FunctionPageInfo, PageResultT queryFunction, // 怎么查 ConsumerListT pageHandler, // 怎么处理 int pageSize // 每页多少条)2. Lambda 表达式Java// 查询函数接收 pageInfo返回 PageResultpageInfo - service.query(queryBO, pageInfo)// 处理函数接收 rows没有返回值rows - { for (T item : rows) { process(item); } }3. 闭包特性JavaSomeBO queryBO new SomeBO(); // 外部变量pageInfo - service.query(queryBO, pageInfo); // Lambda 捕获外部变量4. 执行流程PlainText1. 创建第 1 页 PageInfo2. 调用 queryFunction.apply(pageInfo) → 查询3. 调用 pageHandler.accept(rows) → 处理4. 循环第 2~N 页5. 返回总条数十、课后练习练习题 1补全代码Java// 需求分页查询用户每页 50 条打印每个用户的名字UserQueryBO queryBO new UserQueryBO();queryBO.setStatus(ACTIVE);PageQueryUtil.queryAndProcess( // 补全参数 1查询函数 ________________________________, // 补全参数 2处理函数 ________________________________, // 补全参数 3每页条数 ____);参考答案JavaPageQueryUtil.queryAndProcess( pageInfo - userService.queryUsers(queryBO, pageInfo), users - { for (User user : users) { System.out.println(user.getName()); } }, 50);练习题 2判断正误Java// 这段代码有什么问题PageQueryUtil.queryAndProcess( pageInfo - { userService.queryUsers(queryBO, pageInfo); }, users - System.out.println(users.size()), 100);答案查询函数缺少 return 语句应该改为JavapageInfo - { return userService.queryUsers(queryBO, pageInfo);}结语PageQueryUtil.queryAndProcess 是模板方法模式函数式编程的完美结合模板方法模式PageQueryUtil 定义流程你填充具体逻辑函数式编程用 Lambda 表达式传递行为代码简洁优雅掌握这个工具让你的分页查询代码✅ 内存友好✅ 逻辑清晰✅ 易于复用✅ 优雅简洁记住这个公式PlainTextqueryAndProcess( 怎么查Lambda, 怎么处理Lambda, 每页多少条)下次遇到分页查询试试这个优雅的打开方式吧