代码之家 › 专栏 › 技术社区 › user432024

RX Java 2如何跟踪每个事件的总处理时间?

vert.x rx-java2 rx-java

user432024 · 技术社区 · 6 年前

我有下面的代码,我想跟踪httpRequest花费了多少时间并记录下来。

在顺序代码中,我们通常标记开始、执行和标记结束,最后 (结束时间-开始时间) .

它应该能够打印成功或失败所花费的时间。

io.reactivex.Flowable
    .fromIterable(records.records())
    .parallel(5)
    .flatMap(record -> {
                Single<HttpResponse<String>> request = client
                        .get(xxxxxx, "xxx.xxx.xxx.xxx" , "/xxxxxxx")
                        .as(BodyCodec.string())
                        .rxSend();

                return request.toFlowable();
            }
    )
    .sequential()
    .subscribe(record -> {
        System.out.println(record.body());
    }, ex -> {
        ex.printStackTrace();
    });

我设法做到了这样。但不包括例外情况,这是正确的方向吗?

io.reactivex.Flowable
    .fromIterable(records.records())
    .parallel(5)
    .flatMap(record -> {
        Single<HttpResponse<String>> request = client
                .get(xxxxxx, "xxx.xxx.xxx.xxx" , "xxxxxx")
                .as(BodyCodec.string())
                .rxSend();

        MyWrapper wrapper = new MyWrapper(System.currentTimeMillis(), request);

        return Flowable.just(wrapper);
            }
    )
    .sequential()
    .subscribe(record -> {
        long startTime = record.getStartTime();

        record.getHttpResponse().toFlowable().subscribe(t -> {
            long endTime = System.currentTimeMillis();
            System.out.println("Took: " + (endTime - startTime) + " - " + t.body());
                });


    }, ex -> {
        ex.printStackTrace();
    });

谢谢

1 回复 | 直到 6 年前

user432024 6 年前

这个把戏演得很好…

.flatMap(record -> {
        Single<HttpResponse<String>> request = client
                .get(xxxxxx, "xxxxxx", "xxxxxx")
                .as(BodyCodec.string())
                .rxSend();

        final long startTime = System.currentTimeMillis();

        return request.toFlowable()
                .doOnError(ex -> {
                    long endTime = System.currentTimeMillis();

                    System.out.println("Took: " + (endTime - startTime));

                    ex.printStackTrace();
                })
                .doOnComplete(() -> {
                    long endTime = System.currentTimeMillis();

                    System.out.println("Took: " + (endTime - startTime));
                });
    }
)