messaging

0熱度

1回答

我想在角2做消息，但我有一個問題。我的問題是：如何處理接收到的消息列表時自動刷新當另一個用戶給我發送消息？（現在我必須刷新頁面才能擁有它）。也許我可以使用Observable，但是如何？謝謝你的幫忙！

0熱度

1回答

我有2個JMS隊列，我的應用程序可以根據收到請求的節點將消息發佈到任何一個隊列。 Pentaho應該積極地看待這兩個隊列，並且應該能夠在消息到達隊列中的任何一個時立即進行處理。目前，我已經實現了一項工作來主動偵聽一個隊列並處理該消息併發布相同的響應。如何配置pentaho以同時主動偵聽兩個隊列，並在任何隊列發佈消息時執行相同的操作？編輯我不知道Pentaho提供此類內部服務通信的任何此類直接

0熱度

1回答

訂閱一羣使用RabbitMQ的消費者？

我不能完全肯定這是提出正確的地方，但我對的RabbitMQ的運作問題，實現發佈/訂閱消息系統。我調查的RabbitMQ，看它是否適合我工作的公司的需要，我找不到任何回答這些問題無論是在官方文檔或在互聯網上：是否有可能爲一消費者訂閱一組發佈者？我想這是可能的，如果我們想要訂閱的所有發佈者都將他們的消息發送給交換機，然後將它們轉發給訂閱者。執行此操作最適合的呼氣類型是什麼？是否可以訂閱一組主題？例

1熱度

1回答

卡夫卡生產者配額

這裏是我們的物聯網平臺的入站郵件傳遞流程： Device ---(MQTT)---> RabbitMQ Broker ---(AMQP)---> Apache Storm ---> Kafka 我期待實現解決方案，有效地限制/節流數據以每個發佈到卡夫卡每秒量客戶基礎。當前的策略利用Guava的RateLimiter，每個設備都有自己的本地緩存實例。當接收到設備消息時，映射到該deviceId

0熱度

2回答

是否有意義使用Apache卡夫卡對於這種情況？

有幾個應用程序必須集成在一起，他們必須交換問題。所以他們中的一個會解決問題，然後做一些事情，然後改變這個問題的狀態。其他可能涉及此問題的應用程序應該獲得新的信息。這一直持續到問題達到最終狀態結束。問題是必須映射問題，因爲這些應用程序並不都支持相同的數據格式。我不知道是否總是發送整個問題還是隻發送新狀態作爲事件。卡夫卡如何支持數據轉換？如果我的問題有一個附件？（> 5MB）謝謝你的建議

0熱度

1回答

RabbitMQ同步消息傳遞的優缺點

因爲我們都知道像rabbitMQ這樣的消息總線主要用於異步消息傳遞，因此標準接近是在公共汽車上發佈和發佈消息，而不用擔心誰會處理髮布的消息或何時。但是我正在考慮我們的開發團隊中有關消息同步處理的最新討論：情況是將消息發佈到服務總線，並且作爲發佈者，我想等待任何訂閱者處理消息並將結果返回給我 - 因此它看起來像而是作爲請求 - 響應模型。我現在正在考慮一個類似於這個模型中性能下降的問題。你怎麼看？何

3熱度

1回答

Microsoft.ServiceBus.Messaging與Microsoft.Azure.ServiceBus

MS最近推出了Microsoft.Azure.ServiceBus命名空間。 https://github.com/Azure/azure-service-bus/blob/master/samples/readme.md 它非常適合新.NET標準框架（好像MS沒有足夠的半冗餘代碼基地）我的問題是，如何更好地難道是在條款的表現？我可以有把握地說，Microsoft.ServiceBus.Mes

-1熱度

1回答

ArtemisMQ - 在基於點對點的集羣中工作嗎？

我需要寫關於ArtemisMQ的快速評論。有一點考慮ArtemisMQ在集羣中的體系結構。根據文檔（或者我理解這點），節點獨立工作 - 每個節點都可以被發現，然後在彼此之間創建一些核心橋接。這似乎是P2P。我對嗎？

0熱度

2回答

Microsoft.Azure.ServiceBus .net標準 - 如何批量接收

我期待將使用Microsoft.ServiceBus的一些工作遷移到Microsoft.Azure.ServiceBus。這是爲了我們可以瞄準.net標準。以前的代碼使用ReceiveBatchAsync爲了在一次調用中檢索多個消息。在新的命名空間中我看不到一種方法。設計中是否有新的東西使得這個冗餘，還是1.0.0發佈版本只部分完成？最佳實踐指南似乎指向Microsoft.ServiceB

-1熱度

1回答

使用REST API和消息傳遞的微服務

將微服務暴露給網關的公共REST API並通過消息傳遞與其他服務通信可以嗎？