【Java】Stream流是什么，如何使用Stream流？

浅浅的花香味﹌ 2024-03-27 18:46 212阅读 0赞

![在这里插入图片描述][8d8e0d8a542946af858489a536162608.gif_pic_center]

> 个人简介：Java领域新星创作者；阿里云技术博主、星级博主、专家博主；正在Java学习的路上摸爬滚打，记录学习的过程~  
> 个人主页：[.29.的博客][.29.]  
> 学习社区：[进去逛一逛~][Link 1]

> ![在这里插入图片描述][6eeaa7de0ec543809fe27b56796c8dc5.png_pic_center]

#### Stream流 ####

--------------------

`Stream流`：

*  Stream流结合了Lambda表达式，简化了集合、数组的操作。
 *  
 *  ①**使用步骤：**
 *   *  ①得到一条`Stream流`，并将数据放上去。
     *  ②使用`中间方法`对流水线上的数据进行操作。
     *  ③使用`终结方法`对流水线上的数据进行操作。
     *  小案例：
     *   *      import java.util.ArrayList;
                
                public class StreamDemo {
                          
                	public static void main(String[] args) {
                          
                		/*
                		 * 创建集合、添加元素，使用Stream流，
                		 * ①将开头为“张”的元素添加进新集合
                		 * ②之后将长度为3的元素添加进新集合
                		 * ③遍历
                		 */
                		
                		ArrayList<String> list = new ArrayList<>();
                		list.add("张三丰");
                		list.add("张无忌");
                		list.add("张强");
                		list.add("王麻子");
                		list.add("小李");
                		
                		//获取对象stream流，添加过滤条件，遍历
                		list.stream()
                		    .filter(name -> name.startsWith("张"))
                		    .filter(name -> name.length() == 3)
                		    .forEach(name -> System.out.println(name));
                	}
                }
 *  
 *  ②**获取Stream流：**
 *   *  `default Stream<E> stream()`：单列集合获取Stream流（Collection的默认方法）
     *  `public static <T> Stream<T> stream(T[] array)`：数组获取Stream流（Arrays工具类中的静态方法）
     *  `public static <T> stream<T> of(T... values)`：获取一堆零散数据的Stream流（Stream接口中的静态方法，数据需要统一类型）
     *  **双列集合**无法直接获取Stream流，需要先使用`keySet() / entrySet()`再对获取到的集合使用`stream()`获取。
 *  
 *  ③**Stream流中间方法：**
 *   *  `Stream<T> filter(Predicate<? super T> predicate)`：过滤
     *  `Stream<T> limit(long maxSize)`:Stream流获取前maxSize个元素
     *  `Stream<T> skip(long n)`：跳过前n个元素获取元素
     *  `Stream<T> distance()`：元素去重，**依赖HashCode() 和 equals()**
     *  `static <T> Stream<T> concat(Stream a,Stream b)`：将两个流合并为一个流
     *  `Stream<R> map(Function<T,R> mapper)`：转换流中的数据类型，参数是函数式的，需重写其方法以设置转换规则，泛型依次是原本类型，转换的类型。
     *   *  中间方法、返回新的Stream流，流只能使用一次，建议链式编程。
         *  修改Stream流中的数据，原本集合或数组的数据不变。
 *  
 *  ④**Stream流的终结方法：**
 *   *  `void forEach(Consumer action)`：遍历
     *  `long count()`：统计
     *  `toArray()`：将流中的数据放入数组
     *  `collect(Collector collector)`：将流中的数据放入集合
     *   *  Collectors.toList()
         *  Collectors.toSet()
         *  Collectors.toMap(a,b)：a，b两个函数式接口，需要编写匿名内部类，重写方法，指定数据转换规则。
     *  案例：
     *      import java.util.ArrayList;
            import java.util.Collections;
            import java.util.HashMap;
            import java.util.Map;
            import java.util.stream.Collector;
            import java.util.stream.Collectors;
            
            public class StreamDemo {
                    
            	public static void main(String[] args) {
                    	
            		
            		/*定义集合，添加数据，留下偶数*/
            		ArrayList<Integer> listInt = new ArrayList<>();
            		Collections.addAll(listInt, 1,2,3,4,5,6,7,8,9,10);
            		listInt.stream().filter(s -> s.intValue() % 2 == 0).forEach(i -> System.out.println(i));
            		
            		System.out.println("-------------------------------");
            		
            		/*定义集合，添加姓名，年龄数据，保留年龄大于24的人，数据存入Map集合*/
            		ArrayList<String> listName = new ArrayList<>();
            		Collections.addAll(listName, "张三,18","李四,24","小品,24","小豪,29","张无忌,16","脉哦,22");
            		Map<String,Integer> mapName = listName.stream()
            		        .filter(s -> Integer.parseInt(s.split(",")[1]) >= 24)
            		        .collect(Collectors.toMap(
            		        		s -> s.split(",")[0] ,
            		        		s -> Integer.parseInt(s.split(",")[1])));
            		mapName.entrySet().forEach(s -> System.out.println(s.getKey() + "--" + s.getValue()));
            		
            		
            	}
            }
     *  ![在这里插入图片描述][020d26ed8e334b85a302a8bb0a7f9fd7.png_pic_center]

[![在这里插入图片描述][20a7f1b58dfb4660b75d7f021c157d57.png_pic_center]][20a7f1b58dfb4660b75d7f021c157d57.png_pic_center 1]

[8d8e0d8a542946af858489a536162608.gif_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/5a6118318a1641bdb391390cf26fa212.png
[.29.]: https://blog.csdn.net/ebb29bbe?spm=1018.2226.3001.5343
[Link 1]: https://bbs.csdn.net/forums/185241f773fb401b8ca7994dc3d02333?joinKey=cyru4ex9o7wq-mz6v1koj5x-1-add3ae8dc3827dbbd4360c79af92bbbe
[6eeaa7de0ec543809fe27b56796c8dc5.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/10186701d2fe4501b1ac1bcd0d0e78ee.png
[020d26ed8e334b85a302a8bb0a7f9fd7.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/ec04b75073e540cfb35e38a77258d860.png
[20a7f1b58dfb4660b75d7f021c157d57.png_pic_center]: https://img-blog.csdnimg.cn/20a7f1b58dfb4660b75d7f021c157d57.png#pic_center
[20a7f1b58dfb4660b75d7f021c157d57.png_pic_center 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/6e0acf269ee74f329a91020b311b9161.png