画面の回転を考慮して、AndroidでRxJavaとRetrofitを使用する

ある日、大人気のRxを試すことにしました。 そして、レトロフィットとともに。 そして、彼らの助けを借りて標準タスクを実装する方法をご覧ください：サーバーからデータセットを取得し、それらを表示し、同時に画面を回しても何も失わず、不必要な要求をしないでください。 私がほとんどすぐに得た最初のオプション-シングルトンから取得したObservableでcache（）を呼び出しましたが、それは私には合いませんでした-強制更新のために、何らかの理由で、Retrofitクラスのインスタンスとそのインターフェイスの実装を再作成する必要がありましたAPI Observable自体を再作成しても効果はありません。新しいネットワーク要求を開始して新しいデータを受信する代わりに、常に古いデータが返されました。

自分自身の新しい技術に多大な苦痛を感じた後、cache（）がすべての罪を犯していることがわかりました（むしろ、おそらく私の誤った理解）。 その結果、彼はこれを行いました。フラグメントは、サブスクライバシングルトンをObservable retrofit-aにサブスクライブするメソッドを起動します。これにより、サブスクライバフラグメントがすでにサブスクライブしているonNextおよびonError BehaviorSubject-aが起動します。 GitHubのコードはこちら 、詳細は未定です。

それでは始めましょう。 まず、JSONを提供する最も単純なphpコードを作成します。 画面を回転させるために、データが送信されるまでに5秒の遅延が生じるようにします。

<?php $string = '[ { "title": "Some awesome title 1", "text": "Lorem ipsum dolor sit amet..." }, { "title": "Some awesome title 2", "text": "Lorem ipsum dolor sit amet..." } ]'; $seconds = 5; sleep($seconds); $json = json_decode($string); print json_encode($json, JSON_PRETTY_PRINT);
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

gradleの依存関係：

 compile 'com.android.support:appcompat-v7:23.3.0' compile 'com.android.support:design:23.3.0' compile 'com.android.support:cardview-v7:23.3.0' compile 'com.android.support:recyclerview-v7:23.3.0' compile 'io.reactivex:rxjava:1.1.3' compile 'io.reactivex:rxandroid:1.1.0' compile 'com.squareup.retrofit2:adapter-rxjava:2.0.2' compile 'com.squareup.retrofit2:retrofit:2.1.0' compile 'com.squareup.retrofit2:converter-gson:2.1.0' compile 'com.google.code.gson:gson:2.6.2'
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

Googleのライブラリの最近のバージョンは使用しません。プロジェクトでの軽率な更新で何度も燃やしてしまいます。ウィジェットスタイルの一部の属性を変更してから、すでに修正されたバグを返すか、新しいバグを見つけます。 バージョン23.3.0は比較的安定して動作するので、それを使用してください。

コードに渡します。 私が得たプロジェクト構造は次のとおりです。

アクティビティのマークアップは簡単です。ここでは次のとおりです。

 <?xml version="1.0" encoding="utf-8"?> <android.support.design.widget.CoordinatorLayout android:id="@+id/root" xmlns:android="http://schemas.android.com/apk/res/android" xmlns:app="http://schemas.android.com/apk/res-auto" android:layout_width="match_parent" android:layout_height="match_parent" android:fitsSystemWindows="true"> <android.support.design.widget.AppBarLayout android:id="@+id/app_bar_layout" android:layout_width="match_parent" android:layout_height="?attr/actionBarSize" android:minHeight="?attr/actionBarSize"> <android.support.v7.widget.Toolbar android:id="@+id/toolbar" android:layout_width="match_parent" android:layout_height="?attr/actionBarSize" app:layout_scrollFlags="scroll|enterAlways"/> </android.support.design.widget.AppBarLayout> <FrameLayout android:id="@+id/container" android:layout_width="match_parent" android:layout_height="match_parent" app:layout_behavior="@string/appbar_scrolling_view_behavior" android:paddingEnd="@dimen/activity_horizontal_margin" android:paddingLeft="@dimen/activity_horizontal_margin" android:paddingRight="@dimen/activity_horizontal_margin" android:paddingStart="@dimen/activity_horizontal_margin"/> </android.support.design.widget.CoordinatorLayout>
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

アクティビティのコードは簡潔です：

 public class MainActivity extends AppCompatActivity { private Toolbar toolbar; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); initViews(); setSupportActionBar(toolbar); Fragment fragmentHotelsList = getSupportFragmentManager().findFragmentById(R.id.container); if (fragmentHotelsList == null) { fragmentHotelsList = new ModelsListFragment(); getSupportFragmentManager(). beginTransaction().add(R.id.container, fragmentHotelsList) .commit(); } } private void initViews() { toolbar = (Toolbar) findViewById(R.id.toolbar); } }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

