SignalR入门

2023-10-02 17:48:58

一：什么是signalR

Asp.net SignalR是微软为实现实时通信的一个类库。一般情况下，signalR会使用JavaScript的长轮询(long polling)的方式来实现客户端和服务器通信，随着Html5中WebSockets出现，SignalR也支持WebSockets通信。另外SignalR开发的程序不仅仅限制于宿主在IIS中，也可以宿主在任何应用程序，包括控制台，客户端程序和Windows服务等，另外还支持Mono，这意味着它可以实现跨平台部署在Linux环境下。

SignalR将整个信息的交换封装起来，客户端和服务器都是使用JSON来沟通的，在服务端声明的所有Hub信息，都会生成JavaScript输出到客户端，.NET则依赖Proxy来生成代理对象，而Proxy的内部则是将JSON转换成对象。

客户端和服务端的具体交互情况如下图所示：

1、SignalR传输方式

1、HTML5 传输

这种传输方式当然是需要对HTML5兼容支持。如果客户端不支持HTML5 标准，那么你可以使用其他方式。

WebSocket：（前提是服务器和客户端都可以支持WebSocket ）。WebSocket 是唯一的能够支持服务器和客户端建立真正持久的双向连接的传输方式，但是就是WebSocket要求的条件比较苛刻。WebSocket真正能够支持只是在最新的IE 浏览器、Chrome、Firefox和一些其他的浏览器比如Opera 和 Safari。
服务端发送事件 ：就是我们常说的EventSource （除了IE的其他浏览器都支持支持服务器发送事件）。

2、Comet 传输

下面的传输方式都是建立在Comet Web应用模型上。这种传输方式会在浏览器或者其他客户端保持一个长连接的HTTP请求，服务器可以利用这个请求将数据推送到客户端，而不用等客户端单独去请求数据。

Forever Frame：（只有IE浏览器支持）Forever Frame 会创建一个隐藏的IFrame ，这个IFrame 会向服务器发起一个端点请求，但是这个请求不会结束。服务器会不停的发送脚本到客户端马上执行，提供一个从服务器端到客户端的单向实时连接。服务端到客户端和客户端到服务端分别是两个不同的连接，就像一个标准的HTTP请求，一旦有数据需要发送就会创建一个新的连接。
Ajax 长轮询：长轮询不会创建一个持久的连接，它是会保持一个客户端与服务器的连接，直到服务器做出应答就会立即关闭，然后创建一个新的连接。当连接重置的时候这会导致一些延迟。

2、SignalR连接模式

Http Persisten Connection(持久连接)对象：用来解决长时间连接的功能。还可以由客户端主动向服务器要求数据，而服务器端不需要实现太多细节，只需要处理PersistentConnection 内所提供的五个事件：OnConnected, OnReconnected, OnReceived, one rror 和 OnDisconnect 即可。
Hub（集线器）对象：用来解决实时(realtime)信息交换的功能，服务端可以利用URL来注册一个或多个Hub，只要连接到这个Hub，就能与所有的客户端共享发送到服务器上的信息，同时服务端可以调用客户端的脚本。SignalR将整个信息的交换封装起来，客户端和服务器都是使用JSON来沟通的，在服务端声明的所有Hub信息，都会生成JavaScript输出到客户端，.NET则依赖Proxy来生成代理对象，而Proxy的内部则是将JSON转换成对象。

下面的图展示了Hub和持久连接的关系，让你对底层的传输技术一目了然。

二、服务端

原文参考：教程：通过 SignalR 2 进行实时聊天

使用vs2012创建一个新的ASP.NET Web Application项目。

1、添加服务端Hub

在解决方案中添加SignalR Hub类选项，然后创建文件ChatHub.cs。此步骤将创建ChatHub.cs类文件并添加一组脚本文件和 SignalR 支持到项目的程序集引用。

注意：可以使用NuGet命令 install-package Microsoft.AspNet.SignalR 来引用SignalR到项目中

然后在ChatHub类中输入下面这段代码。

using Microsoft.AspNet.SignalR;

namespace WebApplication2
{
    public class ChatHub : Hub
    {
        public void Send(string name, string message)
        {
            // 客户端通过调用broadcastMessage来获取数据
            Clients.All.broadcastMessage(name, message);
        }
    }
}

在ChatHub类中，可以看到它继承自Microsoft.AspNet.SignalR.Hub类。从Hub类派生出类是构建SignalR应用程序的有用方式。在这个类(ChatHub)中定义的公共方法可以被网页内的脚本访问。

