ASP.NET SignalR2持久连接层解析

2018-06-22 06:08:25来源：未知阅读 ()

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

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

这一篇博客主要介绍一下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()对取消保护操作后返回的数据进行分割获取一个数组。