paho

    0熱度

    1回答

    背景 我一直在玩MQTT的一個項目,遇到了一個奇怪的問題。我使用paho作爲我的MQTT客戶端,並使用VerneMQ作爲代理。 VerneMQ代理服務已啓動並正在運行,我可以通過runnnig netstat來確認,我可以看到127.0.0.1:1883條目處於LISTENING模式。 這是我的客戶端代碼: public class Producer implements MqttCallback

    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熱度

    1回答

    我想在一個名爲'single'的數組中保存溫度數據(我從一個paho客戶端獲得)。最後,我想在儀表中顯示實時數據。 爲此,我創建了一項服務來存儲數據並將數據分發給多個組件。 但我只得到錯誤:「」不能分配給類型'{值:字符串; }」。 我真的很感激這個新想法!謝謝! 我的服務: import { Injectable } from '@angular/core'; import { Compone

    1熱度

    1回答

    我正在使用openssl使用Eclipse Paho MQTT C客戶端通過TLS連接到一個mosquitto代理。這是我的代碼的一部分: MQTTClient client; MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer; MQTTClient_message pubmsg = MQTT

    0熱度

    1回答

    我有以下代碼爲mqtt客戶端從代理接收消息。 如果客戶端與代理斷開連接,則客戶端嘗試再次使用connect()調用與代理進行連接。我已閱讀paho文檔說loop_start()將處理與經紀人的重新連接。請讓我知道是否正確使用connect()呼叫與經紀人重新連接,或讓其自行處理loop_start()。 import paho.mqtt.client as mqtt import json i

    -1熱度

    1回答

    我在我的網站上使用mqtt作爲消息系統。那麼在我的本地機器一切正常,但在我的網站(生產),我得到一個錯誤: vendor.bbaf8c4….bundle.js:1 WebSocket connection to 'ws://localhost:1884/mqtt' failed: Error in connection establishment: net::ERR_CONNECTION_REFU

    1熱度

    2回答

    我使用eclipse MQTT連接到MQTT服務器。 我可以連接到服務器成功,但是當我發佈消息,我得到這個錯誤 連接丟失 消息:連接丟失 LOC:連接丟失 原因:java.io.EOFException的 excep:連接丟失(32109) - java.io.EOFException 我搜索了這個問題。但我找不到任何真正的答案!一些鏈接我公司成立於此處{here,here,here,...} 我

    0熱度

    1回答

    我從線程「Python MQTT連接只有有限的時間」下面的python腳本。 #!/usr/bin/python import sys import paho.mqtt.client as mqtt import time def on_message(client, userdata, msg): if msg.topic == "foo/bar": pri

    0熱度

    1回答

    我們有一個休息服務端點(Spring MVC),它將消息發佈到mqtt代理。 我們計劃緩存MqttClient,以便我們不必爲每個請求創建它。 什麼是最佳選擇?將MqttClient存儲在每個ThreadLocal對象中? 使用諸如Apache Commons Pool之類的對象池? 任何意見,將不勝感激。另外,如果已經有Paho MqttClient的池實現可用?

    0熱度

    1回答

    我正在使用paho.mqtt.client。 下面是代碼的簡化版本,但它仍然顯示問題。 # -*- coding: utf-8 -*- import sys import os import time import logging from time import sleep import paho.mqtt.client as mqtt mqtt_server_ip =