Можно ли использовать Spring Batch с обработкой завершаемых фьючерсов? - PullRequest
0 голосов
/ 06 июня 2019

У меня более 30 читателей, которые могут читать до 500 уникальных тегов каждые 5 минут. Я хочу взять эти уникальные теги и проверить мою базу данных с информацией. Сейчас я читаю только 5-10 читателей одновременно. Можно ли использовать Spring Batch для создания пакетов для проверки базы данных? Я использую метод обмена resttemplate, чтобы поразить мой API. Поэтому я хотел бы отправить список тегов, используя метод обмена в мой API. Как мне это сделать? Я не смог отправить и принять список.

Я пытался отправить и принять список с моим API, и я не могу найти способ сделать это. Сейчас я просто проверяю API по очереди .....

  for (Maybevehicle veh : list) { //Iterate vehicle list
        CompletableFuture<Void> requestCompletableFuture = 
  CompletableFuture
                .supplyAsync(
                        () -> appRestTemplate.exchange(url + 
   veh.getB().getRfidtag(), HttpMethod.GET, requestEntity, 
   Bmwvehiclemain.class),
                        vehicleRequestExecutor
                )
                .thenApply((responseEntity) -> {
                    responses.add(responseEntity.getBody());
                    return responseEntity;
                })
                .thenAccept((responseEntity) -> {
                    //doSomeFinalStuffWithResponse(responseEntity);
                })
  .exceptionally(ex -> {
                   return null;
                });
        completableFutures.add(requestCompletableFuture);
        }
    }

Код, который я добавил, - это просто код, используемый для обработки завершаемого будущего. Работает нормально. Я просто переживаю, что слишком часто попаду в API. Заранее спасибо!

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...