优雅实现网络请求:协程+Flow+Retrofit+OkHttp

1.1 Flow的用法

1. 创建Flow ：使用 flow 函数创建一个Flow，然后在Flow中使用 emit 函数发射数据。

val?numbersFlow?=?flow?{
????for?(i?in?1..3)?{
????????emit(i)
????}
}

2. 收集Flow ：使用 collect 函数收集Flow中的数据，并对数据进行处理。

GlobalScope.launch?{
????numbersFlow.collect?{?number?->
????????println(number)
????}
}

3. 转换Flow ：使用 map、filter 等转换操作符对Flow中的数据进行转换。

val?squaresFlow?=?numbersFlow.map?{?number?->
????number?*?number
}

4. 组合Flow ：使用 combine、zip 等组合操作符将多个Flow组合在一起。

val?anotherFlow?=?flow?{
????for?(i?in?4..6)?{
????????emit(i)
????}
}

val?combinedFlow?=?numbersFlow.combine(anotherFlow)?{?a,?b?->
????a?+?b
}

5. 异常处理 ：使用 catch、onCompletion 等操作符处理Flow中的异常。

val?errorFlow?=?flow?{
????for?(i?in?1..3)?{
????????if?(i?==?2)?{
????????????throw?RuntimeException("Error?on?$i")
????????}
????????emit(i)
????}
}.catch?{?e?->
????println("Caught?exception:?$e")
}

1.2 Flow的原理

• Flow接口 ：代表一个数据流，可以通过 collect 函数进行收集。
• flow函数 ：用于创建一个Flow，可以在其中使用emit函数发射数据。
• collect函数 ：用于收集Flow中的数据，并对数据进行处理。
• 转换操作符 ：如map、filter等，用于对Flow中的数据进行转换。
• 组合操作符 ：如combine、zip等，用于将多个Flow组合在一起。
• 异常处理操作符 ：如catch、onCompletion等，用于处理Flow中的异常。

1.3 示例代码

import?kotlinx.coroutines.flow.*
import?kotlinx.coroutines.*

fun?main()?=?runBlocking?{
????//?创建Flow
????val?numbersFlow?=?flow?{
????????for?(i?in?1..5)?{
????????????delay(100)??//?模拟异步操作
????????????emit(i)
????????}
????}

????//?转换Flow
????val?squaresFlow?=?numbersFlow.map?{?number?->
????????number?*?number
????}

????//?收集Flow
????squaresFlow.collect?{?square?->
????????println("Square:?$square")
????}

????//?组合Flow
????val?anotherFlow?=?flow?{
????????for?(i?in?6..10)?{
????????????delay(100)
????????????emit(i)
????????}
????}

????val?combinedFlow?=?numbersFlow.combine(anotherFlow)?{?a,?b?->
????????a?+?b
????}

????combinedFlow.collect?{?sum?->
????????println("Sum:?$sum")
????}

????//?异常处理
????val?errorFlow?=?flow?{
????????for?(i?in?1..3)?{
????????????if?(i?==?2)?{
????????????????throw?RuntimeException("Error?on?$i")
????????????}
????????????emit(i)
????????}
????}.catch?{?e?->
????????println("Caught?exception:?$e")
????}

????errorFlow.collect?{?number?->
????????println("Number:?$number")
????}
}

通过这个示例，我们可以看到Flow提供了一种简洁、优雅的方式来处理异步、时间相关的操作。我们可以使用Flow的各种操作符对数据流进行转换、组合和异常处理，从而更好地组织和管理我们的代码。

2.1 Retrofit的用法

1. 创建Retrofit实例 ：使用 Retrofit.Builder 创建一个Retrofit实例，并配置HTTP客户端（如OkHttp）、基本URL和转换器等。

val?retrofit?=?Retrofit.Builder()
????.baseUrl("https://api.example.com/")
????.client(OkHttpClient())
????.addConverterFactory(GsonConverterFactory.create())
????.build()

