什么是流式传输？

流式传输是这一种以稳定持续流的形式传输数据的技术。

流式传输的使用场景

有些场景中，服务器返回的数据量较大，等待时间较长，客户端不得不等待服务器返回所有数据后，再进行相应的操作。这时候使用流式传输，可以将服务器数据碎片化，当每个数据碎片读取完成之后，就只传输完成的部分，而不需要等待所有数据都读取完成。

如何在ASP.NET Core SignalR中启用流式传输

在ASP.NET Core SignalR中当一个Hub方法的返回值是ChannelReader或者Task<ChannelReader>, 这个Hub方法自动就会变成一个流式传输Hub方法。

下面我们来做了一个简单的例子

创建一个ASP.NET Core Web应用

首先我们使用Visual Studio 2017创建一个ASP.NET Core Web应用程序。

选择创建ASP.NET Core 2.1的Web Application

创建Hub

下面我们添加一个StreamHub类，代码如下

public class StreamHub : Hub {        public ChannelReader<int> DelayCounter(int delay)     {         var channel = Channel.CreateUnbounded<int>();          _ = WriteItems(channel.Writer, 20, delay);          return channel.Reader;     }      private async Task WriteItems(ChannelWriter<int> writer, int count, int delay)     {         for (var i = 0; i < count; i++)         {             await writer.WriteAsync(i);             await Task.Delay(delay);         }          writer.TryComplete();     } }

• DelayCounter是一个流式传输方法, 它定义了一个延迟参数delay, 定义了推送数据碎片的间隔时间
• WriteItems是一个私有方法，它返回了一个Task对象
• WriteItems方法的最后一行writer.TryComplete()表明了流式传输完成

配置SignalR

首先我们在Startup类的ConfigureService方法中添加SignalR服务

                        
关键字：