RxJava + Retrofit → BaseObservable для вызовов API для централизованной обработки ответов

Ответ 1

Две ссылки, которые вы предоставили, являются действительно хорошей отправной точкой, которую я использовал для создания решения для реагирования на случайные

• сетевые ошибки иногда возникают из-за временного отсутствия сетевого подключения или переключения на стандарт с низкой пропускной способностью, например EDGE, что вызывает SocketTimeoutException
• ошибки сервера → иногда происходят из-за перегрузки сервера

Я обработал ошибки CallAdapter.Factory, чтобы обработать ошибки и соответствующим образом отреагировать на них.

• Импортируйте RetryWithDelayIf из решения, который вы нашли

• Переопределить CallAdapter.Factory для обработки ошибок:

  public class RxCallAdapterFactoryWithErrorHandling extends CallAdapter.Factory {
      private final RxJavaCallAdapterFactory original;
  
      public RxCallAdapterFactoryWithErrorHandling() {
          original = RxJavaCallAdapterFactory.create();
      }
  
      @Override
      public CallAdapter<?> get(Type returnType, Annotation[] annotations, Retrofit retrofit) {
          return new RxCallAdapterWrapper(retrofit, original.get(returnType, annotations, retrofit));
      }
  
      public class RxCallAdapterWrapper implements CallAdapter<Observable<?>> {
          private final Retrofit retrofit;
          private final CallAdapter<?> wrapped;
  
          public RxCallAdapterWrapper(Retrofit retrofit, CallAdapter<?> wrapped) {
              this.retrofit = retrofit;
              this.wrapped = wrapped;
          }
  
          @Override
          public Type responseType() {
              return wrapped.responseType();
          }
  
          @SuppressWarnings("unchecked")
          @Override
          public <R> Observable<?> adapt(final Call<R> call) {
              return ((Observable) wrapped.adapt(call)).onErrorResumeNext(new Func1<Throwable, Observable>() {
                  @Override
                  public Observable call(Throwable throwable) {
                      Throwable returnThrowable = throwable;
                      if (throwable instanceof HttpException) {
                          HttpException httpException = (HttpException) throwable;
                          returnThrowable = httpException;
                          int responseCode = httpException.response().code();
                          if (NetworkUtils.isClientError(responseCode)) {
                              returnThrowable = new HttpClientException(throwable);
                          }
                          if (NetworkUtils.isServerError(responseCode)) {
                              returnThrowable = new HttpServerException(throwable);
                          }
                      }
  
                      if (throwable instanceof UnknownHostException) {
                          returnThrowable = throwable;
                      }
  
                      return Observable.error(returnThrowable);
                  }
              }).retryWhen(new RetryWithDelayIf(3, DateUtils.SECOND_IN_MILLIS, new Func1<Throwable, Boolean>() {
                  @Override
                  public Boolean call(Throwable throwable) {
                      return throwable instanceof HttpServerException
                              || throwable instanceof SocketTimeoutException
                              || throwable instanceof UnknownHostException;
                  }
              }));
          }
      }
  }
  

  HttpServerException является обычным исключением.

• Используйте его в Retrofit.Builder

  Retrofit retrofit = new Retrofit.Builder()
          .addCallAdapterFactory(new RxCallAdapterFactoryWithErrorHandling())
          .build();
  

Экстра. Если вы хотите проанализировать ошибки, возникающие из API (ошибка, которая не вызывает UnknownHostException, HttpException или MalformedJsonException или т.д.), вам необходимо переопределить Factory и использовать пользовательский во время создания экземпляра Retrofit. Разберите ответ и проверьте, содержит ли он ошибки. Если "да", тогда ошибка броска и ошибки будут обрабатываться внутри метода выше.

Ответ 2

Считаете ли вы использование адаптера rxjava для переоснащения? https://mvnrepository.com/artifact/com.squareup.retrofit2/adapter-rxjava/2.1.0 в файле gradle добавить

compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'

здесь интерфейс для модернизации

public interface Service {
@GET("userauth/login?")
Observable<LoginResponse> getLogin(
        @Query("v") String version,
        @Query("username") String username,
        @Query("password") String password);
}

и здесь моя реализация

Service.getLogin(
            VERSION,
            "username",
            "password")
            .subscribe(new Subscriber<LoginResponse>() {
                @Override
                public void onCompleted() {

                }

                @Override
                public void onError(Throwable e) {

                }

                @Override
                public void onNext(LoginResponse loginResponse) {

                }
            });

Обратите внимание, что я использую gson converter factory для анализа моего ответа, поэтому я возвращаю POJO (объект Plain Ole Java Object).

Ответ 3

Посмотрите, как вы можете это сделать.  Здесь api call и передать модель запроса и модель ответа в этом.

public interface RestService {
//SEARCH_USER
@POST(SEARCH_USER_API_LINK)
Observable<SearchUserResponse> getSearchUser(@Body SearchUserRequest getSearchUserRequest);
}

Это переоснащение, я использовал retrofit2

public RestService getRestService() {

    Retrofit retrofit = new Retrofit.Builder()
            .baseUrl(ApiConstants.BASE_URL)
            .addConverterFactory(GsonConverterFactory.create())
            .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
            .client(getOkHttpClient())
            .build();

    return retrofit.create(RestService.class);
}

//get OkHttp instance
@Singleton
@Provides
public OkHttpClient getOkHttpClient() {

    HttpLoggingInterceptor httpLoggingInterceptor = new HttpLoggingInterceptor();
    httpLoggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);

    OkHttpClient.Builder builder = new OkHttpClient.Builder();
    builder.interceptors().add(httpLoggingInterceptor);
    builder.readTimeout(60, TimeUnit.SECONDS);
    builder.connectTimeout(60, TimeUnit.SECONDS);
    return builder.build();
}

Это вызов api, назовите его в своей деятельности.

@Inject
Scheduler mMainThread;
@Inject
Scheduler mNewThread;

 //getSearchUser api method
public void getSearchUser(String user_id, String username) {

    SearchUserRequest searchUserRequest = new SearchUserRequest(user_id, username);

    mObjectRestService.getSearchUser(searchUserRequest).
            subscribeOn(mNewThread).
            observeOn(mMainThread).
            subscribe(searchUserResponse -> {
                Timber.e("searchUserResponse :" + searchUserResponse.getResponse().getResult());
                if (isViewAttached()) {
                    getMvpView().hideProgress();
                    if (searchUserResponse.getResponse().getResult() == ApiConstants.STATUS_SUCCESS) {

                    } else {

                    }
                }
            }, throwable -> {
                if (isViewAttached()) {

                }
            });
}

Надеюсь, это поможет вам.