摘要：在編程中有時候我們需要對做一些特定業務邏輯。諸如的絕大部分都依賴于和都是推送數據詳情請看，如果本身無數據可推送，那么就不會觸發。換句話說內部是不可能得到的。那么怎么做才可以你可以使用的來作為中間值除了之外，還提供了來處理。
在Reactor編程中有時候我們需要對empty Mono做一些特定業務邏輯。下面看一段非reactor編程的代碼：
public void oldCheck(Token token) {
if (token == null) {
// business logic
return;
}
if (token.isExpired) {
// business logic
return;
}
// business logic
return;
}
如果讓你改成reactor你也許會改成這樣：
public Mono badCheck(Mono tokenMono) {
return tokenMono
.flatMap(token -> {
if (token == null) {
// CAUTION: You will never be in here
// business logic
return Mono.empty();
}
if (token.isExpired) {
// business logic
return Mono.empty();
}
// business logic
return Mono.empty();
});
}
上面的示例代碼里的注釋已經寫了if (token == null) {}的這個條件是永遠成立的，這是因為當Mono是empty時，它是不會觸發flatMap的。諸如flatMap的絕大部分Operator都依賴于Publisher（Mono和Flux都是Pubisher）推送數據（詳情請看javadoc），如果Publisher本身無數據可推送，那么就不會觸發Operator。換句話說flatMap內部是不可能得到null的。
那么怎么做才可以？你可以使用Java 8的Optional來作為中間值：
public Mono goodCheck(Mono tokenMono) {
return tokenMono
// Transform Mono to Mono>.
// If Mono is empty, flatMap will not be triggered,
// then we will get a empty Mono>
.flatMap(token -> Mono.just(Optional.of(token)))
// If Mono> is empty, provide an empty Optional,
// then we will get a non-empty Mono> anyway
.defaultIfEmpty(Optional.empty())
// Since Mono> is not empty, flatMap will always be triggered.
.flatMap(tokenOptional -> {
if (!tokenOptional.isPresent()) {
// business logic
return Mono.empty();
}
Token token = tokenOptional.get();
if (token.isExpired) {
// business logic
return Mono.empty();
}
// business logic
return Mono.empty();
});
}
除了defaultIfEmpty之外，Reactor還提供了switchIfEmpty、repeatWhenEmpty來處理empty Mono/Flux。
文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。
轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/74186.html
