Java 8引入的Stream API为集合数据的处理提供了声明式的编程方式，数据过滤作为Stream API的核心操作之一，能够帮助开发者快速从集合中筛选出符合指定条件的元素，大幅简化传统循环过滤的冗余代码。
Stream API过滤的基础用法
Stream API的过滤操作通过filter方法实现，该方法接收一个Predicate函数式接口作为参数，返回一个新的Stream流，其中包含符合过滤条件的元素。基础过滤的语法结构如下：
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
public class StreamFilterDemo {
public static void main(String[] args) {
// 初始化测试数据
List<Integer> numberList = new ArrayList<>();
numberList.add(1);
numberList.add(2);
numberList.add(3);
numberList.add(4);
numberList.add(5);
// 过滤出大于2的元素
List<Integer> filteredList = numberList.stream()
.filter(num -> num > 2)
.collect(Collectors.toList());
System.out.println("过滤后的结果：" + filteredList);
}
}
上述代码中，filter(num -> num > 2)就是过滤逻辑，lambda表达式num -> num > 2实现了Predicate接口的test方法，当元素满足条件时返回true，该元素会被保留到新的流中。
多条件组合过滤
实际开发中往往需要多个条件同时判断，此时可以通过逻辑运算符组合多个过滤条件，也可以多次调用filter方法实现链式过滤。
逻辑运算符组合条件
如果多个条件是且的关系，可以直接在lambda表达式中用&&连接条件：
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
public class MultiConditionFilter {
public static void main(String[] args) {
List<Integer> numberList = new ArrayList<>();
numberList.add(1);
numberList.add(3);
numberList.add(5);
numberList.add(7);
numberList.add(8);
// 过滤出大于3且小于8的偶数
List<Integer> result = numberList.stream()
.filter(num -> num > 3 && num < 8 && num % 2 == 0)
.collect(Collectors.toList());
System.out.println("多条件过滤结果：" + result);
}
}
链式调用filter方法
也可以将每个条件拆分成独立的filter调用，代码可读性会更好：
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
public class ChainFilterDemo {
public static void main(String[] args) {
List<Integer> numberList = new ArrayList<>();
numberList.add(1);
numberList.add(3);
numberList.add(5);
numberList.add(7);
numberList.add(8);
List<Integer> result = numberList.stream()
.filter(num -> num > 3) // 第一个过滤条件：大于3
.filter(num -> num < 8) // 第二个过滤条件：小于8
.filter(num -> num % 2 == 0) // 第三个过滤条件：偶数
.collect(Collectors.toList());
System.out.println("链式过滤结果：" + result);
}
}
复杂对象的过滤场景
实际业务中更多是对自定义对象集合进行过滤，比如过滤出用户列表中年龄大于18且状态为正常的用户，示例如下：
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
// 定义用户实体类
class User {
private String name;
private int age;
private int status; // 1正常 0禁用
public User(String name, int age, int status) {
this.name = name;
this.age = age;
this.status = status;
}
public String getName() {
return name;
}
public int getAge() {
return age;
}
public int getStatus() {
return status;
}
}
public class ObjectFilterDemo {
public static void main(String[] args) {
List<User> userList = new ArrayList<>();
userList.add(new User("张三", 16, 1));
userList.add(new User("李四", 20, 1));
userList.add(new User("王五", 22, 0));
userList.add(new User("赵六", 19, 1));
// 过滤年龄大于18且状态正常的用户
List<User> validUsers = userList.stream()
.filter(user -> user.getAge() > 18 && user.getStatus() == 1)
.collect(Collectors.toList());
System.out.println("符合条件的用户：");
validUsers.forEach(user -> System.out.println(user.getName()));
}
}
过滤操作的注意事项
- Stream流只能被消费一次，调用
collect等方法后流就会关闭，再次使用会抛出异常。 filter方法是中间操作，只有遇到终止操作（如collect、forEach）时才会真正执行过滤逻辑，这是Stream的惰性求值特性。- 如果使用并行流
parallelStream进行过滤，要确保过滤条件是无状态的，避免多线程下的并发问题。 - 过滤后的结果如果需要保持原有顺序，不要随意切换并行流，并行流可能会改变元素的遍历顺序。
过滤与其他Stream操作结合
过滤操作通常会和其他Stream操作配合使用，比如先过滤再映射转换，或者先过滤再统计数量：
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
public class FilterWithOtherOps {
public static void main(String[] args) {
List<String> strList = new ArrayList<>();
strList.add("apple");
strList.add("banana");
strList.add("apricot");
strList.add("orange");
strList.add("blueberry");
// 过滤出以a开头的元素，再转换为大写，最后收集到列表
List<String> processedList = strList.stream()
.filter(str -> str.startsWith("a"))
.map(String::toUpperCase)
.collect(Collectors.toList());
System.out.println("处理后的列表：" + processedList);
// 过滤出长度大于5的元素，统计数量
long count = strList.stream()
.filter(str -> str.length() > 5)
.count();
System.out.println("长度大于5的元素数量：" + count);
}
}
JavaStream_API数据过滤lambda表达式修改时间：2026-07-04 12:21:30