Reactor Java从Azure Key Vault取密钥遇问题：Mono异常及授权报错

1. map操作未执行的原因 #

Reactor的Publisher（包括Mono）是惰性求值的，只有调用subscribe()触发订阅后，整个数据流才会启动执行。你当前代码仅调用map()定义了转换逻辑，但未触发订阅，因此代码不会实际运行，调试时看到的MonoLiftFuseable只是Mono的内部实现类，代表该数据流尚未被激活。

2. 订阅后出现的两个错误解决 #

错误1：Azure授权错误 AKV10000: Request is missing a Bearer or PoP token #

该错误表明ClientSecretCredential无法正确获取访问Key Vault的令牌，可能原因：

• 配置的clientId、clientSecret、tenantId存在错误，比如拼写错误、密钥过期
• 对应的服务主体（Service Principal）未被授予目标Key Vault的访问权限：需在Azure Portal的Key Vault访问策略中，为该SP添加至少"获取密钥"的权限

错误2：Reactor方法找不到 java.lang.NoSuchMethodError: reactor.core.publisher.Mono.mapNotNull(...) #

这是依赖版本冲突导致的：mapNotNull是Reactor 3.4.0及以上版本新增的方法，若你项目依赖的Reactor版本低于此，或Azure SDK依赖的高版本Reactor被项目中的低版本覆盖，就会出现该错误。

解决办法：

• 若为Spring Boot项目，利用Spring Boot的依赖管理统一Reactor版本（Spring Boot 2.4+对应Reactor 3.4+）
• 检查项目依赖树，排除冲突的低版本Reactor依赖，确保使用兼容版本
• 手动指定Reactor版本，例如在pom.xml中：

<dependency>
    <groupId>io.projectreactor</groupId>
    <artifactId>reactor-core</artifactId>
    <version>3.4.30</version> <!-- 选择兼容的稳定版本 -->
</dependency>

修正后的示例代码 #

// 主服务代码：添加subscribe触发执行，并完善错误处理
Mono<KeyVaultSecret> keyVaultSecretParam = azureKeyVaultService.retrieveParamSecret("KV_PARAMS");
keyVaultSecretParam.doOnNext(secretWithVersion -> 
        System.out.printf("Secret is returned with name %s and value %s %n",
                secretWithVersion.getName(), secretWithVersion.getValue())
    )
    .subscribe(
        unused -> {}, 
        error -> System.err.println("获取密钥失败: " + error.getMessage())
    );

注意：若仅需执行打印这类无返回值的副作用逻辑，使用doOnNext()比map()更合适，map()主要用于数据转换。

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