使用SignalR 2进行服务器广播

概述

在本教程中，您将创建一个股票代码应用程序，该应用程序代表您希望定期“推送”或广播从服务器到所有连接客户端的通知的实时应用程序。在本教程的第一部分中，您将从头开始创建该应用程序的简化版本。在本教程的其余部分中，您将安装包含其他功能的NuGet包，并查看这些功能的代码。

您将在本教程的第一部分中构建的应用程序显示包含库存数据的网格。

服务器会定期随机更新股票价格并将更新推送到所有连接的客户端。在浏览器中，Change和％列中的数字和符号会根据来自服务器的通知动态更改。如果您打开其他浏览器到同一个URL，它们都会同时显示相同的数据和相同的数据更改。

该Microsoft.AspNet.SignalR.Sample NuGet包安装在Visual Studio项目的样本模拟股票行情应用。

设置服务器代码

在本节中，您将设置在服务器上运行的代码。

创建Stock类
首先创建将用于存储和传输股票信息的Stock模型类。

在项目文件夹中创建一个新的类文件，将其命名为Stock.cs，然后使用以下代码替换模板代码：

using System;
namespace SignalR.StockTicker
{
public class Stock
{
private decimal _price;
public string Symbol { get; set; }
public decimal Price
{
get
{
return _price;
}
set
{
if (_price == value)
{
return;
}
_price = value;
if (DayOpen == 0)
{
DayOpen = _price;
}
}
}
public decimal DayOpen { get; private set; }
public decimal Change
{
get
{
return Price - DayOpen;
}
}
public double PercentChange
{
get
{
return (double)Math.Round(Change / Price, 4);
}
}
}
}

创建股票时要设置的两个属性是Symbol（例如，Microsoft的MSFT）和Price。其他属性取决于您设置Price的方式和时间。第一次设置Price时，该值会传播到DayOpen。设置Price时的后续时间，Change和PercentChange属性值将根据Price和DayOpen之间的差异计算。

创建StockTicker和StockTickerHub类
您将使用SignalR Hub API来处理服务器到客户端的交互。从SignalR Hub类派生的StockTickerHub类将处理从客户端接收连接和方法调用。您还需要维护库存数据并运行Timer对象以定期触发价格更新，而与客户端连接无关。您不能将这些函数放在Hub类中，因为Hub实例是瞬态的。为集线器上的每个操作创建一个Hub类实例，例如从客户端到服务器的连接和调用。因此，保存库存数据，更新价格和广播价格更新的机制必须在一个单独的类中运行，您可以将其命名为StockTicker。

您只需要在服务器上运行StockTicker类的一个实例，因此您需要将每个StockTickerHub实例的引用设置为singleton StockTicker实例。StockTicker类必须能够向客户端广播，因为它具有库存数据并触发更新，但StockTicker不是Hub类。因此，StockTicker类必须获取对SignalR Hub连接上下文对象的引用。然后，它可以使用SignalR连接上下文对象向客户端广播。

在解决方案资源管理器中，右键单击该项目，然后单击添加| SignalR Hub Class（v2）。

将新集线器命名为StockTickerHub.cs，然后单击“ 添加”。SignalR NuGet包将添加到您的项目中。

使用以下代码替换模板代码：

该中心类是用来定义方法的客户端可以调用服务器上。您正在定义一种方法：GetAllStocks()。当客户端最初连接到服务器时，它将调用此方法以获取所有具有当前价格的股票的列表。该方法可以同步执行并返回，IEnumerable因为它从内存返回数据。如果方法必须通过执行涉及等待的操作（例如数据库查找或Web服务调用）来获取数据，则应指定Task<ienumerable>为返回值以启用异步处理。

HubName属性指定如何在客户端的JavaScript代码中引用Hub。如果不使用此属性，则客户端上的默认名称是类名称的驼峰版本，在本例中为stockTickerHub。

正如您稍后在创建StockTicker类时所看到的那样，在其静态Instance属性中创建该类的单例实例。无论有多少客户端连接或断开连接，StockTicker的单例实例都会保留在内存中，并且该实例是GetAllStocks方法用于返回当前股票信息的实例。

在项目文件夹中创建一个新的类文件，将其命名为StockTicker.cs，然后使用以下代码替换模板代码：

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Threading;
using Microsoft.AspNet.SignalR;
using Microsoft.AspNet.SignalR.Hubs;
namespace SignalR.StockTicker
{
public class StockTicker
{
// Singleton instance
private readonly static Lazy<StockTicker> _instance = new Lazy<StockTicker>(() => new StockTicker(GlobalHost.ConnectionManager.GetHubContext<StockTickerHub>().Clients));
private readonly ConcurrentDictionary<string, Stock> _stocks = new ConcurrentDictionary<string, Stock>();
private readonly object _updateStockPricesLock = new object();
//stock can go up or down by a percentage of this f