问题标签 [ironmq]

我正在尝试在共享点工作流中调用 Iron MQ Rest API。

以下是 API 详细信息： http: //dev.iron.io/mq/reference/api/#add_messages_to_a_queue

在我的工作流程中使用调用 HTTP Web 服务操作时，我无法找到传递请求正文的方法。

API 需要以下格式的请求正文：

请求参数在 sharepoint 中被接受为字典。但上述内容需要在请求正文中提供。这通常使用 Curl 中的 -d 参数来完成。

Sharepoint Call HTTP Web Service Action 中的等效项是什么？

我正在尝试使用 iron.mq 推送队列，但在收到消息后很难弄清楚如何正确响应队列。我意识到我可能还没有完全理解队列系统的行为，但我的理解是它是这样的：

1. 消息发送到队列
2. 消息从队列推送到我的端点
3. 消息被“保留”，直到我的端点响应或超时
4. 端点响应 2xx（成功）并被删除或 4xx/5xx 失败，在这种情况下，队列将尝试将消息重新发送到端点。

例如，我的脚本（使用 FuelPHP）是这样的：

现在我收到了消息，我想做两件事之一：

1. 处理消息并向 ironmq 服务器返回成功的响应
2. 延迟该过程（通过发送 4xx/5xx？）并在定义的时间段后重新发送。

但是......你如何回应推送消息？使用 PHP SDK 的 deleteMessage 方法会导致异常，因为消息似乎不再存在。

我将推送队列端点设置为POST /iron，效果很好。但我也收到了很多其他请求。这些来自 Iron.io 吗？他们有什么意义？他们只是在填满我的 Apache 日志。我的服务器为所有错误返回 500 个错误（在开发模式下为 500 而不是 404）。

POST /webhooks POST /orders/webhook POST /api/orders/webhook

编辑：我使用它进行了调查multicast，发现只有我的第一台服务器收到了这些奇怪的请求。它们似乎与 Iron.io 完全无关。我想这只是巧合，它们是 webhook 请求，我现在才注意到它们。可能有人将我的服务器作为他们 webhook 的端点。>_<

我跑了 composer self-update

然后我在我的composer.json中添加了这个

跑了

和

但现在无论我做什么，我都会收到这个错误

有什么东西被破坏了怎么回事？我试图删除作曲家中的行，但错误现在卡在那里！

我刚开始使用 .NET 和 IronTools 试验 Iron.io。我能够从桌面应用程序向队列推送和获取消息就好了。现在我想创建一个工作人员从队列中获取消息，对其进行处理，然后将其推送到另一个队列。工作人员失败，日志中出现以下错误：

未处理的异常：System.Net.WebException：获取响应流时出错（写入：身份验证或解密失败。）：SendFailure ---> System.IO.IOException：身份验证或解密失败。---> Mono.Security.Protocol.Tls.TlsException：从服务器收到的证书无效。错误代码：Mono.Security.Protocol.Tls.Handshake.Client.TlsServerCertificate.validateCertificates 的 0xffffffff800b0109
（Mono.Security.X509.X509CertificateCollection 证书）[0x00000] 在
Mono.Security.Protocol.Tls.Handshake.Client.TlsServerCertificate的 0 中.ProcessAsTls1 () [0x00000] in :0
在 Mono.Security.Protocol.Tls.Handshake.HandshakeMessage.Process () [0x00000] in :0
在 (wrapper remoting-invoke-with-check) Mono.Security.Protocol.Tls.Handshake.HandshakeMessage:Process () 在 Mono.Security.Protocol.Tls.ClientRecordProtocol.ProcessHandshakeMessage (Mono.Security.Protocol.Tls.TlsStream handMsg) [0x00000] 在
Mono.Security.Protocol.Tls.RecordProtocol.InternalReceiveRecordCallback (IAsyncResult asyncResult) [0x00000] 在 :0 中的 [0x00000]

这是代码：

（实际项目 ID 和令牌已从上面的代码中删除）

我错过了什么？

编辑：我没有提到前 2 个 WriteLines 成功，但它永远不会到达第 3 个 WriteLine。

我设置了一个推送队列来拨打相当多的电话号码并播放录音——一个由 Twilio 提供支持的爆炸公告系统。遍历每个号码并拨打电话需要时间，所以我希望使用推送队列来加快应用程序的导航。

我过去曾尝试在 Laravel 4 中使用 Iron.io 推送队列，似乎任何需要一段时间才能运行的任务，或者如果 HTTP 请求一开始很慢，则该fire()方法中的代码会运行多次，即使使用$job->delete()

这是我的队列处理程序的示例-

I'm looking at the example of the Worker+IronMq.

http://fortrabbit.com/docs/in-depth/workers/scheduler-example

The question is how can I call a specific service in Symfony2 from the worker?

我是 Heroku 的新手，我正在尝试引导本地开发环境。使用 Foreman 或其他工具，有人可以向我指出说明与工人一起发送和消费消息的文档。关键是设置 MQ 和使用本地配置的消息的工作人员。谢谢！

我什么时候会使用像 ironMQ 这样的消息队列，什么时候会使用像 ironWorker 这样的作业处理工作者？

我刚刚开始研究这两个主题，我发现很难区分这两种用途。我知道工作人员或多或少是一个沙箱，它将在应用服务器之外的不同环境中运行程序以增加用户体验。我也知道消息队列很像它的数据库替代方案，即一个任务被添加到一个队列中，然后另一个服务器/编程监听该任务，然后处理它。但是，尽管我认为我了解它们是什么，但我无法区分何时使用它们以及为什么使用它们。

如果我理解正确，我会使用工人来完成图像处理等任务。但是为什么我不能为此使用消息队列，更重要的是为什么不呢？当然，我可以让一个图像 URL 在 ironMQ 中排队，然后让另一个程序检索并处理它。在我看来，这似乎是一个额外的步骤，所以我会避免这样做。

当工作人员可用时，消息队列对我来说对于常见任务似乎毫无意义。当然，对于像发表评论这样的非密集型任务，我可以让工人这样做吗？

我可能误解了每种工具之间的区别，如果是这样，请让我直截了当。否则，请帮忙。

我正在尝试使用 Laravel 设置 IronMq 队列，并且我已经让它工作了，但关键是这种行为不是我们想要的。

我希望 IronMq 等到一个作业完成 ($job->delete()) 来推送一个新的，但我发现它会在前一个完成之前推送消息。

代码结构如下：

有没有人找到防止并行行为并使其顺序的方法？

非常感谢你！