asp.net-mvc - 将 SignalR 与 Azure 表存储结合使用 - 什么体系结构？

Question

我有一个智能电网系统，其中多个硬件设备将原始传感器数据发送到 Azure 队列。每个设备每分钟发送一个数据包。多个 Worker Role 处理队列上的数据包，并将数据推送到 Table Storage。我有一个 Web 角色，用于保存应用程序，供用户查看其设备数据以及与其智能能源系统相关的许多其他警报和消息。目前，Web 应用程序仅使用一分钟间隔的 ajax 轮询来获取最新的数据更新以及任何其他消息和警报。我不想使用 ajax 'pulling'，而是使用 SignalR，并在更新可用时从云中“推送”更新。我不确定整体架构可能是什么样子。

到目前为止，我已经向我的 Web 角色添加了一个 SignalR Hub，只是为了看看我是否可以做到这一点。它工作正常。但是，当表存储发生变化时，如何从该 Hub 触发更新？我是否应该使用处理原始数据的工作角色托管集线器，然后从 Web 应用程序(客户端)建立跨域 SignalR 连接？我什至可以将端点与工作角色相关联吗？如果我有很多工作角色，我是不是只能连接到其中之一，从而错过其他工作角色的数据更新？

也许我应该创建一个单独的 Web 角色来托管 SignalR 集线器，但是如何将处理原始数据的工作角色的更改传达给集线器？也许我需要包含另一个 Azure 队列，它从工作角色获取有关数据更新、警报和任何其他消息的消息，并且该队列由 SignalR 服务器处理。但是，这种方法是否具有可扩展性？如果我有多个 SignalR 服务器实例处理消息队列，它们是否会共享相同的端点并了解实例间的所有客户端连接？或者，工作角色本身可能作为客户端连接到 SignalR 服务器，并将消息从那里转发到客户端。

如果数据以每分钟一次的可预测速率为每个设备生成，那么 SignalR 是否甚至是正确的方法。也许对于更新这个常规数据 ajax 'pulling' 是最好的方法，我应该只使用 SignalR 来处理不频繁的警报和消息，尽管同样，我如何将这些事件从工作角色传达到 SignalR 服务器？

什么样的整体架构适合我的需求？

编辑 06-09-2014 问题解决了一半

我遇到了 http://www.asp.net/signalr/overview/signalr-20/performance-and-scaling/scaleout-with-windows-azure-service-bus这似乎正是我所追求的。这处理了多个 Hub 服务器(Web 角色)实例的问题。现在我只需要一个可以在工作角色上运行的 SignalR 客户端库，以便他们可以通知集线器新数据可用，然后可以增强集线器类以将新数据路由到适当的连接 Web 客户端。

编辑 06-10-2014 找到了一个可行的解决方案

我已经为我的“什么架构”问题添加了一个答案。我认为我的设置的快速摘要可能会有用。我有许多与不同用户相关联的远程设备，这些用户将实时数据发布到 Azure 队列。发布到这些队列的数据由许多工作角色解析并保存到表存储中。 Web 角色为用户(客户端)提供 MVC5 Web 应用程序以登录并查看其数据。我想要一种机制，当新数据发布时，任何连接的客户端都会收到实时通知(客户端应用程序中的数据表和图表可以相应地更新)。具有服务总线横向扩展的 SignalR 被证明是答案。

Answer 1

我需要的解决方案的第一部分是部署客户端可以连接的 SignalR 集线器，以接收发送的任何通知。我无法使用基本的 SignalR 解决方案，因为 MVC5 Web 应用程序托管在一个可能有多个实例的 Web 角色上 - 问题是如何保持所有这些实例同步，以便客户端连接到它们的任何实例' d 仍然收到通知。事实证明，使用 Azure 服务总线的 SignalR 横向扩展可以解决这部分问题。有关如何设置的详细信息，请访问:http://www.asp.net/signalr/overview/signalr-20/performance-and-scaling/scaleout-with-windows-azure-service-bus - 设置非常容易。

问题的第二部分是如何生成源自 Worker Roles(我的队列数据处理器)的通知。首先，我需要能够在我的工作角色中托管 OWIN - 在 http://www.asp.net/aspnet/overview/owin-and-katana/host-owin-in-an-azure-worker-role 中提供的说明绰绰有余。完成此操作后，我创建了一个与部署在我的 Web 角色上的实例同名的空集线器实例(它是空的，因为我不希望有客户端直接连接到它)，并将启动类更改为:

public class Startup
{
    public void Configuration(IAppBuilder app)
    {
        String connectionString = "[Service Bus Connection String]";
        GlobalHost.DependencyResolver.UseServiceBus(connectionString, "[App Name]");
        app.MapSignalR();
    }
}

有了这个，如果我想从 Worker Roles 向客户端发送通知，我会执行以下操作:

var context = GlobalHost.ConnectionManager.GetHubContext<MyHub>();
context.Clients.All.clientMethod("[Message]");

真正发生的情况是，消息的副本被推送到背板(服务总线)并被 Web 角色拾取并推送到连接的客户端。实际上，我将检查谁在线(在 Web 角色中心实例中，我重写 OnConnected 方法以将用户的连接 ID 保存在存储在表存储中的配置文件中)，并且仅创建与这些用户关联的通知以减少 SignalR交通。