Я пытаюсь создать потоковый сервис WCF.Я создал службу, которая, по моему мнению, должна поддерживать потоковые ответы (как проект приложения-службы WCF в VS), и клиент, который является просто проектом консольного приложения, в который я добавил службу в качестве ссылки на службу.Код работает, когда я устанавливаю режим передачи в клиенте в Buffered, но если я изменяю его на StreamedResponse, я получаю поток, который имеет только около 1500 байт данных вместо 33k, которые я получаю, когда использую режим буферизованной передачи.
Вот важные части моего кода:
Интерфейс
namespace Microsoft.Samples.Stream
{
[ServiceContract(Namespace = "http://Microsoft.Samples.Stream")]
public interface IStreamingSample
{
[OperationContract]
System.IO.Stream GetStream(string data);
}
}
Класс, реализующий интерфейс
namespace Microsoft.Samples.Stream
{
public class StreamingService : IStreamingSample
{
public System.IO.Stream GetStream(string data)
{
try
{
FileStream imageFile = File.OpenRead("e:/image.jpg");
return imageFile;
}
catch (IOException ex)
{
throw ex;
}
}
}
}
Web.config в обслуживании:
<?xml version="1.0"?>
<configuration>
<system.web>
<compilation debug="true" targetFramework="4.0" />
</system.web>
<system.serviceModel>
<services>
<service name="Microsoft.Samples.Stream.StreamingService">
<endpoint address="ep1" binding="basicHttpBinding" contract="Microsoft.Samples.Stream.IStreamingSample"/>
<endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange"/>
</service>
</services>
<bindings>
<basicHttpBinding>
<binding maxReceivedMessageSize="67108864" transferMode="StreamedResponse" />
</basicHttpBinding>
</bindings>
<behaviors>
<serviceBehaviors>
<behavior>
<serviceMetadata httpGetEnabled="True"/>
<serviceDebug includeExceptionDetailInFaults="False"/>
</behavior>
</serviceBehaviors>
</behaviors>
</system.serviceModel>
<system.webServer>
<modules runAllManagedModulesForAllRequests="true"/>
</system.webServer>
</configuration>
app.config в клиенте:
<?xml version="1.0" encoding="utf-8" ?>
<configuration>
<system.serviceModel>
<bindings>
<basicHttpBinding>
<binding name="BasicHttpBinding_IStreamingSample" 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="Text" textEncoding="utf-8" transferMode="StreamedResponse"
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:56881/StreamingService.svc/ep1"
binding="basicHttpBinding" bindingConfiguration="BasicHttpBinding_IStreamingSample"
contract="ServiceReference1.IStreamingSample" name="BasicHttpBinding_IStreamingSample" />
</client>
</system.serviceModel>
</configuration>