Stream流

上篇文章講了Java 8 的一個(gè)新特性：Lambda表達(dá)式，在業(yè)務(wù)中若能熟練的使用，可以節(jié)省很多代碼量，看著也整潔很多。那么這篇文章將介紹另一個(gè)新特性：Stream流，不要看錯(cuò)哈?。?！不是打游戲的steam?。?/p>

1、什么是Stream流：

Stream?是Java 8 提出的一個(gè)新概念，不是輸入輸出的 Stream 流?（和IO流其實(shí)沒(méi)有任何關(guān)系哈），而是一種使用函數(shù)式編程方式在集合類(lèi)上進(jìn)行操作的工具。簡(jiǎn)而言之，是以?xún)?nèi)部迭代的方式處理集合數(shù)據(jù)的操作，內(nèi)部迭代可以將更多的控制權(quán)交給集合類(lèi)。Stream 和 Iterator 的功能類(lèi)似，只是Iterator 是以外部迭代的形式處理集合數(shù)據(jù)的操作。

當(dāng)然Stream也有自己特性：

1.不是一種數(shù)據(jù)結(jié)構(gòu)，不會(huì)存數(shù)據(jù)，只是在原數(shù)據(jù)集上定義了一組操作

2.這些操作是惰性的，即每當(dāng)訪問(wèn)到流中的一個(gè)元素，才會(huì)在此元素上執(zhí)行這一系列操作

3.因?yàn)椴槐４鏀?shù)據(jù)，故每個(gè)Stream流只能使用一次。

Stream流的實(shí)現(xiàn)圖：

2、創(chuàng)建流：

想要用Stream流來(lái)操作集合，那么就需要將數(shù)組或者集合先轉(zhuǎn)換成Stream流才可以操作

Stream的官方文檔：

https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/stream/Stream.html

先來(lái)看四個(gè)方法：

1.filter：通過(guò)lambda表達(dá)式來(lái)實(shí)現(xiàn)條件過(guò)濾

2.limit：截取流，截取一段流

3.skip：跳過(guò)流

4.distinct：去除重復(fù)

創(chuàng)建Stream:

public class Test {
    public static void main(String[] args) {
        String [] arr = {"東","南","西","北"};
        //將數(shù)組轉(zhuǎn)換成Stream
        Stream<String> stream = Arrays.stream(arr);
        stream = Stream.of(arr);
        stream = Stream.of("東","南","西","北");
        //將list集合轉(zhuǎn)換成stream
        List<String> list = Arrays.asList("aa","cc","bb","aa","dd");
        stream = list.stream();
        //排序、去重、遍歷
        list.stream().sorted().distinct().forEach(System.out::println);
        //用過(guò)Stream流操作完集合后還可以再轉(zhuǎn)換成一個(gè)新的集合
        List<String> newList = list.stream().sorted().distinct().collect(Collectors.toList());
        System.out.println(newList.toString());
    }
}

輸出：

//遍歷并去重后的結(jié)果：
aa
bb
cc
dd
//用過(guò)Stream流操作完集合后還可以再轉(zhuǎn)換成一個(gè)新的集合
[aa, bb, cc, dd]

四個(gè)方法的操作：Person類(lèi)：

這個(gè)類(lèi)代碼比較多，所有不把get/set方法寫(xiě)進(jìn)去了，大家的使用的時(shí)候別忘！！

public class Person {
    private String  name;
    private Integer age;
    private  String country;
    private  char sex;
    @Override
    public String toString() {
        return "信息表：{" +
                "name='" + name + '\'' +
                ", age=" + age +
                ", country='" + country + '\'' +
                ", sex=" + sex +
                '}';
    }
//這里節(jié)省的get/set代碼
//重寫(xiě)toString（） 和 equals 和 hashcode 方法
    @Override
    public boolean equals(Object o){
        if(this == o)
            return true;
        if(o == null || getClass() != o.getClass())
            return false;
        Person person = (Person) o;
        if(country != null){
            if(this.country.equals(person.country)){
                return  true;
            }else{
                return false;
            }
        }
        return false;
    }
    @Override
    public int hashCode(){
        return Objects.hash(country);
    }
}

測(cè)試類(lèi)：

結(jié)合了lambda表達(dá)式來(lái)寫(xiě)

