NServiceBus 消息重播存档架构

Question

我正在构建一个应用程序，需要保留其发送的消息的副本，以便我可以在稍后阶段重播所有消息。这是必要的，因为消息的处理在开发过程中会发生巨大变化，但数据必须尽快捕获，因为它是实时观察数据。我似乎找不到任何内置功能可以直接解决这个问题，虽然我可以编写一个自定义工具来保存数据，但这似乎与首先使用 NServiceBus 的目的相矛盾。我正在考虑的一些选项：

1. 使用目标总线的 ForwardReceivedMessagesTo 功能来创建存档队列，并构建一个简单的应用程序，该应用程序使用此存档队列作为输入队列，以便在重播工具运行时将消息简单地转发到目标总线运行。这确实会清除存档队列，要求首先使用 mqbkup 实用程序对其进行备份，但这可以作为重播过程的一部分自动进行。或者，使用两个交替的存档队列（一个接收新消息，一个用于重播）可以解决此问题。

2. 使用发布/订阅模型并让存档器订阅目标队列，将消息放入存档队列中。与上述类似的 Replayer 工具可以使用 Archive 队列作为输入队列，并将消息转发到 Target。这也会清除存档队列，需要上述解决方案之一。

3. MassTransit 人员提到了一个名为 BusDriver 的东西，它允许在之间进行复制排队，但我找不到更多相关信息。

我主要关心的是选择最不可能丢失数据的方法，因为一旦进行观察，就不可能在狭窄的时间窗口之外再次进行观察。这似乎应该是一个常见问题，但我似乎无法找到直接的解决方案。建议？

更新 我决定使用日志目标队列。我将让归档器使用日志作为输入并将消息存储到数据库（可以只是基于文件），并允许将消息从该数据库重播到目标队列。虽然可以编写一个工具将消息从日志队列复制到目标队列，但从实际角度来看，真正的问题是管理日志队列：它无法轻松备份（mqbkup 会导致日志队列崩溃） MSMQ 服务，这是不可接受的），并且当我宁愿坚持 NServiceBus 抽象级别时，在队列上进行非破坏性操作需要我编写一个基于 MSMQ 的工具。最终，MSMQ 是一种传输而不是消息存储，因此需要将其视为消息存储。

Answer 1

第一个选择似乎可行。我想补充一点，NSB 附带了一个名为 ReturnToSourceQueue.exe 的工具，它将为您重播消息。您可以打开日记功能来保留消息，但由于它不滚动，因此必须进行清理。我们有 NetApp，并且使用其 SnapMirror 来备份队列数据，我确信也有类似的东西。

Answer 2

#3 BusDriver 命令行参考：

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.)