android - 使用 Rxjava 2 和 Retrofit 2 加载数据失败时应用程序崩溃

Question

我在我的应用程序中使用retrofit2和rxjava2作为网络库。有时，当应用程序无法从 Activity 中的服务器加载数据时，它会崩溃。我很明白为什么会发生这种情况。

这是我的代码:

ApiService.java

public interface ApiService {

@POST("retrofitUsers")
@FormUrlEncoded
Observable<String> saveData(@Field("name") String name,
                         @Field("age") String age);

@GET("getUsers")
Observable<List<BioData>> getData();

}

RetrofitClient.java

public class RetrofitClient {

private static Retrofit retrofit = null;

public static Retrofit getInstance(){

    if(retrofit == null)
        retrofit = new Retrofit.Builder()
                .baseUrl("https://bookbudiapp.herokuapp.com/")
                .addConverterFactory(GsonConverterFactory.create(new GsonBuilder().setLenient().create()))
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .build();

    return retrofit;

}

private RetrofitClient(){

}
}

BioData.java

public class BioData {

@SerializedName("name")
@Expose
private String name;

@SerializedName("age")
@Expose
private String age;

public String getName() {
    return name;
}

public void setName(String name) {
    this.name = name;
}

public String getAge() {
    return age;
}

public void setAge(String age) {
    this.age = age;
}
}

MainActivity.java

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_users);

    recycle = findViewById(R.id.recycle);
    recycle.setHasFixedSize(true);
    recycle.setLayoutManager(new LinearLayoutManager(this));

    list  = new ArrayList<>();

    compositeDisposable = new CompositeDisposable();

    fetchData();
}

    private void fetchData(){

    Retrofit retrofit  = RetrofitClient.getInstance();
    ApiService myApi = retrofit.create(ApiService.class);

    Disposable disposable = myApi.getData().subscribeOn(Schedulers.io())
                                           .observeOn(AndroidSchedulers.mainThread())
                                           .subscribe(new Consumer<List<BioData>>() {
                                               @Override
                                               public void accept(List<BioData> bioData) throws Exception {

                                                   adapter = new UserAdapter(bioData,getApplicationContext());
                                                   recycle.setAdapter(adapter);
                                               }
                                           });



    compositeDisposable.add(disposable);

}

@Override
protected void onStop() {
    super.onStop();

   compositeDisposable.clear();

}
}

有人请让我知道我做错了什么。任何帮助将不胜感激。

谢谢

Answer 1

几天前我遇到了同样的问题，直到我发现这个 Free Dyno Hours ，其中解释:

Every Heroku account is allocated a pool of free dyno hours. An app actively consumes free dyno hours if the app is set to use free dynos and any of the following are true:

It has a web dyno that is receiving traffic (i.e., not sleeping)

It has a worker dyno running

It has a one-off dyno running. For example, one started via the CLI or Scheduler.

这是什么意思？如果您使用的是免费帐户，并且您停留一段时间而没有对您的Heroku网络服务器进行任何调用，它就会休眠，一旦您再次调用它，它就会休眠。别醒了。

有关更多信息，请阅读Heroku Dynos

我所做的是，创建一个OkHttpClient，如下所示:

private fun makeOkHttpClient(): OkHttpClient {
    return OkHttpClient.Builder()
        .connectTimeout(120, TimeUnit.SECONDS)
        .readTimeout(120, TimeUnit.SECONDS)
        .writeTimeout(90, TimeUnit.SECONDS)
        .build()
}

然后在您的Retrofit构建器中只需添加.client(makeOkHttpClient())，这样您就可以分配readTimeout和writeTimeout .

此外，我建议您使用 Disposable 而不是 CompositeDisposable，因为您只有一次调用，这样您就可以避免 .add() 东西。