合并请求后，在使用Retrofit2和RxJava2进行Web服务调用后执行方法时出现问题

问题描述

我恢复了我的问题：我想进行网络服务调用（三个调用），对接收到的数据执行一些操作，最后更新UI（许多textview）。 我使用Retrofit2和rxjava2来执行Web服务调用，特别是Observable.zip（）对这三个Web服务进行一次调用，以便在执行某些计算之前获得所有这三个数据。 webservice调用工作良好，但是我注意到并不是我的计算方法（在onComplete中）中的所有指令都被调用，仅第一个textView.setText（）被调用，之后的所有内容均不执行。即使仅使用Log.i填充方法，也不会全部调用。当我将方法放在onNext（）上时，也会发生同样的事情。不会引发任何错误。我做错了什么？ 这是我的代码：

// Web服务

@GET("url 1")
Observable<List<Data1>> getData1();

@GET("url 2")
Observable<List<Data2>> getData2();

@GET("url 3")
Observable<List<Data3>> getData3();

// MainActivity

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
    //getTextViews
    getData();
}

private void getData(){
    Retrofit retrofit = Retrofit.Builder()
            .baseUrl("apiURL")
            .addCallAdapterFactory(RxJava2CallAdapterFactory.createWithScheduler(Schedulers.io()))
            .client(httpClient.build())
            .addConverterFactory(GsonConverterFactory.create(gson))
            .build();
    WebService service = retrofit.create(WebService.class);
    Observable.zip(service.getData1(),service.getData2(),service.getData3(),new Function3<List<Data1>,List<Data2>,List<Data3>,MergedResponse>() {
        int i;
        @Override
        public MergedResponse apply(List<Data1> data1,List<Data2> data2,List<Data3> data3) throws Exception {
            return new MergedResponse(data1,data2,data3);
        }
    }).subscribe(new Observer<MergedResponse>() {
        @Override
        public void onSubscribe(disposable d) {

        }

        @Override
        public void onNext(MergedResponse mergedResponse) {
            // dispatch my merged data
        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onComplete() {
            computeReceivedData();
        }
    });
}

private void computeReceivedData(){
   // List of expressions to compute data and update the view (textview)
    ...
    textView1.setText()
    textView2.setText()
    ...
   // Only the first expression textView1.setText() here is called.If I put it at the begining of the method,it stop after executing it
}

retrofit和rxjava2 vresion

implementation 'com.squareup.retrofit2:retrofit:2.9.0'
implementation 'com.squareup.retrofit2:converter-gson:2.9.0'
implementation 'com.squareup.okhttp3:logging-interceptor:3.9.0'
implementation "com.squareup.retrofit2:adapter-rxjava2:2.9.0"
implementation 'io.reactivex.rxjava2:rxjava:2.2.2'
implementation 'io.reactivex.rxjava2:rxandroid:2.1.0'
implementation 'androidx.appcompat:appcompat:1.2.0'
implementation 'androidx.legacy:legacy-support-v13:1.0.0'

解决方法

我认为，您正在尝试使用MainThread从后台线程更新UI。

因此您必须在代码中添加以下行

.subscribeOn(Schedulers.io()) // will do operation on background thread
.observeOn(AndroidSchedulers.mainThread()) // will notify UI for changes

例如。

Observable.zip(service.getData1(),service.getData2(),service.getData3(),new Function3<List<Data1>,List<Data2>,List<Data3>,MergedResponse>() {
        int i;

        @Override
        public MergedResponse apply(List<Data1> data1,List<Data2> data2,List<Data3> data3) throws Exception {
            return new MergedResponse(data1,data2,data3);
        }
    }).subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Observer<MergedResponse>() {
                @Override
                public void onSubscribe(Disposable d) {

                }

                @Override
                public void onNext(MergedResponse mergedResponse) {
                    // dispatch my merged data
                }

                @Override
                public void onError(Throwable e) {

                }

                @Override
                public void onComplete() {
                    computeReceivedData();
                }
            });

,

我认为该错误不在onComplete（）方法中。 检查computeReceivedData（）方法以确保其正常工作，然后调试textView2.setText（）以查找错误。 另外，请检查rxjava中zip方法返回的MergedResponse对象。

,

谢谢@yousef，我检查了textView.setText（）调用并发现此错误：

Unable to evaluate the expression "totalJ1.setText(""value");" : Method threw 'android.view.ViewRootImpl$CalledFromWrongThreadException' exception.

为解决此问题，我强制调用在onComplete（）的mainThread中执行：

MainActivity.this.runOnUiThread(new Runnable() {
      @Override
      public void run() {
          computeReceivedData();
      }
});

一切正常。