[游戏开发]Java 8 Stream流

Java 8 提供了Stream流进行数据处理；流只能遍历一次

//        过滤
        list.stream().filter(item -> Objects.equals("1", item.getId())).collect(Collectors.toList());
//        去重
        list.stream().distinct().collect(Collectors.toList());
//        限制条数
        list.stream().limit(2).collect(Collectors.toList());
//        跳过
        list.stream().skip(2).collect(Collectors.toList());
//        String类型排序
        list.stream().sorted(Comparator.comparing(OperaLogDto ::getId,Comparator.comparingInt(Integer ::parseInt))).collect(Collectors.toList());
//        普通排序(reversed() 倒叙)
        list.stream().sorted(Comparator.comparing(OperaLogDto :: getId).reversed()).collect(Collectors.toList());
//        获取字段集合
        list.stream().map(OperaLogDto :: getUserName).collect(Collectors.toList());
//        获取字段集合的每个长度
        list.stream().map(OperaLogDto :: getUserName).map(String :: length).collect(Collectors.toList());
//        将名称为test的名称筛选出来，将名称通过 | 分割，并收集成list<String>。
        list.stream().filter(item -> "test".equals(item.getUserName())).map(item -> item.getUserName().split("//|")).flatMap(Arrays :: stream).collect(Collectors.toList());
//        判断id是否有等于“1”的   allMatch noneMatch
        list.stream().anyMatch(item -> item.getId().equals("1"));
//        查找第一个元素(返回Optional)
        Optional<OperaLogDto> first = list.stream().filter(item -> item.getId().equals("1")).findFirst();
//        String类型求和
        list.stream().map(item -> new BigDecimal(item.getId())).reduce(BigDecimal.ZERO,BigDecimal::add).toPlainString();
//        最大值（返回Optional） min
        list.stream().max(Comparator.comparing(OperaLogDto::getId));
//        以userName分组
        Map<String, List<OperaLogDto>> collect = list.stream().collect(Collectors.groupingBy(OperaLogDto::getUserName));
        for (String key : collect.keySet()){
            List<OperaLogDto> operaLogDtos = collect.get(key);
        }
//        将List合并为字符串
        String collect2 = list.stream().map(item -> item.getId().split(""))
                .flatMap(Arrays::stream).collect(Collectors.joining());
//        按照条件分组
        Map<Integer, List<OperaLogDto>> collect = list.stream().collect(Collectors.groupingBy(item -> {
                    if (item.getId().equals("1")) {
                        return 1;
                    } else {
                        return 2;
                    }
                }));
//        按照条件分组并统计数量
        Map<Integer, Long> collect1 = list.stream().collect(Collectors.groupingBy(item -> {
            if (item.getId().equals("1")) {
                return 1;
            } else {
                return 2;
            }
        }, Collectors.counting()));
//      通过boolean分区等同于 filter
        Map<Boolean, List<OperaLogDto>> collect3 = list.stream().collect(Collectors.partitioningBy(OperaLogDto::getSave));
// 通过boolean分区再通过userName分组
        Map<Boolean, Map<String, List<OperaLogDto>>> collect3 = list.stream().collect(Collectors.partitioningBy(OperaLogDto::getSave, Collectors.groupingBy(OperaLogDto::getUserName)));

上面的方法也可进行复合使用，也可以使用流来进行跨包的转换

list.stream().map(OperaLogDto :: convertTo).collect(Collectors.toList());

在OperaLogDto 中转换即可

    public static OperaLogDto convertTo(OperaLogTo dto) {
        return new OperaLogDto();
    }