paho 相关问题

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

如何使用超时停止阻塞函数subscribe.simple

我想用timeout来停止mqtt的阻塞功能,我使用了timeout_decorator模块,它可以停止命令功能但不能停止阻塞功能,subscribe.simple。 以下c...

回答 2 投票 0

多个并发 MQTT 订阅者

我正在尝试运行多个 pub - 多个子消息交换。 当我尝试启动多个订阅者时(想法是为每个订阅者订阅不同的主题),问题就出现了。 我打开2

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 2 投票 0

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

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

回答 2 投票 0

Paho 从 on_message 回调更新用户数据

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

回答 4 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

Paho MQTT 发生“EOF 违反协议”

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

回答 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)...

回答 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 可用于将其与项目中集成流程的其余部分连接起来。

回答 1 投票 0

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

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

回答 3 投票 0

如何解决 Paho Android 服务问题

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

回答 1 投票 0

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

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

回答 2 投票 0

Paho MQTT cleanSession 设置为 false 但未接收消息

我正在为一个项目测试 MQTT。当客户端连接时,我还能够接收有关我的客户端订阅的主题的消息。我已将 QoS 设置为 1,并将 cleanSession 设置为 false....

回答 3 投票 0

客户端断开连接时 Paho MQTT 消息可靠性

我正在开发 MQTT kafka 源连接器。这些消息是 来自 MQTT 发布者,然后连接器将订阅 MQTT topic(/iot/sensor/#) 并且这些消息将发布到 Kaf...

回答 1 投票 0

将清除会话标志设置为 FALSE 时,我丢失了已发布的值

是否有人有一个合乎逻辑的解释,为什么尽管我有明确的会话标志= false,但我在未连接到代理时却没有收到我订阅的更新的已发布消息? 机智...

回答 3 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.