2. 定义API接口 ：创建一个Kotlin接口，并使用注解描述API的请求方式、路径、参数等信息。

interface?ApiService?{
????@GET("user/{id}")
????suspend?fun?getUser(@Path("id")?id:?Int):?User
}

3. 创建API接口实例 ：使用Retrofit实例的 create 方法创建API接口的实例。

val?apiService?=?retrofit.create(ApiService::class.java)

4. 调用API接口 ：直接调用API接口的方法发起网络请求。

GlobalScope.launch?{
????val?user?=?apiService.getUser(1)
????println("User:?$user")
}

2.2 Retrofit的原理

• Retrofit类 ：用于创建和配置Retrofit实例，以及创建API接口的实例。
• 注解 ：如 @GET、@POST、@Path 等，用于描述API的请求方式、路径、参数等信息。
• 转换器 ：如 GsonConverterFactory、MoshiConverterFactory 等，用于将HTTP响应转换为Kotlin或Java对象，以及将对象转换为请求体。
• HTTP客户端 ：如OkHttpClient，用于实际发起网络请求。Retrofit内部使用HTTP客户端来处理网络请求和响应。

1. 使用 Retrofit.Builder 创建一个Retrofit实例，并配置HTTP客户端、基本URL和转换器等。
2. 使用注解定义API接口，并描述API的请求方式、路径、参数等信息。
3. 使用Retrofit实例的 create 方法创建API接口的实例。Retrofit会使用动态代理创建一个实现了API接口的对象。
4. 调用API接口的方法发起网络请求。Retrofit会根据方法的注解信息构建HTTP请求，并使用HTTP客户端发起请求。然后，Retrofit会使用转换器将HTTP响应转换为Kotlin或Java对象，并返回给调用者。

2.3 示例代码

import?retrofit2.Retrofit
import?retrofit2.converter.gson.GsonConverterFactory
import?retrofit2.http.GET
import?retrofit2.http.Path
import?kotlinx.coroutines.runBlocking
import?okhttp3.OkHttpClient

data?class?User(val?id:?Int,?val?name:?String)

interface?ApiService?{
????@GET("user/{id}")
????suspend?fun?getUser(@Path("id")?id:?Int):?User
}

fun?main()?=?runBlocking?{
????val?retrofit?=?Retrofit.Builder()
????????.baseUrl("https://api.example.com/")
????????.client(OkHttpClient())
????????.addConverterFactory(GsonConverterFactory.create())
????????.build()

????val?apiService?=?retrofit.create(ApiService::class.java)

????val?user?=?apiService.getUser(1)
????println("User:?$user")
}

这个示例展示了如何使用Retrofit优雅地实现网络请求。

val?okHttpClient?=?OkHttpClient.Builder()
????.connectTimeout(15,?TimeUnit.SECONDS)
????.readTimeout(15,?TimeUnit.SECONDS)
????.writeTimeout(15,?TimeUnit.SECONDS)
????.build()

val?retrofit?=?Retrofit.Builder()
????.baseUrl("https://api.example.com/")
????.client(okHttpClient)
????.addConverterFactory(GsonConverterFactory.create())
????.addCallAdapterFactory(CoroutineCallAdapterFactory())
????.build()

interface?ApiService?{
????@GET("user/{id}")
????suspend?fun?getUser(@Path("id")?id:?Int):?User
}

fun?getUser(id:?Int):?Flow<User>?=?flow?{
????val?apiService?=?retrofit.create(ApiService::class.java)
????val?user?=?apiService.getUser(id)
????emit(user)
}.catch?{?e?->
????//?处理异常
}

viewModelScope.launch?{
????getUser(1).collect?{?user?->
????????//?处理数据
????}
}

在这个代码中，我们使用 viewModelScope.launch 来启动一个协程，并在协程中收集Flow。我们可以在 collect 函数中处理数据。