publish-subscribe

0熱度

2回答

我在WebSocket（WS）內發出Redis訂閱。當我接收到WS打開時，我將請求線程化，然後實例化Redis客戶端。在公開之內，我爲Redis提供線程併發布訂閱。這一切正常，直到我收到一個意想不到的WS關閉。此時，運行Redis訂閱的線程消失了。如果我發出取消訂閱，我會得到一個掛起。如果我不退訂，我已經離開了一個幻影訂閱，導致我接下來發生麻煩。發佈它的線程終止後，是否有某種方法可以刪除訂閱？

-2熱度

1回答

Pub/sub基於事件 - Python

我想建立一個系統，我可以根據他們的訂閱某些事件發送消息給不同的用戶。基本上我有一個API給我直播的事件。一些用戶將訂閱這些事件。我的任務是在發生這種事件時向這些用戶發送消息。我試圖用Python設計系統。目前我有以下問題。如何從Python中的直播api持續查詢事件。如何找出哪些用戶訂閱了該特定事件。（Redis或Mysql）如何向所有特定事件的用戶發送通知。（Pub/sub）我想使

8熱度

1回答

更新Rails視圖與Faye從數據庫更改（after_commit回調）在型號

我非常困惑，這是我的第一個Faye或Pub/Sub實現，所以請原諒我，如果這是一個基本問題。我還沒有在其他地方找到答案。任何幫助表示讚賞。如何從模型回調（after_commit，after_save等）調用和更新Rails視圖頁？我需要一個javascript代碼，在after_commit回調觸發後，視圖更新從views/meetings/_show_current_participants

0熱度

1回答

Kafka關於消費羣體的問題

我是卡夫卡的新手。我瀏覽了Kafka文檔。看起來分派給訂閱用戶組的消息是通過將分區與消費者實例綁定來實現的。當我們與Apache卡夫卡的工作，我們應該記住一個重要的事情是消費者的同一消費羣體的數量應小於或等於消耗的主題分區的數量。否則，超出的消費者將不會收到該主題的任何消息。在非生產環境中，我沒有配置主題分區。在這種情況下，卡夫卡是否只有一個分區？如果我啓動了多個共享相同組的消費者並訂閱它們到

1熱度

1回答

使用Express-GraphQL和React-Apollo的GraphQL訂閱

我已經遵循Apollo的文檔來設置客戶端和服務器上的GraphQL訂閱，雖然我90％在那裏，但我無法弄清楚如何設置訂閱渠道以及如何將突變連接到這些渠道，以便每當發生突變時，服務器就會將新數據推送到客戶端。（關於內容，我正在製作一個Reddit克隆，人們發佈主題和其他人發表評論，所以當你看到「主題」或「主題列表」時，將這些視爲帖子。）到目前爲止，我已經設置了阿波羅客戶端訂閱成功： const w

0熱度

2回答

帶有zmq的pub-sub的動態主題，那會好嗎？

我讀過我的文檔大多數例子都是基本用例。只需一個進程發佈X事件，另一個進程訂閱X事件。但在我的應用程序中，X是一種變量。所以我們可以說我的X代表我的用戶。所以我可以做一個像user-ID這樣的服務器事件發佈意味着如果我有1000個用戶連接到服務器，那麼可以發佈和訂閱這麼多的動態主題，然後另外20個服務器訂閱這1000個這個服務器上的主題。讓我們看看這個例子。我有10臺服務器。每個服務器連接

0熱度

2回答

內部Web應用程序：我需要一個API嗎？

我正在創建一個新的Web應用程序，用於與內部數據一起工作的內部應用程序，並且一直在探索技術堆棧選項。我已經用了另一個內部Web應用程序（也使用SQL Server內部數據）一個REST API，但後來我讀到這在今天Meteorpedia 一個常見的問題是如何創建一個流星REST API。首先，瞭解如果您爲自己的應用程序和工具製作API，那就錯了！我們希望非常清楚的是，在服務器和客戶端之間，您有一個

1熱度

1回答

爲什麼不Meteor.subscribe從發佈

我對本出版物 Meteor.publish('user', function(id){ if(id == this.userId) { return Meteor.users.find({_id: id}, {fields: {dob: 1, name: 1, ability: 1, location: 1, clubs: 1, coach: 1, friends: 1}})

0熱度

1回答

ActiveMQ - 僅發佈有興趣訂戶的數據的策略？

我有一個消息代理，各個客戶將在短時間內連接一天。該券商維持可在其上發佈的價格爲成千上萬的事情，但在任何給定的時間設定的當前連接的客戶端將只關心這些事情的一小部分的話題。在一個緊密耦合的系統中，客戶端會明確地訂閱特定的東西，服務器會跟蹤低級客戶端連接/斷開連接事件（自動取消訂閱斷開連接的客戶端）並且只發布客戶訂閱的東西的價格。什麼是在消息系統一樣的ActiveMQ更加鬆散耦合世界處理這種事情的

3熱度

3回答

實時聊天

我想開發與渠道實時聊天，這些都是我的需求： PHP後臺管理網站 Redis作爲會話和數據主存儲器發佈/訂閱將郵件僅發送給頻道的感興趣用戶一個WebSocket連接，用於發送和接收郵件。（可選）要的NodeJS使用大NPM包，比如時間同步或socket.io 我看到兩種不同的架構來實現這一目標：與Socket.io 與Crossbar.io 這是我的問題：哪個架構，我應該選擇？爲什麼？關