データベースからクライアントへのストリーミング応答としてデータを返すWCF-Webを設定しようとしています。このメソッドは現在45.000アイテムを返します。
私の問題は、このメソッドを数回呼び出そうとすると、一部のリクエストが成功し、次の呼び出しがTimeoutExceptionで終了することです。これは、クライアントがホストへの新しい接続を確立できないようです。TransferModeを「Buffered」に変更すると、意図したとおりに機能します。
System.Net.ServicePointManager.DefaultConnectionLimitをより大きな数値に増やすことで、正常に処理される呼び出しの量を増やすことができます。
クライアントが接続を閉じていないように私には思えますか?しかし、なぜStreamedResponseモードのみなのですか?どこが間違っているのですか?何か案が?
ソース:
public static void DoCall() {
var factory = new ChannelFactory<ICacheService>("ICacheService", new EndpointAddress(...));
ICacheService service = factory.CreateChannel();
try
{
var itemsMessage = service.DoStreaming(
Message.CreateMessage(MessageVersion.Soap11, "DoStreaming", "SomeArgumnt")
);
foreach (Item item in GetAllItems(itemsMessage))
{
...
}
var serviceChannel = ((IServiceChannel) service);
if (serviceChannel.State != System.ServiceModel.CommunicationState.Faulted)
serviceChannel.Close();
itemsMessage.Close();
((IServiceChannel)service).Close();
}
catch (Exception ex)
{
((IServiceChannel) service).Abort();
}
factory.Close();
}
private static IEnumerable<Item> GetAllItems(System.ServiceModel.Channels.Message message)
{
XmlReader reader = message.GetReaderAtBodyContents();
if (reader.LocalName != "results")
{
throw new Exception("The service returned an invalid message");
}
XmlSerializer serializer = new XmlSerializer(typeof(Item));
reader.ReadStartElement("results");
while (!reader.EOF && reader.LocalName == "Item")
{
yield return (Item)serializer.Deserialize(reader);
}
reader.ReadEndElement();
}
クライアントバインディング:
<binding
name="BasicHttpBinding_ICacheService"
openTimeout="00:01:00"
receiveTimeout="00:01:00"
sendTimeout="00:10:00"
maxReceivedMessageSize="1000000000"
transferMode="Buffered"
>
<readerQuotas
maxDepth="2147483647"
maxStringContentLength="2147483646"
maxArrayLength="2147483647"
maxBytesPerRead="2147483647"
maxNameTableCharCount="2147483647"
/>
<security mode="None">
<transport clientCredentialType="None" proxyCredentialType="None" realm="" />
<message clientCredentialType="UserName" algorithmSuite="Default" />
</security>
</binding>