Как реализовать сбор данных Asyn c в охттп с CompletableFuture - PullRequest
Новая
       38

Как реализовать сбор данных Asyn c в охттп с CompletableFuture

1 голос
/ 01 марта 2020

Я использую библиотеку с именем milo, она запрограммирована с атрибутом Java 8, как при использовании CompletableFuture.

И теперь я хочу получить данные из REST с помощью OkHttp. Но я не знать, как реализовать это с CompletableFuture. Ниже мой код 

@Override
    public void run(OpcUaClient client, CompletableFuture<OpcUaClient> future) throws Exception {
        // synchronous connect
        client.connect().get();

        List<NodeId> nodeIds = ImmutableList.of(new NodeId(2, "HelloWorld/ScalarTypes/Int32"));

        OkHttpClient okHttpClient = new OkHttpClient();
        Request.Builder requestBuilder = new Request.Builder().url("http://localhost:8080/greeting");


        for (int i = 0; i < 10; i++) {

            Request request = requestBuilder.build();
            Call call= okHttpClient.newCall(request);

            final GreetingModel[] greetingModel = {new GreetingModel()};


            call.enqueue(new Callback() {
                @Override
                public void onFailure(@NotNull Call call, @NotNull IOException e) {
                    logger.error("Writing is wrong");
                }

                @Override
                public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
                    String json = response.body().string();
                    logger.info("Connecting is good");
                    greetingModel[0] = JSON.parseObject(json, GreetingModel.class);
                }
            });

            Variant v = new Variant(greetingModel[0].getId());

            // don't write status or timestamps
            DataValue dv = new DataValue(v, null, null);

            // write asynchronously....
            CompletableFuture<List<StatusCode>> f =
                client.writeValues(nodeIds, ImmutableList.of(dv));

            // ...but block for the results so we write in order
            List<StatusCode> statusCodes = f.get();
            StatusCode status = statusCodes.get(0);

            if (status.isGood()) {
                logger.info("Wrote '{}' to nodeId={}", v, nodeIds.get(0));
            }
        }

        future.complete(client);
    }

}

И на рисунке показан результат. Операция записи опережает получение данных из охттп. результат

...