JAVA8用stream解决分组的问题

Question

User user =new User();
user.setAge=1;
user.setCount =1;
User user1 =new User();
user1.setAge =1;
user1.setCount=1
......
list.add(user);list.add(user1)....
我现在有一个集合list,里面的所有user的count都是1，age有很多多，我现在想要做的是吧list中所有age相同的user，合并成1个，count是这些age相同的user的个数，最后在吧这些放到新的list中。
因为最近接触了java8的stream()，好像有一个groupby的方法，list.stream.collect(xxxx)，提问：用stream怎么写？有什么好的关于stream的资料吗？？

Answer 1

GroupBy是个Collector，它是用来进行Stream上的collect操作的。Collect是一个Mutable Reduction。 所谓reduction，相当于把集合里的每一个元素依次带入一个函数，最终得到一个值。比如求一组int的和，可以用reduction写作。 int sum = numbers.stream().reduce(0, (sum,n) -> sum+n); 其中0是初始和，函数（sum,n)->sum+n 对每个整数调用，最终得到所有数的和。 而所谓Mutable Reduction。是指最终产生的值是个可变的对象，比如list。 回到GroupBy, 它会根据条件把数据产生为Map<条件，List<数据>>的形式。所以如果用GroupBy做到你想要达到的效果，可以这样写： List<User> users = Arrays.asList(newUser(20), newUser(35), newUser(20)); List<User> groupedUsers = users.stream() .collect(Collectors.groupingBy(User::getAge)) //Map {20: [user{count:1, age:20}, user{count:1, age:20}]}, {35: [user{count:1, age:35}] .entrySet() //Map变为entry列表，方便继续Stream操作 .stream().map( (entry) -> new User(entry.getValue().size(), entry.getKey())) //根据Entry产生新的User，list的长度是新的Count，key值是age .sorted(Comparator.comparingInt(User::getAge)) //排序是为了方便后面验证结果 .collect(Collectors.toList()); //从Stream变回list assertEquals(2, groupedUsers.size()); assertEquals(20, groupedUsers.get(0).getAge()); assertEquals(2, groupedUsers.get(0).getCount()); assertEquals(35, groupedUsers.get(1).getAge()); assertEquals(1, groupedUsers.get(1).getCount()); 当然也可以直接写collect的逻辑，不使用GroupBy产生的Map。 List<User> groupedUsers = users.stream().collect( ArrayList<User>::new, //初始的list (list, user)-> { //对每个User调用的函数 Optional<User> ageAdded = list.stream() .filter(u1 -> u1.getAge() == user.getAge()) .findAny(); //查找是否已经加入list了 if ( ageAdded.isPresent() ) { //如果这个age已经在list了，修改user的count值 User counted = ageAdded.get(); counted.setCount(counted.getCount()+1); } else { //加入新的user list.add(new User(user.getCount(), user.getAge())); } }, ArrayList<User>::addAll //合并各小段user list的函数，不并行处理Stream的话不会用到 ); 可以看到因为要找list里已经加入的user，所以这样写也并不简单，而且可能比map更加低效。

Answer 2

用下面思路：stream是在可遍历对象上应用。如果需要分组就用groupingBy。