mqtt相关内容
我正在使用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协议发送数据。 Java项目(tempSensor)使用mqtt协议生成tempvalue,使用mqtt订阅tempvalue的node.js。 node.js和java项目都使用相同的密钥进行发布/订阅。我可以使用java项目发布数据,也可以在node.js中订阅数据。但数据不是可读格式。怎么做 ?因此数据是可读格式。 TempStruct的结构如下: public
..
我在使用自签名证书连接到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
..
在将MQTT添加到我拥有的反应原生项目时,我很难找到正确的方法。该项目需要在iOS和Android上运行,因此理想情况下可以在javascript端处理MQTT。我意识到网络巢穴从移动节点到经典节点是不同的,所以我开始沿着分叉路线阻止MQTT.js并在路障后遇到障碍。 我应该继续下去分叉MQTT.js的路线?我是否应该通过polyfill或其他方式在移动环境中复制节点环境?我应该分解并获得一
..
在Node-Red中,我希望能够在http输入节点和响应节点之间使用MQTT发送消息并等待其响应。我认为一张图片更能说明这一点: 问题是http响应节点必须以某种方式直接链接到输入,所以我想在收到http输入后将整个消息保存在上下文中,然后在发送响应之前将其恢复。问题是,显然,消息的结构是循环的,因此我无法直接将其转换为字符串,以将其存储在上下文中。 我是尝试了不同的方法来解决这个问题
..
想要了解Google云消息传递(以前称为Google Cloud到设备消息传递)等推送通知的基本原因对于云设备通信更加电池友好吗? 在我看来,替代技术涉及“轮询”(通过TCP / IP),同时保持连接处于CONNECTED状态,使用保持活动。或者有什么更好的? 我对GCM有限的认识是,它也使用TCP / IP和keepalives,但客户端从不轮询服务器的状态。相反,服务器通知客户
..
从App Engine标准集成Cloud Pub / Sub API 我正在开发标准Python环境中的Google应用引擎应用程序。对于代码的某些部分,我需要与Google Cloud pub / sub API集成。 正如前面提到的 a>,Pub / Sub只能集成到App Engine灵活环境中(顺便说一句,它也只在alpha中)。有人可以描述如何在App Engine标准环境中
..
我使用的是用于MQTT协议的mosquitto服务器。 使用-c选项的配置文件中的持久性设置,我可以保存数据。 但是生成的文件是二进制文件。 如何读取该文件? 有没有特定的工具可以使用? 感谢您的意见。 谢谢! Amit 解决方案 为什么你要阅读? 当消息(QOS1或QOS2)在运行时,数据只保存在那里,以确保它们在等待来自订阅客户端的响应时不丢失。 在
..
我目前正试图让我的Python(Flask)web服务器显示我的MQTT脚本正在做什么。 MQTT脚本,本质上,它订阅了一个主题,我真的很想对它得到的信息进行分类,并实时显示/更新它。 设置1 = 9 设置2 = 2 $ b类似于一个简单的列表,显示各种定期更新的设置。 $ b Setting3 = 5 首先,我有一个连接页面,在Python(Flask)应该连接到的IP
..
去paho下载了一个mqtt.embedded.c的库文件,然后稍作移植,主要就是修改了对socket的实现,使它可以在我的设备中运行。 设备连接bluemix的iot只要有两种方式,一种是连接它的quickstart,另外一种需要注册设备,由于第二种条件比较多,我就先实现第一种,从他的transport_open()函数可以看出他是利用域名解析来得到相应地址,由于我的设备中并没有相应的域名解析
..
问 题 问题描述: 1.公司需要,用源码开发了一个MQTT的服务器程序,但是需要兼容老的的服务器程序(不是MQTT协议的) 2.老的服务器程序上有很多设备在连接,设备发送的消息,需要通过老程序发送给新的MQTT服务器程序,新的MQTT程序会将接受到的数据,以某一个主题publish。 3.我现在是在老的服务器程序上建立了几个MQTT client 与 新的MQTT服务器程序相连,用来传
..
我正在设置一个使用ssl / tls加密的蚊子经纪人。我不想生成客户端证书。我只想加密连接。 手册页仅描述了可用的设置,而不是需要哪些设置以及如何使用它们。 需要哪些设置,如何设置? 我使用mosquitto 1.3.5 解决方案 这里有一个小小的指南,但并不太多: http://mosquitto.org/man/mosquitto-tls-7.html 您需要设
..
我正在使用Eclipse Paho,使用MQTT来读取传感器数据。我已成功连接,但我想要读取数据。 我的代码到目前为止: public static void main(String [] args){ MqttClient客户端; MqttMessage msg; MemoryPersistence持久性; MqttConnectOptions conn; IMqtt
..
我从此处获取示例代码。 我有头文件 MQTTClient.h 。 然而,当我建立我得到错误: 未定义引用MQTTClient_create 未定义引用MQTTClient_connect 未定义引用MQTTClient_publishMessage 未定义引用MQTTClient_waitForCompletion 未定义引用MQTTClient_disconnect
..
KURA MQTT云客户端发布符合以下公式的消息(更多详细信息): #account-name /#client-id /#API-ID / topic 我想以自己的格式发送MQTT消息,我不想在MQTT消息中发送帐户名称和客户端ID 。 我该怎么做? 我已经尝试更改KURA Web界面中的配置 - > MQTTData传输,我删除了“lwt.topic”的内容
..
我正在尝试在我的项目中实现 eclipse.paho ,以连接Mqtt Broker(订阅和发布目的)。问题是,当我使用订阅功能(实现 MqttCallback 接口)时,我无法确定如果连接丢失,我该如何重新连接。 MqttCallback接口具有connectionLost方法,但是对于调试造成连接丢失的原因很有用。我搜索,但找不到建立自动重新连接的方法。你能建议一个关于这个问题的方式或文件吗?
..
我正在使用paho发送和接收mqtt消息。 到目前为止,发送消息一直没有问题,我通过使用mosquitto接收它们。 现在我想通过使用java客户端,我注意到有关接收消息的文档较少。 我实现了MqttCallback界面,但我仍然无法弄清楚如何读取我已经订阅了一个主题。 这是迄今为止我的源代码,我可以使用mosquitto_sub来阅读消息。 import org.ec
..