问题标签 [amazon-mq]

下面的 TF 代码执行没有问题，并且还创建了 MQ 代理，但我无法在默认创建的 CloudWatch 日志流组下查看 MQ 的日志。有人可以建议我在哪里失踪，以便我可以在 main.tf 下添加 cloudwatch enable 吗？

我正在使用 spring WebSocket、SockJs 和 Amazon MQ 构建一个示例聊天应用程序。当客户端订阅该主题时，它会引发“代理不可用”异常。所有入站流量规则都在 AWS 安全组中正确设置，并且代理也具有 stomp 支持。我正在关注这个Spring Guide。

如果我使用内存代理，它工作正常。非常感谢您对此的帮助，以下是示例代码。

代理：Amazon MQ（内部使用 Active MQ）

版本：5.15.0

WebSocketConfig.java

应用程序启动日志

客户

浏览器控制台日志

正在打开 Web Socket... Web Socket 已打开... CONNECT 接受版本：1.1,1.0 heart-beat:10000,10000

错误消息：经纪人不可用。内容长度：0

stomp.min.js:8 哎呀！失去与 http://localhost:8080/testApp/chat-endpoint 的连接

我在活动/备用模式下使用 AmazonMQ。我需要知道在活动代理失败期间活动和备用代理之间的时间切换是什么。在活动代理和备用代理之间切换是否需要时间。我正在使用来自 stomp python 客户端的故障转移传输。提前致谢

我有一个用例，队列需要 24/7 全天候运行，因此冗余是关键，因此需要多可用区。除此之外，我想确保发送到队列的消息满足以下要求，但我之前从未配置过 AMQ 或 ActiveMQ，所以我有点迷茫。

1. 队列重新启动期间消息保留 = 持久模式
2. 消息可以被多个消费者读取
3. 消息在第一次读取后不会立即从队列中掉出来（确认）
4. 可能将消息的生命周期配置为在 48 小时等时间窗口内可用。

任何满足这些要求的 XML 配置示例或指南都非常棒。我在网上找不到太多关于第 2-4 项的内容。

我使用 Amazon MQ 创建了一个单实例代理，并且能够使用 Eclipse Paho MQTT 客户端仅使用用户名和密码订阅代理。

编码：

运行上面的代码表明我能够订阅主题并接收到我发送的消息。

然而，对 mosquitto_sub 客户端做同样的事情，它给了我协议错误：

错误：

错误：与代理通信时发生网络协议错误。

我搜索了如何使用 SSL 连接到 MQTT Broker。我发现我需要为客户端设置一个证书。

但是如何在没有任何证书集的情况下在 java 中工作？？？

我今天试用了 Amazon MQ，发现它非常容易设置，而且我们可以在 IoT 设备端快速集成发布/订阅功能。但不幸的是，当我查看 Amazon MQ 的限制时，一个实例的最大连接数仅为 1000。

从 Amazon MQ Docs 截取的 ff 屏幕截图：

这太低了。而且我没有看到增加配额的选项。另外，我每个区域最多只能有 20 个代理，所以基本上最多只能有 20k 台设备。并且创建 20 个 broker 的成本太高了，与自己在 8Gb 内存和 2CPU 的 EC2 实例中设置 MQTT broker 相比，我最多可以处理 50k 连接。

然后我看到了另一种选择，即使用 AWS IoT 进行设备管理。它支持多达 50 万台设备。但缺点是我必须将我所有的设备注册为“Thing”，并且我必须为每个设备获取证书。但我真的不需要亚马逊来管理我的设备并跟踪设备的状态，我们已经完成了。此外，我们必须熟悉如何使用 AWS IoT 设备管理控制台管理设备。因此，使用 AWS IoT 服务作为消息代理比使用 Amazon MQ 更耗时。

所以，我的问题是，Amazon MQ 真的不是为物联网设备设计的吗？无论如何只使用AWS IoT设备管理的MQTT代理服务而不使用其管理功能（我认为这是不可能的）？

我正在尝试将 Apache Artemis 代理与 Amazon MQ 代理连接以创建混合架构。我尝试将 ActiveMQ 与 Amazon MQ 连接起来，我可以通过在 broker.xml 文件中使用“网络连接器”来实现它，并且效果很好。

为了连接 Amazon MQ 和 Artemis 代理，我在 Artemis broker.xml 文件中添加了如下所示的“网桥配置”和“连接器”

我遇到了一个例外：找不到ssl 架构。

所以我想了解连接 Artemis 和 AmazonMQ 代理是否与连接 Activemq 和 AmazonMQ 代理相同（即通过更改 broker.xml 文件中的配置）？如果是这样，我需要对上面显示的配置进行哪些更改？

我们想使用 spring websockets + STOMP + amazon MQ 作为一个全功能的消息代理。我们试图进行基准测试，以找出单个 tomcat 节点可以处理多少客户端 websocket 连接。但似乎我们首先达到了 amazonMQ 连接限制。根据aws 文档，amazonMQ 每个节点的连接限制为 1000 个（据我了解，我们可以要求支持来增加限制，但我怀疑它是否可以大幅增加）。所以我的问题是：

1）我是否正确假设对于从客户端到 spring/tomcat 服务器的每个 websocket 连接，从服务器到代理打开相应的连接？这是正确的行为还是我们在这里做错了什么/遗漏了什么？

2）在这里可以做什么？我的意思是，我认为为每 1000 个用户创建代理节点不是一个好主意。

一般来说，我是 Amazon MQ 和 ActiveMQ 的新手。我已将代理配置为具有转发到多个队列的复合主题。我以这种方式设置了 3 个经纪人。三分之二的工作按预期工作。第三个是表现得很奇怪。当我去查看我的主题和队列时，控制台是空的。我为所有 3 个代理使用相同的 XML 配置文件，唯一的区别是主题和队列名称。我想我启用了持久模式，但不确定我的设置是否完全正确。我只是在 XML 中取消了对这一行的注释。

我还<destinations>填写了我想要在重新启动代理时创建的主题和队列的部分。我注意到它们最初可能会出现，但最终会从控制台中消失，除非我们保持向它们写入消息。我不确定要寻找什么，所以希望有人能给我一些指导或方向。

我想将 MassTransit 与 Amazon MQ（可能是 Amazon SQS/SNS？）一起使用。在创建 MassTransit Bus 时，是否有一些方法可以给总线命名或前缀？这将允许开发人员团队共享相同的实例，因为每个队列、路由、网桥等名称都将加上前缀（因此是唯一的）。

挖掘两个经纪人的 MassTransit 配置代码，这看起来是不可能的。虽然我认为这将是一个独立于经纪人的设置。

RabbitMQ 支持可用于此目的的虚拟主机，但我认为这是 RabbitMQ 特有的。