publish-subscribe

    0熱度

    3回答

    我正在寫一個mqtt客戶端,它在收集消息數據時會一直循環。 該數組目前是全局的,但由於這被認爲是不好的做法,我想避免這種情況。不過,我不知道如何用另一個參數調用on_message。 如何避免使用數組作爲全局變量? def on_message(client, userdata, msg): global array array.append(msg.payload)

    3熱度

    1回答

    我正嘗試使用Java實現Google Cloud Pub/Sub以通過Push接收消息,但是我找不到Java的文檔。 我可以通過拉來接收消息,任何導致本地安裝和測試端點的幫助都會非常有幫助。 我已經驗證並添加了域作爲端點想知道下一步該做什麼以開始接收該端點上的消息。

    1熱度

    2回答

    我是ZeroMQ新手(在C++上)。?br: 寫程序時用PUB/SUB正式通信模式原型,我困住了一個問題。 計劃: 這是我的項目,在這裏我想給儘可能多的信息發送到PUB。 爲此,我曾使用一個ROUTER套接字類型。 問題: 接收機是緩慢的,由於該消息被排隊得到(直至到達高水印)和在這之後,開始丟棄上SUB側。 尋找: 我想從ZeroMQ(對C++)的方法,該告訴我了「傑出隊列中的消息計數」。 搜索

    0熱度

    1回答

    我試圖在我的程序中使用mvc-模型。我使用pubsub在我的文件之間進行通信。我想知道是否有另一種溝通方式,而不是使用pubsub? 我的具體問題:我有2個文件。在文件1中,我有一個if結構,它需要來自文件2的信息。如果某個面板隱藏在B幀中,則必須打開幀A,或者如果面板在B幀中可見,則幀A不能打開。 我可以從文件1發送一個pubsub消息到文件2,詢問面板是否隱藏,然後文件2可以發回消息與答案。但

    1熱度

    1回答

    我有一個RTI DDS應用程序,其中reliable reader和reliable writer。 無論何時我重新啓動閱讀器應用程序,閱讀器都會讀取已收到的消息。因此,如果閱讀器收到重新啓動應用程序的消息,則由於在每次應用程序重新啓動時都會讀取重新啓動消息,因此它現在處於重新啓動循環。 我的印象是這些消息會被確認,如果在應用程序重新啓動之前已收到,則不會重新發送。爲什麼我收到消息,因此我已閱讀了

    3熱度

    1回答

    僅在訂閱主題時纔會丟失郵件。 這裏是場景: 用戶訂閱特定的主題,然後在不同的線程(具有相同的上下文和相同的「訂閱的主題」)調用發佈者。 發佈者收到「訂閱的主題」併發布它。當我運行兩個過程(意味着2個訂閱者線程和2個發佈者線程)時,我只在其中一個線程(隨機)上收到一條消息。 我不知道爲什麼我失去了第二條消息。 出版商螺紋: void *publisher = zmq_socket(ptStruct-

    0熱度

    3回答

    據the docs: 如果調用Meteor.subscribe反應的計算中,例如使用Tracker.autorun,當計算無效或停止訂閱將自動取消; 然後明確提到,不需要在autorun內停止訂閱。 這也是流星助手的情況嗎?我相信他們算作reactive computation,但我不完全確定! EDIT 下面是代碼表示的情況的一個片段。 接下來的問題是:我需要做些什麼來阻止objectsSub或

    0熱度

    1回答

    所以我在我的應用程序中使用faye pub-sub,發佈是從不同的應用程序發生的,在我的faye.js中我寫了ajax post rails for rails 。現在,如果我的應用程序的5頁在瀏覽器中打開,faye.js被加載5次,並且post方法被調用5次。如果沒有打開單個頁面,則即使一次,發佈方法也不會工作。但是我正在接受faye服務器發佈的數據。所以當我使用回調方法時,有沒有在faye.r

    0熱度

    1回答

    我有一個小的本地IoT網絡,在Arduino IDe中編寫了一些Wemos D1節點。其中一些有兩個連接的傳感器,例如雨和潮溼。 我想每分鐘發一次數值,一分鐘下雨,一分鐘溼度。 下面的代碼通常與delay(5000);兩個工作,但一旦我有類似delay(60000);節點顯然開始只出版雨水和跳過溼度(我有一個mosquitto_sub -h myIP -v -t '#'運行監聽傳遞消息。 這是我l

    0熱度

    1回答

    如何確保訂閱已準備就緒,而無需訂閱特定發佈或訂閱自動發佈。我的頁面不會在刷新時加載,因爲數據在編譯期間沒有提供,所以我想通過訂閱vue路由器的全球導航衛士。