Java8 Streams 让集合操作飞起来
前言
接上篇文章 java8 新特性 由于上篇过于庞大，使得重点不够清晰，本篇单独拿出 java8 的 Stream 重点说明 ，并做了点补充。
基本说明
Stream 是基于 java8 的 lambda 表达式的，如果不清楚 lambda 表达式，可以查看我的上篇文章Lambda 表达式和函数式接口快速理解
Stream 把要处理的元素看做一种流，流在管道中传输，可以在管道的节点上处理数据，包含过滤，去重，排序，映射，聚合，分组等。
Stream 分为中间操作和后期操作，中期操作会形成一个新的 Stream ，但不会马上对数据进行处理，到后期操作时，再遍历整个集合；可以没有中期操作直接后期操作。
创建流的方式
使用 java.util.Collection 接口的默认方法 stream 或者 parallelStream
使用 java.util.Arrays 的方法 stream 将数组变成流
中期操作和后期操作
Stream 分为中间操作和后期操作，中期操作会形成一个新的 Stream ，但不会马上对数据进行处理，到后期操作时，再遍历整个集合；可以没有中期操作直接后期操作。
中期操作
map 和 map 之类的，用于映射一种类型到另一种类型
filter 用于过滤掉一些不符合要求的元素
distinct 用于排重
sorted 用于排序
flatMap 用于将流扁平化
后期操作
forEach，collect，reduce，anyMatch，allMatch，noneMatch，findFirst 等；
其中属 collect 最为常用，还有一个专门用于 collect 的 Collectors 类，可以用于将集合转成 List，Set，Map 等
代码示例
数据准备
准备一个用于下面例子测试的对象
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class Vehicle {
//车架号
private String vin;
// 车主手机号
private String phone;
// 车主姓名
private String name;
// 所属车租车公司
private Integer companyId;
// 个人评分
private Double score;
//安装的设备列表imei,使用逗号分隔
private String deviceNos;
}
准备一些车辆数据
static List vehicles = new ArrayList<>();
@Before
public void init(){
List imeis = new ArrayList<>();
for (int i = 0; i <5 ; i++) {
List singleVehicleDevices = new ArrayList<>();
for (int j = 0; j < 3; j++) {
String imei = RandomStringUtils.randomAlphanumeric(15);
singleVehicleDevices.add(imei);
}
imeis.add(StringUtils.join(singleVehicleDevices,','));
}
vehicles.add(new Vehicle("KPTSOA1K67P081452","17620411498","9420",1,4.5,imeis.get(0)));
vehicles.add(new Vehicle("KPTCOB1K18P057071","15073030945","张玲",2,1.4,imeis.get(1)));
vehicles.add(new Vehicle("KPTS0A1K87P080237","19645871598","sanri1993",1,3.0,imeis.get(2)));
vehicles.add(new Vehicle("KNAJC526975740490","15879146974","李种",1,3.9,imeis.get(3)));
vehicles.add(new Vehicle("KNAJC521395884849","13520184976","袁绍",2,4.9,imeis.get(4)));
}
forEach 遍历Collection 数据
vehicles.forEach(vehicle -> System.out.println(vehicle));
//这样就可以遍历打印
vehicles.forEach(System.out::println);
forEach 遍历 Map 数据
Map map = new HashMap<>();
map.put("a",1);map.put("b",2);map.put("c",3);
map.forEach((k,v) -> System.out.println("key:"+k+",value:"+v));
filter 数据过滤
// 去掉评分为 3 分以下的车
List collect = vehicles.stream().filter(vehicle -> vehicle.getScore() >= 3).collect(Collectors.toList());
map 对象映射
对一个 List