面试题：Go多路复用中如何合理设置缓冲区提升性能

1. 理解通道缓冲区作用

无缓冲通道：数据发送到无缓冲通道时，发送方会阻塞，直到有接收方从通道接收数据。这种通道保证了数据传输的同步性，适用于需要严格同步的场景，例如生产者 - 消费者模型中，生产者必须等待消费者准备好接收数据。
有缓冲通道：数据发送到有缓冲通道时，如果缓冲区未满，发送方不会阻塞。只有当缓冲区满了，发送方才会阻塞，直到有接收方从通道接收数据，腾出空间。

2. 根据业务场景设置通道缓冲区大小

高并发且数据量小的场景：
- 建议：可以使用较小的缓冲区，甚至无缓冲通道。因为在高并发下，每个数据处理时间短，数据传输频繁，无缓冲通道能更好地保证数据的有序处理，避免缓冲区数据堆积。
- 示例：在一个监控系统中，多个传感器不断发送状态数据（数据量小），这些数据需要按顺序处理以确保状态的一致性。

package main

import (
    "fmt"
)

func main() {
    sensorChan := make(chan int)
    go func() {
        for i := 0; i < 5; i++ {
            sensorChan <- i
        }
        close(sensorChan)
    }()
    for val := range sensorChan {
        fmt.Println("Received from sensor:", val)
    }
}

数据量大且处理时间长的场景：
- 建议：设置较大的缓冲区，这样可以让发送方在处理数据的同时，持续发送数据到通道，减少发送方阻塞时间，提高整体吞吐量。
- 示例：在一个文件处理系统中，从磁盘读取大量数据块（数据量大），并交给处理函数处理，处理过程耗时较长。

package main

import (
    "fmt"
)

func main() {
    dataChan := make(chan []byte, 100)
    go func() {
        // 模拟从磁盘读取数据
        for i := 0; i < 1000; i++ {
            data := make([]byte, 1024)
            dataChan <- data
        }
        close(dataChan)
    }()
    for data := range dataChan {
        // 模拟处理数据
        fmt.Println("Processing data of size:", len(data))
    }
}

流量控制场景：
- 建议：根据下游处理能力设置缓冲区大小。如果下游处理速度慢，设置较小的缓冲区，防止数据过度积压，起到流量控制的作用。
- 示例：在一个网络请求转发系统中，下游服务器处理能力有限，设置与下游处理能力匹配的缓冲区大小。

package main

import (
    "fmt"
)

func main() {
    requestChan := make(chan string, 10)
    go func() {
        requests := []string{"req1", "req2", "req3", "req4", "req5"}
        for _, req := range requests {
            requestChan <- req
        }
        close(requestChan)
    }()
    for req := range requestChan {
        // 模拟下游处理请求
        fmt.Println("Forwarding request:", req)
    }
}

星途面试题库

面试题：Go多路复用中如何合理设置缓冲区提升性能

知识考点

面试题答案

1. 理解通道缓冲区作用

2. 根据业务场景设置通道缓冲区大小