ASP.NET SignalR2持久连接层解析

    越是到年底越是感觉浑身无力,看着啥也不想动,只期盼着年终奖的到来以此来给自己打一针强心剂。估摸着大多数人都跟我一样犯着这样浑身无力的病,感觉今年算是没挣到啥钱,但是话也不能这么说,搞得好像去年挣到钱了似的。不过该做的事情还是得到,因为毕竟自己拿着工资,拿一天钱就得干一天活,无论自己觉得工资给的多还是少,觉得少可以辞职不干,拿着工资就证明自己愿意接受,既然愿意接受,那就没有理由不努力去干活,我觉得这是作为一个员工最起码的信念。

    隔着有一段时间没写文章了,反正最近各种乱七八糟的事都在发生,不过不管怎么样,事情总会慢慢过去。(最近没事,正在研究神学,待有所感悟再与大家分享。)

    这一篇主要介绍一下ASP.NET SignalR持久连接层的相关内容,如有写的不到位和错误的地方,还望大家多多指正。

一.ASP.NET SignalR概述:

    谈到ASP.NET SignalR大多数人应该会比较的熟悉,因在我们的mvc项目中,使用到ASP.NET SignalR的地方还是比较多的。

    ASP.NET SignalR是ASP.NET开发人员的库,它简化了向应用程序添加实时Web功能的过程。实时网络功能能够让服务器代码在连接的客户端可用时立即将内容推送到连接的客户端,而不是让服务器等待客户端请求新数据。SignalR可用于向ASP.NET应用程序添加任何类型的“实时”Web功能。任何时候用户刷新网页,看看新的数据或页面实现长轮询来获取新的数据,它是使用SignalR的候选人。示例包括仪表板和监视应用程序,协作应用程序(如同时编辑文档),作业进度更新和实时表单。

   SignalR还支持需要来自服务器的高频更新的全新类型的web应用。SignalR自动处理连接管理,并允许您同时向所有连接的客户端广播消息。SignalR支持“服务器推送”功能,其中服务器代码可以使用远程过程调用(RPC)在浏览器中调用客户端代码。SignalR的应用可以扩展到使用服务总线。

SignalR提供了一个用于创建从服务器端.NET代码调用客户端浏览器(和其他客户端平台)中的JavaScript函数的服务器到客户端远程过程调用(RPC)的简单API。SignalR还包括用于连接管理(例如,连接和断开事件)的API和分组连接。SignalR提供了一个用于创建从服务器端.NET代码调用客户端浏览器(和其他客户端平台)中的JavaScript函数的服务器到客户端远程过程调用(RPC)的简单API。SignalR还包括用于连接管理(例如,连接和断开事件)的API和分组连接。

    (以上描述摘自MSDN)

   上面介绍了ASP.NET SignalR的一些基本概念和操作,接下来看一下ASP.NET SignalR的抽象层,由底层向上以此为:Internet协议,传输(WebSockets,Server-SentEvents,foreverFrame,长轮询),持久连接层,Hub层。

     由以上的结构图可知ASP.NET SignalR的抽象层结构,在服务器端,当连接打开或关闭、接收数据、给客户端发送信息时,将接受到通知;在客户端,打开或关闭连接,发送或接收任何数据。在ASP.NET SignalR的持久连接层中,有一个核心对象:PersisterConnection类,接下来我们具体了解一下这个类的一些方法。

