publish-subscribe

    0熱度

    2回答

    我看到在MQ集羣基礎設施的問題,即郵件堆積 起來SYSTEM.INTER.QMGR.PUBS這是目前在一個隊列管理器與 集羣主題定義。 Infocenter說:「在發佈/訂閱羣集中,這些發佈爲 ,針對的是承載訂閱的遠程隊列 管理器上的SYSTEM.INTER.QMGR.PUBS隊列。」 我想知道消息流如何與SYSTEM.INTER.QMGR一起使用。 PUBS隊列定義爲 Cluster主題&當地s

    2熱度

    1回答

    大多數Meteor都圍繞集合和遊標進行處理,並在收集文檔時出現並獲取符合條件的新文檔。然而,我正在處理更大的文檔,這些文檔包含多個字段,並且具有深度且不可預測的結構。在頂層有一個清晰的模式,但是一些子文檔是不可預知的json數據。 但是,讓我們來看一個簡單的例子: Reports = new Mongo.collection('reports'); Meteor.publish('report

    0熱度

    2回答

    我對我的問題有一個工作解決方案,但不知道是否有更乾淨的方式來做到這一點。 我的架構由多個服務組成,通過Rabbitmq broker發送消息。 一些工作人員使用這些消息並執行後臺工作。 事情是,我希望能夠創建不同類型的工人,所有消費相同的服務,並能夠通過循環法獲得相同類型的幾名工人。 要做到這一點,服務以pub/sub方式發佈消息,並由在專用於一組工作人員的工作隊列中重新分發消息的進程使用。 有沒

    0熱度

    1回答

    在MQTT中,客戶端可以訂閱主題名稱或主題通配符。可以使用相同的通配符將消息發佈到主題或某些主題。但是如何將消息發佈到一些相互獨立的話題?我需要修改MQTT協議嗎? 例如:我的服務器處理來自10個客戶端(這些客戶端彼此不相關)的連接,它們與ids:client1,client2,...,client10和client1想要發送消息給任意數量的客戶端(例如客戶端3,客戶端7,client8) 感謝

    2熱度

    1回答

    有沒有什麼辦法可以從pubnub.I服務器導入數據我有一個聊天應用程序,我們正在使用谷歌應用程序引擎後端現在我想實現pubnub api的聊天,但所有以前的聊天保存在我的服務器數據庫。請讓我知道是否有任何方法在pubnub數據庫中導入以前的數據。

    0熱度

    1回答

    我有一個SQL Server(例如訂閱者),它訂閱了另一個SQL Server(例如publisher)。 新記錄很容易處理。但我不知道如何捕獲訂閱者中刪除的記錄。 我無法修改發佈者,但我可以完全訪問訂閱者和分發服務器。 例如: record id100 inserted record id100 processed by my program record id100 deleted(how

    3熱度

    1回答

    我正在開發項目的微服務,並且正在使用AWS SNS + SQS試驗發佈 - 子通信。我們不確定如何向服務發信號通知其他服務是否已成功完成任務。 例如,如果服務A發出SNS事件並且服務D,E和F都正在偵聽訂購的SQS隊列,服務A如何知道服務A在服務D,E和F成功了嗎? 我給一個更具體的例子: 一個新用戶註冊一個網站。該網絡呼叫首先到達後端的user service。如果用戶成功,則發送說明創建了新用

    1熱度

    1回答

    新文檔的問題是在服務器上的下一個代碼: Meteor.publish(null , function() { let events = []; Groups.find({participants: this.userId}).forEach(function(item) { events.push(item.latestEvent); }); r

    0熱度

    1回答

    我是Android開發的初學者。我必須開發一款Android應用程序,可以實時提供按需人羣反饋。 這個想法是:任務生產者需要一個任務在第x天,第y天,由n個工人解決,所以他向系統公佈這個;工作人員看到任務何時可用,並且他們贊同;在該日期和時間,任務生產者將任務發送給訂閱的工人,他們立即解決問題,並且一旦任務解決,結果必須返回給任務生產者。 我不確定要使用哪種體系結構模式,以便可以在不使用服務器的情

    1熱度

    1回答

    我想從Strophe.js創建一個websocket連接到Ejabberd,但ejabberd無法建立websocket連接。 下面是詳細: ejabberd版本:16.02 網絡插座管 一般 Request URL:ws://localhost:5280/websocket Request Method:GET Status Code:101 Switching Protocols 響應