Как ограничить скорость запросов API до x в секунду? - PullRequest
Новая
       4

Как ограничить скорость запросов API до x в секунду?

1 голос
/ 05 июня 2019

Мое приложение выполняет повторные запросы API для загрузки фрагментов данных.К сожалению, сервер ограничивает запросы API до 3 в секунду. В приведенном ниже коде, как я могу ограничить количество запросов до X в секунду? 

private void getHistoricalPrices(String currency, String start_date, String end_date, int granularity){
    // show download status
    currentDlPageIndex++;
    view.showDownloadingStatus(currentDlPageIndex, totalDlPages);

    // make the API call
    addDisposable(
            model.isNetworkAvailable()
                    .doOnSuccess(isNetworkAvailable -> {
                        if (!isNetworkAvailable) {
                            showErrorMessage();
                            Timber.v("no internet");
                        }
                    })
                    .filter(isNetworkAvailable -> true)
                    .flatMapSingle(isNetworkAvailable -> model.getHistoricalPrices(currency, start_date, end_date, String.valueOf(granularity)))
                    .subscribeOn(rxSchedulers.io())
                    .observeOn(rxSchedulers.mainThread())
                    .subscribe((Response<List<List<String>>> responseData) -> {
                        if (responseData != null && responseData.code() == HTTP_OK) {
                            List<List<String>> response = responseData.body();

                            if (response != null) {

                                // create list from downloaded data
                                ArrayList<HistoricPrice> tmpHistoricPriceList = new ArrayList<>(response.size());
                                for (List<String> rawHistoricPrice : response) {
                                    HistoricPrice historicPrice = new HistoricPrice(rawHistoricPrice.get(0), rawHistoricPrice.get(1), rawHistoricPrice.get(2), rawHistoricPrice.get(3), rawHistoricPrice.get(4), rawHistoricPrice.get(5));
                                    tmpHistoricPriceList.add(0, historicPrice);
                                }

                                // add the downloaded list to the main list being recreated
                                model.historicPriceList.addAll(tmpHistoricPriceList);
                                Timber.d("added %d records to memory", response.size());

                                // if there's more to download, download another chunk
                                if (intermediateDateSecs != null && intermediateDateSecs < endDateSecs){
                                    startDateSecs = tmpHistoricPriceList.get(tmpHistoricPriceList.size()-1).time + granularity;// add "granularity" to startDateSecs to avoid getting two exact data for the same time
                                    Date startDate = new Date(startDateSecs * 1000L);//requires milliseconds, not epoch
                                    String startStrDate = DateUtils.fromDateToString(startDate);

                                    intermediateDateSecs = startDateSecs + ((ApiService.MAX_HISTORIC_RETURN_VALUES - 1) * granularity);
                                    if (intermediateDateSecs > endDateSecs) intermediateDateSecs = endDateSecs;

                                    Date intermediateDate = new Date(intermediateDateSecs * 1000L);
                                    String intermediateStrDate = DateUtils.fromDateToString(intermediateDate);

                                    getHistoricalPrices(currency, startStrDate, intermediateStrDate, granularity);
                                } else {
                                    // no more to download, save data
                                    Timber.d("downloaded total of %d records", model.historicPriceList.size());
                                    view.hideDownloadingStatus();
                                    showSaveDataMessage();
                                }
                            }
                        }
                    }, error -> {
                        showErrorMessage();
                    })
    );
}

вы можете видеть, что метод getHistoricalPrices() вызывает себя для продолжения загрузки.Эта реализация работает хорошо, за исключением того, что сервер жалуется, когда слишком много запросов API в секунду.

1 Ответ

0 голосов
/ 06 июня 2019

Вы можете выполнять ваш запрос каждые X миллисекунд / секунд, например: 

long interval = 0L; // Your desired interval here in milliseconds
Observable.interval(0, interval, TimeUnit.MILLISECONDS)
    .takeUntil(x -> isTaskComplete == true)
    // Other configuration calls go here
    .subscribe(); // make request here or in doOnNext()
...