增加对Retrofit的支持

Author: alafighting

app/build.gradle

@@ -29,4 +29,6 @@ dependencies {
     compile project(':library')
 
     compile 'com.android.support:appcompat-v7:24.0.0'
+    compile 'com.squareup.retrofit2:converter-gson:2.1.0'
+    compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'
 }

app/src/main/java/com/im4j/kakacache/rxjava/demo/GitHubService.java

@@ -0,0 +1,16 @@
+package com.im4j.kakacache.rxjava.demo;
+
+import java.util.List;
+
+import retrofit2.http.GET;
+import retrofit2.http.Path;
+
+/**
+ * @version alafighting 2016-07
+ */
+public interface GitHubService {
+
+    @GET("users/{user}/repos")
+    rx.Observable<List<GithubRepoEntity>> listRepos(@Path("user") String user);
+
+}

app/src/main/java/com/im4j/kakacache/rxjava/demo/GithubRepoEntity.java

@@ -0,0 +1,66 @@
+package com.im4j.kakacache.rxjava.demo;
+
+import com.google.gson.annotations.SerializedName;
+
+/**
+ * @version alafighting 2016-07
+ */
+public class GithubRepoEntity {
+
+    private String id;
+    private String name;
+    @SerializedName("full_name")
+    private String fullName;
+    private String description;
+
+    public GithubRepoEntity() {
+    }
+    public GithubRepoEntity(String id, String name, String fullName, String description) {
+        this.id = id;
+        this.name = name;
+        this.fullName = fullName;
+        this.description = description;
+    }
+
+    @Override
+    public String toString() {
+        return "GithubRepoEntity{" +
+                "id='" + id + '\'' +
+                ", name='" + name + '\'' +
+                ", fullName='" + fullName + '\'' +
+                ", description='" + description + '\'' +
+                '}';
+    }
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getFullName() {
+        return fullName;
+    }
+
+    public void setFullName(String fullName) {
+        this.fullName = fullName;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+}

app/src/main/java/com/im4j/kakacache/rxjava/demo/MainActivity.java

@@ -6,13 +6,19 @@
 import android.util.Log;
 import android.widget.Button;
 
-import com.im4j.kakacache.rxjava.netcache.RxRemoteCache;
+import com.im4j.kakacache.rxjava.common.utils.LogUtils;
+import com.im4j.kakacache.rxjava.netcache.KakaCache;
+import com.im4j.kakacache.rxjava.netcache.KakaRetrofit;
 import com.im4j.kakacache.rxjava.netcache.strategy.CacheAndRemoteStrategy;
+import com.im4j.kakacache.rxjava.netcache.strategy.FirstCacheStrategy;
 
 import java.util.concurrent.TimeUnit;
 
+import retrofit2.adapter.rxjava.RxJavaCallAdapterFactory;
+import retrofit2.converter.gson.GsonConverterFactory;
 import rx.Observable;
 import rx.Subscriber;
+import rx.schedulers.Schedulers;
 
 /**
  * Demo主界面
@@ -21,23 +27,40 @@
 public class MainActivity extends AppCompatActivity {
     static final String KEY_CACHE = "key_cache";
 
-    private Button btnTest;
+    private Button btnTestCache;
+    private Button btnTestRetrofit;
 
     @Override
     protected void onCreate(@Nullable Bundle savedInstanceState) {
         super.onCreate(savedInstanceState);
         setContentView(R.layout.actiity_main);
 
-        btnTest = (Button) findViewById(R.id.btn_test_cache);
-        btnTest.setOnClickListener(view -> {
-            remote().compose(RxRemoteCache.transformer(KEY_CACHE, new CacheAndRemoteStrategy())).subscribe(data -> {
+        btnTestCache = (Button) findViewById(R.id.btn_test_cache);
+        btnTestCache.setOnClickListener(view -> {
+            remote().compose(KakaCache.transformer(KEY_CACHE, new CacheAndRemoteStrategy())).subscribe(data -> {
                 Log.e("main", "next  data=" + data);
             }, error -> {
                 Log.e("main", "error", error);
             }, () -> {
                 Log.e("main", "completed");
             });
         });
+
+        btnTestRetrofit = (Button) findViewById(R.id.btn_test_retrofit);
+        btnTestRetrofit.setOnClickListener(view -> {
+            KakaRetrofit retrofit = new KakaRetrofit.Builder()
+                    .baseUrl("https://api.github.com/")
+                    .addConverterFactory(GsonConverterFactory.create())
+                    .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
+                    .build();
+
+            GitHubService service = retrofit.create(GitHubService.class);
+            service.listRepos("octocat").compose(KakaCache.transformer(KEY_CACHE, new FirstCacheStrategy())).subscribeOn(Schedulers.io()).subscribe(data -> {
+                LogUtils.e(data);
+            }, error -> {
+                LogUtils.e(error);
+            });
+        });
     }
 
     private rx.Observable<String> remote() {

app/src/main/res/layout/actiity_main.xml

@@ -1,14 +1,22 @@
 <?xml version="1.0" encoding="utf-8"?>
-<RelativeLayout
+<LinearLayout
     xmlns:android="http://schemas.android.com/apk/res/android"
     android:layout_width="match_parent"
-    android:layout_height="match_parent">
+    android:layout_height="match_parent"
+    android:orientation="vertical"
+    android:gravity="center">
 
     <Button
         android:id="@+id/btn_test_cache"
         android:layout_width="wrap_content"
         android:layout_height="wrap_content"
-        android:layout_centerHorizontal="true"
-        android:text="测试缓存"/>
+        android:text="测试普通缓存"/>
 
-</RelativeLayout>
+    <Button
+        android:id="@+id/btn_test_retrofit"
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:textAllCaps="false"
+        android:text="测试Retrofit缓存"/>
+
+</LinearLayout>

library/src/main/java/com/im4j/kakacache/rxjava/common/utils/LogUtils.java

@@ -0,0 +1,53 @@
+package com.im4j.kakacache.rxjava.common.utils;
+
+import android.util.Log;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.Iterator;
+import java.util.List;
+
+/**
+ * @version alafighting 2016-07
+ */
+public final class LogUtils {
+    private LogUtils() {
+    }
+
+    public static void e(Object obj) {
+        StackTraceElement element = new Throwable().getStackTrace()[1];
+        String className = element.getClassName();
+        className = className.substring(className.lastIndexOf(".") + 1);
+        String tag = className+'.'+element.getMethodName()+'('+element.getFileName()+':'+element.getLineNumber()+')';
+        String message = toString(obj);
+
+        Log.e("[KakaCache]", tag+"\t"+message);
+    }
+
+    private static String toString(Object obj) {
+        if (obj == null) {
+            return "[null]";
+        }
+        if (obj instanceof Throwable) {
+            return Log.getStackTraceString((Throwable) obj);
+        }
+        if (obj instanceof Collection) {
+            Iterator it = ((Collection) obj).iterator();
+            if (! it.hasNext())
+                return "[]";
+
+            StringBuilder sb = new StringBuilder();
+            sb.append('[');
+            for (;;) {
+                Object e = it.next();
+                sb.append(e);
+                if (! it.hasNext())
+                    return sb.append(']').toString();
+                sb.append(',').append('\n').append(' ');
+            }
+        }
+        return String.valueOf(obj);
+    }
+
+}