问题标签 [amazon-mq]

我有一个由运行 ActiveMQ 的 Amazon MQ 触发的 Lambda 函数。

我希望我的 Lambda 函数在处理完消息后确认收到消息，以便 ActiveMQ 可以将其从队列或主题中删除。

我在 AWS 上找不到任何相关文档来告诉我应该如何发回该确认，或者 ActiveMQ 如何知道消费者何时成功处理了消息。

有任何想法吗？

我有一个使用mqttNPM 插件向 Amazon MQ 发送消息的 NodeJS 程序。我配置了队列并订阅了，然后发布消息。这是代码。

侦听器使用 OpenWire JMS 客户端，我使用 MQTT 或 WSS 发送消息。在这两种情况下，JMS 客户端都没有收到任何消息。

如果我为接收器编写 NodeJS 代码，它就可以工作。

JMS 客户端是否必须使用 MQTT/WSS 来接收消息？协议在这里重要吗？

我们正在将消息队列从本地解决方案迁移到 Amazon MQ。每周维护重新启动后，我们带有队列侦听器的 Mulesoft 应用程序无法重新连接到 Amazon MQ 负载均衡器 URL。本地 ActiveMQ 解决方案没有这个问题。

不起作用：

解决方法：

有没有办法让负载均衡器 url 工作？我们希望在两个 Amazon MQ 工作程序之间平衡流量。

最大，Amazon MQ 支持多少消费者/订阅者？我们需要在我们的应用程序中同时向 10k 个消费者广播消息。

我浏览了亚马逊文档，每个经纪人只能支持 250 个用户。那么，我们将不得不创建多个代理？

如果我们必须同时向大约 10,000 个消费者广播消息，请建议哪种 ESB 更好？

我们的消费者将是 iOS 和 android 设备。我们将使用 .net core 作为生产者。

注意 - 我们将在 AWS 上部署应用程序，因此无法使用 Azure 服务总线。

我正在尝试将我的 Spring-Boot 应用程序连接到作为 AWS 服务托管的 RabbitMQ。启动应用程序时出现以下异常。

我包括 java 异常、我的 spring boot 和 AWS 的配置

下面提到的是application.yml和pom.xml文件的配置

pom.xml

aws 入站 VPC 配置

感谢任何帮助，谢谢

收到上述警告，在 AmazonMQ 代理中，同时或一段时间后，代理停止将消息传递给消费者。对消费者使用客户端确认。这个问题几乎每周出现一次。此队列包含持久性和非持久性消息。非持久消息的过期时间设置为 0，因此它们在确认之前不会过期。使用以下队列策略

我正在尝试创建 Amazon MQ 的 RabbitMQ 实例并为其指定 Route53 可寻址名称。问题是，我似乎无法弄清楚如何做到这一点，因为 NLB 所需的 IP 地址无法从控制台获得，并且创建的 NLB 在我的帐户中似乎不存在。在 ActiveMQ 版本中，您可以在控制台中使用 IP 地址，并且有一个关于如何执行此操作的优秀教程（https://aws.amazon.com/blogs/compute/creating-static-custom-domain- endpoints-with-amazon-mq/），但由于 IP 没有出现在 RabbitMQ 实例上，我需要找到另一个解决方案。

有人有什么想法或建议吗？

默认情况下，当 RabbitMQ 服务器使用超过 40% 的可用 RAM 时，它会引发内存警报并阻止所有正在发布消息的连接。

可以通过编辑配置文件来调整触发流控的内存阈值，但是如何为AWS上的实例编辑RabbitMQ配置文件呢？

我的用例是连接 amazon documentDB 以读取更改流并在 EKS 集群上部署该更改流事件后从同一服务将其发送到 amazon MQ。在读取 rds-combined-ca-bundle.pem 中指定的密钥并通过 docker 入口点中的以下条目将其导入本地信任存储后，我能够与 documentDB 连接：

在与 documentDB 建立连接并读取更改流后（只要集合中有插入、替换或删除），我试图通过 openwire 协议将更改流事件发送到亚马逊 MQ，当我试图创建与 MQ 的连接时在 Amazon MQ 文档中指定，我收到异常

由于 PKIX javax.net.ssl.sslhandshakeexception，无法与 ssl://X-XXXXXXX-XXX-XXX-XXX-XXXXXX-1.mq.us-east-1.amazonaws.com:61617 建立连接

我知道问题出在哪里。当我在没有在 docker 入口点为 documentDB 指定信任库条目的情况下部署我的服务时，它会与 MQ 连接，并且我也可以将模拟事件发送到 MQ，但是当我指定信任库时使用 documentDB，服务也会在信任库中查找 MQ 的证书这实际上不是 MQ 所必需的，因为它由 AWS 管理。我们不需要使用 Amazon MQ 指定信任库和密钥库。

那么我的问题是如何从同一服务连接 Amazon documentDB 和 Amazon MQ？我的要求是从 documentDB 读取更改流事件并将其从同一服务发送到 amazon MQ。我正在使用一个简单的 java 服务，但如果有一些具体的解决方案可用，可以将其转换为 Spring Boot。

我尝试为 MQ 搜索任何 pem 文件，我可以使用类似于 documentDB 的方式使用它，但正如我之前提到的，Amazon MQ 是 Active MQ 的托管服务，因此没有可用的 pem 文件。

有人可以为此提出一些解决方案吗？

我想删除计划发送到特定队列的消息，但我发现该过程不必要地繁重。

在这里，我延迟向队列发送一条空白消息：

在这里，我想清除该队列的预定消息：

当然，这里的“目的地”需要ActiveMQ.Scheduler.Management代替我的实际队列。但是我无论如何都找不到删除预定发送给queue/my-queue. 我尝试使用selector标题，但这似乎不适用于AMQ_SCHEDULER_ACTION类型消息。

我看到的唯一建议是编写一个消费者来浏览所有计划的消息，检查每个消息的目的地，并按其 ID 删除每个计划。这对我来说似乎很疯狂，因为我不仅有几条消息，而且还有数百万条我想删除的消息。

有没有办法可以向 ActiveMQ 发送命令以清除具有自定义标头值的预定消息？

也许我可以为每个队列定义一个自定义的预定消息位置？

编辑：

我已经围绕stomp.py连接编写了一个包装器来处理以队列为目标的清除计划。MQStompFacade接受现有的和stomp.Connection您正在使用的队列的名称，并提供enqueue、enqueue_many、receive、purge和move。

当从队列接收时，如果include_delayed是True，它将订阅队列和使用计划的主题。假设消息已与此类排队，并且将原始目标队列的名称作为自定义标头，则将过滤掉不发往接收队列的预定消息。

尚未在生产中测试。这里可能有很多优化。

用法：