首页 文章

JDK8函数式编程一个函数可以抛出异常吗？

提问于
浏览 次
3

我有一个要求

  • 从员工存储库中获取员工信息 .

  • 使用一些其他信息更新员工信息 .

  • 将employee对象转换为gatewayRequest对象 .

  • 调用网关服务并获取响应 .

  • 从响应中获取网关调用的返回码 .

对于这个要求，我使用函数式编程来实现结果 .

在这里，我在Service层中创建了多个函数

final Function<String, Employee> getRegisteredEmployee =
        localId -> employeeRepository.findById(employeeId).
                orElseThrow(() -> new ResourceNotFoundException("ResourceNotFound"));

final Function<Employee, Employee> updateEmployeAddressandSave =
        employe -> {
            String status = //some logic to identitythe Employee
            Employee e = new Employee(employee.getName(),employee.getAddress ,"INTERNAL_EMPLOYEE")
            Employee emp = employeeRepository.save(e);
            return emp;
};

同样，我创建了不同的函数，然后我使用函数接口的 andThen 方法来获得结果

getRegisteredEmployee.
       andThen(updateEmployeAddressandSave).
       andThen(transformTheEmployeeToGatewayRequest).
       andThen(allgateWayClinet).apply(12);

根据函数式编程模型，函数应该输入并给出一些输出;它不应该抛出任何异常 . 但在我的例子中，如果找不到员工， getRegisteredEmployee 会抛出异常 .

因此，我不遵循函数式编程核心原则吗？

在函数式编程中抛出异常的另一种方法是什么？

java-8 functional-programming

2 回答

  • 1

    虽然不遵守原则，但在技术上可以创建一个抛出已检查异常的功能界面 .

    @FunctionalInterface
interface CheckedFunction<A, B> {
  B apply(A a) throws Exception;
}

    （因为你正在使用 andThen ，你需要使用 default 关键字来实现它 . 但是，请记住，功能接口必须至多有一个非默认方法，所以你必须提供 andThen 实现默认 . ）

    所以，举个例子，你可以做类似的事情：

    public void doThings(Integer id) throws Exception {

    CheckedFunction<Integer, Employee> fn = (id) -> someMethodThatReturnsAnEmployeeOrThrows(id);

    fn.apply(id)
      .map( ... ) // ... some other stuff

}

    正如我所提到的，这不符合原则;当我绝对不得不冒泡这个例外时，我才会走这条路 . 在这种情况下，其他Java 8功能（例如 Optional ）更合适 . （因为它看起来像你're using spring'的JPA实现，你可以定义你的 findById 方法来返回一个 Optional<Employee> . ）

    回复于
  • 0

    方法getRegisteredEmployee可以返回Optional对象而不是抛出异常 .

    final Function<String, Employee> getRegisteredEmployee =
        localId -> employeeRepository.findById(employeeId);

final Function<Employee, Employee> updateEmployeAddressandSave =
        employe -> {
            if(employe.isPresent()) {
                employe.get();
               ...
               String status = //some logic to identitythe Employee
               Employee e = new Employee(employee.getName(),employee.getAddress ,"INTERNAL_EMPLOYEE")
               Employee emp = employeeRepository.save(e);
               return new Optional(emp);
            } else {
               return Optional.empty();
            }
};

etc...
    回复于

相关问题