masstransit

0熱度

1回答

我有一個使用webgardens的webfarm，我希望在從其他進程引發事件時通知每個進程，此事件主要用於更新內部緩存，例如，如果進程更新「客戶」所有其他進程應該得到通知。每個進程創建一個總線與RabbitMQ，然後我設置一個名爲隨機的終端，我註冊我的消費者，這似乎工作，無論如何，在一天結束時，我發現裏面有很多死兔隊，流程。我試圖使用臨時隊列來達到這個目的，但我不知道如何將事件發佈到總線上並讓

6熱度

1回答

MassTransit中處理程序和消費者之間的區別

MassTransit中處理程序和消費者之間有什麼區別？我已經看過使用其中一個或另一個的例子，但從概念上講，我不清楚兩者之間的區別以及爲什麼要選擇其中一個。

3熱度

1回答

MassTransit與SQL Server數據庫傳輸

對於我的客戶，我們正在研究MassTransit的使用。 MassTransit似乎集中在RabbitMQ的消息傳輸上。由於客戶端的「內部結構約束」，我們堅持使用SQL Server數據庫作爲任何持久性。 MassTransport如何與SQL Server一起用作消息的傳輸機制？

0熱度

1回答

HandlerExtensions.ConnectHandle ConnectHandler <T>（）方法的用途是什麼？

xmlDoc中指出：添加一個消息處理程序服務總線處理消息的特定類型但它並不需要端點名稱。它如何工作？我嘗試了這種方法，但沒有發生任何事。在總線運行時動態添加處理程序有沒有可能？

0熱度

1回答

消費者的生命週期是什麼？

消息使用者在總線啓動時或者每當相應類型的消息出現在端點上時僅創建一次？我的意思是訂閱消息的這個方法： cfg.ReceiveEndpoint(host, "customer_update_queue", e => { e.Consumer<UpdateCustomerConsumer>(); });

0熱度

2回答

MassTransit快速入門App不起作用

我在學習MassTransit。我已經通過NuGet安裝了MassTransit.RabbitMQ 3.3.5版。我已經安裝了Erlang 18.0 *和RabbitMQ 3.6.3（* Erlang版本19.0對RabbitMQ 3.6.3不穩定）。我發現了一個「快速入門」的MassTransit程序here，並修正了一點點typeo後，讓它編譯。但是，當我執行該程序時，發佈的消息「YourMe

0熱度

1回答

使用MassTransit讓消費者脫機（計劃中斷）

我有許多服務器，每個服務器運行一個服務的單個實例/偵聽相同的隊列/端點（有意！）會產生Competing Consumer模式。該解決方案非常棒，因爲它提供了負載平衡和高可用性，並且非常適合我的使用情況。然而，我希望能夠實現的是能夠使各個節點脫機的方式而沒有任何影響。換句話說，一種能夠告訴節點完成對已經收到的任何消息的處理，但不消耗任何消息的方式（而不是僅僅關閉服務並且不得不管理終止任何正在處

2熱度

1回答

MassTransit傳奇與預取運行> 1

我有一個MassTransit傳奇狀態機（從Automatonymous.MassTransitStateMachine派生），我試圖解決一個問題，只有當我將端點配置prefetchCount設置爲大於1 問題在於'StartupCompletedEvent'已發佈，然後在saga狀態被持久保存到數據庫之前立即處理。狀態機的配置如下： State(() => Initialising); St

0熱度

1回答

使用C＃和MassTransit進行文件處理

我已閱讀了很多關於MassTransit並進行了實驗的文章。但是我有一個我不知道MassTransit適合與否的場景。如果有熟悉MT的人會在這件事上爲我提供建議，我將不勝感激。 1-我必須處理具有5種不同佈局或數據結構的CSV文件。 2-每個文件可能有一百萬行。 3-行應按順序處理（FIFO）。因爲順序很重要。 4-一條生產線由多個步驟組成，如從DB獲取相關信息，檢查，計算，分析和保存到DB。 5

1熱度

1回答

隊列可以用於MassTransit與RabbitMQ的持續

文檔狀態： control queues are exclusive and auto-delete - they go away when you go away and are not shared. 我在這裏的後果還不清楚;在我的系統中，我需要隊列是持久的，並且消息要持久。如果我需要降低消費者流程（例如更新）或者需要重新啓動服務器（對於Windows補丁，比如說），我希望現有的隊列不會丟失任