-1

背景

我有一个服务器，它有一个\\Server\Share包含 4 个子文件夹的共享文件夹：

  • 出站决赛
  • 出站暂存
  • 入站决赛
  • 入站暂存

所有文件夹都驻留在同一个物理磁盘和分区上，不使用连接点。

我还有几个 WinForms 客户端（最多 10 个）向这个共享写入和读取文件，每个客户端都在多个线程上工作（最多 5 个）。文件由客户端（总共最多 50 个线程）写入\\Server\Share\OutboundStaging文件夹。每个文件都有一个 GUID 的名称，因此不会被覆盖。一旦文件被完全写入，它就会被客户端移动到\\Server\Share\OutboundFinal文件夹中。在同一台服务器上运行的 Windows 服务会将其拾取、删除、处理，然后将具有相同名称的文件写入文件\\Server\Share\InboundStaging夹。一旦文件被完全写入，它就会被\\Server\Share\InboundFinal服务移动到该文件夹​​中。

此 \\Server\Share\InboundFinal 文件夹由每个 WinForms 客户端的每个线程FileSystemWatcher.WaitForChanged(WatcherChangeTypes.Changed | WatcherChangeTypes.Created, timeOut); 使用FileSystemWatcher.Filter直到文件夹中显示特定文件。

我已经阅读了几个关于FileSystemWatcher行为不正常和不报告 UNC 股票变化的 SO 问题。然而，这对我来说不是这样。

我使用的代码如下所示：

    FileSystemWatcher fileWatcher = new FileSystemWatcher();
    fileWatcher.Path = InboundFinalFolder;
    fileWatcher.Filter = GUIDFileName; // contains full UNC path AND the file name
    fileWatcher.EnableRaisingEvents = true;
    fileWatcher.IncludeSubdirectories = false;
    var res = fileWatcher.WaitForChanged(WatcherChangeTypes.Changed | WatcherChangeTypes.Created, timeOut);
    if (!fileWatcher.TimedOut)
    {
        using (FileStream stream = fi.Open(FileMode.Open, FileAccess.Read, FileShare.Read)) {
        byte[] res = new byte[stream.Length];
        stream.Read(res, 0, stream.Length);
        return res;
    }

这是抛出异常的使用行。

问题

我会假设 fileWatcher.WaitForChanged 只有在具有正确 GUID 名称的文件位于\\Server\Share\InboundFinal文件夹中时才会继续。这正是 FileSystemWatcher 在本地文件夹上的工作方式，但不适用于通过网络访问的文件共享（本地文件，即使通过共享访问，也倾向于工作）。FileSystemWatcher 报告线程正在等待的文件在 FileSystemWatcher\\Server\Share\InboundFinal文件夹中。但是，当我尝试读取文件时，我得到了 FileNotFoundException。读取线程必须等待 3-15 秒才能读取文件。我尝试使用带有Read共享的 FileStream 打开文件。

什么可能导致这种行为？我该如何解决它？理想情况下，FileSystemWatcher.WaitForChanged(WatcherChangeTypes.Changed | WatcherChangeTypes.Created, timeOut);只有在可以读取文件或发生超时时才应继续执行。

4

1 回答 1

0

FileSystemWatcher 名声不好，但实际上，它并没有那么糟糕......

1.)

您的代码示例无法编译。我试过这个：

 FileSystemWatcher fileWatcher = new FileSystemWatcher();
 fileWatcher.Path = "X:\\temp";
 fileWatcher.Filter = "test.txt";
 fileWatcher.EnableRaisingEvents = true;
 fileWatcher.IncludeSubdirectories = false;

 var res = fileWatcher.WaitForChanged(WatcherChangeTypes.Changed |
                                 WatcherChangeTypes.Created, 20000);
 if (!res.TimedOut)
 {
     FileInfo fi = new FileInfo(Path.Combine(fileWatcher.Path, res.Name));

     using (FileStream stream = fi.Open(FileMode.Open, FileAccess.Read, FileShare.Read))
     {
         byte[] buf = new byte[stream.Length];

         stream.Read(buf, 0, (int)stream.Length);
     }

     Console.WriteLine("read ok");
 }
 else
 {
     Console.WriteLine("time out");
 }

我对此进行了测试，其中 X: 是 SMB 共享。它没有问题（对我来说，见下文）。

但：

您应该通过重试打开/读取文件（每次打开失败后休眠 100 毫秒）。这是因为您可能会遇到 FileSystemWatcher 检测到文件，但移动（或其他写入操作）尚未结束的情况，因此您必须等到文件创建/移动器真正准备好。

或者您不等待“真实”文件，而是等待文件移动任务在关闭“真实”文件后创建的标志文件。

2.)

难道是移动任务没有正确关闭文件？

3.)

几年前，我有一些工具（用 perl 编写），其中一个脚本创建了一个标志文件，另一个脚本等待它。

我在 SMB 2 共享上遇到了一些令人讨厌的问题。我发现这是由于 SMB 缓存。

看

https://bogner.sh/2014/10/how-to-disable-smb-client-side-caching/

尝试打开位于 win2k8 共享上的文件时，文件打开最初失败，但最终可以成功

https://technet.microsoft.com/en-us/library/ff686200.aspx

试试这个（在客户端）：

Windows Registry Editor Version 5.00

[HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\services\LanmanWorkstation\Parameters]

"DirectoryCacheLifetime"=dword:00000000
"FileNotFoundCacheLifetime"=dword:00000000

将此保存为 disablecache.reg 并运行 regedit disablecache.reg

然后重新启动。

于 2017-11-18T20:16:21.497 回答