如何将Redisson的RFuture转换为CompletableFuture以兼容原有接口？

要保持原有接口返回CompletableFuture的要求，你可以通过以下几种方式将Redisson返回的CompletionStage转换为CompletableFuture：

方法一：使用Java 9+的CompletableFuture.completedStage() #

Java 9及以上版本提供了直接转换的静态方法，代码简洁高效：

public CompletableFuture<YourValueType> get(String key) {
    CompletionStage<YourValueType> redissonStage = rMapCache.getAsync(key);
    return CompletableFuture.completedStage(redissonStage);
}

这个方法会将传入的CompletionStage包装为一个CompletableFuture，自动同步其完成状态和结果。

方法二：手动包装（兼容Java 8） #

如果你的项目仍在使用Java 8，可以手动创建CompletableFuture并绑定CompletionStage的回调：

public CompletableFuture<YourValueType> get(String key) {
    CompletableFuture<YourValueType> resultFuture = new CompletableFuture<>();
    rMapCache.getAsync(key)
        .whenComplete((value, throwable) -> {
            if (throwable != null) {
                resultFuture.completeExceptionally(throwable);
            } else {
                resultFuture.complete(value);
            }
        });
    return resultFuture;
}

这种方式通过whenComplete监听Redisson异步操作的结果，将结果或异常传递给新创建的CompletableFuture。

方法三：类型判断优化 #

如果Redisson返回的CompletionStage实际已经是CompletableFuture的实现（部分场景下可能如此），可以先做类型判断避免不必要的包装：

public CompletableFuture<YourValueType> get(String key) {
    CompletionStage<YourValueType> stage = rMapCache.getAsync(key);
    if (stage instanceof CompletableFuture) {
        return (CompletableFuture<YourValueType>) stage;
    }
    // 否则执行手动包装逻辑
    CompletableFuture<YourValueType> resultFuture = new CompletableFuture<>();
    stage.whenComplete((value, throwable) -> {
        if (throwable != null) {
            resultFuture.completeExceptionally(throwable);
        } else {
            resultFuture.complete(value);
        }
    });
    return resultFuture;
}

注意事项 #

• 转换后的CompletableFuture会完全同步原CompletionStage的执行状态，包括正常结果和异常信息，不会破坏原有逻辑。
• 如果原有代码依赖CompletableFuture的特有方法（如complete()、cancel()等），必须确保转换后的对象是真正的CompletableFuture实例，避免类型转换异常。

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