使用 Retrofit 和 RxJava 时，应用程序会冻结一点

Question

JSON

[
   {
      "countryName":"..."
   },
   {
      "countryName":"..."
   },
   {
      "countryName":"..."
   } //etc... to 195 countries
]

界面

public interface RetrofitInterface {

    @GET("GetCountries.php")
    Single<List<CountryModel>> getCountries();

}

代码

new Retrofit.Builder().baseUrl(Constants.BASE_URL).addConverterFactory(GsonConverterFactory.create()).addCallAdapterFactory(RxJava3CallAdapterFactory.create()).build().create(RetrofitInterface.class).getCountries().doOnSuccess(countryModels - > {
    for (CountryModel item: countryModels) {
        Chip chip = new Chip(requireContext());
        chip.setText(item.getCountryName());
        fragmentCountriesBinding.fragmentCountriesChipGroupMain.addView(chip);
    }
}).observeOn(AndroidSchedulers.mainThread()).subscribe(new SingleObserver < List < CountryModel >> () {
    @Override
    public void onSubscribe(@io.reactivex.rxjava3.annotations.NonNull Disposable d) {
        
    }

    @Override
    public void onSuccess(@io.reactivex.rxjava3.annotations.NonNull List < CountryModel > countryModels) {
        
    }

    @Override
    public void onError(@io.reactivex.rxjava3.annotations.NonNull Throwable e) {
        
    }
});

我正在尝试将 195 个国家/地区添加到 ChipGroup，但在添加芯片期间应用程序会冻结一点，首先doOnSuccess 方法中的代码在 onSuccess 方法中，但应用程序是冻结了一点，因此代码已移至 doOnSuccess 方法，但我收到此消息 只有创建视图层次结构的原始线程才能触及其视图。

我是 RxJava 新手，有什么解决方案吗？

Answer 1

您忘记为应该订阅的内容设置调度程序。 默认情况下，一个 Observable 和你应用到它的操作符链将在调用它的订阅方法的同一个线程上完成它的工作，并通知它的观察者。 所以如果你从主线程调用它，它将在主线程上执行。这就是为什么您的应用程序冻结的原因，因为您在负责 UI 的主线程上发出网络请求。

要修复它，只需使用 subscribeOn 方法设置另一个调度程序：

 .subscribeOn(Schedulers.io())

所以在你的情况下，它应该看起来像这样：

getCountries().doOnSuccess(countryModels - > {
    ...
}).observeOn(AndroidSchedulers.mainThread())
  .subscribeOn(Schedulers.io())   // Asynchronously subscribes  to the observable on the IO scheduler.
  .subscribe(

    ...

)

详细文档： https://reactivex.io/documentation/operators/subscribeon.html

还有有助于理解 RxJava 中的线程处理的文章： https://proandroiddev.com/understanding-rxjava-subscribeon-and-observeon-744b0c6a41ea