函数在 golang 中用于处理流式数据，提升代码可读性和可重用性，主要通过 map 和 filter 函数实现：map 函数将输入元素转换为新元素；filter 函数过滤符合特定条件的元素。实战案例中，传感器生成温度数据，协程处理数据，仅输出高于 25 度的温度。
Golang 函数：用函数轻松处理流式数据
在 Golang 中，函数是一个强大的工具，可以处理流式数据并提高代码的可读性和可重用性。本文将向你展示如何使用函数来处理流式数据，并提供一个实战案例。
什么是函数？
立即学习“go语言免费学习笔记（深入）”；
函数是包含能执行特定任务的代码块。它们通常接受一个或多个参数，并返回一个结果。函数可以帮助你组织代码，并使之易于维护。
流式数据
流式数据是指以连续流的形式不断传输的数据。它通常用于处理实时数据，例如传感器数据或网络流量。处理流式数据需要使用特定的技术来处理不断流入的数据流。
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
使用函数处理流式数据
Golang 提供了几个内置函数，可以帮助你处理流式数据。其中最常用的是 map 和 filter 函数。
-
map函数将每个输入元素转换为一个新元素，并返回转换后的元素流。 -
filter函数过滤输入元素流，仅返回符合特定条件的元素。
例如，以下代码使用 map 函数将一组数字转换为平方值：
import "fmt"
func main() {
// 创建一个数字切片
nums := []int{1, 2, 3, 4, 5}
// 使用 map 函数将每个数字平方
squaredNums := map(nums, func(n int) int { return n * n })
// 打印平方后的数字
fmt.Println(squaredNums)
}输出：
[1 4 9 16 25]
实战案例
让我们通过一个实战案例来了解如何在 Go 中使用函数处理流式数据。假设你有一个传感器不断生成温度数据流。你希望过滤这些数据，仅保留高于 25 度的温度。
import (
"fmt"
"io"
"time"
"golang.org/x/sync/errgroup"
)
// 传感器生成温度数据
func sensor(w io.Writer, interval time.Duration) {
for {
time.Sleep(interval)
temp := 20 + rand.Intn(15)
fmt.Fprintln(w, temp)
}
}
func main() {
// 创建一个错误组
eg := new(errgroup.Group)
// 启动传感器协程
eg.Go(func() error {
return sensor(os.Stdout, 1 * time.Second)
})
// 创建一个通道来接收温度数据
temps := make(chan int)
// 启动处理协程，过滤数据
eg.Go(func() error {
for {
temp := <-temps
if temp > 25 {
fmt.Printf("温度高于 25 度：%d\n", temp)
}
}
})
// 启动协程向通道中发送数据
eg.Go(func() error {
for {
fmt.Scanf("%d", &temp)
temps <- temp
}
})
// 等待所有协程完成
if err := eg.Wait(); err != nil {
fmt.Println(err)
}
}在这个案例中，sensor 函数模拟一个生成温度数据的传感器。main 函数启动了一个协程来运行传感器，并创建了一个通道来接收温度数据。然后，它启动另一个协程来处理数据，只打印高于 25 度的温度。最后，它通过 eg.Wait() 等待所有协程完成。
