如何在方法引用中处理并记录异常？以getUserByUserId为例

方法引用没办法直接加try-catch逻辑，得把它换成Lambda表达式，在Lambda里封装方法调用并处理异常。下面是两种重构方案：

方案一：直接在Stream中用Lambda处理异常 #

// 假设已初始化日志实例，比如：
// private static final Logger logger = LoggerFactory.getLogger(YourCurrentClass.class);

List<String> listofIds = ldapUsers.stream()
        .map(PersonDTO::getUserId)
        .map(userId -> {
            try {
                return userService.getUserByUserId(userId);
            } catch (NotFoundException e) {
                logger.error("无法找到用户，用户ID: {}", userId, e);
                return Optional.empty();
            }
        })
        .filter(Optional::isPresent)
        .map(Optional::get)
        .map(User::get_id)
        .collect(Collectors.toList());

改动说明 #

• 把原有的userService::getUserByUserId方法引用替换为Lambda表达式，内部嵌入try-catch块
• 捕获NotFoundException后，记录包含目标用户ID的错误日志（保留异常栈信息方便排查问题）
• 异常发生时返回Optional.empty()，后续的filter(Optional::isPresent)会自动过滤掉这些无效结果，不会影响最终列表的生成

方案二：抽离单独方法复用逻辑 #

如果这个异常处理逻辑需要在多处使用，可以把它抽成一个独立方法，再用方法引用调用：

// 抽离的异常处理方法
private Optional<User> getUserWithErrorHandling(String userId) {
    try {
        return userService.getUserByUserId(userId);
    } catch (NotFoundException e) {
        logger.error("无法找到用户，用户ID: {}", userId, e);
        return Optional.empty();
    }
}

// 重构后的Stream代码
List<String> listofIds = ldapUsers.stream()
        .map(PersonDTO::getUserId)
        .map(this::getUserWithErrorHandling)
        .filter(Optional::isPresent)
        .map(Optional::get)
        .map(User::get_id)
        .collect(Collectors.toList());

这种方式让Stream代码更简洁，也便于后续复用异常处理逻辑。

内容的提问来源于stack exchange，提问作者Deepak