C# 中的共享文件夹连接数过多问题

Question

我正在尝试将多个文件复制到共享文件夹（大约 20 个），但每个文件同时位于不同的线程上。

我正在使用这样的代码来复制文件

AppDomain.CurrentDomain.SetPrincipalPolicy(PrincipalPolicy.WindowsPrincipal);    
WindowsIdentity identity = new WindowsIdentity(username, password);
WindowsImpersonationContext context = identity.Impersonate();

try
{
    File.Copy(@"c:\temp\MyFile.txt", @"\\server\folder\Myfile.txt", true);
}
catch
{
    context.Undo();
}

，但有些文件没有被复制，我得到的错误如下：

“No se pueden realizar más conexiones a este Equipment remoto en este momento, ya que hay más de las que puede aceptar”

翻译过来会是这样的

“此时无法与此远程计算机建立更多连接，因为它可以接受更多连接”

是否有其他方法将文件复制到共享文件夹或显式关闭连接？

Answer 1

Windows 工作站对其可以同时接受的网络连接数量有限制。

您可以：

• 使用少于 20 个连接
• 使用不同的文件复制协议，尽管随后您将遇到网络套接字数量的限制
• 切换到使用没有此类限制的服务器操作系统

Answer 2

尝试通过同一线程复制文件。我确信每个连接只有一个线程可以让服务器达到其极限。

Answer 3

Windows 客户端操作系统受限于它们可以接受的并发连接数。即使这是服务器系统，Windows 文件共享也允许管理员限制共享的连接数量。

您可能想要做的是将自己限制为几个并发线程（3 到 5 个就可以了）。将所有文件名放入队列中，并让每个线程将下一个要处理的文件出队（使用适当的锁定），直到队列为空。这称为生产者/消费者方案。作为奖励，您最终可能会获得比同时执行所有 20 个操作更多的吞吐量，因为系统不必花更少的时间担心网络冲突和上下文切换。

Answer 4

请记住，IO 速度几乎始终是瓶颈，因此您最好将一次传输限制为 1 或 2 个文件。您可能会固定磁盘读取或网络吞吐量。最好的选择是从 1 个线程开始测量性能，并寻求传输速度和线程之间的平衡。

Answer 5

问题是每个线程都在建立自己的连接。如果您运行的线程数量多于目标计算机可以接受的数量，您将遇到此问题。您需要找到一种方法来确保不超过此限制。

有什么理由需要多线程吗？我确信答案是“是”，但万一您认为多线程将通过允许同时发生多个复制操作来加速复制操作，但事实并非如此。 bamdwidth 的大小只有这么多，并且目标 PC 只能以特定的速度读取/写入，因此通过尝试在多个线程写入多个文件，您实际上只会单独减慢每个文件的速度。

但是，如果我猜对了，并且多线程还有另一个原因，那么让我提供一种替代方案：在本地写入文件并使用完全不同的进程复制文件。拥有一个可以复制文件的 Windows 服务或控制台应用程序，而您的 UI 线程和其他线程则继续工作。添加中间人可能会增加一些额外的复杂性，但这仍然比试图找到一种方法来解决这个问题要简单。

另一种方法是必须跟踪线程，并确保线程数永远不会超过目标机器上可用的连接数，并且您必须担心连接到该机器的其他进程，因此您无法真正计算也采用这种方法。

跟踪线程并正确锁定当然是可行的，但简单地在本地写入文件并让外部程序进行文件传输更容易编写，并且更容易排除故障。

Answer 6

另一种选择是使用网络驱动器 - 检查是否存在，并在必要时进行映射。映射和取消映射驱动器的代码可以在我的答案中找到：

映射驱动器后，无论线程如何，您的代码都应该使用相同的连接。我们在 Web 服务调用中使用它，从本质上讲，它是多线程的，并且它是一项使用率很高的服务，在高峰时段每分钟复制数百个文件。我相对确定它适用于你的情况。

C# - 从 Web 服务映射网络驱动器

检查是否驱动器已映射，只需调用

if (System.IO.Directory.Exists(<drive letter here>));

编辑 - 添加代码以连接和断开网络驱动器

public static class NetworkDrives
    {
        public static bool  MapDrive(string DriveLetter, string Path, string Username, string Password)
        {

            bool ReturnValue = false;

            if(System.IO.Directory.Exists(DriveLetter + ":\\"))
            {
                DisconnectDrive(DriveLetter);
            }
            System.Diagnostics.Process p = new System.Diagnostics.Process();
            p.StartInfo.UseShellExecute = false;
            p.StartInfo.CreateNoWindow = true;
            p.StartInfo.RedirectStandardError = true;
            p.StartInfo.RedirectStandardOutput = true;

            p.StartInfo.FileName = "net.exe";
            p.StartInfo.Arguments = " use " + DriveLetter + ": " + Path + " " + Password + " /user:" + Username;
            p.Start();
            p.WaitForExit();

            string ErrorMessage = p.StandardError.ReadToEnd();
            string OuputMessage = p.StandardOutput.ReadToEnd();
            if (ErrorMessage.Length > 0)
            {
                throw new Exception("Error:" + ErrorMessage);
            }
            else
            {
                ReturnValue = true;
            }
            return ReturnValue;
        }
        public static bool DisconnectDrive(string DriveLetter)
        {
            bool ReturnValue = false;
            System.Diagnostics.Process p = new System.Diagnostics.Process();
            p.StartInfo.UseShellExecute = false;
            p.StartInfo.CreateNoWindow = true;
            p.StartInfo.RedirectStandardError = true;
            p.StartInfo.RedirectStandardOutput = true;

            p.StartInfo.FileName = "net.exe";
            p.StartInfo.Arguments = " use " + DriveLetter + ": /DELETE";
            p.Start();
            p.WaitForExit();

            string ErrorMessage = p.StandardError.ReadToEnd();
            string OuputMessage = p.StandardOutput.ReadToEnd();
            if (ErrorMessage.Length > 0)
            {
                throw new Exception("Error:" + ErrorMessage);
            }
            else
            {
                ReturnValue = true;
            }
            return ReturnValue;
        }

    }