Jak przerwać strumień z usługi WCF bez czytania do końca?

Question

Jest to problem, który badałem w zeszłym tygodniu i nie mogę znaleźć rozwiązania. Znaleziono posty z prośbą o to samo, ale nigdy nie otrzymuję odpowiedzi, mam nadzieję, że to pomoże także innym.

Mam usługę WCF, która zwraca obiekt zawierający w środku stream. Używam basicHttpBinding z przesyłaniem strumieniowym i Mtom, aby wysłać je do klienta.

Klient wywołuje usługę WCF i zamyka serwer proxy natychmiast po otrzymaniu obiektu odpowiedzi.

Następnie klient odczytuje strumień pobrany z usługi WCF i zapisuje go w pliku na dysku lokalnym. Wszystko to działa dobrze.

Mój problem polega na tym, że klient chce przerwać operację i przestać pobierać dane z usługi WCF. Jeśli wywołam .close() w strumieniu, np .: serverReply.DataStream.Close();, to blokuje i odczytuje cały strumień z usługi WCF do końca przed kontynuowaniem. Strumień może być dość duży, a sieć nie zawsze jest szybka.

Jest to bardzo niepożądane w przypadku wykorzystania zasobów sieciowych, które są w zasadzie marnowane na dane, które już nie są potrzebne. A ponieważ basicHttpBinding zezwala tylko na dwa równoczesne połączenia TCP (domyślnie) z serwerem usługi WCF, blokuje inne próby połączenia, dopóki strumień nie zostanie odczytany do końca.

Mogłabym zwiększyć liczbę jednoczesnych połączeń, ale byłoby to złe rozwiązanie, ponieważ spowodowałoby to kłopot.

Na przykład 20 przerwanych pobrań, które wciąż pobierają dane, aby je wyrzucić. Muszę sprawić, żeby transfer całkowicie się zatrzymał.

Na kliencie obiekt strumieniowy jest zwykłą klasą Stream, więc zawiera tylko metodę ścisłą, nic więcej.

Wywołanie .close() lub na obiekcie proxy nie pomaga, ani nie niszczy go za pomocą .dispose() lub jakiejkolwiek innej metody. Po stronie serwera obsługuję zdarzenie OperationContext.OperationCompleted, ale nie jest ono wywoływane, dopóki dane z stream nie zostaną odczytane do końca.

Pytanie brzmi: jak zamknąć/przerwać transmisję bez jej całkowitego przeczytania?

Answer 1

Czy próbowałeś już grać z ?
Czy próbowali zabawy ze swoimi app.config ustawień pliku np:

<bindings> 
    <wsHttpBinding> 
    <binding name="default" maxReceivedMessageSize="2147483647" maxBufferPoolSize="2147483647" 
      closeTimeout="00:01:00" openTimeout="00:01:00" receiveTimeout="00:10:00" sendTimeout="00:01:00" > 
     <readerQuotas maxArrayLength="2147483647" maxBytesPerRead="4096" maxNameTableCharCount="16384" 
        maxDepth="64" maxStringContentLength="2147483647" /> 
    </binding> 

    </wsHttpBinding> 
</bindings> 

chciałbym zminimalizować timeoutów ANF długości bufora i starają się przerwać lub blisko i zobaczyć co się dzieje.

Answer 2

Po przeprowadzeniu dochodzenia odkryłem, że klient WCF będzie kontynuował czytanie ze strumienia, dopóki nie zakończy się termin closeTimeout, a następnie przerwie połączenie. Możesz zmniejszyć closeTimeout na kliencie, aby zminimalizować problem.

UWAGA: Powinieneś owinąć kod, który zrzuca strumień do bloku try/catch. Metoda stream.Dispose() będzie generować wyjątek TimeoutException, który hamuje wytyczne not throwing exceptions in Dispose method.

Answer 3

Myślę, że po prostu otrzymujesz bufor po zamknięciu. Powinieneś ustawić maxBufferSize na mniejszą wartość.

Możesz również chcieć ograniczyć ilość danych odczytanych na serwerze, zawijając strumień i przesyłając odczyt. Użyj mniejszych porcji, jeśli masz klienta o niskiej przepustowości i zwróć odpowiednią liczbę z metody odczytu, aby dopasować ją do faktycznie przeczytanej ilości. To ograniczyłoby współczynnik wypełnienia bufora.

Moje własne testy na ten temat wymagały pisania zawsze NeverEndingStream i zwracania danych. W pewnym momencie zadzwoniłem blisko do klienta, a prawie natychmiast zamknięcie zostało wywołane na serwerze. Sugeruje to, że bufor został po prostu opróżniony, ponieważ wyraźnie nie byłby w stanie odczytać mojego strumienia do końca.

Jeśli nadal występują problemy, sugeruję, aby śledzić czas odczytywania metody na przesłoniętym strumieniu. Jeśli currentReadtime - lastReadTime jest> x, możesz zamiast tego wywołać Close i wygenerować wyjątek. To na pewno ją zabije.