java流式資料處理stream

說明

java 8種添加了一種聲明的方式處理資料Stream。可以讓程式員寫出高效率、幹淨、簡潔的代碼。這種風格将元素集合看作一種流， 流在管道中傳輸， 并且可以在管道的節點上進行處理， 如篩選， 排序，聚合等。

forEach

用來疊代流中的每個資料

List<Integer> numbers = Arrays.asList(1, 2, 3);
numbers.stream().forEach(System.out::println);
           

filter

用于過濾元素

List<Integer> numbers = Arrays.asList(1, 2, 3);
numbers.stream().filter(n -> n > 2).forEach(System.out::println);
           

limit

用于擷取指定數量的流

List<Integer> numbers = Arrays.asList(1, 2, 3);
numbers.stream().limit(2).forEach(System.out::println);
           

sorted

用于對流進行排序

List<Integer> numbers = Arrays.asList(1, 2, 3);
numbers.stream().sorted((n1, n2) -> n2.compareTo(n1)).forEach(System.out::println);
           

map

用于映射每個元素到對應的結果

List<Integer> numbers = Arrays.asList(1, 2, 3);
numbers.stream().map(n -> n * 2).forEach(System.out::println);
           

Collectors

實作了很多規約操作，如将流轉換成集合和聚合元素

• list

  List<Integer> numbers = Arrays.asList(1, 2, 3);
  List<Integer> ns = numbers.stream().filter(n -> n > 2).collect(Collectors.toList());
             

• set

  List<Integer> numbers = Arrays.asList(1, 2, 3);
  Set<Integer> ns = numbers.stream().filter(n -> n > 2).collect(Collectors.toSet());
             

• map

  List<User> users = new ArrayList<>();
  // 使用者id-使用者名
  Map<Long, String> map = users.stream().collect(Collectors.toMap(u1 -> u1.getId(), u2 -> u2.getName()));
  // 按照年齡分組
  Map<Integer, List<User>> map = users.stream().collect(Collectors.groupingBy(User::getAge));
             

• joining

  List<Integer> numbers = Arrays.asList(1, 2, 3);
  System.out.println(numbers.stream().map(n -> n.toString()).collect(Collectors.joining(", ")));
             

summaryStatistics

統計

List<Integer> numbers = Arrays.asList(1, 2, 3);
IntSummaryStatistics statis = numbers.stream().mapToInt(n -> n).summaryStatistics();
System.out.println("最大值"+statis.getMax());
System.out.println("最小值"+statis.getMin());
System.out.println("和"+statis.getSum());
System.out.println("平均值"+statis.getAverage());