publish-subscribe

    0熱度

    2回答

    我在c++(使用zhelpers.hpp)和python3 ZeroMQ訂戶的ZeroMQ發佈者(使用pyzmq)。 問題是,用戶沒有收到消息。我想,ZeroMQ過濾器存在問題。我無法弄清楚,如何正確使用.setsockopt()中的c++來收回來自python發佈者的消息。 Python的出版商: import zmq context = zmq.Context() sock

    13熱度

    1回答

    我是Redis和Kafka的初學者。 Redis可以用作實時pub-sub。不過卡夫卡也是實時發佈的。 我很困惑哪一個使用什麼時候。任何使用情況將是一個很大的幫助! 謝謝!

    0熱度

    1回答

    我正在嘗試使用Hazelcast開發特定功能(訂閱服務)。訂閱將根據謂詞來偵聽特定的地圖。這可以通過entryListener輕鬆實現。到現在爲止還挺好。 但是,當我添加eventListener(並不斷收到持續更新)時,緩存不是空的。如果將eventListener添加到具有實體的緩存中,則不會了解緩存中的當前條目。 我可以調用map.values(),但是這不提供真正的解決方案,因爲添加eve

    0熱度

    1回答

    我從Github &下載了根據給定指令安裝的Arduino Yun SDK。我運行示例BasicPubSub &它成功運行&我看到每秒到達MQTT客戶端訂閱主題的消息。太棒了! 但我在資源選項卡上看不到設備連接。它仍然說'上次更新=沒有狀態'。 這是爲什麼? 我需要每10秒發送一次消息。我將BasicPubSub循環中的延遲更改爲延遲(10000)。但是現在,只有第一條消息才被收到,主題爲&串口監

    0熱度

    1回答

    我有一個問題,我不知道如何解決它。我在WSB2 ESB 4.9.0上。 我想通過使用事件的代理來調用主題。但是,這永遠不會調用訂閱它的代理。 <?xml version="1.0" encoding="UTF-8"?> <proxy name="publishSubscribeTest" startOnLoad="true" trace="disable" transports="ht

    0熱度

    1回答

    我有一個類似的問題,因爲這後消費從Hazelcast隊列消息僅一次: Consume message only once from Topic per listeners running in cluster 當我試圖使用隊列發佈消息,並在兩個不同的JVM中加入一個項目監聽器,我我兩次都收到這些消息。我想只在羣集/分佈式環境中收到消息一次。 這裏是我的代碼片段: 發佈消息: getQueue().

    1熱度

    1回答

    下面的代碼是我想要做的簡單抽象 - 它處理髮布和訂閱dojo事件模型。我的目標是發佈一個事件,併爲該事件訂閱一個方法。 <html> <head> <script> dojoConfig={async:true, parseOnLoad: true} </script> <script type="text/javascript" src="dojo/dojo.js"> </scrip

    0熱度

    1回答

    我有一個工作的Redis pub子配置,如在spring boot redis pub子指南中所述。 下面是RedisMessageListenerContainer @Bean RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapte

    0熱度

    1回答

    如果我PUBLISH Redis上的消息有一個訂閱者,但該訂閱者需要1秒鐘才能收到該消息將阻止PUBLISH一秒鐘,還是他們獨立行動? 如果他們獨立行動多少PUBLISH命令將排隊之前壞的東西開始發生?

    -2熱度

    1回答

    我是Meteor的新手。我需要使用Meteor js建立一個類似於頭像的文本搜索系統。我在服務器端的收藏大約有一百萬字,所以不可能將它們全部發布(我的頁面將永久加載,所以我假設收藏太大以至於永遠同步)。但是,每次,我的系統都需要在整個集合中進行搜索。任何人都有關於如何做到這一點的建議?非常感謝