在开发过程中，我们经常会遇到需要按顺序执行一系列操作的场景，例如调用远程服务、执行本地命令等。这些操作可能成功也可能失败。一个常见的需求是，如果任何一个操作失败并返回一个特定的错误码，我们希望立即停止后续操作并返回该错误码；只有当所有操作都成功时，才返回一个表示整体成功的默认值。
传统的做法可能涉及大量的if-else语句来检查每个操作的结果，导致代码冗长且难以维护。当尝试使用Optional来简化代码时，例如在ifPresent lambda表达式中尝试return，会发现这是不允许的，因为lambda无法直接控制外部方法的流程。本文将介绍两种优雅地解决此问题的方法。
问题场景与Optional的挑战
假设我们有一个executeCmd(String command)方法，它执行一个命令并返回一个Optional<Integer>。如果命令执行失败，它会返回一个包含错误码的Optional（例如Optional.of(errorCode)）；如果命令执行成功，它会返回Optional.empty()，表示可以继续执行下一个命令。
我们期望实现以下逻辑：
立即学习“Java免费学习笔记（深入）”；
public void topMethod() {
int cr = execCmds();
// ... 对cr进行处理 ...
}
private int execCmds() {
// 期望：如果executeCmd("my command")返回错误码，则立即返回该错误码
// 否则，继续执行executeCmd("my next command")
// ...
// 如果所有命令都成功，返回0
return 0;
}
// 辅助方法，模拟命令执行
public Optional<Integer> executeCmd(String command) {
// 模拟逻辑：例如，某些命令失败，某些成功
if (command.contains("fail")) {
System.out.println("Executing: " + command + " -> Failed (code 1)");
return Optional.of(1); // 失败，返回错误码
} else if (command.contains("next fail")) {
System.out.println("Executing: " + command + " -> Failed (code 2)");
return Optional.of(2); // 失败，返回错误码
}
System.out.println("Executing: " + command + " -> Success");
return Optional.empty(); // 成功，继续
}直接在ifPresent中使用return cr;是无效的，因为lambda表达式不能中断外部方法的执行流。
解决方案一：使用 Optional.or() (JDK 9+)
Optional.or()方法是JDK 9引入的一个强大特性，它允许我们以一种声明式的方式处理Optional链。
Optional.or()工作原理
Optional.or()方法接收一个Supplier<Optional<T>>作为参数。它的行为如下：
- 如果当前Optional实例包含一个值（即isPresent()为true），那么or()方法会直接返回当前Optional实例，而不会执行Supplier中提供的逻辑。
- 如果当前Optional实例为空（即isEmpty()为true），那么or()方法会调用Supplier来获取一个新的Optional实例，并返回该实例。
这种惰性求值的特性完美契合了我们的需求：只有当前一个命令成功（返回Optional.empty()）时，才会尝试执行下一个命令。
示例代码
import java.util.Optional;
public class CommandExecutorOr {
public int execCmds() {
return executeCmd("my command") // 尝试执行第一个命令
.or(() -> executeCmd("my next command")) // 如果第一个命令成功，尝试执行第二个
.or(() -> executeCmd("another command")) // 如果第二个命令成功，尝试执行第三个
.or(() -> executeCmd("final command (fail)")) // 最后一个命令，模拟失败
.orElse(0); // 如果所有命令都成功（都返回Optional.empty()），则最终返回0
}
// 辅助方法，模拟命令执行
public Optional<Integer> executeCmd(String command) {
if (command.contains("fail")) {
System.out.println("Executing: " + command + " -> Failed (code 1)");
return Optional.of(1); // 失败，返回错误码
} else if (command.contains("next fail")) {
System.out.println("Executing: " + command + " -> Failed (code 2)");
return Optional.of(2); // 失败，返回错误码
}
System.out.println("Executing: " + command + " -> Success");
return Optional.empty(); // 成功，继续
}
public static void main(String[] args) {
CommandExecutorOr executor = new CommandExecutorOr();
System.out.println("\n--- Test Case 1: First command fails ---");
// 假设第一个命令模拟为失败
// 为了演示，这里需要修改executeCmd的内部逻辑或传入特定参数
// 实际应用中，executeCmd的失败/成功是其内部逻辑决定的
System.out.println("Result code: " + executor.execCmds()); // 预期输出 1
System.out.println("\n--- Test Case 2: All commands succeed ---");
// 为了演示，这里需要修改executeCmd的内部逻辑
// 假设所有命令都成功
// 实际运行中，如果将"final command (fail)"改为"final command"，结果会是0
// 例如，可以这样模拟：
CommandExecutorOr executor2 = new CommandExecutorOr() {
@Override
public Optional<Integer> executeCmd(String command) {
System.out.println("Executing: " + command + " -> Success");
return Optional.empty();
}
};
System.out.println("Result code: " + executor2.execCmds()); // 预期输出 0
}
}注意事项：
- 此方法要求Java 9或更高版本。
- executeCmd方法必须返回Optional<Integer>。如果返回OptionalInt，则不能直接使用or()，需要转换为Optional<Integer>或使用下一个解决方案。
- orElse(0)是最终的默认值，表示所有命令都成功执行后的结果。
解决方案二：使用 Stream of Supplier (JDK 8兼容)
对于仍在使用JDK 8的环境，或者当executeCmd返回OptionalInt而不能直接使用Optional.or()时，可以采用Stream和Supplier的组合方式。
工作原理
这种方法的核心思想是创建一个包含所有命令执行逻辑的Supplier流。每个Supplier负责调用一个executeCmd方法，并返回一个OptionalInt（或Optional<Integer>）。然后，我们通过流操作来找到第一个非空的OptionalInt。
- 创建Supplier流： 将每个executeCmd调用封装在一个Supplier中，然后将这些Supplier收集到一个Stream中。
- 惰性执行： Stream的map(Supplier::get)操作会按顺序调用每个Supplier，但由于后续的filter和findFirst操作，只有当需要时才会真正执行Supplier。
- 过滤和查找： filter(OptionalInt::isPresent)会筛选出那些包含错误码的OptionalInt。findFirst()则会获取第一个遇到的错误码。
- 默认值： orElse(0)提供一个默认的成功返回值。
示例代码
import java.util.OptionalInt;
import java.util.function.Supplier;
import java.util.stream.Stream;
public class CommandExecutorStream {
public int execCmds() {
return Stream.<Supplier<OptionalInt>>of(
() -> executeCmd("my command"),
() -> executeCmd("my next command"),
() -> executeCmd("another command"),
() -> executeCmd("final command (fail)") // 最后一个命令，模拟失败
)
.map(Supplier::get) // Stream<OptionalInt> - 惰性执行每个Supplier
.filter(OptionalInt::isPresent) // Stream<OptionalInt> - 过滤出包含值的OptionalInt
.mapToInt(OptionalInt::getAsInt) // IntStream - 将OptionalInt转换为int流
.findFirst() // OptionalInt - 获取第一个错误码
.orElse(0); // 如果没有错误码，返回0
}
// 辅助方法，模拟命令执行，返回OptionalInt
public OptionalInt executeCmd(String command) {
if (command.contains("fail")) {
System.out.println("Executing: " + command + " -> Failed (code 1)");
return OptionalInt.of(1); // 失败，返回错误码
} else if (command.contains("next fail")) {
System.out.println("Executing: " + command + " -> Failed (code 2)");
return OptionalInt.of(2); // 失败，返回错误码
}
System.out.println("Executing: " + command + " -> Success");
return OptionalInt.empty(); // 成功，继续
}
public static void main(String[] args) {
CommandExecutorStream executor = new CommandExecutorStream();
System.out.println("\n--- Test Case 1: First command fails ---");
System.out.println("Result code: " + executor.execCmds()); // 预期输出 1
System.out.println("\n--- Test Case 2: All commands succeed ---");
CommandExecutorStream executor2 = new CommandExecutorStream() {
@Override
public OptionalInt executeCmd(String command) {
System.out.println("Executing: " + command + " -> Success");
return OptionalInt.empty();
}
};
System.out.println("Result code: " + executor2.execCmds()); // 预期输出 0
}
}注意事项：
- 此方法兼容JDK 8及更高版本。
- 适用于OptionalInt，也可以稍作修改用于Optional<Integer>（将OptionalInt::isPresent改为Optional::isPresent，mapToInt改为map并处理Optional<Integer>）。
- 同样利用了惰性求值，只有在当前命令成功时才会评估下一个Supplier。
总结
无论是使用JDK 9+的Optional.or()还是JDK 8兼容的Stream of Supplier，这两种方法都提供了一种简洁、声明式且符合函数式编程风格的方式来处理链式命令执行中的早期退出逻辑。它们避免了冗余的if-else结构，提高了代码的可读性和可维护性，同时通过惰性求值确保了只有在必要时才执行后续操作。在实际项目中，应根据项目的JDK版本和具体需求选择最合适的实现方案。