在这段代码中(ChatHub类)，客户端通过调用ChatHub.Send方法，并把名称和消息内容做为参数传递给ChatHub。而ChatHub则通过Clients.All.broadcastMessage方法把该消息广播给所有客户端。

Send方法演示了几个Hub概念:

在hub上声明一些公共方法，以便客户端可以调用它们。
使用Microsoft.AspNet.SignalR.Hub。客户端动态属性用于与连接到此中心的所有客户端进行通信。
调用客户机上的函数(如broadcastMessage函数)来更新客户机。

2、添加OWIN 启动类

在Solution Explorer中，右击项目，然后添加一个名为Startup的OWIN 启动类，然后输入下面这段代码。

using Microsoft.Owin;
using Owin;

[assembly: OwinStartup(typeof(WebApplication2.Startup))]
namespace WebApplication2
{
    public class Startup
    {
        public void Configuration(IAppBuilder app)
        {
            app.MapSignalR();
        }
    }
}

三、客户端

在项目中添加一个静态网页文件，并命名为index.html，然后右击该网页文件，并选择Set As Start Page，在Index.html中输入下面的代码，注意引用正确的文件名。

<!DOCTYPE html>
<html>
<head>
    <title>SignalR Simple Chat</title>
    <style type="text/css">
        .container {
            background-color: #99CCFF;
            border: thick solid #808080;
            padding: 20px;
            margin: 20px;
        }
    </style>
</head>
<body>
    <div class="container">
        <input type="text" id="message" />
        <input type="button" id="sendmessage" value="Send" />

        <input type="hidden" id="displayname" />
        <ul id="discussion"></ul>
    </div>

    <!--Reference the jQuery library. -->
    <script src="Scripts/jquery-1.12.4.js"></script>
    <!--Reference the SignalR library. -->
    <script src="Scripts/jquery.signalR-2.4.1.js"></script>
    <!--Reference the autogenerated SignalR hub script. -->
    <script src="signalr/hubs"></script>
    <!--Add script to update the page and send messages.-->
    <script type="text/javascript">
        $(function () {
            // Declare a proxy to reference the hub.
            var chat = $.connection.chatHub;
            // Create a function that the hub can call to broadcast messages.
            chat.client.broadcastMessage = function (name, message) {
                // Html encode display name and message.
                var encodedName = $('<div />').text(name).html();
                var encodedMsg = $('<div />').text(message).html();;
                // Add the message to the page.
                $('#discussion').append('<li><strong>' + encodedName
                    + '</strong>:&nbsp;&nbsp;' + encodedMsg + '</li>');
            };
            // Get the user name and store it to prepend to messages.
            $('#displayname').val(prompt('Enter your name:', ''));
            // Set initial focus to message input box.
            $('#message').focus();
            // Start the connection.
            $.connection.hub.start().done(function () {
                $('#sendmessage').click(function () {
                    // Call the Send method on the hub.
                    chat.server.send($('#displayname').val(), $('#message').val());
                    // Clear text box and reset focus for next comment.
                    $('#message').val('').focus();
                });
            });
        });
    </script>
</body>
</html>

客户端通过jquery.signalR.js和signalr/hubs来与服务器进行通信，首先它要声明一个代理来引用集线器。

var chat = $.connection.chatHub

请注意：在JavaScript中，对服务器类及其成员的引用必须是camelCase形式。本例中将C#服务端的ChatHub类在JavaScript中的引用为chatHub。

然后它要再定义一个回调函数，这个回调函数主要是为了让服务器进行调用，从而将数据推送到客户端。

chat.client.broadcastMessage = function (name, message) {
    //TODO:接收服务器推送的消息
};

而下面的代码则是为了确保在将消息发送到服务器之前已经与服务器建立了连接。启动连接后，传递一个函数来处理HTML页面中Send按钮上的单击事件。

// 与服务器建立连接后才能发送消息到服务器
$.connection.hub.start().done(function () {
    $('#sendmessage').click(function () {
        // 调用服务器端的ChatHub.Send方法，并把消息发送到服务器
        chat.server.send("name", "message");
    });
});

保存项目，并按F5运行,就可以实现B/S模式下的即时通讯。

四、运行结果

项目运行起来后，同时用多个浏览器打开的，输入各自的姓名之后，就能够实现即时通讯了。回到我们的vs，还能够看到自动生成的hubs脚本文件，如下图所示。

三个不同的浏览器中的运行方式。当 Tom、 Anand 和 Susan 发送消息时，所有浏览器实时更新：

码农公寓