这个UtilException帮助类允许您在 Java 流中使用任何已检查的异常，如下所示：
Stream.of("java.lang.Object", "java.lang.Integer", "java.lang.String")
.map(rethrowFunction(Class::forName))
.collect(Collectors.toList());
注意Class::forNamethrows ClassNotFoundException，这是选中的。流本身也会抛出ClassNotFoundException，而不是一些包装未经检查的异常。
public final class UtilException {
@FunctionalInterface
public interface Consumer_WithExceptions<T, E extends Exception> {
void accept(T t) throws E;
}
@FunctionalInterface
public interface BiConsumer_WithExceptions<T, U, E extends Exception> {
void accept(T t, U u) throws E;
}
@FunctionalInterface
public interface Function_WithExceptions<T, R, E extends Exception> {
R apply(T t) throws E;
}
@FunctionalInterface
public interface Supplier_WithExceptions<T, E extends Exception> {
T get() throws E;
}
@FunctionalInterface
public interface Runnable_WithExceptions<E extends Exception> {
void run() throws E;
}
/** .forEach(rethrowConsumer(name -> System.out.println(Class.forName(name)))); or .forEach(rethrowConsumer(ClassNameUtil::println)); */
public static <T, E extends Exception> Consumer<T> rethrowConsumer(Consumer_WithExceptions<T, E> consumer) throws E {
return t -> {
try { consumer.accept(t); }
catch (Exception exception) { throwAsUnchecked(exception); }
};
}
public static <T, U, E extends Exception> BiConsumer<T, U> rethrowBiConsumer(BiConsumer_WithExceptions<T, U, E> biConsumer) throws E {
return (t, u) -> {
try { biConsumer.accept(t, u); }
catch (Exception exception) { throwAsUnchecked(exception); }
};
}
/** .map(rethrowFunction(name -> Class.forName(name))) or .map(rethrowFunction(Class::forName)) */
public static <T, R, E extends Exception> Function<T, R> rethrowFunction(Function_WithExceptions<T, R, E> function) throws E {
return t -> {
try { return function.apply(t); }
catch (Exception exception) { throwAsUnchecked(exception); return null; }
};
}
/** rethrowSupplier(() -> new StringJoiner(new String(new byte[]{77, 97, 114, 107}, "UTF-8"))), */
public static <T, E extends Exception> Supplier<T> rethrowSupplier(Supplier_WithExceptions<T, E> function) throws E {
return () -> {
try { return function.get(); }
catch (Exception exception) { throwAsUnchecked(exception); return null; }
};
}
/** uncheck(() -> Class.forName("xxx")); */
public static void uncheck(Runnable_WithExceptions t)
{
try { t.run(); }
catch (Exception exception) { throwAsUnchecked(exception); }
}
/** uncheck(() -> Class.forName("xxx")); */
public static <R, E extends Exception> R uncheck(Supplier_WithExceptions<R, E> supplier)
{
try { return supplier.get(); }
catch (Exception exception) { throwAsUnchecked(exception); return null; }
}
/** uncheck(Class::forName, "xxx"); */
public static <T, R, E extends Exception> R uncheck(Function_WithExceptions<T, R, E> function, T t) {
try { return function.apply(t); }
catch (Exception exception) { throwAsUnchecked(exception); return null; }
}
@SuppressWarnings ("unchecked")
private static <E extends Throwable> void throwAsUnchecked(Exception exception) throws E { throw (E)exception; }
}
关于如何使用它的许多其他示例（在静态导入之后UtilException）：
@Test
public void test_Consumer_with_checked_exceptions() throws IllegalAccessException {
Stream.of("java.lang.Object", "java.lang.Integer", "java.lang.String")
.forEach(rethrowConsumer(className -> System.out.println(Class.forName(className))));
Stream.of("java.lang.Object", "java.lang.Integer", "java.lang.String")
.forEach(rethrowConsumer(System.out::println));
}
@Test
public void test_Function_with_checked_exceptions() throws ClassNotFoundException {
List<Class> classes1
= Stream.of("Object", "Integer", "String")
.map(rethrowFunction(className -> Class.forName("java.lang." + className)))
.collect(Collectors.toList());
List<Class> classes2
= Stream.of("java.lang.Object", "java.lang.Integer", "java.lang.String")
.map(rethrowFunction(Class::forName))
.collect(Collectors.toList());
}
@Test
public void test_Supplier_with_checked_exceptions() throws ClassNotFoundException {
Collector.of(
rethrowSupplier(() -> new StringJoiner(new String(new byte[]{77, 97, 114, 107}, "UTF-8"))),
StringJoiner::add, StringJoiner::merge, StringJoiner::toString);
}
@Test
public void test_uncheck_exception_thrown_by_method() {
Class clazz1 = uncheck(() -> Class.forName("java.lang.String"));
Class clazz2 = uncheck(Class::forName, "java.lang.String");
}
@Test (expected = ClassNotFoundException.class)
public void test_if_correct_exception_is_still_thrown_by_method() {
Class clazz3 = uncheck(Class::forName, "INVALID");
}
但在了解以下优点、缺点和限制之前，请不要使用它：
• 如果调用代码要处理检查的异常，您必须将其添加到包含流的方法的 throws 子句中。编译器不会再强迫你添加它，所以更容易忘记它。
• 如果调用代码已经处理了检查的异常，编译器会提醒你在包含流的方法声明中添加 throws 子句（如果你不这样做，它会说：Exception is never throw in body of相应的 try 语句）。
• 在任何情况下，您都无法将流本身包围起来以在包含该流的方法内捕获已检查的异常（如果您尝试，编译器会说：在相应的try 语句的主体中永远不会抛出异常）。
• 如果您调用的方法实际上永远不会抛出它声明的异常，那么您不应包含 throws 子句。例如：new String(byteArr, "UTF-8") 抛出 UnsupportedEncodingException，但 Java 规范保证 UTF-8 始终存在。在这里， throws 声明是一种麻烦，欢迎任何使用最少样板来使其静音的解决方案。
• 如果你讨厌检查异常并认为一开始就不应该将它们添加到 Java 语言中（越来越多的人有这种想法，而我不是其中之一），那么就不要将检查异常添加到 Java 语言中。包含流的方法的 throws 子句。然后，受检异常的行为就像未受检异常一样。
• 如果您正在实现一个严格的接口，您没有添加 throws 声明的选项，但抛出异常是完全合适的，那么包装一个异常只是为了获得抛出它的特权会导致带有虚假异常的堆栈跟踪它没有提供有关实际问题的信息。一个很好的例子是 Runnable.run()，它不会抛出任何已检查的异常。在这种情况下，您可能决定不将检查的异常添加到包含流的方法的 throws 子句中。
• 在任何情况下，如果您决定不向包含流的方法的 throws 子句添加（或忘记添加）已检查异常，请注意引发 CHECKED 异常的以下 2 个后果：
1）调用代码将无法通过名称捕获它（如果您尝试，编译器会说：异常不会在相应的try语句体中抛出）。它会冒泡，并且可能在主程序循环中被一些“catch Exception”或“catch Throwable”捕获，这可能是你想要的。
2）它违反了最小意外原则：捕获 RuntimeException 已经不足以保证捕获所有可能的异常。出于这个原因，我认为这不应该在框架代码中完成，而只能在您完全控制的业务代码中完成。
结论：我认为这里的限制并不严重，UtilException可以放心使用该类。然而，这取决于你！