实现remote数据请求demo

Author: Karl

app/src/main/java/com/xiasuhuei321/gank_kotlin/MainActivity.kt

@@ -9,17 +9,24 @@ import com.xiasuhuei321.gank_kotlin.extension.shortToast
 import kotlinx.android.synthetic.main.activity_main.*
 
 class MainActivity : AppCompatActivity() {
+    val data = DataSource()
     override fun onCreate(savedInstanceState: Bundle?) {
         super.onCreate(savedInstanceState)
         supportRequestWindowFeature(Window.FEATURE_NO_TITLE)
         window.setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN,
                 WindowManager.LayoutParams.FLAG_FULLSCREEN)
         setContentView(R.layout.activity_main)
+
         weatherIv.setOnClickListener {
             shortToast("weather icon be clicked")
         }
     }
 
+    override fun onResume() {
+        super.onResume()
+        data.getRemoteData()
+    }
+
     override fun onDestroy() {
         super.onDestroy()
         weatherWv.onDestroy()

app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/DataSource.kt

@@ -1,27 +1,29 @@
 package com.xiasuhuei321.gank_kotlin.datasource
 
+import android.util.Log
 import com.xiasuhuei321.gank_kotlin.datasource.bean.PostType
-import com.xiasuhuei321.gank_kotlin.datasource.local.LocalDataImpl
 import com.xiasuhuei321.gank_kotlin.datasource.remote.RemoteDataImpl
-import com.xiasuhuei321.gank_kotlin.extension.LogUtil
+import com.xiasuhuei321.gank_kotlin.datasource.remote.RemoteDataSource
 import com.xiasuhuei321.gank_kotlin.extension.io_main
 
 /**
  * Created by xiasuhuei321 on 2017/8/11.
  * author:luo
  * e-mail:[email protected]
  */
- object DataSource {
-    val TAG: String = "DataSource"
-//    val server = RemoteDataImpl()
-    val local = LocalDataImpl()
+ class DataSource {
+    private val remote :RemoteDataSource
+
+    init {
+        remote = RemoteDataImpl()
+    }
 
     fun getRemoteData(){
-        RemoteDataImpl.INSTANCE
+        remote
                 .getRemoteData(PostType.ANDROID,10,1)
                 .io_main()
                 .subscribe({
-                    jsonResult-> LogUtil.d(jsonResult.toString())
+                    jsonResult-> Log.w("okhttp","content--->${jsonResult}")
                 },{
                     e-> e.printStackTrace()
                 })

app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/bean/Data.kt

@@ -16,3 +16,5 @@ data class GankData(var _id:String,
                     var url:String,
                     var used:Boolean,
                     var who:String)
+
+

app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/net/ApiStore.kt app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/net/ApiService.kt

@@ -13,7 +13,7 @@ import retrofit2.http.Path
  * author:luo
  * e-mail:[email protected]
  */
-interface ApiStore {
+interface ApiService {
     /**
      * http://gank.io/api/data/数据类型/请求个数/第几页
      */

app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/net/Network.kt

@@ -0,0 +1,46 @@
+package com.xiasuhuei321.gank_kotlin.datasource.net
+
+import android.util.Log
+import com.xiasuhuei321.gank_kotlin.datasource.bean.API
+import okhttp3.Interceptor
+import okhttp3.OkHttpClient
+import okhttp3.logging.HttpLoggingInterceptor
+import retrofit2.Retrofit
+import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory
+import retrofit2.converter.gson.GsonConverterFactory
+
+/**
+ * Created by Karl on 2017/9/7 0007.
+ * Retrofit Client
+ */
+
+object Network {
+
+    private val retrofit:Retrofit
+    private val okHttpClient:OkHttpClient
+
+    init {
+        val logging = Interceptor{chain ->
+            val request = chain.request()
+            Log.w("okhttp","okhttp--->"+request.url().toString())
+            chain.proceed(request)
+        }
+
+        okHttpClient =
+                OkHttpClient.Builder().addInterceptor(logging).build()
+
+        retrofit =
+                Retrofit.Builder()
+                        .baseUrl(API.BASE_PATH)
+                        .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
+                        .addConverterFactory(GsonConverterFactory.create())
+                        .client(okHttpClient)
+                        .build()
+
+
+    }
+
+    val service:ApiService by lazy { retrofit.create(ApiService::class.java) }
+
+}
+

app/src/main/java/com/xiasuhuei321/gank_kotlin/datasource/net/ReHelper.kt

@@ -1,11 +1,8 @@
 package com.xiasuhuei321.gank_kotlin.datasource.remote
 
-import com.xiasuhuei321.gank_kotlin.datasource.net.ApiStore
 import com.xiasuhuei321.gank_kotlin.datasource.bean.GankData
 import com.xiasuhuei321.gank_kotlin.datasource.bean.JsonResult
-import com.xiasuhuei321.gank_kotlin.datasource.bean.TechBean
-import com.xiasuhuei321.gank_kotlin.datasource.net.ReHelper
-import com.xiasuhuei321.gank_kotlin.extension.io_main
+import com.xiasuhuei321.gank_kotlin.datasource.net.Network
 import io.reactivex.Observable
 
 
@@ -14,22 +11,14 @@ import io.reactivex.Observable
  * author:luo
  * e-mail:[email protected]
  */
-class RemoteDataImpl private constructor(): RemoteDataSource {
+class RemoteDataImpl :RemoteDataSource {
 
-    private var apiStore: ApiStore? = null
+    override fun getRemoteData(type: String, count: Int, pageIndex: Int):
+            Observable<JsonResult<List<GankData>>> {
 
-    init {
-        if (apiStore==null) apiStore =  ReHelper.getInstance().create(ApiStore::class.java)
-    }
-
-    companion object {
-        val INSTANCE:RemoteDataImpl by lazy { this.INSTANCE }
-    }
+        return Network.service
+                .getCategoricalData(type,count = count.toString(),pageIndex = pageIndex.toString())
 
-    override fun getRemoteData(type: String, count: Int, pageIndex: Int): Observable<JsonResult<List<GankData>>> {
-        return apiStore!!.getCategoricalData(type,count.toString(),pageIndex.toString())
     }
 
-
-
 }