これで、フレームワークの準備ができました。アプリケーションの動作については次のとおりです。

• アプリケーションが起動すると、ネットワークへのリクエストが開始されます。
• 答えは、データまたはエラーのいずれかでなければなりません。
• 画面を回転させてアクティビティ/フラグメントを再作成すると、既にダウンロードされているデータがあれば表示する必要があります。 それらがない場合、または新しいデータの要求がまだ完了していない場合は、ダウンロードインジケーターを表示し、データを受信するためにサブスクライブする必要があります。
• 当然、データを失ったり、ネットワーク上で新しいリクエストを再起動したりする必要はありません。
• また、データの更新を強制する機能も必要です。

冒頭で述べたように、キャッシュ（）に高い期待がありましたが、理解しているように、リクエスト自体をネットワークにキャッシュし、Observableを再作成しても、Retrofitaオブジェクトを再作成せずにネットワークに新しいリクエストを作成することはできません。これは明らかに間違った方法です。 最初は、私がすべきことを理解できませんでした。 コードを掘り下げて、とにかく、数時間、私は極端な対策を取ることに決めました-私はstackoverflowについて質問しました 。 そこで、彼らは私に直接答えませんでしたが、2つのヒントを与えました-既に述べたcache（）の振る舞いと、データの送受信と最新のデータ自体の保存が可能なBehaviorSubjectの使用を試すことができるという事実についてです。

後者にはすぐに小さな問題がありました-ためらうことなく、私はObservableレトロフィットのためにBehaviorSubjectを、BehaviorSubjectのためにフラグメントを登録しました。 画面の回転中にタスクが完了した場合にのみ、すべてが真実であるように思われ、フラグメントは最後のデータを正しく受信します...データ自体ではなくonCompleteイベントを正しく受信します。 ここでは、Observableがexitイベントを発行しないようにする方法、またはサブスクライバーからそれを無視する方法をグーグルで試しながら、簡単に凍結しました。 グーグルは黙っていて、あらゆる方向で、私が間違った方向に滴っていることを暗示していた。 そして、はい-同様のアイデアは技術の初心者にしかなかったかもしれません）解決策は簡単であることが判明しました-Observableの動作を変更しようとする代わりに、私は単にBehaviorSubjectにサインアップせず、単に最初のコールバック（onNextおよびonError）で2番目の対応するメソッドを呼び出しました onComplete-無視されます。

