kotlin 协程间通信

Kotlin 协程间通信可以通过 Channel、Actor 等方式实现。可以使用 Channel 来实现协程之间的消息传递，也可以使用 Actor 来实现协程之间的状态共享和消息传递。此外，还可以使用 Mutex、Semaphore 等同步原语来实现协程之间的同步和互斥。

相关问题

学习kotlin 协程，需要列出一个kotlin 协程的大纲

以下是Kotlin协程的基本大纲：

1. 理解协程的概念
- 协程与线程的区别
- 协程的优点和适用场景

2. 创建协程
- 基于函数的协程（suspend函数）
- 协程作用域（CoroutineScope）和上下文（CoroutineContext）
- 启动协程的不同方法

3. 协程的执行流程
- 协程的挂起与恢复
- 协程的取消和异常处理

4. 协程间的通信
- 使用通道（Channel）进行协程间通信
- 使用共享变量（Shared Mutable State）进行协程间通信

5. 协程的高级特性
- 协程的并发与并行
- 协程的调度策略（Dispatchers）
- 协程的异常处理和重试机制

6. 协程在Android中的应用
- 使用协程简化异步代码
- 协程的Android扩展库（ktx）
- 协程在不同架构模式中的应用

注意：以上是Kotlin协程的基本大纲，但是由于协程本身是一个庞大的主题，因此不同的人可能会有不同的理解和组织方式。

kotlin 协程 TCP demo

以下是基于 Kotlin 协程的 TCP Demo。它使用 Kotlin 协程中提供的 `Socket`、`ServerSocket` 等类来完成 TCP 通信。

1. 客户端：

import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking
import java.io.BufferedReader
import java.io.InputStreamReader
import java.io.PrintWriter
import java.net.Socket

fun main() = runBlocking {
    val socket = Socket("localhost", 12345)
    val reader = BufferedReader(InputStreamReader(socket.getInputStream()))
    val writer = PrintWriter(socket.getOutputStream(), true)

    GlobalScope.launch(Dispatchers.IO) {
        while (true) {
            val line = reader.readLine()
            println("Server: $line")
        }
    }

    while (true) {
        val input = readLine() ?: break
        writer.println(input)
    }
}

2. 服务端：

import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking
import java.io.BufferedReader
import java.io.InputStreamReader
import java.io.PrintWriter
import java.net.ServerSocket

fun main() = runBlocking {
    val serverSocket = ServerSocket(12345)

    while (true) {
        val socket = serverSocket.accept()
        val reader = BufferedReader(InputStreamReader(socket.getInputStream()))
        val writer = PrintWriter(socket.getOutputStream(), true)

        GlobalScope.launch(Dispatchers.IO) {
            while (true) {
                val line = reader.readLine()
                println("Client: $line")
                writer.println("You said: $line")
            }
        }
    }
}

在运行客户端和服务端之后，可以在客户端输入消息并发送到服务端，服务端会将消息回显给客户端。