messaging

0熱度

1回答

Google雲應用引擎（python）：從device1接收帖子併發送帖子到設備2

我有一個Google Cloud項目，包含一個SQL數據庫和Python 2.7中的App Engine。瞭解我所做的是從RaspberryPi向App Engine發送帖子並將數據保存到雲中。與此同時，RasPi能夠從雲端或App引擎接收數據，這要歸功於代碼：self.response.write（jsondata）。這工作正常。現在我在系統中引入了一個新設備，我將調用Raspi2。 Ras

2熱度

3回答

如何使ZeroMQ超時排出隊列，但尚未在設定時間內發送的消息？

我有一個應用程序運行在服務器上，它接受來自電話應用程序的請求，然後在工作服務器上負載平衡請求。我試圖添加一個超時的情況下，主服務器上的出站隊列中的超時時間長度的消息從隊列中刪除。更具體地說，主服務器上的應用程序是用golang編寫的，並實現了負載均衡的Paranoid Pirate Pattern。我公司目前擁有的代碼是： import ( "fmt" zmq "github.c

-1熱度

1回答

郵件路由基於規則

我正在尋找一個符合以下情形的Java服務器技術：客戶端X發送消息 - >某些服務器組件決定的基礎上，例如某些規則if message from client X and content equals Y, forward message to Client Z (or a group of clients)。客戶端Z（或讀取該消息的組中的第一個）確認消息並採取進一步的（物理）操作。消息應該可

0熱度

1回答

消息管理器破壞

我正在嘗試編寫一個簡單的消息管理器，但是沒有任何消息顯示在我的隊列中。調用它的代碼是： //initialize message manager CJournal.Journal(Main.class, "Initializing message manager"); MessageManager messageManager = new MessageManager();

0熱度

2回答

NATS發佈者可以將單個消息發送到多個隊列嗎？

我正在構建一個系統，兩個不同的實體需要處理來自同一個源的消息（以不同的方式 - 例如，一個會記錄所有消息，而另一個實體可能需要聚合數據）。理想情況下，每個實體對於性能和彈性都是完全可擴展的，因此我們有多個發佈者，多個日誌訂閱者和多個聚合訂閱者，但每個發佈的每個消息仍然由一個日誌訂閱者和一個聚合訂閱者處理。通過AMQP，我們可以通過發佈到扇出交換機來實現此目的，該交換機將消息分發到兩個隊列，其中每

0熱度

1回答

Masstransit + RabbitMQ。在兩種不同的消息類型之間共享一個隊列

我有一個發佈者，它將消息發佈到rabbitmq：// localhost/test123隊列。一條消息具有TestMessage類型，另一條是TestMessage2類型。出版商配置： sbc.UseRabbitMq(r => r.ConfigureHost(new MessageUrn("rabbitmq://localhost/test123"), c => { })); sbc.UseL

1熱度

1回答

AMQP | RabbitMQ |爲什麼他們有Fanout交換時，可以通過直接交換實現同樣的路由密鑰的多個隊列？

AMQP/RabbitMQ的新手。試圖理解這些概念/原理，並且偶然發現了這一點。以下兩種範例有什麼區別？扇出交換： FanoutExchange - >隊列1（路由鍵1），隊列2（路由鍵1）， VS 直接交換： DirectExchange - >隊列1（路由Key 1），Queue2（Routing Key 1），兩者都不能達到相同的效果嗎？如果不是的話，請問有人能說明它是如何不同的，以

0熱度

1回答

在使用Sendbird的網站中實現聊天

首先我想道歉，如果這是一個不適當的問題，但我有一個網站，我需要實現聊天，並計劃使用sendbird。事情是，我不完全是一個專業人士，我已經看過他們的JavaScript文檔和git上看到的樣品，但我不知道要使用哪一個，即使我做我不知道如何將它集成我現有的項目。我會很感激在正確的方向輕輕推動，博客文章，視頻或任何有助於。

0熱度

2回答

akka是否自發地向自定義演員發送自己的消息？

我創建了一些演員，它應該用自己的消息包裝所有傳入的消息並進一步轉發它們。不幸的是，我沒有任何用戶消息的公共基類，所以我打算用Object.class來捕捉它們。現在我不確定阿卡是否可以將自己的消息發送給演員。我不想偶爾轉發一些發給我的封裝演員的系統消息。

0熱度

2回答

有了Spring Cloud Stream，我應該爲每種事件類型配置頻道嗎？

我正在使用springboot，spring cloud netflix等構建一個項目來構建微服務。對於一些異步通信，我使用Spring Cloud Stream來生成和使用事件。例如在合同服務中起草商業合同後，服務會發佈一個合同創建事件，由審計服務使用，以啓動審計過程。此外，用戶服務將消耗該事件來爲相關方創建通知。該場景是我有很多事件，消費者將根據事件類型訂閱感興趣的事件。我遇到的問題是，