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 条评论
登录 后参与评论

相关文章

来自专栏白驹过隙

ACE - 代码层次及Socket封装

原文出自http://www.cnblogs.com/binchen-china,禁止转载。

521
来自专栏技术博客

Asp.Net Web API 2第四课——HttpClient消息处理器

    Asp.Net Web API第一课:入门http://www.cnblogs.com/aehyok/p/3432158.html

683
来自专栏Netkiller

《Netkiller Virtualization 手札》Docker 卷管理

本文节选择《Netkiller Virtualization 手札》Docker 卷管理 1.5. 卷管理 1.5.1. 列出卷 docker volume l...

3749
来自专栏C#

简单易用的.NET免费开源RabbitMQ操作组件EasyNetQ解析

   对于目前大多的.NET项目,其实使用的技术栈都是差不多,估计现在很少用控件开发项目的了,毕竟一大堆问题。对.NET的项目,目前比较适合的架构ASP.NET...

2308
来自专栏大内老A

我的WCF之旅(2):Endpoint Overview

WCF实际上是构建了一个框架,这个框架实现了在互联系统中各个Application之间如何通信。使得Developers和Architect在构建分布式系统中,...

1757
来自专栏白驹过隙

ACE - 代码层次及Socket封装

2767
来自专栏Kubernetes

Kubernetes Node Co

Author: xidianwangtao@gmail.com NewNodeController入口 Controller Manager在启动时,会启...

3487
来自专栏大内老A

WCF后续之旅(1): WCF是如何通过Binding进行通信的

《我的WCF之旅》系列自开篇以来,得到了园子里很多朋友的厚爱,并荣登了博客园2007年度系列博文Top 10。由于工作原因,沉寂了几个月,今天开始WCF新的旅程...

1909
来自专栏Android知识点总结

SpringBoot-18-之AOP+log4j 记录访问请求信息

761
来自专栏恰同学骚年

.NET Core微服务之基于EasyNetQ使用RabbitMQ消息队列

  “消息”是在两台计算机间传送的数据单位。消息可以非常简单,例如只包含文本字符串;也可以更复杂,可能包含嵌入对象。消息被发送到队列中,“消息队列”是在消息的传...

1525

扫码关注云+社区