Java中Stream流的基本操作
目录
Stream流的思想和生成方式
1、生成流
通过数据源(集合,数组等)生成流。如：list.stream()；
2、中间操作
一个流后面可以跟随零个或多个中间操作，其目的主要是打开流，做出某种程度的数据过滤/映射，然后返回一个新的流，交给下一个操作使用如：filter()；
3、终结操作
一个流只能有一个终结操作，当这个操作执行后，流就被使用“光”了，无法再被操作。所以这必定是流的最后一个操作如：forEach；
Stream流的常见生成方式
1、Collection体系（List，Set）的集合可以使用默认方法stream()生成流 default Stream<E> stream()
//Collections下的list与set 的Stream流
List<String> list = new ArrayList<String>();
Stream listStream =list.stream();
Set<String> set = new HashSet<String>();
Stream setStream = set.stream();
2、Map体系的集合间接的生成流
// Map下的Stream流(间接生成流)
Map map = new HashMap();
Stream key = map.keySet().stream();
Stream value = map.values().stream();
Stream kv = map.entrySet().stream();3、数组可以通过Stream接口的静态方法of(T... values)生成流
//数组可以通过Stream接口的静态方法of（T...values）生成流
String[] string = {"wangbadn","giao"};
Stream stra = Stream.of(string);
Stream star2 = Stream.of("而是能够","hfjksdhfjks");
Stream stream = Stream.of(10,23,34);Stream流的常见中间操作方法：
1、Stream<T> filter(Predicate predicate)：用于对流中的数据进行过滤
list.stream().filter(s -> s.startsWith("王")).filter(s -> s.length()==3).forEach(s -> System.out.println(s));2、Stream<T> limit(long maxSize)：返回此流中的元素组成的流，截取前指定参数个数的数据
//取前三个数据在控制台输出
list.stream().limit(3).forEach(System.out::println);3、Stream<T> skip(long n)：跳过指定参数个数的数据，返回由该流的剩余元素组成的流
//跳过三个元素，把剩下的元素在控制台输出
list.stream().skip(3).forEach(System.out::println);//跳过2个元素，把剩下的元素在前两个在控制台输出
list.stream().skip(2).limit(2).forEach(System.out::println);4、static <T> Stream<T> concat(Stream a, Stream b)：合并a和b两个流为一个流
//取前4个元素组成一个流
Stream<String> s1 = list.stream().limit(4);
//跳过2个元素组成一个流
Stream<String> s2 = list.stream().skip(2);
//合并需求1和需求2得到的流，并把结果在控制台输出
Stream.concat(s1,s2).forEach(System.out::println);5、Stream<T> distinct()：返回由该流的不同元素（根据Object.equals(Object) ）组成的流
//合并需求1和需求2得到的流，并把结果在控制台输出，要求字符串元素不能重复
Stream.concat(s1,s2).distinct().forEach(System.out::println);6、Stream<T> sorted()：返回由此流的元素组成的流，根据自然顺序排序
//按照字母顺序把数据在控制台输出
list.stream().sorted().forEach(System.out::println);7、Stream<T> sorted(Comparator comparator)：返回由该流的元素组成的流，根据提供的Comparator进行排序
//按照字符长度把数据在控制台输出
list.stream().sorted((s11,s22) -> s11.length()-s22.length()).forEach(System.out::println);
//但是这样的话后面不能按照自然顺序排序所以使用下面的方式会更好
list.stream().sorted((s11,s22) -> {
int num1 = s11.length()-s22.length();
int num2 = num1 == 0?s11.compareTo(s22):num1;
return num2;
}).forEach(System.out::println);8、<R> Stream<R> map(Function mapper)：返回由给定函数应用于此流的元素的结果组成的流；IntStream mapToInt(ToIntFunction mapper)：返回一个IntStream其中包含将给定函数应用于此流的元素的结果
//将集合中的字符串数据转换成整数之后在控制台输出
list.stream().map(s -> Integer.parseInt(s)).forEach(System.out::println);
// 方法引用改写
list.stream().map(Integer::parseInt).forEach(System.out::println);
list.stream().mapToInt(Integer::parseInt).forEach(System.out::println);
// int sum() 返回此流中元素的总和。 注意：此方法是IntStream流里面的方法
int result = list.stream().mapToInt(Integer::parseInt).sum();
System.out.println(result);Stream流的常见终结操作方法
1、void forEach(Consumer action)：对此流的每个元素执行操作
//把集合中的元素在控制台输出
list.stream().forEach(System.out::println);
long count()：返回此流中的元素数
//统计集合中有几个王开头的元素，并且把统计结果在控制台输出
long giao = list.stream().filter(s -> s.startsWith("王")).count();Stream流的练习
现在有两个ArrayList集合，分别存储6名男演员名称和6名女演员名称，要求完成如下的操作
- 男演员只要名字为3个字的前三人
- 女演员只要姓林的，并且不要第一个
- 把过滤后的男演员姓名和女演员姓名合并到一起
- 把上一步操作后的元素作为构造方法的参数创建演员对象,遍历数据
演员类Actor已经提供，里面有一个成员变量，一个带参构造方法，以及成员变量对应的get/set方法
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Stream;
public class StreamDemo3 {
public static void main(String[] args) {
List<String > list1 = new ArrayList<>();
List<String > list2 = new ArrayList<>();
list1.add("沈1宝1");
list1.add("沈宝2");
list1.add("沈宝3");
list1.add("沈宝4");
list1.add("沈宝5");
list1.add("沈宝6");
list2.add("贾平1");
list2.add("贾平2");
list2.add("贾平3");
list2.add("贾平4");
list2.add("贾平5");
list2.add("贾平6");
//男生只要名字为三个字的前三人
Stream<String> Man = list1.stream().filter(s -> s.length() == 3).limit(3);
//女生只要姓贾的，并且不要第一个
Stream<String> Woman = list2.stream().filter(s -> s.startsWith("贾")).skip(1);
//把过滤后的男生姓名和女生姓名合并到一起
Stream<String> s1 = Stream.concat(Man,Woman);
// 把上一步操作后的元素作为构造方法的参数创建男女对象,遍历数据
// s1.map(Actor::new).forEach(System.out::println);
s1.map(Actor::new).forEach(p -> System.out.println( p.getName()));
//简化写法
Stream.concat(list1.stream().filter(s -> s.length() == 3).limit(3)
,list2.stream().filter(s -> s.startsWith("贾")).skip(1)).map(Actor::new)
.forEach(p -> System.out.println(p.getName()));
}
}
class Actor {
String name;
public Actor(String name){
this.name = name;
}
public void setName(String name){
this.name = name;
}
public String getName(){
return name;
}
}Stream流的收集操作
对数据使用Stream流的方式操作完毕后，我想把流中的数据收集到集合中，该怎么办呢？
Stream流的收集方法
1、 public static <T> Collector toList()：把元素收集到List集合中
// 得到名字为三个字的流
Stream<String> ss1= list1.stream().filter(s -> s.length()==4);
// 把使用Stream流操作完毕的数据收集到list集合中
List<String> names = ss1.collect(Collectors.toList());
for(String s : names){
System.out.println(s);
};2、public static <T> Collector toSet()：把元素收集到Set集合中
创建set集合对象
Set<Integer> set = new HashSet<Integer>();
set.add(10);
set.add(20);
set.add(30);
set.add(31);
set.add(33);
set.add(35);
// 得到年龄大于25的流
Stream<Integer> ages = set.stream().filter(age -> age > 25);
// 把使用Stream流操作完毕的数据收集到Set集合中并遍历
Set<Integer> age1 = ages.collect(Collectors.toSet());
for (Integer a: age1) {
System.out.println(a);
}3、 public static Collector toMap(Function keyMapper,Function valueMapper)：把元素收集到Map集合中
String[] strings = {"王飞,30","李易峰,25","周杰伦,34","小李子,87"};
//得到字符串中年龄数据大于28的流
Stream<String> arrayStream = Stream.of(strings).filter(s -> Integer.parseInt(s.split(",")[1]) > 28);
//把使用Stream流操作完毕的数据收集到Map集合中并遍历,z字符串中的姓名作键，年龄做值
Map<String, Integer> map = arrayStream.collect(Collectors.toMap(s -> s.split(",")[0]
, s -> Integer.parseInt(s.split(",")[1])));
Set<String> keySet = map.keySet();
for (String key:keySet) {
Integer value = map.get(key);
System.out.println(key+","+value);
}