paho

    2熱度

    1回答

    我想在我的項目用SpringMVC使用MQTT。官方示例,In this link用new關鍵字創建所有對象。據我所知,這不是Spring風格。建議創建bean的方法不是嗎? 我發現了一些例子(彈簧集成,MQTT,其基於Eclipse的泛美衛生組織,MQTT)配置的基於XML的,但我想讓它基於Java的配置。我完成了基於Java的整個項目。項目中沒有.xml文件(甚至不包括web.xml)。 如果

    0熱度

    1回答

    我們決定在我們的移動應用程序中使用mqtt協議作爲聊天模塊。我也想在服務器端保存主題的消息。但我看到,mqtt客戶端在這裏是全球性的,所以有一種方法是我必須訂閱mqtt客戶端的單個實例到所有主題並將消息保存在數據庫中。但是做到這一點是正確的做法。我只是在擔心。 private void buildClient(){ log.debug("Connecting... "+CLIENT_I

    0熱度

    1回答

    我將簡單的JSON字符串{"TMP":"-15.5826"}發佈到Web客戶端。信息出現在message.payloadString我可以在html中打印它,但我無法用JSON.parse()解析消息。 obj和data是未定義的。這是主要問題,要解決這個問題我首先使用JSON.stringify()這個時候解析消息但是data仍然是未定義的。看起來stringify會添加額外的雙引號並且使jso

    3熱度

    2回答

    我得到「java.io.eof」異常,當我試圖訂閱mqtt客戶端。我使用eclipse paho庫和使用蚊子經紀人。我沒有得到任何答案,所以請幫助我爲什麼會發生這種情況? MQTT連接和訂閱 我使用這個代碼用於連接和訂閱mosquitto private void buildClient(String clientId){ log.debug("Connecting... "+clien

    1熱度

    1回答

    我嘗試了以下應用程序,其中兩個客戶端連續發送消息,另一個客戶端接收消息。但在這裏,似乎messageAllved方法已在單個線程中調用。因爲一旦來自一個客戶端的消息卡住,其他客戶端消息也不會收到。這是我的執行問題還是這是行爲?請指教。下面顯示的是我的代碼。 import java.text.SimpleDateFormat; import java.util.Calendar; import

    2熱度

    1回答

    我已經在啓用了websockets的Visual Studio上使用Cmake生成項目文件,從而構建了mosquitto。我使用libwebsockets-1.4。 我用一個websocket監聽器運行這個代理,如下圖所示,它開始通過websockets監聽端口8000。 現在我用的是泛美衛生組織的WebSocket客戶端,並試圖連接到代理 client = new Paho.MQTT.Clien

    1熱度

    1回答

    我在Android中使用Paho MQTT客戶端連接到IBM Bluemix快速入門IoT服務。連接部分運行良好,但是當我發佈時,雲應用程序顯示我斷開連接,但在客戶端中,我沒有發生異常。 我用這個權限: <uses-permission android:name="android.permission.INTERNET"/> 連接: String broker = "tcp://quicks

    0熱度

    1回答

    雖然我在使用paho和spring框架的應用程序中修復了客戶端中的一些問題,但我發現了MQTT的集成。我不確定這是否能解決我的問題,我甚至不知道這是什麼。 有人可以解釋一起使用它的區別是什麼? Spring框架是否會帶來錯誤,導致整合解決的問題? 還是存儲足夠用這兩種技術分開? 由我使用的依賴關係: <dependency> <groupId>org.springframework.

    2熱度

    1回答

    我的應用程序使用paho客戶端時出現以下錯誤消息。發生此錯誤後,客戶端停止接收消息。雖然不確定,但我認爲我仍然可以發佈消息。 o.e.p.c.mqttv3.internal.ClientState : 106ed26f-74f8-4048-9035-cb9146e35c7c:67c62857-af3c-4aa0-9f28-3f4db6baf811: Timed out as no activit

    2熱度

    1回答

    我的服務使用paho mqtt時出現問題。它超時但沒有連接丟失的報告。有沒有人有解決這個問題的辦法? public void connect(String client_id) { String tmpDir = System.getProperty("java.io.tmpdir"); MqttDefaultFilePersistence dataStore = new