public class Test {
    public static void main(String[] args) {
        List<Person> perosnList = new ArrayList<>();
        perosnList.add(new Person("王一", 30, "中國(guó)", &#39;M&#39;));
        perosnList.add(new Person("張三", 19, "美國(guó)", &#39;F&#39;));
        perosnList.add(new Person("李四", 29, "日本", &#39;F&#39;));
        perosnList.add(new Person("小美", 74, "英國(guó)", &#39;M&#39;));
        perosnList.add(new Person("熊二", 15, "意大利", &#39;F&#39;));
        perosnList.add(new Person("熊大", 66, "韓國(guó)", &#39;F&#39;));
        //返回年齡大于20歲的學(xué)生集合
        System.out.println("返回年齡大于20歲的學(xué)生集合");
        perosnList.stream().filter(p -> p.getAge() > 20).forEach(System.out::println);
        //返回年齡大于50歲的學(xué)生集合
        System.out.println("返回年齡大于50歲的集合");
        List<Person> list = perosnList.stream().filter(p -> p.getAge() > 50).collect(Collectors.toList());
        System.out.println(list);
        //返回年齡大于20歲的中國(guó)學(xué)生
        System.out.println("返回年齡大于20歲的中國(guó)人");
        perosnList.stream().filter(p -> p.getAge() > 20).filter(p -> p.getCountry().equals("韓國(guó)")).forEach(System.out::println);
        //年齡大于20  中國(guó)  性別M
        System.out.println("返回年齡大于20  中國(guó)  性別M");
        perosnList.stream().filter(p -> p.getAge() > 20 && p.getCountry().equals("中國(guó)") && p.getSex() == &#39;M&#39;).forEach(System.out::println);
    }
}

看看結(jié)果：

返回年齡大于20歲的學(xué)生集合
信息表：{name='王一', age=30, country='中國(guó)', sex=M}
信息表：{name='李四', age=29, country='日本', sex=F}
信息表：{name='小美', age=74, country='英國(guó)', sex=M}
信息表：{name='熊大', age=66, country='韓國(guó)', sex=F}
返回年齡大于50歲的集合
[信息表：{name='小美', age=74, country='英國(guó)', sex=M}, 信息表：{name='熊大', age=66, country='韓國(guó)', sex=F}]
返回年齡大于20歲的中國(guó)人
信息表：{name='熊大', age=66, country='韓國(guó)', sex=F}
返回年齡大于20 ?中國(guó) ?性別M
信息表：{name='王一', age=30, country='中國(guó)', sex=M}

小結(jié)：

使用Stream流可以容易操作數(shù)組或者集合，可以結(jié)合Lambda表達(dá)式，可以讓一句表達(dá)式整潔明了，其實(shí)既然是Java退出的新特性，那么肯定是有用處的。

3、Stream的map映射流

public class Test {
    public static void main(String[] args) {
        //map的作用是迭代取到每個(gè)list元素，再通過(guò)map里面的函數(shù)進(jìn)行相應(yīng)的操作
        List<String> list1 = Arrays.asList("a","bb","ccc","dddd");
        //通過(guò)map取到每個(gè)集合元素的長(zhǎng)度并返回
        Stream<Integer> stream = list1.stream().map(p->p.length());
        stream.forEach(System.out::println);
        System.out.println("----------------");
        List<String> userList = new ArrayList<>();
        userList.add("周杰倫.tom");
        userList.add("尼古拉斯.趙四");
        userList.add("牛頓.巴基斯");
        userList.add("趙少華.思密達(dá)");
        List<String> uList = userList.stream().map(p->p.substring(p.indexOf(".")+1,
                p.length())).collect(Collectors.toList());
        System.out.println(uList.toString());
    }
}

輸出：

1
2
3
4
----------------
[tom, 趙四, 巴基斯, 思密達(dá)]

4、Stream查找與匹配

Stream內(nèi)還有一個(gè) anyMatch(Predicate predicate)?的方法：

返回此流中的任何元素是否匹配所提供的詞

Demo:

public class Test {
    public static void main(String[] args) {
        List<String> list = Arrays.asList("周杰倫","王力宏","孫燕姿","林俊杰");
        boolean flag1 = list.stream().anyMatch(ele->ele.contains("燕"));
        System.out.println("有沒(méi)有名字包含燕的同學(xué)："+flag1);
        //判斷開(kāi)頭:
        boolean flag2 = list.stream().anyMatch(ele->ele.startsWith("王"));
        System.out.println("有沒(méi)有名字開(kāi)頭是王的同學(xué)："+flag2);
        //判斷結(jié)尾:
        boolean flag3 = list.stream().anyMatch(ele->ele.endsWith("杰"));
        System.out.println("有沒(méi)有名字結(jié)尾是杰的同學(xué)："+flag3);
        // anyMatch是匹配所有的，要滿(mǎn)足條件
        boolean flag4 = list.stream().anyMatch(ele->ele.length()>2);
        System.out.println("所有同學(xué)的名字都是兩個(gè)字以上的嗎"+flag4);
        boolean flag5 = list.stream().anyMatch(ele->ele.startsWith("王"));
        System.out.println("所有同學(xué)的名字都有王嗎？"+flag5);
        //noneMatch
        boolean flag6 = list.stream().noneMatch(ele->ele.contains("燕"));
        System.out.println("集合中都沒(méi)有包含&#39;燕&#39;這個(gè)字嗎"+flag5);
    }
}

輸出：

有沒(méi)有名字包含燕的同學(xué)：true
有沒(méi)有名字開(kāi)頭是王的同學(xué)：true
有沒(méi)有名字結(jié)尾是杰的同學(xué)：true
所有同學(xué)的名字都是兩個(gè)字以上的嗎t(yī)rue
所有同學(xué)的名字都有王嗎？true
集合中都沒(méi)有包含'燕'這個(gè)字嗎t(yī)rue

使用anyMatch()里面的方法可以很容易對(duì)這個(gè)流的信息匹配。

以上是分析Java中的Stream流實(shí)例的詳細(xì)內(nèi)容。更多信息請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！