SignalR 在集线器或控制器中实现 CRUD 方法

Question

我有一个基于 ASP.NET MVC 应用程序的 Angular 应用程序，并且有一个仪表板，其中显示了在创建/更新/删除事件中更改的一些平均值和总数。通常这些事件在Controller中实现如下：

Controller.cs：

[HttpPost]
public JsonResult Create(Record record)
{
    // code omitted for brevity
    return Json(new { Data = data, success = true }, JsonRequestBehavior.AllowGet);
}

[HttpPost]
public JsonResult Update(Record record)
{
    // code omitted for brevity
    return Json(new { Data = data, success = true }, JsonRequestBehavior.AllowGet);
}

[HttpPost]
public JsonResult Delete(int id)
{
    // code omitted for brevity
    return Json(new { Data = data, success = true }, JsonRequestBehavior.AllowGet);
}

但是，每次执行这些方法后，我都需要调用相应的 Hub 方法来更新仪表板页面上的数字。

Hub.cs：

public class NotificationHub : Hub
{
    public void Update(Record record)
    {
        Clients.All.updateStatisticsToPage(record);
    }
}

所以，我的问题是：

1)如何结合这些方法来更新仪表板页面上的数字？我应该将 CRUD 方法移动到集线器并只使用这种方法吗？我添加了最后一行是为了通知客户当前的统计数据。

[HttpPost]
public JsonResult Create(Record record)
{
    // code omitted for brevity
    return Json(new { Data = data, success = true }, JsonRequestBehavior.AllowGet);

    // send update to all clients
    Clients.All.updateStatisticsToPage(record);
}

或者我应该在执行 crud 操作后将方法保留在 Controller 方法中并调用 hub 方法？

2) 当我在一次 crud 事件后更新仪表板页面上的统计信息时，我认为我构建的结构不同于聊天应用程序。因为我只在 crud 事件之后向 Dashboard 组件发送通知。真的吗？

Answer 1

如果您想使用 SignalR，我建议使用 CQRS 架构模式。它将解决您的问题。在垂直切片架构中，您将看到向所有客户端发送通知的最佳位置。

1) 如果你想要一个简单但有味道的解决方案，那么就这样做吧。但我建议使用 CQRS。 2) 是的:)

Answer 2

另一方面，是否有另一种不使用 CQRS 而不是将 CRUD 方法移至 Hub 的智能解决方案？因为Hub类没有包含Controller类的一些方法，所以最好在Controller中继续使用同样的方法（Create Update Delete），添加Clients.All.updateStatisticsToPage(record);操作执行后的行。有可能吗，你能举个例子吗？

我没有以这种方式使用它，但我认为这是可能的。您可以尝试使用 IStatisticsHub 接口创建 StatisticsHub：

public interface IStatisticsHub
{
    Task Send(string message);
}

public class StatisticHub : Microsoft.AspNetCore.SignalR.Hub, IStatisticsHub
{
    private readonly IHubContext<StatisticHub > _context;

    public StatisticHub(IHubContext<EventTypeHub> context)
    {
        _context = context;
    }

    public async Task Send(string message)
    {
        await _context.Clients.All.SendAsync("Send", message);
    }
}

现在您可以将此集线器作为单例添加到 DI 容器：

services.AddSingleton<IStatisticsHub, StatisticHub>();

最后一步是将此集线器注入您的控制器：

public class Controller : ControllerBase
{
    private readonly IStatisticsHub _statisticsHub;

    public Controller(IStatisticsHub statisticsHub)
    {
        _statisticsHub = statisticsHub;
    }

    [HttpPost]
    public JsonResult Update(Record record)
    {
        // code omitted for brevity

        // send message to all clients
        _statisticsHub.Send("Statistics");

        return Json(new { Data = data, success = true }, JsonRequestBehavior.AllowGet);
    } 
}

它应该以这种方式工作。

首先，前端必须与这个集线器建立一个WebSocket连接来接收所有的消息，但我相信你已经知道了。