问题标签 [cloudamqp]

我在其他线程上看到过类似的问题，但没有一个给出确凿的答案。

我将启动大约 4 个消费者（使用 Bunny 客户端 gem 用 Ruby 编写）来订阅同一个队列并处理消息，并且在消耗大约 20,000-40,000 条消息之前一切正常。然后消费者只是停止接收消息。连接/通道保持打开状态，服务器仍然可以识别消费者，但他们只是没有收到消息。

我不认为这是类似线程中建议的预取问题。我已经在各个级别设置了预取，它并没有解决问题。问题不在于单个消费者在其他消费者之前获取所有消息 - 而是所有消费者都停止了。

我正在使用托管的 RabbitMQ 服务 CloudAMQP，所以我认为这可能是那里的性能问题，但是发布消息仍然可以正常工作，并且无论我选择的实例大小如何，我都会遇到同样的问题。日志中没有什么奇怪的。

我应该补充一点，我正在使用以下命令明确确认消息：ch.acknowledge(delivery_info.delivery_tag, false)。

我在这里有点难过，非常感谢您的帮助。如果我遗漏了任何重要的细节，请告诉我。

一些示例代码：

我正在尝试将我的 Coldfusion 应用程序连接到 CloudAMQP 的 RabbitMQ 服务。我已经能够创建 java 对象，但是当我尝试创建 newConnection() 时，它失败了。我在想这可能与我的配置有关？以下是我如何将 AMQP 的设置（右）映射到我的代码（左）。我基本上遵循 Luis Majano 在 github ( lmajano/messaging-polyglot ) 上的示例代码，他在视频Down the RabbitMQ Hole with ColdFusion中提到了该代码

注意：我将在发布后轮换密码，因此这些凭据将不起作用。似乎是谨慎的做法:)

当我运行此代码时，我能够成功创建工厂。writeDump(factory)代码输出以下内容。

注意：newConnection() 方法

现在，当我尝试factory.newConnection()像这样实际创建连接时......

它失败！这是捕获中转储的结果writeDump(err)

知道为什么它会在factory.newConnection()方法调用上失败吗？

如何在 Cloudamqp 中将音频文件作为消息发送？

我猜我需要它的字节流并将其作为 JSON 发送。但我不确定这是否可能。还是我只发送音频文件位置的链接以供下载？

我正在使用 Celery 处理我的烧瓶应用程序中的后台任务，但我无法使其与 CloudAMQP 一起使用

代理 urlamqp://ali:**@127.0.0.1:5672// 用于本地使用和amqp://name:password@moose.rmq.cloudamqp.com/name生产

我尝试在本地使用 CloudAMQP，这是日志

之后什么也没有发生；任务未执行，但在我返回本地代理 url 后，排队的任务正常执行。

我在 cloudamqp 上工作得很好，直到突然间 wascally/rabbot 停止连接到我的端点。我已经在本地安装了 RabbitMQ，并且我的系统运行良好。从那以后，我尝试通过 bigwig 在 Heroku 上设置 RabbitMq 实例，但无济于事。我使用的端点应该没问题，我还安装了 amqp.node 和 node-amqp 来测试它是否是 rabbot 的问题。但是，这些都不能连接。

知道问题可能是什么吗？

我正在尝试使用amqplibAMQP 0-9-1 library and client for Node.JS

我有一个关于缓冲区的问题。我怎样才能给他们写一个 JSON 对象。

channel.publish需要缓冲区的content形式。

在我发布消息之后，当我在 worker 中使用它们时，如何再次从缓冲区中提取消息以取回 JavaScript 对象。

message传递给消费者的对象的形式为

content我们传递给发布者的内容在哪里

我在 Heroku 上运行的 Django 站点正在使用 CloudAMQP 来处理其计划的 Celery 任务。CloudAMQP 注册的消息比我的任务多得多，我不明白为什么。

例如，在过去的几个小时中，我将运行大约 150 个计划任务（两个每分钟运行一次，另一个每五分钟运行一次），但是 CloudAMQP 控制台的消息计数增加了大约 1,300 个。

我的相关 Django 设置：

我的档案：

查看 Heroku 日志，我只看到了我所期望的正在运行的计划任务的数量。

RabbitMQ 概览图在大多数情况下往往看起来像这样：

我对 RabbitMQ 的了解还不够，无法知道其他面板是否能解决这个问题。我认为它们没有显示出任何可以解释所有这些信息的明显信息。

我想至少了解额外的消息是什么，然后是否有办法可以消除部分或全部。

我想使用 RabbitMQ 在移动应用程序和桌面应用程序之间进行通信以进行消息传递。是否可以在 PC 等移动设备上启动rabbitmq-server，或者您必须为此使用CloudAMQP（例如：https://www.cloudamqp.com/blog/2015-07-29-rabbitmq-on-android。 html )?

我正在尝试使用 QPID 库连接到 CloudAMQP，并且一直收到连接被拒绝或连接重置错误。如果我使用本地安装的 RabbitMQ 实例，它就可以正常工作。我从 nodeamqplib 或其他解决方案连接到 CloudAMQP 没有任何问题。

我猜这与 CloudAMQP 实例需要 SSL 的方式有关，但我不确定。我想尝试以与配置 CloudAMQP 完全相同的方式设置本地实例，以查看是否可以获得更多日志记录。

任何帮助将非常感激，

谢谢，

伊恩

我试图让 Spring 在 heroku 平台上与 CloudAMQP 一起工作。这是我的背景：

但是我遇到了一些奇怪的事情：在本地它工作得很好，通过 CLOUDAMQP_URL=localhost，但是在 heroku 上我得到了以下异常：

我将 ${HEROKU_CLOUDAMQP_URL} 替换为实际的连接字符串，形式如下：

完整的堆栈跟踪：

难道我做错了什么？

提前致谢。