【问题标题】:Sending files over TCP/ .NET SSLStream is slow/not working通过 TCP/.NET SSLStream 发送文件很慢/不起作用
【发布时间】:2012-09-10 17:39:14
【问题描述】:

我正在编写一个与 SSL 一起工作的服务器/客户端应用程序(通过SSLStream),它必须做很多事情(不仅仅是文件接收/发送)。目前,它是这样工作的:只有一个连接。我总是使用SSLStream.WriteLine() 从客户端/服务器发送数据并使用SSLStream.ReadLine() 接收数据,因为我可以通过一个连接发送所有信息,并且可以从所有线程发送而不会破坏数据。

现在我想实现文件发送和接收。与我的客户端/服务器应用程序中的其他内容一样,每条消息都有一个前缀(如 cl_files 或 sth)和一个 base64 编码的内容部分(前缀和内容由 | 分隔)。我实现了这样的文件共享:上传者向接收者发送一条关于文件总大小的消息,然后上传者通过前缀 r 发送文件的 base64 编码部分。

我的问题是文件共享真的很慢。我从 localhost 到 localhost 的速度约为 20KB/s。我还有另一个问题。如果我增加文件的 base64 编码部分的大小(这使文件共享更快),前缀 r 不会再发送给接收器(因此无法识别数据)。

我怎样才能让它更快?

任何帮助将不胜感激。

我的(可能是坏的)代码是给客户的:

//its running inside a Thread
FileInfo x = new FileInfo(ThreadInfos.Path);
long size = x.Length; //gets total size
long cursize = 0;
FileStream fs = new FileStream(ThreadInfos.Path, FileMode.Open);
Int16 readblocks = default(Int16);
while (cursize < size) {
    byte[] buffer = new byte[4096];
    readblocks = fs.Read(buffer, 0, 4096);
    ServerConnector.send("r", getBase64FromBytes(buffer));//It sends the encoded Data with the prefix r over SSLStream.WriteLine
    cursize = cursize + Convert.ToInt64(readblocks);
    ThreadInfos.wait.setvalue((csize / size) * 100);//outputs value to the gui
}
fs.Close();

对于服务器:

case "r"://switch case for prefixes
           if (isreceiving)
           {
              byte[] buffer = getBytesFromBase64(splited[1]);//splited ist the received Line over ReadLine splitted by the seperator "|"
              rsize = rsize + buffer.LongLength;
              writer.Write(buffer, 0, buffer.Length);//it writes the decoded data into the file
              if (rsize == rtotalsize)//checks if file is completed
              {
                 writer.Close();
              }
           }
break;

【问题讨论】:

  • 你能读出大于 4096 的块吗?您的文件平均有多大?
  • 我用 8000 试了一下,有些消息被破坏了,用 2048 也试了一下,它可以工作,但速度很慢。平均而言,文件大小为 500kb-10mb
  • 每当我必须发送消息时,我会将大小设置为非常大(百兆),并让底层 TCP 流为您处理流量控制。你可以添加你的 getBytesFromBase64 函数吗?那是你写的自定义吗?尝试暂时删除它并发送纯字节,看看是否可以改善它。
  • getBytesFromBase64 只不过是return System.Convert.FromBase64String(input); 明天我会尝试删除 Base64,但是如何通过 Stream.ReadLine() 发送字节数组?
  • 当您将某些内容转换为 base 64 时,ReadLine 是如何工作的? \n 字符是否得到 base-64 编码。我担心如果 base-64 编码偶然放入 \n ,ReadLine 可能读取的数据太少。例如,如果您发送“hamburger\n”并变成“3df232\n42sdf”(我只是编造的),这可能吗?

标签: c# .net tcp sslstream


【解决方案1】:

您的问题源于您正在通过文本协议执行本质上是二进制操作的事实,并且您通过加密通道执行此操作会加剧该问题。我不会为你重新发明这个,但这里有一些选择......

  1. 考虑转换为 HTTPS 客户端/服务器模型,而不是重新发明轮子。这将为您提供一个定义明确的文件 PUT/GET 操作模型。

  2. 如果您不能(或不会)转换为 HTTPS,请考虑为二进制数据提供安全传输和明确定义的协议的其他客户端/服务器库。例如,我经常使用protobuf-csharp-portprotobuf-csharp-rpc 在我们的数据中心或本地网络中提供安全协议和传输。

  3. 如果您坚持使用原始 SslStream 进行传输,请尝试使用定义明确且经过验证的二进制序列化框架,例如 protobuf-csharp-portprotobuf-net 来定义您的协议。

  4. 最后,如果您必须继续使用已有的框架,请尝试一些类似 http 的技巧。将名称/值对编写为定义随后的原始二进制内容的文本。

【讨论】:

  • 因为它是垃圾软件,我想用我现有的框架来制作它。知道我可以在不中断其他通信的情况下直接发送字节而不是 base64 吗?
【解决方案2】:

首先 base64 over ssl 无论如何都会很慢,ssl 本身比原始传输要慢。现在文件传输不是通过base64完成的,http协议比其他任何协议都稳定得多,所有平台上的大多数库都非常稳定。 Base64 占用比实际数据更大的大小,加上编码时间。

此外,您的以下行可能有问题。

ThreadInfos.wait.setvalue((csize / size) * 100);//outputs value to the gui

如果您的这条线被阻塞,那么每 4kb 就会变慢。每 4kb 更新也是不对的,除非进度值与之前的值相差很大,否则不需要为它更新 ui。

【讨论】:

    【解决方案3】:

    我会在网络之前/之后尝试 gzip 压缩。根据我的经验,它有帮助。我想说一些这样的代码可能会有所帮助:

    using(GZipStream stream = new GZipStream(sslStream, CompressionMode.Compress)) 
    {
        stream.Write(...);
        stream.Flush();
        stream.Close();
    }
    

    警告:如果 Flush 未完成,它可能会干扰 SSL。它需要一些测试......我没有尝试编译代码。

    【讨论】:

      【解决方案4】:

      我认为 Akash Kava 是对的。

      while (cursize < size) {
          DateTime start = DateTime.Now;
          byte[] buffer = new byte[4096];
          readblocks = fs.Read(buffer, 0, 4096);
          ServerConnector.send("r", getBase64FromBytes(buffer));
          DateTime end = DateTime.Now;
          Console.Writline((end-start).TotalSeconds);
          cursize = cursize + Convert.ToInt64(readblocks);
          ThreadInfos.wait.setvalue((csize / size) * 100);
          end = DateTime.Now;
          Console.Writline((end-start).TotalSeconds);
      }
      

      通过这样做,您可以找出瓶颈在哪里。

      您向服务器发送数据包的方式也不可靠。

      是否可以粘贴您的实现

      ThreadInfos.wait.setvalue((csize / size) * 100);

      【讨论】:

        猜你喜欢
        • 1970-01-01
        • 2016-02-17
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        • 2014-09-03
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        相关资源
        最近更新 更多