二.ASP.NET SignalR持久连接层服务端核心对象方法解析:

    ASP.NET SignalR中的每一个持久层都可以通过某一个URL从外部进行访问。为保持客户端和服务器之间持久连接的开放性,并使用传输在这样的连接上发送数据,这个用来访问SignalR持久连接的底层API提供了隐藏固有复杂性的抽象层。

   1.PersisterConnection类的事件方法:

      在PersisterConnection中包含几个事件方法,这几个方法都是虚方法,如下:

    OnConnected():在建立新连接时调用。

    OnReconnected():在超时后连接重新连接时调用。

    OnReceived():从连接接收数据时调用。

    OnDisconnected():当连接正常断开或由于超时时调用。

      以上的4个方法中,返回的类型都是TaskAsyncHelper.Empty,如下源码:

    /// <summary>
    /// 从连接接收数据时调用。
    /// </summary>
    /// <param name="request">当前连接的IRequest。</param>       <param name="connectionId">发送数据的连接的ID。</param>       <param name="data">有效负载发送到连接。</param>
    /// <returns>
    ///System.Threading.Tasks.Task在接收操作完成时完成。/// </returns>
    protected virtual Task OnReceived(IRequest request, string connectionId, string data)
    {
      return TaskAsyncHelper.Empty;
    }

    以上的方法都是异步方法,用以实现代码的异步执行,或者返回一个能够通过某个Task对象表示和异步执行的后台任务,在方法的传入参数中,代码中已经做类对应的介绍。如果需要进一步了解TaskAsyncHelper.Empty的相关信息,可以具体查看System.Threading.Tasks.Task命名空间中的类。

   2.ProcessRequest():处理所有的请求。

      PersisterConnection类的ProcessRequest()方法是用与OWIN入口点,该方法存在多个重载版本,现在只介绍一个重载的源码:

    public virtual Task ProcessRequest(HostContext context)
    {
      if (context == null)
        throw new ArgumentNullException("context");
      if (!this._initialized)
        throw new InvalidOperationException(string.Format((IFormatProvider) CultureInfo.CurrentCulture, Resources.Error_ConnectionNotInitialized, new object[0]));
      if (PersistentConnection.IsNegotiationRequest(context.Request))
        return this.ProcessNegotiationRequest(context);
      if (PersistentConnection.IsPingRequest(context.Request))
        return PersistentConnection.ProcessPingRequest(context);
      this.Transport = this.GetTransport(context);
      if (this.Transport == null)
        return PersistentConnection.FailResponse(context.Response, string.Format((IFormatProvider) CultureInfo.CurrentCulture, Resources.Error_ProtocolErrorUnknownTransport, new object[0]), 400);
      string connectionToken = context.Request.QueryString["connectionToken"];
      if (string.IsNullOrEmpty(connectionToken))
        return PersistentConnection.FailResponse(context.Response, string.Format((IFormatProvider) CultureInfo.CurrentCulture, Resources.Error_ProtocolErrorMissingConnectionToken, new object[0]), 400);
      string connectionId;
      string message;
      int statusCode;
      if (!this.TryGetConnectionId(context, connectionToken, out connectionId, out message, out statusCode))
        return PersistentConnection.FailResponse(context.Response, message, statusCode);
      this.Transport.ConnectionId = connectionId;
      Task<string> groupsToken = this.Transport.GetGroupsToken();
      Func<string, PersistentConnection, HostContext, Task> func = (Func<string, PersistentConnection, HostContext, Task>) ((g, pc, c) => pc.ProcessRequestPostGroupRead(c, g));
      HostContext hostContext = context;
      Func<string, PersistentConnection, HostContext, Task> successor;
      return TaskAsyncHelper.FastUnwrap(TaskAsyncHelper.Then<string, PersistentConnection, HostContext, Task>(groupsToken, successor, this, hostContext));
    }

    由以上的源码可以看出,该方法为一个异步虚方法,并且接受一个参数HostContext表示当前请求。当一个PersistentConnection的管道完成时,返回一个System.Threading.Tasks.Task。Transport.GetGroupsToken()用与获取组令牌。ProcessRequest()的另一个重载版本是OWIN的入口。

   3.TryGetConnectionId():用与获取ConnectionId。

     看到ConnectionId应该都不会陌生,因为在前面介绍的4中事件方法中有一个参数就是ConnectionId,该参数是一个唯一标识符,他和初始化通信过程中通过SiganlR自动产生的连接有关。默认情况下,SignalR框架将使用一个guid进行标识。

    可以使用该连接符给某些特定的客户端直接发送消息,或是对他们实施任何类型的个性化监视。

    接下来,我们具体看一下源码:

