Stream数据流

骑猪看日落 2022-07-13 07:46 182阅读 0赞

*  引入-forEach循环：

import java.util.ArrayList;
    import java.util.List;
    
    /** * forEach只能进行集合数据的输出，但是很多时候我们在进行集合数据输出时 * 还需要对于数据进行处理，也就是Iterator的输出。 * Created by Dujiang on 2016/12/31. */
    public class TestDemo { 
        public static void main (String[] args) {
            List<String> all = new ArrayList<>();
            all.add("张三");
            all.add("王五");
            all.add("赵六");
    
            all.forEach(System.out::println);
        }
    
    }

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

*  取得Stream对象

import java.util.ArrayList;
    import java.util.List;
    import java.util.stream.Stream;
    
    /** * Created by Dujiang on 2016/12/31. */
    public class TestDemo { 
        public static void main (String[] args) {
            List<String> all = new ArrayList<>();
            all.add("Hello");
            all.add("World");
            all.add("Good");
    
            Stream<String> stream = all.stream();//取得Stream类里面的一个对象
            System.out.println(stream.count()); //取得数据个数
        }
    
    }

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

*  消除重复数据distinct()

import java.util.ArrayList;
    import java.util.List;
    import java.util.stream.Stream;
    
    /** * Created by Dujiang on 2016/12/31. */
    public class TestDemo { 
        public static void main (String[] args) {
            List<String> all = new ArrayList<>();
            all.add("Hello");
            all.add("World");
            all.add("Good");
            all.add("Hello");
            all.add("Hello");
            all.add("Hello");
    
    
            Stream<String> stream = all.stream();//取得Stream类里面的一个对象
            System.out.println(stream.distinct().count()); //取得数据个数(去掉重复数据)
        }
    
    }

*  取消后收集数据：

import java.util.ArrayList;
    import java.util.List;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    /** * Created by Dujiang on 2016/12/31. */
    public class TestDemo { 
        public static void main (String[] args) {
            List<String> all = new ArrayList<>();
            all.add("Hello");
            all.add("World");
            all.add("Good");
            all.add("Hello");
            all.add("Hello");
            all.add("Hello");
    
    
            Stream<String> stream = all.stream();//取得Stream类里面的一个对象
          // System.out.println(stream.distinct().count()); //取得数据个数(去掉重复数据)
    
            //去除掉所有的重复数据后，形成的集合数据，里面是不包含重复内容的集合
            List<String> nA = stream.distinct().collect(Collectors.toList());
            nA.forEach(System.out::println);
        }
    
    }

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

*  数据过滤（过滤区分大小写）

import java.util.ArrayList;
    import java.util.List;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    /** * Created by Dujiang on 2016/12/31. */
    public class TestDemo {
        public static void main (String[] args) {
            List<String> all = new ArrayList<>();
            all.add("张三a");
            all.add("李四b");
            all.add("王五c");
            all.add("赵六B");
            all.add("赵大b");
            all.add("钱二c");
    
    
            Stream<String> stream = all.stream();//取得Stream类里面的一个对象
          //  System.out.println(stream.distinct().count()); //取得数据个数(去掉重复数据)
    
            //去除掉所有的重复数据后，形成的集合数据，里面是不包含重复内容的集合
    
            //在这里增加了数据的一个过滤操作，使用了断言型的函数式接口，使用了String类中的contains()方法
            List<String> nA = stream.distinct().filter((x) ->x.contains("b")).collect(Collectors.toList());
            nA.forEach(System.out::println);
        }
    
    }

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

*  将大小写统一之后，再进行过滤：

import java.util.ArrayList;
    import java.util.List;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    /** * */
    public class TestDemo {
        public static void main (String[] args) {
            List<String> all = new ArrayList<>();
            all.add("张三a");
            all.add("李四b");
            all.add("王五B");
            all.add("赵六a");
            all.add("赵大b");
            all.add("钱二c");
    
            Stream<String> stream = all.stream();//取得Stream类里面的一个对象
            //下面这段代码先把大写字母转小写，再进行过滤。
            List<String> nA = stream.distinct().map((lamd) -> lamd.toLowerCase()).filter((lamd) ->lamd.contains("b"))
                    .collect(Collectors.toList());
            nA.forEach(System.out::println);
        }
    
    }

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

*  分页处理操作：

import java.util.ArrayList;
    import java.util.List;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    /** * */
    public class TestDemo {
        public static void main (String[] args) {
            List<String> all = new ArrayList<>();
            all.add("张三a");
            all.add("李四b");
            all.add("王五B");
            all.add("赵六a");
            all.add("赵大b");
            all.add("钱二c");
    
            Stream<String> stream = all.stream();//取得Stream类里面的一个对象
            //下面这段代码先把大写字母转小写
            //skip(2).limit(6)：跨越两个，取出六个，但是跨越两个之后，只剩下四个，所以取出四个。
            List<String> nA = stream.distinct().map((lamd) -> lamd.toLowerCase()).skip(2).limit(6)
                    .collect(Collectors.toList());
            nA.forEach(System.out::println);
        }
    
    }

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

*  数据匹配：

import java.util.ArrayList;
    import java.util.List;
    import java.util.function.Predicate;
    import java.util.stream.Stream;
    
    /** *数据匹配，多个条件可以用or或者and */
    public class TestDemo { 
        public static void main (String[] args) throws Exception{
            List<String> all = new ArrayList<>();
            all.add("张三a");
            all.add("李四b");
            all.add("王五B");
            all.add("赵六a");
            all.add("赵大b");
            all.add("钱二c");
    
            Predicate<String> predicate1 = x ->x.contains("张三a") ;
            Predicate<String> predicate2 = x ->x.contains("钱二") ;
            Stream<String> stream = all.stream();//取得Stream类里面的一个对象
    
            if (stream.anyMatch(predicate1.or(predicate2))){
                System.out.println("数据匹配");
            }else {
                System.out.println("数据不匹配");
            }
        }
    
    }