Paho是一个Eclipse项目,旨在提供开放式和标准消息传递协议(如MQTT)的可扩展开源实现,旨在为机器对机器(M2M)和物联网(IoT)提供新的,现有的和新兴的应用程序。
我想用timeout来停止mqtt的阻塞功能,我使用了timeout_decorator模块,它可以停止命令功能但不能停止阻塞功能,subscribe.simple。 以下c...
我正在尝试运行多个 pub - 多个子消息交换。 当我尝试启动多个订阅者时(想法是为每个订阅者订阅不同的主题),问题就出现了。 我打开2
当我使用本地broker,即localhost时,程序可以运行,但是当我使用公共broker(例如Eclipse Project)时,程序无法运行并出现错误 超时错误:超时 可以这样吗...
如果只有一个代理、一个发布者、一个主题和干净的会话,在这个简化的情况下, 能否保证订阅者端的消息发送顺序与发送顺序相同...
我有一个在 docker 中运行的 mosquitto mqtt 代理。我开始它是一个 docker compose 文件。现在我正在尝试与经纪人连接,它在本地工作。当我尝试以 docker 身份连接时
基本上,我希望我的用户数据充当全局标志,在 on_message() 回调的连续执行之间读取和更新。我编写并运行了以下脚本: 导入 paho.mqtt.c...
我正在尝试实现 Paho Python MQTT 并连接到在线代理,但代码似乎出现错误。 ValueError:不支持的回调API版本:2.0版本添加了callback_api_vers...
为什么 Paho MQTT 给我“不支持的回调 API 版本”错误?
我正在尝试实现 Paho Python MQTT 并连接到在线代理,但代码似乎出现错误。 ValueError:不支持的回调API版本:2.0版本添加了callback_api_vers...
我正在尝试实现 Paho Python MQTT 并连接到在线代理,但代码似乎出现错误。 ValueError:不支持的回调API版本:2.0版本添加了callback_api_vers...
尽管订阅但未调用 MQTT handleMessage 函数
我正在开发一个 Go 应用程序,该应用程序订阅 MQTT 主题并使用 handleMessage 函数处理传入消息。但是,我遇到了一个问题,handleMessage 函数......
有没有办法在 Android 14 中使用 MqttAndroidClient?
HiveMQ 和 Paho 库都使用 AlarmPingSender。但是,该库尚未更新,因此无法(我认为?)在 Android 14 中使用 MQTT。有人可以帮助我吗? 我尝试过
我正在尝试使用 TLS 构建一个简单的代理 + pubsub 客户端。我的经纪人是一个 eclipse-mosquitto 容器,我为我的客户使用 python。当我尝试连接到我的经纪人时,我收到此错误...
Ubuntu、mosquitto 和 paho-mqtt 出现 MQTT“协议版本无效”错误
我目前正在使用运行 Ubuntu 18.04 的 NVIDIA Jetson 开发 MQTT 项目。我已安装 mosquitto(版本 2.0.15)作为我的 MQTT 代理,并为我的 Python MQTT 安装 paho-mqtt(版本 1.6.1)...
如何在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 可用于将其与项目中集成流程的其余部分连接起来。
MQTT:javax.net.ssl.SSLHandshakeException:证书上没有 subjectAltNames 匹配
我正在尝试通过 paho 客户端连接服务器(我使用的版本是 org.eclipse.paho.client.mqttv3-1.2.1.jar) 当我尝试连接时,我得到: “MQTT:javax.net.ssl.SSLHandshakeExce...
我正在尝试连接到 mqtt 并且我正在使用 android studio giraffe 我试过这样 但我收到此错误: 2023-12-10 09:37:11.352 9467-9467 AndroidRuntime com.example.mqtt4 ...
我在通过 eclipse Paho 客户端在 Moquette 服务器中消费离线 MQTT 消息时遇到问题。 以下是我遵循的步骤。 创建并旋转 Moquette ...
Paho MQTT cleanSession 设置为 false 但未接收消息
我正在为一个项目测试 MQTT。当客户端连接时,我还能够接收有关我的客户端订阅的主题的消息。我已将 QoS 设置为 1,并将 cleanSession 设置为 false....
我正在开发 MQTT kafka 源连接器。这些消息是 来自 MQTT 发布者,然后连接器将订阅 MQTT topic(/iot/sensor/#) 并且这些消息将发布到 Kaf...
是否有人有一个合乎逻辑的解释,为什么尽管我有明确的会话标志= false,但我在未连接到代理时却没有收到我订阅的更新的已发布消息? 机智...