问题标签 [moquette]

这可以很好地启动连接并发布第一条消息：

此连接每秒发布超过 100 条消息，这行没有问题：

但过了一会儿（几分钟后）这个方法的第三行

即使我将超时设置为 1 秒，也会永远阻塞线程。

我使用 Moquette 作为带有 websockets 的 MQTT 代理。

我已经开始阅读一些关于 MQTT 协议及其实现的细节。我经常遇到“集群”这个词。谁能帮我理解 MQTT 协议的“集群”是什么意思？

在各种 MQTT 协议的比较中，有一个术语“集群”的列

在我的 mqtt-source.properties 文件中包含

我在创建源连接器时遇到了以下问题。注意 [使用 kafka-connect-cli-1.0.6-all.jar 创建源连接器] 。

Moquette MQTT 版本

分发 0.10-bundle-tar

JVM版本

java版本“1.8.0_161”

我有一个关于通过 Eclipse Paho 客户端在 Moquette 服务器中使用离线 MQTT 消息的问题。

以下是我遵循的步骤。

1. 创建并启动了 Moquette MQTT 代理。
2. 使用 eclipse Paho 客户端创建了一个简单的 MQTT 消费者应用程序。
3. 将消费者设置为使用主题上的数据：“设备/报告/#”，QOS：1 和 CleanSession：False
4. 创建了一个简单的 MQTT 数据发布者，以使用 Eclipse Paho 将数据发布到 MQTT 代理。
5. 使用 MQTT 数据发布者将消息发布到：“devices/reported/client_1”主题，QOS：1

上述步骤成功，没有任何问题。

然后我停止了我的消费者应用程序并将 MQTT 数据发送到具有相同主题的代理。使用我的发布者应用程序 - 服务器能够接收这些消息，但此时没有任何消费者可以使用此消息，因为我已经停止了我的消费者。然后我再次启动了我的消费者应用程序。它已成功连接到代理，但是在消费者关闭时它没有收到我发送给代理的任何消息。

我是否需要对我的 Moquette 服务器进行任何特定配置以保留数据（使用干净的会话：false）？还是我错过了什么？

请在下面找到我的示例代码，

Moquette 服务器初始化

MQTT 消费者

MQTT 发布者

我想知道是否有办法配置 Moquette-Broker 以使用 BouncyCastle-Library 设置 TLS-Connection？由于配置选项不同，我需要使用 BouncyCastle 实现 TLS-Connection-Setup。

我有一个服务来管理我的 MQTT 客户端连接，MQTT 工作正常，但问题是当我重新启动代理服务器时，Android 客户端没有重新连接。onConnectionLost()回调时触发异常。

笔记

1. 我在同一台计算机上使用 Moquette Broker -> Moquette
2. 我有两个 Android 客户端应用程序，一个使用服务（有问题）和另一个在线程上工作，没有服务（这工作正常，重新连接没问题）。
3. 我无法运行 Android 客户端 MQTT 库，因为我使用的是 Eclipse Paho MQTT。
4. 是的，我做setAutomaticReconnect(true);

问题

使用 Service 的 Android 应用程序可以永久运行，无需重新连接到 MQTT Broker。

代码

MQTTService.java

异常堆栈跟踪

我在我的 android 应用程序上使用 Paho 的 MQTT 客户端作为服务。当我在 API 26 及更高版本上尝试它时，它可以正常工作，但订阅在该版本下不起作用。

我正在使用 genymotion 来测试和 SDK 调试工具。API 26 进入 onSuccess 方法，但 API 25 没有。发布方法在两个客户端上都没有任何问题。

连接没有问题。它连接没有问题。我只是想知道为什么 subscribe 在 26 以下的 API 版本上有这个问题。

使用 AWS greengrass 处理边缘案例，我们计划在设备上运行多个 docker 容器，这些容器将使用 MQTT 相互通信。

到目前为止，我们已成功安装和连接 greengrass，部署容器并使用greengrass组件aws.greengrass.clientdevices.mqtt.Moquette的进程间通信。

这是使用套接字连接。

如何使用主机、端口和身份验证将我的应用程序连接到本地 MQTT 代理？

像这样的东西

到目前为止，我只能使用 IPC 建立连接。特别是对于开发，另一种连接模式会很有帮助。此外，我们还想将外部设备附加到 MQTT 代理。

谢谢你的支持！

将 MQTT 消息从移动应用程序（Android）发送到离线 AWS greengrass v2 核心设备（边缘设备）的最佳方式是什么？

我可以使用 Python SDK greengrass Core Device（也是 Raspberry Pi）从 Raspberry Pi 发送 MQTT 消息。这是 - 我不会说简单但 - 可能。

如何从 Android 应用程序管理它？

大多数链接都指向 aws Amplify，但这始终连接到云。

胡乱猜测：

• 我必须将所有 aws“事物”证书添加到应用程序（而不是使用 cognito）
• 使用一些软件来构建身份验证文件（这是主要问题）
• 使用一些 mqtt 模块发送和订阅主题