问题标签 [cloudamqp]

我有一个 Spring Boot 应用程序，我将其部署到 Cloud Foundry 实例 (BlueMix)。我已将 CloudAMQP 实例绑定到应用程序，并希望使用它来发送我的 STOMP 消息。我无法正确配置我的 StompBrokerRelayRegistration 类以成功连接 CloudAMP 中的 RabbitMQ 实例。我打过电话

但这试图连接到本地主机。我认为它可能会尝试使用我的 org.springframework.amqp.rabbit.connection.ConnectionFactory bean，但我想不会。

然后我尝试使用 VCAP_SERVICES 中的信息调用 setRelayHost、setRelayPort、setSystemLogin、setSystemPasscode 和 setVirtualHost。完成此操作后，Spring 似乎尝试连接到 RabbitMQ 实例，但根据日志，连接立即关闭说

对等方重置连接

. 任何人都知道我可能做错了什么？

更新

显然我使用了错误的端口。使用端口 5672 会导致立即关闭连接的行为。如果我使用端口 61613，则连接似乎已建立。但是，一旦浏览器尝试建立 websocket，就会引发以下异常

在此之上，我看到了这个警告

有人知道这里出了什么问题吗？

我的 Django 应用程序正在 Heroku 上运行。最终，我想将原始和处理后的图像文件存储在 Amazon S3 上。我的代码的第一个版本通过将所有文件存储在 S3 上来工作，但偶尔会遇到 Heroku 30 sec Application Error 消息，这意味着请求的往返时间超过 30 秒。我修改了代码以上传和处理 dyno 的本地/临时文件系统上的文件，并使用带有 CloudAMQP 的 celery worker 将后台文件传输到 S3。我的应用程序正在成功上传和处理文件。应用程序的其他部分读取文件，所以我知道它们正在被写入。但是，由于某种原因，工作人员无法查看文件。我收到 Heroku 日志错误：app[scheduler.1]: ... [Errno 2] No such file or directory: u'/app/media/images/....

芹菜工人应该能够看到临时文件系统吗？我可能会错过 Heroku 上的一些配置步骤吗？

感谢您提供的任何意见或评论。

我试图了解我的 Heroku 托管后端上的 Web-Dynos、Worker-Dynos 和 RabbitMQ 之间发生了什么。

我注意到我有超过 10 个到 RabbitMQ 的连接，尽管到目前为止我使用的是一个 Web-Dyno 和一个 Woker-Dyno。我正在使用 greenthreads (eventlet) 并希望每个 Web- 或 Worker-Dyno 有一个连接。

这是我的工人从 Procfile 开始的： celery -E -A proj worker -B -l info --maxtasksperchild=1000

就我而言，我可以有超过 10 个打开的连接：

这也是我的队列列表（celery似乎用于排队任务，不太确定其他两个是做什么用的）：

我试过玩，BROKER_POOL_LIMIT它似乎没有帮助。现在BROKER_POOL_LIMIT = 1，连接数为 10。

这可能是由 eventlet 而不是通常的 gunicorn-workers 引起的吗？

我正在尝试通过 ssl 将我的 django heroku 应用程序与 cloudamqp 连接起来。没有它工作正常。

要在 celery 中使用 ssl，我将BROKER_USE_SSL设置变量设置为True. 不幸的是，默认的 5672 端口无法处理 ssl。所以我尝试将 heroku config var 设置CLOUDAMQP_RABBITMQ_AMQP_PORT为 443 和 5671 但都返回未知协议。也许我错过了什么，或者你有提示。

提前致谢

我正在使用 RabbitMQ 队列，我在 node.js / express 应用程序中使用它，我正在使用 Wascally 作为我的库来消费和发布消息。

我的场景是，在消费者完成处理消息后，它再次将消息重新排队，因此任务是在一个循环中完成的。例如，消息启动从某个 API 下载数据的任务，完成后它再次发布相同的消息，因此将再次执行数据下载。

问题是，如果我的消费者应用程序崩溃，则消息将作为“未确认”保留在队列中。如果消费者在一段时间内（例如 30 秒）没有响应，我应该怎么做才能让我的消息返回队列？

我打算在 Android 应用程序上使用 CloudAMQP。我的问题是 AMQP 是否在 Android 上的套接字上工作？

我很担心，因为它将是一个实时应用程序，并且会话中会有很多消息传递，我无法批量处理这些消息。

嗨，我正在尝试在我的风帆应用程序中使用 rabbitmq。当我在给连接适配器后尝试在我的模型中发布数据时，我可以看到在我的兔子队列中接收到的数据，但数据库尚未创建。我使用 mongo 数据库作为我的模型，并使用sails-rabbitmq 作为我的 node_module 我引用了这个链接

连接适配器是 -

在我的模型中指定连接如下

据我了解，我们不需要编写创建和更新控制器方法，它应该与sails 提供的默认CRUD 操作一起使用。但是当我尝试创建数据库条目时没有得到任何响应。

我有一个使用 RabbitMq 作为消息队列的工作人员

我想将工作人员配置为根据队列中的消息数量进行扩展

正在使用 cloudamqp 如何在弹性 beantalk 中添加自定义缩放触发器

我正在对使用 CodeIgniter 开发的消息队列解决方案进行原型设计。该代码托管在 GoDaddy 基本共享托管计划上，并连接到 CloudAMQP 上的 RabbitMQ 试用实例。我使用videlalvaro/php-amqplib 库。

该解决方案运行了几天，昨天我开始收到连接被拒绝错误。代码没有更改，实际上在我的本地机器上运行的相同代码可以正常工作并连接到 CloudAMQP。

这让我相信问题可能出在 GoDaddy 托管上。花了大约 48 小时试图解决这个问题，我的项目现在停滞不前。

有没有人有任何想法？我现在唯一的选择是转移到不同的托管服务并尝试，但这是重要的一步，我想确保我不会错过一些小东西。

下面代码的相关部分：

我有一个 ActiveMQ 服务器的详细信息，我想连接并查看可用的数据。我想使用 RabbitMQ(CloudAMQP)。

我已经阅读了文档，但我无法弄清楚如何建立这种联系？

我的连接细节如下：

据我所知，这些是足够的连接细节。非常欢迎任何帮助。