12.1 Android中协程的基本使用

前言

在使用协程的时候一直没有一个具体的概念，只知道协程能够使得异步操作等同于同步操作，且不会造成线程阻塞，且第一次使用协程是根据前辈的代码修改而学会的，没有一个规范性的思维，通过查看官方资料将协程的使用重新梳理一遍，一个简单，不麻烦的做法。

1、导入依赖

选择依赖的方式主要分为两种，查看创建项目的时候中Build configuration language的选项选择的某一项，根据项目来选择

Groovy：

dependencies {implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:1.3.9'
}

kotlin：

dependencies {implementation("org.jetbrains.kotlinx:kotlinx-coroutines-android:1.3.9")
}

2、使用协程获取服务器中的数据

目的： 防止直接在UI线程中进行网络请求出现线程阻塞，导致应用程序无响应（ANR）

Dispatchers.IO：
用于执行I/O操作，如读写文件、访问数据库等。
这个调度器会尝试在后台线程池中执行I/O密集型任务，从而避免阻塞主线程。

Dispatchers.Main：
用于在Android的主线程（UI线程）上执行协程。
这个调度器确保与UI相关的操作（如更新UI元素）在主线程上执行。
在非Android平台上（如桌面应用或纯Kotlin项目），Dispatchers.Main 可能不可用或行为不同。

Dispatchers.Default：
用于执行计算密集型任务。可用于执行网络请求，获取服务器数据
这个调度器使用共享的后台线程池来执行协程，从而优化CPU资源的利用。
它是默认的调度器，如果你没有为协程指定调度器，那么它将使用 Dispatchers.Default。

Dispatchers.Unconfined：
不绑定到任何特定的线程。
协程在哪个线程上启动，它就会在那个线程上继续执行，直到遇到挂起点（如 suspend 函数调用）。
一旦协程挂起并恢复，它可能会在任何线程上继续执行，这取决于挂起函数的实现。

通常不建议在生产代码中使用 Dispatchers.Unconfined，因为它可能导致难以追踪的线程安全问题。
用法：

// 创建一个协程作用域（通常是在ViewModel、Activity或Fragment中）
val coroutineScope = CoroutineScope(SupervisorJob() + Dispatchers.IO)// 在协程作用域中启动一个协程
coroutineScope.launch(Dispatchers.IO) {// 执行I/O操作
}

2.1 定义请求回调结果的数据类

sealed 关键字
sealed 关键字用于定义一个密封类（sealed class），用于控制子类的个数，只接受子类在密封类的同一个文件中声明，或者作为密封类的嵌套类。

有助于改进when表达式，当使用密封类的时候，编译器会确保when表达式覆盖所有可能得子类，如果没有覆盖的话，则会出现报错的提醒，这有助于提高代码的健壮性和可维护性。

sealed class Result<out R> {data class Success<out T>(val data: T) : Result<T>()data class Error(val exception: Exception) : Result<Nothing>()
}

2.2 网络请求

为了防止主线程调用 makeLoginRequest 后出现阻塞界面情况。可以使用协程库中的 withContext() 函数将协程的执行操作移至其他线程，在其中执行耗时的网络请求操作

class LoginRepository(private val responseParser: LoginResponseParser) {private const val loginUrl = "https://example.com/login"suspend fun makeLoginRequest(jsonBody: String): Result<LoginResponse> {return withContext(Dispatchers.IO) {// Blocking network request codeval url = URL(loginUrl)(url.openConnection() as? HttpURLConnection)?.run {requestMethod = "POST"setRequestProperty("Content-Type", "application/json; utf-8")setRequestProperty("Accept", "application/json")doOutput = trueoutputStream.write(jsonBody.toByteArray())return Result.Success(responseParser.parse(inputStream))}return Result.Error(Exception("Cannot open HttpURLConnection"))}}
}

3、网络回调结构

假设请求回调的结构为：

{"success": true,"user": {"id": 123,"username": "exampleUser","email": "[e-mail]"},"token": "some_jwt_token"}

为了适配并处理网络请求回调的数据，需要创建数据类，方便适配回调数据。

data class User(val id: Int,val username: String,val email: String
)data class LoginResponse(val success: Boolean,val user: User?,val token: String?
)

将网络请求返回的InoutStream通过LoginResponseParser 处理，读取返回的数据并进行处理，转为LoginResponse的数据。

import com.google.gson.Gson
import com.google.gson.JsonSyntaxException
import java.io.BufferedReader
import java.io.InputStream
import java.io.InputStreamReaderobject LoginResponseParser {private val gson = Gson()@Throws(JsonSyntaxException::class)fun parse(inputStream: InputStream): LoginResponse {return try {// 使用try-with-resources语句自动关闭BufferedReadergson.fromJson(BufferedReader(InputStreamReader(inputStream)).use {it.readText()}, LoginResponse::class.java)} catch (e: IOException) {// 处理IOException，例如记录日志或抛出运行时异常throw RuntimeException("Failed to read input stream", e)} catch (e: JsonSyntaxException) {// 处理JsonSyntaxException，例如记录日志或抛出运行时异常throw RuntimeException("Failed to parse JSON", e)}}
}

4、通过ViewModel处理网络请求数据

class LoginViewModel(private val loginRepository: LoginRepository
): ViewModel() {fun login(username: String, token: String) {viewModelScope.launch {val jsonBody = "{ username: \"$username\", token: \"$token\"}"val result = try {loginRepository.makeLoginRequest(jsonBody)} catch(e: Exception) {Result.Error(Exception("Network request failed"))}when (result) {is Result.Success<LoginResponse> -> // Happy pathelse -> Result.Error(Exception("reponse is error"))// Show error in UI}}}
}

想要了解更多协程相关的知识点，可以查看官网