问题标签 [amazon-mq]

我已按如下方式配置 ActiveMQ 重新交付插件（最多 4 次重新交付）

如果客户端发送 ACK 失败，则重新传递消息。到目前为止一切都很好......但是，代理完全忽略了最大重新传递，并且它不断“无限”地重新传递消息。此外，消息永远不会移动到 DLQ。

我也尝试 ?jms.redeliveryPolicy.maximumRedeliveries=4在连接 URI（STOMP 连接器）上使用：，但也没有运气。

非常感谢任何帮助！

我们将 Amazon MQ、ActiveMQ 和 OpenWire 用于我们的事件驱动消息传递系统。

可以接收的最大帧大小为 104,857,600 (100 MB)。在发送等于 103 MB 的消息（使用邮递员）后查看 AWS 中的代理日志时，明确指出 100 MB 是限制。

在联系 AWS Support 时，他们提到 AmazonMQ 服务团队出于安全原因实施了这些限制，如果/我可以增加此限制，他们会回复我。

我假设如果他们确实有解决方案来增加它，那不会太多。这让我想到了这个问题——有人知道绕过这堵墙的任何方法吗？您是否能够编辑 Amazon MQ 配置 xml 文件以支持此最大帧大小增加？

非常感谢您的参与。

我创建了一个 Amazon MQ 代理：

• 选择代理引擎：RabbitMQ 3.8.6
• 单实例代理
• 网络和安全：公共访问
• VPC 和子网：使用默认 VPC 和子网

我尝试了两个库：来自 RabbitMQ 手册和 Enqueue\AmqpExt

他们中的任何一个都无法连接到亚马逊（使用 docker 容器一切正常。但我想尝试 AMAZON MQ。

我使用了下面的代码：

结果：

使用 'ssl_on' => true 相同的错误。

我不知道这是否会发生，因为我没有向亚马逊提供 ssl 证书。

如果是这样，如何解决？

在Amazon MQ中，当我们从Active MQ客户端连接到Amazon MQ代理时，我们只使用连接 URL，ssl://<broker>:61617但在整个 AWS 文档中没有提到此客户端-代理通信是否安全以及TLS客户端-代理连接使用哪个版本。下面是 AWS在此处提供的连接 Amazon MQ 的示例代码片段。

这篇文章说它使用SSL但没有提及，TLS/SSL它使用的旧版本SSL不再安全。

Amazon MQ代理 - 客户端连接使用哪个 TLS/SSL 版本？我们是否有任何其他方法可以将最新版本的 TLS 与Amazon MQ代理 - 客户端一起使用？

我下面的代码在 .netcore 3.1 中（使用 RabbitMQ.Client 6.1）连接到 AmazonMQ（RabbitMQ）

我使用自容器发布代码，它在机器（Windows 10）中运行良好，但是当我在 Windows 7 中运行它时，出现此错误。

经过一段时间挖掘错误并搜索并尝试（例如关闭防火墙，为我的应用程序添加入站出站规则），我无法弄清楚如何解决这个问题。任何人都可以帮我解决这个问题。非常感谢。

我偶然发现了这篇将rabbitmq 迁移到amazon mq (rabbitmq) 的文章。 https://aws.amazon.com/blogs/compute/migrating-message-driven-applications-to-amazon-mq-for-rabbitmq/

我看到这句话：

“在 Amazon MQ for RabbitMQ 中，我们仅支持使用 TLS 的 AMQP 安全版本。下面的代码片段演示了使用 Pika 库的 AMQPS 连接。请注意，我们不支持服务器端的对等验证。”

这是否意味着必须始终为 amazon mq (rabbitmq) 提供安全连接，或者它只是说如果我们决定进行安全连接，我们必须使用 TLS

我有一个在 localhost 上运行的 ActiveMQ 实例，它试图连接到在 AWS (Amazon MQ) 上运行的另一个实例。在 AWS 上运行的代理需要通过 SSL 建立代理到代理的连接。

在我的 localhost 代理中activemq.xml，我添加了以下内容以创建与在 AWS 上运行的代理的连接（目前只是一种方式）：

如果我尝试用它来启动我的 localhost 代理，我的activemy.log文件中会出现以下错误：

因此，为了尝试解决这个问题，我在 localhost 代理的activemq.xml配置中添加了以下内容：

broker.ks和client.ts是使用以下命令生成的：

这就是我在我的本地主机代理上启用 SSL 所做的一切，我不确定除了将该<sslContext>元素添加到我的配置中是否还有其他需要做的事情。

当我在进行更改后尝试启动 localhost 代理时，我现在得到一个不同的错误activemq.log：

这就是我难住的地方。

有谁知道我做错了什么？我在 AWS 代理的配置中看不到任何与 SSL 相关的内容，我假设这是因为 AWS 故意向我隐藏了这一点，以防止我更改该代理的任何 SSL 设置。

我是否需要以某种方式获取 AWS 代理使用的 SSL 证书并将其添加到我的 localhost 代理？我不知道下一步该做什么。

更新：我使用 Portecle 从 AWS 代理下载 SSL 证书并将它们添加到client.ts.

我们正在使用内部使用 ActiveMQ 的 Amazon MQ。每当 ActiveMQ 收到消息时，我们都可以触发 AWS lambda 函数。我编写了一个 lambda 函数，它从 SQS 事件中读取消息。我们有一个SQSevent可以捕获的类型，但是对于 Amazon MQ，我不知道要使用哪种类型的函数签名。

对于 SQS，我们使用这个：

我不知道要为 Amazon MQ 使用什么：

请帮忙。我无法从本地访问 AWS，因此在部署代码之前进行检查。

概括

我正在尝试使用我的消费者设置心跳，以便它可以检测到连接断开 - 例如，如果代理重新启动，它可能会重新连接到故障转移。

我使用在本地运行的 Consumer/Dispatcher 和在 AWS 中运行的队列测试了代码，一切正常。但是，当将代码移动到 AWS 时，消费者会与服务器/代理设置心跳，但心跳要么永远不会由服务器/代理发送，要么永远不会被客户端/消费者接收。结果HeartbeatException，一旦请求的服务器心跳间隔过去，就会抛出。

我的代码基于 stomp-php-examples github 中的示例

• 回购：https ://github.com/stomp-php/stomp-php-examples
• 心跳示例：https ://github.com/stomp-php/stomp-php-examples/blob/support/version-4/src/heartbeats_server.php

我对为什么这不起作用的下一个最佳猜测与队列配置有关，因为我使用的是 AWS 提供的默认配置（我认为）。我已经用谷歌搜索并搜索了关于心跳的配置设置，但还没有走得太远，因为这是一个新话题。任何帮助，将不胜感激！

设置

• 亚马逊 MQ (ActiveMQ 5.15.14)
• stomp-php 5.0（截至今天的最新版本）

我很高兴提供有关我的设置的更多详细信息。

代码

消费者（精简版）

我已经在 5.15.14 版本的单实例代理上进行了复制。

我已经尝试为代理打开 STOMP 调试，但似乎不允许使用uri下面的属性。<transportConnector>配置将保存但拉出uri属性。

<transportConnector>Amazon MQ 配置中允许的元素及其属性

使用 Spring XML 配置文件（xsd 文件）

我正在使用 Amazon MQ 托管服务，并且对 MQ 在重新启动时的行为有疑问。

代理的私有 IP 会改变还是静态的？

我在 VPC 内使用 Amazon MQ。