paho 相关问题

Paho是一个Eclipse项目，旨在提供开放式和标准消息传递协议（如MQTT）的可扩展开源实现，旨在为机器对机器（M2M）和物联网（IoT）提供新的，现有的和新兴的应用程序。

超时错误：在 mqtt 中使用公共代理时超时 [已解决]

当我使用本地broker，即localhost时，程序可以运行，但是当我使用公共broker（例如Eclipse Project）时，程序无法运行并出现错误超时错误：超时可以这样吗...

python mqtt paho

回答 1 投票 0

简化情况下能否保证mqtt消息送达顺序？

如果只有一个代理、一个发布者、一个主题和干净的会话，在这个简化的情况下，能否保证订阅者端的消息发送顺序与发送顺序相同...

mqtt paho

回答 2 投票 0

无法与docker内的mosquitto MQTT代理连接

我有一个在 docker 中运行的 mosquitto mqtt 代理。我开始它是一个 docker compose 文件。现在我正在尝试与经纪人连接，它在本地工作。当我尝试以 docker 身份连接时

python docker mqtt paho

回答 2 投票 0

Paho 从 on_message 回调更新用户数据

基本上，我希望我的用户数据充当全局标志，在 on_message() 回调的连续执行之间读取和更新。我编写并运行了以下脚本：导入 paho.mqtt.c...

python callback global-variables paho user-data

回答 4 投票 0

Paho MQTT“不支持的回调 API 版本”错误

我正在尝试实现 Paho Python MQTT 并连接到在线代理，但代码似乎出现错误。 ValueError：不支持的回调API版本：2.0版本添加了callback_api_vers...

python mqtt paho hivemq

回答 1 投票 0

为什么 Paho MQTT 给我“不支持的回调 API 版本”错误？

我正在尝试实现 Paho Python MQTT 并连接到在线代理，但代码似乎出现错误。 ValueError：不支持的回调API版本：2.0版本添加了callback_api_vers...

python mqtt paho hivemq

回答 1 投票 0

为什么 Paho MQTT 给我“不支持的回调”错误？

我正在尝试实现 Paho Python MQTT 并连接到在线代理，但代码似乎出现错误。 ValueError：不支持的回调API版本：2.0版本添加了callback_api_vers...

python mqtt paho hivemq

回答 1 投票 0

尽管订阅但未调用 MQTT handleMessage 函数

我正在开发一个 Go 应用程序，该应用程序订阅 MQTT 主题并使用 handleMessage 函数处理传入消息。但是，我遇到了一个问题，handleMessage 函数......

go mqtt iot paho messagebroker

回答 1 投票 0

有没有办法在 Android 14 中使用 MqttAndroidClient？

HiveMQ 和 Paho 库都使用 AlarmPingSender。但是，该库尚未更新，因此无法（我认为？）在 Android 14 中使用 MQTT。有人可以帮助我吗？我尝试过

android kotlin mqtt paho

回答 1 投票 0

Paho MQTT 发生“EOF 违反协议”

我正在尝试使用 TLS 构建一个简单的代理 + pubsub 客户端。我的经纪人是一个 eclipse-mosquitto 容器，我为我的客户使用 python。当我尝试连接到我的经纪人时，我收到此错误...

python docker ssl mqtt paho

回答 1 投票 0

Ubuntu、mosquitto 和 paho-mqtt 出现 MQTT“协议版本无效”错误

我目前正在使用运行 Ubuntu 18.04 的 NVIDIA Jetson 开发 MQTT 项目。我已安装 mosquitto（版本 2.0.15）作为我的 MQTT 代理，并为我的 Python MQTT 安装 paho-mqtt（版本 1.6.1）...

networking mqtt mosquitto paho

回答 1 投票 0

如何在Spring Integration中自定义MqttSubscription？

