问题标签 [emq]

我已经浏览了 emq集群的文档，但我找不到关于如何完成会话管理的明确解释。我知道主题表在集群节点之间共享，但客户端连接信息不是？如果一个节点宕机了怎么办？它会丢失有关它正在管理的客户端会话的所有信息吗？

我正在使用 paho-mqtt 从 emqx 代理接收数据，但我丢失了数据，因为有时我的 paho-mqtt 订阅者出现故障。当我再次运行订阅者时，任何获取数据的方法都会提供所有已发布的数据。

我在https://docs.emqx.io/broker/v3/en/guide.html#emq-x-bridge-cache-configuration上看到了文档，它说如果网络出现故障，您可以启用文件缓存，因为emqx 现在不做这些了。

当我设置时，例如 emqx 3.0.0.0 上的参数它在启动时失败并在未声明的 lof 文件中说：

你知道它是我的 emqx 版本的问题还是可能是 sintax 的问题。

提前致谢

我有一个在 EC2 上运行的 emqx mqtt 代理，ssl 和 wss 配置如下所示 -

当我尝试使用没有 ssl(ws://IP:8083/mqtt) 的 emqx 仪表板（托管在 http）连接到代理时，它工作正常但是当我使用 emqx 仪表板（托管在 https）和 ssl（wss:// IP:8084/mqtt)，它没有连接。如何通过 wss 上的 https 连接代理？

编辑：我想要一种方式的身份验证。我将从 React Web 应用程序和 NodeJS 应用程序连接到代理。所以，我不想从客户端提供证书。我使用的证书是 EMQX 安装提供的证书。另外，我使用的是 EMQx 为 https ssl 提供的客户端证书。如果浏览器在没有任何警告的情况下打开 https，它也应该能够连接到 websocket。

软呢帽 31。

EMQX 不作为服务启动。它从控制台成功启动。

可能是什么问题呢？

我在 Ubuntu EC2 上有一个 emqx 代理设置。

当我尝试通过带有 IP 地址的 websocket 连接到 emqx 时，它工作正常。 但是当我使用子域时，连接失败。我的 Apache 配置是

Apache 访问日志

我将 apache 的日志级别更改为“调试”，这些是错误日志。看起来它正在尝试查找 /mqtt 文件夹。

我已经启用了模式“proxy_wstunnel.load”。如何使用子域连接到 mqtt 和 ws？

背景：我有一个用 C++ 实现的微服务，带有 REST 和 WebSocket API 以及 pub/sub 功能。现在我需要支持 MQTT，事情变得更加复杂，因为我的微服务必须跟踪活动订阅以实现可扩展性的原因。例如，为了限制传递消息到主题和订阅，每个客户端可能有几个自己的主题。

我找到了列出订阅和路由的 REST API 端点： https ://docs.emqx.io/broker/v3/en/rest.html#subscriptions

https://docs.emqx.io/broker/v3/en/rest.html#routes

这可能允许我在自己的服务中启动订阅。我需要的是一种拦截订阅的有效方法。

有没有办法“订阅”订阅和取消订阅的事件挂钩，而无需在 Erlang 中编写扩展？例如，将这些事件转发到我的微服务可以作为 MQTT 客户端订阅的 MQTT 主题？

Emqx hooks 文档： https ://docs.emqx.io/enterprise/latest/en/advanced/hooks.html

我发送大数据（约50MB），并将mqtt.max_packet_size值添加为6400KB，但仍然报告错误信息。来自https://docs.emqx.io/docs/broker/v3/cn/config.html#mqtt 它显示这个值mqtt.max_packet_size = 1MB，我不确定这个值是否可以添加更多，因为我需要发送大数据。请指教。谢谢

当前配置：

emqtt 版本信息如下：

错误日志

我正在开发一个智能控制风扇的应用程序。智能风扇控制电路包括 Node MCU。将有两种风扇控制模式，智能和自动。在智能模式下，风扇的速度可以通过应用机器学习预测算法获得的预测值改变。预测值由服务器上的 python 脚本生成，移动应用程序需要从服务器获取。我需要在这个通信周期之间有一个 MQTT 代理，其中应用程序将通过 MQTT 协议从服务器获取数据，类似地，节点 MCU 和移动应用程序将通过该 MQTT 代理进行通信。我正在使用一个开源的 EMQ MQTT 代理。EMQ MQTT 代理有两种选择：一种是 EMQx，一种是 EMQ 云，其服务相当昂贵。

我是物联网的新手。在互联网上进行研究后，我获得了这个见解来开发这个项目。请指导我如何设置此 MQTT 云服务，以便不同的客户端可以通过 Internet 连接到 MQTT 代理。

我将感谢您的技术帮助。

我正在寻找一个可扩展的 pub 子集群，如果有订阅者，发布者可能只将给定主题的消息发送到 socketcluster？

原因是我所有的发布者都为许多主题处理数百万条消息，这些主题在很长一段时间内都没有订阅者。因此，将所有内容发送到 pub 子集群在计算上和价格上都是巨大的浪费。