我一直在尝试构建一个WCF流传输的示例，仅用于测试目的，但我无法确定它是否实际进行了流传输。
这个示例非常基本：
- 服务器返回大型二进制内容（在本例中为PDF文件）
- 客户端将大型二进制内容写入文件。
然而，问题似乎是尽管我认为我已经正确地配置了服务器和客户端以进行流传输：
- 它似乎并不是实际的流传输，因为我遇到了
IOException，其消息为已超过传入消息的最大消息大小配额（65536） - 即使我将流缓冲区设置为8192（或任何其他大小），读取也是按1536字节的增量进行的
完整的主机代码在此处：
using System;
using System.IO;
using System.ServiceModel;
using System.ServiceModel.Description;
namespace WcfStreamingHost
{
internal class Program
{
private static void Main(string[] args)
{
BasicHttpBinding binding = new BasicHttpBinding();
binding.TransferMode = TransferMode.Streamed;
binding.MaxBufferSize = 65536;
binding.MaxReceivedMessageSize = 65536;
binding.ReaderQuotas.MaxBytesPerRead = 65536;
binding.SendTimeout = TimeSpan.FromMinutes(10);
ServiceHost host = new ServiceHost(typeof (ContentProvider), new Uri("http://charles-m4600:1234/contentprovider"));
host.Description.Behaviors.Add(new ServiceMetadataBehavior());
host.Description.Behaviors.Find<ServiceDebugBehavior>().IncludeExceptionDetailInFaults = true;
host.AddServiceEndpoint(typeof (IMetadataExchange), MetadataExchangeBindings.CreateMexHttpBinding(), "mex");
host.AddServiceEndpoint(typeof (IContentProvider), binding, "streamed");
host.Open();
Console.ReadKey();
}
}
[ServiceBehavior(InstanceContextMode = InstanceContextMode.PerCall, ConcurrencyMode = ConcurrencyMode.Single)]
public class ContentProvider : IContentProvider
{
#region IContentProvider Members
[OperationBehavior(AutoDisposeParameters = true)]
public Stream GetFile()
{
Stream stream = File.OpenRead("large_file.pdf");
return stream;
}
#endregion
}
[ServiceContract]
public interface IContentProvider
{
[OperationContract]
Stream GetFile();
}
}
完整的客户端代码在这里：
using System;
using System.IO;
using System.ServiceModel;
using WcfStreamingClient.LocalSvc;
namespace WcfStreamingClient
{
internal class Program
{
private static void Main(string[] args)
{
BasicHttpBinding binding = new BasicHttpBinding();
binding.TransferMode = TransferMode.Streamed;
binding.MaxBufferSize = 65536;
binding.MaxReceivedMessageSize = 65536;
binding.ReaderQuotas.MaxBytesPerRead = 65536;
binding.ReceiveTimeout = TimeSpan.FromMinutes(10);
EndpointAddress address = new EndpointAddress("http://charles-m4600:1234/contentprovider/streamed");
using (ContentProviderClient client = new ContentProviderClient(binding, address))
{
using (Stream stream = client.GetFile())
{
FileInfo file = new FileInfo("output.pdf");
if (file.Exists)
{
file.Delete();
}
using (FileStream fileStream = file.Create())
{
const int bufferLen = 8192;
byte[] buffer = new byte[bufferLen];
int count = 0;
int total = 0;
while ((count = stream.Read(buffer, 0, bufferLen)) > 0)
{
fileStream.Write(buffer, 0, count);
total += count;
Console.Out.WriteLine("Read {0} bytes", total);
}
}
}
}
}
}
}
我已经阅读了其他关于这个问题的帖子，但似乎找不到任何线索。