使用发布-订阅模式使用 SignalR 向客户端发送更新

Question

我有一些信息需要实时显示给用户。在我重复调用服务器以获取新数据之前。

现在我正在考虑用 SignalR 替换这些重复调用。一般的想法是在客户端订阅集线器，当新条目将添加到数据库时，该集线器将向所有客户端发送更新，但是我坚持使用该结构的一般设计。

所以我有我的 WebAPI 项目和服务层。在添加新条目时的服务中，我将引发一个事件并在集线器内部捕获该事件并将更新发送给所有客户端。

使用 SignalR 实现这些事情的方法是否正确？鉴于我正在使用 asp.net WebAPI 和 SimpleInjector，有人可以解释我如何实现它。

Answer 1

带有 signalR 的 PubSub 模式可以使用组本地实现。以群组名称为主题，用户可以通过加入\离开群组来订阅\退订。

这里是代码 sn-ps。它是直截了当的，应该可以很好地扩展。

[HubName("PubSub")]
public class PubSubHub : Hub {
    public void Publish(string topic, object data) {
        Clients.Group(topic).onNewMsg(topic, data);
    }
    public async Task Subscribe(string topic) {
        await Groups.Add(Context.ConnectionId, topic);
        Clients.Client(Context.ConnectionId).onSubscribed(topic);
    }

    public async Task Unsubscribe(string topic) {
        await Groups.Remove(Context.ConnectionId, topic);
        Clients.Client(Context.ConnectionId).onUnsubscribed(topic);
    }
}

Answer 2

围绕 SignalR 设计 pub/sub 的方法有很多

我为 SignalR 创建了一个包装器，以事件聚合形式解决它

请查看维基

https://github.com/AndersMalmgren/SignalR.EventAggregatorProxy/wiki

使用 nuget 安装

Install-Package SignalR.EventAggregatorProxy 

查看演示项目 https://github.com/AndersMalmgren/SignalR.EventAggregatorProxy/tree/master/SignalR.EventAggregatorProxy.Demo.MVC4