mqtt

    1热度

    1回答

    我已经为MQTT订户编写了一个python脚本,它在本地完美地工作。 的Python脚本用户 import paho.mqtt.client as mqtt import os,json filePath = "logs.csv" def initiateFile(): if (os.path.exists(filePath) == False): fileObj

    0热度

    1回答

    背景 我一直在玩MQTT的一个项目,遇到了一个奇怪的问题。我使用paho作为我的MQTT客户端,并使用VerneMQ作为代理。 VerneMQ代理服务已启动并正在运行,我可以通过runnnig netstat来确认,我可以看到127.0.0.1:1883条目处于LISTENING模式。 这是我的客户端代码: public class Producer implements MqttCallback

    0热度

    1回答

    当代理后面可以使用emqttc https://github.com/emqtt/emqttc? 您可以将SSL选项传递给emqttc:start_link函数,但它似乎没有为代理执行任何操作。作为一个例子,我尝试使用{proxy_auth,{Proxy_Username, Proxy_Password}}作为选项。任何建议,如果这是可能的或如何配置它的代理使用?

    0热度

    1回答

    我正在运行一个RabbitMQ实例,它通过rabbitmq_web_mqtt插件通过websockets提供MQTT。 由于遗留原因,我需要支持非默认的WebSocket URL。 我在文档中看到可以通过{ port, 1234 }配置更改端口,但我找不到任何方法来更改WebSocket URL。它目前设置为默认路径/ws 是否可以在不修改插件的情况下更改WebSocket URL?

    2热度

    1回答

    我正在研究亚马逊物联网作为定期测量数据的移动设备的传输机制(通常每N分钟,N为2到32分钟之间的任何地方)。利用MQTT,我可以利用亚马逊的经纪商将完成的测量结果发布给QoS = 1的订户。我们还假设我的唯一用户只是监听通配符主题(例如abc /#)的另一个设备,并将发布的消息存储到本地数据库中。 但现在它也有可能是: the publishing mobile devices have spot

    -1热度

    1回答

    我对Aws物联网相当陌生。我知道我们可以为Aws IoT编写Java客户端。我有以下三个查询: Java客户端是否仅用于接收来自Aws'Thing'的消息? 其他设备可以订阅Java客户端 可以这样客户端也将消息发送给其他设备 这将是有益的,如果你能帮忙的出发点,以实现Java。参考任何文章或链接将非常有帮助。

    -1热度

    3回答

    我在MQTT应用程序的工作,并为int当我收到来自MQTT经纪人有效载荷的信息,并试图将其从void *的是MESSAGE->的有效载荷为int的转换的 signed int var_1=*((int*) message->payload); ,而不是将其转换为它是将其转换为另一个数,看到这个我使用下面的代码: printf("Message:%s\n",message->payload);

    0热度

    1回答

    我正尝试使用Python 2.7和Paho MQTT 1.3.1将JSON数据推送到IBM Watson IoT平台。 它可以与来自IBM的Github的IoT Python客户端一起工作,但是我的设备环境不支持此扩展。 测试时,我在IBM Watson IoT中禁用了TLS加密。 这是我的代码: import json import paho.mqtt.client as mqtt cli

    0热度

    2回答

    我想提出以下申请。 1.Send a command from mosquitto_pub to Arduino device via Watson IoT. 2.Arduino subscribes to commands. 3.Arduino publishes sensor information to mosquitto_sub via Watson IoT. 为了进行简单的连接测

    1热度

    1回答

    我正在使用openssl使用Eclipse Paho MQTT C客户端通过TLS连接到一个mosquitto代理。这是我的代码的一部分: MQTTClient client; MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer; MQTTClient_message pubmsg = MQTT