遅延によるネットワーク要求のグループ化

Question

私はオブジェクトの3つのグループが同じレルムデータベースにあります。各グループはタグと他の情報のセットです。各タグについて、IDを受け取るためにネットワークに要求する必要があります。クエリはグループごとに異なります（URLの変更と応答）。

各グループの要求を並行して行う必要があり、毎分20クエリを超えることはありません。アクティビティが破壊されても、プログラムは動作するはずです。私はIntentServieをやったが、わからない次のステップは何か。遅れて並列クエリを正しく行うにはどうすればよいですか？ IntentServiceを使用することは可能ですか？

問題をよりよく理解するために示された「for」のサイクル。また、すべてのレスポンスを1つのデータベースに書き込む必要があります。そのため、すべてのストリームでアクセスできる必要があります。

public class SubscribersGathering extends IntentService { 

private RealmResults<HashtagObject> hashtags; 
private RealmResults<SearchtagObject> searchtags; 
private RealmResults<NametagObject> nametags; 

public SubscribersGathering() { 
    super("SubscribersGathering"); 
} 

@Override 
protected void onHandleIntent(Intent intent) { 
    Realm realmForThisThread = Realm.getDefaultInstance(); 
    this.hashtags = realmForThisThread.where(HashtagObject.class).findAll(); 
    this.searchtags = realmForThisThread.where(SearchtagObject.class).findAll(); 
    this.nametags = realmForThisThread.where(NametagObject.class).findAll(); 
    realmForThisThread.close(); 

    for(int i=0;i<hashtags.size();i++){ 
     getHashtagTag(hashtags.get(i).getHashtag()); 
    } 
    for(int i=0;i< searchtags.size();i++){ 
     getSearchTags(searchtags.get(i).getId()); 
    } 
    etc  
} 

private void getHashtagTag(final String tagName){ 

      HttpURLConnection urlConnection = null; 
      try { 
       URL url = new URL(“URL_1”); 
       urlConnection = (HttpURLConnection) url 
         .openConnection(); 
       urlConnection.setRequestMethod("GET"); 
       urlConnection.setDoInput(true); 
       urlConnection.connect(); 
       String response = Tools.streamToString(urlConnection 
         .getInputStream()); 
       JSONObject jsonObj = (JSONObject) new JSONTokener(response) 
         .nextValue(); 
       for(int i=0;i<jsonObj.getJSONArray("data").length();i++) { 
        JSONObject json = (JSONObject)  jsonObj.getJSONArray("data").get(i); 
        Log.d(tagName, json.getJSONObject("user").getString("id")); 
       } 
      }catch(Exception exc){ 
       exc.printStackTrace(); 
      }finally { 
       if(urlConnection!=null){ 
        try{ 
         urlConnection.disconnect(); 
        }catch(Exception e){ 
         e.printStackTrace(); 
        } 
       } 
      } 
} 

    private void getSearchTags (final String tagName){ 

    } 

    etc 

}

Answer 1

あなたは、ネットワーク運用の並走を実行するための多くのオプションを持っています。それはあなたが選ぶべきものです。基本的に、私はあなたにこれらのいずれかを示唆することができます。

1. ExecutorService

   に基づくソリューションは、ランナブルにあなたのタスクを分割し、ExecutorServiceのを使用してそれらを実行します。コードは次のようになります。

   public void onHandleIntent(Intent intent) { 
        Runnable hashtagsTask = new Runnable() { 
         @Override 
         public void run() { 
          for (int i = 0; i < hashtags.size(); i++) { 
           getHashtag(i);// do something, fetch hashtags, etc 
          } 
         }  
        }; 
        Runnable searchtagsTask = new Runnable() { 
         @Override 
         public void run() { 
          // do something 
         } 
        }; 
   
   
        ExecutorService pool = Executors.newFixedThreadPool(3); 
        pool.execute(hashtagsTask); 
        pool.execute(searchtagsTask); 
        // etc 
   
        pool.awaitTermination(); 
   } 
   

2. をいくつかIntentServicesにあなたのタスクを分割します。したがって、すべてのサービスが独自のデータを取得します。個人的に私はそれが良い解決策だとは思わないが、場合によっては柔軟性があるかもしれない。

3. RxJavaとそのObservable#zipメソッドを使用します。ここで重要な考え方は、独自のスレッドに各観測可能に加入するようになります。

   public void onHandleIntent(Intent intent) { 
        Observable.zip(
         getHashtags().subscribeOn(Schedulers.newThread()), 
         getSearchtags().subscribeOn(Schedulers.newThread()), 
         new Func2<List<String>, List<String>, Void>() { 
          @Override 
          public Void call(List<String> hashtags, List<String> searchtags) { 
            // do something with your data 
            return null; 
          } 
         } 
       ) 
        .subscribe(); 
   } 
   
   private Observable<List<String>> getHashtags() { 
        return Observable.defer(new Func0<Observable<List<String>>>() { 
          @Override 
          public Observable<List<String>> call() { 
           // fetch your data 
           return null; 
          } 
        }; 
   }