internal bool TryGetConnectionId(HostContext context, string connectionToken, out string connectionId, out string message, out int statusCode)
    {
      string str1 = (string) null;
      connectionId = (string) null;
      message = (string) null;
      statusCode = 400;
      try
      {
        str1 = this.ProtectedData.Unprotect(connectionToken, "SignalR.ConnectionToken");
      }
      catch (Exception ex)
      {
        TraceSource trace = this.Trace;
        string format = "Failed to process connectionToken {0}: {1}";
        object[] objArray = new object[2];
        int index1 = 0;
        string str2 = connectionToken;
        objArray[index1] = (object) str2;
        int index2 = 1;
        Exception exception = ex;
        objArray[index2] = (object) exception;
        trace.TraceInformation(format, objArray);
      }
      if (string.IsNullOrEmpty(str1))
      {
        message = string.Format((IFormatProvider) CultureInfo.CurrentCulture, Resources.Error_ConnectionIdIncorrectFormat, new object[0]);
        return false;
      }
      string[] strArray = str1.Split(PersistentConnection.SplitChars, 2);
      connectionId = strArray[0];
      if (string.Equals(strArray.Length > 1 ? strArray[1] : string.Empty, PersistentConnection.GetUserIdentity(context), StringComparison.OrdinalIgnoreCase))
        return true;
      message = string.Format((IFormatProvider) CultureInfo.CurrentCulture, Resources.Error_UnrecognizedUserIdentity, new object[0]);
      statusCode = 403;
      return false;
    }

   该方法返回bool值,接受5个参数,分别为:HostContext请求内容,connectionToken连接令牌,connectionId连接ID,message消息,statusCode状态代码。进入方法后,首先判断参数信息是否符合要求。ProtectedData.Unprotect()方法用与取消保护,接受传入的连接令牌。PersistentConnection.GetUserIdentity()用与获取用户身份。

   4.VerifyGroups():用与验证组。

     在我们的实际项目中,一般是针对某一个用户进行消息的处理,如果想要将消息按照组别进行操作应该怎么处理,在SignalR提供了一个VerifyGroups方法。

 internal IList<string> VerifyGroups(string connectionId, string groupsToken)
    {
      if (string.IsNullOrEmpty(groupsToken))
        return ListHelper<string>.Empty;
      string str1 = (string) null;
      try
      {
        str1 = this.ProtectedData.Unprotect(groupsToken, "SignalR.Groups.v1.1");
      }
      catch (Exception ex)
      {
        TraceSource trace = this.Trace;
        string format = "Failed to process groupsToken {0}: {1}";
        object[] objArray = new object[2];
        int index1 = 0;
        string str2 = groupsToken;
        objArray[index1] = (object) str2;
        int index2 = 1;
        Exception exception = ex;
        objArray[index2] = (object) exception;
        trace.TraceInformation(format, objArray);
      }
      if (string.IsNullOrEmpty(str1))
        return ListHelper<string>.Empty;
      string[] strArray = str1.Split(PersistentConnection.SplitChars, 2);
      string a = strArray[0];
      string json = strArray.Length > 1 ? strArray[1] : string.Empty;
      string b = connectionId;
      int num = 5;
      if (!string.Equals(a, b, (StringComparison) num))
        return ListHelper<string>.Empty;
      return (IList<string>) JsonSerializerExtensions.Parse<string[]>(this.JsonSerializer, json);
    }

  该方法返回一个List<string>集合,接受两个参数connectionId,groupsToken进行分组操作。ProtectedData.Unprotect()方法用与取消保护,接受传入的连接令牌。在SignalR中一般在处理消息请求时,需要进行取消保护这一步操作。Split()对取消保护操作后返回的数据进行分割获取一个数组。

三.总结:

   以上是简单的介绍SignalR的持久层的一些方法,并没有提供一些基本样例,因为个人觉得在网上还是有自己多的demo,微软的官网也提供的更为详尽的操作说明,所以在这里就不做这一方面的重复介绍。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏恰同学骚年

.NET Core微服务之基于MassTransit实现数据最终一致性(Part 1)

  关于数据一致性的文章,园子里已经有很多了,如果你还不了解,那么可以通过以下的几篇文章去快速地了解了解,有个感性认识即可。

1285
来自专栏葡萄城控件技术团队

异步陷阱之死锁篇

提倡异步编程旨在给用户更好的前端体验,但异步编程也让学习成本和犯错几率大大升高,其中最常见且最难处理的就是死锁。 何谓“死锁”,英文术语称“Deadlock”,...

2839
来自专栏AhDung

【手记】WebBrowser响应页面中的blank开新窗口及window.close关闭本窗体

上述窗体是指WebBrowser所在的Form,基本上,上述目的就是让该窗体表现得像个正常浏览器而已。

823
来自专栏菩提树下的杨过

用VS2010调试微软开放的部分源码

msdn上有一篇讲解如何用vs2008调试源码的文章:http://blogs.msdn.com/b/sburke/archive/2008/01/16/con...

2265
来自专栏张善友的专栏

使用RestSharp 库消费Restful Service

现在互联网上的服务接口都是Restful的,SOAP的Service已经不是主流。.NET/Mono下如何消费Restful Service呢,再也没有了方便的...

1925
来自专栏恰同学骚年

.NET Core微服务之开源项目CAP的初步使用

下面的文字来自CAP的Wiki文档:https://github.com/dotnetcore/CAP/wiki

2711
来自专栏大内老A

如何通过自定义MessageFilter的方式利用按键方式操作控件滚动条[附源代码]

很长一段时间内,一直在做一个SCSF(Smart Client Software Factory)的项目,已经进入UAT阶段。最近,用户提出了一个要求:需要通过...

2337
来自专栏大内老A

Enterprise Library深入解析与灵活应用(7):再谈PIAB与Unity之间的集成

在EnteLib中,PIAB(Policy Injection Application Block)和Unity的定位是轻量级的AOP框架和IoC容器(Cont...

20010
来自专栏NetCore

Do You Kown Asp.Net Core - 根据实体类自动创建Razor Page CURD页面模板

Scaffolding Template Intro 我们知道在Asp.Net MVC中,如果你使用的EF的DBContext的话,你可以在vs中通过右键解决方...

2266
来自专栏恰同学骚年

自己动手写一个简单的MVC框架(第二版)

  在ASP.NET MVC中,最核心的当属“路由系统”,而路由系统的核心则源于一个强大的System.Web.Routing.dll组件。

902

扫码关注云+社区