Java 8 核心新特性实战教程

Java 8 是 Java 发展史上最具里程碑意义的版本之一。它引入了函数式编程思想，极大地简化了代码编写，提升了开发效率和系统性能。本教程将带你深入掌握 Java 8 的核心特性，并通过实战示例让你快速上手。

一、 Lambda 表达式：开启函数式编程之门

Lambda 表达式是 Java 8 最核心的特性，它允许你将代码视为数据，使代码更加简洁、可读。

什么是 Lambda 表达式？

Lambda 表达式本质上是一个匿名函数，它可以作为参数传递，或作为方法的返回值。它极大地简化了函数式接口（只有一个抽象方法的接口）的实现。

基本语法

(parameters) -> expression或(parameters) -> { statements; }

示例：从匿名类到 Lambda

假设我们要对一个字符串列表进行排序。

Java 7 及之前（使用匿名类）

List<String>names=Arrays.asList("Steve","Tim","Lucy","Patricia","Ella");Collections.sort(names,newComparator<String>(){@Overridepublicintcompare(Stringa,Stringb){returnb.compareTo(a);// 降序}});

Java 8（使用 Lambda 表达式）

List<String>names=Arrays.asList("Steve","Tim","Lucy","Patricia","Ella");Collections.sort(names,(a,b)->b.compareTo(a));// 或者更简洁地使用方法引用Collections.sort(names,Comparator.reverseOrder());

可以看到，Lambda 表达式让代码变得极其简洁。

四大核心函数式接口

Java 8 在java.util.function包中定义了四个最常用的函数式接口，它们是 Lambda 编程的基石。

示例

// Predicate: 判断字符串是否以'a'开头Predicate<String>predicate=s->s.startsWith("a");System.out.println(predicate.test("apple"));// true// Consumer: 打印字符串Consumer<String>consumer=s->System.out.println(s);consumer.accept("Hello, Lambda!");// Hello, Lambda!// Function: 将字符串转换为大写Function<String,String>function=s->s.toUpperCase();System.out.println(function.apply("hello"));// HELLO// Supplier: 提供一个随机数Supplier<Double>supplier=()->Math.random();System.out.println(supplier.get());

二、 Stream API：声明式数据处理

Stream API 是 Java 8 引入的用于处理集合数据的强大工具。它允许你以声明式的方式对数据进行过滤、映射、排序、聚合等操作，代码更清晰、更易于并行化。

核心概念

• 声明式：你只需告诉程序“做什么”，而不是“怎么做”。
• 管道：Stream 操作分为中间操作（如filter,map）和终止操作（如collect,forEach）。中间操作会返回一个新的 Stream，可以链式调用；终止操作会消费 Stream 并产生结果。
• 惰性求值：中间操作不会立即执行，只有当终止操作被调用时，整个处理流程才会真正开始。

创建 Stream

// 从集合创建List<String>list=Arrays.asList("apple","banana","orange");Stream<String>streamFromList=list.stream();// 从数组创建String[]array={"cat","dog","mouse"};Stream<String>streamFromArray=Arrays.stream(array);// 使用 Stream.of()Stream<String>streamOfValues=Stream.of("red","green","blue");

常用操作实战

让我们通过一个订单处理的例子来体验 Stream 的强大。

importjava.math.BigDecimal;importjava.util.*;importjava.util.stream.Collectors;classOrder{privateLonguserId;privateBigDecimalorderAmount;privateintorderStatus;// 1: paid, 0: unpaidprivateDatecreateTime;privateStringorderNo;// 构造函数、Getter 和 Setter 省略publicOrder(LonguserId,BigDecimalorderAmount,intorderStatus,DatecreateTime,StringorderNo){this.userId=userId;this.orderAmount=orderAmount;this.orderStatus=orderStatus;this.createTime=createTime;this.orderNo=orderNo;}publicLonggetUserId(){returnuserId;}publicBigDecimalgetOrderAmount(){returnorderAmount;}publicintgetOrderStatus(){returnorderStatus;}publicDategetCreateTime(){returncreateTime;}publicStringgetOrderNo(){returnorderNo;}}publicclassStreamExample{privatestaticfinalList<Order>ORDER_LIST=Arrays.asList(newOrder(1L,newBigDecimal("100.00"),1,newDate(),"ORD001"),newOrder(2L,newBigDecimal("250.50"),0,newDate(),"ORD002"),newOrder(1L,newBigDecimal("80.00"),1,newDate(),"ORD003"),newOrder(3L,newBigDecimal("500.00"),1,newDate(),"ORD004"));publicstaticvoidmain(String[]args){// 1. 筛选与映射：获取所有已付款订单的订单号List<String>paidOrderNos=ORDER_LIST.stream().filter(order->order.getOrderStatus()==1)// 筛选已付款.map(Order::getOrderNo)// 映射为订单号.collect(Collectors.toList());// 收集到列表System.out.println("已付款订单号: "+paidOrderNos);// 2. 聚合统计：计算订单总金额BigDecimaltotalAmount=ORDER_LIST.stream().map(Order::getOrderAmount).reduce(BigDecimal.ZERO,BigDecimal::add);System.out.println("订单总金额: "+totalAmount);// 3. 分组统计：按用户ID分组，统计每个用户的订单数量Map<Long,Long>userOrderCountMap=ORDER_LIST.stream().collect(Collectors.groupingBy(Order::getUserId,Collectors.counting()));System.out.println("用户订单数量统计: "+userOrderCountMap);// 4. 排序：按订单金额降序排序List<Order>sortedOrderList=ORDER_LIST.stream().sorted(Comparator.comparing(Order::getOrderAmount).reversed()).collect(Collectors.toList());System.out.println("按金额降序排序的订单: "+sortedOrderList.stream().map(Order::getOrderNo).collect(Collectors.toList()));}}

三、 全新的日期时间 API (java.time)

旧的java.util.Date和java.util.Calendar存在线程不安全、设计混乱等问题。Java 8 引入了全新的java.time包，提供了清晰、不可变且线程安全的日期时间类。

核心类

• LocalDate: 表示日期，不含时区（如 2026-04-02）。
• LocalTime: 表示时间，不含时区（如 16:19:58）。
• LocalDateTime: 表示日期和时间，不含时区（如 2026-04-02T16:19:58）。
• ZonedDateTime: 表示带时区的日期和时间。
• DateTimeFormatter: 用于格式化和解析日期时间，线程安全，替代了旧的SimpleDateFormat。

示例

importjava.time.LocalDate;importjava.time.LocalDateTime;importjava.time.format.DateTimeFormatter;publicclassDateTimeExample{publicstaticvoidmain(String[]args){// 获取当前日期和时间LocalDatedate=LocalDate.now();LocalTimetime=LocalTime.now();LocalDateTimedateTime=LocalDateTime.now();System.out.println("当前日期: "+date);System.out.println("当前时间: "+time);System.out.println("当前日期时间: "+dateTime);// 格式化日期时间DateTimeFormatterformatter=DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");StringformattedDateTime=dateTime.format(formatter);System.out.println("格式化后: "+formattedDateTime);// 解析日期时间LocalDateTimeparsedDateTime=LocalDateTime.parse("2026-04-02 16:19:58",formatter);System.out.println("解析后: "+parsedDateTime);}}

四、 接口默认方法与静态方法

Java 8 允许在接口中定义带有方法体的默认方法和静态方法，这为接口的演进提供了极大的灵活性，解决了接口升级会破坏实现类的难题。

默认方法 (default method)

使用default关键字修饰，为接口方法提供默认实现。实现类可以选择性地重写它。

interfaceVehicle{defaultvoidstart(){System.out.println("车辆正在启动...");}}classCarimplementsVehicle{// 可以重写，也可以不重写}publicclassDefaultMethodTest{publicstaticvoidmain(String[]args){CarmyCar=newCar();myCar.start();// 输出: 车辆正在启动...}}

静态方法 (static method)

接口中的静态方法只能通过接口名调用，不能被实现类继承。

interfaceVehicle{staticvoidstop(){System.out.println("车辆正在停止...");}}publicclassStaticMethodTest{publicstaticvoidmain(String[]args){Vehicle.stop();// 直接通过接口名调用}}

五、 Optional 类：优雅地处理空指针

NullPointerException是 Java 中最常见的异常。Optional是一个容器类，它可以包含一个非空的值，或者为空。它强制你显式地处理值为空的情况，从而避免空指针异常。

常用方法

• of(T value): 创建一个包含非空值的 Optional。
• ofNullable(T value): 创建一个可能为空的 Optional。
• isPresent(): 判断值是否存在。
• ifPresent(Consumer<? super T> action): 如果值存在，则执行给定的操作。
• orElse(T other): 如果值存在则返回值，否则返回other。
• map(Function<? super T, ? extends U> mapper): 如果值存在，则对其进行转换。

示例

importjava.util.Optional;publicclassOptionalExample{publicstaticvoidmain(String[]args){Stringstr=null;// 传统方式if(str!=null){System.out.println(str.length());}// 使用 OptionalOptional<String>optionalStr=Optional.ofNullable(str);optionalStr.ifPresent(s->System.out.println(s.length()));// 值存在才执行intlength=optionalStr.map(String::length).orElse(-1);// 提供默认值System.out.println("字符串长度: "+length);// 输出: 字符串长度: -1}}

六、 生产环境最佳实践与避坑指南

掌握了基本用法后，了解如何在生产环境中正确使用这些特性至关重要。

1. 严格区分流的适用场景

• 简单遍历：对于简单的循环，使用传统的for循环可能性能更高，因为 Stream 有初始化开销。
• 复杂集合操作：当需要进行多步骤的过滤、映射、聚合时，Stream 能极大提升代码可读性。
• CPU 密集型、大数据量：使用并行流 (parallelStream()) 可以充分利用多核 CPU 的性能。
• IO 密集型、阻塞型操作：禁止使用并行流，因为它会阻塞ForkJoinPool的公共线程池，影响整个应用的性能。

2. 避免自动装箱拆箱的性能损耗

处理基本数据类型（如int,long）时，优先使用IntStream,LongStream,DoubleStream等原始类型流，避免频繁的装箱和拆箱操作。

// 错误示例：会产生大量的 Integer 对象longcount=orderList.stream().map(Order::getId).count();// 正确示例：使用原始类型流，性能更高longcount=orderList.stream().mapToLong(Order::getId).count();

3. 禁止流的复用

Stream 是一次性的。调用终止操作后，Stream 就会被消费掉，再次使用会抛出IllegalStateException。

// 错误示例Stream<Order>orderStream=orderList.stream();orderStream.count();orderStream.forEach(System.out::println);// 会抛出异常// 正确示例：每次使用时重新创建流orderList.stream().count();orderList.stream().forEach(System.out::println);

4. 并行流的线程安全规范

在并行流中，禁止向非线程安全的集合（如ArrayList）中添加元素，这会导致数据丢失或并发修改异常。应始终使用collect方法来安全地收集结果。

// 错误示例：线程不安全List<Long>userIdList=newArrayList<>();orderList.parallelStream().forEach(order->userIdList.add(order.getUserId()));// 正确示例：使用 collect，线程安全List<Long>userIdList=orderList.parallelStream().map(Order::getUserId).collect(Collectors.toList());

5. 自定义并行流线程池

并行流默认使用全局的ForkJoinPool，其线程数等于 CPU 核心数。长时间运行的任务会阻塞这个公共池。对于关键任务，可以创建自定义的ForkJoinPool来实现线程隔离。

ForkJoinPoolcustomPool=newForkJoinPool(4);// 自定义线程数customPool.submit(()->orderList.parallelStream().collect(Collectors.groupingBy(Order::getUserId))).join();