NServiceBus消息重播存檔體系結構

Question

我構建的應用程序需要保留它發送的消息的副本，以便我可以在以後階段重播所有消息。這是必要的，因爲在開發過程中消息的處理將發生顯着變化，但是數據必須儘快捕獲，因爲它是實時觀測數據。我似乎無法找到任何直接解決此問題的內置功能，而我可以編寫自定義工具來保存數據，這似乎與首先使用NServiceBus的目的相矛盾。有些選項我考慮：

1. 使用目標總線創建歸檔隊列，並建立使用這種歸檔隊列作爲輸入隊列簡單地將消息轉發到目標總線的簡單應用程序的ForwardReceivedMessagesTo功能只要Replayer工具運行。這會清除存檔隊列，要求先使用mqbkup實用程序先備份它，但這可以作爲重放過程的一部分自動執行。或者，使用兩個交替存檔隊列（一個接收新消息，另一個接收重放）可以解決這個問題。

2. 使用發佈/訂閱模型並讓Archiver訂閱目標隊列，將郵件放入存檔隊列中。與上面類似的Replayer工具可以使用Archive隊列作爲輸入隊列並將消息轉發給目標。這也將清除存檔隊列，需要上述解決方案之一。

3. MassTransit人員提到了一種叫做BusDriver的東西，它允許在隊列之間進行復制，但我找不到任何關於它的更多信息。

我最關心的是選擇是最不容易丟失數據，因爲一旦觀察是由它永遠不會被一個狹窄的時間窗口之外再提出的辦法。這似乎應該是一個普遍的問題，但我似乎無法找到一個簡單的解決方案。建議？

更新我已決定使用已記錄的目標隊列。我將讓Archiver使用日誌作爲輸入並將消息存儲到數據庫（可能只是基於文件），並允許將數據庫中的消息重播到目標隊列。儘管可以編寫一個將日誌隊列中的消息複製到目標隊列的工具，但從實際角度來看，真正的問題是管理日誌隊列：它無法輕鬆備份（mqbkup降低MSMQ服務，這是不可接受的），並且在隊列上非破壞性地運行需要我編寫基於MSMQ的工具，而我寧願堅持NServiceBus抽象級別。最終，MSMQ是一種傳輸方式，而不是一種消息存儲方式，因此需要將其作爲一種處理方式。

Answer 1

第一個選項似乎可行。我會補充說，NSB帶有一個名爲ReturnToSourceQueue.exe的工具，可以爲你回放消息。你可以啓用日誌來保留消息，但是由於不會滾動，所以有些東西需要清理。我們有NetApp，並且我們已經使用它的SnapMirror來備份隊列數據，我相信這裏有類似的東西。

Answer 2

＃3佈德裏弗命令行參考：

BusDriver is a command-line utility used to administer queues, service bus instances and other things related to MassTransit. 

Command-Line Reference 

    busdriver.exe [verb] [-option:value] [--switch] 

    help, --help  Displays help 

    count    Counts the number of messages in the specified 
         queue 

     -uri    The URI of the queue 

    peek    Displays the body of messages in the queue without 
         removing the messages 

     -uri    The URI of the queue 
     -count   The number of messages to display 

    move    Move messages from one queue to another 

     -from    The URI of the source queue 
     -to    The URI of the destination queue 
     -count   The number of messages to move 

    requeue    Requeue messages from one queue to another 

     -uri    The URI of the queue 
     -count   The number of messages to move 

    save    Save messages from a queue to a set of files 

     -uri    The URI of the source queue 
     -file    The name of the file to write to (will have .1, .2 
         appended automatically for each message) 
     -count   The number of messages to save 
     --remove   If set, the messages will be removed from the queue 

    load    Load messages from a set of files into a queue 

     -uri    The URI of the destination queue 
     -file    The name of the file to read from (will have .1, .2 
         appended automatically for each message) 
     -count   The number of messages to load 
     --remove   If set, the message file will be removed once the 
         message has been loaded 

    trace    Request a trace of messages that have been received 
         by a service bus 

     -uri    The URI of the control bus for the service bus 
         instance 
     -count   The number of messages to request 

     status   Request a status probe of the bus at the endpoint 

      -uri   The URI of the control bus for the service bus instance 

    exit, quit   Exit the interactive console (run without arguments 
         to start the interactive console) 

Examples: 

    count -uri:msmq://localhost/mt_server 
     Returns the number of messages that are present in the local 
     MSMQ private queue named "mt_server" 

    peek -uri:msmq://localhost/mt_client 
     Displays the body of the first message present in the local 
     MSMQ private queue named "mt_client" 

    trace -uri:msmq://localhost/mt_subscriptions 
     Requests and displays a trace of the last 100 messages received 
     by the mt_subscriptions (the default queue name used by the 
     subscription service, which is part of the RuntimeServices) 

    move -from:msmq://localhost/mt_server_error -to:msmq://localhost/mt_server 
     Moves one message from the mt_server_error queue to the mt_server 
     queue (typically done to reprocess a message that was previously 
     moved to the error queue due to a processing error, etc.)