本篇文章是对如何在asp.net core 的web api中使用Channels的简单介绍.
引子
设想一下我们有这样一个典型的生产者/消费者问题，我在controller 上收到一个请求并希望通过后台服务执行任务。
相信你的第一个想法是使用一些外部的消息队列来实现，如 RabbitMQ 或Kafka，这对于这样的一个简单任务来说这些组件都有点重了。所以我决定在不使用任何外部消息队列的情况下实现它。
所以我的第一次尝试是使用ConcurrentQueue和一些锁，但它变得很复杂。所以我尝试搜索一些更简单的方式，直到我找到了“Channels”。
Channels是什么
一个 Channel 是一个 . NET 数据结构或集合，我们可以在其中存储来自生产者的数据，同时消费者可以检索它，而无需从我们这边进行任何额外的同步。
生产者/消费者描述了生产者发布消息的行为，并且有一个或多个消费者可以对该消息进行处理，但每条消息只能读取一次。它不会对每个订阅者进行重复消费。换句话说就是，消费者之间是竞争消费。
例子
当我搜索示例时，我发现了很多控制台应用程序示例，但没有针对 Web API的，因此我决定尝试以 ASP.Net Core Web API 项目为例来进行演示
所以让我们开始吧。
在 Visual Studio 中创建一个 Web API 项目，或者您可以使用下面的 cmd命令进行创建
dotnet new webapi -o LearningChannels
现在为了简单起见，我使用两个后台任务，一个用于生产者，一个用于消费者。
WriterService
ReaderService
而对于ASP.NET Core Web API，最重要的部分是定义通道和依赖注入。
我们已经完成了更改。
让我们测试一下。运行应用程序
正如我们在输出窗口中看到的那样，一旦数据写入Channels，消费者就会读取它。
现在，如果您在我的示例中注意到我使用了无界Channels。
那是什么，还有什么其他选择。让我们看看他们。
有界Channels和无界Channels
CreateUnbounded方法创建一个对可以存储的项目数量没有限制的channel。当然在某些时候它可能会达到内存的限制，这时候你会得到内存不足的异常。
另一方面，CreateBounded方法可以创建一个具有在创建期间提供的显式数量限制的通道。
有界Channels有一些用于指示不同行为的选项,BoundedChannelFullMode
public enum BoundedChannelFullMode
{
Wait,
DropNewest,
DropOldest,
DropWrite
}
默认为Wait，等待队列中有空间时写入。因此TryWrite将为此类channel返回 false。
DropOldest将删除“最旧”的数据。
DropNewest将删除最新的数据。
DropWrite删除当前正在写入的数据。
因此，您可以根据你的场景选择适合的选项。
总结
在本教程中，我们已经了解了通道如何在应用程序中处理异步任务时发挥作用。
希望你喜欢阅读它。
快乐编码并继续学习..！
参考阅读：
https://medium.com/@niteshsinghal85/using-channels-for-asynchronous-queuing-in-c-ed96c51d4576
