Go语言异步API设计的扇入扇出模式详解

本篇文章主要是结合我之前面试的各种经历和实战开发中遇到的问题解决经验整理的，希望这篇《Go语言异步API设计的扇入扇出模式详解》对你有很大帮助！欢迎收藏，分享给更多的需要的朋友学习~

扇出是从电子工程中借用的一个术语，它描述了输入的逻辑门连接到另一个输出门的数量。输出需要提供足够的电流来驱动所有连接的输入。在事务处理系统中，用来描述为了服务一个输入请求而需要做的请求总数。

扇入是指为逻辑单元的输入方程提供输入信号的最大数量。扇入是定义单个逻辑门可以接受的最大数字输入数量的术语。大多数晶体管-晶体管逻辑 (TTL) 门有一个或两个输入，尽管有些有两个以上。典型的逻辑门具有 1 或 2 的扇入。

扇入/扇出服务

我们举一个现实世界的例子，一个电子商务网站将自己与一个第三方支付网关整合在一起。 这里，网站使用支付网关的 API 来弹出支付屏幕并输入安全证书。同时，网站可能会调用另一个称为分析的 API 来记录支付的尝试。这种将一个请求分叉成多个请求的过程被称为 fan-out 扇出。在现实世界中，一个客户请求可能涉及许多扇出服务。

另一个例子是 MapReduce。Map 是一个扇入的操作，而 Reduce 是一个扇出的 操作。一个服务器可以将一个信息扇出到下一组服务（API），并忽略结果。或者可以等到这些服务器的所有响应都返回。如 如下图所示，一个传入的请求被服务器复用为转换成两个传出的请求：

扇入 fan-in 是一种操作，即两个或更多传入的请求会聚成一个请求。这种情况下，API如何聚合来自多个后端服务的结果，并将结果即时返回给客户。

例如，想想一个酒店价格聚合器或航班票务聚合器，它从不同的数据提供者那里获取关于多个酒店或航班的请求信息并显示出来。

下图显示了扇出操作是如何结合多个请求并准备一个最终的响应，由客户端消费的。

客户端也可以是一个服务器，为更多的客户提供服务。如上图所示，左侧的服务器正在收集来自酒店 A、酒店 B 和 航空公司供应商 A，并为不同的客户准备另一个响应。

因此，扇入和扇出操作并不总是完全相互独立的。大多数情况下，它将是一个混合场景，扇入和扇出操作都是相互配合的。

请记住，对下一组服务器的扇出操作可以是异步的。也是如此。对于扇入请求来说，这可能不是真的。扇入操作有时被称为 API 调用。

Go 语言实现扇入/扇出模式

Fan-out：多个 goroutine 从同一个通道读取数据，直到该通道关闭。OUT 是一种张开的模式，所以又被称为扇出，可以用来分发任务。

Fan-in：1 个 goroutine 从多个通道读取数据，直到这些通道关闭。IN 是一种收敛的模式，所以又被称为扇入，用来收集处理的结果。

package main
import (
	"context"
	"log"
	"sync"
	"time"
)
// Task 包含任务编号及任务所需时长
type Task struct {
	Number int
	Cost   time.Duration
}
// task channel 生成器
func taskChannelGerenator(ctx context.Context, taskList []Task) 
参考链接：
Fan-in/fan-out of services
Understanding the Fan-Out/Fan-In API Integration Pattern
终于介绍完啦！小伙伴们，这篇关于《Go语言异步API设计的扇入扇出模式详解》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！