@[toc]
常用方法
forEach()sorted()filter()limit()skip()
拓展,分页 distinct()map()findFirst()reduce()groupingBy()toMap() 数值流
方法
虽然jdk1.8已经出了很久很久,但是我在实际项目中用的很少,最近使用到了stream api。感觉有些常用的方法非常方便,能够通过很少代码实现我的需求,后悔没有早一点了解。所以特此花了一些时间对常用的api方法进行了整理和熟悉。
常用方法例如:以日志数据为例
初始化5条数据,进行下面 *** 作
ListforEach()list = init();
对此流的每个元素执行 *** 作
java8之前
for (LogsDO logsDO : list) { System.out.println(logsDO); } //或者 for (int i = 0; i < list.size(); i++) { System.out.println(list.get(i)); }
java8 lambda
list.forEach(System.out::println);
java 8 stream lambda
records.stream().forEach(x->{ System.out.println(x); });sorted()
返回由该流的元素组成的流,根据提供的 Comparator进行排序。
按执行所消耗的时间排序,正序
list.stream().sorted(Comparator.comparing(LogsDO::getConsumingTime)).forEach(System.out::println);
倒序
list.stream().sorted(Comparator.comparing(LogsDO::getConsumingTime).reversed()).forEach(System.out::println);filter()
返回由与此给定谓词匹配的此流的元素组成的流。
过滤出指定结果,如只要登录方法
java8之前
for (LogsDO logsDO : list) { if ("login".equals(logsDO.getActionMethod())) { System.out.println(logsDO); } }
java8 stream
list.stream().filter((LogsDO logsDO) -> "login".equals(logsDO.getActionMethod())).forEach(System.out::println);limit()
返回由该流的元素组成的流,截断长度不能超过maxSize 。
如只取前3条数据
list.stream().limit(3).forEach(System.out::println);skip()
在丢弃流的第一个n元素后,返回由该流的n元素组成的流。 如果此流包含少于n元素,那么将返回一个空流。
跳过前2条数据,从第3条数据开始
list.stream().skip(2).forEach(System.out::println);拓展,分页
根据limit()和skip()进行分页
private static void page(int page, int limit, Listdistinct()list) { int start = (page - 1) * limit; int end = limit; list.stream().skip(start).limit(end).forEach(System.out::println); }
返回由该流的不同元素(根据Object.equals(Object))组成的流。
这里举例子为List
private static Listinit1() { List list = new ArrayList(); list.add(1); list.add(2); list.add(3); list.add(1); list.add(3); return list; }
init1().stream().distinct().forEach(System.out::println);map()
返回由给定函数应用于此流的元素的结果组成的流。
只取某列作为数据list
如只取id列
ListfindFirst()idList = list.stream().map(LogsDO::getId).collect(Collectors.toList());
返回此流的第一个元素的Optional如果流为空,则返回一个空的Optional 。 如果流没有遇到顺序,则可能会返回任何元素。
获取第一条数据
LogsDO logsDO = list.stream().findFirst().get();
也可以和过滤一起使用,只获取第一条方法为login的数据
LogsDO logsDO = list.stream().filter((LogsDO)->"login".equals(LogsDO.getActionMethod())).findFirst().get();reduce()
查询出耗时最长的数据
LogsDO logsDO = list.stream().reduce((s1, s2) -> s1.getConsumingTime() > s2.getConsumingTime() ? s1 : s2).get();
意思就是两个耗时时间比较,如果s1大,则取s1,否则取s2。
或者
LogsDO logsDO = list.stream().max(Comparator.comparing(LogsDO::getConsumingTime)).get();groupingBy()
分组
如以请求方法进行分组
list.stream().collect(Collectors.groupingBy(LogsDO::getActionMethod));toMap()
从list中指定key、value,转为map格式数据
转map,key为id,value为对象
list.stream().collect(Collectors.toMap(LogsDO::getId, Function.identity()));
转map,key为id,value为请求方法
list.stream().collect(Collectors.toMap(LogsDO::getId, LogsDO::getActionMethod));S
数值流
mapToInt()
返回一个IntStream ,其中包含将给定函数应用于此流的元素的结果。
IntStream intStream = list.stream().mapToInt(LogsDO::getId);
mapToLong()
返回一个LongStream ,其中包含将给定函数应用于此流的元素的结果。
LongStream longStream = list.stream().mapToLong(LogsDO::getConsumingTime);
mapToDouble()
返回一个DoubleStream ,其中包含将给定函数应用于此流的元素的结果。
方法System.out.println(list.stream().mapToLong(LogsDO::getConsumingTime).sum()); System.out.println(list.stream().mapToLong(LogsDO::getConsumingTime).max().getAsLong()); System.out.println(list.stream().mapToLong(LogsDO::getConsumingTime).min().getAsLong()); System.out.println(list.stream().mapToLong(LogsDO::getConsumingTime).average().getAsDouble()); System.out.println(list.stream().mapToLong(LogsDO::getConsumingTime).count());
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)