带有文件系统观察器的 NServicebus

Question

我希望我的端点在检测到特定文件夹中的文件被删除时发送一个事件。我能够通过使用实现 IWantToRunWhenBusStartsAndStops 的类来使其工作，该类又设置了 FileSystemWatcher 来监视给定的文件夹。我的问题是，这是使用 nservicebus 解决此问题的最佳方式，还是我遗漏了一些可能会给我带来麻烦的东西？

这是我的代码：

public class FileSystem : IWantToRunWhenBusStartsAndStops
{
    private FileSystemWatcher watcher;

    public void Start()
    {
        ConfigFileWatcher();
    }

    public void Stop()
    {

    }

    [PermissionSet(SecurityAction.Demand, Name = "FullTrust")]
    private void ConfigFileWatcher()
    {
        watcher = new FileSystemWatcher();
        watcher.Path = @"c:\";
        /* Watch for changes in LastAccess and LastWrite times, and
           the renaming of files or directories. */
        watcher.NotifyFilter = NotifyFilters.LastAccess | NotifyFilters.LastWrite
           | NotifyFilters.FileName | NotifyFilters.DirectoryName;
        // Only watch text files.
        watcher.Filter = "*.txt";

        // Add event handlers.
        watcher.Changed += new FileSystemEventHandler(OnChanged);
        watcher.Created += new FileSystemEventHandler(OnChanged);
        watcher.Deleted += new FileSystemEventHandler(OnChanged);

        // Begin watching.
        watcher.EnableRaisingEvents = true;
    }

    // Define the event handlers. 
    private static void OnChanged(object source, FileSystemEventArgs e)
    {
        // Specify what is done when a file is changed, created, or deleted.
        Console.WriteLine("File: " + e.FullPath + " " + e.ChangeType);

        // fire off an event here...
    }

}

Answer 1

根据其他答案和 cmets，我相信您的 FileSystemWatcher 通过订阅 OnChanged 事件而保持活动状态。

这实际上是（相当）常见的内存泄漏原因，尽管在您的情况下，它实际上将您的观察者保留在内存中并允许它继续运行。从您的 OnChanged() 方法中删除 static 关键字，我相信您会看到您所期望的行为。

当然，您希望 FileSystemWatcher 继续运行。 . .一种选择可能是将观察者变量本身设为静态。如果你走那条路，我会把它放在一个单独的类中，然后通过实现 IWantToRunWhenBusStartsAndStops 的类对其进行初始化。

Answer 2

如果你看NServiceBus源码，在容器初始化中，你会看到IWantToRunWhenBusStartsAndStops注册了一个每次调用的生命周期

ForAllTypes<IWantToRunWhenBusStartsAndStops>(TypesToScan, t => configurer.ConfigureComponent(t, DependencyLifecycle.InstancePerCall));

这意味着该类将在 Start() 被调用后被释放。您的实现有效，因为您的事件订阅了静态处理程序，该处理程序使订阅保持活动状态。

我们在生产中使用文件观察器，但我们将它们烘焙为高级卫星。卫星保证被初始化为单例并且不会被丢弃。它们也有 Start 和 Stop 方法。他们确实有地址并且应该能够处理传入的消息，但是您可以使用一些虚拟地址并且在处理程序中什么也不做，除非您想让您的文件系统观察程序卫星双向（即接收消息并将它们作为文件放在磁盘上）。

在 NServiceBus 中，建议将持续运行的非一次性进程设置为卫星。许多 NServiceBus 组件被制成卫星。

您可能会对如何自己制造卫星感到好奇，但这很容易做到。可以查看接口签名here。

它看起来像这样

using System;
using System.IO;
using NServiceBus;
using NServiceBus.Satellites;

public class FileSystem : ISatellite
{
    private FileSystemWatcher _watcher;

    public bool Handle(TransportMessage message)
    {
        return true;
    }

    public void Start()
    {
        _watcher = new FileSystemWatcher
        {
            Path = @"c:\",
            NotifyFilter = NotifyFilters.LastAccess |    NotifyFilters.LastWrite
                           | NotifyFilters.FileName | NotifyFilters.DirectoryName,
            Filter = "*.txt"
        };
        _watcher.Changed += OnChanged;
        _watcher.Created += OnChanged;
        _watcher.Deleted += OnChanged;
        _watcher.EnableRaisingEvents = true;
    }

    public void Stop()
    {
        _watcher.Dispose();
    }

    public Address InputAddress
    {
        get { return Address.Parse("FileSystemSatellite"); }
    }

    public bool Disabled
    {
        get { return false; }
    }

    // Define the event handlers. 
    private void OnChanged(object source, FileSystemEventArgs e)
    {
        // Specify what is done when a file is changed, created, or    deleted.
        Console.WriteLine("File: " + e.FullPath + " " + e.ChangeType);

        // fire off an event here...
    }
}

您需要记住一件事：每颗卫星都有自己的队列。在这种情况下，它将始终为空。