如何在 golang 中使用非阻塞 i/o 提升并发性能？使用管道、通道等并发原语创建并行执行的任务。通过 syscall 包和标准库函数实现非阻塞 i/o，如打开非阻塞文件或设置管道为非阻塞。使用非阻塞读写操作，并在数据未准备好时返回 eagain。在真实场景中，可以利用非阻塞 i/o 实现高并发 http 服务器。
如何在 Golang 中使用非阻塞 I/O 提升并发性能
非阻塞 I/O 是读取或写入数据而不会阻塞当前线程的技术。它对于高负载、高并发应用至关重要，因为它能确保应用在处理请求时不受 I/O 操作的阻塞影响。
Golang 的非阻塞 I/O
立即学习“go语言免费学习笔记（深入）”；
Go 的并发编程模型建立在 Goroutine 之上，Goroutine 是轻量级的、并发的执行线程。通过使用管道、通道和其他并发原语，Go 程序可以轻松创建并行执行的任务。
非阻塞 I/O 在 Go 中通过 syscall 包和其他标准库函数来实现：
打开非阻塞文件
fd, err := syscall.Open("file.txt", syscall.O_RDWR|syscall.O_NONBLOCK, 0666)
if err != nil {
// handle error
}
打开非阻塞管道
reader, writer := os.Pipe() syscall.SetNonblock(writer.Fd(), true)
非阻塞读写
// 非阻塞读
b := make([]byte, 1024)
n, err := syscall.Read(fd, b)
if err == syscall.EAGAIN {
// 数据未准备好，非阻塞返回
} else if err != nil {
// handle other errors
}
// 非阻塞写
m := "Hello, World!"
n, err := syscall.Write(fd, []byte(m))
if err == syscall.EAGAIN {
// 数据未准备好，非阻塞返回
} else if err != nil {
// handle other errors
}
实战案例：非阻塞 HTTP 服务器
以下是一个使用非阻塞 I/O 实现的简单 HTTP 服务器：
package main
import (
"fmt"
"net"
"syscall"
)
func main() {
// 监听端口 8080
listener, err := net.Listen("tcp", ":8080")
if err != nil {
panic(err)
}
// 设置非阻塞
syscall.SetNonblock(listener.Fd(), true)
for {
// 非阻塞接受连接
conn, err := listener.Accept()
if err == syscall.EAGAIN {
// 没有传入连接，继续循环
continue
} else if err != nil {
// handle other errors
}
// 在新 Goroutine 中处理请求
go handleConnection(conn)
}
}
func handleConnection(conn net.Conn) {
// 在这里处理连接的 I/O 操作
}
