8

好的，所以我对消息队列感兴趣。我真的已经对这个主题进行了大量研究。我阅读了“programming windows azure”（关于 Azure 队列），阅读了大量有关 Azure 服务总线的教程和信息，还观看了有关消息传递模式的第 9 频道视频等。

但我只是不明白：在现实生活场景中如何使用它？所有示例都只是将单个字符串或带有一些数据的对象放入队列中，然后从“另一端”的队列中读取它。但是你怎么知道如何处理这些数据？例如：我可以尝试将一个客户、一个订单和一个地址保存到数据库中，所以我将这 3 个对象放在一个队列中以读取另一端并将它们放入我的数据库中。我怎么知道如何处理这些对象？

我有一些问题：

  1. 将什么样的数据放入队列中。可能是一个命令，它在读取时执行，所以队列中的所有内容都具有相同的接口，并且对象本身知道要做什么？
  2. 在哪一层之间使用队列？我正在考虑将内容放入服务层的队列中（在验证之后）并在数据访问层中读取它，以便将其放入数据库中。
  3. 一个人应该排多少队？你想连接的层之间只有一个队列，或者它们之间有多个队列（可能出于不同的目的，虽然我想不出任何）？
  4. 这种松散耦合形式允许我们对请求进行排队，以便稍后处理它们（例如：当我们想重新启动数据库时）。这很酷，但是如果我想读取数据而不是写入数据怎么办？那么数据库应该是在线的。我应该通过队列读取数据，还是我的服务层可以从数据访问层提取数据并将其传递给表示层？

我认为这是我脑海中嗡嗡作响的大部分问题。我希望任何人都可以为我解决这个问题。

4

3 回答 3

7

在最简单的示例中，假设您将要执行的操作序列化到队列中，然后是参数的序列化版本：

问：Delete: User 5

这很好，因为您的 Worker Role 可以阅读并采取相应的行动。在这个例子中似乎不是一个很大的好处，因为排队可能需要和删除一样长的时间，但是如果你想对所有用户执行 BI 怎么办？在等待同步请求进行处理时，您的网页或应用程序永远不会刷新。但是，如果您将该请求推送到队列中：

问：RunSome2HourProcess: User *

现在您可以返回您已将操作排队，然后继续您愉快的方式，而从队列中拉出的服务器将能够在闲暇时处理。

更重要的是，这可以实现更好的规模场景。如果最后一条消息被拆分怎么办？因此，您没有做所有用户，而是做了类似的事情：

问RunSome2HourProcess: User A*-M*

问RunSome2HourProcess: User N*-Z*

两个 azure worker 角色将分担负载并并行处理您的信息。

还有一些围绕重试、工作流、跨角色异步通信等的场景，但这应该为您提供一些理由，说明为什么在正确的场景中排队可以很好。

因此，在这些示例中： 1. 我们将操作和标识符/查询放入队列项中。从队列中轮询的工作者角色将知道如何处理它。

  1. 您可以在服务层和处理层之间使用队列。您可以在处理层之间使用队列。您可以在同一层中使用队列。天空是极限

  2. 我通常为每个操作创建 1 个队列。所以在上面的例子中，我有 Run2HourProcess 队列，只需将参数写入它。并为任何其他进程类型创建一个新队列。但它们非常灵活，所以这取决于开发人员。

  3. 除非它是长时间运行的读取（即示例中的缩略图生成示例或数据处理速度慢的结果），否则您访问数据库的速度也一样快。

于 2012-04-04T22:34:22.997 回答
2
  1. 嗯，你可以放任何你想要的东西。这只是一个消息，所以无论你的层同意什么都会起作用。我们会在消息中注明何时应发送电子邮件、何时需要处理视频等。
  2. 我不一定会考虑层之间的排队，就像在面向用户的实时进程（例如，Web 服务器）和后台处理之间排队一样。使用排队来做您不希望您的 Web 角色在用户等待时花时间做的事情。
  3. 你可以随心所欲地制作，真的。如果队列消息有一个字段说明它们的含义，那么您可以假设将所有内容放在一个队列中，尽管我不一定建议这样做。我们有大约六个队列：一个用于发送通知，一个用于视频处理，一个用于报告生成请求等。
  4. 我绝对不会使用队列作为数据存储和检索。这只是该工作的错误工具，例如尝试使用 TCP 存储数据。

请注意，单个工作实例（即 VM）可以读取任意数量的队列。您只需要以这种方式编写代码。如果您有很多没有看到太多流量的队列，那么这是降低成本的合理方法。另一种选择是将几种消息类型组合到一个队列中。这样，您只有一个地方可以查找消息。

或者，您可以让许多工作人员从同一个队列中读取，以便将工作平均分配给他们。

于 2012-04-05T18:12:30.693 回答
0

除了 Rob 提到的之外，消息队列还用于处理突发流量，这些流量可以等待（在队列中）直到有空闲的 worker 可用。

我相信 Azure 服务总线、队列和主题在幕后利用消息队列来完成同样的任务。我还看到 AppFabric 托管的 Workflow Foundation 也可能会这样做的提示。

于 2012-04-05T16:42:22.300 回答