问题标签 [job-queue]

我系统中的每个 Job 都属于一个特定的用户 ID，并且可以从多个来源放入 rabbitmq。我的要求：

• 在任何给定时间，每个用户都不应运行超过 1 个作业。
• 其他用户的作业不应因为特定用户的作业堆积而出现任何延迟。
• 每个作业应至少执行一次。每个作业都有一个最大重试次数，如果失败，则会延迟重新插入队列（或可能延迟）。
• 维护作业顺序（每个用户）是可取的，但不是强制性的。
• 作业可能应该被持久化，因为我需要它们至少执行一次。作业没有到期时间。
• 任何工作人员都应该能够为任何用户运行作业。

有了这些要求，我认为为每个单独的用户维护一个队列是有意义的。我还需要所有工作人员监视所有用户队列并为用户执行作业，该用户的作业当前未在任何地方运行（即每个用户不超过 1 个作业）

这个解决方案可以在集群设置中使用 RabbitMQ 吗？由于队列的数量会很大，我不确定每个观察每个用户队列的工作人员是否会导致显着的开销。任何帮助表示赞赏。

是否有人拥有类似于Path 的 Android Priority Job Queue的 iOS 作业队列，他们不介意与社区共享？我对 iOS 很陌生，所以我不确定平台本身是否提供这样的解决方案。在 android 上不存在这样的东西，所以我不得不使用 Path 慷慨提供的库。如果 iOS 本身或 Xcode 有这样的解决方案/API，请指点我。如果不是，请分享你的，如果你不介意的话。谢谢。

基本上我正在寻找一个作业队列，即使在没有网络的情况下也可以允许用户将数据发送到服务器：这意味着即使用户应该关闭 iPhone，队列也会保留数据。然后在稍后的某个时间，当系统检测到网络时，将数据推送到服务器。

关于 SO 已经有一个类似的问题，所以我将其包括在内以获取更多详细信息：How to queue up data for server dispatch on android。不同之处在于我的问题是针对 iOS 的，而他们的问题是针对 Android 的。

用例

我的案例是假设用户在地铁（无网络）上搭乘火车，但决定发送电子邮件。然后关闭应用程序，甚至关闭手机。然后一个小时后，在用户重新打开手机后，当检测到网络时，应用程序会发送电子邮件。

我有一个客户端服务器应用程序，我正在使用 rxjava 来处理来自客户端的服务器请求。客户端一次只能执行一个请求，因此我打算使用类似于蹦床调度程序的线程队列调度程序。

现在我尝试实现一种机制来观察服务器上的变化。因此，我发送了一个长期存在的请求，该请求会阻塞，直到服务器发生一些更改并发回结果（长拉）。

这个长拉请求应该只在作业队列空闲时运行。我正在寻找一种在安排常规请求时自动停止监视请求并在队列变空时重新启动它的方法。我考虑过修改蹦床调度程序以获得这种行为，但我觉得这是一个常见问题，可能有更简单的解决方案？

我正在构建一个具有这种结构的作业队列（Nodejs+Mongodb）：

我在我的系统中定义了 4 种状态：新、等待、工作、失败、完成

要求：我需要在作业队列中选择状态为“新”的最新作业。

目前，我正在使用

当工作文件较少时，效果很好。但也有文件编号的情况。上升到 50k。然后锁定期（使用 mongostat）超过 100%（有时达到 200%）。因此，我的服务器无法在这种情况下提供新作业。

任何人都可以建议我对此查询更有效的方法吗？

提前致谢 ：）

使用Path JobQueue 库，有没有办法知道数据何时成功发送到服务器？例如，如果我使用 AsyncTask，那么 onPostExecute 将是回调方法。

在 Path JobQueue 库中，据我了解，onRun 类似于 AsynTask 的 doInBackground；onAdd 用于将数据持久化到本地磁盘时。谢谢你的帮助。

这里有人熟悉 Fiserv（以前的 Open Solutions）DNA 银行平台吗？我正在寻找关于 ACH 起源的第二种意见，因为我们在工作的运行方式上遇到了问题。

我们遇到的问题是关于在我们的系统上发布付款的时间，特别是贷款支付。发生的情况是，原始文件将在付款到期之日发送给美联储，但是我们这边是在一天后完成的，而不是它设定的日期。

我不认为这与美联储日有关，因为我们已经尝试在 2/1 和 1/1 运行我们的 ACHC/ACHD 设置，并且两种方式都遇到了同样的问题，这对我来说表明这可能与AH_ORIG 和 MM_SALOT/MM_IALOT 作业的运行顺序。

我知道 MM_SALOT 和 MM_IALOT 作业在 AH_ORIG 作业运行的前一天晚上运行。AH_ORIG 作业在正常的 ACH 异常处理期间在早上运行。

我还注意到，在我们的 ACH 起源报告中，交易的贷款方通过 XPMT 几乎就像在另一家机构产生并进入我们的贷款支付一样。我所拥有的文档表明，我们发起的交易的取款方应显示为 XWTH（他们这样做），贷款分配应显示为 LPMT（他们不是）。

我的问题是：1）我们的美联储日期应该设置在什么时候？我们每周 7 天处理分配，纪录片指出 ACHC 和 ACHD 应设置为 1/1。2) AH_ORIG 和 MM_SALOT 以及 MM_IALOT 作业应该以什么顺序运行，应该在什么时候运行？

如果有人可以帮助我解决这个问题，将不胜感激。

我已经构建了一个 rabbitmq 包装器，它向消费者发布消息，并且运行良好。

我是否也可以在 rabbitmq 中构建一个工作队列（如 gearman），它可以将长时间运行的任务分发给消费者，消费者反过来将结果通知发布者。

我想这将要求发布者也充当消费者，我不确定如何实施。（如果我错了，请纠正我）。

或者，rabbitmq 不是这种情况的工具。

谢谢，

Parse 的致命弱点之一是您无法将视频保存到数据库中（它们的 10MB 限制意味着视频长度少于 30 秒）。因此，为了补充 Parse，我正在使用 Cloudinary Parse 模块。但现在我有一个问题。通常，Parse 负责最终将数据保存到云中，允许用户即使在离线时也可以上传数据。有没有办法让 Parse 和 Cloudinary 实现这一点，而我自己不必依赖作业队列，例如compile 'com.path:android-priority-jobqueue:1.1.2'？

有人指出我遇到这个问题的原因是因为 proguard 4.9，所以我继续更新到 proguard-5.2.1。但我仍然有同样的问题。有没有人找到解决方案？我通过确认新版本

我proguard-rule.pro的很简单

错误行是

感谢您的任何提示。

更正

由于我使用的是 Android Studio，听起来我必须处理 Proguard 插件。如何更新插件？也许这可能会有所帮助。

我需要为 JobQueue 序列化字符串集合。我怎么做？使用HashSet<String>会导致异常。我正在使用https://github.com/path/android-priority-jobqueue（这里没有标签）