1

我有时需要一次更新许多文档，10K 甚至更多，我在想每种方式的优点/缺点是什么？

我想到了两种方法，我很乐意了解什么是优势/劣势并以第三种方式听到。

我正在寻找一种好的批处理方式来做到这一点。

方式1，发送到observable以获取所有文件并完成工作：

Observable
            .from(ids)
            .flatMap(new Func1<String, Observable<JsonDocument>>() {
                @Override
                public Observable<JsonDocument> call(String id) {
                    return bucket.async().get(id);
                }
            })
            .map(new Func1<JsonDocument, JsonDocument>() {
                @Override
                public JsonDocument call(JsonDocument original) {
                    // do some change in the document content
                    original.content().put("add", "content");
                    return original;
                }
            })
            .flatMap(new Func1<JsonDocument, Observable<JsonDocument>>() {
                @Override
                public Observable<JsonDocument> call(JsonDocument modified) {
                    return bucket.async().replace(modified);
                }
            }).subscribe();

方式2，在每个文档ID上运行并使用异步获取，然后更改文档异步方式：

for (String id : ids){
        bucket.async()
                .get(id)
                .map(new Func1<JsonDocument, JsonDocument>() {
                    @Override
                    public JsonDocument call(JsonDocument jsonDocument) {
                    // do some change in the document content
                        jsonDocument.content().put("add", "content");
                        return jsonDocument;
                    }
                })
                .flatMap(new Func1<JsonDocument, Observable<JsonDocument>>() {
                    @Override
                    public Observable<JsonDocument> call(JsonDocument modified) {
                        return bucket.async().replace(modified);
                    }
                }).subscribe();
    }
4

1 回答 1

1

这可以使用一点性能基准测试，但我认为这两种方法都很好，并且性能应该相对接近。

在这两种情况下使用bucket.async()确保在内部，请求将迅速在 ringBuffer 中排队并发送到服务器。

第三种方式类似于选项 2，但使用阻塞 API，这肯定会表现得更差。

总而言之，选项 1 纯粹是 Rx，虽然在 中可能会产生一点开销，但Observable.from也许它提供了最连贯的可读性，所以我会使用这个。另外，您可以获得单个流和订阅，因此您只需支付一次开销。

于 2015-02-25T13:52:51.453 回答