paho相关内容
我正在使用python mosquitto(paho)库.我遇到了Unexpected disconnection.的问题,我发现它不断掉线并与服务器建立连接. .我找不到问题.有时它显示[Error 104]连接被对等方重置.我将经纪人托管在亚马逊网络服务上. 我的错误是--- 已连接到xx.xx.xx.xx:1883 意外断开连接. 已连接到xx.xx.xx.xx:1883
..
我正在使用Paho MQTT客户端与本地客户端进行小型IoT项目,将mqtt数据发送到本地mosquitto代理(充当网桥),然后发送到我的远程代理(SAP IoT Cloud). 从客户端到远程代理的数据流(使用TLS)正在成功运行,现在我正努力在相应位置之间放置和配置桥接器. 由于我必须对mqtt消息(QoS 1)使用TLS,因此创建了另一个具有端口8883的侦听器.还提供与用于发
..
我已经在覆盆子服务器上安装了mosquitto服务器. 此服务器正常工作:我已经测试了mosquitto_sub和mosquitto_pub命令. 我已经编写了这个python脚本: import paho.mqtt.client as mqtt import time client = mqtt.Client('module_test_4') client.connect('
..
我正在尝试实现MQTT库.并且根据一个教程,MQTT消息的固定标头应该看起来像发布的图片中所示. 也在同一教程中,我发现固定标头的编码方法写为: mqtt.write((byte) ((retain ? 1 : 0) | qos
..
我正在使用Paho和Mosqitto进行MQTT通信.我们必须支持两种序列化模型-xml和json.因此,我正在寻找如何在MQTT中标识内容类型或有效负载类型. MQTT中是否有类似的HTTP Content-Type可以快速识别它? Content-Type:应用程序/json Content-Type:应用程序/xml 谢谢 解决方案 不,MQTT负载只是字节数组,并
..
我的发布者和订阅者都以QOS = 2的身份连接到mosquitto(paho)代理,并通过clean_session = false维护持久会话.当我与连接到代理的订户发布消息时,订户成功接收到该消息,现在,如果我断开订户的连接,然后再次发布消息并与订户建立连接,那么当我的订户处于脱机状态时,我将能够检索到那些消息. 我的问题是- 代理中是否有任何存储,可以在订户脱机时存储所有消息.
..
有人知道我在哪里可以得到在无限循环中同时发布和订阅的示例MQTT客户端Go(golang)代码吗? 我正在与在MacO上运行的Mosquitto经纪人进行通讯. 更多细节... 获取来自网络的消息(主题) 根据该消息计算内容 将计算结果发送回网络(主题) 这是我正在使用的代码: package main import ( "fmt" MQTT "github.
..
我正在使用mosquitto作为代理,并使用paho(python)作为客户端.我正在尝试使订户接收脱机消息. 为此,我进行了以下更改: 固定的客户ID 第2级质量 但是,订阅者仍然无法接收消息. 有什么帮助吗? 谢谢, 拉胡尔 解决方案 为了使您的客户端成为持久客户端,并在脱机时接收发送到主题的消息,您需要满足以下条件: 固定的客户端ID(已完成) 始
..
我正在制作一个带有mqtt客户端和后台服务的应用程序,当我收到某些mqtt消息时会发出通知. 我使用Paho库和服务作为客户端,只要我连接到wifi并打开代理,一切都可以正常运行. 我不希望通过Internet访问代理,因此当没有可用的wifi时,客户端将断开连接,问题是当wifi重新连接时,mqtt客户端将不会重新连接. 我尝试了很多事情,但是最新的测试是让处理程序检查是否有互
..
菜鸟在这里. 我有一个简单的python代码,该代码应该订阅一个主题,并使用MQTT协议将JSON有效负载发布到同一主题.但是由于某种原因,我无法将有效载荷作为JSON加载! 我在做什么错了? # -*- coding: utf-8 -*- import paho.mqtt.client as mqtt import json mqtt_broker = '192.16
..
我正在使用Mosquitto Mqtt和paho API在Android设备上接收推送消息。但是一旦网络连接发生变化,它就会停止接收消息。以下是使用简单测试用例重现问题的步骤: 1)创建一个简单的活动。 2)On Activity StartUp通过paho API连接到mosquitto测试服务器(test.mosquitto.org:1883)。 3)订阅一些主题。 4
..
当我尝试订阅mqtt客户端时,我得到“java.io.eof”异常。我正在使用eclipse paho库并使用mosquitto broker。我没有得到任何答案,所以请帮助我为什么会这样? Mqtt连接和订阅 我使用此代码连接和订阅mosquitto private void buildClient(String clientId) { log.debug(“Connect
..
我正在使用paho发送和接收mqtt消息。到目前为止,发送消息没有问题。我收到它们有问题。我的代码是: package BenchMQTT; import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken; import org.eclipse.paho.client.mqttv3.IMqttToken; import or
..
我想对mosquitto进行压力测试,所以我创建了一些代码,如下所示 for(int i = 0; i
..
我们正在使用 Spring message-driven-channel-adapter 来订阅 MQTT 主题。但是我们经常遇到错误。我已使用JavaScript客户端( mqttws31.js )测试了连接,该工作正常。意味着连接没有问题。 错误: - org.springframework.integration.mqtt.inbound.MqttPahoMessageDriv
..
我在使用自签名证书连接到mqtt服务器时遇到问题。即时通讯使用Paho客户端,并希望使用 TLSv1.2 连接到服务器。实际上我已成功连接Android API 20+但在此版本之下没有成功。 到目前为止我做过的事情: 1-创建了一个PKCS#12密钥库并放入.crt文件并为其提供密码并保存(它将是.pfx文件) 2-将.pfx文件添加到android项目中的原始文件夹中
..
我在我的应用程序中使用Eclipse Paho android mqtt服务。我能够订阅并将消息发布到mqtt broker。 我在应用程序中有几个活动,当任何活动启动时,它使用连接到代理mqttAndroidClient.connect(null,new IMqttActionListener(){} 并在获取响应mqttAndroidClient.setCallback(new MqttC
..
我正在使用Eclipse Paho,使用MQTT来读取传感器数据。我已成功连接,但我想要读取数据。 我的代码到目前为止: public static void main(String [] args){ MqttClient客户端; MqttMessage msg; MemoryPersistence持久性; MqttConnectOptions conn; IMqtt
..
我正在尝试在我的项目中实现 eclipse.paho ,以连接Mqtt Broker(订阅和发布目的)。问题是,当我使用订阅功能(实现 MqttCallback 接口)时,我无法确定如果连接丢失,我该如何重新连接。 MqttCallback接口具有connectionLost方法,但是对于调试造成连接丢失的原因很有用。我搜索,但找不到建立自动重新连接的方法。你能建议一个关于这个问题的方式或文件吗?
..
我刚刚开始使用Java Android编程,甚至一般的Java编程,我想使用一个特定的MqttHandler类实现Paho MQTT Android服务,我想将回调设置为MqttHandler类的参数。关于回调的其他答案一般建议使用接口类,但我不知道如何工作。这是我试过的: public interface InterfaceMqttCallback extends MqttCallbac
..