1.写在前面
关于Stream API的内容，已经基本上说完了。大家可以参考我的这两篇文章：
Stream API的创建方式及中间操作、Stream API的终止操作
那么这篇文章主要就是说一个Stream API的简单应用练习题。
2.应用举例
首先，我们需要创建一个交易员类、交易类、存储这两个类对象的List集合。
package com.szh.java8.exer; import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; /** * 交易员类 */ @Data @NoArgsConstructor @AllArgsConstructor public class Trader { private String name; private String city; }
package com.szh.java8.exer; import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; /** * 交易类 */ @Data @NoArgsConstructor @AllArgsConstructor public class Transaction { private Trader trader; private int year; private int value; }
List<Transaction> transactions = Arrays.asList( new Transaction(new Trader("Brian", "Cambridge"),2011,300), new Transaction(new Trader("Raoul", "Cambridge"),2012,1000), new Transaction(new Trader("Raoul", "Cambridge"),2011, 400), new Transaction(new Trader("Mario", "Milan"),2012, 710), new Transaction(new Trader("Mario", "Milan"),2012, 700), new Transaction(new Trader("Alan", "Cambridge"),2012,950) );
2.1 找出2011年发生的所有交易， 并按交易额排序（从低到高）
@Test public void test1() { transactions.stream() .filter((t) -> t.getYear() == 2011) .sorted((t1,t2) -> Integer.compare(t1.getValue(),t2.getValue())) .forEach(System.out::println); }
2.2 交易员都在哪些不同的城市工作过？
@Test public void test2() { transactions.stream() .map((t) -> t.getTrader().getCity()) .distinct() .forEach(System.out::println); }
2.3 查找所有来自剑桥的交易员，并按姓名排序
@Test public void test3() { transactions.stream() .filter((t) -> t.getTrader().getCity().equals("Cambridge")) .map(Transaction::getTrader) .sorted((t1,t2) -> t1.getName().compareTo(t2.getName())) .distinct() .forEach(System.out::println); }
2.4 返回所有交易员的姓名字符串，按字母顺序排序
@Test public void test4() { transactions.stream() .map((t) -> t.getTrader().getName()) .sorted() .forEach(System.out::println); }
2.5 有没有交易员是在米兰工作的？
@Test public void test5() { boolean b = transactions.stream() .anyMatch((t) -> t.getTrader().getCity().equals("Milan")); System.out.println(b); }
2.6 打印生活在剑桥的交易员的所有交易额
@Test public void test6() { Optional<Integer> sum = transactions.stream() .filter((t) -> t.getTrader().getCity().equals("Cambridge")) .map(Transaction::getValue) .reduce(Integer::sum); System.out.println(sum.get()); // Integer reduce = transactions.stream() // .filter((t) -> t.getTrader().getCity().equals("Cambridge")) // .map(Transaction::getValue) // .reduce(0, (x, y) -> x + y); // System.out.println(reduce); }
2.7 所有交易中，最高的交易额是多少
@Test public void test7() { Optional<Integer> max = transactions.stream() .map((t) -> t.getValue()) .max(Integer::compare); System.out.println(max.get()); }
2.8 找到交易额最小的交易
@Test public void test8() { Optional<Transaction> min = transactions.stream() .min((t1, t2) -> Integer.compare(t1.getValue(), t2.getValue())); System.out.println(min.get()); }
