RabbitMQ 架构与 AngularJS/.NET Web API 应用程序相结合

Question

所以我有一个 SPA（单页应用程序），其中 AngularJS 作为前端，.NET Web API 作为后端（C#）。我需要根据某些用户操作生成 SQL Server Reporting Services (SSRS) 报告，即选择一些数据并按下按钮。这是我现有架构的粗略说明：

FRONT END                 BACK END                  SSRS Report
==========                =========                 ===========
**AngularJS Web page**-->**.NET Web API controller**-->**Intermediary class (passes arguments to report)** -->**Generate report and save to file**

这可行，但问题是在生成报告时，应用程序必须坐在那里等待它们完成，同时用户不能做任何事情。如果要创建许多报告，例如 100 多个，则可能需要一两分钟以上的时间，这对我来说是不可接受的。

这就是 RabbitMQ 的用武之地。我的想法是让 .NET Web API 控制器向服务器发送消息，一旦服务器接收到消息，就会对上面的中间类执行调用，从而生成报告，然后将响应发送回客户端，让他们知道报告已生成。我想我需要为此使用 RPC 场景，所以我在 RabbitMQ 网站上完成了相应的教程，看起来很简单。

但我不知道，这就是我的问题，是如何从 .NET Web API 应用程序启动客户端和服务器。坦率地说，我现在有点迷茫，因为这是我第一次真正体验任何类型的消息传递，我不太确定如何处理它，架构方面的。如果我能在脑海中详细了解整个事情是如何工作的，我可以从那里编写代码，但是在这一点上，我无法想象如何构建应用程序。

所以，问题：

1. 如何从 .NET Web API 控制器启动 RabbitMQ 服务器和客户端？服务器和客户端应该是类库还是控制台应用程序，还是完全是其他东西？

2. 我所设想的架构会起作用还是有更好的方法？

3. 任何关于如何实现我想要完成的任务的一般性建议都将不胜感激。

Answer 1

1. RabbitMQ 服务器不是从控制器启动的东西 - 它一直在运行。从控制器发送消息到rabbitmq 服务器。另一方面，另一个应用程序（Windows 服务、控制台应用程序，甚至 linux 上的单声道服务）监听这些消息并处理它们。 RabbitMQ 服务器只管理端点之间的消息发送。在您的情况下，处理来自您的控制器的消息的应用程序也始终在运行（使其成为 Windows 服务非常合理）。

2. 这样的架构可以正常工作。不过，RabbitMQ 可能有点矫枉过正——它更适用于多服务器、高负载的场景。如果您的负载较低并且所有应用程序都在同一台服务器上 - 您可以使用其他工具（如hangfire.io、MSMQ，或者甚至只是在 Web 服务器进程中运行后台任务，正如另一个答案所建议的那样）。如果简单的工具可以完成您的工作 - 为什么不呢。

3. 在生成报告时不要一直保持从客户端（浏览器）到服务器的连接。只需将任务放入兔子队列进行处理（或以其他方式开始生成报告）并返回。然后，如果工作完成，则从客户端定期轮询，或者（更好地）通过 websocket 连接通知客户端。这当然是在报告生成可能需要一些时间（比如说超过 30 秒）的情况下。

更新：更多关于整体架构的信息。

• RabbitMQ 服务器作为 Windows 服务运行，与 Windows 一起启动。
• 当您收到通过 Web api 生成报告的请求时 - 您将 GenerateReport 消息与所需的所有信息一起发送，然后您返回（不等待生成报告）。如果您将报告存储在数据库中，那么它们是持久的 - 在数据库中创建关于报告请求的记录。否则 - 将有关待处理报告的信息保留在内存中（以便您知道目前正在生成 X 报告）。在理想情况下，您还可以通过 Web 套接字在客户端和服务器之间建立持久连接。如果是这种情况 - 您将实时通知用户报告生成状态。否则 - 用户将不得不不时轮询服务器。
• 另一边有你写的windows服务，也是和windows server一起启动的。它侦听 GenerateReport 消息并开始生成。可以有多个这样的服务，或者您可以在一个服务中拥有多个订阅 - 这将在多个服务之间平均分配工作量。在报告生成期间 - 发布 ReportProgress 消息。完成后 - 更新数据库中的报告（如果您保留它们）并发布 ReportDone 消息。 Web Api 服务中的后台线程会侦听此类消息。如果您有 websockets 连接 - 您只需将这些消息传递给客户端，以便他实时查看报告生成进度。否则 - 更新数据库或内存结构，以便下次客户端轮询报告状态时 - 你有一些东西要返回。
• 如果出现问题 - 没问题（如果您将报告保存在数据库中）。在启动时，如果有待处理的报告，您的生成服务将检查数据库并生成它们。如果客户端在报告生成期间断开连接（从网站） - 仍然没有问题，当他返回时报告将准备好并且可以从数据库提供服务。如果 web api 服务崩溃 - 仍然没有问题。

Answer 2

在切换到 RabbitMQ 之前，您是否尝试过使用 .Net 4.5 中引入的新 HostingEnvironment.QueueBackgroundWorkItem

HostingEnvironment.QueueBackgroundWorkItem(cancellationToken =>
{
    return Task.Factory.StartNew(() =>
    {
        // Generate report and save to file
    }, cancellationToken);
});