问题标签 [queuing]

我在 Centos7 集群上使用 SLURM。

是否可以让 SLURM 在同一个集群上与各种操作系统（例如 Centos7 和 Debian8）一起工作？

我处于可以（本地）使用 Service Fabric 但无法利用 Azure 服务总线（或任何“云”）的情况。排队/发布订阅的必然结果是什么？允许使用 Service Fabric，因为它能够在本地容器中运行，并且是“免费的”。其他 3rd 方消息传递基础设施，如 RabbitMQ，也没有考虑（目前）。

我已经使用本地增长的总线构建了系统，基于 MSMQ 和 WCF，但我不知道如何在 SF 中完成同样的事情。我怀疑我可以让 SF 服务使用公开 msmq 的自定义 ICommunicationListener，但这只能在集群内部使用（我理解它的方式）。我可以在它们前面构建一个 HTTPBridge（在 SF 中）以使它们在集群外部可用，但是我会失去生命周期解耦（客户端能够调用服务，使用队列，即使该服务不在线当时）因为桥本身不会从排队的任何方面受益。

我有几种可能性，但都患有一些仅因 SF 而存在的疾病，本地。此外，相同的代码需要轻松部署到完整的 Azure SF（我可以在其中使用 ASB，这个问题就消失了），所以我不想仅仅因为我在某些情况下托管它而构建两个单独的系统。

感谢您的任何提示。

这个问题是关于服务架构之间的消息队列。关于这个话题几乎找不到任何东西。

情况：微服务 A 和微服务 B。微服务 A 处理实体“某事”而 B 需要处理。我保持一般性以避免讨论边界。

在我们的例子中，A 发送一条包含事件和相关实体 ID 的消息，例如 Event: somethingCreated SomethingID: 1234

B 使用此消息，如果它需要更多信息，它会使用 SomethingID 从 A 获取此消息。

第二种方法是消息不仅包含上述信息，还包含元数据，如 Event: somethingCreated SomethingID: 1234 SomeFieldKey: someFieldValue ...

精益消息： 优点： * 更少的网络使用 * 始终相同的消息结构 缺点： * 如果需要来自 A 的信息，则必须有某种机制来捕获例如网络故障

Fat message: Pro: * 信息已经存在 Con: * 如果附加信息不够怎么办？

所以它既有优点也有缺点，我在这里的目的是大致了解您正在使用哪种方法。

感谢您提前回答

我曾经能够简单地在编辑器上的不同程序上按运行，这些程序将显示在历史日志中，并在当前程序完成后留在队列中以串行运行，因为我从 3.6.1 更新到 3.6。 6 我似乎不能再这样做了。我不想运行单独的实例（对此有很多答案）我只想让工作像以前那样连续运行，如果有人知道答案，请帮助，非常感谢

请单击此链接以显示图片我很难分析如何创建一个有多个用户的排队系统。假设有 2 个用户正在使用一个系统，我将如何实现它？我不明白如何实现它的逻辑。就像第一个用户将点击下一个按钮一样，我将如何更新它以及队列号与其他用户一起更新

这是标准的银行柜台问题来说明我的问题：

考虑一个客户随机到达的简单银行。顾客将在两个柜台之一接受服务，每个柜台的服务时间都是随机的。此外，假设等待的顾客形成一个单一的 FIFO 队列。

这是并发症：

假设我们有兴趣从某一天的中午开始建模这个系统，而不是在一天的开始。中午时分，两个柜台都被占满了，已经排起了4个顾客。

有没有办法在 R simmer 中建立这个起始状态？

这是我已经拥有的代码：

我有一个生产者，它产生一个带有属性类型的 POJO。只能有两种类型，“A”和“B”。我有一个消费者线程池。每当我从 Producer 收到类型为“B”的消息时，在继续执行之前，我需要确保池中的所有其他线程都已完成执行（现在是默认的 Thread.sleep）。然后消费者线程应该获取“B”类型的消息并运行它。在此线程运行之前，无法从队列中弹出任何消息。

例子：

我是为我们组织构建专有学习管理系统的团队的一员。当用户注册在线课程时，我们会向用户发送一封电子邮件，其中包含有关登录以参加课程的说明。当大量注册用户时，显然这会导致一些性能问题。我正在研究开发一个用于排队电子邮件然后异步发送它们的框架。

我们的平台是通过 Azure Web 应用程序和 Azure SQL 数据库部署的。它是用 .NET MVC 编写的，我们通过 SMTP 发送电子邮件。

有没有人对最佳实践有任何建议，或者什么是实现这一目标的最有效方法？我研究了 Azure 服务总线、第三方开源解决方案（例如 Hangfire），并编写了一个标准控制台应用程序来处理要发送的电子邮件的数据库表。

假设有 M/M/1 队列，实现了两个优先级。如果存在高优先级或低优先级的客户（即只存在一个优先级的客户）会发生什么？二维马尔可夫链变成“有效的一维马尔可夫链”？它会像 FCFS 纪律一样行事吗？对整个系统和优先级客户的平均等待时间有何影响？

我正在实现一个批量获取和处理请求的查询引擎。我正在使用异步/等待。

现在执行流程在一个层次结构中运行，其中有一个包含查询的项目列表，每个查询都有一个获取。

我想要做的是将项目捆绑在 n 组中，所以即使每个项目都有 m 个查询，里面有 fetches，也只有 n*m 个请求同时运行；特别是只有一个请求将同时向同一个域发出。

问题是，当我等待项目的执行时（在外部级别，在一段时间内将项目分组并停止迭代，直到承诺解决），当内部查询的执行被推迟时，这些承诺正在解决，因为获取的内部等待。

这导致我的排队只是暂时停止，而不是等待内部承诺解决。

这是外部的排队类：

这是队列正在运行的简单项目类。我省略了多余的代码。

这是项目中包含的查询。每个项目都有一个查询列表。同样，一些代码被删除，因为它并不有趣。

while inAsyncItemQueue正确停止，但仅在执行流程到达第 3 步之前Query。一旦它到达那个 fetch，它是标准 fetch 函数的包装器，外部 promise 就会解析，并且我最终会同时执行所有请求。

我怀疑问题出在 Query 类的某个地方，但我对如何避免外部承诺的解决感到困惑。

我尝试让Query类run函数返回文档，以防万一，但无济于事。

任何想法或指导将不胜感激。我将尝试回答有关代码的任何问题或在需要时提供更多信息。

谢谢！

PS：这是一个带有工作示例的代码框：https ://codesandbox.io/s/goofy-tesla-iwzem

正如您在控制台出口中看到的那样，while 循环在提取完成之前进行迭代，并且它们都在同时执行。