HTTP 失败：java.io.IOException：在多窗口模式下已取消

Question

一切工作正常，当我的应用程序进入onPause状态然后onResume调用任何 API 时，我遇到以下错误。

HTTP 失败：java.io.IOException：已取消

我正在使用 RxJava 和 Retrofit 来完成所有网络操作。以下是我的设置。

应用程序组件.java

@ApplicationScope
@Component(modules = {ContextModule.class, NetworkModule.class})
public interface ApplicationComponent {
    void inject(MyApplication myApplication);
}

应用范围.java

@Scope
@Retention(RetentionPolicy.CLASS)
  public @interface ApplicationScope {
}

ContextModule.java

@Module
public class ContextModule {

    private Context context;

    public ContextModule(Context context){
        this.context = context;
    }

    @Provides
    @ApplicationScope
    public Context applicationContext(){
        return context.getApplicationContext();
    }

}

网络模块.java

@Module @ApplicationScope
public class NetworkModule {

    private final String BASE_CONTACT_URL = "";

    @Provides @ApplicationScope
    public PoolAPIService getPoolApiService(Retrofit retrofit){
        APIServiceapiServicece = retrofit.create(APIService.class);
        return apiServicece;
    }

    @Provides @ApplicationScope
    public Retrofit getRetrofit(OkHttpClient okHttpClient){
        Retrofit retrofit = new Retrofit.Builder()
                .baseUrl(BASE_CONTACT_URL)
                .addConverterFactory(GsonConverterFactory.create())
                .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                .client(okHttpClient)

                .build();

        return retrofit;
    }

    @Provides @ApplicationScope
    public OkHttpClient getOkHttpClient(HttpLoggingInterceptor interceptor, Cache cache){
        OkHttpClient okhttpclient = new OkHttpClient.Builder()
                .addInterceptor(interceptor)
                .cache(cache)
                .build();
        return okhttpclient;
    }

    @Provides @ApplicationScope
    public HttpLoggingInterceptor getInterceptor(){
        HttpLoggingInterceptor interceptor = new HttpLoggingInterceptor(new HttpLoggingInterceptor.Logger() {
            @Override
            public void log(String message) {
                Log.d("Log", message);
            }
        });
        interceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
        return interceptor;
    }

    @Provides @ApplicationScope
    public Cache getCache(File cacheFile){
        Cache cache = new Cache(cacheFile, 10*1024*1024); //10MB size
        return cache;
    }

    @Provides @ApplicationScope
    public File getCacheFile(Context context){
        File cacheFile = new File(context.getCacheDir(), "cache");
        cacheFile.mkdirs();
        return cacheFile;
    }

    @Provides @ApplicationScope
    public Picasso getPicasso(Context context, OkHttpClient okHttpClient){
        Picasso picasso = new Picasso.Builder(context)
                .downloader(new OkHttp3Downloader(okHttpClient))
                .build();
        return picasso;
    }

}

我将它注入到我的应用程序类中。

我的应用程序.java

public class MyApplication extends Application {

    ApplicationComponent applicationComponent;
    @Inject
    APIService apiService;

    @Override
    public void onCreate() {
        super.onCreate();

        applicationComponent = DaggerApplicationComponent.builder()
                .contextModule(new ContextModule(this))
                .build();

        applicationComponent.inject(this);
    }

    public APIService getAPIService(){
        return apiService;
    }

}

这就是我调用 API 服务的方式。

登录活动.java

//creating LoginService instance
LoginService loginService = new LoginService(((MyApplication)getApplication()).getAPIService());

.......

void login() {
        final String mobileNumber = view.getMobileNumber();
        final String password = view.getPassword();

        Subscriber<LoginResponse> subscriber = new Subscriber<LoginResponse>() {
            @Override
            public void onCompleted() {
                Log.d(TAG, "onCompleted");
                if(subscriptionLogin != null && !subscriptionLogin.isUnsubscribed()){
                    subscriptionLogin.unsubscribe();
                }
            }

            @Override
            public void onError(Throwable e) {
                Log.e(TAG, "error: " + e.getMessage());
            }

            @Override
            public void onNext(LoginResponse loginResponse) {
                Log.d(TAG, loginResponse.message);
            }
        };


        LoginRequest request = new LoginRequest();
        request.mobileNumber = mobileNumber;
        request.password = password;

        subscriptionLogin = service.login(subscriber, request);

        compositeSubscription.add(subscriptionLogin);

 ....

  void onDestroy() {
    //unsubscribe all the subscription
    compositeSubscription.unsubscribe();
}

日志猫

--> POST http://.../.. http/1.1
Content-Type: application/json; charset=UTF-8
Content-Length: 32
--> END POST (32-byte body)
<-- HTTP FAILED: java.io.IOException: Canceled

Answer 1

我已经记录了onStart、onResume、onPause和onStop。这是 Activity 进入多窗口模式时的输出：

我敢打赌你没有想到 afteronResume立即onPause会被调用。而且，只要您在onResume中创建订阅，您就可以在 中取消订阅onPause，这会立即发生。

HTTP 失败：java.io.IOException：已取消

这意味着您已取消订阅（即您的改造呼叫已取消）。