jdk8 Stream流式处理

1、Strem函数

List<People> list = new ArrayList<>();
//根据age对list分组，得到map
Map<String,List<People>> groupByAge=().collect((People::getAge));
//进阶通过partitioningBy进行分区(分组)，返回值的键仍然是布尔类型，但是它的分类是根据范围进行分类的，分区比较适合处理根据范围进行分类
Map<Boolean,List<People>> rs=().collect(partitioningBy(item-><30));


//根据age进行排序（reserve倒序）得到排序后的List
List<People> peopleListSorted = ().sorted((People::getAge).reversed()).collect(());
//提取age,去重后排序
List<String> ageList = ().map(People::getAge).distinct().sorted().collect(());
//提取年龄大于20的people
List<People> olderThan20 = ().filter(e->(()) > 20).collect(());
//累加List中的money
BigDecimal totalMoney = ().map(People::getMoney).reduce(, BigDecimal::add);

Integer sum=().map(People::getMoney).reduce((x,y)->x+y).get();
Double sum = ().map(People::getMoney).reduce(0.0,Double::sum);

//查询
People people = ().filter(e->().equals("20")).findFirst().orElse(null);
//List<People> -> Map<String,People> (name,people)
//对象集合转化为map
Map<String,People> map = ().collect((People::getName,n->n,(key1,key2)->key1));
//查找流中最大值和最小值
List<Person> personList = generatePersonList();
Person olderOne = ().max((Person::getAge)).orElse(null);
Person youngerOne = ().min((Person::getAge)).orElse(null);

//对象去重
ArrayList<Person> collect = ().collect(
(

(() -> new TreeSet<>((Person::getAge))),ArrayList::new)
);
//通过joining拼接流中的元素
String result=().map(People::getName).collect((", "));
//skip跳过流中前2个元素
Stream<People> rs = ().skip(2);

2、optinal判断空处理

对于深度嵌套的语句，可能需要多次判空，才能保证代码的健壮性，但是用if来实现，会有一堆的if语句，java8通过optinal比较优雅的解决了这个问题。
举个例子：
String isocode = ().getCountry().getIsocode().toUpperCase();

通常if判断的做法
if (user != null) {
    Address address = ();
    if (address != null) {
        Country country = ();
        if (country != null) {
            String isocode = ();
            if (isocode != null) {
                isocode = ();
            }
        }
    }
}
Optional的做法
String isocode = (user)
  .map(User::getAddress)
  .map(Address::getCountry)
  .map(Country::getIsocode)
  .orElse("default");

3、Stream的groupby

group by生成一个拥有分组功能的Collector，有三个重载方法

需要一个参数：按照该参数进行分组。结果返回一个Map集合，每个Map的key默认是分组参数的类型，value是一个List集合。

Map <String,List < User >> collect = 
().collect((User: :getEdu));

需要两个参数：第二参数是Collector类型，可以对value进行处理。

可以对结果进行映射
Map <String,List <Integer>> collect = 
().collect(
(User: :getEdu,
//第二个参数对Map的value进行处理（映射）
(User: :getId, ()))
);



可以对结果进行求和
Map <String,Double> collect = ().collect(
(User: :getEdu,
    //对参数进行累计求和
(User: :getPrice))
);

可以对结果进行统计
Map < String,Long > collect = ().collect(
(User: :getEdu,
    //获取count数量
())
);

需要三个参数，第三个参数添加了对结果Map的生成方式，默认是HashMap

Map <String,Double > collect = ().collect(
(User: :getEdu,
    //决定map的生成方式，使用TreeMap
    TreeMap: :new,
    //对参数进行累计求和
    (User: :getPrice))
);

秒客网

jdk8 Stream流式处理

相关文章