4

我有点卡在这里...

我的目标很简单：我想公开一个 IIS 托管（然后是 Windows Azure）WCF 服务，通过它我可以使用流式传输文件上传文件，并添加一些关于我要上传的文件的 META 数据（文件名、MD5-hash all通常的东西...），并能够显示有关上传的准确进度信息。

首先，我创建了一个继承自FileStream的派生类StreamWithProgress，我在其中重写了Read方法，以在每次读取时引发一个事件，通过该事件传递进度信息。

其次，我使用MessageContract ( http://msdn.microsoft.com/en-us/library/ms730255.aspx ) 创建了一个 WCF 服务，将 META 数据和流对象包装到一个 SOAP 信封中。这个服务真的很简单，只公开一个上传方法。

我已将所有缓冲区大小设置为接受大量数据，如下所示：

和 httpRuntime 设置如下：

IIS\ASP 兼容性设置如下：

并按以下方式禁用批处理：

我创建了一个自托管服务，通过该服务上传成功。然后我将它“升级”到一个IIS 托管服务（在我的本地机器上），它可以工作。然后我创建了一个本地托管的 Windows Azure 服务，它带有一个 WCF webrole，它可以工作。

但问题是，在所有实例中都没有发生实际的流式传输……所有这些实例都在发送数据之前对其进行了缓冲。

当我看到我的客户端正在报告进度时，我遇到了这个问题，但是服务器直到整个文件被缓冲后才开始写入文件。

我的实际代码如下。

任何想法\帮助？任何事情都将不胜感激……</p>

谢谢！

服务器 web.config：

<?xml version="1.0"?>
<configuration>
    <system.serviceModel>

        <bindings>
            <basicHttpBinding>
                <binding name="uploadBasicHttpBinding" 
                 maxReceivedMessageSize="2147483647" 
                 transferMode="Streamed" 
                 messageEncoding="Mtom"
                 maxBufferPoolSize="2147483647"
                 maxBufferSize="2147483647">
                 <readerQuotas maxArrayLength="2147483647" 
                                maxBytesPerRead="2147483647" 
                                maxDepth="2147483647" 
                                maxNameTableCharCount="2147483647" 
                                maxStringContentLength="2147483647"/>
                </binding>
            </basicHttpBinding>
        </bindings>

            <behaviors>
                <serviceBehaviors>
                    <behavior name="defaultBehavior">
                        <serviceMetadata httpGetEnabled="true"/>
                        <serviceDebug includeExceptionDetailInFaults="false"/>
                        <dataContractSerializer maxItemsInObjectGraph="2147483647"/>
                    </behavior>
                </serviceBehaviors>
            </behaviors>

        <!-- Add this for BufferOutput setting -->
        <serviceHostingEnvironment multipleSiteBindingsEnabled="true" aspNetCompatibilityEnabled="true"/>

        <services>
            <service name="WcfService1.Service1" behaviorConfiguration="defaultBehavior">           
                <endpoint binding="basicHttpBinding" contract="WcfService1.IService1" bindingConfiguration="uploadBasicHttpBinding"/>
                <endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange"/>
            </service>
        </services>

    </system.serviceModel>

    <system.webServer>
        <modules runAllManagedModulesForAllRequests="true"/>
    </system.webServer>

    <system.web>
        <compilation debug="true"/>
    <httpRuntime maxRequestLength="2147483647" />
    </system.web>

</configuration>

服务合同：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.Serialization;
using System.ServiceModel;
using System.ServiceModel.Web;
using System.Text;
using System.IO;

namespace WcfService1
{
    [ServiceContract]
    public interface IService1
    {
        [OperationContract(IsOneWay=true)]
        void UploadStream(Encapsulator data);
    }
}

实际服务：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.Serialization;
using System.ServiceModel;
using System.ServiceModel.Web;
using System.Text;

using System.IO;
using System.Web;
using System.ServiceModel.Activation;

namespace WcfService1
{
    [MessageContract]
    public class Encapsulator
    {
        [MessageHeader(MustUnderstand = true)]
        public string fileName;
        [MessageBodyMember(Order = 1)]
        public Stream requestStream;
    }

    [AspNetCompatibilityRequirements(RequirementsMode = AspNetCompatibilityRequirementsMode.Allowed)]
    public class Service1 : IService1
    {
        public Service1()
        {
            HttpContext context = HttpContext.Current;

            if (context != null)
            {
                context.Response.BufferOutput = false;
            }
        }

        public void UploadStream(Encapsulator data)
        {
            const int BUFFER_SIZE = 1024;

            int bytesRead = 0;

            byte[] dataRead = new byte[BUFFER_SIZE];

            string filePath = Path.Combine(@"C:\MiscTestFolder", data.fileName);

            string logPath = Path.Combine(@"C:\MiscTestFolder", string.Concat(data.fileName, ".log"));

            bytesRead = data.requestStream.Read(dataRead, 0, BUFFER_SIZE);

            StreamWriter logStreamWriter = new StreamWriter(logPath);

            using (System.IO.FileStream fileStream = new System.IO.FileStream(filePath, FileMode.Create))
            {
                while (bytesRead > 0)
                {
                    fileStream.Write(dataRead, 0, bytesRead);
                    fileStream.Flush();

                    logStreamWriter.WriteLine("Flushed {0} bytes", bytesRead.ToString());
                    logStreamWriter.Flush();

                    bytesRead = data.requestStream.Read(dataRead, 0, BUFFER_SIZE);
                }

                fileStream.Close();
            }

            logStreamWriter.Close();
        }
    }
}

客户端 app.config：

<?xml version="1.0"?>
<configuration>
    <system.serviceModel>

        <bindings>
            <basicHttpBinding>
                <binding name="BasicHttpBinding_IService1" closeTimeout="00:01:00"
                    openTimeout="00:01:00" receiveTimeout="00:10:00" sendTimeout="00:01:00"
                    allowCookies="false" bypassProxyOnLocal="false" hostNameComparisonMode="StrongWildcard"
                    maxBufferSize="65536" maxBufferPoolSize="524288" maxReceivedMessageSize="65536"
                    messageEncoding="Mtom" textEncoding="utf-8" transferMode="Streamed"
                    useDefaultWebProxy="true">
                    <readerQuotas maxDepth="32" maxStringContentLength="8192" maxArrayLength="16384"
                        maxBytesPerRead="4096" maxNameTableCharCount="16384" />
                    <security mode="None">
                        <transport clientCredentialType="None" proxyCredentialType="None"
                            realm="" />
                        <message clientCredentialType="UserName" algorithmSuite="Default" />
                    </security>
                </binding>
            </basicHttpBinding>
        </bindings>

        <client>
            <endpoint address="http://localhost/WcfService1/Service1.svc"
                binding="basicHttpBinding" bindingConfiguration="BasicHttpBinding_IService1"
                contract="UploadService.IService1" name="BasicHttpBinding_IService1" />
        </client>

    </system.serviceModel>

    <startup>
        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.0"/>
    </startup>
</configuration>

客户端主要代码：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

using CustomFileUploaderTester.UploadService;
using System.ServiceModel;
using System.IO;

namespace CustomFileUploaderTester
{
    class Program
    {
        private static long bytesRead = 0;

        static void Main(string[] args)
        {
            Service1Client client = new Service1Client();

            using (StreamWithProgress fstream = new StreamWithProgress(@"C:\BladieBla\someFile.wmv", FileMode.Open))
            {
                client.InnerChannel.AllowOutputBatching = false;

                fstream.ProgressChange += new EventHandler<StreamReadProgress>(fstream_ProgressChange);

                client.UploadStream("someFile.wmv", fstream);

                fstream.Close();
            }

            Console.ReadKey();
        }

        static void fstream_ProgressChange(object sender, StreamReadProgress e)
        {
            bytesRead += e.BytesRead;

            Console.WriteLine(bytesRead.ToString());
        }
    }
}

派生的 FileStream 类 ( StreamWithProgress )

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;

namespace CustomFileUploaderTester
{
    public class StreamReadProgress : EventArgs
    {
        #region Public Properties

        public long BytesRead
        {
            get;
            set;
        }

        public long Length
        {
            get;
            set;
        }

        #endregion

        #region Constructor

        public StreamReadProgress(long bytesRead, long fileLength)
            : base()
        {
            this.BytesRead = bytesRead;

            this.Length = fileLength;
        }

        #endregion
    }

    public sealed class StreamWithProgress : FileStream
    {
        #region Public Events

        public event EventHandler<StreamReadProgress> ProgressChange;

        #endregion

        #region Constructor

        public StreamWithProgress(string filePath, FileMode fileMode)
            : base(filePath, fileMode)
        {
        }

        #endregion

        #region Overrides

        public override int Read(byte[] array, int offset, int count)
        {
            int bytesRead = base.Read(array, offset, count);

            this.RaiseProgressChanged(bytesRead);

            return bytesRead;
        }

        #endregion

        #region Private Worker Methods

        private void RaiseProgressChanged(long bytesRead)
        {
            EventHandler<StreamReadProgress> progressChange = this.ProgressChange;

            if (progressChange != null)
            {
                progressChange(this, new StreamReadProgress(bytesRead, this.Length));
            }
        }


        #endregion
    }
}

-- 更新：2012-04-20

在我安装了一个环回适配器之后，我用 RawCap 跟踪了通信，发现数据实际上是流式传输的，但是 IIS 服务器在调用 web 方法之前正在缓冲所有数据！

根据这篇文章：

http://social.msdn.microsoft.com/Forums/is/wcf/thread/cfe625b2-1890-471b-a4bd-94373daedd39

这是 WCF 继承的 ASP.Net 行为......但他们正在谈论在 .Net 4.5 中对此的修复：|

如果有人有任何其他建议，那就太好了！

谢谢！！

4

2 回答 2

3

经过一些严格的测试，我看到数据实际上是流式传输的。我将该[MessageContract]属性应用于 Encapsulator 类（根据http://msdn.microsoft.com/en-us/library/ms733742.aspx），这使我能够发送一些关于文件的额外元数据。使用 WireShark 和 RawCap 很明显，在读取 Stream 时数据是通过网络发送的。

另一个让他头疼的问题是，在实际调用上传方法之前，正在流式传输的数据是在服务器端缓冲的（使用 IIS 7.5）！这有点令人担忧，但据此：http ://social.msdn.microsoft.com/Forums/is/wcf/thread/cfe625b2-1890-471b-a4bd-94373daedd39 应该在 4.5 .Net 发布

于 2012-04-24T14:02:40.457 回答
3

您将 Mtom 与流传输模式一起使用。这可能会导致问题。请尝试删除 Mtom。实际上，无论如何，Mtom 是一个非常古老的标准。另外，当使用流传输模式的 SOAP 服务时，我们只能有一个类型为 Stream 的参数。我们不能使用像 Encapsulator 这样的自定义类型。

构建文件上传/下载服务的推荐解决方案是使用 REST。在 .NET 平台上构建 REST 服务的方法之一是使用 ASP.NET Web API：http ://www.asp.net/web-api 。使用这个API，我们不需要处理流传输模式。我们需要处理的是 Range 标头。这篇博文可能会有所帮助：http: //blogs.msdn.com/b/codefx/archive/2012/02/23/more-about-rest-file-upload-download-service-with-asp-net-web- api-and-windows-phone-background-file-transfer.aspx. 但也请注意，此 API 尚未发布。如果你不想使用预发布的产品，你可以使用其他技术，例如，你可以使用 MVC 控制器作为 REST 服务，或者使用 WCF REST 服务，或者构建一个自定义的 http 处理程序等。如果你想要要使用 Stream，需要自定义流。我建议您查看 http://blogs.msdn.com/b/james_osbornes_blog/archive/2011/06/10/streaming-with-wcf-part-1-custom-stream-implementation.aspx以获取示例.

此致，

明旭。

于 2012-04-20T07:30:49.573 回答