首页 / ASP.NET / ASP.NET Core SignalR中的流式传输深入讲解

ASP.NET Core SignalR中的流式传输深入讲解

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了ASP.NET Core SignalR中的流式传输深入讲解，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含5825字，纯文字阅读大概需要9分钟。

内容图文

前言

什么是流式传输？

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

流式传输的使用场景

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

SignalR

SignalR是一个.NET Core/.NET Framework的开源实时框架. SignalR的可使用Web Socket, Server Sent Events 和 Long Polling作为底层传输方式.

SignalR基于这三种技术构建, 抽象于它们之上, 它让你更好的关注业务问题而不是底层传输技术问题.

SignalR这个框架分服务器端和客户端, 服务器端支持ASP.NET Core 和 ASP.NET; 而客户端除了支持浏览器里的javascript以外, 也支持其它类型的客户端, 例如桌面应用.

如何在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 SignalR中的流式传输深入讲解 - 文章图片

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

ASP.NET Core SignalR中的流式传输深入讲解 - 文章图片

创建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服务

services.AddSignalR();

然后我们还需要为SignalR流添加路由，我们需要在Startup类的Configure方法中添加如下代码：

app.UseSignalR(routes =>
{
 routes.MapHub<StreamHub>("/streamHub");
});

添加SignalR客户端脚本库

这一步中我们需要在客户端中添加SignalR JS库。

这里我们需要借助npm来下载SignalR JS库。

npm install @aspnet/signalr

安装完成后，我们手动将signalr.js从<projectfolder>\node_modules@aspnet\signalr\dist\browser目录中拷贝到wwwroot\lib\signalr目录下

编写页面

拷贝以下代码到Index.cshtml

@page
@model IndexModel
@{
 ViewData["Title"] = "Home page";
}

<div class="container">
 <div class="row"> </div>
 <div class="row">
 <div class="col-6"> </div>
 <div class="col-6">
  <input type="button" id="streamButton" value="Start Streaming" />
 </div>
 </div>
 <div class="row">
 <div class="col-12">
  <hr />
 </div>
 </div>
 <div class="row">
 <div class="col-6"> </div>
 <div class="col-6">
  <ul id="messagesList"></ul>
 </div>
 </div>
</div>
<script src="~/lib/signalr/signalr.js"></script>
<script src="~/js/signalrstream.js"></script>

JavaScript中启用流式传输

在wwwroot\js目录中创建一个新文件signalrstream.js ,代码如下

var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
 return new (P || (P = Promise))(function (resolve, reject) {
 function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
 function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
 function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
 step((generator = generator.apply(thisArg, _arguments || [])).next());
 });
};

var connection = new signalR.HubConnectionBuilder()
 .withUrl("/streamHub")
 .build();
document.getElementById("streamButton").addEventListener("click", (event) => __awaiter(this, void 0, void 0, function* () {
 try {
 connection.stream("DelayCounter", 500)
  .subscribe({
  next: (item) => {
   var li = document.createElement("li");
   li.textContent = item;
   document.getElementById("messagesList").appendChild(li);
  },
  complete: () => {
   var li = document.createElement("li");
   li.textContent = "Stream completed";
   document.getElementById("messagesList").appendChild(li);
  },
  error: (err) => {
   var li = document.createElement("li");
   li.textContent = err;
   document.getElementById("messagesList").appendChild(li);
  },
  });
 }
 catch (e) {
 console.error(e.toString());
 }
 event.preventDefault();
}));

(() => __awaiter(this, void 0, void 0, function* () {
 try {
 yield connection.start();
 }
 catch (e) {
 console.error(e.toString());
 }
}))();

代码解释

与传统SignalR不同，这里我们使用了不同的语法创建一个SignalR连接

var connection = new signalR.HubConnectionBuilder()
 .withUrl("/streamHub")
 .build();

对于一般的SignalR连接，我们会使用connection.on方法来添加监听器，但是在使用流式传输的时候，我们需要改用connection.stream方法, 这个方法有2个参数

Hub方法名称, 本例中是DelayCounter
Hub方法的参数, 本例中是500

connection.stream("DelayCounter", 500)
 .subscribe({
 next: (item) => {
  var li = document.createElement("li");
  li.textContent = item;
  document.getElementById("messagesList").appendChild(li);
 },
 complete: () => {
  var li = document.createElement("li");
  li.textContent = "Stream completed";
  document.getElementById("messagesList").appendChild(li);
 },
 error: (err) => {
  var li = document.createElement("li");
  li.textContent = err;
  document.getElementById("messagesList").appendChild(li);
 },
});

