问题标签 [cloudamqp]

我有一个疑问 - AMQP 在内部使用哪种数据结构来存储消息。我知道它有传输 (TCP/IP) 消息协议和类型系统

消息属性的可移植表示 消息代理 – MOM 层 API 映射 代理之间的路由管理 – 即将添加的 AMQP 网络协议

我相信它应该只是排队。

如果是这样，那么所有操作，如阻塞队列并使其持久（等）都在其上执行？它如何工作的任何示例（网址或博客都可以）

AWS SQS 是否仅遵循 AMQP 架构？

是否可以为 IBM Bluemix 上托管的 cloudAMQP 创建虚拟主机？如果可能，哪些计划会支持这一点？

我们的产品将在 Bluemix 上使用 CloudAMQP。它必须支持多个租户。我们可以选择每个租户拥有一个虚拟主机吗？

谢谢

多米尼克·罗伊

我有一项服务部署到heroku。我的服务使用 cloudamqp 作为云消息传递服务。当我的服务在我的本地环境上运行时，我连接成功并且我从未发现此错误。

但是当我将我的服务部署到heroku时，我得到了这个错误。

当我看到我的 rabbitmq 管理页面时，我的服务成功连接到我的 cloudamqp rabbitmq 服务器。像这样显示

这是我的服务上的 application.yml ..

有人可以帮我解决这个问题。

我正在使用托管在 CloudAMQP 上的 RabbitMQ 实例。我正在调用管理 API以获取详细的队列统计信息。对 API 的 10 次调用中约有 1 次返回无效数字。

端点是/api/queues/[vhost]/[queue]?msg_rates_age=600&msg_rates_incr=30。我正在寻找在 10 分钟内以 30 秒为增量的平均消息速率。通常会返回我感兴趣的统计数据的有效数据，例如

但有时我会得到一个或两个“avg_rate”值的错误结果，通常是 714676 或更高。如果我然后等待 15 秒并再次调用相同的 API，则数字会恢复正常。超过 10 分钟的平均值不可能以 200 的倍数跳跃，然后几秒钟后又回落。

我无法通过本地安装重现该问题，只能在队列总是非常繁忙的生产环境中重现。管理网页上显示的数据看起来总是正确的。有没有其他方法可以像 UI 一样准确地获得相同的统计数据？

我正在使用 cloudamqp 消息服务来试用 MQ（在本例中为 RabbitMQ）。我正在尝试将消息从 Java 类推送到队列中，但它总是说：

拒绝连接

System.getenv 也返回 null （我也坚持这一点）。

下面是代码和异常：

堆栈跟踪：

当我捕获通用异常时，它正在捕获空指针异常：

java.lang.NullPointerException @connection = factory.newConnection()

我的代码如下所示：

I have two rails applications, App1 and App2(added cloudAMQP gem) in heroku, App1 is producing some message when click on a button

App1

so in the App2 i have to consume all the messages without any button click and put that in sidekiq to process the data, but i am stuck on how can i automatically read from that queue, i know the code how to read values from queue, people are saying sneakers gem, but i am bit confused with sidekiq and sneakers, any idea of how can we do it in heroku?

首先，这在我的本地机器上运行良好。

我有一个发布者应用程序（Rails 3），它正在向 heroku 中的cloudamq（插件）发布消息，我们在 cloudamq 中获取消息

和一个消费者应用程序（Rails 5），它也作为一个单独的应用程序在 heroku 上运行，我把这个消费者放在一个 rake 任务中，但这里的问题是只有当我们重新启动服务器时才从队列中获取消息，这意味着这个 rake 任务当我们重新启动时会运行，但在 rabbitMQ 中它显示总是在运行

那么一旦我们推送到heroku，我们如何才能让消费者持续收听呢？

此外，一旦我们从队列中获取消息，我必须调用 sidekiq 工作人员，这不会发生吗？使用“redis to go”插件

消费应用

我在这个消费者应用程序中使用过的 Gem

这是从队列中获取消息作为 rake 任务的消费者部分。

档案

我在远程（cloudamqp.com）上使用 rabbitmq，并在 Kubernetes 上创建了一个 cron 作业。在我的本地机器上，我的工作运行良好，Kubernetes cronJob 的调度非常好，但是 Job 将 rabbitmq 连接 URL 重定向到127.0.0.1:5672 ，我得到一个错误。

我检查了 cron 作业的日志，我的连接 URL 非常好，但是当 pika 尝试连接到主机时，它会自动重定向到，127.0.0.1:5672因为我们知道 cron pod 没有运行任何rabbitmq 服务器，因此它拒绝连接。

CronJob.yml

RabbitMQ 连接

连接 URL 完全相同，适用于我的本地设置。

我依赖 CloudAMQP 服务，我需要能够支持最大 10 兆字节的消息：

我的问题是，只要第 3 行没有被注释掉，队列就会抛出异常：

我在这里做错了什么？