message-queue

0熱度

1回答

假設有一個ActiveMq實例，並且有100個客戶端正在監聽主題。當在主題中發佈新消息時，是否可以限制接收它的訂閱者數量（僅示例10）？如果現在有其他消息傳遞組件能夠做到這一點，或者存在解決方案/合併最佳實踐？

2熱度

2回答

我想了解如何動態地向外擴展應用程序，它消耗的話題（可惜我不能減少其數量 - 通過設計每個主題是特定類型的數據）的數量龐大。我想我的應用集羣從所有的200個多種主題分擔負載。例如，當一個新的應用程序節點添加到集羣中時，它應該從舊節點「偷走」一些主題訂閱，這樣負載將再次均勻分佈。據我瞭解，卡夫卡partinions /消費羣體幫助並行的話題，不共享多個主題之間的負載。

1熱度

1回答

爲什麼我的信號處理程序不僅僅是等待子進程？

我的代碼是一個多進程併發服務器進程，它使用系統V消息隊列與客戶端進程進行通信，一個客戶端與一個子進程通信。第一個我希望等待子進程不再使用。當我設置SIGCHLD處理程序與SIG_IGN，程序可以正常工作，但總是錯誤，當我趕上SIGCHLD，錯誤是客戶端進程阻塞在mesrcv系統調用，這意味着服務器不會發送消息給客戶端。秒,當我輸入^ \來退出我的客戶端進程時，服務器進程終止，我使它成爲一個守護

0熱度

1回答

正在尋找消耗MDB消息來自遠程隊列的MDB當前示例10

我有一個定義隊列的Wildfly 10實例，發佈到該隊列以及通過MDB從該隊列接收消息。這已經完成了。現在我想添加第二個Wildfly 10實例，在另一臺機器上運行，它也將接收來自第一個實例中定義的相同（遠程）隊列的消息。我花了2天尋找當前如何做到這一點的例子。有很多問題和一些過時的答案。它似乎是從Q實現中期望的最微不足道的事情之一，但我找不到任何示例。有人請向我介紹一個好的和當前的例

0熱度

1回答

使用消息隊列的線程同步不是爲了

以下代碼是從Raymond's Pycon keynotes on cuncurrency，很棒的演示。這是一個有點長，所以我會用這個問題開始：如果消息加到一起到隊列，以前被認爲是一個線程中完成的，怎麼來的，他們都應該打印打印爛漫？在線程初始化之間添加一個100ms的延遲解決了這個問題，輸出和預期的一樣。 - import Queue, time counter_queue = Queue.

0熱度

1回答

如何從REST通信到消息隊列

REST Microservice如何與另一個混合的Microservice進行通信，這意味着他可以與REST和Message Queue進行通信。例如一個API網關。對於外部世界，他可以通過REST與應用程序，手機進行通信，但是來自後端的通信是通過消息隊列進行的。使用案例：我的主頁想要從數據庫中獲得車輛。他通過GET-Request請求API網關。 API網關接受GET請求並將其發佈到消息隊

1熱度

1回答

想要在同一個RabbitMQ隊列上運行多個使用者

我在後端有一個RabbitMQ應用程序。所以我想開發自定義的第三方分析代碼，它連接RabbitMQ上的應用程序隊列並收集數據。所以我的問題是我想確保應用程序和我的代碼不會從rabbitmq中丟失任何數據。如果可能的話，我該如何配置RabbitMQ隊列？我有RabbitMQ的管理權限。我希望，因爲我沒有訪問做應用程序代碼它不是生產問題的代碼感謝您的幫助

0熱度

1回答

混淆Masstransit ReceiveFrom方法和消費者行爲

我想創建一個隊列與RabbitMq在哪裏我會發送一些消息在一邊，並在另一個應用程序接收。我'與下面的代碼這樣做： return ServiceBusFactory.New(x => { var uriString = string.Format(@"rabbitmq://{0}/{1}/{2}?prefetch={3}", host, virtualHost, queue

1熱度

1回答

如何在Masstransit/RabbitMQ中組織隊列？

我想知道消費消息的最佳實踐。我已經閱讀了MassTransit文檔，並且正在尋找這方面的內容，但是我沒有得出任何結論。我有一個api（託管公交車實例），正在發佈消息。這些消息是多種多樣的，因爲這個API不是微服務（購買，銷售等的消息）。如何組織我的消費者/隊列？一個隊列類型的過程？例如，一個用於購買，另一個用於銷售，這個解決方案可能涉及許多流程，我不確定它是否是一個好的解決方案。如果我想購買

0熱度

1回答

進程間通信的最佳途徑是什麼？

嗨我要在.net中開發應用程序。它是.net核心。這是網絡應用程序。我有一個進程在同一臺機器上運行。這是用c編程編寫的。我想在我的.net應用程序和進程之間進行雙向通信。那麼哪種機制非常適合？像我將在Linux環境中託管我的.net應用程序的要求，並且過程也在Linux環境中運行。我經歷了命名管道，消息隊列等。按照我的要求，這將是一個好的解決方案？在這方面可以有人幫助我嗎？任何幫助將不勝感激。謝謝