paho相关内容

蚊子意外断开

我正在使用python mosquitto(paho)库.我遇到了Unexpected disconnection.的问题,我发现它不断掉线并与服务器建立连接. .我找不到问题.有时它显示[Error 104]连接被对等方重置.我将经纪人托管在亚马逊网络服务上. 我的错误是--- 已连接到xx.xx.xx.xx:1883 意外断开连接. 已连接到xx.xx.xx.xx:1883 ..
发布时间:2020-05-12 18:48:18 Python

Mosquitto Broker Bridge配置-协议版本不可接受

我正在使用Paho MQTT客户端与本地客户端进行小型IoT项目,将mqtt数据发送到本地mosquitto代理(充当网桥),然后发送到我的远程代理(SAP IoT Cloud). 从客户端到远程代理的数据流(使用TLS)正在成功运行,现在我正努力在相应位置之间放置和配置桥接器. 由于我必须对mqtt消息(QoS 1)使用TLS,因此创建了另一个具有端口8883的侦听器.还提供与用于发 ..
发布时间:2020-05-12 18:48:09 其他开发

MQTT qos参数无效

我已经在覆盆子服务器上安装了mosquitto服务器. 此服务器正常工作:我已经测试了mosquitto_sub和mosquitto_pub命令. 我已经编写了这个python脚本: import paho.mqtt.client as mqtt import time client = mqtt.Client('module_test_4') client.connect(' ..
发布时间:2020-05-12 18:48:02 其他开发

MQTT中的内容类型替代

我正在使用Paho和Mosqitto进行MQTT通信.我们必须支持两种序列化模型-xml和json.因此,我正在寻找如何在MQTT中标识内容类型或有效负载类型. MQTT中是否有类似的HTTP Content-Type可以快速识别它? Content-Type:应用程序/json Content-Type:应用程序/xml 谢谢 解决方案 不,MQTT负载只是字节数组,并 ..
发布时间:2020-05-12 18:47:24 其他开发

当订户以QOS = 2脱机时,由mosquitto代理发布的消息存储

我的发布者和订阅者都以QOS = 2的身份连接到mosquitto(paho)代理,并通过clean_session = false维护持久会话.当我与连接到代理的订户发布消息时,订户成功接收到该消息,现在,如果我断开订户的连接,然后再次发布消息并与订户建立连接,那么当我的订户处于脱机状态时,我将能够检索到那些消息. 我的问题是- 代理中是否有任何存储,可以在订户脱机时存储所有消息. ..
发布时间:2020-05-12 18:47:20 其他开发

golang mqtt发布并订阅

有人知道我在哪里可以得到在无限循环中同时发布和订阅的示例MQTT客户端Go(golang)代码吗? 我正在与在MacO上运行的Mosquitto经纪人进行通讯. 更多细节... 获取来自网络的消息(主题) 根据该消息计算内容 将计算结果发送回网络(主题) 这是我正在使用的代码: package main import ( "fmt" MQTT "github. ..
发布时间:2020-05-12 18:47:10 其他开发

接收离线消息mqtt

我正在使用mosquitto作为代理,并使用paho(python)作为客户端.我正在尝试使订户接收脱机消息. 为此,我进行了以下更改: 固定的客户ID 第2级质量 但是,订阅者仍然无法接收消息. 有什么帮助吗? 谢谢, 拉胡尔 解决方案 为了使您的客户端成为持久客户端,并在脱机时接收发送到主题的消息,您需要满足以下条件: 固定的客户端ID(已完成) 始 ..
发布时间:2020-05-12 18:47:07 其他开发

wifi断开并不会重新连接时,应用程序,服务和mqtt崩溃

我正在制作一个带有mqtt客户端和后台服务的应用程序,当我收到某些mqtt消息时会发出通知. 我使用Paho库和服务作为客户端,只要我连接到wifi并打开代理,一切都可以正常运行. 我不希望通过Internet访问代理,因此当没有可用的wifi时,客户端将断开连接,问题是当wifi重新连接时,mqtt客户端将不会重新连接. 我尝试了很多事情,但是最新的测试是让处理程序检查是否有互 ..
发布时间:2020-05-12 18:46:58 Java开发

Python 3 Paho-MQTT发布/订阅的JSON消息无法解析

菜鸟在这里. 我有一个简单的python代码,该代码应该订阅一个主题,并使用MQTT协议将JSON有效负载发布到同一主题.但是由于某种原因,我无法将有效载荷作为JSON加载! 我在做什么错了? # -*- coding: utf-8 -*- import paho.mqtt.client as mqtt import json mqtt_broker = '192.16 ..
发布时间:2019-11-26 20:43:11 Python

Android - Paho Mqtt客户端在网络连接更改后不会收到消息(移动数据已禁用并再次启用)

我正在使用Mosquitto Mqtt和paho API在Android设备上接收推送消息。但是一旦网络连接发生变化,它就会停止接收消息。以下是使用简单测试用例重现问题的步骤: 1)创建一个简单的活动。 2)On Activity StartUp通过paho API连接到mosquitto测试服务器(test.mosquitto.org:1883)。 3)订阅一些主题。 4 ..
发布时间:2019-01-08 13:06:58 Java开发

