1
Java SDKでcouchbase 4.0.1を使用しています。Couchbaseはレプリカから取得
これは私のコードです:
bucket.async()
.get(key)
.onErrorResumeNext(throwable -> {
if (throwable instanceof TimeoutException) {
return getBucket().async().getFromReplica(key, ReplicaMode.ALL);
}
return Observable.error(throwable);
})
.map(doc -> doc.content())
.toBlocking()
.singleOrDefault(null);
私はTimeoutExceptionを取得する場合 - 私は、サーバの問題が原因のレプリカが、先週、に行き、私達は私達のサーバーのいずれかからのOutOfMemory例外が発生しました。もちろん、私たちはレプリカからドキュメントを取得していないし、私たちはいくつかの例外を抱えていました。
例外の有無を確認するにはどうすればよいですか?常にレプリカに行く
おかげで、
イド