關于Couchbase Java SDK的一件整潔的事情是，它建立在出色的Rx-Java庫的基礎上，這為與Couchbase服務器實例進行交互提供了一種反應性的方式，一旦掌握了它，它就非常直觀。

考慮一個我打算存儲在Couchbase中的非常簡單的json文檔：

{"key":"1","value":"one"}

和一個Java類來保存此json：

public class KeyVal {private String key;private String value;... }

以下是將KeyVal實例插入Couchbase存儲桶的代碼：

JsonObject jsonObject = JsonObject.empty().put("key", keyVal.getKey()).put("value", keyVal.getValue()); JsonDocument doc = JsonDocument.create(keyVal.getKey(), jsonObject); Observable<JsonDocument> obs = bucket.async().insert(doc);

插入的返回類型是Observable ，因此，如果需要將返回類型映射回KeyVal，則可以使用Observable類提供的廣泛映射支持。

Observable<KeyVal> obs = bucket.async().insert(doc).map(jsonDoc -> new KeyVal(jsonDoc.id(), jsonDoc.content().getString("value")));

其他API遵循類似的模式，例如。 檢索保存的文檔：

bucket.async().get(id).map(doc ->new KeyVal(doc.id(),doc.content().getString("value")));

• 如果您有興趣進一步研究此示例，請參閱我的github存儲庫中的工作示例– https://github.com/bijukunjummen/sample-karyon2-couch

資源資源

• Couchbase Java SDK ：http://docs.couchbase.com/developer/java-2.1/java-intro.html
• Rx-Java ：https://github.com/ReactiveX/RxJava
• Couchbase網站上提供了一篇關于Rx-Java的出色而簡潔的文章 ：http://docs.couchbase.com/developer/java-2.0/observables.html

翻譯自: https://www.javacodegeeks.com/2015/09/couchbase-java-sdk-with-rx-java.html

總結

以上是生活随笔為你收集整理的具有Rx-Java的Couchbase Java SDK的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。