publish-subscribe

0熱度

1回答

我們知道，KEYS命令塊Redis的服務器，並需要使用*SCAN命令來代替。據我瞭解的Redis服務器可以處理大量的發佈 - 訂閱連接。那麼，如果我在這樣的服務器上調用PUBSUB CHANNELS命令，它可以在執行此命令期間處理pubsub連接還是處理其他命令？

0熱度

1回答

用這個例子瞭解jQuery＆Pub Sub模式

我使用jQuery一段時間，但通常jQuery非常簡單。我剛看了一些視頻教程，其中作者使用了一種叫做Pub Sub Pattern的東西。我從來沒有聽說過，所以我搜索了＃1和谷歌的解釋： Why would one use the Publish/Subscribe pattern (in JS/jQuery)? 但它仍然不是很清楚，我，尤其是因爲這是代碼由上述教程的作者使用。所以，我會在這裏粘貼

2熱度

2回答

Google雲端發佈/子重試次數

我們正在從一個不穩定的消息隊列服務轉移到NodeJS中的Google Pub Sub。它似乎工作正常，但我們想包括錯誤處理。我們希望限制特定消息的重試次數，比如在我們的測試環境中執行10次，在生產中執行100次。現在，如果一條消息失敗10次（測試中），而不是它坐在我們的隊列中，並繼續處理並失敗7天，我們希望將其移動到單獨的錯誤隊列併發送給我們一封電子郵件。我們目前已將所有這些設置在我們之前的消

1熱度

1回答

訂閱反應性沒有用戶輸入，並在出版物轉移時間框架

我對流星世界有點新，並試圖獲得它的掛鉤，但卡住的東西。我想在沒有用戶交互的頁面上顯示呼叫集合的子集（請參閱它作爲火車站的到達或離開板）。我有一個發佈容器的一段時間的呼叫子集。 Meteor.publish('currentcalls', function(){ var start = moment().subtract(24, 'hours').toDate(); var

0熱度

1回答

Python 3 - 使用kwargs和args only模塊

我在tkinter中編寫了一個gui，並使用發佈/訂閱模塊（pyPubSub）來通知程序的不同部分發生了什麼，如果他們訂閱了。所以，我有兩個功能，我需要一起工作。從tkinter，我正在使用： after_idle(callback, *args) 調用主循環內的消息發送。正如你所看到的，它只接受* args作爲發送給回調的參數。我送的回調是從pyPubSub： sendMessage(top

0熱度

1回答

ejabberd MUC和MUC/Sub澄清

我最近一直在玩ejabberd中的新MUC-Sub模塊 - 用例是我需要在我的移動應用程序中擁有類似WhatsApp的永久房間。在我進一步深入使用MUC/Sub之前，請問一位ejabberd專家對以下概念有何看法？我可能缺乏對ejabberd的全面瞭解，因此是基本問題。或者請讓我知道請一個好地方開始瞭解下面更好的...我已經詳細研究這兩個鏈接（https://blog.process-one.ne

0熱度

2回答

WAMP是否發佈/訂閱電池使用效率？

我在寫一個客戶端桌面應用程序，需要從服務器接收更新。這些更新將很少（可能每週1次），但我希望儘快收到它們。難道電池上的「訂閱」主題將通過WAMP提供更新並讓應用程序在後臺持續運行？使用基於REST的API定期輪詢服務器會更高效嗎？

0熱度

1回答

NetMQ代理與XSub/Xpub模式中的控件套接字使用示例？

我正在嘗試使用NetMQ +控制套接字來實現帶有XPUB/XSUB模式的集線器（以控制集線器的行爲）。我使用代理，NetMqPoller，並希望使用控制套接字。但無論我嘗試 - 它都不起作用。這是我的代碼，爲什麼它不起作用的任何想法？ Using xpubSocket As New XPublisherSocket("@tcp://127.0.0.1:1234") Using xsub

0熱度

1回答

從大型機

我想用也駐留在主機Server.Do Java代碼連接到的QueueManager在大型機使用JMS的java連接到MQ我們有什麼樣的代碼從一個運行在大型機方面的java連接到大型機MQ ？我們是否需要使用客戶端或綁定模式進行連接？

0熱度

1回答

Meteor.js - 不會顯示訂閱數據，只顯示光標對象

爲什麼它不顯示我的模板中的文件記錄？它返回到模板的唯一東西就是'遊標'對象。中的console.log（文件）輸出爲JS控制檯什麼： FilesCollection {collectionName: "Files", downloadRoute: "/cdn/storage", schema: Object, chunkSize: 524288, namingFunction: false…}