如果还不懂如何使用 Consumer 接口,来公司我当面给你讲!

背景

没错,我还在做 XXXX 项目,还在与第三方对接接口,不同的是这次是对自己业务逻辑的处理。

在开发过程中我遇到这么一个问题:

表结构:
一张主表A ,一张关联表B ,表 A 中存储着表 B 记录的状态。

场景:
第一步创建主表数据,插入A表;第二步调用第三方接口插入B表同时更新A表的状态。此时大家应该都会想到在进行第二步的时候需要做好数据的幂等性。这样的话就会存在以下几种情况:

一、B表中不存在与A表关联的数据,此时需要调用第三方接口,插入B表同时更新A表的状态;

二、B表中存在与A表关联的数据;

  1. A表中的状态为处理中:直接返回处理中字样;
  2. A表中的状态为处理成功:直接返回成功的字样;
  3. A表中的状态为处理失败:此时需要调用第三方接口,更新B表同时更新A表的状态;

代码实现

首先我是这样编写的伪代码

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 的使用已经全部掌握了。如果你还存在一丝丝的疑虑,那么就接着往下看,我们将介绍一下四种常见的函数式接口。

函数式接口.jpg

函数式接口

那什么是函数式接口呢?函数式接口是只有一个抽象方法(Object的方法除外),但是可以有多个非抽象方法的接口,它表达的是一种逻辑上的单一功能。

@FunctionalInterface

@FunctionalInterface 注解用来表示该接口是函数式接口。它有助于及早发现函数式接口中出现的或接口继承的不适当的方法声明。

如果接口用该注解来注释,但实际上不是函数式接口,则会在编译时报错。

Consumer

我们一般称之为“消费者”,它表示接受单个输入参数但不返回结果的操作。不同于其它函数式接口,Consumer 预期通过副作用进行操作。

那什么又是副作用呢?说一下我所理解的副作用,副作用其实就是一个函数是否会修改它范围之外的资源,如果有就叫有副作用,反之为没有副作用。比如修改全局变量,修改输入参数所引用的对象等。

@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 类型的,返回结果为:李四

看到这儿,我们常见的四种函数式接口就已经介绍完了。说实话,函数式接口我已经看过好几遍了,尤其是 ConsumerSupplier。当时只是脑子里学会了,没有应用到具体的项目中,下次再遇到的时候还是一脸懵逼,不知道大家有没有这种感受。

所以我们需要总结经验教训,一定要将代码的原理搞懂,然后多敲几遍,争取应用到自己的项目中,提升自己的编码能力。

以上就是今天的全部内容了,如果你有不同的意见或者更好的idea,欢迎联系阿Q,添加阿Q可以加入技术交流群参与讨论呦!

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,657评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,662评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 158,143评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,732评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,837评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,036评论 1 291
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,126评论 3 410
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,868评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,315评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,641评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,773评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,470评论 4 333
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,126评论 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,859评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,095评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,584评论 2 362
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,676评论 2 351

推荐阅读更多精彩内容