问题标签 [cloudamqp]

我需要将消息推送到外部rabbitmq。我的 java 配置成功声明了要推送的队列，但是每次我尝试推送时，都会出现下一个异常：

豆：

发送消息服务类：

顺便说一句，当我在本地启动 rabbitmq 时，它工作得很好。当我使用容器化 rabbitmq 或外部 cloudamqp 时出现此问题

因此，再一次，当我运行我的应用程序时，我可以在 RabbitMQ 仪表板中看到新队列（已声明），但每次推送消息的尝试都以异常结束。

在 cloudamqp（托管的 rabbitmq 服务）的 rabbitmq 诊断页面上，我收到有关 rabbitmq 客户端已过时的警告。但是，似乎没有提供关于客户 rabbitmq 认为哪些是过时的、哪些客户没有过时以及为什么这很重要的信息？

为什么 cloudamqp 会发出此警告？哪些客户“足够新”？

我是 rabbitmq 的新人，我想从我为训练和测试创建的 localhost 连接到 cloudamqp 实例。但是当我运行时出现php artisan rabbitmq:consume此错误：

ACCESS_REFUSED - Login was refused using authentication mechanism AMQPLAIN. For details see the broker logfile.(0, 0)

我以前也vladimir-yuldashev/laravel-queue-rabbitmq为项目安装过

队列.php：

.env 文件（来自 cloudamqp 网站中实例详细信息的凭据）：

启用了 VPC 连接器Route all traffic through the VPC connector和防火墙规则以允许 VPC 的所有出口流量。尽管如此，由于超时，我无法连接到 RabbitMQ 实例（cloudamqp）。

我目前在我的两个应用程序（web/worker）之间实现 RabbitMQ 消息传递时遇到问题。我的 RabbitMQ 服务托管在 CloudAMQP（Heroku 插件）上。但是，@RabbitListener我声明的任何似乎都尝试连接到localhost而不是云服务。

将以下组件添加到我的工作应用程序中后：

我遇到以下错误：

如何绑定 RabbitListener 以使其连接到 AMQP 环境？这是我的配置：

我想使用发布者确认将消息异步发布到我的应用程序中的代理。我有一个查询，所以假设我的应用程序尝试将消息异步发布到代理，并且 RabbitMQ 服务器没有剩余的磁盘空间，那么这些消息会发生什么？

简而言之，如果我的应用程序触发了1000条消息以发布，并且代理仅成功发布了5条消息（ACK），那么在代理 ACK/NACK 剩余消息之前的那段时间里，剩余消息将存储在哪里？

参考文献如下： https ://www.rabbitmq.com/tutorials/tutorial-seven-java.html https://www.rabbitmq.com/confirms.html#publisher-confirms

我正在尝试通过我的 CPanel 上的计划任务创建与 CloudAMQP 的连接，当我 SSH 到服务器并手动运行脚本时它工作正常，但是当我尝试通过调度程序运行时，我得到了这个：

我的 PHP 代码如下所示：

老实说，我很难过。第一个大型 PHP 项目（学习编码），我迷路了。

我将pika与托管的CloudAMQP实例一起使用。

消息以短时间的形式发布到队列中：大约 10 条消息/秒，然后几分钟内什么也没有。消费者有时可能需要大约 30 秒来处理一条消息。我的简单消费者代码是：

有时，我会看到以下行为：

• 大约 20-30 条消息在几次快速爆发中发布到队列中
• 消费者获取所有排队的消息，一口气自动确认它们，即它们都从队列中“消失”
• 在处理完自动确认的消息后，pika 会抛出以下异常：

（下面的完整追溯）

我auto_ack=True通过手动禁用和确认消息解决了我的问题（见下文）。

是否有解决此问题的替代方法？EOF Exception 是否发生是因为 CloudAMQP/RabbitMQ 服务器没有及时收到心跳，并关闭了连接？或者是 pika 的内部超时..？谢谢！

追溯：

我在 Heroku 上使用 CloudAMQP 和 Celery 来安排任务。当我将代码推送到 Heroku 时，突然收到以下错误：

问题是，它在 3 个月内工作得非常好。前几天我突然收到这个错误。我已经检查了 Github 上的提交，并且没有对我的设置进行任何调整。那么这个错误可能是什么？我当前的 Heroku 配置是：

我的 Procfile 内容如下：

我正在围绕amqplibPromise API 构建一个 Typescript 包，以使我更简单地在两个 RabbitMQ 队列之间发送消息。

这是所述包的类中的一个方法，负责向 RabbitMQ 发送消息。它实际上并没有发送消息，因为我无法从 CloudAMQP 看到它们。

这是我创建的一个创建连接和通道的类，在这里使用：

}

我的连接工厂似乎工作正常，因为我可以看到来自 CloudAMQP 仪表板的连接。我也可以从仪表板看到已创建（在我的代码中声明）的队列。但是，我无法让 amqplib 向 CloudAMQP 发送消息。

这是我用来调用我的包的（异步）代码：

似乎有什么问题？