我在 Spring Integration 中使用 org.eclipse.paho.mqttv5.client 并尝试在 mqtt 中设置无本地选项，如下所示： @豆公共 MessageProducer 入站（ClientManager 我在 Spring Integration 中使用 org.eclipse.paho.mqttv5.client 并尝试在 mqtt 中设置 no local 选项，如下所示： @Bean public MessageProducer inbound(ClientManager<IMqttAsyncClient, MqttConnectionOptions> clientManager) { Mqttv5PahoMessageDrivenChannelAdapter adapter = new Mqttv5PahoMessageDrivenChannelAdapter( clientManager, "test" ); adapter.setCompletionTimeout(5000); adapter.setQos(2); adapter.connectComplete(true); adapter.setOutputChannel(mqttInputChannel()); return adapter; } 但是Mqttv5PahoMessageDrivenChannelAdapter没有办法设置MqttSubscription（有mqtt的no-local的配置）在Mqttv5PahoMessageDrivenChannelAdapter类中，它有一个方法subscribe： private void subscribe() { var clientManager = getClientManager(); if (clientManager != null && this.mqttClient == null) { this.mqttClient = clientManager.getClient(); } String[] topics = getTopic(); ApplicationEventPublisher applicationEventPublisher = getApplicationEventPublisher(); this.topicLock.lock(); try { if (topics.length == 0) { return; } int[] requestedQos = getQos(); MqttSubscription[] subscriptions = IntStream.range(0, topics.length) .mapToObj(i -> new MqttSubscription(topics[i], requestedQos[i])) .toArray(MqttSubscription[]::new); IMqttMessageListener listener = this::messageArrived; IMqttMessageListener[] listeners = IntStream.range(0, topics.length) .mapToObj(t -> listener) .toArray(IMqttMessageListener[]::new); this.mqttClient.subscribe(subscriptions, null, null, listeners, null) .waitForCompletion(getCompletionTimeout()); String message = "Connected and subscribed to " + Arrays.toString(topics); logger.debug(message); if (applicationEventPublisher != null) { applicationEventPublisher.publishEvent(new MqttSubscribedEvent(this, message)); } } catch (MqttException ex) { if (applicationEventPublisher != null) { applicationEventPublisher.publishEvent(new MqttConnectionFailedEvent(this, ex)); } logger.error(ex, () -> "Error subscribing to " + Arrays.toString(topics)); } finally { this.topicLock.unlock(); } } 但它仅使用参数 MqttSubscription 和 topic 创建 qos： MqttSubscription[] subscriptions = IntStream.range(0, topics.length).mapToObj(i -> new MqttSubscription(topics[i], requestedQos[i])).toArray(MqttSubscription[]::new); 这是我们在引入 MQTT v5 支持时错过的东西。看起来我们必须引入类似基于 MqttSubscription 的构造函数之类的东西，作为普通 topic 及其 qos 的替代选项。这样您就可以对每个订阅进行细粒度配置。请提出 GH 问题，我们将在下一个 Spring Integration 版本中解决该问题。作为解决方法，我只能建议直接使用 Paho API。自定义 MessageProducerSupport impl 可用于将其与项目中集成流程的其余部分连接起来。

java spring-integration mqtt paho

回答 1 投票 0

MQTT：javax.net.ssl.SSLHandshakeException：证书上没有 subjectAltNames 匹配

我正在尝试通过 paho 客户端连接服务器（我使用的版本是 org.eclipse.paho.client.mqttv3-1.2.1.jar）当我尝试连接时，我得到： “MQTT：javax.net.ssl.SSLHandshakeExce...

android ssl mqtt paho

回答 3 投票 0

如何解决 Paho Android 服务问题

我正在尝试连接到 mqtt 并且我正在使用 android studio giraffe 我试过这样但我收到此错误： 2023-12-10 09:37:11.352 9467-9467 AndroidRuntime com.example.mqtt4 ...

java android android-studio mqtt paho

回答 1 投票 0

Moquette 中不会使用 Paho 客户端消耗离线消息

我在通过 eclipse Paho 客户端在 Moquette 服务器中消费离线 MQTT 消息时遇到问题。以下是我遵循的步骤。创建并旋转 Moquette ...