c# - 让 IIS 托管 WCF 服务中的流式传输正常工作

标签 c# wcf iis azure

我有点被困在这里......

我的目标非常简单:我想公开一个 IIS 托管(然后是 Windows Azure)的 WCF 服务，通过该服务我可以使用流式传输来上传文件，并添加一些有关我要上传的文件的 META 数据(文件名、MD5) -散列所有常用的东西...)，并能够显示有关上传的准确进度信息。

首先，我创建了一个派生类StreamWithProgress，它继承自FileStream，其中我重写了Read方法来引发事件每次阅读我都会传递进度信息。

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

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

和 httpRuntime 设置如下:

IIS\ASP 兼容性设置如下:

并按照以下方式禁用批处理:

我创建了一个自托管服务，通过该服务上传成功。 然后我将其“升级”为 IIS 托管服务(在我的本地计算机上)，效果很好。 然后，我使用 WCF webrole 创建了一个本地托管的 Windows Azure 服务，该服务有效。

但问题是，在任何情况下都没有发生实际的流传输……所有这些都在发送数据之前缓冲了数据。

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

我的实际代码如下。

有什么想法\帮助吗？ 任何事情都会受到极大的赞赏......

谢谢!

服务器 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>

服务契约(Contract):

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();
        }
    }
}

客户端应用程序配置:

<?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 中对此的修复:|

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

谢谢!!

最佳答案

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

构建文件上传/下载服务的推荐解决方案是使用 REST。在.NET平台上构建REST服务的方法之一是使用ASP.NET Web API:http://www.asp.net/web-api 。使用这个API，我们不需要处理流传输模式。我们需要处理的是 Range header 。这篇博文可能会有所帮助: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 Controller 作为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获取示例。

最诚挚的问候，

徐明。

关于c# - 让 IIS 托管 WCF 服务中的流式传输正常工作，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/10225229/

上一篇：c# - 线程池 - 限制对某些方法的调用

下一篇：c# - 在 C#4.0 中创建并关闭 Excel 文件后，Excel 仍在任务管理器中运行

相关文章：

wcf - 在 Web 场环境中使用共享缓存来检测 WCF 中的重放攻击

wcf - WCF : How to handle errors when calling another WCF service?

c# - 尝试从 Windows 服务读取 IIS 站点的 web.config 文件

c# - 网页访问问题

c# - Web.config iis url重写

c# - 从一个流复制到另一个？

c# - 在 .net 核心中安全地释放依赖注入(inject)的 wcf 客户端

c# - List<string> 上的 Dapper sql 查询内部连接

c# - .RowFilter 与 "IN"和 "NOT IN"

windows-services - Msmq 和 WCF 服务

©2024 IT工具网  联系我们