Eclipse paho Mqtt:获取java.io.EOF异常

当我尝试订阅mqtt客户端时,我得到“java.io.eof”异常。我正在使用eclipse paho库并使用mosquitto broker。我没有得到任何答案,所以请帮助我为什么会这样? Mqtt连接和订阅 我使用此代码连接和订阅mosquitto private void buildClient(String clientId) { log.debug(“Connect ..
发布时间:2019-01-08 11:58:06 Java开发

如何使用自签名证书连接到Android(paho客户端)中的Mqtt服务器?

我在使用自签名证书连接到mqtt服务器时遇到问题。即时通讯使用Paho客户端,并希望使用 TLSv1.2 连接到服务器。实际上我已成功连接Android API 20+但在此版本之下没有成功。 到目前为止我做过的事情: 1-创建了一个PKCS#12密钥库并放入.crt文件并为其提供密码并保存(它将是.pfx文件) 2-将.pfx文件添加到android项目中的原始文件夹中 ..
发布时间:2018-12-17 10:00:49 Java开发

使用单个连接实例实现Eclipse MQTT Android Client

我在我的应用程序中使用Eclipse Paho android mqtt服务。我能够订阅并将消息发布到mqtt broker。 我在应用程序中有几个活动,当任何活动启动时,它使用连接到代理mqttAndroidClient.connect(null,new IMqttActionListener(){} 并在获取响应mqttAndroidClient.setCallback(new MqttC ..
发布时间:2018-12-12 18:03:11 Java开发

如何从Eclipse中的MQTT读取数据Paho?

我正在使用Eclipse Paho,使用MQTT来读取传感器数据。我已成功连接,但我想要读取数据。 我的代码到目前为止: public static void main(String [] args){ MqttClient客户端; MqttMessage msg; MemoryPersistence持久性; MqttConnectOptions conn; IMqtt ..
发布时间:2017-07-30 18:36:26 Java开发

Java Eclipse Paho实现 - 自动重新连接

我正在尝试在我的项目中实现 eclipse.paho ,以连接Mqtt Broker(订阅和发布目的)。问题是,当我使用订阅功能(实现 MqttCallback 接口)时,我无法确定如果连接丢失,我该如何重新连接。 MqttCallback接口具有connectionLost方法,但是对于调试造成连接丢失的原因很有用。我搜索,但找不到建立自动重新连接的方法。你能建议一个关于这个问题的方式或文件吗? ..
发布时间:2017-07-29 20:08:53 Java开发

Paho-mqtt回调在不同的类android java

我刚刚开始使用Java Android编程,甚至一般的Java编程,我想使用一个特定的MqttHandler类实现Paho MQTT Android服务,我想将回调设置为MqttHandler类的参数。关于回调的其他答案一般建议使用接口类,但我不知道如何工作。这是我试过的: public interface InterfaceMqttCallback extends MqttCallbac ..
发布时间:2016-11-10 11:39:52 Java开发