如果还不懂如何使用 Consumer 接口，来青岛我当面给你讲！
发布时间：2025-11-05 02:40:32 来源：创站工坊 作者：域名
背景
没错，果还我还在做 XXXX 项目，不懂还在与第三方对接接口，何使不同的接讲是这次是对自己业务逻辑的处理。
在开发过程中我遇到这么一个问题：
表结构：一张主表A ，口青一张关联表B ，岛当表 A 中存储着表 B 记录的果还状态。
场景：第一步创建主表数据，不懂插入A表;第二步调用第三方接口插入B表同时更新A表的何使状态。此时大家应该都会想到在进行第二步的接讲时候需要做好数据的幂等性。这样的口青话就会存在以下几种情况：
一、B表中不存在与A表关联的岛当数据，此时需要调用第三方接口，果还插入B表同时更新A表的不懂状态;
二、B表中存在与A表关联的何使数据;
A表中的状态为处理中：直接返回处理中字样;
A表中的状态为处理成功：直接返回成功的字样;
A表中的状态为处理失败：此时需要调用第三方接口，更新B表同时更新A表的状态;
代码实现
首先我是这样编写的IT技术网伪代码
B b = this.baseMapper.selectOne(queryWrapper); if (b != null) { String status = b.getStatus(); if (Objects.equals(Constants.STATUS_ING, status)){ return "处理中"; } else if (Objects.equals(Constants.STATUS_SUCCESS, status)){ return "处理成功"; } //失败的操作 //请求第三方接口并解析响应结果 ...... if (ReturnInfoEnum.SUCCESS.getCode().equals(parse.getCode())) { ...... //更新B表操作 bb.setStatus(Constants.STATUS_ING); mapper.updateById(bb); //更新A表的状态 a.setStatus(Constants.STATUS_ING); aMapper.updateById(a); } } else { //请求第三方接口并解析响应结果 ...... if (ReturnInfoEnum.SUCCESS.getCode().equals(parse.getCode())) { ...... //插入B表操作 bb.setStatus(Constants.STATUS_ING); mapper.insert(bb); //更新A表的状态 a.setStatus(Constants.STATUS_ING); aMapper.updateById(a); } }不知道细心的小伙伴是否发现，存在B表记录并且状态为“失败”的情况和不存在B表的情况除了插入B表或者更新B表的操作之外，其余的操作都是相同的。
如果我们想要将公共的部分抽取出来，发现都比较零散，还不如不抽取，但是不抽取代码又存在大量重复的代码不符合我的风格。于是我便将手伸向了 Consumer 接口。
更改之后的伪代码
B b = this.baseMapper.selectOne(queryWrapper); if (b != null) { String status = b.getStatus(); if (Objects.equals(Constants.STATUS_ING, status)){ return "处理中"; } else if (Objects.equals(Constants.STATUS_SUCCESS, status)){ return "处理成功"; } //失败的操作 getResponse(dto, response, s -> mapper.updateById(s)); } else { getResponse(dto, response, s -> mapper.updateById(s)); } public void getResponse(DTO dto, Response response, Consumer<B> consumer){ //请求第三方接口并解析响应结果 ...... if (ReturnInfoEnum.SUCCESS.getCode().equals(parse.getCode())) { ...... bb.setStatus(Constants.STATUS_ING); consumer.accept(bb); //更新A表的状态 a.setStatus(Constants.STATUS_ING); aMapper.updateById(a); } }看到这，如果大家都已经看懂了，那么恭喜你，说明你对 Consumer 的使用已经全部掌握了。如果你还存在一丝丝的站群服务器疑虑，那么就接着往下看，我们将介绍一下四种常见的函数式接口。
函数式接口
那什么是函数式接口呢?函数式接口是只有一个抽象方法(Object的方法除外)，但是可以有多个非抽象方法的接口，它表达的是一种逻辑上的单一功能。
@FunctionalInterface
@FunctionalInterface 注解用来表示该接口是函数式接口。它有助于及早发现函数式接口中出现的或接口继承的不适当的方法声明。
如果接口用该注解来注释，但实际上不是函数式接口，则会在编译时报错。
Consumer
我们一般称之为“消费者”，它表示接受单个输入参数但不返回结果的操作。不同于其它函数式接口，Consumer 预期通过副作用进行操作。
那什么又是副作用呢?说一下我所理解的副作用，WordPress模板副作用其实就是一个函数是否会修改它范围之外的资源，如果有就叫有副作用，反之为没有副作用。比如修改全局变量，修改输入参数所引用的对象等。
@FunctionalInterface public interface Consumer<T> { /** * 对给定的参数执行此操作。 */ void accept(T t); /** * * 返回一个组合的 Consumer ，依次执行此操作，然后执行after操作。 * 如果执行任一操作会抛出异常，它将被转发到组合操作的调用者。 * 如果执行此操作会引发异常，则不会执行after操作。 */ default Consumer<T> andThen(Consumer<? super T> after) { Objects.requireNonNull(after); return (T t) -> { accept(t); after.accept(t); }; } }正如我们案例中遇到的场景，我们只需要将要执行的逻辑方法当作参数传入 getResponse() 中，然后在该方法中执行 accept() 方法进行消费即可。如果还不理解，我们可以把它转换为匿名内部类的调用方式。
getResponse(dto, response, new Consumer<B>() { @Override public void accept(B bb) { mapper.insert(bb); } );当调用accept() 方法的时候就会去调用匿名内部类的方法了，也就是我们传入 getResponse() 的逻辑方法。
Supplier
我们一般称之为“生产者”，没有参数输入，但是能返回结果，为结果的提供者。
@FunctionalInterface public interface Supplier<T> { /** * 获取一个结果 */ T get(); }可以举个简单的例子感受下：
Optional<Double> optional = Optional.empty(); optional.orElseGet(()->Math.random() ); //orElseGet 方法的源码，里边用到了 get 方法 public T orElseGet(Supplier<? extends T> other) { return value != null ? value : other.get(); }Function
我把它称为“转换者”，表示接收一个参数通过处理之后返回一个结果的函数。
@FunctionalInterface public interface Function<T, R> { /** * 将 T 类型的参数传入，经过函数表达式的计算，返回 R 类型的结果 */ R apply(T t); /** * 返回一个组合函数，先将参数应用于 before 函数，然后将结果应用于当前函数，返回最终结果。 * 如果对任一函数的求值引发异常，则会将其转发给组合函数的调用方。 */ default <V> Function<V, R> compose(Function<? super V, ? extends T> before) { Objects.requireNonNull(before); return (V v) -> apply(before.apply(v)); } /** * 返回一个组合函数，先将参数应用与当前函数，然后将结果应用于 after 函数，返回最终的结果。 * 如果对任一函数的求值引发异常，则会将其转发给组合函数的调用方。 */ default <V> Function<T, V> andThen(Function<? super R, ? extends V> after) { Objects.requireNonNull(after); return (T t) -> after.apply(apply(t)); } /** * 返回始终返回其输入参数的函数。 */ static <T> Function<T, T> identity() { return t -> t; } }我们在 lambda 表达式中应用比较多，所以我们来简单演示下：
@Data @AllArgsConstructor public class Teacher { private String name; private int age; } public class TeacherTest { public static void main(String[] args) { List<Teacher> list = Arrays.asList( new Teacher("张三",25), new Teacher("李四",28), new Teacher("王五",18)); List<String> collect = list.stream().map(item -> item.getName()).collect(Collectors.toList()); System.out.println(collect); } }其中 map 接收的参数就是 Function 类型， item 为传入参数，item.getName() 为返回处理的结果，最后输出结果为
[张三, 李四, 王五]Predicate
我们称之为“判断者”，通过接收参数 T 来返回 boolean 的结果。
@FunctionalInterface public interface Predicate<T> { /** * 接收一个参数, 判断这个参数是否匹配某种规则, 匹配成功返回true, 匹配失败则返回false */ boolean test(T t); /** * 接收一个 Predicate 类型的参数，用当前函数和 other 函数逻辑与判断参数 t 是否匹配规则，成功返回true，失败返回 false * 如果当前函数返回 false，则 other 函数不进行计算 * 在评估 Predicate 期间引发的任何异常都会转发给调用方 */ default Predicate<T> and(Predicate<? super T> other) { Objects.requireNonNull(other); return (t) -> test(t) && other.test(t); } /** * 返回当前Predicate取反操作之后的Predicate */ default Predicate<T> negate() { return (t) -> !test(t); } /** * 接收一个 Predicate 类型的参数，用当前函数和 other 函数 逻辑或 判断参数 t 是否匹配规则，成功返回true，失败返回 false * 如果当前函数返回 true，则 other 函数不进行计算 * 在评估 Predicate 期间引发的任何异常都会转发给调用方 */ default Predicate<T> or(Predicate<? super T> other) { Objects.requireNonNull(other); return (t) -> test(t) || other.test(t); } /** * 静态方法：传入一个参数，用来生成一个 Predicate，调用test() 方法时调的 object -> targetRef.equals(object) 函数式 * */ static <T> Predicate<T> isEqual(Object targetRef) { return (null == targetRef) ? Objects::isNull : object -> targetRef.equals(object); } }相信大家在编码过程中经常会遇到该函数式接口，我们举个例子来说一下：
public static void main(String[] args) { List<Teacher> list = Arrays.asList( new Teacher("张三",25), new Teacher("李四",28), new Teacher("王五",18)); list = list.stream().filter(item -> item.getAge()>25).collect(Collectors.toList()); list.stream().forEach(item->System.out.println(item.getName())); }其中 filter() 的参数为 Predicate 类型的，返回结果为：李四
看到这儿，我们常见的四种函数式接口就已经介绍完了。说实话，函数式接口我已经看过好几遍了，尤其是 Consumer 和 Supplier。当时只是脑子里学会了，没有应用到具体的项目中，下次再遇到的时候还是一脸懵逼，不知道大家有没有这种感受。
所以我们需要总结经验教训，一定要将代码的原理搞懂，然后多敲几遍，争取应用到自己的项目中，提升自己的编码能力。
本文转载自微信公众号「阿Q说代码」，可以通过以下二维码关注。转载本文请联系阿Q说代码公众号。
- 联想老办公电脑改造教程（打造高性能工作站的关键步骤和技巧）
- 艾酷键盘（艾酷键盘的创新设计与功能性能，让办公更加高效和舒适）
- 使用80D配16-35镜头拍摄的绝佳体验（发挥80D潜力，16-35镜头助力创作绝美影像）
- 聚创伟夜（探索聚创伟夜的魅力与前景）
- 联想电脑CPU风扇错误的解决方法（探索联想电脑CPU风扇错误原因及应对措施）
- 以尽翔资本如何帮助企业发展（实力投资助力企业腾飞）
- 艾酷键盘（艾酷键盘的创新设计与功能性能，让办公更加高效和舒适）
- 掌门一对一（从根本上改变教育方式，让每个学生都能实现自己的潜能）
- 康佳彩电LED55R6610U质量怎么样？（全面评估LED55R6610U的性能和用户反馈）
- 了解BS耳机的性能和优势（BS耳机）
- 苹果电脑如何安装Win10系统（一步步教你在苹果电脑上安装Windows10系统）
- 探索5S电池的性能和特点（-高效能、环保、可靠）
- 以神牛环闪的创新技术为主题的文章（揭秘神牛环闪技术的全球领先地位与应用前景）
- 以盆景碎纸机的效果和使用方法（探讨以盆景碎纸机的优势和适用范围）
- 电脑链接错误代码651的解决办法（遇到错误代码651时，你需要知道的关键信息）
- 探索iOS10.2.1正式版的新特性与改进（提升用户体验、增强系统性能的关键更新）
- 宏基笔记本的优势与劣势（了解宏基笔记本的性能和用户评价）
- 手柄小鸡（探索创新科技，畅享游戏乐趣）
- 电脑C盘满了怎么删除没用的东西？（解决电脑C盘存储问题的实用方法）
- 超声波在医疗领域的应用及发展（探索超声波技术在医疗中的创新和前景）
随便看看
- Copyright © 2025 Powered by 如果还不懂如何使用 Consumer 接口，来青岛我当面给你讲！,创站工坊 滇ICP备2023006006号-44sitemap