最後に、ここにシングルトンがあります：

 public class RetrofitSingleton { private static final String TAG = RetrofitSingleton.class.getSimpleName(); private static Observable<ArrayList<Model>> observableRetrofit; private static BehaviorSubject<ArrayList<Model>> observableModelsList; private static Subscription subscription; private RetrofitSingleton() { } public static void init() { Log.d(TAG, "init"); RxJavaCallAdapterFactory rxAdapter = RxJavaCallAdapterFactory.createWithScheduler(Schedulers.io()); Gson gson = new GsonBuilder().create(); Retrofit retrofit = new Retrofit.Builder() .baseUrl(Const.BASE_URL) .addConverterFactory(GsonConverterFactory.create(gson)) .addCallAdapterFactory(rxAdapter) .build(); GetModels apiService = retrofit.create(GetModels.class); observableRetrofit = apiService.getModelsList(); } public static void resetModelsObservable() { observableModelsList = BehaviorSubject.create(); if (subscription != null && !subscription.isUnsubscribed()) { subscription.unsubscribe(); } subscription = observableRetrofit.subscribe(new Subscriber<ArrayList<Model>>() { @Override public void onCompleted() { //do nothing } @Override public void onError(Throwable e) { observableModelsList.onError(e); } @Override public void onNext(ArrayList<Model> models) { observableModelsList.onNext(models); } }); } public static Observable<ArrayList<Model>> getModelsObservable() { if (observableModelsList == null) { resetModelsObservable(); } return observableModelsList; } }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

フラグメント自体。 なぜなら 強制更新メソッドとロードインジケーターが必要な場合、一見最も明らかな解決策はSwipeRefreshLayoutを使用することです。 しかし、彼には大きな問題があります。つまり、彼に爽快なステータスを設定することです。 回転する円を示しています。 時々、まったく表示されないか、必要なときに消えないことがあります。 また、異なるバージョンのサポートライブラリにCoordinatorLayoutが表示された後、このウィジェットはAppBarLayoutで正しく動作し始めます（AppBarLayoutが完全に展開されてスクロールダウンする前でも、プルツーリフレッシュが機能します）。 Googleでかつてこのバグを修正してから、...返品したもの。 そして再び...一般に、この例では、このウィジェットにタッチしませんが、メニューにボタンを作成し、適切なタイミングで非表示/表示する回転アニメーションを使用した単純なImageViewを作成します。 SwipeRefreshLayoutを使用すると簡単で問題はありません。

フラグメントマークアップは次のとおりです。

 <?xml version="1.0" encoding="utf-8"?> <FrameLayout xmlns:android="http://schemas.android.com/apk/res/android" android:layout_width="match_parent" android:layout_height="match_parent"> <android.support.v7.widget.RecyclerView android:id="@+id/recycler" android:layout_width="match_parent" android:layout_height="match_parent"/> <ImageView android:id="@+id/loading_indicator" android:layout_width="50dp" android:layout_height="50dp" android:layout_gravity="center" android:contentDescription="@string/app_name" android:src="@drawable/ic_autorenew_indigo_500_48dp" android:visibility="gone"/> </FrameLayout>
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

とてもシンプルなので、必要はありません。 フラグメントのJavaコードはもう少し複雑なので、確実に提供します。

 public class ModelsListFragment extends Fragment { private static final String TAG = ModelsListFragment.class.getSimpleName(); private Subscription subscription; private ImageView loadingIndicator; private RecyclerView recyclerView; private ArrayList<Model> models = new ArrayList<>(); private boolean isLoading; @Override public void onCreate(@Nullable Bundle savedInstanceState) { super.onCreate(savedInstanceState); setHasOptionsMenu(true); } @Override public void onCreateOptionsMenu(Menu menu, MenuInflater inflater) { inflater.inflate(R.menu.menu_models_list, menu); super.onCreateOptionsMenu(menu, inflater); } @Override public boolean onOptionsItemSelected(MenuItem item) { int id = item.getItemId(); switch (id) { case R.id.refresh: Log.d(TAG, "refresh clicked"); RetrofitSingleton.resetModelsObservable(); showLoadingIndicator(true); getModelsList(); return true; } return super.onOptionsItemSelected(item); } @Nullable @Override public View onCreateView(LayoutInflater inflater, @Nullable ViewGroup container, @Nullable Bundle savedInstanceState) { View v = inflater.inflate(R.layout.fragment_models_list, container, false); if (savedInstanceState != null) { models = savedInstanceState.getParcelableArrayList(Const.KEY_MODELS); isLoading = savedInstanceState.getBoolean(Const.KEY_IS_LOADING); } recyclerView = (RecyclerView) v.findViewById(R.id.recycler); loadingIndicator = (ImageView) v.findViewById(R.id.loading_indicator); recyclerView.setLayoutManager(new LinearLayoutManager(getActivity())); recyclerView.setAdapter(new ModelsListRecyclerAdapter(models)); if (models.size() == 0 || isLoading) { showLoadingIndicator(true); getModelsList(); } return v; } private void showLoadingIndicator(boolean show) { isLoading = show; if (isLoading) { loadingIndicator.setVisibility(View.VISIBLE); loadingIndicator.animate().setInterpolator(new AccelerateDecelerateInterpolator()).rotationBy(360).setDuration(500).setListener(new AnimatorListenerAdapter() { @Override public void onAnimationEnd(Animator animation) { loadingIndicator.animate().setInterpolator(new AccelerateDecelerateInterpolator()).rotationBy(360).setDuration(500).setListener(this); } }); } else { loadingIndicator.animate().cancel(); loadingIndicator.setVisibility(View.GONE); } } private void getModelsList() { if (subscription != null && !subscription.isUnsubscribed()) { subscription.unsubscribe(); } subscription = RetrofitSingleton.getModelsObservable(). subscribeOn(Schedulers.io()). observeOn(AndroidSchedulers.mainThread()). subscribe(new Subscriber<ArrayList<Model>>() { @Override public void onCompleted() { Log.d(TAG, "onCompleted"); } @Override public void onError(Throwable e) { Log.d(TAG, "onError", e); isLoading = false; if (isAdded()) { showLoadingIndicator(false); Snackbar.make(recyclerView, R.string.connection_error, Snackbar.LENGTH_SHORT) .setAction(R.string.try_again, new View.OnClickListener() { @Override public void onClick(View v) { RetrofitSingleton.resetModelsObservable(); showLoadingIndicator(true); getModelsList(); } }) .show(); } } @Override public void onNext(ArrayList<Model> newModels) { Log.d(TAG, "onNext: " + newModels.size()); int prevSize = models.size(); isLoading = false; if (isAdded()) { recyclerView.getAdapter().notifyItemRangeRemoved(0, prevSize); } models.clear(); models.addAll(newModels); if (isAdded()) { recyclerView.getAdapter().notifyItemRangeInserted(0, models.size()); showLoadingIndicator(false); } } }); } @Override public void onSaveInstanceState(Bundle outState) { super.onSaveInstanceState(outState); outState.putParcelableArrayList(Const.KEY_MODELS, models); outState.putBoolean(Const.KEY_IS_LOADING, isLoading); } @Override public void onDestroy() { super.onDestroy(); if (subscription != null && !subscription.isUnsubscribed()) { subscription.unsubscribe(); } } }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

ここにポイントごとにあります：

• 作成するとき、メニューに独自の要素があると言います。
• アクティベーションメニューに新しいメニュー項目を追加します。
• メニューをクリックする方法を再定義し、その中でデータの強制更新を開始します（シングルトンメソッドを呼び出し、ダウンロードインジケーターのアニメーションを開始し、BehaviorSubjectを再サブスクライブします）
• onCreateViewでは、フラグメントのマークアップをロードし、状態を復元します（つまり、データ内のリストとロードした/ロードしないステータス）、データのリストが空であることを確認するか、ロード中にインジケーターを表示し、BehaviorSubjectにサブスクライブします。
• getModelsList（）メソッドでは、サブスクライブおよびサブスクライブする場合、最初にBehaviorSubjectからサブスクライブ解除します。 onNextおよびonErrorでは、それに応じて応答します。エラーテキストと「繰り返し」ボタンを含むSnackBarを表示します。 フラグメントデータリストのデータを更新し、アダプタに通知します。 どちらの場合も、ダウンロードインジケーターを停止し（フラグメントが追加された場合（isAdded（）））、アップロード/ダウンロードのステータスを更新します。
• onSaveInstanceState保存状態
• onDestroyで、BehaviorSubjectからサブスクライブ解除します

購読と購読解除が必要になる時期を犠牲にして、私にはわかりません。 onResume / onPauseでこれを行うためのヒントをインターネットで見ましたが、同じことをすることを考えました...しかし、onDestroyの購読を解除すると、データが到着する前にアプリケーションを最小化した後でも、データがフラグメントになり、アプリケーションに切り替えた後に表示されます。 はい、そうでない場合、アプリケーションをデプロイすると、onResumeが呼び出され、BehaviorSubjectに再サブスクライブし、データはどこにも行き来しません...しかし、私の方法も機能します-この問題に関する異論や考えがある場合-コメント。

そして最後に-データモデル。 おそらく最初に近い位置に配置する必要があったのでしょうが、非常に単純なので、最後に配置することにしました。 注目に値する唯一のことは、Parcelableインターフェイスのクラスによる実装です。これにより、画面の回転後の回復のためにモデルをバンドルに書き込むことができます。 APIからモデルへのJSON文字列の解析が正しく機能するためには、クラスのフィールドにセッターとゲッターの両方が存在する必要があることに注意してください。 それで、フィールドへの注釈が正しい値を持つように。

 public class Model implements Parcelable { /** * Parcel implementation */ public static final Parcelable.Creator<Model> CREATOR = new Parcelable.Creator<Model>() { @Override public Model createFromParcel(Parcel source) { return new Model(source); } @Override public Model[] newArray(int size) { return new Model[size]; } }; @SerializedName("title") private String title; @SerializedName("text") private String text; /** * Parcel implementation */ private Model(Parcel in) { this.title = in.readString(); this.text = in.readString(); } /** * Parcel implementation */ @Override public int describeContents() { return 0; } /** * Parcel implementation */ @Override public void writeToParcel(Parcel dest, int flags) { dest.writeString(title); dest.writeString(text); } public String getTitle() { return title; } public void setTitle(String title) { this.title = title; } public String getText() { return text; } public void setText(String text) { this.text = text; } }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

以上です。 戦いでRetrofit + RxJava / RxAndroidを試してみたところ、アプリケーションの実用的なプロトタイプが得られました。トラフィックをあまり消費せず、画面が回転してもクラッシュせず、依存関係に流行のライブラリがあります。 最後まで読んでくれてありがとう！

PSもう一度リンク：

stackoverflowに関する質問： http : //en.stackoverflow.com/q/541099/17609

GitHubリポジトリ： https : //github.com/mohaxspb/RxRetrofitAndScreenOrientation