JavaStreamgroupingBy使用教程

在这个例子中，我们首先按照 menu 和 group 的组合对 userList 进行分组。然后，我们使用 filtering Collector 来过滤掉 IOType 为 NONE 的元素。

注意： 如果某个分组中的所有元素都被 filtering Collector 过滤掉，那么该分组的键仍然会存在于结果 Map 中，但是对应的值将会是一个空列表。

filter 操作 vs. filtering Collector

filter 操作和 filtering Collector 的区别在于它们的作用范围不同。filter 操作是在流的中间阶段进行的，它会过滤掉不满足条件的元素，从而影响后续的所有操作。而 filtering Collector 是在 groupingBy 之后进行的，它只会过滤掉每个分组中的元素，而不会影响其他分组。

如果在分组之前就可以确定哪些元素需要被过滤掉，那么使用 filter 操作会更加高效。例如：

import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
import java.util.HashSet;
import java.util.Objects;

public class GroupingByExample {

    public enum IOType {
        NONE, TYPE1, TYPE2
    }

    public static class User {
        private String stringSeq;
        private Set ioTypes;

        public User(String stringSeq) {
            this.stringSeq = stringSeq;
            this.ioTypes = new HashSet<>();
        }

        public String getStringSeq() {
            return stringSeq;
        }

        public Set getIoTypes() {
            return ioTypes;
        }

        public void addIoType(IOType ioType) {
            this.ioTypes.add(ioType);
        }

        public void setIoTypes(Set ioTypes) {
            this.ioTypes = ioTypes;
        }
    }

    public static void main(String[] args) {
        List userList = List.of(
                new User("menu1:group1:TYPE1"),
                new User("menu1:group1:TYPE2"),
                new User("menu2:group2:TYPE1"),
                new User("menu1:group1:NONE")
        );

        String DELIMITER = ":";

        Map> groupedUsers = userList.stream()
                .filter(e -> !e.getStringSeq().split(DELIMITER)[2].equals("NONE")) // 在分组之前过滤掉 IOType 为 NONE 的元素
                .collect(Collectors.groupingBy(
                        e -> {
                            String[] arr = e.getStringSeq().split(DELIMITER);
                            return String.join(DELIMITER, arr[0], arr[1]);
                        }
                ));

        System.out.println(groupedUsers);
        // Output: {menu2:group2=[GroupingByExample$User@48524c6f], menu1:group1=[GroupingByExample$User@4f023edb, GroupingByExample$User@3cd1a2f1]}
    }
}

在这个例子中，我们在分组之前使用 filter 操作过滤掉了 IOType 为 NONE 的元素。这样可以避免在分组之后再进行过滤，从而提高效率。此外，由于在分组之前已经过滤掉了所有 IOType 为 NONE 的元素，因此结果 Map 中不会存在对应的键。

避免副作用

在流操作中，应该避免使用副作用。副作用是指函数除了返回值之外，还修改了外部状态。例如，在 mapping 函数中修改传入的 User 对象的 ioTypes 属性就是一个副作用。

副作用可能会导致流操作的结果变得不可预测，并且难以调试。为了避免副作用，应该尽量使用纯函数。纯函数是指只依赖于输入参数，并且不修改外部状态的函数。

如果必须使用副作用，那么应该尽量将其限制在流操作的末尾，并且要确保副作用不会影响后续的操作。

总结

在使用 Java Stream 的 groupingBy 方法进行分组时，可以使用 filtering Collector 来有条件地添加元素。filtering Collector 允许我们在分组之后，对每个分组的结果进行过滤。如果在分组之前就可以确定哪些元素需要被过滤掉，那么使用 filter 操作会更加高效。在流操作中，应该避免使用副作用，尽量使用纯函数。

终于介绍完啦！小伙伴们，这篇关于《JavaStreamgroupingBy使用教程》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布文章相关知识，快来关注吧！