Spring web-flux 端操作返回 Mono<Void>

Question

public interface RefreshTokenReactiveRepository extends ReactiveCrudRepository<RefreshToken, Long> {

Mono<RefreshToken> findByValue(String value);

}

下一个方法在 TokenService 类中。

public Mono<TokenPair> exchangeRefreshToken(String refreshTokenValue) {
  return refreshTokenReactiveRepository.findByValue(refreshTokenValue)
    .zipWhen(
        previousRefreshToken ->
            refreshTokenReactiveRepository.deleteById(previousRefreshToken.getId())
                .then(Mono.just("")),
        (previousRefreshToken, deleteResult) -> previousRefreshToken
    )
    .map(RefreshToken::getAccount)
    .flatMap(this::generateTokenPair);
 }

我想执行refreshTokenReactiveRepository.deleteById(previousRefreshToken.getId()) 侧操作，这取决于之前的单声道结果​​（Mono<RefreshToken>）和returns Mono<Void>。然后我要 zipWhen 返回Mono<RefreshToken>。

我仅通过使用then 替换返回的Mono<Void> 值来实现这一点：

refreshTokenReactiveRepository.deleteById(previousRefreshToken.getId())
                    .then(Mono.just(""))  

那么，有没有更明确的方法来实现这个目标？在这种情况下 zipWhen 的替代方案是什么？

Answer 1

如果不需要deleteById方法的返回值，则不需要使用zip；在这里，您只想从存储库中删除以前的令牌（如果它在那里），然后返回它。像这样的东西应该可以工作：

public Mono<TokenPair> exchangeRefreshToken(String refreshTokenValue) {
    return refreshTokenReactiveRepository.findByValue(refreshTokenValue)
            .flatMap(previousRefreshToken ->
                refreshTokenReactiveRepository
                        .deleteById(previousRefreshToken.getId())
                        .thenReturn(previousRefreshToken.getAccount())
            )
            .flatMap(this::generateTokenPair);
}

您可以通过在您的存储库中添加deleteByValue 方法来简化此操作；您将删除数据存储区中的令牌并在单个数据库查询中将其取回。