connection.stream方法的返回对象中有一个subscribe方法，这个方法中可以注册3个事件

next - 获得到一个数据碎片时执行
complete - 流式传输完成时执行
error - 流式传输异常时执行

最终效果

ASP.NET Core SignalR中的流式传输深入讲解 - 文章图片

总结

流式传输不是一个新概念，但是对ASP.NET Core SignalR来说，这是一个非常棒的特性。流式传输保证的用户体验的流畅，也降低了服务器压力。

大部分程序员都知道SignalR不能传输过大的数据，但是使用流式传输之后，客户端不需要一次性等待服务器端返回所有数据，所以如果你的项目单次请求的数据量很大，可以考虑使用SignalR的流式传输改善用户体验，减轻服务器压力。

本篇源代码地址 https://github.com/lamondlu/StreamingInSignalR （本地下载）

好了，以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。

内容总结

以上是互联网集市为您收集整理的ASP.NET Core SignalR中的流式传输深入讲解全部内容，希望文章能够帮你解决ASP.NET Core SignalR中的流式传输深入讲解所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/376773.html

来源：【匿名】

更多 ►

【ASP.NET Core SignalR中的流式传输深入讲解】教程文章相关的互联网学习教程文章

ASP.NET SignalR 与LayIM配合，轻松实现网站客服聊天室（六）之好友申请、同意、拒绝【图】

不知道距离上一篇多久没有写了，可能是因为忙（lan）的关系吧。废话不多说，今天要介绍的不算什么新知识，主要是逻辑上的一些东西。什么逻辑呢，加好友，发送好友申请，对方审批通过，拒绝。（很遗憾，对方审批通过和拒绝后的通知没做，看完本博客的小伙伴有兴趣的可以尝试一下）。　　抽空写了新版本的聊天室，内容和上次差不多，这次加上了数据库来处理一些逻辑，包括登录注册功能，OK，现在开始。好友申请　　新版本中做了一个默...

在ASP.NET CORE 2.0使用SignalR技术【代码】

阅读目录一、前言二、环境搭建三、最后回到目录一、前言上次讲SignalR还是在《在ASP.NET Core下使用SignalR技术》文章中提到，ASP.NET Core 1.x.x 版本发布中并没有包含SignalR技术和开发计划中。时间过得很快，MS已经发布了.NET Core 2.0 Preview 2 预览版，距离正式版已经不远了，上文中也提到过在ASP.NET Core 2.0中的SignalR将做为重要的组件与MVC等框架一起发布。它的开发团队也兑现了承诺，使用TypeScript对它的javascript客...

ASP.NET Core 2.2 基础知识(十七) SignalR 一个极其简陋的聊天室【代码】【图】

原文:ASP.NET Core 2.2 基础知识(十七) SignalR 一个极其简陋的聊天室这是一个极其简陋的聊天室!这个例子只是在官方的例子上加了 Group 的用法而已,主要是官方给的 Group 的例子就两行代码,看不出效果.第一步:修改 chat.js"use strict";//创建一个连接var connection = new signalR.HubConnectionBuilder().withUrl("/chatHub").build();//定义客户端的 ReceiveMessage 方法 connection.on("ReceiveMessage", function (user, mess...

SignalR中丰富多彩的消息推送方式的实现代码【图】

在上一篇 SignalR 文章中，演示了如何通过 SignalR 实现了简单的聊天室功能；本着简洁就是美的原则，这一篇我们也来聊聊在 SignalR 中的用户和组的概念，理解这些基础知识有助于更好的开发基于 SignalR 的应用，通过对用户和分组的理解，进一步扩展出对用户和分组的管理，以及消息推送的各种方式，为全面接入 SignalR 做准备。 1. 用户在 SignalR 中，用户表示连接，一个用户代表一个连接，一个“系统用户”可以创建多个连接身份，...

Asp.Net Core使用SignalR进行服务间调用方法示例【图】

网上查询过很多关于ASP.NET core使用SignalR的简单例子，但是大部分都是简易聊天功能，今天心血来潮就搞了个使用SignalR进行服务间调用的简单DEMO。至于SignalR是什么我就不多说了，微软官方文档也不少。第一步新建项目所有VS开发第一步都是新建一个解决方案哈，这里我就不多介绍如何新建项目啦~~ 开发环境，VS2017,.NET CORE 2.1新建两个asp.net core项目如此简单的操作大家都懂的注入SignalR 在被调用的服务端的Startup.cs中...